當前位置:首頁 » 編程語言 » cado連接sqlserver
擴展閱讀
webinf下怎麼引入js 2023-08-31 21:54:13
堡壘機怎麼打開web 2023-08-31 21:54:11

cado連接sqlserver

發布時間: 2022-11-28 15:28:39

⑴ 求問C++怎麼連接sql server啊

//TestADOSql.cpp:定義控制台應用程序的入口點。
//

#include"stdafx.h"
#include"iostream"
#include"string"
#include"vector"
//步驟1:添加對ADO的支持
#import"C:.dll"no_namespacerename("EOF","adoEOF")
usingnamespacestd;

int_tmain(intargc,_TCHAR*argv[])
{
CoInitialize(NULL);//初始化COM環境
_ConnectionPtrpMyConnect(__uuidof(Connection));//定義連接對象並實例化對象
_RecordsetPtrpRst(__uuidof(Recordset));//定義記錄集對象並實例化對象
try
{
//步驟2:創建數據源連接
/*打開資料庫「SQLServer」,這里需要根據自己PC的資料庫的情況*/
pMyConnect->Open("Provider=SQLOLEDB;Server=.;Database=AIS2;uid=sa;pwd=;","","",adModeUnknown);
}
catch(_com_error&e)
{
cout<<"Initiatefailed!"<<endl;
cout<<e.Description()<<endl;
cout<<e.HelpFile()<<endl;
return0;
}
cout<<"Connectsucceed!"<<endl;

//步驟3:對數據源中的資料庫/表進行操作
try
{
pRst=pMyConnect->Execute("select*fromgendat",NULL,adCmdText);//執行SQL:select*fromgendat
if(!pRst->BOF)
{
pRst->MoveFirst();
}
else
{
cout<<"Dataisempty!"<<endl;
return0;
}
vector<_bstr_t>column_name;

/*存儲表的所有列名,顯示表的列名*/
for(inti=0;i<pRst->Fields->GetCount();i++)
{
cout<<pRst->Fields->GetItem(_variant_t((long)i))->Name<<"";
column_name.push_back(pRst->Fields->GetItem(_variant_t((long)i))->Name);
}
cout<<endl;

/*對表進行遍歷訪問,顯示表中每一行的內容*/
while(!pRst->adoEOF)
{
vector<_bstr_t>::iteratoriter=column_name.begin();
for(iter;iter!=column_name.end();iter++)
{
if(pRst->GetCollect(*iter).vt!=VT_NULL)
{
cout<<(_bstr_t)pRst->GetCollect(*iter)<<"";
}
else
{
cout<<"NULL"<<endl;
}
}
pRst->MoveNext();
cout<<endl;
}
}
catch(_com_error&e)
{
cout<<e.Description()<<endl;
cout<<e.HelpFile()<<endl;
return0;
}

//步驟4:關閉數據源
/*關閉資料庫並釋放指針*/
try
{
pRst->Close();//關閉記錄集
pMyConnect->Close();//關閉資料庫
pRst.Release();//釋放記錄集對象指針
pMyConnect.Release();//釋放連接對象指針
}
catch(_com_error&e)
{
cout<<e.Description()<<endl;
cout<<e.HelpFile()<<endl;
return0;
}
CoUninitialize();//釋放COM環境
return0;
}

⑵ 如何用C++連接SQL資料庫

(樓上兩位說的很對,我給你粘一篇文章吧 初學者 看看有好處。
需要的話 你可以留下郵箱 我這有一些初學者的文檔可以發給你很不錯,希望繼續努力。面試,到時候一切都是是浮雲。。。哈哈)

基本流程
萬事開頭難,任何一種新技術對於初學者來說最重要的還是「入門」,掌握其要點。讓我們來看看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:阻止其它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(); ///如果已經打開了連接則關閉它

------------------------------------------------------------------------------------
呵呵,是啊,我以前不做VC的,所以這次老闆有個項目要做,沒辦法啊!!以後多請教啊!!
------------------------------------------------------------------------------------
你現在不少基礎的不會,上來就連接資料庫有點難
------------------------------------------------------------------------------------
要是你用vc6,就右健點擊要添加變數的控制項,選擇classwizard,選擇member variables選項卡,它會自動指到你想要添加變數的控制項,你直接點選擇add variable,起個名字就可以了
------------------------------------------------------------------------------------
我關鍵是不知道怎麼給控制項添加與之相對應的變數!!請明示啊!!
------------------------------------------------------------------------------------
CBaseEditBox是什麼東西?你不要這樣定義。應該先把控制項放在對話框窗體上,再給這個控制項添加與之相對應的變數,這樣,VC就自動把控制項和變數聯系起來了
------------------------------------------------------------------------------------
剛弄,不怎麼會,請明示!!!

我想把從資料庫中讀出來的記錄放在一個文本框中!

然後在界面上放置了一個edit box

我在類C***Dlg中添加了變數
public:
CBaseEditBox m_list

接下來我在一個按鈕的onOK事件里連接資料庫並想把得到的記錄放到m_list里

// 讀入庫中各欄位並加入列表框中
while(!m_pRecordset- >adoEOF)
{
var = m_pRecordset- >GetCollect("UserName");
if(var.vt != VT_NULL)
strName = (LPCSTR)_bstr_t(var);
var = m_pRecordset- >GetCollect("Password");
if(var.vt != VT_NULL)
strAge = (LPCSTR)_bstr_t(var);

m_list.AddString( strName + " -- > "+strAge );

m_pRecordset- >MoveNext();
}

// 默認列表指向第一項,同時移動記錄指針並顯示
m_list.SetCurSel(0);

然後一大堆錯誤:
d:\microsoft visual studio\myprojects\testado\testadodlg.h(18) : error C2146: syntax error : missing "; " before identifier "m_list "
d:\microsoft visual studio\myprojects\testado\testadodlg.h(18) : error C2501: "CBaseEditBox " : missing storage-class or type specifiers
d:\microsoft visual studio\myprojects\testado\testadodlg.h(18) : error C2501: "m_list " : missing storage-class or type specifiers
TestADODlg.cpp
d:\microsoft visual studio\myprojects\testado\testadodlg.h(18) : error C2146: syntax error : missing "; " before identifier "m_list "
d:\microsoft visual studio\myprojects\testado\testadodlg.h(18) : error C2501: "CBaseEditBox " : missing storage-class or type specifiers
d:\microsoft visual studio\myprojects\testado\testadodlg.h(18) : error C2501: "m_list " : missing storage-class or type specifiers
D:\Microsoft Visual Studio\MyProjects\TestADO\TestADODlg.cpp(195) : error C2065: "m_list " : undeclared identifier
D:\Microsoft Visual Studio\MyProjects\TestADO\TestADODlg.cpp(195) : error C2228: left of ".AddString " must have class/struct/union type
D:\Microsoft Visual Studio\MyProjects\TestADO\TestADODlg.cpp(201) : error C2228: left of ".SetCurSel " must have class/struct/union type
Generating Code...
Error executing cl.exe.

請問什麼原因那?

------------------------------------------------------------------------------------
http://www.vckbase.com/document/viewdoc/?id=496

把文章中連接Access的語句換成:
連接SQL資料庫:
m_pConnection- >Open("Provider=SQLOLEDB.1;Server=192.168.1.6;DATABASE=mysql;UID=sa;PWD=;","","",adModeUnknown);

其中Server是SQL伺服器的名稱,DATABASE是庫的名稱

⑶ 使用ADO連接sqlserver資料庫 在有的電腦可以 有的電腦連接不上是什麼原因

"\"在C語言的作用忘記了?如果資料庫存放位置是本機,建議使用127.0.0.1否則:如果是公網,則用域名,區域網則用IP最好是將連接字串寫在非EXE里,這樣方便發布和修改資料庫伺服器位置、帳號密碼還有,vc中連通前,你應該在mssql管理器中嘗試連接,如果在mssql管理器中都連接不能,則問題不出在VC中caseDATABASE_MSSQL:strcpy_s(data,"Driver={SQLServer};");strcat_s(data,"Server=");strcat_s(data,addr);if(addr[0]!='.')//如果伺服器地址使用".",則不能加埠{strcat_s(data,",");strcat_s(data,port);}strcat_s(data,";");strcat_s(data,"UID=");strcat_s(data,user);strcat_s(data,";");strcat_s(data,"PWD=");strcat_s(data,pwd);strcat_s(data,";");if(strlen(database)){strcat_s(data,"Database=");strcat_s(data,database);strcat_s(data,";");}上面是連接字元串生成代碼,下面是打開連接的函數intCAdoDataBase::Open(constchar*data){intret=0;memset(m_strLogin,0,1024);strcpy_s(m_strLogin,data);this->Lock();do{try{m_pConnection.CreateInstance(__uuidof(Connection));ret=m_pConnection->Open((_bstr_t)data,"","",adModeUnknown);m_bFlag=TRUE;ret=0;}catch(_com_errore){m_bFlag=FALSE;strcpy_s(m_strErrCode,e.Description());m_pConnection=NULL;ret=-1;}}while(FALSE);this->UnLock();returnret;}

⑷ VC通過ADO連接的SQLServer 怎麼向資料庫中插入空值

把控制項設置成一個無效的日期就可以了,比如1900-01-01

⑸ 資料庫連接失敗

CADOConnection::CADOConnection()
{
m_Conn=NULL;
TimeOut=15;
}

CADOConnection::~CADOConnection()
{
if(m_Conn!=NULL)
{
ComUnInit();
}
}

BOOL CADOConnection::ComInit()
{

if FAILED(::CoInitialize(NULL)) // COM 初始化調用
{
CoUninitialize();
return FALSE;
}
return TRUE;
}

void CADOConnection::ComUnInit()
{
if(m_Conn!=NULL)
{
try{
m_Conn.Release();
}
catch(...)
{

}
}
m_Conn=NULL;
::CoUninitialize();
}

BOOL CADOConnection::ConnectToDB(LPSTR pConnString, /* 連接字串 */ LPSTR pUserId ,/* 用戶名 */ LPSTR pUserPassword , /* 用戶密碼 */ \
enum ConnectOptionEnum ConnectOption) //連接參數
{
_ConnectionPtr ptrConn;
try
{
HRESULT hr = S_OK;// 默認返回值
// 創建一個連接實體
hr=ptrConn.CreateInstance(__uuidof(Connection));
// 設定連接等待的最大秒數,默認是15秒
ptrConn->ConnectionTimeout=TimeOut;
// 打開連接
//ptrConn->CursorLocation=adUseClient;
hr =ptrConn->Open(_bstr_t(pConnString),_bstr_t(pUserId),_bstr_t(pUserPassword),ConnectOption);
if(hr!=S_OK)return FALSE;
m_Conn=ptrConn;
return TRUE;
}
catch(_com_error pComError)
{
// 錯誤處理
ErrorFunc(&pComError);
return FALSE;
}
}

void CADOConnection::ErrorFunc(_com_error *pComError)
{

// COM 錯誤取得
lpComErrorStr[0]=0;
// 當執行COM功能的時候,如果出錯,可以捕捉到_com_error的異常
sprintf(lpComErrorStr, "錯誤編號:%08lx 。 錯誤信息:%s 。錯誤源 :%s 。 錯誤描述:%s 。", \
pComError->Error(), /* 錯誤編號*/ pComError->ErrorMessage(),/* 錯誤信息 */(LPCSTR) pComError->Source(),/* 錯誤源 */ (LPCSTR) pComError->Description());// 錯誤描述
strcpy(lpErrorDescription,(LPCSTR) pComError->Description());
errornumber=pComError->Error();

// 通過上面的代碼我們可以看出,_com_error對象中可以得到COM所有出錯的信息
}

_ConnectionPtr CADOConnection::GetConnectionPtr()
{
return m_Conn;
}

void CADOConnection::Close()
{
try{
if(m_Conn!=NULL)
m_Conn->Close();
}
catch(...)
{

}
}

void CADOConnection::SetCursorLocation(enum CursorLocationEnum Val)
{
m_Conn->CursorLocation=Val;
}

⑹ c++連接完資料庫,向資料庫發送信息後,怎樣確定信息已經執行完了呢

BOOL ConnectSQLServer(CString dbsrc, CString dbname, CString user, CString pass, long lOptions = adConnectUnspecified);
/*========================================================================
Name:連接 SQL SERVER 資料庫.
-----------------------------------------------------
Params:[dbsrc]:SQL SERVER 伺服器名.
[dbname]:默認的資料庫名.
[user]:用戶名.
[pass]:密碼.
==========================================================================*/
BOOL CAdoConnection::ConnectSQLServer(CString dbsrc, CString dbname, CString user, CString pass, long lOptions)
{
CString strConnect = _T("Provider=SQLOLEDB.1; Data Source=") + dbsrc +
_T("; Initial Catalog=") + dbname +
_T("; User ID=") + user +
_T("; PWD=") + pass;
return Open(LPCTSTR(strConnect), lOptions);
}

/*========================================================================
Params:
- strSQL:SQL語句, 表名, 存儲過程調用或持久 Recordset 文件名.
- CursorType: 可選. CursorTypeEnum 值, 確定打開 Recordset 時應該
使用的游標類型. 可為下列常量之一.
[常量][說明]
-----------------------------------------------
adOpenForwardOnly打開僅向前類型游標.
adOpenKeyset打開鍵集類型游標.
adOpenDynamic打開動態類型游標.
adOpenStatic打開靜態類型游標.
-----------------------------------------------
- LockType: 可選, 確定打開 Recordset 時應該使用的鎖定類型(並發)
的 LockTypeEnum 值, 可為下列常量之一.
[常量][說明]
-----------------------------------------------
adLockReadOnly只讀 - 不能改變數據.
adLockPessimistic保守式鎖定 - 通常通過在編輯時立即鎖定數據源的記錄.
adLockOptimistic開放式鎖定 - 只在調用 Update 方法時才鎖定記錄.
adLockBatchOptimistic 開放式批更新 - 用於批更新模式(與立即更新模式
相對).
-----------------------------------------------
- lOption可選. 長整型值, 用於指示 strSQL 參數的類型. 可為下
列常量之一.
[常量][說明]
-------------------------------------------------
adCmdText指示strSQL為命令文本, 即普通的SQL語句.
adCmdTable指示ADO生成SQL查詢返回以 strSQL 命名的表中的
所有行.
adCmdTableDirect指示所作的更改在strSQL中命名的表中返回所有行.
adCmdStoredProc指示strSQL為存儲過程.
adCmdUnknown指示strSQL參數中的命令類型為未知.
adCmdFile指示應從在strSQL中命名的文件中恢復保留(保存的)
Recordset.
adAsyncExecute指示應非同步執行strSQL.
adAsyncFetch指示在提取 Initial Fetch Size 屬性中指定的初始
數量後, 應該非同步提取所有剩餘的行. 如果所需的行尚未
提取, 主要的線程將被堵塞直到行重新可用.
adAsyncFetchNonBlocking 指示主要線程在提取期間從未堵塞. 如果所請求
的行尚未提取, 當前行自動移到文件末尾.
==========================================================================*/
BOOL CAdoRecordSet::Open(LPCTSTR strSQL, long lOption, CursorTypeEnum CursorType, LockTypeEnum LockType)
{
ASSERT(m_pConnection != NULL);
ASSERT(m_pRecordset != NULL);
ASSERT(AfxIsValidString(strSQL));
if(_tcscmp(strSQL, _T("")) != 0)
{
m_strSQL = strSQL;
}
if (m_pConnection == NULL || m_pRecordset == NULL)
{
return FALSE;
}
if (m_strSQL.IsEmpty())
{
ASSERT(FALSE);
return FALSE;
}
try
{
if (IsOpen()) Close();
return SUCCEEDED(m_pRecordset->Open(_variant_t(LPCTSTR(m_strSQL)),
_variant_t((IDispatch*)m_pConnection->GetConnection(), true),
CursorType, LockType, lOption));
}
catch (_com_error e)
{
TRACE(_T("Warning: 打開記錄集發生異常. 錯誤信息: %s; 文件: %s; 行: %d\n"), e.ErrorMessage(), __FILE__, __LINE__);
TRACE(_T("%s\r\n"), GetLastError());
return FALSE;
}
}

如果你要確定信息執行完,可以設置為adConnectUnspecified模式,他是阻塞的,等他執行完後才會返回。這樣你就可以確定了

⑺ vc中怎麼連接SqlServer

以下給出一個Visual C++下使用ADO的Connection對象及其Record set對象的基本步驟:

(1) 使用import指令引入ADO2組件

例:#import "C:\ADO\msado15.dll" no_namespace rename("EOF", "EndOfFile")

(2) 定義CADORecordBinding 的派生類,用於程序與資料庫表欄位的交互,該類的定義可參見icrsint.h。

例:

class CIntlive : public CADORecordBinding
{
public:
DBTIMESTAMP m_datetime; //定義ADO記錄集欄位變數(與資料庫表欄位相對應)
long m_key;
long m_value;
long m_quality;
WORD m_stsdatetime; //定義ADO記錄集狀態變數
WORD m_stskey;
WORD m_stsvalue;
WORD m_stsquality;
BEGIN_ADO_BINDING(CIntlive) //將資料庫欄位與ADO記錄集欄位變數綁定
ADO_VARIABLE_LENGTH_ENTRY2(1,adDBTimeStamp,m_datetime,sizeof(m_datetime),m_stsdatetime,true)
ADO_NUMERIC_ENTRY(2,adInteger,m_key,10,0,m_stskey,true)
ADO_NUMERIC_ENTRY(3,adInteger,m_value,10,0,m_stsvalue,true)
ADO_NUMERIC_ENTRY(4,adInteger,m_quality,10,0,m_stsquality,true)
END_ADO_BINDING()
};

(3) 調用CoInitialize初始化COM ::CoInitialize(NULL);

(4) 聲明ADO的Connection對象指針和Recordset對象指針並初始化。(類型名在 msado15.dll中已定義)

例:

_ConnectionPtr pConnection1 = NULL;
_RecordsetPtr rstADO1 = NULL;

(5) 定義CADORecordBinding派生類的實例及其Bind介面指針。

例:

CIntlive m_intdata;
IADORecordBinding *rstADOBind1 = NULL;

(6) 產生Connection對象實例和Record set對象實例。

例:

pConnection1.CreateInstance(_uuidof(Connection));
rstADO1.CreateInstance(__uuidof(Recordset)) ;

(7) 連接到資料庫並打開Record set對象,其中open函數的參數的使用方法可參見微軟MSDN中ADO 相應對象參數的Basic描述。

例:

PConnection1->Open("driver={SQL server};server=servera;uid=sa;pwd=;database=pubs","","",NULL);
rstADO1->Open("data", _variant_t((IDispatch *)pConnection1,true),
adOpenKeyset,adLockBatchOptimistic, adCmdTable);

(8) 將CADORecordBinding派生類的實例聯編到Record set對象的Bind介面。

例:

RstADOBind1->BindToRecordset(&m_intdata);

(9) 對Record set對象實例進行操作。操作方法可參見微軟MSDN中ADO Record set對象相應方法的Basic描述。

例:

rstADO1->Move Next(); //移動游標到下一條記錄
rstADO1->Update(_variant_t("quality"),_variant_t("3"))); //修改記錄的quality欄位的值為3
rstADO1->Update Batch(adAffectAll)); //將在Record set對象上的所有更新一次送入資料庫

(10) 關閉Record set對象並釋放Bind介面。

例:

RstADO1->Close();
RstADOBind2->Release();

(11) 關閉連接 pConnection1->Close();

(12) 調用CoUnitialize釋放COM資源 ::CoUninitialize();

⑻ MFC用ado方法和資料庫連接後,怎麼取得數據(高加分)

ADO第一次親密接觸 -- 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中的HeaderFiles里找到)
#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:阻止其它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("DataSource=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中的許多內容還沒有介紹,下次我們將詳細介紹Recordset對象的屬性、方法並解決幾個關鍵的技術:綁定方式處理記錄集數據、存儲過程的調用、事務處理、圖象在資料庫中的保存與讀取、與表格控制項的配合使用等。