• <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)  編輯 收藏 引用
            国产精品亚洲综合专区片高清久久久 | 中文精品99久久国产 | 久久精品综合网| 久久综合九色综合网站| 国产精品熟女福利久久AV | 久久久久人妻精品一区三寸蜜桃| 国产aⅴ激情无码久久| 青青草国产精品久久久久| 久久综合伊人77777| 欧美黑人又粗又大久久久 | 亚洲а∨天堂久久精品| 97久久精品国产精品青草| 噜噜噜色噜噜噜久久| 四虎国产永久免费久久| 日产精品久久久一区二区| 亚洲精品国精品久久99热| 99热都是精品久久久久久| 久久久久亚洲Av无码专| 色婷婷久久综合中文久久一本| A狠狠久久蜜臀婷色中文网| 超级97碰碰碰碰久久久久最新| 久久国产乱子伦精品免费强| 久久精品国产亚洲av麻豆色欲| 亚洲Av无码国产情品久久| 精品久久久久国产免费| 99久久免费国产特黄| 99精品久久精品一区二区| 久久久无码精品午夜| 国产精品欧美亚洲韩国日本久久| 久久久久99精品成人片直播| 久久久久亚洲av成人网人人软件| 欧美久久综合九色综合| 蜜桃麻豆www久久国产精品| 久久免费观看视频| 久久亚洲AV无码西西人体| 久久精品夜色噜噜亚洲A∨| 久久精品无码一区二区三区免费| 国产呻吟久久久久久久92| 久久精品国产亚洲Aⅴ蜜臀色欲| 精品久久久久久无码人妻热| 久久免费观看视频|