• <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>

            kenlistian

            厚積薄發. 勤為槳,思為帆

               :: 首頁 :: 新隨筆 ::  :: 聚合  :: 管理 ::
              73 隨筆 :: 4 文章 :: 22 評論 :: 0 Trackbacks

                一般來說,和數據庫連接通常不容易斷鏈,但是特別做些服務性質的,無人監守的程序時,則要考慮數據庫連接的ado發生斷鏈時的情況。在這種情況下,考慮建立數據庫鏈路檢測異常保護就是非常重要的。

            通常,與數據庫連接中斷有以下2種情況:

            1。數據庫服務器服務停止,
            2。與數據庫服務器之間的網絡發生中斷


            采用如下代碼在使用做pRs做open查詢操作時,拋出異常,此異常可判斷為到數據庫服務器的連接發生中斷
            Error   number:   80004005
            [DBNETLIB][ConnectionWrite (WrapperWrite()).]一般性網絡錯誤。請檢查網絡文檔。
            SQLState   :   08S0
            NativeError   :   b

            當pConn在Close,重新Open連接會發生異常,此異常是重新連接時拋出的。此時可判斷為到遠程服務器的連接完全中斷
            Error   number:   80004005
            [DBNETLIB][ConnectionOpen (Connect()).]SQL Server 不存在或拒絕訪問。
            SQLState   :   08001
            NativeError   :   11

            檢測代碼基本如下,此代碼的部分參考自ADO手冊,并加以部分的修改
            for(;;)
            {
                try {
                    if   (g_isConnected) {
                            pRs-> Open(_bstr_t(“select 1”),  _variant_t((IDispatch*)pConn,true), adOpenStatic,
                                               adLockReadOnly, adCmdText);
                            if (pRs)
                                if   (pRs-> State == adStateOpen)
                                      pRs-> Close();
                    } else {
                         if   (pConn)
                             if   (pConn->State   ==   adStateOpen)
                                    pConn->Close();
                         pConn->Open(_bstr_t(strCnn),_bstr_t(""),_bstr_t(""),adModeUnknown);   //重新打開連接
                         isConnected=TRUE;
                    }
               }
               catch   (_com_error   &pCome)
               {

                      _variant_t   vtConnect   =   (_variant_t)(pConn.GetInterfacePtr());//pRs-> GetActiveConnection();
                      switch(vtConnect.vt)
                     {
                            case   VT_BSTR:
                                    PrintComError(pCome);
                                    break;
                            case   VT_DISPATCH:
                                     PrintProviderError(vtConnect);
                                     break;
                           default:
                                 printf( "Errors   occured. ");
                                break;
                       }
                       isConnected=   FALSE;
                 }
                 Sleep(1000);
            }
            void   PrintProviderError(_ConnectionPtr   pConnection)
            {
                         ErrorPtr     pErr     =   NULL;
                         if(   (pConnection-> Errors-> Count)   >   0)
                        {
                                long   nCount   =   pConnection-> Errors-> Count;
                               for(long   i   =   0;   i   <   nCount;   i++)
                               {
                                      pErr   =   pConnection-> Errors-> GetItem(i);
                                      TRACE( "Error   number:   %x\n%s\n ",   pErr-> Number,  (LPCSTR)pErr-> Description);
                                      TRACE( "SQLState   :   %s\n ",   (LPCTSTR)pErr-> SQLState);
                                      TRACE( "NativeError   :   %x\n ",   pErr-> NativeError);
                              }
                        }
            }

            void   PrintComError(_com_error   &e)
            {
                _bstr_t   bstrSource(e.Source());
               _bstr_t   bstrDescription(e.Description());
               //   Print   Com   errors.    
                TRACE( "Error\n ");
                TRACE( "\tCode   =   %08lx\n ",   e.Error());
                TRACE( "\tCode   meaning   =   %s\n ",   e.ErrorMessage());
                TRACE( "\tSource   =   %s\n ",   (LPCSTR)   bstrSource);
                TRACE( "\tDescription   =   %s\n ",   (LPCSTR)   bstrDescription);
            }

             

            把它整理成到一個線程中不斷作為數據庫鏈路檢測,發現該連接斷開則返回連接來處理。測試代碼附文。我用的sql server數據庫做測試過。源碼下載位置:

            http://www.pudn.com/downloads95/sourcecode/database/detail389188.html

            posted on 2008-01-06 00:03 kenlistian 閱讀(837) 評論(0)  編輯 收藏 引用
            新狼窝色AV性久久久久久| 久久精品无码午夜福利理论片| 久久精品人人做人人爽97 | 久久精品国产亚洲AV无码偷窥| 久久精品水蜜桃av综合天堂 | 久久久久亚洲AV无码麻豆| 97精品国产97久久久久久免费 | 久久99国内精品自在现线| 国产精品热久久无码av| 国产亚洲精久久久久久无码77777| 国产国产成人精品久久| 精品国产日韩久久亚洲| 亚洲天堂久久精品| 精品熟女少妇a∨免费久久| 久久亚洲天堂| 久久国产视屏| 久久久久久久尹人综合网亚洲| 国产激情久久久久久熟女老人| 久久se精品一区二区影院 | 亚洲av伊人久久综合密臀性色| 久久97久久97精品免视看秋霞| 久久精品人人槡人妻人人玩AV| 国产一区二区久久久| 久久久久久极精品久久久| 久久青草国产精品一区| 91久久婷婷国产综合精品青草| 人妻精品久久久久中文字幕69 | 午夜精品久久久久久99热| 中文字幕无码av激情不卡久久| 久久精品国内一区二区三区| 久久国产色AV免费看| 亚洲中文字幕无码久久2020| 国产精品乱码久久久久久软件| 亚洲国产精品狼友中文久久久| 日韩久久久久中文字幕人妻| 久久久不卡国产精品一区二区| 久久久久国色AV免费看图片| 久久影院午夜理论片无码| 怡红院日本一道日本久久 | 韩国免费A级毛片久久| 亚洲午夜久久久久妓女影院|