PDO implementiert eine Methode, um festzustellen, ob die Verbindung verfügbar ist

In diesem Artikel wird hauptsächlich die Methode von PHP PDO vorgestellt, um festzustellen, ob die Verbindung verfügbar ist. Ich hoffe, dass sie für alle hilfreich ist.

mysql_ping() Prüft, ob die Verbindung zum Server normal ist. Gibt true zurück, wenn eine Verbindung zum Server verfügbar ist, andernfalls false.

Aber PDO unterstützt die Methode mysql_ping() nicht, daher müssen Sie Ihren eigenen Code schreiben, um die Methode mysql_ping() zu simulieren und zu überprüfen, ob die Verbindung besteht verfügbar.

Der Code lautet wie folgt:

<?php
/**
 * 检查连接是否可用
 * @param Link $dbconn 数据库连接
 * @return Boolean
 */
function pdo_ping($dbconn){
  try{
    $dbconn->getAttribute(PDO::ATTR_SERVER_INFO);
  } catch (PDOException $e) {
    if(strpos($e->getMessage(), &#39;MySQL server has gone away&#39;)!==false){
      return false;
    }
  }
  return true;
}
?>

Codedemonstration:

1. Testdatentabelle erstellen

CREATE TABLE `user` (
 `id` int(11) unsigned NOT NULL AUTO_INCREMENT,
 `name` varchar(20) NOT NULL,
 PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

2. Testdaten einfügen

insert into user(name) values('fdipzone'),('xfdipzone'),('terry');

mysql> select * from user;
+----+-----------+
| id | name   |
+----+-----------+
| 1 | fdipzone |
| 2 | xfdipzone |
| 3 | terry   |
+----+-----------+

3. Demodatei

db.php

<?php
// 数据库操作类
class DB{

  // 保存数据库连接
  private static $_instance = null;

  // 连接数据库
  public static function get_conn($config){
    if(isset(self::$_instance) && !empty(self::$_instance)){
      return self::$_instance;
    }

    $dbhost = $config[&#39;host&#39;];
    $dbname = $config[&#39;dbname&#39;];
    $dbuser = $config[&#39;user&#39;];
    $dbpasswd = $config[&#39;password&#39;];
    $pconnect = $config[&#39;pconnect&#39;];
    $charset = $config[&#39;charset&#39;];

    $dsn = "mysql:host=$dbhost;dbname=$dbname;";
    try {
      $h_param = array(
          PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
      );
      if ($charset != &#39;&#39;) {
        $h_param[PDO::MYSQL_ATTR_INIT_COMMAND] = &#39;SET NAMES &#39; . $charset; //設置默認編碼
      }
      if ($pconnect) {
        $h_param[PDO::ATTR_PERSISTENT] = true;
      }
      $conn = new PDO($dsn, $dbuser, $dbpasswd, $h_param);

    } catch (PDOException $e) {
      throw new ErrorException(&#39;Unable to connect to db server. Error:&#39; . $e->getMessage(), 31);
    }

    self::$_instance = $conn;
    return $conn;
  }

  // 执行查询
  public static function query($dbconn, $sqlstr, $condparam){
    $sth = $dbconn->prepare($sqlstr);
    try{
      $sth->execute($condparam);
    } catch (PDOException $e) {
      echo $e->getMessage().PHP_EOL;
    }
    $result = $sth->fetchAll(PDO::FETCH_ASSOC);
    return $result;
  }

  // 重置连接
  public static function reset_connect(){
    self::$_instance = null;
  }

}
?>

test.php

<?php
require &#39;db.php&#39;;

// 数据库设定
$config = array(
  &#39;host&#39; => &#39;localhost&#39;,
  &#39;dbname&#39; => &#39;user&#39;,
  &#39;user&#39; => &#39;root&#39;,
  &#39;password&#39; => &#39;&#39;,
  &#39;pconnect&#39; => 0,
  &#39;charset&#39; => &#39;&#39;
);

// 循环执行
while(true){

  // 创建数据连接
  $dbconn = DB::get_conn($config);

  // 判断连接是否有效
  $status = pdo_ping($dbconn);

  if($status){
    echo &#39;connect ok&#39;.PHP_EOL;
  }else{
    echo &#39;connect failure&#39;.PHP_EOL;

    // 重置连接
    DB::reset_connect();
    $dbconn = DB::get_conn($config);
  }

  // 执行查询
  $sqlstr = &#39;select * from user where id=?&#39;;
  $condparam = array(mt_rand(1,3));
  $data = DB::query($dbconn, $sqlstr, $condparam);
  print_r($data);

  // 延时10秒
  echo &#39;sleep 10&#39;.PHP_EOL.PHP_EOL;
  sleep(10);

}

/**
 * 检查连接是否可用
 * @param Link $dbconn 数据库连接
 * @return Boolean
 */
function pdo_ping($dbconn){
  try{
    $dbconn->getAttribute(PDO::ATTR_SERVER_INFO);
  } catch (PDOException $e) {
    if(strpos($e->getMessage(), &#39;MySQL server has gone away&#39;)!==false){
      return false;
    }
  }
  return true;
}
?>

4. Ausführung

Führen Sie test.php im PHP-CLI-Modus aus und führen Sie dann sofort mysql.server stop und mysql.server start aus, um eine Flash-Unterbrechung zu simulieren

mysql.server stop
Shutting down MySQL
.... SUCCESS! 
mysql.server start
Starting MySQL
 SUCCESS!

Ausführungsausgabe:

connect ok
Array
(
  [0] => Array
    (
      [id] => 2
      [name] => xfdipzone
    )

)
sleep 10

connect failure
Array
(
  [0] => Array
    (
      [id] => 3
      [name] => terry
    )

)
sleep 10

connect ok
Array
(
  [0] => Array
    (
      [id] => 3
      [name] => terry
    )

)
sleep 10

Sie können sehen, dass nach dem Flash pdo_ping( ) gibt „false“ zurück und die Verbindung schlägt fehl. Rufen Sie dann die automatische Wiederverbindung auf, um sicherzustellen, dass nachfolgende Abfragen weiterhin ausgeführt werden können.

Das Obige ist der gesamte Inhalt dieses Artikels. Ich hoffe, er wird für das Studium aller hilfreich sein.

Verwandte Empfehlungen:

Verwenden Sie Composer, um den PHP-Namespace automatisch zu laden

PHP 3 Möglichkeiten, eine Verbindung zur Datenbank herzustellen

Vollständige Liste der Redis-Befehle unter PHP

Das obige ist der detaillierte Inhalt vonPDO implementiert eine Methode, um festzustellen, ob die Verbindung verfügbar ist. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!