ADO-2
?
VC開發數據庫基礎之ADO篇
?
一、ADO簡介
ADO(ActiveX Data Object)是Microsoft數據庫應用程序開發的新接口，是建立在OLE DB之上的高層數據庫訪問技術，請不必為此擔心，即使你對OLE DB，COM不了解也能輕松對付ADO,因為它非常簡單易用，甚至比你以往所接觸的ODBC API、DAO、RDO都要容易使用，并不失靈活性。本文將詳細地介紹在VC下如何使用ADO來進行數據庫應用程序開發，并給出示例代碼。
本文示例代碼
二、基本流程
萬事開頭難，任何一種新技術對于初學者來說最重要的還是“入門”，掌握其要點。讓我們來看看ADO數據庫開發的基本流程吧！
(1)初始化COM庫，引入ADO庫定義文件
(2)用Connection對象連接數據庫
(3)利用建立好的連接，通過Connection、Command對象執行SQL命令，或利用Recordset對象取得結果記錄集進行查詢、處理。
(4)使用完畢后關閉連接釋放對象。
準備工作:
為了大家都能測試本文提供的例子，我們采用Access數據庫，您也可以直接在我們提供的示例代碼中找到這個test.mdb。
下面我們將詳細介紹上述步驟并給出相關代碼。
【1】COM庫的初始化
我們可以使用AfxOleInit()來初始化COM庫，這項工作通常在CWinApp::InitInstance()的重載函數中完成，請看如下代碼:
BOOL CADOTest1App::InitInstance()
{
AfxOleInit();
......
【2】用#import指令引入ADO類型庫
我們在stdafx.h中加入如下語句：(stdafx.h這個文件哪里可以找到?你可以在FileView中的Header Files里找到)
#import "c:/program files/common files/system/ado/msado15.dll" no_namespace rename("EOF","adoEOF")
這一語句有何作用呢？其最終作用同我們熟悉的#include類似,編譯的時候系統會為我們生成msado15.tlh,ado15.tli兩個C++頭文件來定義ADO庫。
幾點說明:
(1) 您的環境中msado15.dll不一定在這個目錄下，請按實際情況修改
(2) 在編譯的時候肯能會出現如下警告，對此微軟在MSDN中作了說明，并建議我們不要理會這個警告。
msado15.tlh(405) : warning C4146: unary minus operator applied to unsigned type, result still unsigned
【3】創建Connection對象并連接數據庫
首先我們需要添加一個指向Connection對象的指針:
_ConnectionPtr m_pConnection;
下面的代碼演示了如何創建Connection對象實例及如何連接數據庫并進行異常捕捉。
BOOL CADOTest1Dlg::OnInitDialog()
{
CDialog::OnInitDialog();
HRESULT hr;
try
{
hr = m_pConnection.CreateInstance("ADODB.Connection");///創建Connection對象
if(SUCCEEDED(hr))
{
hr = m_pConnection->Open("Provider=Microsoft.Jet.OLEDB.4.0;Data Source=test.mdb","","",adModeUnknown);///連接數據庫
///上面一句中連接字串中的Provider是針對ACCESS2000環境的，對于ACCESS97,需要改為:Provider=Microsoft.Jet.OLEDB.3.51; }
}
catch(_com_error e)///捕捉異常
{
CString errormessage;
errormessage.Format("連接數據庫失敗!/r/n錯誤信息:%s",e.ErrorMessage());
AfxMessageBox(errormessage);///顯示錯誤信息
}
在這段代碼中我們是通過Connection對象的Open方法來進行連接數據庫的，下面是該方法的原型
HRESULT Connection15::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);
(3)不通過DSN對SQL SERVER數據庫進行連接： m_pConnection->Open("driver={SQL Server};Server=127.0.0.1;DATABASE=vckbase;UID=sa;PWD=139","","",adModeUnknown);
其中Server是SQL服務器的名稱，DATABASE是庫的名稱
Connection對象除Open方法外還有許多方法，我們先介紹Connection對象中兩個有用的屬性ConnectionTimeOut與State
ConnectionTimeOut用來設置連接的超時時間，需要在Open之前調用，例如: m_pConnection->ConnectionTimeout = 5;///設置超時時間為5秒
m_pConnection->Open("Data Source=adotest;","","",adModeUnknown);
State屬性指明當前Connection對象的狀態，0表示關閉，1表示已經打開，我們可以通過讀取這個屬性來作相應的處理，例如:
if(m_pConnection->State)
m_pConnection->Close(); ///如果已經打開了連接則關閉它
【4】執行SQL命令并取得結果記錄集
為了取得結果記錄集，我們定義一個指向Recordset對象的指針:_RecordsetPtr m_pRecordset;
并為其創建Recordset對象的實例: m_pRecordset.CreateInstance("ADODB.Recordset");
SQL命令的執行可以采用多種形式，下面我們一進行闡述。
(1)利用Connection對象的Execute方法執行SQL命令
Execute方法的原型如下所示:
_RecordsetPtr Connection15::Execute ( _bstr_t CommandText, VARIANT * RecordsAffected, long Options ) 其中CommandText是命令字串，通常是SQL命令。參數RecordsAffected是操作完成后所影響的行數, 參數Options表示CommandText中內容的類型，Options可以取如下值之一：
adCmdText:表明CommandText是文本命令
adCmdTable:表明CommandText是一個表名
adCmdProc:表明CommandText是一個存儲過程
adCmdUnknown:未知
Execute執行完后返回一個指向記錄集的指針，下面我們給出具體代碼并作說明。 _variant_t RecordsAffected;
///執行SQL命令：CREATE TABLE創建表格users,users包含四個字段:整形ID,字符串username,整形old,日期型birthday
m_pConnection->Execute("CREATE TABLE users(ID INTEGER,username TEXT,old INTEGER,birthday DATETIME)",&RecordsAffected,adCmdText);
///往表格里面添加記錄
m_pConnection->Execute("INSERT INTO users(ID,username,old,birthday) valueS (1, ''''''''Washington'''''''',25,''''''''1970/1/1'''''''')",&RecordsAffected,adCmdText);
///將所有記錄old字段的值加一
m_pConnection->Execute("UPDATE users SET old = old+1",&RecordsAffected,adCmdText);
///執行SQL統計命令得到包含記錄條數的記錄集
m_pRecordset = m_pConnection->Execute("SELECT COUNT(*) FROM users",&RecordsAffected,adCmdText);
_variant_t vIndex = (long)0;
_variant_t vCount = m_pRecordset->GetCollect(vIndex);///取得第一個字段的值放入vCount變量
m_pRecordset->Close();///關閉記錄集
CString message;
message.Format("共有%d條記錄",vCount.lVal);
AfxMessageBox(message);///顯示當前記錄條數
(2)利用Command對象來執行SQL命令
_CommandPtr m_pCommand;
m_pCommand.CreateInstance("ADODB.Command");
_variant_t vNULL;
vNULL.vt = VT_ERROR;
vNULL.scode = DISP_E_PARAMNOTFOUND;///定義為無參數
m_pCommand->ActiveConnection = m_pConnection;///非常關鍵的一句，將建立的連接賦值給它
m_pCommand->CommandText = "SELECT * FROM users";///命令字串
m_pRecordset = m_pCommand->Execute(&vNULL,&vNULL,adCmdText);///執行命令，取得記錄集
在這段代碼中我們只是用Command對象來執行了SELECT查詢語句，Command對象在進行存儲過程的調用中能真正體現它的作用。下次我們將詳細介紹。
(3)直接用Recordset對象進行查詢取得記錄集
例如
m_pRecordset->Open("SELECT * FROM users",_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 )
其中：
①Source是數據查詢字符串
②ActiveConnection是已經建立好的連接（我們需要用Connection對象指針來構造一個_variant_t對象)
③CursorType光標類型，它可以是以下值之一,請看這個枚舉結構:
enum CursorTypeEnum
{
adOpenUnspecified = -1,///不作特別指定
adOpenForwardOnly = 0,///前滾靜態光標。這種光標只能向前瀏覽記錄集，比如用MoveNext向前滾動,這種方式可以提高瀏覽速度。但諸如BookMark,RecordCount,AbsolutePosition,AbsolutePage都不能使用
adOpenKeyset = 1,///采用這種光標的記錄集看不到其它用戶的新增、刪除操作，但對于更新原有記錄的操作對你是可見的。
adOpenDynamic = 2,///動態光標。所有數據庫的操作都會立即在各用戶記錄集上反應出來。
adOpenStatic = 3///靜態光標。它為你的記錄集產生一個靜態備份，但其它用戶的新增、刪除、更新操作對你的記錄集來說是不可見的。
};
④LockType鎖定類型，它可以是以下值之一，請看如下枚舉結構：
enum LockTypeEnum
{
adLockUnspecified = -1,///未指定
adLockReadOnly = 1,///只讀記錄集
adLockPessimistic = 2,悲觀鎖定方式。數據在更新時鎖定其它所有動作，這是最安全的鎖定機制
adLockOptimistic = 3,樂觀鎖定方式。只有在你調用Update方法時才鎖定記錄。在此之前仍然可以做數據的更新、插入、刪除等動作
adLockBatchOptimistic = 4，樂觀分批更新。編輯時記錄不會鎖定，更改、插入及刪除是在批處理模式下完成。
};
⑤Options請參考本文中對Connection對象的Execute方法的介紹
【5】記錄集的遍歷、更新
根據我們剛才通過執行SQL命令建立好的users表，它包含四個字段:ID,username,old,birthday
以下的代碼實現：打開記錄集，遍歷所有記錄，刪除第一條記錄，添加三條記錄，移動光標到第二條記錄，更改其年齡，保存到數據庫。
_variant_t vUsername,vBirthday,vID,vOld;
_RecordsetPtr m_pRecordset;
m_pRecordset.CreateInstance("ADODB.Recordset");
m_pRecordset->Open("SELECT * FROM users",_variant_t((IDispatch*)m_pConnection,true),adOpenStatic,adLockOptimistic,adCmdText);
while(!m_pRecordset->adoEOF)///這里為什么是adoEOF而不是EOF呢?還記得rename("EOF","adoEOF")這一句嗎?
{
vID = m_pRecordset->GetCollect(_variant_t((long)0));///取得第1列的值,從0開始計數，你也可以直接給出列的名稱，如下一行
vUsername = m_pRecordset->GetCollect("username");///取得username字段的值
vOld = m_pRecordset->GetCollect("old");
vBirthday = m_pRecordset->GetCollect("birthday");
///在DEBUG方式下的OUTPUT窗口輸出記錄集中的記錄
if(vID.vt != VT_NULL && vUsername.vt != VT_NULL && vOld.vt != VT_NULL && vBirthday.vt != VT_NULL)
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("ID",_variant_t((long)(i+10)));
m_pRecordset->PutCollect("username",_variant_t("葉利欽"));
m_pRecordset->PutCollect("old",_variant_t((long)71));
m_pRecordset->PutCollect("birthday",_variant_t("1930-3-15"));
}
m_pRecordset->Move(1,_variant_t((long)adBookmarkFirst));///從第一條記錄往下移動一條記錄,即移動到第二條記錄處
m_pRecordset->PutCollect(_variant_t("old"),_variant_t((long)45));///修改其年齡
m_pRecordset->Update();///保存到庫中
【6】關閉記錄集與連接
記錄集或連接都可以用Close方法來關閉
m_pRecordset->Close();///關閉記錄集
m_pConnection->Close();///關閉連接
至此，我想您已經熟悉了ADO操作數據庫的大致流程，也許您已經胸有成竹，也許您還有點胡涂，不要緊！建議你嘗試寫幾個例子，這樣會更好地熟悉ADO,最后我給大家寫了一個小例子，例子中讀出所有記錄放到列表控件中、并可以添加、刪除、修改記錄。
點這里下載示例代碼
后記：限于篇幅ADO中的許多內容還沒有介紹，下次我們將詳細介紹Recordset對象的屬性、方法并解決幾個關鍵的技術：綁定方式處理記錄集數據、存儲過程的調用、事務處理、圖象在數據庫中的保存與讀取、與表格控件的配合使用等
//--------------------------------------------------------------------------------------
又一個說明：
在vc中怎么使用ADO訪問數據庫?
1、#import "msado15.dll" no_namespace rename("EOF","ADOEOF")
? 引入"msado15.dll"動態庫。
2、定義一個變量? _ConnectionPtr m_AdoCon；代表一個代表與數據源進行的唯一會話
3、打開數據庫
??????? _bstr_t connString;?? //連接字符串
try
{
connString = _T("Provider=MSDASQL.1;Data Source=kong;Persist Security Info=False");
m_AdoCon.CreateInstance(__uuidof(Connection));//???
m_AdoCon->Open(connString, "", "", -1);
}
catch (_com_error& comerr)
{
IErrorInfo* pErrorInfo = comerr.ErrorInfo();
HRESULT hr = comerr.Error();
if (pErrorInfo)
{
BSTR bsDesc = NULL;
pErrorInfo->GetDescription( &bsDesc );
_bstr_t sDesc( bsDesc, false );
AfxMessageBox(sDesc.operator LPCTSTR());
pErrorInfo->Release();
}
?????????? }
4、使用
CString strIp, SQL_STR, strTemp, strResult;
UINT port;
_RecordsetPtr?? AdoRst;?????????????? //RecordSet的實例
_StreamPtr AdoStream;???????????????? //Ado數據流
SQL_STR = m_strText;?????????????????? //SQL語句
if (m_AdoCon->State == adStateClosed) //判斷連接是否已經關閉
{
strTemp = "Ado connection hasn't set up.";
m_pWnd->SendMessage(WM_FRESHWATCHLIST, (WPARAM)(&strTemp));
SendMsg(strTemp, FALSE);
return;
}
try
{
//Create Recordset Interface
AdoRst.CreateInstance(__uuidof(Recordset));
AdoRst->Open((LPCTSTR)SQL_STR, m_AdoCon.GetInterfacePtr(),
adOpenDynamic,adLockOptimistic,adCmdUnknown);?????? //打開并且執行SQL（SQL_STR）語句
if (strTemp != "SELECT")
strResult =_T("OK!");
else
{
//Save the xmlResult to strResult
AdoStream.CreateInstance(__uuidof(Stream));??????? //
AdoRst->Save(AdoStream.GetInterfacePtr(), adPersistXML);
strResult = ((BSTR)AdoStream->ReadText(adReadAll));????? //轉換為XML格式
}
}
catch (_com_error& comerr)
{
//catch the COM exception
IErrorInfo* pErrorInfo = comerr.ErrorInfo();
HRESULT hr = comerr.Error();
if (pErrorInfo)
{
BSTR bsDesc = NULL;
pErrorInfo->GetDescription( &bsDesc );
_bstr_t sDesc( bsDesc, false);
strResult = sDesc.operator LPCTSTR();
pErrorInfo->Release();
}
}
5.取得表中的字段 GetCollect（）
int nItem;
_variant_t vUsername,vBirthday,vID,vOld;
try
{
m_pRecordset.CreateInstance("ADODB.Recordset");
m_pRecordset->Open("SELECT * FROM users",_variant_t((IDispatch*)theApp.m_pConnection,true),adOpenStatic,adLockOptimistic,adCmdText);
m_bSuccess = TRUE;
while(!m_pRecordset->adoEOF)
{
vID = m_pRecordset->GetCollect("ID");
vUsername = m_pRecordset->GetCollect("username");
vOld = m_pRecordset->GetCollect("old");
vBirthday = m_pRecordset->GetCollect("birthday");
nItem=m_userlist.InsertItem(0xffff,(_bstr_t)vID);
m_userlist.SetItem(nItem,1,1,(_bstr_t)vUsername,NULL,0,0,0);
m_userlist.SetItem(nItem,2,1,(_bstr_t)vOld,NULL,0,0,0);
m_userlist.SetItem(nItem,3,1,(_bstr_t)vBirthday,NULL,0,0,0);
m_pRecordset->MoveNext();
}
}
6.添加數據 PutCollect()
if(!m_pRecordset->adoEOF && m_nCurrentSel >= 0 && m_bAutoSave)
{
vUserID = (long)m_nUserID;
vUsername = m_sUsername;
vOld = (long)m_nOld;
vBirthday = m_tBirthday;
m_pRecordset->PutCollect("ID",vUserID);
m_pRecordset->PutCollect("username",vUsername);
m_pRecordset->PutCollect("old",vOld);
m_pRecordset->PutCollect("birthday",vBirthday)
??????? }
//--------------------------------------------------------------------------------------
在ado中獲取access中表的信息
void OpenSchemaX(TCHAR *TableName)
{
??? HRESULT? hr = S_OK;
IADORecordBinding?? *picRs = NULL;
_RecordsetPtr pRstSchema("ADODB.Recordset");
_ConnectionPtr pConnection("ADODB.Connection" );
pConnection->ConnectionString = TableName;
pConnection->Provider = "Microsoft.Jet.OLEDB.4.0";
?? try
??? {
pConnection->Open(pConnection->ConnectionString, "", "", adModeUnknown);
? pRstSchema->QueryInterface(
????????? __uuidof(IADORecordBinding), (LPVOID*)&picRs);
??????? pRstSchema = pConnection->OpenSchema(adSchemaTables);//枚舉表的名稱處理
??????? while(!(pRstSchema->EndOfFile))
??????? {
CString strTableType;
??????????? _bstr_t table_name = pRstSchema->Fields->
??????????????? GetItem("TABLE_NAME")->Value;//獲取表的名稱
??????????? _bstr_t table_type = pRstSchema->Fields->
??????????????? GetItem("TABLE_TYPE")->Value;//獲取表的類型
??????????? strTableType.Format("%s",(LPCSTR) table_type);
if(!lstrcmp(strTableType,_T("TABLE")))
??????????? {
m_cbTeam.AddString((LPCSTR) table_name);//添加表的名稱
}
??????????? pRstSchema->MoveNext();
??????? }
??????? // Clean up objects before exit.
??????? pRstSchema->Close();
??????? pConnection->Close();
??? }
??? catch (_com_error &e)
??? {
??????? // Notify the user of errors if any.
??????? // Pass a connection pointer accessed from the Connection.???????
??????? PrintProviderError(pConnection);
??????? PrintComError(e);
??? }
}
--------------------------------------------------------------------------------
CSDN VC編程經驗總結
?
ADO 2.8 Samples?
See Also
Clear Method | Command Object | Connection Object | Errors Collection | Execute Method (ADO Command) | Execute Method (ADO Connection) | Requery Method
Execute, Requery, and Clear Methods Example (VC++)
This example demonstrates the Execute method when run from both a Command object and a Connection object. It also uses the Requery method to retrieve current data in a recordset, and the Clear method to clear the contents of the Errors collection. The ExecuteCommand and PrintOutput functions are required for this example to run.
// BeginExecuteCpp
#include <ole2.h>
#include <stdio.h>
#import "c:/Program Files/Common Files/System/ADO/msado15.dll" /
??? no_namespace rename("EOF", "EndOfFile")
// Function declarations
inline void TESTHR(HRESULT x) {if FAILED(x) _com_issue_error(x);};
void ExecuteX(void);
void ExecuteCommand(_CommandPtr pCmdTemp, _RecordsetPtr pRstTemp);
void PrintOutput(_RecordsetPtr pRstTemp);
void PrintProviderError(_ConnectionPtr pConnection);
void PrintComError(_com_error &e);
//????? Main Function???????? //
void main()
{
??? if(FAILED(::CoInitialize(NULL)))
??????? return;
??? ExecuteX();
??? ::CoUninitialize();
}
///
//????? ExecuteX Function??????? //
///
void ExecuteX(void)
{
?? HRESULT??? hr = S_OK;
??? // Define string variables.
?? _bstr_t strSQLChange("UPDATE Titles SET Type = "
??????????? "'self_help' WHERE Type = 'psychology'");
?? _bstr_t strSQLRestore("UPDATE Titles SET Type = "
??????????? "'psychology' WHERE Type = 'self_help'");
?? _bstr_t strCnn("Provider='sqloledb';Data Source='MySqlServer';"
??????????? "Initial Catalog='pubs';Integrated Security='SSPI';");
??? // Define ADO object pointers.
??? // Initialize pointers on define.
??? // These are in the ADODB::? namespace.
??? _ConnectionPtr? pConnection = NULL;
??? _CommandPtr???? pCmdChange? = NULL;
??? _RecordsetPtr?? pRstTitles? = NULL;
??? try
??? {
??????? // Open connection.
??????? TESTHR(pConnection.CreateInstance(__uuidof(Connection)));
??????? pConnection->Open (strCnn, "", "", adConnectUnspecified);
??????? // Create command object.
??????? TESTHR(pCmdChange.CreateInstance(__uuidof(Command)));
??????? pCmdChange->ActiveConnection = pConnection;
??????? pCmdChange->CommandText = strSQLChange;
??????? // Open titles table, casting Connection pointer to an
??????? // IDispatch type so converted to correct type of variant.
??????? TESTHR(pRstTitles.CreateInstance(__uuidof(Recordset)));
??????? pRstTitles->Open ("Titles", _variant_t((IDispatch *) pConnection,
??????????? true), adOpenStatic, adLockOptimistic, adCmdTable);
??????? // Print report of original data.
??????? printf(
??????????? "/n/nData in Titles table before executing the query: /n");
??????? // Call function to print loop recordset contents.
??????? PrintOutput(pRstTitles);
??????? // Clear extraneous errors from the Errors collection.
??????? pConnection->Errors->Clear();
??????? // Call ExecuteCommand subroutine to execute pCmdChange command.
??????? ExecuteCommand(pCmdChange, pRstTitles);
??????? // Print report of new data.
??????? printf(
??????????? "/n/n/tData in Titles table after executing the query: /n");
??????? PrintOutput(pRstTitles);
??????? // Use the Connection object's execute method to
??????? // execute SQL statement to restore data.
??????? pConnection->Execute(strSQLRestore, NULL, adExecuteNoRecords);
??????? // Retrieve the current data by requerying the recordset.
??????? pRstTitles->Requery(adCmdUnknown);
??????? // Print report of restored data.
??????? printf(
??????????? "/n/n/tData after exec. query to restore original info: /n");
??????? PrintOutput(pRstTitles);
??? }
??? catch (_com_error &e)
??? {
??????? PrintProviderError(pConnection);
??????? PrintComError(e);
??? }
??? // Clean up objects before exit.
??? if (pRstTitles)
??????? if (pRstTitles->State == adStateOpen)
??????????? pRstTitles->Close();
??? if (pConnection)
??????? if (pConnection->State == adStateOpen)
??????????? pConnection->Close();
}
//
//????? ExecuteCommand Function???????? //
//
void ExecuteCommand(_CommandPtr pCmdTemp, _RecordsetPtr pRstTemp)
{
??? try
??? {
??????? // CommandText property already set before function was called.
??????? pCmdTemp->Execute(NULL, NULL, adCmdText);
??????? // Retrieve the current data by requerying the recordset.
??????? pRstTemp->Requery(adCmdUnknown);
??? }
??? catch(_com_error &e)
??? {
??????? // Notify user of any errors that result from
??????? // executing the query.
??????? // Pass a connection pointer accessed from the Recordset.
??????? PrintProviderError(pRstTemp->GetActiveConnection());
??????? PrintComError(e);
??? }
}
/
//????? PrintOutput Function?????? //
/
void PrintOutput(_RecordsetPtr pRstTemp)
{
??? // Ensure at top of recordset.
??? pRstTemp->MoveFirst();
??? // If EOF is true, then no data and skip print loop.
??? if( pRstTemp->EndOfFile )
??? {
??????? printf("/tRecordset empty/n");
??? }
??? else
??? {
??????? // Define temporary strings for output conversions.
??????? // Initialize to first record's values.
??????? _bstr_t bstrTitle;
??????? _bstr_t bstrType;
??????? // Enumerate Recordset and print from each.
??????? while(!(pRstTemp->EndOfFile))
??????????? {
??????????? // Convert variant string to convertable string type.
??????????? bstrTitle = pRstTemp->Fields->GetItem("Title")->Value;
??????????? bstrType? = pRstTemp->Fields->GetItem("Type")->Value;
??????????? printf("/t%s, %s /n",
??????????????? (LPCSTR) bstrTitle,
??????????????? (LPCSTR) bstrType);
???
??????????? pRstTemp->MoveNext();
??????? }
??? }
}
///
//????? PrintProviderError Function????????? //
///
void PrintProviderError(_ConnectionPtr pConnection)
{
??? // Print Provider Errors from Connection object.
??? // pErr is a record object in the Connection's Error collection.
??? ErrorPtr? pErr = NULL;
??? if( (pConnection->Errors->Count) > 0)
??? {
??????? long nCount = pConnection->Errors->Count;
??????? // Collection ranges from 0 to nCount -1.
??????? for(long i = 0; i < nCount; i++)
??????? {
??????????? pErr = pConnection->Errors->GetItem(i);
??????????? printf("/t Error number: %x/t%s", pErr->Number,
??????????????? pErr->Description);
??????? }
??? }
}
//
//????? PrintComError Function????? //
//
void PrintComError(_com_error &e)
{
??? _bstr_t bstrSource(e.Source());
??? _bstr_t bstrDescription(e.Description());
???
??? // Print Com errors.
??? printf("Error/n");
??? printf("/tCode = %08lx/n", e.Error());
??? printf("/tCode meaning = %s/n", e.ErrorMessage());
??? printf("/tSource = %s/n", (LPCSTR) bstrSource);
??? printf("/tDescription = %s/n", (LPCSTR) bstrDescription);
}
// EndExecuteCpp
?
發信人: wesley (pine~心中的森林), 信區: VisualC
標? 題: ADO is AOK (ADO其實很簡單) (一) (轉載)
發信站: BBS 水木清華站 (Fri Nov 19 11:30:18 1999)
?
【 以下文字轉載自 Database 討論區 】
【 原文由 wesley 所發表 】
本文摘自http://www.codeguru.com/mfc_database/Ado_Aok.shtml。作者：Bob Place
?
翻譯改寫：wesley at 水木清華。 Email: wesley@video.mdc.tsinghua.edu.cn。
?
前言：
??? 有人經常問：現在最好的數據訪問方法是什么？回答當然是ADO！
??? M$花了不少時間，推出了一種叫 UDA(Universal Data Access)的東東，還有一套看
起來蠻簡單的數據訪問對象ADO(ActiveX Data Object)，用來替代過時的 DAO(Data Ac
cess Object)、RDO(Remote Data Object)。
??? DAO 的底層是 JET 引擎，主要用來提供對 ACCESS 數據庫的訪問，比較新的版本也
支持訪問其他數據庫，不過對于其他數據庫，需經過 JET 的中間層，訪問速度比較差。
在所有對 ACCESS 數據庫的訪問方法中， JET是最快的。最新的 JET Engine版本為4.0
，對應的 DAO 版本為3.6，可以訪問 ACCESS 2000 的數據庫。MFC里面 CDAODatabase
和 CDAORecordset 即為 DAO 的 MFC 包裝。
??? RDO 的底層是 ODBC，RDO僅僅是對ODBC API的一個薄包裝層，薄得簡直有點不象樣
，很多人都用 ODBC API寫過程序 (我的第一個SQL Server客戶端程序就是用ODBC API寫
的一個Console Application)，把那些并不復雜的API跟RDO一比就能發現，包裝得簡直
沒有專業精神。也正因為薄，所以速度較快，在ADO出現以前，訪問MS SQL Server最快
的方法就是 RDO 了(不要跟我說還有DB-Library，不論是看MS的文檔，還是我親自實驗
，DB-Library都沒有ODBC/RDO快)。最新的 RDO 版本為 2.0，說是最新，似乎也有好幾
年沒有更新了，原因是MS早已經決定將其淘汰。不過遺憾的是，現在大家都還在用的 C
Database、CRecordset 就是 RDO 的 MFC 包裝。現在還用這兩個類，就象有了寶馬奔馳
，還騎破永久上下班，只是因為不會開車。 :-(
??? ADO 的底層是 OLE DB，不僅能訪問關系型數據庫，也可以訪問非關系型數據庫，這
可是現在最快速的數據庫訪問中間層啊！ADO對OLE DB的包裝可以說相當成功，對象模型
簡明扼要，沒有一點多余的東西，功能還遠超DAO、RDO。直到此時，我才算是有點佩服
MS，OLE DB里面數十個密密麻麻的接口對我來說實在是太恐怖了，還是乖乖的用ADO吧。
?
??? 有一點很不幸，微軟提供的ADO文檔幾乎沒有有關VC的內容，象我這樣的VC菜鳥，坐
進了寶馬舒適的駕駛倉，不知道該怎么上手下腳，郁悶之極！
??? 這篇文章真是救黎民于水火之中，不容我不把它貢獻出來讓大家共享。
?
開始：
??? 在用ADO以前，一定得讓你的程序知道去哪里找ADO。在stdafx.h文件里，需要加上
下面的代碼：
?#import "c:/program files/common files/system/ado/msado15.dll" no_namespace
?rename("EOF", "adoEOF")
??? 這行代碼的作用是，告訴編譯器去哪里找ADO的庫文件(可能在你的機器上路徑有所
不同)，然后說明不用namespace，并且將 EOF 更名為 adoEOF(如果不這樣干，很有可能
會碰到常量沖突)。
??? 只要加了這句話，準備工作就全干完了，很簡單是嗎？不用包含任何頭文件，不用
為link指定任何lib文件，我也覺得有點神奇。//shrug
?
_ConnectionPtr, _CommandPtr, 和 _RecordsetPtr (本文中未提及 _CommandPtr)：
??? ADO，和 CDAODatabase、CDatabase 非常相似，也分這么幾塊，不同的是，ADO 以
?COM 為基礎，這幾塊都是標準的COM組件，而 CDatabase 等等則是 MFC 類。有一點必
須提請注意，要學習ADO編程，學點COM是不可避免的了，不過這是件好事，現在如果不
會一點COM、OLE什么的，估計很難適應Windows編程的形勢。ADO里面的三個組成部份就
是三個COM組件：Connection、Command、Recordset。(還有兩個暫時用不上的:)
??? Connection用于建立數據庫連接，執行不返回任何結果集的SQL語句。
??? Command用于返回結果集，并提供簡單的方法執行存儲過程或者任何返回結果集的S
QL語句。
??? Recordset就是結果集，可進行數據的存取、滾動操作。
??? 如果給Command和Recordset正確的Connection string，而不是一個Connection對象
的指針，它們一樣可以打開記錄集，這種情況適用于單數據庫操作。當程序里需要頻繁
進行數據庫操作時，最好還是預先定義一個Connection對象，用它連接數據庫，而用Re
cordset處理數據。本文中將大量討論這兩個對象。
??? _ConnectionPtr是一個Connection的接口，與CDatabase和CDAODatabase類似，實際
工作原理也差不多。在程序里創建它的實例，通過某個OLE DB provider指向一個數據源
，并開啟連接。下面的代碼是CDAODatabase和_ConnectionPtr的開啟實例：
?
DAO:
??? CDaoDatabase MyDb = new CDaoDatabase();
??? m_DaoServerDB.Open(NULL,FALSE,FALSE,"ODBC;DSN=SAMS_SVR;UID=admin;PWD=adm
in");
?
ADO:
??? _ConnectionPtr MyDb;
??? MyDb.CreateInstance(__uuidof(Connection));
??? MyDb->Open("DSN=SAMS_SVR;UID=admin;PWD=admin","","",-1);
?
??? _RecordsetPtr是記錄集接口，與CDAORecordset類似。先看看它的開啟方式與CDAO
Recordset有多么相似：
?
DAO:
??? CDaoRecordset MySet = new CDaoRecordset(MyDb);
??? MySet->Open(AFX_DAO_USE_DEFAULT_TYPE,"SELECT * FROM some_table");
?
ADO:
??? _RecordsetPtr MySet;
??? MySet.CreateInstance(__uuidof(Recordset));
??? MySet->Open("SELECT * FROM some_table", MyDb.GetInterfacePtr(), adOpenDy
namic, adLockOptimistic, adCmdText);
?
??? (譯者注：請注意ADO在Open Recordset的時候，使用了MyDb.GetInterfacePtr()作
為參數之一，當時我用了_ConnectionPtr, &(_ConnectionPtr)都不行，原來要這么用，
真是不服不行。:()
??? ADO只是略微的麻煩一點，不過花這點功夫獲得ADO的多多好處還是很值的。
??? 現在有了一個Connection和一個Recordset，下面該用這兩個東東取點數據出來了。
不妨先假定有一個名為m_List的Listbox，我們把數據取出來往里塞。
?
DAO:
??? VARIANT *vFieldValue;
??? COleVariant covFieldValue;
??? CString Holder;
??? while(!MySet->IsEOF())
??? {
??????? MySet->GetFieldValue("FIELD_1", covFieldValue);
??????? vFieldValue = (LPVARIANT)covFieldValue;
??????? if(vFieldValue->vt!-VT_NULL)
??????? {
??????????? Holder.Format("%s",vFieldValue->pbVal);
??????????? m_List.AddString(Holder);
??????? }
??????? MySet.MoveNext();
??? }
?
ADO:
??? _variant_t Holder
??? while(!MySet->adoEOF)
??? {
??????? Holder = MySet->GetCollect("FIELD_1");
??????? if(Holder.vt!=VT_NULL)
??????? m_List.AddString((char*)_bstr_t(Holder));
??????? MySet->MoveNext();
??? }
?
??? 注意：在微軟所有的文檔里，都沒找到GetCollect方法。我找了所有的地方，也從
沒人提起過，在文檔里的示例方式是這樣：
??????? Holder = MySet->GetFields->Field->(_variant_t(FieldNumber))->Value;
??? 你喜歡哪一種呢，反正我是喜歡GetCollect。(譯者注：鬼知道他從哪里搞到這個方
法，難道是從MS自己人的程序里？I 服了 him。)
?
動態綁定 vs DFX(CRecordset 和 CDAORecordset的預先字段綁定，Data Field Exchan
ge)：
??? 動態綁定即使用SQL語句動態構造結果字段，而不是象 CDAORecordset 里面用DFX去
把所有原始字段映射成成員變量。動態綁定的例子：
??? SELECT (SUM(field_1) + SUM(field_2)) AS answer FROM some_table
??? 如果用DFX，估計就得在程序里自己寫了：
??? m_answer = m_field_1 + m_field2;
??? (譯者注：盡管很多人喜歡 DFX 的字段預先綁定，寧可這么寫代碼，不過我很少用
?DFX，當然在 VB 里面更是從來不會用到，好象用得比較多的也就是在 Delphi 里面，
用起來還比較爽，大概是 MS 的文檔里讓我別用，而 Borland 的破文檔里卻沒說吧。
:-)
??? 相比之下，動態綁定確有其優越的地方，減少了代碼量，也讓程序更小、更易維護
。再說，這也是MS推薦的獲取數據方式，更靈活，速度更快，更易維護，我們還能要求
什么呢？
??? 對于大多數程序來說，都是創建一個全局的Connection，然后用Recordset來處理數
據，如果Recordset數量很多，可以想象光是花費在DFX上面的代碼就有多少。如果使用
動態綁定，這些都省掉了。
?
_variant_t 和 _bstr_t 到底是什么玩意？
??? 很不幸，我們喜愛的CString類在COM里用不了(CStringEx也一樣)，因為COM必須設
計成跨平臺，它需要一種更普遍的方式來處理字符串以及其他數據。這就是VARIANT數據
類型的來歷，還有BSTR類型。VARIANT就是一個巨大的 union，包含了你能想得到的所有
的數據類型，除了char*，不過還好，BSTR取代了char*。
??? (譯者注：似乎VARIANT是個很慢的東西，大家都不愿意使它，不過按我看來，情況
沒這么糟糕，union照理說不應該慢到哪去，要說慢，也是慢在給VARIANT分配地址空間
上，這點在VC里面做得比VB要好
??? 這些東西看起來的確有點恐怖，不過實在用不著怕，等下面熟悉了這兩個東西之后
，你會很快喜歡的)
??? 簡單來說，_variant_t是一個類，包裝了VARIANT數據類型，并允許我們簡單的對之
進行強制類型轉換(相信大家都喜歡這個)，_bstr_t對BSTR干了同樣的事情。在下面的例
子里，你將看到怎么用GetCollect把數據取到VARIANT里，又怎么把它放到_bstr_t里，
最后強制轉換成char*，以及把_variant_t強制轉換成long、double或者其他一切東西：
?
??? _variant_t Holder;
??? // first get the VARIANT and put it into the _variant_t
??? Holder = MySet->GetCollect("FIELD_1");
??? // now put it into a _bstr_t and cast it to a char*
??? m_List.AddString((char*)_bstr_t(Holder));
?
??? 對比一下沒有用 _variant_t 和 _bstr_t 的代碼：
?
??? COleVariant covFieldValuel
??? VARIANT vFieldValue
??? CString Holder;
??? MySet->GetFieldValue("FIELD_1", covFieldValue);
??? vFieldValue = (LPVARIANT)covFieldValue;
??? Holder.Format("%s",vFieldValue->pbVal);
??? m_List.AddString(Holder);
?
??? 區別大了！
?
(待續)
?
--
世界上既無所謂幸福也無所謂不幸
只有一種狀況和另一種狀況的比較
只有體驗過極度不幸的人
才能品嘗到極度的幸福
?
※ 來源:·BBS 水木清華站 bbs.net.tsinghua.edu.cn·[FROM: 166.111.159.21]
發信人: wesley (pine~心中的森林), 信區: VisualC
標? 題: ADO is AOK (ADO其實很簡單) (二) (轉載)
發信站: BBS 水木清華站 (Fri Nov 19 11:30:29 1999)
?
【 以下文字轉載自 Database 討論區 】
【 原文由 wesley 所發表 】
Update，Insert，Delete：
??? 當我進行Update，Insert，Delete操作時，通常我喜歡用Connection和Command對象
，原因是，用CString來構造SQL語句簡單一些，然后直接用Connection.Execute就行了
。當然，用Recordset干這些也是可以的。
?
??? Update方法有下面三種方法調用：
??? 1: 給某個Field對象(或某些個)的Value屬性賦值，然后調用Update方法；
??? 2: 將字段名和字段值作為參數傳給Update方法；
??? 3: 將字段名和字段值的數組作為參數傳給Update方法。
?
??? AddNew方法如下調用：
??? 1: 直接調用，然后同Update調用方法一；
??? 2: 將字段名數組、字段值數組作為參數傳給AddNew方法。
?
??? Delete方法最簡單，直接調用就行了，刪除當前記錄！
?
??? 做完這些事情，可能需要調用Requery方法才能看到效果。
??? 下面的示例代碼需要我們創建一個簡單的MFC Application，然后在CWinApp類里面
聲明三個接口的對象：
?
??? // Global ADO Objects
??? // connection
??? _ConnectionPtr m_pConnection;
??? _CommandPtr? m_pCommand;
??? _RecordsetPtr m_pRecordset;
?
??? 在VC6里面有一點很有意思，如果敲 "m_pConnection."，你會看到一個方法和屬性
列表，如果敲"m_pConnection->"，還會看到一個方法和屬性列表，當然里面的內容完全
不同，因為你實際是在指向兩個不同的東西。下面就是這兩種混用的代碼：
?
??? _ConnectionPtr MyDb;
??? MyDb.CreateInstance(__uuidof(Connection));
??? MyDb->Open("DSN=SAMS_SVR;UID=admin;PWD=admin","","",-1);
?
??? 回到示例代碼，在 application 的 InitInstance 方法里，我打開數據連接，指向我
機器上的一個數據庫，你需要更改ConnectionString，使用你自己的ODBC數據源或指定
一個OLE DB provider。
?
??? // When we open the application we will open the ADO connection
??? m_pConnection.CreateInstance(__uuidof(Connection));
??? m_pConnection->Open("DSN=ADOTest","","",-1);
?
??? 如果你打開about對話框，就會看到一個Listbox，還有一個叫button1的按鈕，這里
面包含了 ADO 調用的核心代碼。我創建了一個_RecordsetPtr接口的實例，打開我需要
的記錄集，然后遍歷所有記錄，將它們塞到Listbox里去：
?
??? _variant_t TheValue;
??? theApp.m_pRecordset.CreateInstance(__uuidof(Recordset));
??? try
??? {
??????? theApp.m_pRecordset->Open("SELECT DISTINCT FLDESC FROM tblFALines",
??????????????? theApp.m_pConnection.GetInterfacePtr(),
??????????????? adOpenDynamic,
??????????????? adLockOptimistic,
??????????????? adCmdText);
??????? while(!theApp.m_pRecordset->adoEOF)
??????? {
??????????????? TheValue = theApp.m_pRecordset->GetCollect("FLDESC");
??????????????? if(TheValue.vt!=VT_NULL)
??????????????? m_List.AddString((char*)_bstr_t(TheValue));
??????????????? theApp.m_pRecordset->MoveNext();
??????? }
??????? theApp.m_pRecordset->Close();
??? }
??? catch(_com_error *e)
??? {
??????? CString Error = e->ErrorMessage();
??????? AfxMessageBox(e->ErrorMessage());
??? }
??? catch(...)
??? {
??????? MessageBox("Whoa this is bad");
??? }
?
??? 記得一定要用try和catch，否則ADO調用錯誤有可能使你的程序崩潰，一定要隨時記
得捕捉_com_error例外以及其它錯誤。
??? 我盡可能的使代碼簡單，所以省略了很多細節，尤其是忽略了很多好的編程習慣(比
如檢查大多數COM方法都返回的HRESULT值)。本文的目的是想說，ADO并沒什么難的，CO
M也一樣，而不是想表現ADO能做的所有事情。我甚至都沒仔細想過ADO能為你帶來什么，
不過我肯定一點，那就是ADO比DAO、RDO更快、更容易使用、并且功能強大得多。看看本
站點其它的文章，你就會知道，通過ADO調用存儲過程有多么容易！
??? 最后，我想向大家推薦兩本書，其中有一本是完全免費的，在www.informit.com可
以找到電子版，另一本必須得付錢買了，不過我還是推薦兩本都買，除非你家浴池里、
床頭邊也放了計算機。 :)
??? 免費的那本是<Learn Database Programming with Visual C++ in 21 days>。哦，
我知道你在想什么，我也知道那些'in 21 days'的書通常都很爛，而且當著其它程序員
的面買這樣的書的確有點丟面子，并且還很不好意思把這樣的書擺在書架上顯眼的位置
。不過這一本絕對是個例外！里面的內容簡直太棒了！
??? 要花錢的那本是<ADO 2.0>，由WROC出版... (譯者注：細節就省了吧，反正我們也
不會花美元去買英文書)。
?
??? 譯者注：一年以前，我在www.mcp.com(現在已經更名為informit)看到這本書，看過
之后覺得實在是本難得一見的好書，不僅講ADO深入淺出，COM的來歷、基礎、發展都說
得很清楚，還有不少C++的高級知識，這也是我看過的唯一一本“21天”的書，與其它的
“21天”簡直是天壤之別。強烈建議大家買一本。
??? 中譯本：Visual C++ 數據庫編程...(一時記不起了)，清華大學出版社出版，清華
書店有賣，大家快去買啊！注意不要買機械工業出版社那本 VC 數據庫編程的書，看起
來名字很象，不過內容爛得可以。
??? 如果要看相關的文章，請訪問站點www.codeguru.com，祝大家早日成為編程高手，
已經是高手的更加高！
?
--
世界上既無所謂幸福也無所謂不幸
只有一種狀況和另一種狀況的比較
只有體驗過極度不幸的人
才能品嘗到極度的幸福
?
※ 修改:·wesley 於 Nov 19 11:30:06 修改本文·[FROM:? 166.111.159.21]
※ 來源:·BBS 水木清華站 bbs.net.tsinghua.edu.cn·[FROM: 166.111.159.21]
在stdafx.h中添加：
#import "c:/program files/common files/system/ado/msado15.dll" no_namespace rename("EOF","adoEOF")
正式代碼：
_RecordsetPtr m_pRs;
_ConnectionPtr m_pConn;
try
{
?CoInitialize(NULL);
?m_pConn.CreateInstance(__uuidof(Connection));
?m_pRs.CreateInstance(__uuidof(Recordset));
?
?//設置服務器端游標
?m_pConn->CursorLocation = adUseServer;//adUseClient;adUseNone
???
?//連接ORACLE數據庫
?m_pConn->Open(L"Provider=OraOLEDB.Oracle.1;User ID=pkuwh_za;password=a;Data Source=213;Persist Security Info=False",
??????L"",L"",adOpenUnspecified);
?//上面的語句按下面的方式寫可以不用配置oracle數據源
??????? //m_pConn->Open(L"Provider=OraOLEDB.Oracle.1;User ID=pkuwh_za;Password=a;Data Source=(DESCRIPTION=(ADDRESS=(PROTOCOL=TCP)(HOST=192.168.3.213)(PORT=1521))(CONNECT_DATA=(SERVICE_NAME = ZAGL)));Persist Security Info=False",L"",L"",adOpenUnspecified);
?
?m_pRs->PutRefActiveConnection(m_pConn);
?CString t = "select * from case_acceptinfo where rownum <= 3";
?m_pRs->Open(_variant_t(t),_variant_t((IDispatch*)m_pConn,true),adOpenDynamic,adLockOptimistic,adCmdUnknown);
?
?while(!m_pRs->adoEOF)
?{
??CString m_s1 = _com_util::ConvertBSTRToString((_bstr_t)m_pRs->GetCollect("reporttime"));
??MessageBox(m_s1);
??m_pRs->MoveNext();
?}
?m_pRs->Close();
?m_pConn->Close();
?m_pRs=NULL;
?m_pConn=NULL;
?CoUninitialize();
}
catch(_com_error &e)
{?
?AfxMessageBox(e.Description());
}
總結
- 上一篇： Android手机应用开发（一） | 基
- 下一篇： jquery选择器篇