|
ADO
我用的是ADO,下面的自己写的一个数据库操作类
//AdoConnect.h
class CAdoConnect //创建访问数据库的类,基于ADO访问技术
{
public:
_RecordsetPtr m_pRecordset; //定义一个记录集对象
_ConnectionPtr m_pConnection; //定义一个连接对象
void ExitConnect(); //关闭连接
BOOL ExecuteSQL(_bstr_t bstrSQL);//执行参数指定的SQL语句
_RecordsetPtr& GetRecordSet(_bstr_t bstrSQL);//执行参数指定的SQL语句,并返回一个记录集的指针
BOOL OnInitDBConnect(); //初始化数据库连接
CAdoConnect(); //构造函数
virtual ~CAdoConnect(); //析构函数
};
//AdoConnect.cpp
CAdoConnect::CAdoConnect()
{
}
CAdoConnect::~CAdoConnect()
{
}
BOOL CAdoConnect::OnInitDBConnect() //该方法用于连接到数据库,成功连接时返回true,失败时返回false
{
::CoInitialize(NULL); //初始化OLE/COM环境
HRESULT hr;
try
{
hr = m_pConnection.CreateInstance("ADODB.Connection"); //创建Connection对象
if(SUCCEEDED(hr))
{
_bstr_t strConnect;
strConnect="Provider=Microsoft.Jet.OLEDB.4.0;Data Source=Hotel.mdb;Persist Security Info=False;Jet OLEDB:Database Password=1234";
m_pConnection->ConnectionTimeout =30; //设置超时时间为5秒
hr = m_pConnection->Open(strConnect,"","",adModeUnknown);
}
}
catch(_com_error e) //捕捉异常
{
CString errormessage;
errormessage.Format("连接数据库失败!\r\n错误信息:%s",e.ErrorMessage());
AfxMessageBox(errormessage);
return false;
}
return true;
}
_RecordsetPtr& CAdoConnect::GetRecordSet(_bstr_t bstrSQL)//从数据库中获得记录
{
try
{
if(m_pConnection==NULL) //连接数据库,如果Connection对象为空,则重新连接数据库
OnInitDBConnect();
m_pRecordset.CreateInstance("ADODB.Recordset");
m_pRecordset->Open(bstrSQL,_variant_t((IDispatch *)m_pConnection,true),adOpenDynamic,adLockOptimistic,adCmdText); //取得表中的记录
}
catch(_com_error e) //捕捉异常
{
CString errormessage;
errormessage.Format("获取数据库记录失败!\r\n错误信息:%s",e.ErrorMessage());
AfxMessageBox(errormessage);
}
return m_pRecordset; //返回结果集
}
BOOL CAdoConnect::ExecuteSQL(_bstr_t bstrSQL)//执行参数bstrSQL所指定的SQL语句
{
_variant_t RecordsAffected;
try
{
if(m_pConnection==NULL)
OnInitDBConnect();
m_pConnection->Execute(bstrSQL,&RecordsAffected,adCmdText);
return true;
}
catch(_com_error e)
{
CString errormessage;
errormessage.Format("执行语句失败!\r\n错误信息:%s",e.ErrorMessage());
AfxMessageBox(errormessage);
return false;
}
}
void CAdoConnect::ExitConnect()//断开与数据库的连接
{
if(m_pRecordset!=NULL) //关闭记录集
m_pRecordset->Close();
if(m_pConnection->State) //关闭连接
m_pConnection->Close();
::CoUninitialize(); //释放环境
} |
评分
-
1
查看全部评分
-
|