概述
對於在WINDOWS上編寫數據庫程序的程序員來說,ActiveX Data Objects (ADO) 是最常使用的技術了,通過ADO可以簡單的實現數據庫的連接以及數據訪問。但 是在VC++中使用ADO時,卻因為是使用COM的方式來調用,常常出現一些系統無法編譯通過,或使用中程序非法出錯的問題,在這裡想大概介紹一下VC++中調用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;// 默認返回值
_ConnectionPtrptrConn; // 定義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, _ConnectionPtrptrConn)
{
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, _ConnectionPtrptrConn);
{
// 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錯誤取得
ErrorPtrpErr = 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 對象取得錯誤編號和錯誤信息。