Как восстановить соединение с MySQL через PDO в PHP-скрипте?

Question

[Remmi]

На сервере под Windows Server 2003 работает PHP-скрипт в режиме CLI (что-то вроде демона), он принимает данные и записывает их в базу.

Соединение с базой устанавливается через PDO с помощью самописного класса:

class DB {
    protected static $dbInstance;

    private function __construct() {
        return self;
    }
    private function __clone() {
        return self;
    }

    private function __wakeup() {
        return self;
    }

    public static function getDB () {
        if (is_null(self::$dbInstance)) {
            try {
                $cfg = Config::getConfig();
                self::$dbInstance = new PDO(
                    'mysql:host='.$cfg['dbHost'].';dbname='.$cfg['dbName'].''
                    , $cfg['dbUser']
                    , $cfg['dbPass']);
            }
            catch (PDOException $e) {
                return false;
            }
        }
        return self::$dbInstance;
    }
}

Когда данные идут непрерывно, соединение держится отлично. Но при простое скрипта более 17 часов (может быть и меньше) - данные перестают записываться. Проверка соединения на null результатов не принесла. Могу предположить, что надо как-то проверять состояние соединения.

Вопрос: как проверить наличие соединения с MySQL через PDO?

Answer 1

[Алексей]

На сколько я помню, там нет функции пинг.
Можно воспользоваться чем то таким http://terenceyim.wordpress.com/2009/01/09/adding-ping-function-to-pdo/ или извратится по своему.

Comments

[Remmi]

Спасибо, похоже именно это и было нужно. Буду проверять, о результатах отпишусь завтра.

[Remmi]

С первого раза не заработало, скорее всего сам в реализации ошибся. Грешу на то, что перед инициализацией нового PDO-объекта не обнулял его.

[Remmi]

Функция пинга работает, но при сбросе по таймауту говорит, что соединение активно. То есть, запрос "SELECT 1" выполняется корректно. Либо делать принудительный реконнект после определённого промежутка времени, либо продолжать искать косяки. Возможно, что Exception не срабатывает в пинге.

Answer 2

[Opaspap]

что то типа

private $lastping=0;
public function ping() {
    if ((time()-$this->lastping)<10) return;
    try {
        self::$dbInstance->query('SELECT 1');
    } catch {
       self::$dbInstance=NULL;
       self::getDB();
    }
    $this->lastping=time();
}

Это если ping нужен, я как понимаю у вас standalone приложение, можно наверное этот пинг заставить не каждый раз ping делать, а скажем не чаще раз в 10 сек, чтобы когда много подряд запросов не проверять, а ловить уже исключения (если уж порвалось соединение по причине остановки сервера, например)

upd: реализовал что написал выше, т.к. заметил ответ @ScorpLeX

Comments

[Remmi]

Всё отлично :) Единственное, что мне не по душе в этом варианте - фиксированный таймаут. Если не получится по своему реализовать, буду делать именно такой вариант.

Answer 3

[Remmi]

Спасибо @ScorpLeX и @Opaspap за верное направление.

Решил задачу следующим образом: написал функцию пинга, но не просто отправлял запрос "SELECT 1" к базе, а запрос с простым арифметическим выражением и проверял его результат. Без проверки показывало, что запрос выполняется корректно, а на самом деле это было не так (подозреваю, что надо было включать исключения четвёртым параметром).

/**
     * Проверка состояния соединения: активно или нет
     * @return bool
     */
    public static function isActiveConnection () {
        if (is_null(self::$dbInstance)) {            
            return false;
        }

        try {
            $testRes = self::$dbInstance->query('SELECT 1+2+3');
            $testArray = $testRes->fetch();
            if ($testArray[0] == 6) {
                return true;
            }
        }
        catch (PDOException $e) {
            return false;
        }
        return false;
    }

    /**
     * Возвращает объект базы данных для дальнейшей работы
     * @return mixed
     */
    public static function getDB () {
        if (!self::isActiveConnection()) {
            self::initConnection();    
        }
        return self::$dbInstance;
    }

Answer 4

[ertaquo]

В конструкторе PDO четвертым параметром передавайте array(PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION), тогда вроде должны генерироваться исключения.

Answer 5

[bredmm]

если соединение с базой именно обрывается то всегда вернется ошибка "MySQL server has gone away" от mysql клиента на сервере, можно отлавливать ее

Answer 6

[toxa82]

Самый простой способ установить переменную MySQL wait_timeout по-больше. Но если окажется слишком много висящих соединений можно упереться в лимит коннектов.

Comments

[Алексей]

Не делайте так.

[Remmi]

Сначала рассматривал этот вариант, но не стал так делать, потому что
1) с базой работает не только скрипт
2) неизвестно максимальное время соединения
3) если можно проверять и восстанавливать, увеличивать таймаут незачем

Answer 7

[Максим Гаврилов]

Лучше не терять соединение:

$this -> pdo = new \PDO(
                "mysql:host=" . $this -> DB_HOST . " ;dbname=" . $this -> DB_NAME . ";", 
                $this -> DB_USER, 
                $this -> DB_PW,
                array(\PDO::ATTR_PERSISTENT => true)
            );