PDO：MySQL 服务器已消失

Question

我有一个脚本，每晚都要进行大量的跑腿工作。

它使用在循环中执行的 PDO 准备语句。

前几个运行良好，但后来我发现它们都失败并出现错误： “MySQL 服务器已经消失”。

我们运行 MySQL 5.0.77。

PHP 版本 5.2.12

网站的其余部分运行良好。

Answer 1

您向服务器发送的数据包很可能比允许的最大数据包长。

当您尝试插入超过服务器最大数据包大小的 BLOB 时，即使在本地服务器上，您也会在客户端看到以下错误消息：

MySQL 服务器已经消失

并且服务器日志中出现以下错误消息：（如果启用了错误日志记录）

错误 1153 收到的数据包大于“max_allowed_pa​​cket”字节

要解决此问题，您需要确定将插入的最大 BLOB 的大小，并设置 max_allowed_pa​​cket相应地在 my.ini 中，例如：

[mysqld]
...
max_allowed_packet = 200M
...

Answer 2

B.5.2.9。 MySQL 手册的 MySQL 服务器已消失 部分列出了导致此错误的可能原因。

也许你正处于其中一种情况？ -- 特别是考虑到您正在运行长时间操作，关于 wait_timeout 可能很有趣......

Answer 3

我遇到了同样的问题，如果超时，托管服务器管理会终止连接。

由于我主要使用了查询，所以我编写了一个代码，我们可以包含下面的类并将类名替换为“ConnectionManagerPDO”，而不是使用 PDO 类。我刚刚完成了 PDO 类。

final class ConnectionManagerPDO
{

    private $dsn;
    private $username;
    private $passwd;
    private $options;
    private $db;
    private $shouldReconnect;

    const RETRY_ATTEMPTS = 3;

    public function __construct($dsn, $username, $passwd, $options = array())
    {
        $this->dsn = $dsn;
        $this->username = $username;
        $this->passwd = $passwd;
        $this->options = $options;
        $this->shouldReconnect = true;
        try {
            $this->connect();
        } catch (PDOException $e) {
            throw $e;
        }
    }

    /**
     * @param $method
     * @param $args
     * @return mixed
     * @throws Exception
     * @throws PDOException
     */
    public function __call($method, $args)
    {
        $has_gone_away = false;
        $retry_attempt = 0;
        try_again:
        try {

            if (is_callable(array($this->db, $method))) {

                return call_user_func_array(array($this->db, $method), $args);
            } else {

                trigger_error("Call to undefined method '{$method}'");
                /*
                 * or
                 *
                 * throw new Exception("Call to undefined method.");
                 *
                 */
            }
        } catch (\PDOException $e) {

            $exception_message = $e->getMessage();

            if (
                ($this->shouldReconnect)
                && strpos($exception_message, 'server has gone away') !== false
                && $retry_attempt <= self::RETRY_ATTEMPTS
            ) {
                $has_gone_away = true;
            } else {
                /*
                 * What are you going to do with it... Throw it back.. FIRE IN THE HOLE
                 */
                throw $e;
            }
        }

        if ($has_gone_away) {
            $retry_attempt++;
            $this->reconnect();
            goto try_again;
        }
    }


    /**
     * Connects to DB
     */
    private function connect()
    {
        $this->db = new PDO($this->dsn, $this->username, $this->passwd, $this->options);
        /*
         * I am manually setting to catch error as exception so that the connection lost can be handled.
         */
        $this->db->setAttribute( PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION );
    }

    /**
     * Reconnects to DB
     */
    private function reconnect()
    {
        $this->db = null;
        $this->connect();
    }
}

然后就可以像在 PDO 中一样开始使用上面的类了。

try {
    $db = new ConnectionManagerPDO("mysql:host=localhost;dbname=dummy_test", "root", "");
    $query = $db->query("select * from test");
    $query->setFetchMode(PDO::FETCH_ASSOC);
}
catch(PDOException $e){
    /*
        handle the exception throw in ConnectionManagerPDO
    */
}

Answer 4

尝试在您的 Pod 实例上使用 PDO::setAttribute(PDO::ATTR_EMULATE_PREPARES, true)。不知道这会有帮助，但没有日志数据，这就是我所得到的一切。

Answer 5

很可能您的连接已被终止（例如，通过 wait_timeout 或另一个线程发出 KILL 命令）、服务器崩溃或您以某种方式违反了 mysql 协议。

后者很可能是 PDO 中的一个错误，如果您使用服务器端准备好的语句或多结果，则极有可能（提示：不要）

服务器崩溃需要进行调查；查看服务器日志。

如果您仍然不知道发生了什么，请使用网络数据包转储程序（例如 tcpdump）转储连接的内容。

您还可以启用通用查询日志 - 但在生产中要非常小心。

Answer 6

Nathan H，下面是用于 pdo 重新连接的 php 类 + 代码使用示例。
附上屏幕截图。

<?php

# set errors reporting level
error_reporting(E_ALL ^ E_NOTICE ^ E_WARNING);

# set pdo connection
include('db.connection.pdo.php');

/* # this is "db.connection.pdo.php" content
define('DB_HOST', 'localhost');
define('DB_NAME', '');
define('DB_USER', '');
define('DB_PWD', '');
define('DB_PREFIX', '');
define('DB_SHOW_ERRORS', 1);

# connect to db
try {
    $dbh = new PDO('mysql:host='.DB_HOST.';dbname='.DB_NAME, DB_USER, DB_PWD);
    $dbh->setAttribute(PDO::ATTR_DEFAULT_FETCH_MODE, PDO::FETCH_ASSOC);
    $dbh->setAttribute(PDO::ATTR_EMULATE_PREPARES, TRUE);
    $dbh->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
}
catch(PDOException $e) {
    # echo $e->getMessage()."<br />";
    # exit;
    exit("Site is temporary unavailable."); #
}
*/

$reconnection = new PDOReconnection($dbh);

$reconnection->getTimeout();

echo $dbh->query('select 1')->fetchColumn();
echo PHP_EOL;
echo 'sleep 10 seconds..'.PHP_EOL;

sleep(10);

$dbh = $reconnection->checkConnection();
echo $dbh->query('select 1')->fetchColumn();
echo PHP_EOL;
echo 'sleep 35 seconds..'.PHP_EOL;

sleep(35);

$dbh = $reconnection->checkConnection();
echo $dbh->query('select 1')->fetchColumn();
echo PHP_EOL;
echo 'sleep 55 seconds..'.PHP_EOL;

sleep(55);

$dbh = $reconnection->checkConnection();
echo $dbh->query('select 1')->fetchColumn();
echo PHP_EOL;

echo 'sleep 300 seconds..'.PHP_EOL;
sleep(300);
$dbh = $reconnection->checkConnection();
echo $dbh->query('select 1')->fetchColumn();
echo PHP_EOL;

# *************************************************************************************************
# Class for PDO reconnection
class PDOReconnection
{
    private $dbh;

    # constructor
    public function __construct($dbh)
    {
        $this->dbh = $dbh;
    }

    # *************************************************************************************************

    # get mysql variable "wait_timeout" value
    public function getTimeout()
    {
        $timeout = $this->dbh->query('show variables like "wait_timeout"')->fetch(); # print_r($timeout);
        echo '========================'.PHP_EOL.'mysql variable "wait_timeout": '.$timeout['Value'].' seconds.'.PHP_EOL.'========================'.PHP_EOL;
    }

    # *************************************************************************************************

    # check mysql connection
    public function checkConnection()
    {
        try {
            $this->dbh->query('select 1')->fetchColumn();
            echo 'old connection works..'.PHP_EOL.'========================'.PHP_EOL;
        } catch (PDOException $Exception) {
            # echo 'there is no connection.'.PHP_EOL;
            $this->dbh = $this->reconnect();
            echo 'connection was lost, reconnect..'.PHP_EOL.'========================'.PHP_EOL;
        }

        return $this->dbh;
    }

    # *************************************************************************************************

    # reconnect to mysql
    public function reconnect()
    {
        $dbh = new PDO('mysql:host=' . DB_HOST . ';dbname=' . DB_NAME, DB_USER, DB_PWD);
        $dbh->setAttribute(PDO::ATTR_DEFAULT_FETCH_MODE, PDO::FETCH_ASSOC);
        $dbh->setAttribute(PDO::ATTR_EMULATE_PREPARES, TRUE); 
        $dbh->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);    
        return $dbh;
    }
}
# /Class for PDO reconnection
# *************************************************************************************************

Answer 7

今天早上在 Laravel 中更改数据库属性后，我遇到了同样的错误。我注释掉了旧的设置并粘贴了新的设置。问题是新设置缺少 DB_CONNECTION 变量：

DB_CONNECTION=pgsql

显然您需要添加您正在使用的任何连接类型：sqlite、mysql，...

Answer 8

我遇到了完全相同的问题。
我通过对 PDO 对象进行取消设置而不是将其设置为 NULL 来解决此问题。

例如：

function connectdb($dsn,$username,$password,$driver_options) {
    try {
        $dbh = new PDO($dsn,$username,$password,$driver_options);
        return $dbh;
    }
    catch(PDOException $e)
    {
        print "DB Error: ".$e->getMessage()."<br />";
        die();
    }
    
}

function closedb(&$dbh) {
    unset($dbh);             // use this line instead of $dbh = NULL;
}

此外，强烈建议取消所有 PDO 对象的设置。这包括包含准备好的语句的变量。

Answer 9

$pdo = new PDO(
    $dsn,
    $config['username'],
    $config['password'],
    array(
        PDO::ATTR_PERSISTENT => true,
        PDO::ATTR_ERRMODE    => PDO::ERRMODE_EXCEPTION
    )
);

试试这个。它可能会起作用