ADO 是目前在Windows環(huán)境中比較流行的客戶端數(shù)據(jù)庫編程技術(shù)。ADO是建立在OLE DB底層技術(shù)之上的高級編程接口，因而它兼具有強(qiáng)大的數(shù)據(jù)處理功能（處理各種不同類型的數(shù)據(jù)源、分布式的數(shù)據(jù)處理等等）和極其簡單、易用的編程接口，因而得到了廣泛的應(yīng)用。而且按微軟公司的意圖，OLE DB和ADO將逐步取代 ODBC和DAO。現(xiàn)在介紹ADO各種應(yīng)用的文章和書籍有很多，本文著重站在初學(xué)者的角度，簡要探討一下在VC++中使用ADO編程時的一些問題。我們希望閱讀本文之前，您對ADO技術(shù)的基本原理有一些了解。

　　一、在VC++中使用ADO編程

　　ADO實際上就是由一組Automation對象構(gòu)成的組件，因此可以象使用其它任何Automation對象一樣使用ADO。ADO中最重要的對象有三個：Connection、Command和Recordset，它們分別表示連接對象、命令對象和記錄集對象。如果您熟悉使用MFC中的ODBC類（CDatabase、CRecordset)編程，那么學(xué)習(xí)ADO編程就十分容易了。

　　使用ADO編程時可以采用以下三種方法之一：

　　1、使用預(yù)處理指令#import

#import "C:\Program Files\Common Files\System\ADO\msado15.dll" \ no_namespace rename("EOF", "EndOfFile")

　　但要注意不能放在stdAfx.h文件的開頭，而應(yīng)該放在所有include指令的后面。否則在編譯時會出錯。
程序在編譯過程中，VC++會讀出msado15.dll中的類型庫信息，自動產(chǎn)生兩個該類型庫的頭文件和實現(xiàn)文件msado15.tlh和msado15.tli（在您的Debug或Release目錄下）。在這兩個文件里定義了ADO的所有對象和方法，以及一些枚舉型的常量等。我們的程序只要直接調(diào)用這些方法就行了，與使用MFC中的COleDispatchDriver類調(diào)用Automation對象十分類似。

　　2、使用MFC中的CIDispatchDriver

　　就是通過讀取msado15.dll中的類型庫信息，建立一個COleDispatchDriver類的派生類，然后通過它調(diào)用ADO對象。

　　3、直接用COM提供的API

　　如使用如下代碼：

CLSID clsid; HRESULT hr = ::CLSIDFromProgID(L"ADODB.Connection", &clsid); if(FAILED(hr)) {...} ::CoCreateInstance(clsid, NULL, CLSCTX_SERVER, IID_IDispatch, (void **) &pDispatch); if(FAILED(hr)) {...}

　　以上三種方法，第一和第二種類似，可能第一種好用一些，第三種編程可能最麻煩。但可能第三種方法也是效率最高的，程序的尺寸也最小，并且對ADO的控制能力也最強(qiáng)。

　　據(jù)微軟資料介紹，第一種方法不支持方法調(diào)用中的默認(rèn)參數(shù)，當(dāng)然第二種方法也是這樣，但第三種就不是這樣了。采用第三種方法的水平也最高。當(dāng)你需要繞過ADO而直接調(diào)用OLE DB底層的方法時，就一定要使用第三種方法了。

　　ADO編程的關(guān)鍵，就是熟練地運(yùn)用ADO提供的各種對象(object)、方法(method)、屬性(property)和容器（collection）。另外，如果是在MS SQL或Oracle等大型數(shù)據(jù)庫上編程，還要能熟練使用SQL語言。


　　二、使用#import方法的編程步驟

　　這里建議您使用#import的方法，因為它易學(xué)、易用，代碼也比較簡潔。

　　1、 添加#import指令

　　打開stdafx.h文件，將下列內(nèi)容添加到所有的include指令之后：

#include <icrsint.h> //Include support for VC++ Extensions #import "C:\Program Files\Common Files\System\ADO\msado15.dll" \ no_namespace rename("EOF", "adoEOF")

　　其中icrsint.h文件包含了VC++擴(kuò)展的一些預(yù)處理指令、宏等的定義，用于COM編程時使用。

　　2、定義_ConnectionPtr型變量，并建立數(shù)據(jù)庫連接

　　建立了與數(shù)據(jù)庫服務(wù)器的連接后，才能進(jìn)行其他有關(guān)數(shù)據(jù)庫的訪問和操作。ADO使用Connection對象來建立與數(shù)據(jù)庫服務(wù)器的連接，所以它相當(dāng)于MFC中的CDatabase類。和CDatabase類一樣，調(diào)用Connection對象的Open方法即可建立與服務(wù)器的連接。

　　數(shù)據(jù)類型 _ConnectionPtr實際上就是由類模板_com_ptr_t而得到的一個具體的實例類，其定義可以到msado15.tlh、comdef.h 和comip.h這三個文件中找到。在msado15.tlh中有：

_COM_SMARTPTR_TYPEDEF(_Collection, __uuidof(_Collection));

　　經(jīng)宏擴(kuò)展后就得到了_ConnectionPtr類。_ConnectionPtr類封裝了Connection對象的Idispatch接口指針，及一些必要的操作。我們就是通過這個指針來操縱Connection對象。類似地，后面用到的_CommandPtr和_RecordsetPtr類型也是這樣得到的，它們分別表示命令對象指針和記錄集對象的指針。

　　（1）、連接到MS SQL Server

　　注意連接字符串的格式，提供正確的連接字符串是成功連接到數(shù)據(jù)庫服務(wù)器的第一步，有關(guān)連接字符串的詳細(xì)信息參見微軟MSDN Library光盤。

　　本例連接字符串中的server_name，database_name，user_name和password在編程時都應(yīng)該替換成實際的內(nèi)容。

_ConnectionPtr pMyConnect=NULL; HRESULT hr=pMyConnect.CreateInstance(__uuidof(Connection))); if(FAILED(hr))return; _bstr_t strConnect="Provider=SQLOLEDB; Server=server_name;" "Database=database_name; uid=user_name; pwd=password;"; //connecting to the database server now: try{pMyConnect->Open(strConnect,"","",NULL);} catch (_com_error &e) { ::MessageBox(NULL,e.Description(),"警告",MB_OK │ MB_ICONWARNING); }

　　注意Connection對象的Open方法中的連接字符串參數(shù)必須是BSTR或_bstr_t類型。另外，本例是直接通過OLE DB Provider建立連接，所以無需建立數(shù)據(jù)源。

　　（2）、通過ODBC Driver連接到Database Server連接字符串格式與直接用ODBC編程時的差不多：

_bstr_t strConnect="DSN=datasource_name; Database=database_name; uid=user_name; pwd=password;";

　　此時與ODBC編程一樣，必須先建立數(shù)據(jù)源。

　　3、定義_RecordsetPtr型變量，并打開數(shù)據(jù)集

　　定義_RecordsetPtr型變量，然后通過它調(diào)用Recordset對象的Open方法，即可打開一個數(shù)據(jù)集。所以Recordset對象與MFC中的CRecordset類類似，它也有當(dāng)前記錄、當(dāng)前記錄指針的概念。如：

_RecordsetPtr m_pRecordset; if(!FAILED(m_pRecordset.CreateInstance( __uuidof( Recordset ))) { m_pDoc->m_initialized=FALSE; return; } try{ m_pRecordset->Open(_variant_t("mytable"), _variant_t((IDispatch *)pMyConnect,true), adOpenKeyset, adLockOptimistic, adCmdTable); } catch (_com_error &e) { ::MessageBox(NULL,"無法打開mytable表。","提示", MB_OK │ MB_ICONWARNING); }

　　Recordset對象的Open方法非常重要，它的第一個參數(shù)可以是一個SQL語句、一個表的名字或一個命令對象等等；第二個參數(shù)就是前面建立的連接對象的指針。此外，用Connection和Command對象的Execute方法也能得到記錄集，但是只讀的。


　　4、讀取當(dāng)前記錄的數(shù)據(jù)

　　我認(rèn)為讀取數(shù)據(jù)的最方便的方法如下：

try{ m_pRecordset->MoveFirst(); while(m_pRecordset->adoEOF==VARIANT_FALSE) { //Retrieve column's value: CString sName=(char*)(_bstr_t)(m_pRecordset->Fields->GetItem (_variant_t("name"))->Value); short cAge=(short)(m_pRecordset->Fields->GetItem (_variant_t("age"))->Value); //Do something what you want to do: ...... m_pRecordset->MoveNext(); } }//try catch (_com_error &e) { CString str=(char*)e.Description(); ::MessageBox(NULL,str+"\n又出毛病了。","提示", MB_OK │ MB_ICONWARNING); }

　　本例中的name和age都是字段名，讀取的字段值分別保存在sName和cAge變量內(nèi)。例中的Fields是Recordset對象的容器，GetItem方法返回的是Field對象，而Value則是Field對象的一個屬性（即該字段的值）。通過此例，應(yīng)掌握操縱對象屬性的方法。例如，要獲得Field 對象的Value屬性的值可以直接用屬性名Value來引用它（如上例），但也可以調(diào)用Get方法，例如：

CString sName=(char*)(_bstr_t)(m_pRecordset->Fields->GetItem (_variant_t("name"))->GetValue());

　　從此例還可以看到，判斷是否到達(dá)記錄集的末尾，使用記錄集的adoEOF屬性，其值若為真即到了結(jié)尾，反之則未到。判斷是否到達(dá)記錄集開頭，則可用BOF屬性。

　　另外，讀取數(shù)據(jù)還有一個方法，就是定義一個綁定的類，然后通過綁定的變量得到字段值（詳見后面的介紹）。

　　5、修改數(shù)據(jù)

　　方法一：

try{ m_pRecordset->MoveFirst(); while(m_pRecordset->adoEOF==VARIANT_FALSE) { m_pRecordset->Fields->GetItem (_variant_t("姓名"))->Value=_bstr_t("趙薇"); ...... m_pRecordset->Update(); m_pRecordset->MoveNext(); } }//try

　　改變了Value屬性的值，即改變了字段的值。

　　方法二：

m_pRecordset->Fields->GetItem (_variant_t("姓名"))->PutValue(_bstr_t("趙薇"));

　　方法三：就是用定義綁定類的方法（詳見后面的介紹）。

　　6、添加記錄

　　新記錄添加成功后，即自動成為當(dāng)前記錄。AddNew方法有兩種形式，一個含有參數(shù)，而另一個則不帶參數(shù)。

　　方法一（不帶參數(shù)）：

// Add new record into this table: try{ if(!m_pRecordset->Supports(adAddNew)) return; m_pRecordset->AddNew(); m_pRecordset->Fields->GetItem (_variant_t("姓名"))->Value=_bstr_t("趙薇"); m_pRecordset->Fields->GetItem (_variant_t("性別"))->Value=_bstr_t("女"); m_pRecordset->Fields->GetItem (_variant_t("age"))->Value=_variant_t((short)20); m_pRecordset->Fields->GetItem (_variant_t("marry"))->Value=_bstr_t("未婚"); m_pRecordset->Update(); }//try catch (_com_error &e) { ::MessageBox(NULL, "又出毛病了。","提示",MB_OK │ MB_ICONWARNING); }

　　這種方法弄完了還要調(diào)用Update()。

　　方法二（帶參數(shù)）：

_variant_t varName[4],narValue[4]; varName[0] = L"姓名"; varName[1] = L"性別"; varName[2] = L"age"; varName[3] = L"marry"; narValue[0]=_bstr_t("趙薇"); narValue[1]=_bstr_t("女"); narValue[2]=_variant_t((short)20); narValue[3]=_bstr_t("未婚"); const int nCrit = sizeof varName / sizeof varName[0]; // Create SafeArray Bounds and initialize the array SAFEARRAYBOUND rgsaName[1],rgsaValue[1]; rgsaName[0].lLbound = 0; rgsaName[0].cElements = nCrit; SAFEARRAY *psaName = SafeArrayCreate( VT_VARIANT, 1, rgsaName ); rgsaValue[0].lLbound = 0; rgsaValue[0].cElements = nCrit; SAFEARRAY *psaValue = SafeArrayCreate( VT_VARIANT, 1, rgsaValue ); // Set the values for each element of the array HRESULT hr1=S_OK.hr2=S_OK; for( long i = 0 ; i < nCrit && SUCCEEDED( hr1 ) && SUCCEEDED( hr2 );i++) { hr1=SafeArrayPutElement(psaName, &i,&varName[i]); hr2=SafeArrayPutElement(psaValue, &i,&narValue[i]); } // Initialize and fill the SafeArray VARIANT vsaName,vsaValue; vsaName.vt = VT_VARIANT │ VT_ARRAY; vsaValue.vt = VT_VARIANT │ VT_ARRAY; V_ARRAY(&vsaName) = psaName;//&vsaName->parray=psaName; //see definition in oleauto.h file. V_ARRAY(&vsaValue) = psaValue; // Add a new record: m_pRecordset->AddNew(vsaName,vsaValue);

　　這種方法不需要調(diào)用Update，因為添加后，ADO會自動調(diào)用它。此方法主要是使用SafeArray挺麻煩。

　　方法三：就是用定義綁定類的方法（詳見后面的介紹）。

　7、刪除記錄

　　調(diào)用Recordset的Delete方法就行了，刪除的是當(dāng)前記錄。要了解Delete的其它用法請查閱參考文獻(xiàn)。

try{ m_pRecordset->MoveFirst(); while(m_pRecordset->adoEOF==VARIANT_FALSE) { CString sName=(char*)(_bstr_t)(m_pRecordset->Fields->GetItem (_variant_t("姓名"))->Value); if(::MessageBox(NULL,"姓名="+sName+"\n刪除她嗎？", "提示",MB_YESNO │ MB_ICONWARNING)==IDYES) { m_pRecordset->Delete(adAffectCurrent); m_pRecordset->Update(); } m_pRecordset->MoveNext(); } }//try catch (_com_error &e) { ::MessageBox(NULL,"又出毛病了。","提示",MB_OK │ MB_ICONWARNING); }

　　8、使用帶參數(shù)的命令

　　Command對象所代表的就是一個Provider能夠理解的命令，如SQL語句等。使用Command對象的關(guān)鍵就是把表示命令的語句設(shè)置到CommandText屬性中，然后調(diào)用Command對象的Execute方法就行了。一般情況下在命令中無需使用參數(shù)，但有時使用參數(shù)，可以增加其靈活性和效率。

　　(1). 建立連接、命令對象和記錄集對象

　　本例中表示命令的語句就是一個SQL語句（SELECT語句）。SELECT語句中的問號?就代表參數(shù)，如果要多個參數(shù)，就多放幾個問號，每個問號代表一個參數(shù)。

_ConnectionPtr Conn1; _CommandPtr Cmd1; ParametersPtr *Params1 = NULL; // Not an instance of a smart pointer. _ParameterPtr Param1; _RecordsetPtr Rs1; try { // Create Connection Object (1.5 Version) Conn1.CreateInstance( __uuidof( Connection ) ); Conn1->ConnectionString = bstrConnect; Conn1->Open( bstrEmpty, bstrEmpty, bstrEmpty, -1 ); // Create Command Object Cmd1.CreateInstance( __uuidof( Command ) ); Cmd1->ActiveConnection = Conn1; Cmd1->CommandText = _bstr_t("SELECT * FROM mytable WHERE age< ?"); }//try

　　要注意命令對象必須與連接對象關(guān)聯(lián)起來才能起作用，本例中將命令對象的ActiveConnection屬性設(shè)置為連接對象的指針，即為此目的：

Cmd1->ActiveConnection = Conn1;

　　(2). 創(chuàng)建參數(shù)對象，并給參數(shù)賦值

// Create Parameter Object Param1 = Cmd1->CreateParameter( _bstr_t(bstrEmpty), adInteger, adParamInput, -1, _variant_t( (long) 5) ); Param1->Value = _variant_t( (long) 5 ); Cmd1->Parameters->Append( Param1 );

　　用命令對象的方法來創(chuàng)建一個參數(shù)對象，其中的長度參數(shù)（第三個）如果是固定長度的類型，就填-1，如果是字符串等可變長度的就填其實際長度。Parameters是命令對象的一個容器，它的Append方法就是把創(chuàng)建的參數(shù)對象追加到該容器里。Append進(jìn)去的參數(shù)按先后順序與SQL語句中的問號從左至右一一對應(yīng)。

　　(3). 執(zhí)行命令打開記錄集

// Open Recordset Object Rs1 = Cmd1->Execute( &vtEmpty, &vtEmpty2, adCmdText );

　　但要注意，用Command和Connection對象的Execute方法得到的Recordset是只讀的。因為在打開Recordset之前，我們無法設(shè)置它的LockType屬性（其默認(rèn)值為只讀）。而在打開之后設(shè)置LockType不起作用。

　　我發(fā)現(xiàn)用上述方法得到記錄集Rs1后，不但Rs1中的記錄無法修改，即使直接用SQL語句修改同一表中任何記錄都不行。

　　要想能修改數(shù)據(jù)，還是要用Recordset自己的Open方法才行，如：

try{ m_pRecordset->Open((IDispatch *) Cmd1, vtMissing, adOpenStatic, adLockOptimistic, adCmdUnspecified); } catch (_com_error &e) { ::MessageBox(NULL,"mytable表不存在。","提示",MB_OK │ MB_ICONWARNING); }

　　Recordset對象的Open方法真是太好了，其第一個參數(shù)可以是SQL語句、表名字、命令對象指針等等。

　　9、響應(yīng)ADO的通知事件

　　通知事件就是當(dāng)某個特定事件發(fā)生時，由Provider通知客戶程序，換句話說，就是由Provider調(diào)用客戶程序中的一個特定的方法（即事件的處理函數(shù)）。所以為了響應(yīng)一個事件，最關(guān)鍵的就是要實現(xiàn)事件的處理函數(shù)。

　　(1). 從ConnectionEventsVt接口派生出一個類

　　為了響應(yīng)_Connection的通知事件，應(yīng)該從ConnectionEventsVt接口派生出一個類：

class CConnEvent : public ConnectionEventsVt { private: ULONG m_cRef; public: CConnEvent() { m_cRef = 0; }; ~CConnEvent() {}; STDMETHODIMP QueryInterface(REFIID riid, void ** ppv); STDMETHODIMP_(ULONG) AddRef(void); STDMETHODIMP_(ULONG) Release(void); STDMETHODIMP raw_InfoMessage( struct Error *pError, EventStatusEnum *adStatus, struct _Connection *pConnection); STDMETHODIMP raw_BeginTransComplete( LONG TransactionLevel, struct Error *pError, EventStatusEnum *adStatus, struct _Connection *pConnection); ...... };

　　　(2). 實現(xiàn)每一個事件的處理函數(shù)(凡是帶raw_前綴的方法都把它實現(xiàn)了)：

STDMETHODIMP CConnEvent::raw_InfoMessage( struct Error *pError, EventStatusEnum *adStatus, struct _Connection *pConnection) { *adStatus = adStatusUnwantedEvent; return S_OK; };

　　有些方法雖然你并不需要，但也必須實現(xiàn)它，只需簡單地返回一個S_OK即可。但如果要避免經(jīng)常被調(diào)用，還應(yīng)在其中將adStatus參數(shù)設(shè)置為adStatusUnwantedEvent，則在本次調(diào)用后，以后就不會被調(diào)用了。
另外還必須實現(xiàn)QueryInterface, AddRef, 和Release三個方法:

STDMETHODIMP CConnEvent::QueryInterface(REFIID riid, void ** ppv) { *ppv = NULL; if (riid == __uuidof(IUnknown) ││ riid == __uuidof(ConnectionEventsVt)) *ppv = this; if (*ppv == NULL) return ResultFromScode(E_NOINTERFACE); AddRef(); return NOERROR; } STDMETHODIMP_(ULONG) CConnEvent::AddRef() { return ++m_cRef; }; STDMETHODIMP_(ULONG) CConnEvent::Release() { if (0 != --m_cRef) return m_cRef; delete this; return 0; }

　　(3). 開始響應(yīng)通知事件

// Start using the Connection events IConnectionPointContainer *pCPC = NULL; IConnectionPoint *pCP = NULL; hr = pConn.CreateInstance(__uuidof(Connection)); if (FAILED(hr)) return; hr = pConn->QueryInterface(__uuidof(IConnectionPointContainer), (void **)&pCPC); if (FAILED(hr)) return; hr = pCPC->FindConnectionPoint(__uuidof(ConnectionEvents), &pCP); pCPC->Release(); if (FAILED(hr)) return; pConnEvent = new CConnEvent(); hr = pConnEvent->QueryInterface(__uuidof(IUnknown), (void **) &pUnk); if (FAILED(hr)) return rc; hr = pCP->Advise(pUnk, &dwConnEvt); pCP->Release(); if (FAILED(hr)) return; pConn->Open("dsn=Pubs;", "sa", "", adConnectUnspecified);

　　也就是說在連接(Open)之前就做這些事。

　　(4). 停止響應(yīng)通知事件

pConn->Close(); // Stop using the Connection events hr = pConn->QueryInterface(__uuidof(IConnectionPointContainer), (void **) &pCPC); if (FAILED(hr)) return; hr = pCPC->FindConnectionPoint(__uuidof(ConnectionEvents), &pCP); pCPC->Release(); if (FAILED(hr)) return rc; hr = pCP->Unadvise( dwConnEvt ); pCP->Release(); if (FAILED(hr)) return;

　　在連接關(guān)閉之后做這件事。