• <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 閱讀(832) 評論(0)  編輯 收藏 引用
            欧美大战日韩91综合一区婷婷久久青草| 久久夜色精品国产噜噜噜亚洲AV| 国产精品青草久久久久婷婷| 丁香五月网久久综合| 久久综合色区| 久久久久免费看成人影片| Xx性欧美肥妇精品久久久久久| 午夜肉伦伦影院久久精品免费看国产一区二区三区 | 久久精品无码一区二区三区日韩| 亚洲精品国产自在久久| 国产精品久久久久…| 久久亚洲精品国产精品婷婷| 久久精品国产久精国产| 久久精品国产免费观看三人同眠| 久久久青草久久久青草| 无码超乳爆乳中文字幕久久| 亚洲人成无码久久电影网站| 999久久久国产精品| 99re久久精品国产首页2020| 久久精品国产亚洲AV不卡| 久久久这里有精品中文字幕| 国产69精品久久久久9999| 久久国产精品-久久精品| 精品综合久久久久久888蜜芽| 亚洲国产精品狼友中文久久久| 久久香蕉一级毛片| 69久久夜色精品国产69| 日产精品久久久久久久| 亚洲国产精品无码久久久秋霞2 | 久久91精品国产91久久麻豆| 久久亚洲精品成人无码网站| 欧美激情精品久久久久久久九九九 | 色8久久人人97超碰香蕉987| 久久久久久久97| 亚洲国产另类久久久精品黑人 | 亚洲国产精品无码久久SM| 久久人人爽人人爽人人爽| 亚洲国产成人精品无码久久久久久综合 | 久久国产香蕉视频| 久久精品国产亚洲av瑜伽| 久久一区二区三区免费|