MySQL PDO DB Adapter. PDO with some extra good stuff specifically for MySQL.

2.1.0 2022-01-02 08:33 UTC

This package is auto-updated.

Last update: 2024-07-03 08:57:51 UTC



Code Checks Codecov Latest Stable Version Total Downloads Licence

MySQL PDO DB Adapter. PDO with some extra good stuff specifically for MySQL.

What this DB wrapper offers over others.

  • Database switching method
  • Unified unknown database exception
  • Capturing invalid SQL statements exception
  • Automatic reconnect useful for long running processes (server has gone away)
  • Connection retries on failed to connect
  • Connection cloning
  • Useful additional methods for:
    • timezone
    • buffering
    • quoting (tables, columns, values)
    • select
    • insert
    • update
    • delete


Via Composer

$ composer require phlib/db


"require": {
    "phlib/db": "*"

Basic Usage

$config = [
    'host' => 'localhost',
    'username' => 'myuser',
    'password' => 'mypassword',
    'dbname' => 'mydatabase'
$db = new \Phlib\Db\Adapter($config);
$table = $db->quoteIdentifier('mytable');
/* @var $stmt \PDOStatement */
$stmt = $db->query("SELECT * FROM $table WHERE id = ?", [$rowId]);


Name Type Required Default Description
host String Yes Hostname or IP address.
username String No '' Username to connect to server.
password String No '' Password to connect to server.
port Integer No Port to connect to server.
dbname String No Database name to use.
charset String No 'utf8mb4' Sets the character to use on the connection.
timezone String No '+0:00' Sets the timezone to use on the connection. Values: 'system', '+\-dd:dd' or 'timezone'. MySQL Manual
timeout Integer No 2 Sets the connection timeout. Range from 0 to 120.
retryCount Integer No 0 Sets how many times to try to reconnect to the DB server after unsuccessful connection attempts. Range from 0 to 10.
attributes Array No [] Driver-specific options used when connecting, e.g. \PDO::ATTR_*


The following section documents the less obvious API's. Most methods are doc blocked and are self explanatory.


This is useful when you're dealing with the results of one query while inserting as both operations can not be done on the same connection.

$db2 = (clone)$db1;

Adapter Buffering

This is useful when requesting large amounts of data from the DB server. By default, PDO will pull all the results back and hold the results in memory even for fetch() calls. With large result sets this causes out of memory problems. To stop PDO pulling the results back turn off buffering.

if ($db->isBuffered()) {


All Phlib Db Exceptions implement the \Phlib\Db\Exception\Exception interface.

try {
    $db = new \Phlib\Db\Adapter($config);
    $result = $db->query($sql, $bind);
} catch (\Phlib\Db\Exception\Exception $e) {


+-- \Exception
|  +-- \InvalidArgumentException
|  |  +-- \Phlib\Db\Exception\InvalidArgumentException
|  +-- \RuntimeException
|  |  +-- \PDOException
|  |  |  +-- \Phlib\Db\Exception\RuntimeException
|  |  |  |  +-- \Phlib\Db\Exception\UnknownDatabaseException
|  |  |  |  +-- \Phlib\Db\Exception\InvalidQueryException

Invalid Query

The InvalidQueryException has special methods for retrieving the query and associated bind parameters. The message recorded for exception includes these details but the methods allow a clean way of extracting them.

  • getQuery
  • getBindData

Known Issues

Setting the connection from outside the class will cause odd behaviour.

$pdo = new \PDO('mysql:host=localhost');
$db = new \Phlib\Db\Adapter();
$config = $db->getConfig(); // config is an empty array

$db->reconnect(); // throws InvalidArgumentException missing host param.


This package is free software: you can redistribute it and/or modify it under the terms of the GNU Lesser General Public License as published by the Free Software Foundation, either version 3 of the License, or (at your option) any later version.

This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public License for more details.

You should have received a copy of the GNU Lesser General Public License along with this program. If not, see