2014-09-23 155 views
6

這個已經有twoquestions了,但實際上沒有人回答過這個問題。PDO:如何檢查連接是否處於活動狀態?

我知道,如果連接失敗(假設您啓用PDO::ERRMODE_EXCEPTION),PDO將拋出異常,但我想測試連接是否爲仍然活動,可能幾小時後。

我有一個長時間運行的腳本,並在一段時間後超時。理論上我可以通過PDO::ATTR_TIMEOUT增加這段時間,但基本上我想寫一個函數讓我返回一個活動的連接 - 如果它已經建立了並且沒有超時或者重新連接。

我應該只是做SELECT 1,趕上例外,並重新連接?還是有更好的方法?

+1

我發佈了一個答案,並沒有意識到你把我的答案放在你的問題中,詢問是否有更好的方法,我的不好。我將使用'SELECT 1'方法作爲IIRC,在PDO中沒有實際的「ping」方法。 – 2014-09-23 21:20:45

+0

我會以非常充滿希望的方式來看待這個問題,因爲我有一個非常相似的場景,我會**真的喜歡優雅的解決方案。 – castis 2014-09-23 21:33:37

+1

一直在網上搜索,我發現這個網站:http://brady.lucidgene.com/2013/04/handling-pdo-lost-mysql-connection-error/我的知識不足以提供優雅的答案,但它確實看起來很有趣 – icecub 2014-09-23 22:02:43

回答

7

MySQL協議爲此支持一個特殊的命令COM_PING,C API有一個調用mysql_ping()來發送它。這將測試連接是否處於活動狀態。

如果連接是使用MYSQL_OPT_RECONNECT創建的,則自動連接(https://dev.mysql.com/doc/refman/5.6/en/auto-reconnect.html)。

不幸的是,如果您使用當前版本的PDO,則不支持這些功能。您只能提交SQL查詢字符串,而不是特殊命令。 PDO現在使用mysqlnd驅動程序,它有其優點,但不支持重新連接選項。所以這個問題無論如何都是無稽之談。

我不知道任何更優雅的解決方案,比試圖發出像SELECT 1這樣的「虛擬」查詢,發現異常,並且如果得到錯誤代碼2006(服務器已消失),請重新連接。

您可以創建一個單例類來保存數據庫連接,並在應用程序代碼每次調用getConnection()時測試活動連接。下面是我測試的例子:

class DB 
{ 
    protected static $pdo = null; 

    public static function getConnection() { 
     // initialize $pdo on first call 
     if (self::$pdo == null) { 
      self::init(); 
     } 

     // now we should have a $pdo, whether it was initialized on this call or a previous one 
     // but it could have experienced a disconnection 
     try { 
      echo "Testing connection...\n"; 
      $old_errlevel = error_reporting(0); 
      self::$pdo->query("SELECT 1"); 
     } catch (PDOException $e) { 
      echo "Connection failed, reinitializing...\n"; 
      self::init(); 
     } 
     error_reporting($old_errlevel); 

     return self::$pdo; 
    } 

    protected static function init() { 
     try { 
      echo "Opening new connection...\n"; 
      self::$pdo = new PDO('mysql:host=huey;dbname=test', 'root', 'root'); 
      self::$pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); 
     } catch (PDOException $e) { 
      die($e->getMessage()); 
     } 
    } 
} 

使用方法如下:

echo "Query for 2:\n"; 
$pdo = DB::getConnection(); 
echo $pdo->query("SELECT 2")->fetchColumn() . "\n"; 

echo "\nSleeping 10 seconds...\n"; 
sleep(10); /* meanwhile I use another window to KILL the connection */ 
echo "\n"; 

echo "Query for 3:\n"; 
$pdo = DB::getConnection(); 
echo $pdo->query("SELECT 3")->fetchColumn() . "\n"; 

輸出:

Query for 2: 
Opening new connection... 
Testing connection... 
2 

Sleeping 10 seconds... 

Query for 3: 
Testing connection... 
Connection failed, reinitializing... 
Opening new connection... 
3 

你可以看到,它檢測到連接失敗,並重新初始化。

相關問題