PDO：如何检查连接是否确实有效？

曾经有过two 问题已经讨论过这个问题，但没有人真正回答这个问题。

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

我有一个长时间运行的脚本，一段时间后它就超时了。理论上我可以增加这个时间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（服务器已消失），则重新连接。

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

Output:

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

Sleeping 10 seconds...

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

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