PDO：如何检查连接是否处于活动状态？

这个已经有two questions了，但实际上没有人回答过这个问题。PDO：如何检查连接是否处于活动状态？

我知道，如果连接失败（假设您启用PDO::ERRMODE_EXCEPTION），PDO将抛出异常，但我想测试连接是否为仍然活动，可能几小时后。

我有一个长时间运行的脚本，并在一段时间后超时。理论上我可以通过PDO::ATTR_TIMEOUT增加这段时间，但基本上我想写一个函数让我返回一个活动的连接 - 如果它已经建立了并且没有超时或者重新连接。

我应该只是做SELECT 1，赶上例外，并重新连接？还是有更好的方法？

2014-09-23 mpen

我发布了一个答案，并没有意识到你把我的答案放在你的问题中，询问是否有更好的方法，我的不好。我将使用'SELECT 1'方法作为IIRC，在PDO中没有实际的“ping”方法。 – 2014-09-23 21:20:45

我会以非常充满希望的方式来看待这个问题，因为我有一个非常相似的场景，我会**真的喜欢优雅的解决方案。 – castis 2014-09-23 21:33:37

一直在网上搜索，我发现这个网站：http://brady.lucidgene.com/2013/04/handling-pdo-lost-mysql-connection-error/我的知识不足以提供优雅的答案，但它确实看起来很有趣 – icecub 2014-09-23 22:02:43

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

你可以看到，它检测到连接失败，并重新初始化。

来源

2014-09-23 23:39:43

PDO：如何检查连接是否处于活动状态？

回答

相关问题