• <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)  編輯 收藏 引用
            久久久精品人妻一区二区三区蜜桃| 国产成人精品久久亚洲高清不卡 | 久久精品无码一区二区app| 国内精品久久久久影院网站 | 99久久精品免费看国产免费| 久久久久亚洲精品天堂久久久久久 | 久久亚洲国产最新网站| 久久国产精品99精品国产| 精品人妻伦一二三区久久| 一本色道久久99一综合| 精品一久久香蕉国产线看播放 | 久久精品国产91久久麻豆自制| 久久夜色撩人精品国产小说| 99国产欧美精品久久久蜜芽| 久久精品成人影院| 亚洲成人精品久久| 久久亚洲中文字幕精品有坂深雪 | 久久91综合国产91久久精品| 亚洲伊人久久成综合人影院 | 99久久夜色精品国产网站| 久久一日本道色综合久久| 一个色综合久久| 日本亚洲色大成网站WWW久久| 99久久精品免费看国产免费| 久久久久无码精品国产不卡| 久久久久久久女国产乱让韩| 武侠古典久久婷婷狼人伊人| 亚洲午夜久久久久久久久电影网| 91精品国产9l久久久久| 亚洲精品无码久久久| 久久精品水蜜桃av综合天堂| 亚洲中文久久精品无码ww16| 免费精品久久天干天干| 亚洲国产一成久久精品国产成人综合 | 2021精品国产综合久久| 日本强好片久久久久久AAA | 麻豆精品久久精品色综合| 久久综合丁香激情久久| 久久精品成人免费看| 青青草原综合久久大伊人精品| 亚洲国产精品热久久|