作者:l4nk0r
时间:2010-1-22
功能:基于ADO
数据库类实现
1.首先在stdafx.h文件添加如下代码:
// 导入ADO的动态链接库
#import "c:Program FilesCommon FilesSystemadomsado15.dll" no_namespace rename("EOF","adoEOF") rename("BOF","adoBOF")
2.实现ADOConn.h类定义
class ADOConn
{
public:
ADOConn();
virtual ~ADOConn();
_ConnectionPtr m_pConnection;
_RecordsetPtr m_pRecordset;
_RecordsetPtr m_pSubRecord;
_variant_t b;
_variant_t c;
public:
// 初始化―连接
数据库
void OnInitADOConn();
// 执行查询
_RecordsetPtr& GetRecordSet(_bstr_t bstrSQL);
// 执行SQL语句，Insert Update _variant_t
BOOL ExecuteSQL(_bstr_t bstrSQL);
void ExitConnect();
};
3.类的实现文件ADOConn.cpp
#include "stdafx.h"
#include "ADOConn.h"
#ifdef _DEBUG
#undef THIS_FILE
static char THIS_FILE[]=__FILE__;
#define new DEBUG_NEW
#endif
ADOConn::ADOConn()
{
}
ADOConn::~ADOConn()
{
}
// 初始化数据库连接
void ADOConn::OnInitADOConn()
{
::CoInitialize(NULL);
try
{
// 创建实例
m_pConnection.CreateInstance("ADODB.Connection");
// 这里我写的是针对Access数据库的连接字符串,请相应修改
_bstr_t strConnect = "Provider=Microsoft.Jet.OLEDB.4.0;Data Source=point.mdb;Mode=ReadWrite;Persist Security Info=False";
// 打开数据库
m_pConnection->Open(strConnect,"","",adModeUnknown);
}
// 异常捕获
catch(_com_error e)
{
AfxMessageBox(e.Description());
}
}
// 获取记录集
_RecordsetPtr& ADOConn::GetRecordSet(_bstr_t bstrSQL)
{
try
{
if(m_pConnection==NULL)
OnInitADOConn();
m_pRecordset.CreateInstance(__uuidof(Recordset));
// 执行sql语句得到记录集
m_pRecordset->Open(bstrSQL,m_pConnection.GetInterfacePtr(),adOpenDynamic,adLockOptimistic,adCmdText);
}
catch(_com_error e)
{
AfxMessageBox(e.Description());
}
return m_pRecordset;
}
// 执行任意SQL语句
BOOL ADOConn::ExecuteSQL(_bstr_t bstrSQL)
{
try
{
if(m_pConnection == NULL)
OnInitADOConn();
m_pConnection->Execute(bstrSQL,NULL,adCmdText);
return true;
}
catch(_com_error e)
{
AfxMessageBox(e.Description());
return false;
}
}
// 关闭数据库连接
void ADOConn::ExitConnect()
{
if (m_pRecordset != NULL)
m_pRecordset->Close();
m_pConnection->Close();
::CoUninitialize();
}