在需要對數據庫進行操作時，OLE DB總是被認為是一種效率最高但最難的方法。但是以我最近使用OLE DB的經驗看來，OLE DB的效率高則高矣，但卻一點都不難。說它難恐怕主要是因為可參考的中文資料太少，為了幫助以后需要接觸OLE DB的同行，我撰寫了這篇文章。本文包含如下內容：

　　1. OLE DB寫數據庫；
　　2. OLE DB讀數據庫；
　　3. OLE DB對二進制數據(text、ntext、image等)的處理。

　　首先來看看對SQL Server進行寫操作的代碼，有一定VC基礎的讀者應該可以很順利地看懂。OLE DB寫數據庫，就是這么簡單！

　　注:
　　1.以下代碼中使用的模板類EAutoReleasePtr與ATL中的CComPtr類似，是一個在析構時自動調用Release的類。CComPtr的代碼在ATLBASE.H中定義。
　　2.以下代碼均在UNICODE環境下編譯，因為執行的SQL語句必須是UNICODE的。設置工程為UNICODE的方法是:首先在project->settings->C/C++的屬性頁中的Preprocessor中，刪除_MBCS寫入UNICODE,_UNICODE。然后在link屬性頁中Category中選擇output，在Entry-Point symbol 中添加wWinMainCRTStartup。

　　EAutoReleasePtr pIDBInitialize;
　　HRESULT hResult = ConnectDatabase( &pIDBInitialize, _T("127.0.0.1"), _T(“sa”), _T("password") );
　　if( FAILED( hResult ) )
　　{
　　//失敗，可能是因為數據庫沒有啟動、用戶名密碼錯等等
　　return;
　　}

　　EAutoReleasePtr pIOpenRowset;
　　hResult = CreateSession( pIDBInitialize, &pIOpenRowset );
　　if( FAILED( hResult ) )
　　{
　　//出錯
　　return;
　　}

　　EAutoReleasePtr pICommand;
　　EAutoReleasePtr pICommandText;
　　hResult = CreateCommand( pIOpenRowset, &pICommand, &pICommandText );
　　if( FAILED( hResult ) )
　　{
　　//出錯
　　return;
　　}

　　hResult = ExecuteSQL( pICommand, pICommandText, _T("USE PBDATA") );
　　if( FAILED( hResult ) )
　　{
　　//如果這里失敗，那就是SQL語句執行失敗。在此處，就是PBDATA還未創建
　　return;
　　}

　　// 創建表
　　ExecuteSQL( pICommand, pICommandText, _T("CREATE TABLE 2005_1(Volume real NOT NULL,ID int NOT NULL IDENTITY)") );

　　// 添加記錄
　　ExecuteSQL( pICommand, pICommandText, _T("INSERT INTO 2005_1 VALUES(100.0)") );

　　//...

　　其中幾個函數的代碼如下:

　　HRESULT ConnectDatabase( IDBInitialize** ppIDBInitialize, LPCTSTR pszDataSource, LPCTSTR pszUserID, LPCTSTR pszPassword )
　　{
　　ASSERT( ppIDBInitialize != NULL && pszDataSource != NULL && pszUserID != NULL && pszPassword != NULL );

　　UINT uTimeout ＝ 15U; // 連接數據庫超時（秒）
　　TCHAR szInitStr[1024];
　　VERIFY( 1023 >= wsprintf( szInitStr, _T("Provider=SQLOLEDB;Data Source=%s;Initial Catalog=master;User Id=%s;Password=%s;Connect Timeout=%u"), pszDataSource, pszUserID, pszPassword, uTimeout ) );
　　//Initial Catalog=master指明連接成功后，"USE master"。

　　EAutoReleasePtr pIDataInitialize;
　　HRESULT hResult = ::CoCreateInstance( CLSID_MSDAINITIALIZE, NULL, CLSCTX_INPROC_SERVER,
　　IID_IDataInitialize, ( void** )&pIDataInitialize );
　　if( FAILED( hResult ) )
　　{
　　return hResult;
　　}

　　EAutoReleasePtr pIDBInitialize;
　　hResult = pIDataInitialize->GetDataSource( NULL, CLSCTX_INPROC_SERVER, ( LPCOLESTR )szInitStr,
　　IID_IDBInitialize, ( IUnknown** )&pIDBInitialize );
　　if( FAILED( hResult ) )
　　{
　　return hResult;
　　}
　　hResult = pIDBInitialize->Initialize( );
　　if( FAILED( hResult ) )
　　{
　　return hResult;
　　}
　　* ppIDBInitialize = pIDBInitialize.Detach( );
　　return S_OK;
　　}

　　HRESULT CreateSession( IDBInitialize* pIDBInitialize, IOpenRowset** ppIOpenRowset )
　　{
　　ASSERT( pIDBInitialize != NULL && ppIOpenRowset != NULL );
　　EAutoReleasePtr pSession;
　　HRESULT hResult = pIDBInitialize->QueryInterface( IID_IDBCreateSession, ( void** )&pSession );
　　if( FAILED( hResult ) )
　　{
　　return hResult;
　　}
　　EAutoReleasePtr pIOpenRowset;
　　hResult = pSession->CreateSession( NULL, IID_IOpenRowset, ( IUnknown** )&pIOpenRowset );
　　if( FAILED( hResult ) )
　　{
　　return hResult;
　　}
　　* ppIOpenRowset = pIOpenRowset.Detach( );
　　return S_OK;
　　}

　　HRESULT CreateCommand( IOpenRowset* pIOpenRowset, ICommand** ppICommand, ICommandText** ppICommandText )
　　{
　　ASSERT( pIOpenRowset != NULL && ppICommand != NULL && ppICommandText != NULL );
　　HRESULT hResult;
　　EAutoReleasePtr pICommand;
　　{
　　EAutoReleasePtr pICreateCommand;
　　hResult = pIOpenRowset->QueryInterface( IID_IDBCreateCommand, ( void** )&pICreateCommand );
　　if( FAILED( hResult ) )
　　{
　　return hResult;
　　}

　　hResult = pICreateCommand->CreateCommand( NULL, IID_ICommand, (IUnknown**)&pICommand );
　　if( FAILED( hResult ) )
　　{
　　return hResult;
　　}
　　}
　　EAutoReleasePtr pICommandText;
　　hResult = pICommand->QueryInterface( &pICommandText );
　　if( FAILED( hResult ) )
　　{
　　return hResult;
　　}
　　* ppICommand = pICommand.Detach( );
　　* ppICommandText = pICommandText.Detach( );
　　return S_OK;
　　}

　　HRESULT ExecuteSQL( ICommand* pICommand, ICommandText* pICommandText, LPCTSTR pszCommand, LONG* plRowsAffected )
　　{
　　ASSERT( pICommand != NULL && pICommandText != NULL && pszCommand != NULL && pszCommand[0] != 0 );

　　HRESULT hResult = pICommandText->SetCommandText( DBGUID_DBSQL, ( LPCOLESTR )pszCommand );
　　if( FAILED( hResult ) )
　　{
　　return hResult;
　　}
　　LONG lAffected;
　　hResult = pICommand->Execute( NULL, IID_NULL, NULL, plRowsAffected == NULL ? &lAffected : plRowsAffected, ( IUnknown** )NULL );
　　return hResult;
　　}

[1] [2] [3] [4]  下一頁