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
or
"require": {
"phlib/db": "*"
}
$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.
Adapter::__clone
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()) {
$db->disableBuffering();
}
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) {
$this->logException($e);
}
+-- \Exception | +-- \InvalidArgumentException | | +-- \Phlib\Db\Exception\InvalidArgumentException | +-- \RuntimeException | | +-- \PDOException | | | +-- \Phlib\Db\Exception\RuntimeException | | | | +-- \Phlib\Db\Exception\UnknownDatabaseException | | | | +-- \Phlib\Db\Exception\InvalidQueryException
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
Setting the connection from outside the class will cause odd behaviour.
$pdo = new \PDO('mysql:host=localhost');
$db = new \Phlib\Db\Adapter();
$db->setConnection($pdo);
$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 http://www.gnu.org/licenses/.