mysql_ping() Checks whether the connection to the server is normal. Returns true if a connection to the server is available, false otherwise.
But PDO does not support themysql_ping()method, so you need to write your own code to simulate the mysql_ping() method to check whether the connection is available.
getAttribute(PDO::ATTR_SERVER_INFO); } catch (PDOException $e) { if(strpos($e->getMessage(), 'MySQL server has gone away')!==false){ return false; } } return true; }?>
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. Insert test data
insert into user(name) values('fdipzone'),('xfdipzone'),('terry');mysql> select * from user; +----+-----------+| id | name | +----+-----------+| 1 | fdipzone | | 2 | xfdipzone || 3 | terry | +----+-----------+
3.Demo file
db.php
PDO::ERRMODE_EXCEPTION, ); if ($charset != '') { $h_param[PDO::MYSQL_ATTR_INIT_COMMAND] = 'SET NAMES ' . $charset; //設置默認編碼 } if ($pconnect) { $h_param[PDO::ATTR_PERSISTENT] = true; } $conn = new PDO($dsn, $dbuser, $dbpasswd, $h_param); } catch (PDOException $e) { throw new ErrorException('Unable to connect to db server. Error:' . $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
'localhost', 'dbname' => 'user', 'user' => 'root', 'password' => '', 'pconnect' => 0, 'charset' => '');// 循环执行while(true){ // 创建数据连接 $dbconn = DB::get_conn($config); // 判断连接是否有效 $status = pdo_ping($dbconn); if($status){ echo 'connect ok'.PHP_EOL; }else{ echo 'connect failure'.PHP_EOL; // 重置连接 DB::reset_connect(); $dbconn = DB::get_conn($config); } // 执行查询 $sqlstr = 'select * from user where id=?'; $condparam = array(mt_rand(1,3)); $data = DB::query($dbconn, $sqlstr, $condparam); print_r($data); // 延时10秒 echo 'sleep 10'.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(), 'MySQL server has gone away')!==false){ return false; } } return true; }?>
4. Execute
Execute test.php in php cli mode, and then immediately execute mysql.server stop and mysql.server start to simulate an interruption
mysql.server stopShutting down MySQL .... SUCCESS! mysql.server start Starting MySQL SUCCESS!
Execution output:
connect okArray( [0] => Array ( [id] => 2 [name] => xfdipzone ) ) sleep 10connect failureArray( [0] => Array ( [id] => 3 [name] => terry ) ) sleep 10connect okArray( [0] => Array ( [id] => 3 [name] => terry ) ) sleep 10
You can see that after the interruption, pdo_ping() returns false, the connection fails, and then calls automatic reconnection to ensure that subsequent queries can continue to be executed.
This article explains how to determine whether the connection is available through PDO in php. For more related content, please pay attention to the php Chinese website.
Related recommendations:
Use php to determine whether the page or image has been gzip compressed
HTML5 gets the current geographical location and The example shown on Baidu Map
Create a unique number class through the auto-increment id in php
The above is the detailed content of How to determine whether the connection is available through PDO in php. For more information, please follow other related articles on the PHP Chinese website!