PDO:如何检查连接是否处于活动状态 - PDO: How to check if connection is active, for real?

PDO: How to check if connection is active, for real?

关于这个问题已经有两个问题了，但实际上没有人回答这个问题。

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

我有一个很长的运行脚本，过了一段时间就超时了。理论上，我可以用PDO::ATTR_TIMEOUT增加这段时间，但基本上我想写一个函数，给我一个活动的连接——如果它已经建立并且没有超时，则是一个现有的连接，或者如果它已经超时，则重新连接。

我应该只执行SELECT 1，捕获异常，然后重新连接吗？或者有更好的方法吗？

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（服务器已经离开），则重新连接。

您可以创建一个singleton类来保存数据库连接，并在应用程序代码每次调用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

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