VC 資料庫程式設計--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)使用完畢後關閉連接配接釋放對象。

在MFC環境中,我們可以使用AfxOleInit()來初始化COM庫，(若在非MFC環境裡,必須要用CoInitialize(NULL)初始化, 對應最好在代碼結束處加一行 CoUninitialize()),這項工作通常在CWinApp::InitInstance()的重載函數中完

成，請看如下代碼:

BOOL CADOTest1App::InitInstance()

{

AfxOleInit(); //或 CoUninitialize());

......

}

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

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

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

首先我們需要添加一個指向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={SQL Server};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】

為了取得結果記錄集，我們定義一個指向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 student(Sno INTEGER,Sname TEXT,Ssex TEXT,Sage INTEGER,Sdept TEXT)",&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); //執行SQL統計指令得到包含記錄條數的記錄集

_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方法的介紹

根據我們剛才通過執行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){}

記錄集或連接配接都可以用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;

}

VC 資料庫程式設計--ADO接口詳解

繼續閱讀

Android – ListView 中添加按鈕，動态删除添加ItemView的操作

報錯：'mysql' 不是内部或外部指令，也不是可運作的程式或批處理檔案。

Linxu常用指令技巧彙總

ERROR 1 (HY000): Can't create/write to file '/tmp/#sql_4188_1.MYI' (Errcode: 28)

艱難安裝LDAP,SSL認證

《Linux指令行與Shell腳本程式設計大全第2版.布盧姆》pdf

MySQL的4種隔離級别？出現問題

XX系統實施過程問題總結

無元件上傳圖檔到資料庫中，最完整解決方案

【MySQL資料庫】資料庫索引事務1.索引2.事務

neo4j之cypher使用文檔

NOSQL安全攻擊

mybatis_入門程式Mybatis入門

登入plsql 報錯 the account is locked --使用者被鎖

sqlServer根據經緯查距離

SequoiaDB巨杉資料庫C++驅動概述