• <ins id="pjuwb"></ins>
    <blockquote id="pjuwb"><pre id="pjuwb"></pre></blockquote>
    <noscript id="pjuwb"></noscript>
          <sup id="pjuwb"><pre id="pjuwb"></pre></sup>
            <dd id="pjuwb"></dd>
            <abbr id="pjuwb"></abbr>
            ADO 是目前在Windows環境中比較流行的客戶端數據庫編程技術。ADO是建立在OLE DB底層技術之上的高級編程接口,因而它兼具有強大的數據處理功能(處理各種不同類型的數據源、分布式的數據處理等等)和極其簡單、易用的編程接口,因而得到了廣泛的應用。而且按微軟公司的意圖,OLE DB和ADO將逐步取代 ODBC和DAO。現在介紹ADO各種應用的文章和書籍有很多,本文著重站在初學者的角度,簡要探討一下在VC++中使用ADO編程時的一些問題。我們希望閱讀本文之前,您對ADO技術的基本原理有一些了解。
            一、在VC++中使用ADO編程
            ADO實際上就是由一組Automation對象構成的組件,因此可以象使用其它任何Automation對象一樣使用ADO。ADO中最重要的對象有三個:Connection、Command和Recordset,它們分別表示連接對象、命令對象和記錄集對象。如果您熟悉使用MFC中的ODBC類(CDatabase、CRecordset)編程,那么學習ADO編程就十分容易了。
            使用ADO編程時可以采用以下三種方法之一:
            1、使用預處理指令#import
            #import "C:\Program Files\Common Files\System\ADO\msado15.dll" \
               no_namespace rename("EOF", "EndOfFile")
            但要注意不能放在stdAfx.h文件的開頭,而應該放在所有include指令的后面。否則在編譯時會出錯。
            程序在編譯過程中,VC++會讀出msado15.dll中的類型庫信息,自動產生兩個該類型庫的頭文件和實現文件msado15.tlh和msado15.tli(在您的Debug或Release目錄下)。在這兩個文件里定義了ADO的所有對象和方法,以及一些枚舉型的常量等。我們的程序只要直接調用這些方法就行了,與使用MFC中的COleDispatchDriver類調用Automation對象十分類似。
            2、使用MFC中的CIDispatchDriver
            就是通過讀取msado15.dll中的類型庫信息,建立一個COleDispatchDriver類的派生類,然后通過它調用ADO對象。
            3、直接用COM提供的API
             如使用如下代碼:
             CLSID clsid;
             HRESULT hr = ::CLSIDFromProgID(L"ADODB.Connection", &clsid);
             if(FAILED(hr))
             {...}
             ::CoCreateInstance(clsid, NULL, CLSCTX_SERVER, IID_IDispatch, (void **)
                  &pDispatch);
             if(FAILED(hr))
             {...}
            以上三種方法,第一和第二種類似,可能第一種好用一些,第三種編程可能最麻煩。但可能第三種方法也是效率最高的,程序的尺寸也最小,并且對ADO的控制能力也最強。
            據微軟資料介紹,第一種方法不支持方法調用中的默認參數,當然第二種方法也是這樣,但第三種就不是這樣了。采用第三種方法的水平也最高。當你需要繞過ADO而直接調用OLE DB底層的方法時,就一定要使用第三種方法了。
            ADO編程的關鍵,就是熟練地運用ADO提供的各種對象(object)、方法(method)、屬性(property)和容器(collection)。另外,如果是在MS SQL或Oracle等大型數據庫上編程,還要能熟練使用SQL語言。
            二、使用#import方法的編程步驟
            這里建議您使用#import的方法,因為它易學、易用,代碼也比較簡潔。
            1、 添加#import指令
            打開stdafx.h文件,將下列內容添加到所有的include指令之后:
            #include <icrsint.h>   //Include support for VC++ Extensions
            #import "C:\Program Files\Common Files\System\ADO\msado15.dll" \
               no_namespace rename("EOF", "adoEOF")
            其中icrsint.h文件包含了VC++擴展的一些預處理指令、宏等的定義,用于COM編程時使用。
            2、定義_ConnectionPtr型變量,并建立數據庫連接
            建立了與數據庫服務器的連接后,才能進行其他有關數據庫的訪問和操作。ADO使用Connection對象來建立與數據庫服務器的連接,所以它相當于MFC中的CDatabase類。和CDatabase類一樣,調用Connection對象的Open方法即可建立與服務器的連接。
            數據類型 _ConnectionPtr實際上就是由類模板_com_ptr_t而得到的一個具體的實例類,其定義可以到msado15.tlh、comdef.h 和comip.h這三個文件中找到。在msado15.tlh中有:
            _COM_SMARTPTR_TYPEDEF(_Collection, __uuidof(_Collection));
            經宏擴展后就得到了_ConnectionPtr類。_ConnectionPtr類封裝了Connection對象的Idispatch接口指針,及一些必要的操作。我們就是通過這個指針來操縱Connection對象。類似地,后面用到的_CommandPtr和_RecordsetPtr類型也是這樣得到的,它們分別表示命令對象指針和記錄集對象的指針。
            (1)、連接到MS SQL Server
            注意連接字符串的格式,提供正確的連接字符串是成功連接到數據庫服務器的第一步,有關連接字符串的詳細信息參見微軟MSDN Library光盤。
            本例連接字符串中的server_name,database_name,user_name和password在編程時都應該替換成實際的內容。
             _ConnectionPtr pMyConnect=NULL;
             HRESULT hr=pMyConnect.CreateInstance(__uuidof(Connection)));
             if(FAILED(hr))return;
            _bstr_t strConnect="Provider=SQLOLEDB; Server=server_name;"
              "Database=database_name; uid=user_name; pwd=password;"; 
            //connecting to the database server now:
             try{pMyConnect->Open(strConnect,"","",NULL);}
             catch (_com_error &e)
             {
              ::MessageBox(NULL,e.Description(),"警告",MB_OK | MB_ICONWARNING);
             }

            注意Connection對象的Open方法中的連接字符串參數必須是BSTR或_bstr_t類型。另外,本例是直接通過OLE DB Provider建立連接,所以無需建立數據源。
            (2)、通過ODBC Driver連接到Database Server
            連接字符串格式與直接用ODBC編程時的差不多:
            _bstr_t strConnect="DSN=datasource_name; Database=database_name; uid=user_name; pwd=password;";
            此時與ODBC編程一樣,必須先建立數據源。
            3、定義_RecordsetPtr型變量,并打開數據集
            定義_RecordsetPtr型變量,然后通過它調用Recordset對象的Open方法,即可打開一個數據集。所以Recordset對象與MFC中的CRecordset類類似,它也有當前記錄、當前記錄指針的概念。如:
             _RecordsetPtr m_pRecordset;
             if(!FAILED(m_pRecordset.CreateInstance( __uuidof( Recordset )))
             {
              m_pDoc->m_initialized=FALSE;
              return;
             }
            try{
              m_pRecordset->Open(_variant_t("mytable"),
                        _variant_t((IDispatch *)pMyConnect,true), adOpenKeyset,
                        adLockOptimistic, adCmdTable);
             }
             catch (_com_error &e)
             {
              ::MessageBox(NULL,"無法打開mytable表。","提示",
            MB_OK | MB_ICONWARNING);
             }
            Recordset對象的Open方法非常重要,它的第一個參數可以是一個SQL語句、一個表的名字或一個命令對象等等;第二個參數就是前面建立的連接對象的指針。此外,用Connection和Command對象的Execute方法也能得到記錄集,但是只讀的。
            4、讀取當前記錄的數據
            我認為讀取數據的最方便的方法如下:
             try{
              m_pRecordset->MoveFirst();  
              while(m_pRecordset->adoEOF==VARIANT_FALSE) 
              {
               //Retrieve column's value: 
               CString sName=(char*)(_bstr_t)(m_pRecordset->Fields->GetItem
                (_variant_t("name"))->Value);
               short cAge=(short)(m_pRecordset->Fields->GetItem
                (_variant_t("age"))->Value);
               //Do something what you want to do:
               ......
               m_pRecordset->MoveNext();   
              }
             }//try
             catch (_com_error &e)
             {
              CString str=(char*)e.Description();
              ::MessageBox(NULL,str+"\n又出毛病了。","提示",
            MB_OK | MB_ICONWARNING);
             }

            本例中的name和age都是字段名,讀取的字段值分別保存在sName和cAge變量內。例中的Fields是Recordset對象的容器,GetItem方法返回的是Field對象,而Value則是Field對象的一個屬性(即該字段的值)。通過此例,應掌握操縱對象屬性的方法。例如,要獲得Field 對象的Value屬性的值可以直接用屬性名Value來引用它(如上例),但也可以調用Get方法,例如:
            CString sName=(char*)(_bstr_t)(m_pRecordset->Fields->GetItem
                (_variant_t("name"))->GetValue());
            從此例還可以看到,判斷是否到達記錄集的末尾,使用記錄集的adoEOF屬性,其值若為真即到了結尾,反之則未到。判斷是否到達記錄集開頭,則可用BOF屬性。
            另外,讀取數據還有一個方法,就是定義一個綁定的類,然后通過綁定的變量得到字段值(詳見后面的介紹)。
            5、修改數據
            方法一:
             try{
              m_pRecordset->MoveFirst();  
              while(m_pRecordset->adoEOF==VARIANT_FALSE) 
              {   
               m_pRecordset->Fields->GetItem
                (_variant_t("姓名"))->Value=_bstr_t("趙薇");
               ......
               m_pRecordset->Update();www.chinai tp 采吧采吧不是罪 ow er.comJuJIe

               m_pRecordset->MoveNext();   
              }
             }//try
            改變了Value屬性的值,即改變了字段的值。
            方法二:
              m_pRecordset->Fields->GetItem
                (_variant_t("姓名"))->PutValue(_bstr_t("趙薇"));
            方法三:就是用定義綁定類的方法(詳見后面的介紹)。
            6、添加記錄
            新記錄添加成功后,即自動成為當前記錄。AddNew方法有兩種形式,一個含有參數,而另一個則不帶參數。
            方法一(不帶參數):
             // Add new record into this table:
             try{
              if(!m_pRecordset->Supports(adAddNew)) return;www.chinai tp 采吧采吧不是罪 ow er.comJuJIe

              m_pRecordset->AddNew(); 
              m_pRecordset->Fields->GetItem
               (_variant_t("姓名"))->Value=_bstr_t("趙薇");
              m_pRecordset->Fields->GetItem
               (_variant_t("性別"))->Value=_bstr_t("女");
              m_pRecordset->Fields->GetItem
               (_variant_t("age"))->Value=_variant_t((short)20);
              m_pRecordset->Fields->GetItem
               (_variant_t("marry"))->Value=_bstr_t("未婚");
              m_pRecordset->Update();  
             }//try
             catch (_com_error &e)
             {
              ::MessageBox(NULL, "又出毛病了。","提示",MB_OK | MB_ICONWARNING);
             }
            這種方法弄完了還要調用Update()。
            方法二(帶參數):
              _variant_t varName[4],narValue[4];
              varName[0] = L"姓名";
              varName[1] = L"性別";
              varName[2] = L"age";
              varName[3] = L"marry";
              narValue[0]=_bstr_t("趙薇");
              narValue[1]=_bstr_t("女");
              narValue[2]=_variant_t((short)20);
              narValue[3]=_bstr_t("未婚");www.chinai tp 采吧采吧不是罪 ow er.comJuJIe

              const int nCrit = sizeof varName / sizeof varName[0];
              // Create SafeArray Bounds and initialize the array
              SAFEARRAYBOUND rgsaName[1],rgsaValue[1];
              rgsaName[0].lLbound = 0;  
              rgsaName[0].cElements = nCrit;
              SAFEARRAY *psaName = SafeArrayCreate( VT_VARIANT, 1, rgsaName );
              rgsaValue[0].lLbound = 0;
              rgsaValue[0].cElements = nCrit;
              SAFEARRAY *psaValue = SafeArrayCreate( VT_VARIANT, 1, rgsaValue );
              // Set the values for each element of the array
              HRESULT hr1=S_OK.hr2=S_OK;
              for( long i = 0 ; i < nCrit && SUCCEEDED( hr1 ) && SUCCEEDED( hr2 );i++)  
              {     
               hr1=SafeArrayPutElement(psaName, &i,&varName[i]);
               hr2=SafeArrayPutElement(psaValue, &i,&narValue[i]);       }
              
              // Initialize and fill the SafeArray
              VARIANT vsaName,vsaValue;  
              vsaName.vt = VT_VARIANT | VT_ARRAY;
              vsaValue.vt = VT_VARIANT | VT_ARRAY;
              V_ARRAY(&vsaName) = psaName;//&vsaName->parray=psaName;
               //see definition in oleauto.h file.
              V_ARRAY(&vsaValue) = psaValue;
               
              // Add a new record:
              m_pRecordset->AddNew(vsaName,vsaValue);
            這種方法不需要調用Update,因為添加后,ADO會自動調用它。此方法主要是使用SafeArray挺麻煩。
            方法三:就是用定義綁定類的方法(詳見后面的介紹)。
            7、刪除記錄
            調用Recordset的Delete方法就行了,刪除的是當前記錄。要了解Delete的其它用法請查閱參考文獻。
             try{
              m_pRecordset->MoveFirst();  
              while(m_pRecordset->adoEOF==VARIANT_FALSE) 
              {
               CString sName=(char*)(_bstr_t)(m_pRecordset->Fields->GetItem
                (_variant_t("姓名"))->Value);
               if(::MessageBox(NULL,"姓名="+sName+"\n刪除她嗎?",
                "提示",MB_YESNO | MB_ICONWARNING)==IDYES)
               {
                m_pRecordset->Delete(adAffectCurrent);   
                m_pRecordset->Update();
               }
               m_pRecordset->MoveNext();   
              }
             }//try
             catch (_com_error &e)
             {
              ::MessageBox(NULL,"又出毛病了。","提示",MB_OK | MB_ICONWARNING);
             }
            8、使用帶參數的命令
            Command對象所代表的就是一個Provider能夠理解的命令,如SQL語句等。使用Command對象的關鍵就是把表示命令的語句設置到CommandText屬性中,然后調用Command對象的Execute方法就行了。一般情況下在命令中無需使用參數,但有時使用參數,可以增加其靈活性和效率。
            (1). 建立連接、命令對象和記錄集對象
            本例中表示命令的語句就是一個SQL語句(SELECT語句)。SELECT語句中的問號?就代表參數,如果要多個參數,就多放幾個問號,每個問號代表一個參數。
            _ConnectionPtr  Conn1;
            _CommandPtr     Cmd1;
            ParametersPtr   *Params1 = NULL;   // Not an instance of a smart pointer.
            _ParameterPtr   Param1;
            _RecordsetPtr   Rs1;www.chinai tp 采吧采吧不是罪 ow er.comJuJIe

            try
            {
             // Create Connection Object (1.5 Version)
             Conn1.CreateInstance( __uuidof( Connection ) );
             Conn1->ConnectionString = bstrConnect;
                Conn1->Open( bstrEmpty, bstrEmpty, bstrEmpty, -1 );
                // Create Command Object
                Cmd1.CreateInstance( __uuidof( Command ) );
                Cmd1->ActiveConnection = Conn1;
                Cmd1->CommandText  = _bstr_t("SELECT * FROM mytable WHERE age< ?");
            }//try
            要注意命令對象必須與連接對象關聯起來才能起作用,本例中將命令對象的ActiveConnection屬性設置為連接對象的指針,即為此目的:
            Cmd1->ActiveConnection = Conn1;
             (2). 創建參數對象,并給參數賦值
            // Create Parameter Object
            Param1 = Cmd1->CreateParameter( _bstr_t(bstrEmpty),
                   adInteger,
                   adParamInput,
                   -1,
                    _variant_t( (long) 5) );
            Param1->Value = _variant_t( (long) 5 );
            Cmd1->Parameters->Append( Param1 );
            用命令對象的方法來創建一個參數對象,其中的長度參數(第三個)如果是固定長度的類型,就填-1,如果是字符串等可變長度的就填其實際長度。Parameters是命令對象的一個容器,它的Append方法就是把創建的參數對象追加到該容器里。Append進去的參數按先后順序與SQL語句中的問號從左至右一一對應。
            (3). 執行命令打開記錄集
            // Open Recordset Object
            Rs1 = Cmd1->Execute( &vtEmpty, &vtEmpty2, adCmdText );
            但要注意,用Command和Connection對象的Execute方法得到的Recordset是只讀的。因為在打開Recordset之前,我們無法設置它的LockType屬性(其默認值為只讀)。而在打開之后設置LockType不起作用。
            我發現用上述方法得到記錄集Rs1后,不但Rs1中的記錄無法修改,即使直接用SQL語句修改同一表中任何記錄都不行。
            要想能修改數據,還是要用Recordset自己的Open方法才行,如:
             try{
               m_pRecordset->Open((IDispatch *) Cmd1, vtMissing,
                adOpenStatic, adLockOptimistic, adCmdUnspecified);
              }
              catch (_com_error &e)
              {
               ::MessageBox(NULL,"mytable表不存在。","提示",MB_OK | MB_ICONWARNING);
              }
            Recordset對象的Open方法真是太好了,其第一個參數可以是SQL語句、表名字、命令對象指針等等。
            9、響應ADO的通知事件
            通知事件就是當某個特定事件發生時,由Provider通知客戶程序,換句話說,就是由Provider調用客戶程序中的一個特定的方法(即事件的處理函數)。所以為了響應一個事件,最關鍵的就是要實現事件的處理函數。
            (1). 從ConnectionEventsVt接口派生出一個類
            為了響應_Connection的通知事件,應該從ConnectionEventsVt接口派生出一個類:
            class CConnEvent : public ConnectionEventsVt
            {
            private:
                  ULONG   m_cRef;
            public:
                  CConnEvent() { m_cRef = 0; };
                  ~CConnEvent() {};www.chinai tp 采吧采吧不是罪 ow er.comJuJIe

                  STDMETHODIMP QueryInterface(REFIID riid, void ** ppv);
                  STDMETHODIMP_(ULONG) AddRef(void);
                  STDMETHODIMP_(ULONG) Release(void);
                  STDMETHODIMP raw_InfoMessage(
                     struct Error *pError,
                     EventStatusEnum *adStatus,
                     struct _Connection *pConnection);
                  STDMETHODIMP raw_BeginTransComplete(
                     LONG TransactionLevel,
                     struct Error *pError,
                     EventStatusEnum *adStatus,
                     struct _Connection *pConnection);
              ......
            };
            (2). 實現每一個事件的處理函數(凡是帶raw_前綴的方法都把它實現了):
            STDMETHODIMP CConnEvent::raw_InfoMessage(
                     struct Error *pError,
                     EventStatusEnum *adStatus,
                     struct _Connection *pConnection)
                     {
                     *adStatus = adStatusUnwantedEvent;
                     return S_OK;
                     };www.chinai tp 采吧采吧不是罪 ow er.comJuJIe

            有些方法雖然你并不需要,但也必須實現它,只需簡單地返回一個S_OK即可。但如果要避免經常被調用,還應在其中將adStatus參數設置為adStatusUnwantedEvent,則在本次調用后,以后就不會被調用了。
            另外還必須實現QueryInterface, AddRef, 和Release三個方法: 
             STDMETHODIMP CConnEvent::QueryInterface(REFIID riid, void ** ppv)
             {
                  *ppv = NULL;
                  if (riid == __uuidof(IUnknown) ||
                      riid == __uuidof(ConnectionEventsVt)) *ppv = this;
                  if (*ppv == NULL)
                     return ResultFromScode(E_NOINTERFACE);
                  AddRef();
                  return NOERROR;
               }
               STDMETHODIMP_(ULONG) CConnEvent::AddRef() { return ++m_cRef; };
               STDMETHODIMP_(ULONG) CConnEvent::Release()
            {
            if (0 != --m_cRef) return m_cRef;
            delete this;
            return 0;
            }
            (3). 開始響應通知事件
             // Start using the Connection events
             IConnectionPointContainer   *pCPC = NULL;
             IConnectionPoint         *pCP = NULL;www.chinai tp 采吧采吧不是罪 ow er.comJuJIe

             hr = pConn.CreateInstance(__uuidof(Connection));
               if (FAILED(hr)) return;www.chinai tp 采吧采吧不是罪 ow er.comJuJIe

             hr = pConn->QueryInterface(__uuidof(IConnectionPointContainer),
                  (void **)&pCPC);
             if (FAILED(hr)) return;
             hr = pCPC->FindConnectionPoint(__uuidof(ConnectionEvents), &pCP);
             pCPC->Release();
             if (FAILED(hr)) return;www.chinai tp 采吧采吧不是罪 ow er.comJuJIe

             pConnEvent = new CConnEvent();
               hr = pConnEvent->QueryInterface(__uuidof(IUnknown), (void **) &pUnk);
               if (FAILED(hr)) return rc;
               hr = pCP->Advise(pUnk, &dwConnEvt);
               pCP->Release();
               if (FAILED(hr)) return;www.chinai tp 采吧采吧不是罪 ow er.comJuJIe

             pConn->Open("dsn=Pubs;", "sa", "", adConnectUnspecified);
            也就是說在連接(Open)之前就做這些事。
            (4). 停止響應通知事件
             pConn->Close();
             // Stop using the Connection events
              hr = pConn->QueryInterface(__uuidof(IConnectionPointContainer),
                  (void **) &pCPC);
               if (FAILED(hr)) return;
               hr = pCPC->FindConnectionPoint(__uuidof(ConnectionEvents), &pCP);
               pCPC->Release();
               if (FAILED(hr)) return rc;
               hr = pCP->Unadvise( dwConnEvt );
               pCP->Release();
               if (FAILED(hr)) return;
            在連接關閉之后做這件事。
            10、邦定數據
            定義一個綁定類,將其成員變量綁定到一個指定的記錄集,以方便于訪問記錄集的字段值。
            (1). 從CADORecordBinding派生出一個類:
            class CCustomRs : public CADORecordBinding
            {
            BEGIN_ADO_BINDING(CCustomRs)
               ADO_VARIABLE_LENGTH_ENTRY2(3, adVarChar, m_szau_fname,
                     sizeof(m_szau_fname), lau_fnameStatus, false)
               ADO_VARIABLE_LENGTH_ENTRY2(2, adVarChar, m_szau_lname,
                     sizeof(m_szau_lname), lau_lnameStatus, false)
               ADO_VARIABLE_LENGTH_ENTRY2(4, adVarChar, m_szphone,   
                     sizeof(m_szphone),    lphoneStatus,    true)
            END_ADO_BINDING()www.chinai tp 采吧采吧不是罪 ow er.comJuJIe

            public:
               CHAR   m_szau_fname[22];
               ULONG   lau_fnameStatus;
               CHAR   m_szau_lname[42];
               ULONG   lau_lnameStatus;
               CHAR   m_szphone[14];
               ULONG   lphoneStatus;
            };
            其中將要綁定的字段與變量名用BEGIN_ADO_BINDING宏關聯起來。每個字段對應于兩個變量,一個存放字段的值,另一個存放字段的狀態。字段用從1開始的序號表示,如1,2,3等等。
            特別要注意的是:如果要綁定的字段是字符串類型,則對應的字符數組的元素個數一定要比字段長度大2(比如m_szau_fname[22],其綁定的字段au_fname的長度實際是20),不這樣綁定就會失敗。我分析多出的2可能是為了存放字符串結尾的空字符null和BSTR字符串開頭的一個字(表示BSTR的長度)。這個問題對于初學者來說可能是一個意想不到的問題。
            CADORecordBinding類的定義在icrsint.h文件里,內容是:
            class CADORecordBinding
            {
            public:
             STDMETHOD_(const ADO_BINDING_ENTRY*, GetADOBindingEntries) (VOID) PURE;
            };www.chinai tp 采吧采吧不是罪 ow er.comJuJIe

            BEGIN_ADO_BINDING宏的定義也在icrsint.h文件里,內容是:
            #define BEGIN_ADO_BINDING(cls) public: \
            typedef cls ADORowClass; \
            const ADO_BINDING_ENTRY* STDMETHODCALLTYPE GetADOBindingEntries() { \
            static const ADO_BINDING_ENTRY rgADOBindingEntries[] = { www.chinai tp 采吧采吧不是罪 ow er.comJuJIe

            ADO_VARIABLE_LENGTH_ENTRY2宏的定義也在icrsint.h文件里:
            #define ADO_VARIABLE_LENGTH_ENTRY2(Ordinal, DataType, Buffer, Size, Status, Modify)\
             {Ordinal, \
             DataType, \
             0, \
             0, \
             Size, \
             offsetof(ADORowClass, Buffer), \
             offsetof(ADORowClass, Status), \
             0, \
             classoffset(CADORecordBinding, ADORowClass), \
             Modify},www.chinai tp 采吧采吧不是罪 ow er.comJuJIe

             #define END_ADO_BINDING宏的定義也在icrsint.h文件里:
             #define END_ADO_BINDING()   {0, adEmpty, 0, 0, 0, 0, 0, 0, 0, FALSE}};\
             return rgADOBindingEntries;}
            (2). 綁定
            _RecordsetPtr   Rs1;
            IADORecordBinding   *picRs=NULL;
            CCustomRs rs;
            ......
            Rs1->QueryInterface(__uuidof(IADORecordBinding),
                           (LPVOID*)&picRs));
            picRs->BindToRecordset(&rs);
            派生出的類必須通過IADORecordBinding接口才能綁定,調用它的BindToRecordset方法就行了。
            (3). rs中的變量即是當前記錄字段的值
            //Set sort and filter condition:
            // Step 4: Manipulate the data
            Rs1->Fields->GetItem("au_lname")->Properties->GetItem("Optimize")->Value = true;
            Rs1->Sort = "au_lname ASC";
            Rs1->Filter = "phone LIKE '415 5*'";www.chinai tp 采吧采吧不是罪 ow er.comJuJIe

            Rs1->MoveFirst();
            while (VARIANT_FALSE == Rs1->EndOfFile)
            {
             printf("Name: %s\t %s\tPhone: %s\n", 
              (rs.lau_fnameStatus == adFldOK ? rs.m_szau_fname : ""),
                    (rs.lau_lnameStatus == adFldOK ? rs.m_szau_lname : ""),
                    (rs.lphoneStatus == adFldOK ? rs.m_szphone   : ""));
                     if (rs.lphoneStatus == adFldOK)
                        strcpy(rs.m_szphone, "777");
                     TESTHR(picRs->Update(&rs));   // Add change to the batch
              Rs1->MoveNext();
            }
            Rs1->Filter = (long) adFilterNone;
            ......
            if (picRs) picRs->Release();
            Rs1->Close();
            pConn->Close();
            只要字段的狀態是adFldOK,就可以訪問。如果修改了字段,不要忘了先調用picRs的Update(注意不是Recordset的Update),然后才關閉,也不要忘了釋放picRs(即picRs->Release();)。
            (4). 此時還可以用IADORecordBinding接口添加新紀錄
             if(FAILED(picRs->AddNew(&rs)))
             ......
            11. 訪問長數據
            在Microsoft SQL中的長數據包括text、image等這樣長類型的數據,作為二進制字節來對待。
            可以用Field對象的GetChunk和AppendChunk方法來訪問。每次可以讀出或寫入全部數據的一部分,它會記住上次訪問的位置。但是如果中間訪問了別的字段后,就又得從頭來了。
            請看下面的例子:
            //寫入一張照片到數據庫:
            VARIANT varChunk;
            SAFEARRAY *psa;
            SAFEARRAYBOUND rgsabound[1];www.chinai tp 采吧采吧不是罪 ow er.comJuJIe

            //VT_ARRAY | VT_UI1
            CFile f("h:\\aaa.jpg",CFile::modeRead);
            BYTE  bVal[ChunkSize+1];
            UINT uIsRead=0;
            //Create a safe array to store the array of BYTES 
            while(1)
            {
             uIsRead=f.Read(bVal,ChunkSize);
             if(uIsRead==0)break;
             rgsabound[0].cElements =uIsRead;
                rgsabound[0].lLbound = 0;
             psa = SafeArrayCreate(VT_UI1,1,rgsabound);
             for(long index=0;index<uIsRead;index++)         
             {
              if(FAILED(SafeArrayPutElement(psa,&index,&bVal[index])))
              ::MessageBox(NULL,"啊,又出毛病了。","提示",MB_OK | MB_ICONWARNING);
             }
             varChunk.vt = VT_ARRAY|VT_UI1;
             varChunk.parray = psa;
             try{
              m_pRecordset->Fields->GetItem("photo")->AppendChunk(varChunk);
             }
             catch (_com_error &e)
             {
              CString str=(char*)e.Description();
              ::MessageBox(NULL,str+"\n又出毛病了。","提示",MB_OK | MB_ICONWARNING);
             }
             ::VariantClear(&varChunk);
             ::SafeArrayDestroyData( psa);
             if(uIsRead<ChunkSize)break;
            }//while(1) 
            f.Close();www.chinai tp 采吧采吧不是罪 ow er.comJuJIe

            //從數據庫讀一張照片:
            CFile f;
            f.Open("h:\\bbb.jpg",CFile::modeWrite|CFile::modeCreate);
            long lPhotoSize = m_pRecordset->Fields->Item["photo"]->ActualSize; 
            long lIsRead=0;www.chinai tp 采吧采吧不是罪 ow er.comJuJIe

            _variant_t varChunk;
            BYTE buf[ChunkSize];
            while(lPhotoSize>0)
            {
             lIsRead=lPhotoSize>=ChunkSize? ChunkSize:lPhotoSize;
             varChunk = m_pRecordset->Fields->
                              Item["photo"]->GetChunk(lIsRead);
             for(long index=0;index<lIsRead;index++)        
             {          
              ::SafeArrayGetElement(varChunk.parray,&index,buf+index);   
             }
             f.Write(buf,lIsRead);
             lPhotoSize-=lIsRead;
            }//while()
            f.Close();
            12. 使用SafeArray問題
            學會使用SafeArray也是很重要的,因為在ADO編程中經常要用。它的主要目的是用于automation中的數組型參數的傳遞。因為在網絡環境中,數組是不能直接傳遞的,而必須將其包裝成SafeArray。實質上SafeArray就是將通常的數組增加一個描述符,說明其維數、長度、邊界、元素類型等信息。SafeArray也并不單獨使用,而是將其再包裝到VARIANT類型的變量中,然后才作為參數傳送出去。在VARIANT的vt成員的值如果包含VT_ARRAY|...,那么它所封裝的就是一個SafeArray,它的parray成員即是指向SafeArray的指針。SafeArray中元素的類型可以是VARIANT能封裝的任何類型,包括VARIANT類型本身。 
            使用SafeArray的具體步驟:
            方法一:
             包裝一個SafeArray:
            (1). 定義變量,如:
             VARIANT varChunk;
             SAFEARRAY *psa;
                SAFEARRAYBOUND rgsabound[1];
            (2). 創建SafeArray描述符:
             uIsRead=f.Read(bVal,ChunkSize);//read array from a file.
             if(uIsRead==0)break;
             rgsabound[0].cElements =uIsRead;
             rgsabound[0].lLbound = 0;
             psa = SafeArrayCreate(VT_UI1,1,rgsabound);
            (3). 放置數據元素到SafeArray:
             for(long index=0;index<uIsRead;index++)         
             {
              if(FAILED(SafeArrayPutElement(psa,&index,&bVal[index])))
               ::MessageBox(NULL,"出毛病了。","提示",MB_OK | MB_ICONWARNING);
             }
             一個一個地放,挺麻煩的。
            (4). 封裝到VARIANT內:
             varChunk.vt = VT_ARRAY|VT_UI1;
             varChunk.parray = psa;
             這樣就可以將varChunk作為參數傳送出去了。www.chinai tp 采吧采吧不是罪 ow er.comJuJIe

             讀取SafeArray中的數據的步驟:
            (1). 用SafeArrayGetElement一個一個地讀
             BYTE buf[lIsRead];
             for(long index=0;index<lIsRead;index++)        
             {          
              ::SafeArrayGetElement(varChunk.parray,&index,buf+index);   
             }
             就讀到緩沖區buf里了。
            方法二:
             使用SafeArrayAccessData直接讀寫SafeArray的緩沖區:
            (1). 讀緩沖區:
             BYTE *buf;
             SafeArrayAccessData(varChunk.parray, (void **)&buf);
             f.Write(buf,lIsRead);
             SafeArrayUnaccessData(varChunk.parray);
            (2). 寫緩沖區:
             BYTE *buf;
             ::SafeArrayAccessData(psa, (void **)&buf);
             for(long index=0;index<uIsRead;index++)         
             {
              buf[index]=bVal[index];  
             }
             ::SafeArrayUnaccessData(psa);www.chinai tp 采吧采吧不是罪 ow er.comJuJIe

             varChunk.vt = VT_ARRAY|VT_UI1;
             varChunk.parray = psa;www.chinai tp 采吧采吧不是罪 ow er.comJuJIe

            這種方法讀寫SafeArray都可以,它直接操縱SafeArray的數據緩沖區,比用SafeArrayGetElement和SafeArrayPutElement速度快。特別適合于讀取數據。但用完之后不要忘了調用::SafeArrayUnaccessData(psa),否則會出錯的。
            13. 使用書簽( bookmark )
            書簽可以唯一標識記錄集中的一個記錄,用于快速地將當前記錄移回到已訪問過的記錄,以及進行過濾等等。Provider會自動為記錄集中的每一條記錄產生一個書簽,我們只需要使用它就行了。我們不能試圖顯示、修改或比較書簽。ADO用記錄集的Bookmark屬性表示當前記錄的書簽。
            用法步驟:
            (1). 建立一個VARIANT類型的變量
            _variant_t VarBookmark;
            (2). 將當前記錄的書簽值存入該變量
            也就是記錄集的Bookmark屬性的當前值。
             VarBookmark = rst->Bookmark;
            (3). 返回到先前的記錄
            將保存的書簽值設置到記錄集的書簽屬性中:
             // Check for whether bookmark set for a record
             if (VarBookmark.vt == VT_EMPTY)
              printf("No Bookmark set!\n");
             else
              rst->Bookmark = VarBookmark;
            設置完后,當前記錄即會移動到該書簽指向的記錄。
            14、設置過濾條件
            Recordset對象的Filter屬性表示了當前的過濾條件。它的值可以是以AND或OR連接起來的條件表達式(不含WHERE關鍵字)、由書簽組成的數組或ADO提供的FilterGroupEnum枚舉值。為Filter屬性設置新值后Recordset的當前記錄指針會自動移動到滿足過濾條件的第一個記錄。例如:
            rst->Filter  = _bstr_t ("姓名='趙薇'  AND  性別=’女’");
            在使用條件表達式時應注意下列問題:
            (1)、可以用圓括號組成復雜的表達式
            例如:
            rst->Filter  =  _bstr_t ("(姓名='趙薇'  AND  性別=’女’)  OR  AGE<25");
            但是微軟不允許在括號內用OR,然后在括號外用AND,例如:
            rst->Filter  = _bstr_t ("(姓名='趙薇'  OR 性別=’女’)  AND  AGE<25");
            必須修改為:
            rst->Filter  = _bstr_t ("(姓名='趙薇'  AND  AGE<25)  OR  (性別=’女’  AND  AGE<25)");
            (2)、表達式中的比較運算符可以是LIKE
            LIKE后被比較的是一個含有通配符*的字符串,星號表示若干個任意的字符。
            字符串的首部和尾部可以同時帶星號*
            rst->Filter  =  _bstr_t ("姓名 LIKE '*趙*' ");
            也可以只是尾部帶星號:
            rst->Filter  =  _bstr_t ("姓名 LIKE '趙*' ");
            Filter屬性值的類型是Variant,如果過濾條件是由書簽組成的數組,則需將該數組轉換為SafeArray,然后再封裝到一個VARIANT或_variant_t型的變量中,再賦給Filter屬性。
            15、索引與排序
            (1)、建立索引
            當以某個字段為關鍵字用Find方法查找時,為了加快速度可以以該字段為關鍵字在記錄集內部臨時建立索引。只要將該字段的Optimize屬性設置為true即可,例如:
            pRst->Fields->GetItem("姓名")->Properties->
                        GetItem("Optimize")->PutValue("True");
            pRst->Find("姓名 = '趙薇'",1,adSearchForward);
            ......
            pRst->Fields->GetItem("姓名")->Properties->
                        GetItem("Optimize")->PutValue("False");
            pRst->Close();
            說明:Optimize屬性是由Provider提供的屬性(在ADO中稱為動態屬性),ADO本身沒有此屬性。
            (2)、排序
            要排序也很簡單,只要把要排序的關鍵字列表設置到Recordset對象的Sort屬性里即可,例如:
            pRstAuthors->CursorLocation = adUseClient;
            pRstAuthors->Open("SELECT * FROM mytable",
                        _variant_t((IDispatch *) pConnection),
                        adOpenStatic, adLockReadOnly, adCmdText);
            ......
            pRst->Sort = "姓名 DESC, 年齡 ASC";
            關鍵字(即字段名)之間用逗號隔開,如果要以某關鍵字降序排序,則應在該關鍵字后加一空格,再加DESC(如上例)。升序時ASC加不加無所謂。本操作是利用索引進行的,并未進行物理排序,所以效率較高。
            但要注意,在打開記錄集之前必須將記錄集的CursorLocation屬性設置為adUseClient,如上例所示。Sort屬性值在需要時隨時可以修改。
            16、事務處理
            ADO中的事務處理也很簡單,只需分別在適當的位置調用Connection對象的三個方法即可,這三個方法是:
            (1)、在事務開始時調用
            pCnn->BeginTrans();
            (2)、在事務結束并成功時調用
            pCnn->CommitTrans ();
            (3)、在事務結束并失敗時調用
            pCnn->RollbackTrans ();
            在使用事務處理時,應盡量減小事務的范圍,即減小從事務開始到結束(提交或回滾)之間的時間間隔,以便提高系統效率。需要時也可在調用BeginTrans()方法之前,先設置Connection對象的IsolationLevel屬性值,詳細內容參見MSDN中有關ADO的技術資料。
            三、使用ADO編程常見問題解答
            以下均是針對MS SQL 7.0編程時所遇問題進行討論。
            1、連接失敗可能原因
            Enterprise Managemer內,打開將服務器的屬性對話框,在Security選項卡中,有一個選項Authentication。
            如果該選項是Windows NT only,則你的程序所用的連接字符串就一定要包含Trusted_Connection參數,并且其值必須為yes,如:
            "Provider=SQLOLEDB;Server=888;Trusted_Connection=yes"
              ";Database=master;uid=lad;";
            如果不按上述操作,程序運行時連接必然失敗。
            如果Authentication選項是SQL Server and Windows NT,則你的程序所用的連接字符串可以不包含Trusted_Connection參數,如:
            "Provider=SQLOLEDB;Server=888;Database=master;uid=lad;pwd=111;";
            因為ADO給該參數取的默認值就是no,所以可以省略。我認為還是取默認值比較安全一些。
            2、改變當前數據庫的方法
            使用Tansct-SQL中的USE語句即可。
            3、如何判斷一個數據庫是否存在
            (1)、可打開master數據庫中一個叫做SCHEMATA的視圖,其內容列出了該服務器上所有的數據庫名稱。
            (2) 、更簡便的方法是使用USE語句,成功了就存在;不成功,就不存在。例如:
             try{
              m_pConnect->Execute ( _bstr_t("USE INSURANCE_2002"),NULL,
              adCmdText|adExecuteNoRecords );
             }
             catch (_com_error &e)
             {
              blSuccess=FALSE;
              CString str="數據庫INSURANCE_2002不存在!\n";
              str+=e.Description();
              ::MessageBox(NULL,str,"警告",MB_OK | MB_ICONWARNING); 
             }
            4、判斷一個表是否存在
            (1)、同樣判斷一個表是否存在,也可以用是否成功地打開它來判斷,十分方便,例如:
             try{
              m_pRecordset->Open(_variant_t("mytable"),
                        _variant_t((IDispatch *)m_pConnection,true), adOpenKeyset,
                        adLockOptimistic, adCmdTable);
             }
             catch (_com_error &e)
             {
              ::MessageBox(NULL,"該表不存在。","提示",MB_OK | MB_ICONWARNING);
             }

            (2)、要不然可以采用麻煩一點的辦法,就是在MS-SQL服務器上的每個數據庫中都有一個名為sysobjects的表,查看此表的內容即知指定的表是否在該數據庫中。
            (3)、同樣,每個數據庫中都有一個名為TABLES的視圖(View),查看此視圖的內容即知指定的表是否在該數據庫中。
            5、類型轉換問題
            (1)、類型VARIANT_BOOL
            類型VARIANT_BOOL等價于short類型。The VARIANT_BOOL is equivalent to short. see it's definition below:
            typdef short VARIANT_BOOL
            (2)、_com_ptr_t類的類型轉換
            _ConnectionPtr可以自動轉換成IDspatch*類型,這是因為_ConnectionPtr實際上是_com_ptr_t類的一個實例,而這個類有此類型轉換函數。
            同理,_RecordsetPtr和_CommandPtr也都可以這樣轉換。
            (3)、_bstr_t和_variant_t類
            在ADO編程時,_bstr_t和_variant_t這兩個類很有用,省去了許多BSTR和VARIANT類型轉換的麻煩。
            6、打開記錄集時的問題
            在打開記錄集時,在調用Recordset的Open方法時,其最后一個參數里一定不能包含adAsyncExecute,否則將因為是異步操作,在讀取數據時無法讀到數據。
            7、異常處理問題
            對所有調用ADO的語句一定要用try和catch語句捕捉異常,否則在發生異常時,程序會異常退出。
            8、使用SafeArray問題
            在初學使用中,我曾遇到一個傷腦筋的問題,一定要注意:
            在定義了SAFEARRAY的指針后,如果打算重復使用多次,則在中間可以調用::SafeArrayDestroyData釋放數據,但決不能調用::SafeArrayDestroyDescriptor,否則必然出錯,即使調用SafeArrayCreate也不行。例如:
            SAFEARRAY *psa;
            ......
            //When the data are no longer to be used:
            ::SafeArrayDestroyData( psa);
            我分析在定義psa指針時,一個SAFEARRAY的實例(也就是SAFEARRAY描述符)也同時被自動建立了。但是只要一調用::SafeArrayDestroyDescriptor,描述符就被銷毀了。
            所以我認為::SafeArrayDestroyDescriptor可以根本就不調用,即使調用也必須在最后調用。
            9、重復使用命令對象問題
            一個命令對象如果要重復使用多次(尤其是帶參數的命令),則在第一次執行之前,應將它的Prepared屬性設置為TRUE。這樣會使第一次執行減慢,但卻可以使以后的執行全部加快。
            10、綁定字符串型字段問題
            如果要綁定的字段是字符串類型,則對應的字符數組的元素個數一定要比字段長度大2(比如m_szau_fname[22],其綁定的字段au_fname的長度實際是20),不這樣綁定就會失敗。
            11、使用AppendChunk的問題
            當用AddNew方法剛剛向記錄集內添加一個新記錄之后,不能首先向一個長數據字段(image類型)寫入數據,必須先向其他字段寫入過數據之后,才能調用AppendChunk寫該字段,否則出錯。也就是說,AppendChunk不能緊接在AddNew之后。另外,寫入其他字段后還必須緊接著調用AppendChunk,而不能調用記錄集的Update方法后,才調用AppendChunk,否則調用AppendChunk時也會出錯。換句話說,就是必須AppendChunk在前,Update在后。因而這個時候就不能使用帶參數的AddNew了,因為帶參數的AddNew會自動調用記錄集的Update,所以AppendChunk就跑到Update的后面了,就只有出錯了!因此,這時應該用不帶參數的AddNew。
            我推測這可能是MS SQL 7.0的問題,在MS SQL 2000中則不存在這些問題,但是AppendChunk仍然不能在Update之后。
            四、小結
            一般情況下,Connection和Command的Execute用于執行不產生記錄集的命令,而Recordset的Open用于產生一個記錄集,當然也不是絕對的。特別Command主要是用于執行參數化的命令,可以直接由Command對象執行,也可以將Command對象傳遞給Recordset的Open。
            本文中的代碼片斷均在VC++ 6.0、Windows NT 4.0 SP6和MS SQL 7.0中調試通過。相信您讀過之后,編寫簡單的數據庫程序應該沒有問題了。當然要編寫比較實用的、復雜一點的程序,還需要對OLE DB、ADO以及數據庫平臺再多了解一點,希望您繼續努力,一定會很快成功的!詳細參考資料請參見微軟MSDN July 2000光盤或MS SQL 7.0在線文檔資料(Books online)。文中難免有錯誤和不妥之處,敬請各位批評指正!www.chinai tp 采吧采吧不是罪 ow er.comJuJIe

            參考文獻:
            1、 微軟MSDN Library - July 2000 / Platform SDK / Data Services / Microsoft Data Access Components (MDAC) / Microsoft ActiveX Data Objects (ADO)
            2、 微軟MS SQL 7.0在線文檔資料(Books online)---- Building SQL Server Applications / ADO and SQL Server
            3、 微軟MS SQL 7.0在線文檔資料(Books online)---- Building SQL Server Applications / Transact – SQL Reference
            4、 微軟MSDN Library - July 2000 / Platform SDK / Data Services / Microsoft Data Access Components (MDAC) / Microsoft OLE DB

            Posted on 2005-12-15 11:03 艾凡赫 閱讀(773) 評論(0)  編輯 收藏 引用 所屬分類: ADO編程技術
            久久亚洲AV成人无码电影| 久久99精品久久久久久不卡| 一本色道久久综合狠狠躁篇 | 久久久久久久波多野结衣高潮| 久久久久久久久久久免费精品| 久久免费视频一区| 久久天天躁狠狠躁夜夜2020一| 久久午夜无码鲁丝片秋霞 | 奇米综合四色77777久久| 9久久9久久精品| 香蕉久久夜色精品国产尤物| 午夜欧美精品久久久久久久| 久久国产精品无码一区二区三区 | 久久青青草视频| 亚洲国产精品人久久| 久久久久久久波多野结衣高潮| 久久被窝电影亚洲爽爽爽| 日韩十八禁一区二区久久| 日韩精品久久无码人妻中文字幕 | 久久99热这里只频精品6| 国产欧美久久一区二区| 亚洲午夜精品久久久久久app| 久久久久国产精品熟女影院 | 一本久久综合亚洲鲁鲁五月天亚洲欧美一区二区 | 亚洲成色999久久网站| 中文字幕热久久久久久久| 国产高清国内精品福利99久久| 精品久久久无码人妻中文字幕| 大香网伊人久久综合网2020| 久久婷婷五月综合97色一本一本| 久久夜色撩人精品国产| 国产成人精品久久综合| 久久精品国产一区二区三区日韩| 7777精品久久久大香线蕉| 免费一级做a爰片久久毛片潮| 久久综合九色综合精品| 国产精品久久久久天天影视| 亚洲色大成网站www久久九| 久久久久久精品久久久久| 中文成人久久久久影院免费观看| 久久无码精品一区二区三区|