學習ADO時總結的一些經驗

 

 

用ADO操作數據庫的方法步驟

 

ADO接口簡介

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

_ConnectionPtr接口返回一個記錄集或一個空指針。

通常使用它來創建一個數據連接或執行一條不返回任何結果的SQL語句，如一個存儲過程。使用_ConnectionPtr接口返回一個記錄集不是一個好的使用方法。通常同Cdatabase一樣，使用它創建一個數據連接，然后使用其它對象執行數據輸入輸出操作。

 

_CommandPtr接口返回一個記錄集。

它提供了一種簡單的方法來執行返回記錄集的存儲過程和SQL語句。在使用_CommandPtr接口時，你可以利用全局_ConnectionPtr接口，也可以在_CommandPtr接口里直接使用連接串。如果你只執行一次或幾次數據訪問操作，后者是比較好的選擇。但如果你要頻繁訪問數據庫，并要返回很多記錄集，那么，你應該使用全局_ConnectionPtr接口創建一個數據連接，然后使用_CommandPtr接口執行存儲過程和SQL語句。

 

 

_RecordsetPtr是一個記錄集對象。

與以上兩種對象相比，它對記錄集提供了更多的控制功能，如記錄鎖定，游標控制等。同_CommandPtr接口一樣，它不一定要使用一個已經創建的數據連接，可以用一個連接串代替連接指針賦給_RecordsetPtr的connection成員變量，讓它自己創建數據連接。如果你要使用多個記錄集，最好的方法是同Command對象一樣使用已經創建了數據連接的全局_ConnectionPtr接口，然后使用_RecordsetPtr執行存儲過程和SQL語句。

 

 

基本流程

 (1)初始化COM庫，引入ADO庫定義文件

(2)用Connection對象連接數據庫

(3)利用建立好的連接，通過Connection、Command對象執行SQL命令，或利用Recordset對象取得結果記

   錄集進行查詢、處理。

(4)使用完畢后關閉連接釋放對象。

 

【1】COM庫的初始化

我們可以使用AfxOleInit()來初始化COM庫，這項工作通常在CWinApp::InitInstance()的重載函數中完

成，請看如下代碼:

 

BOOL CADOTest1App::InitInstance()

{

  AfxOleInit();

  ......

}

 

 

【2】用#import指令引入ADO類型庫

我們在stdafx.h中加入如下語句：

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

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

 

【3】創建Connection對象并連接數據庫

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

 

_ConnectionPtr m_pConnection;

 

BOOL CADOTest1Dlg::OnInitDialog()

{

 CDialog::OnInitDialog();

 try

 {

  HRESULT 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) //COM錯誤取得,當執行COM功能的時候，如果出錯，可以捕捉到_com_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);

 }

}

 

也可以使用UDL文件進行連接。

try

{ 

 m_pConnection.CreateInstance(__uuidof(Connection));  

 m_pConnection->ConnectionString ="File Name=e.udl";

 m_pConnection->Open("","","",NULL);

}

catch(_com_error e)

{....}

 

◆在這段代碼中我們是通過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);

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

 

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

m_pConnection->Open(“driver={SQLServer};Server=127.0.0.1;DATABASE=vckbase;UID=sa;PWD=139”,””,””,adModeUnknown);//其中Server是SQL服務器的名稱，DATABASE是庫的名稱

 

◆先介紹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執行完后返回一個指向記錄集的指針，下面我們給出具體代碼并作說明。 

try

{

 _variant_t ra;

 

 m_pConnection->Execute("CREATE TABLE 學生信息(學號 INTEGER,姓名 TEXT,年齡 INTEGER,生日 DATETIME)",&ra,adCmdText);

 m_pConnection->Execute("INSERT INTO 學生信息(學號,姓名,年齡,生日) VALUES (112105, '程紅秀',22,'1982-08-16')",&ra,adCmdText); m_pRecordset = m_pConnection->Execute("SELECT COUNT(*) FROM 學生信息",&ra,adCmdText);   /

 _variant_t vCount = m_pRecordset->GetCollect((_variant_t)(long)(0)); //取得第一個字段的值放入vCount變量

 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="INSERT INTO 學生信息(學號,姓名,年齡,生日) VALUES (112105, '程紅秀',22,'1982-08-16')";

  m_pCommand->Execute(NULL,NULL,adCmdText);

 

  m_pCommand->CommandText="SELECT COUNT(*) FROM 學生信息";

  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 )

其中：

 ①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命令建立好的 學生信息 表，它包含四個字段:學號，姓名，年齡，生日以下的代碼實現：打開記錄集，遍歷所有記錄，刪除第一條記錄，添加三條記錄，移動光標到第二條記錄，更改其年齡，保存到數據庫。

 

 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)

  {

   vID = m_pRecordset->GetCollect(_variant_t((long)0));    //取得第1列的值,從0開始計數，你也可以直接給出列的名稱，如下一行

   vUsername = m_pRecordset->GetCollect("姓名");  //取得姓名字段的值

   vOld = m_pRecordset->GetCollect("年齡");

   vBirthday = m_pRecordset->GetCollect("生日");

  

   TRACE("id:%d,姓名:%s,年齡:%d,生日:%s\r\n",    vID.lVal,    (LPCTSTR)(_bstr_t)vUsername,    vOld.lVal,

    (LPCTSTR)(_bstr_t)vBirthday);  //在DEBUG方式下的OUTPUT窗口輸出記錄集中的記錄

 

   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("1930-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){}

 

【6】關閉記錄集與連接

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

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

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

 

在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;

}