对于在WINDOWS上编写数据库程序的程序员来说，ActiveX Data Objects （ADO） 是最常使用的技术了，通过ADO可以简单的实现数据库的连接以及数据访问。但是在VC++中使用ADO时，却因为是使用COM的方式来调用，常常出现一些系统无法编译通过，或使用中程序非法出错的问题，在这里想大概介绍一下ＶＣ＋＋中调用ADO的常用方法。
1、 用import导入ADO 的 COM 文件msado15.dll
例如：
|
#import "C:\Program Files\Common Files\System\ADO\msado15.dll"\
no_namespace |
2、COM 使用时初始化
|
HRESULT ComInit()
{
HRESULT hr = S_OK; // 默认返回值
if FAILED(CoInitialize(NULL)) // COM 初始化调用
{
CoUninitialize();
hr = E_UNEXPECTED;
}
return hr;
} |
3、建立数据库连接
|
HRESULT ConnectToDB( LPSTR pUserId , // 用户名
LPSTR pConnString, // 连接字串
LPSTR pUserPassword , // 用户密码
ConnectOptionEnum ConnectOption ) // 连接参数
{
HRESULT hr = S_OK; // 默认返回值
_ConnectionPtr ptrConn; // 定义Connection对象
try
{
// 创建一个连接实体
hr = ptrConn.CreateInstance( __uuidof(Connection) );
// 设定连接等待的最大秒数，默认是15秒
ptrConn->ConnectionTimeout = 20
// 打开连接
hr = ptrConn->Open( pConnString, pUserId, pUserPassword, ConnectOption );
return hr;
}
catch( _com_error & pComError )
{
…… // 错误处理
return E_UNEXPECTED;
}
} |
4.执行一个SQL 查询，得到数据集（recordset）
|
_RecordsetPtr GetRecordSet( LPSTR strSql, _ConnectionPtr ptrConn )
{
try
{
RecordsetPtr ptrRS； // recordset 对象
// 创建recordset 对象实体
ptrRS.CreateInstance( __uuidof(Recordset) );
ptrRS->Open( strSql, ptrConn.GetInterfacePtr(), adOpenForwardOnly,
adLockUnspecified, adCmdText );
或者
ptrRS = ptrConn ->Execute( m_ strSql,NULL, adCmdText );
return ptrRS;
}
catch( _com_error & a_pComError )
{
….// 错误处理
return NULL;
}
} |
5.通过数据集（recordset）得到列的名称
|
HRESULT GetColumnNames( _RecordsetPtr ptrRs, // recordset 对象
char strColNames[][255],
DataTypeEnum iColTypes[] )
{
try
{ // 参数变量
_variant_t l_vaIndex;
l_vaIndex.vt = VT_I2;
// COLUMNS总数
long lColCount;
lColCount = ptrRs ->Fields->Count;
// 循环取得列的属性和名称
for( int iIndex = 0 ; iIndex < lColCount; iIndex++ )
{
l_vaIndex.iVal = iIndex; // 设置循环索引
// 取得字段名称
sprintf(strColNames[iIndex], "%s", (LPSTR)ptrRs ->Fields->GetItem(l_vaIndex)->Name);
// 取得字段属性
iColTypes = ptrRs ->Fields->GetItem(l_vaIndex)->Type;
}
}
return S_OK; // 编辑者：此处不明何解？？？
}
catch( _com_error & a_pComError )
{
…. // 错误处理
return E_UNEXPECTED;
}
catch(...)
{
…. // 错误处理
return E_UNEXPECTED;
}
} |
6.通过数据集（recordset）得到当前行记录
|
HRESULT getOneRecord( _RecordsetPtr ptrRs,
const long lNoOfColumns,
_variant_t varValue[] )
{
try
{
// 参数变量
_variant_t l_vaIndex;
l_vaIndex.vt = VT_I2;
// 循环取得列的值
for( long lIndex = 0; lIndex < lNoOfColumns; lIndex++ )
{
l_vaIndex.iVal = lIndex;
// 取得字段值
varValue[lIndex] = ptrRs->Fields->GetItem(l_vaIndex)->Value;
}
return S_OK;
}
catch( _com_error & a_pComError )
{
…. // 错误处理
return E_UNEXPECTED;
}
catch(...)
{
…. // 错误处理
return E_UNEXPECTED;
}
} |
7.出错情况下错误信息的取得
|
void ErrorFunc( _com_error &pComError, _ConnectionPtr ptrConn );
{
// COM 错误取得
// 当执行COM功能的时候，如果出错，可以捕捉到_com_error的异常
char lpComErrorStr512];
sprintf( lpComErrorStr512,
"ErrorCode = %08lx \ Error Message = %s \ Source = %s \ Description = %s ",
pComError.Error(), // 错误编号
pComError.ErrorMessage(), // 错误信息
(LPCSTR) pComError.Source(), // 错误源
(LPCSTR) pComError.Description() ); // 错误描述
// 通过上面的代码我们可以看出，_com_error对象中可以得到COM所有出错的信息
// ADO错误取得
ErrorPtr pErr = NULL;
if( (ptrConn ->Errors->Count) > 0)
{
long nCount = ptrConn ->Errors->Count;
for( long i = 0; i < nCount; i++ )
{
pErr = a_pConnPtr->Errors->GetItem(i);
char l_pchErrorString[512];
sprintf( l_pchErrorString,"Error:\n Error number: %x\t%s",
pErr->Number, // 错误编号
pErr->Description ); // 错误描述
}
}
// ADO 处理出错的情况下, 在connection对象里面都有记录，可以通过访问
// connection 对象取得错误编号和错误信息。 |
