CodeExplorer
You are a developer and looking for Shopware projects?
Apply Now!
PDO example
$result = $stmt->execute();
if (0 === $stmt->rowCount()) {
break;
}
}
}
private function getConnection(): \PDO
{
if (!isset($this->conn)) {
$this->conn = new \PDO($this->dsn, $this->username, $this->password, $this->connectionOptions);
$this->conn->setAttribute(\PDO::ATTR_ERRMODE, \PDO::ERRMODE_EXCEPTION);
$this->checkDriver();
}
return $this->conn;
}
private function checkDriver(): void
{
if ('pgsql' !== $driver = $this->conn->getAttribute(\PDO::ATTR_DRIVER_NAME)) {
if (0 === $stmt->rowCount()) {
break;
}
}
}
private function getConnection(): \PDO
{
if (!isset($this->conn)) {
$this->conn = new \PDO($this->dsn, $this->username, $this->password, $this->connectionOptions);
$this->conn->setAttribute(\PDO::ATTR_ERRMODE, \PDO::ERRMODE_EXCEPTION);
$this->checkDriver();
}
return $this->conn;
}
private function checkDriver(): void
{
if ('pgsql' !== $driver = $this->conn->getAttribute(\PDO::ATTR_DRIVER_NAME)) {
$store1->delete($key);
$store2->save($key);
$this->assertTrue($store2->exists($key));
}
public function testWaitAndSaveAfterConflictReleasesLockFromInternalStore()
{
$store1 = $this->getStore();
$postgresHost = $this->getPostgresHost();
$pdo = new \PDO('pgsql:host='.$postgresHost, 'postgres', 'password');
$pdo->setAttribute(\PDO::ATTR_ERRMODE, \PDO::ERRMODE_EXCEPTION);
$store2 = new PostgreSqlStore($pdo);
$keyId = uniqid(__METHOD__, true);
$store1Key = new Key($keyId);
$store1->save($store1Key);
// set a low time out then try to wait and save, which will fail // because the key is already set above. $pdo->exec('SET statement_timeout = 1');
$store2->save($key);
$this->assertTrue($store2->exists($key));
}
public function testWaitAndSaveAfterConflictReleasesLockFromInternalStore()
{
$store1 = $this->getStore();
$postgresHost = $this->getPostgresHost();
$pdo = new \PDO('pgsql:host='.$postgresHost, 'postgres', 'password');
$pdo->setAttribute(\PDO::ATTR_ERRMODE, \PDO::ERRMODE_EXCEPTION);
$store2 = new PostgreSqlStore($pdo);
$keyId = uniqid(__METHOD__, true);
$store1Key = new Key($keyId);
$store1->save($store1Key);
// set a low time out then try to wait and save, which will fail // because the key is already set above. $pdo->exec('SET statement_timeout = 1');
class PdoCasterTest extends TestCase
{
use VarDumperTestTrait;
/** * @requires extension pdo_sqlite */
public function testCastPdo()
{
$pdo = new \PDO('sqlite::memory:');
$pdo->setAttribute(\PDO::ATTR_STATEMENT_CLASS, ['PDOStatement', [$pdo]]);
$pdo->setAttribute(\PDO::ATTR_ERRMODE, \PDO::ERRMODE_EXCEPTION);
$cast = PdoCaster::castPdo($pdo, [], new Stub(), false);
$this->assertInstanceOf(EnumStub::class, $cast["\0~\0attributes"]);
$attr = $cast["\0~\0attributes"] = $cast["\0~\0attributes"]->value;
$this->assertInstanceOf(ConstStub::class, $attr['CASE']);
$this->assertSame('NATURAL', $attr['CASE']->class);
$this->assertSame('BOTH', $attr['DEFAULT_FETCH_MODE']->class);
@unlink(self::$dbFile);
}
public function createCachePool(int $defaultLifetime = 0): CacheItemPoolInterface
{
return new PdoAdapter('sqlite:'.self::$dbFile, 'ns', $defaultLifetime);
}
public function testCleanupExpiredItems()
{
$pdo = new \PDO('sqlite:'.self::$dbFile);
$getCacheItemCount = fn () => (int) $pdo->query('SELECT COUNT(*) FROM cache_items')->fetch(\PDO::FETCH_COLUMN);
$this->assertSame(0, $getCacheItemCount());
$cache = $this->createCachePool();
$item = $cache->getItem('some_nice_key');
$item->expiresAfter(1);
$item->set(1);
class DatabaseFactory
{
/** * @throws Exception * @throws PDOException * * @return PDO */
public function createPDOConnection(DatabaseConnectionInformation $info)
{
$conn = new PDO(
$this->buildDsn($info),
$info->username,
$info->password,
[
PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC,
PDO::MYSQL_ATTR_INIT_COMMAND => 'SET NAMES utf8',
]
);
$this->setNonStrictSQLMode($conn);
{
/** * @throws Exception * @throws PDOException * * @return PDO */
public function createPDOConnection(DatabaseConnectionInformation $info)
{
$conn = new PDO(
$this->buildDsn($info),
$info->username,
$info->password,
[
PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC,
PDO::MYSQL_ATTR_INIT_COMMAND => 'SET NAMES utf8',
]
);
$this->setNonStrictSQLMode($conn);
if (isset($dbConfig['factory']) && class_exists($dbConfig['factory'])) {
$factory = $dbConfig['factory'];
return $factory::createPDO($dbConfig);
}
$password = $dbConfig['password'] ?? '';
$connectionString = self::buildConnectionString($dbConfig);
try {
$conn = new PDO(
'mysql:' . $connectionString,
$dbConfig['username'],
$password,
$dbConfig['pdoOptions'] ?? null
);
$conn->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
$conn->setAttribute(PDO::ATTR_DEFAULT_FETCH_MODE, PDO::FETCH_ASSOC);
$conn->setAttribute(PDO::ATTR_STRINGIFY_FETCHES, true);
// Reset sql_mode "STRICT_TRANS_TABLES" that will be default in MySQL 5.6
unset($this->pdo, $this->driver); // only close lazy-connection
}
return true;
}
/** * Lazy-connects to the database. */
private function connect(#[\SensitiveParameter] string $dsn): void {
$this->pdo = new \PDO($dsn, $this->username, $this->password, $this->connectionOptions);
$this->pdo->setAttribute(\PDO::ATTR_ERRMODE, \PDO::ERRMODE_EXCEPTION);
$this->driver = $this->pdo->getAttribute(\PDO::ATTR_DRIVER_NAME);
}
/** * Builds a PDO DSN from a URL-like connection string. * * @todo implement missing support for oci DSN (which look totally different from other PDO ones) */
private function buildDsnFromUrl(#[\SensitiveParameter] string $dsnOrUrl): string {
return true;
}
/** * Lazy-connects to the database. */
private function connect(#[\SensitiveParameter] string $dsn): void {
$this->pdo = new \PDO($dsn, $this->username, $this->password, $this->connectionOptions);
$this->pdo->setAttribute(\PDO::ATTR_ERRMODE, \PDO::ERRMODE_EXCEPTION);
$this->driver = $this->pdo->getAttribute(\PDO::ATTR_DRIVER_NAME);
}
/** * Builds a PDO DSN from a URL-like connection string. * * @todo implement missing support for oci DSN (which look totally different from other PDO ones) */
private function buildDsnFromUrl(#[\SensitiveParameter] string $dsnOrUrl): string {
'filePreDeleteCallback',
]);
}
}
parent::tearDown();
}
/** * Tests the quick-start command. */
public function testQuickStartCommand() {
$sqlite = (new \PDO('sqlite::memory:'))->query('select sqlite_version()')->fetch()[0];
if (version_compare($sqlite, Tasks::SQLITE_MINIMUM_VERSION) < 0) {
$this->markTestSkipped();
}
// Install a site using the standard profile to ensure the one time login // link generation works.
$install_command = [
$this->php,
'core/scripts/drupal',
'quick-start',
]);
}
}
parent::tearDown();
}
/** * Tests the quick-start command. */
public function testQuickStartCommand() {
$sqlite = (new \PDO('sqlite::memory:'))->query('select sqlite_version()')->fetch()[0];
if (version_compare($sqlite, Tasks::SQLITE_MINIMUM_VERSION) < 0) {
$this->markTestSkipped();
}
// Install a site using the standard profile to ensure the one time login // link generation works.
$install_command = [
$this->php,
'core/scripts/drupal',
'quick-start',
if (isset($dbConfig['port'])) {
$dsn[] = 'port=' . $dbConfig['port'];
}
if (isset($dbConfig['unix_socket'])) {
$dsn[] = 'unix_socket=' . $dbConfig['unix_socket'];
}
$dsn = 'mysql:' . implode(';', $dsn);
try {
$conn = new PDO(
$dsn,
$dbConfig['username'],
$dbConfig['password'],
[PDO::MYSQL_ATTR_INIT_COMMAND => "SET NAMES 'UTF8'"]
);
$conn->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
$conn->setAttribute(PDO::ATTR_DEFAULT_FETCH_MODE, PDO::FETCH_ASSOC);
} catch (PDOException $e) {
echo 'ERROR: ' . $e->getMessage();
exit(1);
}
$dsn[] = 'port=' . $dbConfig['port'];
}
if (isset($dbConfig['unix_socket'])) {
$dsn[] = 'unix_socket=' . $dbConfig['unix_socket'];
}
$dsn = 'mysql:' . implode(';', $dsn);
try {
$conn = new PDO(
$dsn,
$dbConfig['username'],
$dbConfig['password'],
[PDO::MYSQL_ATTR_INIT_COMMAND => "SET NAMES 'UTF8'"]
);
$conn->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
$conn->setAttribute(PDO::ATTR_DEFAULT_FETCH_MODE, PDO::FETCH_ASSOC);
} catch (PDOException $e) {
echo 'ERROR: ' . $e->getMessage();
exit(1);
}
\PDO::ATTR_EMULATE_PREPARES => TRUE,
// Limit SQL to a single statement like mysqli. \PDO::MYSQL_ATTR_MULTI_STATEMENTS => FALSE,
// Convert numeric values to strings when fetching. In PHP 8.1, // \PDO::ATTR_EMULATE_PREPARES now behaves the same way as non emulated // prepares and returns integers. See https://externals.io/message/113294 // for further discussion. \PDO::ATTR_STRINGIFY_FETCHES => TRUE,
];
try {
$pdo = new \PDO($dsn, $connection_options['username'], $connection_options['password'], $connection_options['pdo']);
}
catch (\PDOException $e) {
switch ($e->getCode()) {
case static::CONNECTION_REFUSED:
if (isset($connection_options['unix_socket'])) {
// Show message for socket connection via 'unix_socket' option. $message = 'Drupal is configured to connect to the database server via a socket, but the socket file could not be found.';
$message .= ' This message normally means that there is no MySQL server running on the system or that you are using an incorrect Unix socket file name when trying to connect to the server.';
throw new DatabaseConnectionRefusedException($e->getMessage() . ' [Tip: ' . $message . '] ', $e->getCode(), $e);
}
if (isset($connection_options['host']) && in_array(strtolower($connection_options['host']), ['', 'localhost'], TRUE)) {
// Limit SQL to a single statement like mysqli. \PDO::MYSQL_ATTR_MULTI_STATEMENTS => FALSE,
// Convert numeric values to strings when fetching. In PHP 8.1, // \PDO::ATTR_EMULATE_PREPARES now behaves the same way as non emulated // prepares and returns integers. See https://externals.io/message/113294 // for further discussion. \PDO::ATTR_STRINGIFY_FETCHES => TRUE,
];
try {
$pdo = new \PDO($dsn, $connection_options['username'], $connection_options['password'], $connection_options['pdo']);
}
catch (\PDOException $e) {
switch ($e->getCode()) {
case static::CONNECTION_REFUSED:
if (isset($connection_options['unix_socket'])) {
// Show message for socket connection via 'unix_socket' option. $message = 'Drupal is configured to connect to the database server via a socket, but the socket file could not be found.';
$message .= ' This message normally means that there is no MySQL server running on the system or that you are using an incorrect Unix socket file name when trying to connect to the server.';
throw new DatabaseConnectionRefusedException($e->getMessage() . ' [Tip: ' . $message . '] ', $e->getCode(), $e);
}
if (isset($connection_options['host']) && in_array(strtolower($connection_options['host']), ['', 'localhost'], TRUE)) {
if (str_contains($key, "\0") || str_contains($key, '%') || !preg_match('//u', $key)) {
$key = rawurlencode($key);
}
return parent::getId($key);
}
private function getConnection(): \PDO
{
if (!isset($this->conn)) {
$this->conn = new \PDO($this->dsn, $this->username, $this->password, $this->connectionOptions);
$this->conn->setAttribute(\PDO::ATTR_ERRMODE, \PDO::ERRMODE_EXCEPTION);
}
$this->driver ??= $this->conn->getAttribute(\PDO::ATTR_DRIVER_NAME);
return $this->conn;
}
private function getServerVersion(): string
{
return $this->serverVersion ??= $this->conn->getAttribute(\PDO::ATTR_SERVER_VERSION);
}
}
$key = rawurlencode($key);
}
return parent::getId($key);
}
private function getConnection(): \PDO
{
if (!isset($this->conn)) {
$this->conn = new \PDO($this->dsn, $this->username, $this->password, $this->connectionOptions);
$this->conn->setAttribute(\PDO::ATTR_ERRMODE, \PDO::ERRMODE_EXCEPTION);
}
$this->driver ??= $this->conn->getAttribute(\PDO::ATTR_DRIVER_NAME);
return $this->conn;
}
private function getServerVersion(): string
{
return $this->serverVersion ??= $this->conn->getAttribute(\PDO::ATTR_SERVER_VERSION);
}
}
return $this->pdo;
}
/** * Lazy-connects to the database. * * @param string $dsn DSN string */
private function connect($dsn)
{
$this->pdo = new PDO($dsn, $this->username, $this->password, $this->connectionOptions);
$this->pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
$this->driver = $this->pdo->getAttribute(PDO::ATTR_DRIVER_NAME);
}
/** * Helper method to begin a transaction. * * Since SQLite does not support row level locks, we have to acquire a reserved lock * on the database immediately. Because of https://bugs.php.net/42766 we have to create * such a transaction manually which also means we cannot use PDO::commit or * PDO::rollback or PDO::inTransaction for SQLite. * * Also MySQLs default isolation, REPEATABLE READ, causes deadlock for different sessions * due to http://www.mysqlperformanceblog.com/2013/12/12/one-more-innodb-gap-lock-to-avoid/ . * So we change it to READ COMMITTED. */
}
/** * Lazy-connects to the database. * * @param string $dsn DSN string */
private function connect($dsn)
{
$this->pdo = new PDO($dsn, $this->username, $this->password, $this->connectionOptions);
$this->pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
$this->driver = $this->pdo->getAttribute(PDO::ATTR_DRIVER_NAME);
}
/** * Helper method to begin a transaction. * * Since SQLite does not support row level locks, we have to acquire a reserved lock * on the database immediately. Because of https://bugs.php.net/42766 we have to create * such a transaction manually which also means we cannot use PDO::commit or * PDO::rollback or PDO::inTransaction for SQLite. * * Also MySQLs default isolation, REPEATABLE READ, causes deadlock for different sessions * due to http://www.mysqlperformanceblog.com/2013/12/12/one-more-innodb-gap-lock-to-avoid/ . * So we change it to READ COMMITTED. */
protected function getPersistentSqliteDsn()
{
$this->dbFile = tempnam(sys_get_temp_dir(), 'sf_sqlite_sessions');
return 'sqlite:'.$this->dbFile;
}
protected function getMemorySqlitePdo()
{
$pdo = new \PDO('sqlite::memory:');
$pdo->setAttribute(\PDO::ATTR_ERRMODE, \PDO::ERRMODE_EXCEPTION);
$storage = new PdoSessionHandler($pdo);
$storage->createTable();
return $pdo;
}
public function testWrongPdoErrMode()
{
$this->expectException(\InvalidArgumentException::class);
$pdo = $this->getMemorySqlitePdo();
unset($this->pdo, $this->driver); // only close lazy-connection
}
return true;
}
/** * Lazy-connects to the database. */
private function connect(#[\SensitiveParameter] string $dsn): void {
$this->pdo = new \PDO($dsn, $this->username, $this->password, $this->connectionOptions);
$this->pdo->setAttribute(\PDO::ATTR_ERRMODE, \PDO::ERRMODE_EXCEPTION);
$this->driver = $this->pdo->getAttribute(\PDO::ATTR_DRIVER_NAME);
}
/** * Builds a PDO DSN from a URL-like connection string. * * @todo implement missing support for oci DSN (which look totally different from other PDO ones) */
private function buildDsnFromUrl(#[\SensitiveParameter] string $dsnOrUrl): string {
return true;
}
/** * Lazy-connects to the database. */
private function connect(#[\SensitiveParameter] string $dsn): void {
$this->pdo = new \PDO($dsn, $this->username, $this->password, $this->connectionOptions);
$this->pdo->setAttribute(\PDO::ATTR_ERRMODE, \PDO::ERRMODE_EXCEPTION);
$this->driver = $this->pdo->getAttribute(\PDO::ATTR_DRIVER_NAME);
}
/** * Builds a PDO DSN from a URL-like connection string. * * @todo implement missing support for oci DSN (which look totally different from other PDO ones) */
private function buildDsnFromUrl(#[\SensitiveParameter] string $dsnOrUrl): string {
$stmt->bindValue(':id', $this->getHashedKey($key));
$stmt->bindValue(':token', $this->getUniqueToken($key));
$result = $stmt->execute();
return (bool) (\is_object($result) ? $result->fetchOne() : $stmt->fetchColumn());
}
private function getConnection(): \PDO
{
if (!isset($this->conn)) {
$this->conn = new \PDO($this->dsn, $this->username, $this->password, $this->connectionOptions);
$this->conn->setAttribute(\PDO::ATTR_ERRMODE, \PDO::ERRMODE_EXCEPTION);
}
return $this->conn;
}
/** * Creates the table to store lock keys which can be called once for setup. * * @throws \PDOException When the table already exists * @throws \DomainException When an unsupported PDO driver is used */
$stmt->bindValue(':token', $this->getUniqueToken($key));
$result = $stmt->execute();
return (bool) (\is_object($result) ? $result->fetchOne() : $stmt->fetchColumn());
}
private function getConnection(): \PDO
{
if (!isset($this->conn)) {
$this->conn = new \PDO($this->dsn, $this->username, $this->password, $this->connectionOptions);
$this->conn->setAttribute(\PDO::ATTR_ERRMODE, \PDO::ERRMODE_EXCEPTION);
}
return $this->conn;
}
/** * Creates the table to store lock keys which can be called once for setup. * * @throws \PDOException When the table already exists * @throws \DomainException When an unsupported PDO driver is used */