VC連接數據庫方式


目前Windows系統上常見的數據庫接口包括:

  • ODBC(開放數據庫互連):訪問數據庫得先配置數據源
  • MFC(Microsoft基礎類)ODBC類
  • DAO(數據訪問對象)
  • RDO(遠程數據對象)
  • OLE DB(對象鏈接嵌入數據庫)
  • ADO(ActiveX數據對象)

    ODBC(Open Database Connectivity,開放數據庫連接)是由Microsoft定義的一種數據庫訪問標准,它提供了一種標准的數據庫訪問方法以訪問不同數據庫提供商的數據庫,其本質上是一組數據庫訪問API.雖然數據庫訪問有多種方法,但ODBC以其編程相對簡單,在實際編程中被廣泛使用。 VC++中提供了一組封裝了ODBC API的MFC ODBC類,以減少程序代碼編寫量。在VC++中使用MFC ODBC類訪問數據庫時,一般都是先配置或選擇已有的數據源,再構造CDatabase類對象,打開數據源,用該數據庫類對象和SQL(結構化查詢語言)可以對庫進行訪問,再構造CRecordset類或其繼承類對象,用數據集類對象和SQL可以實現對庫中的表的操作。在VC++中用MFC ODBC類操作SQL Server數據庫基本上也是這個思路。 

1.配置數據源 
在程序中根據用戶選擇動態配置數據源而不調用ODBC數據源管理器,對於應用程序開發有時是十分必要的。畢竟ODBC數據源管理器對於對數據庫不熟悉的用戶顯的復雜了,且ODBC數據源管理器的界面風格有可能與整個應用程序的界面風格不一致,對於嚴謹的應用程序開發者來說,這些都是不能容忍的。 

配置SQL Server數據源時,必須有SQL Server服務器名和服務器中的目標數據庫名(否則打開該數據源時,就會彈出配置數據源對話框或失敗)。這與配置Access等數據庫的數據源時指定數據庫文件的路徑不同。 

可以通過ODBC API函數SQLBrowseConnect得到本地所有的SQL Server服務器、服務器中的庫、語言信息等。其使用方法如下所示: 

①得到服務器名 
SQLBrowseConnect(hdbc, "DRIVER={SQL Server};", SQL_NTS, BrowseResult, sizeof(BrowseResult), &BrowseResultLen); 

其中hdbc是用SQLAllocHandle函數得到的連結句柄,第二個參數是指定連結屬性的輸入字符串,第三個參數是輸入字符串的長度,第四個參數是輸出字符串的指針,我們要得到的信息就存於這個字符串中,第五個參數指定輸出字符串的長度,第六個參數是實際返回字符串的長度。BrowseResult所指向的函數返回的字符串中含有形如“SERVER:Server={Server_name1,Server_name2,…}”的字符串,其中Server_name1、Server_name2就是SQL Server服務器名。 

②得到庫名 

當用戶選定一個服務器之后,可以進一步利用SQLBrowseConnect函數得到服務器中存在的庫或語言信息(如果需要的話)。 

SQLBrowseConnect(hdbc,"SERVER=Server_name1;UID=sa;PWD=515578;",SQL_NTS, BrowseResult, sizeof(BrowseResult), &BrowseResultLen); 

其中UID和PWD是訪問該服務器的用戶名和密碼。這次BrowseResult所指向的函數返回的字符串中含有形如DATABASE:Database={master,model,…}和LANGUAGE:Language={Arabic, Brazilian, English, …}的字符串,其中master、model為服務器中的數據庫名。 

利用這些得到信息就可以配置SQL Server數據源了: 

SQLConfigDataSource(NULL,ODBC_ADD_DSN,"SQL Server","DSN=myDSN\0 SERVER=xhm\0DATABASE=pubs\0\0" )) 

作者有幸在網上找到Santosh Rao編寫的CSQLInfoEnumerator類,該類有 EnumerateSQLServers、EnumerateDatabase、EnumerateDatabaseLanguage三個成員函數,其封裝了SQLBrowseConnect函數並進行相應的字符處理,大大簡化了SQLBrowseConnect函數的使用。 

2.與數據源建立連接 

如果使用ODBC API函數進行連結,函數SQLConnect、SQLDriverConnect和SQLBrowseConnect都可以實現。其中SQLConnect函數用於給定所有參數直接建立與數據源的連接;SQLDriverConnect用於給定了部分連接參數,並彈出數據源瀏覽窗口與用戶交互,獲得足夠的參數后建立與數據源的連接;而SQLBrowseConnect是通過迭代獲取連結參數再進行連接,其使用如前所述。 

MFC為連接數據源提供了一個數據庫類CDatabase,通過它我們可以非常方便地與數據源建立連結: 

//m_db是CDatabase的對象 

  //m_szUserId,m_szPassword是CString對象,為訪問數據源的用戶名和密碼 

CString str; 

str = _T("DSN=xhmtest;UID=")+m_szUserId+_T(";PWD=")+m_szPassword; 

if (! m_db.OpenEx(str, CDatabase::noOdbcDialog ) ){ 

AfxMessageBox("打開數據源失敗"); 




另外,如果我們想對數據源進行操作,就可以利用打開的CDatabase對象執行SQL語句實現。如新建一張表: 
str = "CREATE TABLE TableDemo (Column1TEXT, Column2 NUMBER)"; 

m_db.ExecuteSQL(sSql); 

3.得到數據庫的結構信息 

在VC++中可以單獨利用ODBC API獲取數據庫的結構信息,但方法非常復雜,各種參數也不易理解,且返回的結果不易獲取。MFC中也沒有為應用程序開發者得到數據庫結構信息而提供單獨的類。但是我們還是可以通過一些已有的方法方便地獲得數據庫的結構信息。 

3.1 得到數據庫中的表 

利用ODBC API函數SQLTables可以得到數據庫中的表信息,但使用不易。 

在MSDN的sample中有一個catalog例程,它示范了如果得到一個數據庫的表信息和表中的字段信息,該程序中有兩個非常實用的類:Ctables和Ccolumns.其中CTables繼承CRecordset類,通過非常巧妙的方法封裝了SQLTables函數,並將結果集存於CRecordset類,方便獲取。 

在程序中我們可以這樣應用: 

//m_db是已經打開的CDatabse對象, 

//m_strTableOwner是CComboBox對象 

CTables rs(&m_db); 

rs.Open(NULL, NULL, NULL, "TABLE"); 

CString strTableRef; 

m_combTable.ResetContent(); 

while (!rs.IsEOF()) 



strTableRef = _T("["); 

if (!rs.m_strTableOwner.IsEmpty()) 

strTableRef += rs.m_strTableOwner + _T("].["); 

strTableRef += rs.m_strTableName + _T("]"); 

m_combTable.AddString(strTableRef); 

rs.MoveNext(); 



rs.Close(); 


在CTables對象Open方法第四個能數指定“TABLE”是指返回庫中的表,當該參數為“SYSTEM TABLE”時返回系統表,當為NULL時,返回所有表。 

3.2 得到表中字段結構 

得到表中字段結構有三種具體實現方式: 

①直接利用ODBC API 函數SQLColumn;其實現也同樣復雜。 

②利用前面提到的封裝了SQLColumns函數的CColumns類;其使用方法與CTables類似,其成員變量m_strColumnName即為字段名 

③利用CRecordset類的成員函數。MFC在CRecordset類中提供了獲取表結構信息方法,使用非常方便。(但很奇怪為什么CDatabase類沒有獲取庫結構信息的類方法?) 

我們以利用CRecodrset為例簡單說明怎樣得到表結構。假設現在要得到用戶在CComboBox對象中所選表的所有字段名,並將它埴入一個CListCtrl對象(其View屬性被設為Report)的列名中去: 

//m_strTableOwner和上同,為CComboBox對象 

//m_listData為ClistCtrl對象 

CRecordset rs 

CODBCFieldInfo info; 

CString strSQL; 

m_combTable.GetLBText(m_combTable.GetCurSel(), strSQL); 

strSQL = _T("SELECT * FROM ") + strSQL; 

rs.Open(Open(CRecordset::snapshot, strSQL, CRecordset::readOnly); 

int nColumns = rs.GetODBCFieldCount(); 

for (int nNum = 0; nNum < nColumns; nNum++) 



prs->GetODBCFieldInfo(nNum, info); 

m_listData.InsertColumn(nNum, info.m_strName, LVCFMT_LEFT, 80) 




另外,我們可以利用CRecordSet::GetFieldValue函數通過指定列名或列序數得到記錄集中游標所指記錄的值,通過CRecordset::AddNew、CRecordset::CancelUpdate、CRecordset::Delete、CRecordset::Edit、CRecordset::Update等函數操作CRecordset打開的表。

 

 

一、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錯誤信息:%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:缺?gt;>5鼻暗男碸扇ㄎ瓷柚?br>adModeRead:只讀
adModeWrite:只寫
adModeReadWrite:可以讀寫
adModeShareDenyRead:阻止其它Connection對象以讀權限打開連接
adModeShareDenyWrite:阻止其它Connection對象以寫權限打開連接
adModeShareExclusive:阻止其它Connection對象以讀寫權限打開連接
adModeShareDenyNone:阻止其它Connection對象以任何權限打開連接
我們給出一些常用的連接方式供大家參考:
(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",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();///關閉連接


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM