VC中運用ADO共同完成數據庫的設置

ADO是應用層的編程接口,它通過OLE DB提供的COM接口訪問數據,它適合于各種客戶機/服務器應用系統和基于Web的應用,尤其在一些腳本語言中訪問數據庫操作是ADO的主要優勢。ADO是一套用自動化技術建立起來的對象層次結構,它比其他的一些對象模型如DAO(Data Access Object)、RDO(Remote Data Object)等具有更好的靈活性,使用更為方便,并且訪問數據的效率更高。SQL是強大的數據庫操作系統，通過ADO和SQL語句的配合，我們可以的實現對數據庫的一系列操作，例如創建數據庫、創建表、創建索引，實現數據庫的多重查詢、高級查詢和數據的匯總等技術。下面通過例程介紹如何通過ADO和SQL語句的配合實現對數據庫的操作。

　　第一步：通過Access創建數據庫test.mdb。

　　第二步：創建單文檔工程testado，所有的選項都取默認值。

　　第三步：COM庫的初始化

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

　　BOOL CADOTest1App::InitInstance()
　　　{
　　　　AfxOleInit();
　　　　......

　　第四步：用#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庫。

　　第五步：在testadoview.h中定義一個指向Connection對象的指針:_ConnectionPtr _pConnection;

　　第六步：添加如下代碼：

void CTestadoView::OnInitialUpdate()
{
CView::OnInitialUpdate();
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對象并將其釋放，代碼如下：

CTestadoView::~CTestadoView()
{
m_pConnection->Close();
m_pConnection.Release();
}


　　第八步：添加菜單項"創建數據庫表"，并添加相應的消息處理函數，然后添加代碼如下：

void CTestadoView::OnAddtable()
{
_variant_t RecordsAffected;
m_pConnection->Execute("CREATE TABLE new(ID INTEGER,username TEXT,old INTEGER)",&RecordsAffected,adCmdText);
}


　　運行程序，執行菜單當中的命令"添加表"，我們可以發現數據庫中已經添加了一個表new，其中的字段有我們定義的字段。

　　第九步：添加菜單項"刪除數據庫表"，并添加相應的消息處理函數，然后添加代碼如下：

void CTestadoView::OnDeleteTable()
{
_variant_t RecordsAffected;
m_pConnection->Execute("DROP TABLE new",&RecordsAffected,adCmdText);
}


　　運行程序，執行菜單當中的命令"刪除表"，我們可以發現數據庫中剛才添加的表new已被刪除。

　　第十步：添加菜單項"添加一列"，并添加相應的消息處理函數，然后添加代碼如下：

void CTestadoView::OnAddColumn()
{
_variant_t RecordsAffected;
m_pConnection->Execute("ALTER TABLE new ADD newcolumn1 INTEGER",&RecordsAffected,adCmdText);
}


　　運行程序，執行菜單當中的命令"添加一列"，我們可以發現數據庫中剛才添加的表new中已添加了一個新列。

　　第十一步：添加菜單項"刪除一列"，并添加相應的消息處理函數，然后添加代碼如下：

void CTestadoView::OnAddColumn()
{
_variant_t RecordsAffected;
m_pConnection->Execute("ALTER TABLE new ADD newcolumn1 INTEGER",&RecordsAffected,adCmdText);
}


　　運行程序，執行菜單當中的命令"刪除一列"，我們可以發現數據庫中剛才添加的表new中的新列已被刪除。

　　第十二步：添加菜單項"添加記錄"，并添加相應的消息處理函數，然后添加代碼如下：

void CTestadoView::OnAddRecord()
{
_variant_t RecordsAffected;
for(int i = 1;i < 10; i ++)
{
CString strSQL;
strSQL.Format("INSERT INTO new(ID,username,old) VALUES (%d, 'Washington',%d)",i,i*9);
m_pConnection->Execute((_bstr_t)strSQL,&RecordsAffected,adCmdText);
}


　　運行程序，執行菜單當中的命令"添加記錄"，我們可以發現數據庫中剛才添加的表new中添加了九條新的記錄。

　　第十三步：添加菜單項"old字段加1"，并添加相應的消息處理函數，然后添加代碼如下：

void CTestadoView::OnOldAddone()
{
_variant_t RecordsAffected;
m_pConnection->Execute("UPDATE new SET old = old+1",&RecordsAffected,adCmdText);
}}

　　運行程序，執行菜單當中的命令"old記錄加1"，我們可以發現數據庫中剛才添加的表new中的九條新的記錄的old字段都自動加1。

　　第十四步：添加菜單項"統計記錄數目"，并添加相應的消息處理函數，然后添加代碼如下：

void CTestadoView::OnTotalRecords()
{
_RecordsetPtr m_pRecordset;
_variant_t RecordsAffected;
m_pRecordset =m_pConnection->Execute("SELECT COUNT(*) FROM new where ID > 0",&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);///顯示當前記錄條數
}

　　運行程序，執行菜單當中的命令"統計記錄數目"，我們可以得到數據庫中記錄的數目。

　　第十五步：添加菜單項"設置ID為索引"，并添加相應的消息處理函數，然后添加代碼如下：

void CTestadoView::OnSetIdIndex()
{
_variant_t RecordsAffected;
m_pConnection->Execute("CREATE UNIQUE INDEX id ON new(ID)",&RecordsAffected,adCmdText);
}

　　運行程序，執行菜單當中的命令"設置ID為索引"，我們可以發現數據庫中ID被設置為索引。

　　第十六步：添加菜單項"數據匯總"、"old字段的總和"、"old字段的均值"、"old的最小值"、"old字段的最大值"，并添加相應的消息處理函數，然后添加代碼如下：

void CTestadoView::OnOldMax()
{
_RecordsetPtr m_pRecordset;
_variant_t RecordsAffected;
m_pRecordset =m_pConnection->Execute("select MAX(old) from new",&RecordsAffected,adCmdText);
_variant_t vIndex = (long)0;
_variant_t vCount = m_pRecordset->GetCollect(vIndex);
///取得第一個字段的值放入vCount變量
m_pRecordset->Close();///關閉記錄集
m_pRecordset.Release();
CString Message;
Message.Format("最大值是%d",vCount.lVal);
AfxMessageBox(Message);
}
void CTestadoView::OnOldMin()
{
_RecordsetPtr m_pRecordset;
_variant_t RecordsAffected;
m_pRecordset =m_pConnection->Execute("select MIN(old) from new",&RecordsAffected,adCmdText);
_variant_t vIndex = (long)0;
_variant_t vCount = m_pRecordset->GetCollect(vIndex);
///取得第一個字段的值放入vCount變量
m_pRecordset->Close();///關閉記錄集
m_pRecordset.Release();
CString Message;
Message.Format("最小值是%d",vCount.lVal);
AfxMessageBox(Message);
}

void CTestadoView::OnOldTotal()
{
_RecordsetPtr m_pRecordset;
_variant_t RecordsAffected;
m_pRecordset =m_pConnection->Execute("select SUM(old) from new",&RecordsAffected,adCmdText);
_variant_t vIndex = (long)0;
_variant_t vCount = m_pRecordset->GetCollect(vIndex);
///取得第一個字段的值放入vCount變量
m_pRecordset->Close();///關閉記錄集
m_pRecordset.Release();
CString Message;
Message.Format("總和是%d",(long)vCount);
AfxMessageBox(Message);
}

void CTestadoView::OnOldAverage()
{
_RecordsetPtr m_pRecordset;
_variant_t RecordsAffected;
m_pRecordset =m_pConnection->Execute("select AVG(old) from new",&RecordsAffected,adCmdText);
_variant_t vIndex = (long)0;
_variant_t vCount = m_pRecordset->GetCollect(vIndex);
///取得第一個字段的值放入vCount變量
m_pRecordset->Close();///關閉記錄集
m_pRecordset.Release();
CString Message;
Message.Format("平均值是%d",(long)vCount);
AfxMessageBox(Message);
}}

　　運行程序，執行菜單當中的匯總命令，我們可以得到相關的匯總信息。