ADO接口簡介

源地址：http://blog.csdn.net/xiaobai1593/article/details/7449151

參考：

1. 百度文庫：http://wenku.baidu.com/view/8e2e99ecf8c75fbfc77db230.html

2. CSDN：http://blog.csdn.net/augusdi/article/details/7005597

接口概述：

ADO庫包含三個基本接口：_ConnectionPtr接口、_CommandPtr接口和_RecordsetPtr接口。

(1) _ConnectionPtr接口返回一個記錄集或一個空指針

通常使用它來創建一個數據連接 或 執行一條不返回任何結果的SQL語句，如一個存儲過程。

（使用_ConnectionPtr接口返回一個記錄集不是一個好的使用方法）

通常同Cdatabase一樣，使用它創建一個數據連接，然后使用其它對象執行數據輸入輸出操作。

(2) _CommandPtr接口返回一個記錄集

它提供了一種簡單的方法來執行返回記錄集的存儲過程和SQL語句。

在使用_CommandPtr接口時，你可以利用全局_ConnectionPtr接口，也可以在_CommandPtr接口里直接使用連接串。

如果你只執行一次或幾次數據訪問操作，后者是比較好的選擇。

但如果你要頻繁訪問數據庫，并要返回很多記錄集，那么，你應該使用全局_ConnectionPtr接口創建一個數據連接，

然后使用_CommandPtr接口執行存儲過程和SQL語句。

(3) _RecordsetPtr是一個記錄集對象

與以上兩種對象相比，它對記錄集提供了更多的控制功能，如記錄鎖定，游標控制等。

同_CommandPtr接口一樣，它不一定要使用一個已經創建的數據連接，

可以用一個連接串代替連接指針賦給_RecordsetPtr的connection成員變量，讓它自己創建數據連接。

如果你要使用多個記錄集，最好的方法是同Command對象一樣使用已經創建了數據連接的全局_ConnectionPtr接口，然后使用_RecordsetPtr執行存儲過程和SQL語句。

使用步驟：

?

1> 引入ADO類

#import "c:\program files\common files\system\ado\msado15.dll"? no_namespace rename ("EOF", "adoEOF")

其作用同我們熟悉的#include類似，編譯的時候系統會為我們生成 msado15.tlh、ado15.tli 兩個C++頭文件來定義ADO庫。

在 #import "" 引入ADO之后就可以用3個智能指針了:_ConnectionPtr、_RecordsetPtr和_CommandPtr

2> 初始化COM庫，引入ADO庫定義文件

?

在MFC中可以用? AfxOleInit();

非MFC環境中用? CoInitialize(NULL);/ CoUnInitialize();

3> 用Connection對象連接數據庫

首先我們需要添加一個指向Connection對象的指針：

_ConnectionPtr?m_pConnection;??
HRESULT?hr?=?m_pConnection.CreateInstance("ADODB.Connection");//創建Connection對象??
if(SUCCEEDED(hr))??
{??
????try??
????{??
????????hr?=?m_pConnection->Open("Provider=Microsoft.Jet.OLEDB.4.0;Data?Source=test.mdb","","",adModeUnknown);//連接數據庫??
????}??
????//COM錯誤取得,當執行COM功能的時候，如果出錯，可以捕捉到_com_error的異常??
????catch?(_com_error?e)???
????{????
????}??
}??

在這段代碼中我們是通過Connection對象的Open() 方法來進行連接數據庫的，下面是該方法的原型：

HRESULT Connection::Open (_bstr_t ConnectionString, _bstr_t UserID, _bstr_t Password, long Options )

參數：

ConnectionString 為連接字串,

UserID??? 是用戶名,

Password? 是登陸密碼,

Options??? 是連接選項,用于指定Connection對象對數據的更新許可權,?

Options可以是如下幾個常量：

??? adModeUnknown:? 缺省。當前的許可權未設置
??? adModeRead:??? 只讀
??? adModeWrite:? 只寫
??? adModeReadWrite:? 可以讀寫
??? adModeShareDenyRead: 阻止其它Connection對象以讀權限打開連接
??? adModeShareDenyWrite: 阻止其它Connection對象以寫權限打開連接
??? adModeShareExclusive: 阻止其它Connection對象打開連接
??? adModeShareDenyNone: 允許其它程序或對象以任何權限建立連接

補充：常用的數據庫連接方法：

(1) 通過JET數據庫引擎對ACCESS2000數據庫的連接

m_pConnection->Open("Provider=Microsoft.Jet.OLEDB.4.0;Data Source=C:\\test.mdb","","",adModeUnknown);

(2) 通過DSN數據源對任何支持ODBC的數據庫進行連接

m_pConnection->Open("Data Source=adotest;UID=sa;PWD=;","","",adModeUnknown);

//m_pConnection->Open("DSN=test;","","",0);? //連接叫作test的ODBC數據源\

(3) 不通過DSN對SQL SERVER數據庫進行連接：?

m_pConnection->Open("driver={SQL Server};Server=127.0.0.1;DATABASE=vckbase;UID=sa;PWD=13Array","","",adModeUnknown);

其中Server是SQL服務器的名稱，DATABASE是庫的名稱

Connection對象中兩個有用的屬性：ConnectionTimeOut與State

其中：ConnectionTimeOut用來設置連接的超時時間，需要在Open之前調用，例如:???

//設置超時時間為5秒??
m_pConnection->ConnectionTimeout?=?5;???
m_pConnection->Open("Data?Source=adotest;","","",adModeUnknown);??

??????????? State屬性指明當前Connection對象的狀態，0表示關閉，1表示已經打開，我們可以通過讀取這個屬性來作相應的處理，例如:

//如果已經打開了連接則關閉它??
if(m_pConnection->State)??
{??
?????m_pConnection->Close();??
}???

?

4> 利用建立好的連接，通過Connection、Command對象執行SQL命令，或利用Recordset對象取得結果記 錄集進行查詢、處理

?

SQL命令的執行可以采用多種形式，下面我們一進行闡述。

(1) ?利用Connection對象的Execute方法執行SQL命令

Execute方法的原型如下所示：

_RecordsetPtr Connection::Execute (_bstr_t CommandText, VARIANT * RecordsAffected, long Options )

參數：

CommandText? 是命令字串，通常是SQL命令；
RecordsAffected? 是操作完成后所影響的行數；
Options??? 表示CommandText中內容的類型，Options可以取如下值之一：
????? adCmdText：表明CommandText是文本命令
????? adCmdTable：表明CommandText是一個表名
????? adCmdProc：表明CommandText是一個存儲過程
????? adCmdUnknown：缺省。當前的許可權未設置

Execute執行完后返回一個指向記錄集的指針_RecordsetPtr，下面我們給出具體代碼并作說明。??

try??
{??
????_variant_t?ra;??
??
????m_pRecordset?=?m_pConnection->Execute("SELECT?COUNT(*)?FROM?學生信息",?&ra,?adCmdText);???
?????//取得第一個字段的值放入vCount變量??
????_variant_t?vCount?=?m_pRecordset->GetCollect((_variant_t)(long)(0));??
??
????m_pRecordset->Close();???
??????
????CString?message;??
????message.Format("共有%d條記錄",vCount.lVal);??
????AfxMessageBox(message);????
}??
??
catch?(_com_error?e)???
{?...}??

(2)利用 Command對象來執行SQL命令

?

try??
{?????
????_CommandPtr?m_pCommand;???
????m_pCommand.CreateInstance("ADODB.Command");??
????
????//關鍵的一句，將建立的連接賦值給它??
????m_pCommand->ActiveConnection?=?m_pConnection;???
????m_pCommand->CommandText="SELECT?COUNT(*)?FROM?userInfo";??
????//執行文本命令??
????m_pRecordset=m_pCommand->Execute(NULL,?NULL,?adCmdText);??
??
????_variant_t?vCount?=?m_pRecordset->GetCollect((_variant_t)(long)0);?//取得第一個字段的值??
????
????CString?str;??
????str.Format("共有%d條記錄",vCount.lVal);??
????AfxMessageBox(str);????
??
????m_pRecordset->Close();???
}??
catch?(_com_error?e)?{...}??

在這段代碼中我們只是用Command對象來執行了SELECT查詢語句，Command對象在進行存儲過程的調用中能真正體現它的作用。下次我們將詳細介紹。

(3) 直接用Recordset對象進行查詢取得記錄集?

? m_pRecordset->Open("SELECT * FROM 學生信息",_variant_t((IDispatch *)m_pConnection,true),adOpenStatic,adLockOptimistic,adCmdText);

Open方法的原型是這樣的：

HRESULT Recordset15::Open ( const _variant_t & Source, const _variant_t & ActiveConnection, enum CursorTypeEnum CursorType, enum LockTypeEnum LockType, long Options )

參數：

1> Source是數據查詢字符串

2> ActiveConnection是已經建立好的連接（我們需要用Connection對象指針來構造一個_variant_t對象)

3> CursorType光標類型，它可以是以下值之一，請看這個枚舉結構：
? enum CursorTypeEnum
? {
??? adOpenUnspecified = -1, //不作特別指定
??? adOpenForwardOnly = 0, //前滾靜態光標。這種光標只能向前瀏覽記錄集，比如用MoveNext向前滾動,這種方式可以提高瀏覽速度。但諸如BookMark,RecordCount,AbsolutePosition,AbsolutePage都不能使用
??? adOpenKeyset = 1,? //采用這種光標的記錄集看不到其它用戶的新增、刪除操作，但對于更新原有記錄的操作對你是可見的。
??? adOpenDynamic = 2,? //動態光標。所有數據庫的操作都會立即在各用戶記錄集上反應出來。
??? adOpenStatic = 3? //靜態光標。它為你的記錄集產生一個靜態備份，但其它用戶的新增、刪除、更新操作對你的記錄集來說是不可見的。
? };
4> LockType鎖定類型，它可以是以下值之一，請看如下枚舉結構：
? enum LockTypeEnum
? {
??? adLockUnspecified = -1,? //未指定
??? adLockReadOnly = 1,? //只讀記錄集
??? adLockPessimistic = 2,? //悲觀鎖定方式。數據在更新時鎖定其它所有動作，這是最安全的鎖定機制
??? adLockOptimistic = 3,? //樂觀鎖定方式。只有在你調用Update方法時才鎖定記錄。在此之前仍然可以做數據的更新、插入、刪除等動作
??? adLockBatchOptimistic = 4， //樂觀分批更新。編輯時記錄不會鎖定，更改、插入及刪除是在批處理模式下完成。
? };

?

5> 使用完畢后關閉連接，釋放對象。

?

(3) 執行SQL命令并取得結果記錄集

為了取得結果記錄集，我們定義一個指向Recordset對象的指針：?_RecordsetPtr ?m_pRecordset;

1. m_pRecordset.CreateInstance("ADODB.Recordset");

?

(4) 記錄集的遍歷、更新

根據我們剛才通過執行SQL命令建立好的 學生信息 表，它包含四個字段:學號，姓名，年齡，生日

以下的代碼實現：打開記錄集，遍歷所有記錄，刪除第一條記錄，添加三條記錄，移動光標到第二條記錄，更改其年齡，保存到數據庫。

try??
{??
????_variant_t?vUsername,vBirthday,vID,vOld;??
????_RecordsetPtr?m_pRecordset;??
??????
????m_pRecordset.CreateInstance("ADODB.Recordset");??
??????
????m_pRecordset->Open("SELECT?*?FROM?學生信息",_variant_t((IDispatch*)m_pConnection,true),adOpenStatic,adLockOptimistic,adCmdText);??
??
????while(!m_pRecordset->adoEOF)???
????{??
????????//取得第1列的值,從0開始計數，也可以直接給出列的名稱，如下一行??
????????vID?=?m_pRecordset->GetCollect(_variant_t((long)0));??
????????//取得姓名字段的值??
????????vUsername?=?m_pRecordset->GetCollect("姓名");??
????????vOld?=?m_pRecordset->GetCollect("年齡");??
????????vBirthday?=?m_pRecordset->GetCollect("生日");??
????
????????//在DEBUG方式下的OUTPUT窗口輸出記錄集中的記錄??
????????TRACE("id:%d,姓名:%s,年齡:%d,生日:%s\r\n",?vID.lVal,?(LPCTSTR)(_bstr_t)vUsername,?vOld.lVal,?(LPCTSTR)(_bstr_t)vBirthday);????
??
????????//移到下一條記錄??
????????m_pRecordset->MoveNext();??????
????}??
????
????//移到首條記錄??
????m_pRecordset->MoveFirst();??????
????//刪除當前記錄??
????m_pRecordset->Delete(adAffectCurrent);??????
????
????//添加三條新記錄并賦值??
????for(int?i=0;?i<3;?i++)??????
????{??
????????m_pRecordset->AddNew();????//添加新記錄??
????????m_pRecordset->PutCollect("學號",_variant_t((long)(i+10)));??
????????m_pRecordset->PutCollect("姓名",_variant_t("王斌年"));??
????????m_pRecordset->PutCollect("年齡",_variant_t((long)21));??
????????m_pRecordset->PutCollect("生日",_variant_t("1Array30-3-15"));??
????}??
????
????//從第一條記錄往下移動一條記錄,即移動到第二條記錄處??
????m_pRecordset->Move(1,_variant_t((long)adBookmarkFirst));??????
????m_pRecordset->PutCollect(_variant_t("年齡"),_variant_t((long)45));????//修改其年齡??
????m_pRecordset->Update();????//保存到庫中??
????
}???
catch?(_com_error?e)??
{}??

(5) 關閉記錄集與連接

記錄集或連接都可以用Close()方法來關閉

m_pRecordset->Close(); //關閉記錄集?

m_pConnection->Close(); //關閉連接

?(6) 錯誤的獲取

在stdafx.h中進行宏定義:

#if?!defined?CATCH_ERROR??
#define?CATCH_ERROR??
{??
????CString?strComError;??
????strComError.Format("錯誤編號:?%08lx\n錯誤信息:?%s\n錯誤源:?%s\n錯誤描述:?%s",??e.Error(),?e.ErrorMessage(),?(LPCSTR)?e.Source(),?(LPCSTR)?e.Description());??
????::MessageBox(NULL,strComError,"錯誤",MB_ICONEXCLAMATION);???
}??
#endif??

使用方法：
try
{? ...}
catch?(_com_error e)
{
CATCH_ERROR;
}