class Connection
Same name in this branch
- 9 core/modules/mysql/src/Driver/Database/mysql/Connection.php \Drupal\mysql\Driver\Database\mysql\Connection
- 9 core/modules/system/tests/modules/database_statement_monitoring_test/src/sqlite/Connection.php \Drupal\database_statement_monitoring_test\sqlite\Connection
- 9 core/modules/system/tests/modules/database_statement_monitoring_test/src/mysql/Connection.php \Drupal\database_statement_monitoring_test\mysql\Connection
- 9 core/modules/system/tests/modules/database_statement_monitoring_test/src/pgsql/Connection.php \Drupal\database_statement_monitoring_test\pgsql\Connection
- 9 core/modules/system/tests/modules/driver_test/src/Driver/Database/DrivertestMysql/Connection.php \Drupal\driver_test\Driver\Database\DrivertestMysql\Connection
- 9 core/modules/system/tests/modules/driver_test/src/Driver/Database/DrivertestMysqlDeprecatedVersion/Connection.php \Drupal\driver_test\Driver\Database\DrivertestMysqlDeprecatedVersion\Connection
- 9 core/modules/system/tests/modules/driver_test/src/Driver/Database/DrivertestPgsql/Connection.php \Drupal\driver_test\Driver\Database\DrivertestPgsql\Connection
- 9 core/modules/pgsql/src/Driver/Database/pgsql/Connection.php \Drupal\pgsql\Driver\Database\pgsql\Connection
- 9 core/tests/fixtures/database_drivers/module/corefake/src/Driver/Database/corefake/Connection.php \Drupal\corefake\Driver\Database\corefake\Connection
- 9 core/tests/fixtures/database_drivers/module/corefake/src/Driver/Database/corefakeWithAllCustomClasses/Connection.php \Drupal\corefake\Driver\Database\corefakeWithAllCustomClasses\Connection
- 9 core/tests/fixtures/database_drivers/core/corefake/Connection.php \Drupal\Core\Database\Driver\corefake\Connection
- 9 core/tests/fixtures/database_drivers/custom/corefake/Connection.php \Drupal\Driver\Database\corefake\Connection
- 9 core/tests/fixtures/database_drivers/custom/fake/Connection.php \Drupal\Driver\Database\fake\Connection
- 9 core/lib/Drupal/Core/Database/Driver/sqlite/Connection.php \Drupal\Core\Database\Driver\sqlite\Connection
- 9 core/lib/Drupal/Core/Database/Driver/mysql/Connection.php \Drupal\Core\Database\Driver\mysql\Connection
- 9 core/lib/Drupal/Core/Database/Driver/pgsql/Connection.php \Drupal\Core\Database\Driver\pgsql\Connection
- 9 core/lib/Drupal/Core/Database/Connection.php \Drupal\Core\Database\Connection
Same name in other branches
- 8.9.x core/modules/system/tests/modules/database_statement_monitoring_test/src/sqlite/Connection.php \Drupal\database_statement_monitoring_test\sqlite\Connection
- 8.9.x core/modules/system/tests/modules/database_statement_monitoring_test/src/mysql/Connection.php \Drupal\database_statement_monitoring_test\mysql\Connection
- 8.9.x core/modules/system/tests/modules/database_statement_monitoring_test/src/pgsql/Connection.php \Drupal\database_statement_monitoring_test\pgsql\Connection
- 8.9.x core/modules/system/tests/modules/driver_test/src/Driver/Database/DrivertestMysql/Connection.php \Drupal\driver_test\Driver\Database\DrivertestMysql\Connection
- 8.9.x core/modules/system/tests/modules/driver_test/src/Driver/Database/DrivertestMysqlDeprecatedVersion/Connection.php \Drupal\driver_test\Driver\Database\DrivertestMysqlDeprecatedVersion\Connection
- 8.9.x core/modules/system/tests/modules/driver_test/src/Driver/Database/DrivertestPgsql/Connection.php \Drupal\driver_test\Driver\Database\DrivertestPgsql\Connection
- 8.9.x core/tests/fixtures/database_drivers/module/corefake/src/Driver/Database/corefake/Connection.php \Drupal\corefake\Driver\Database\corefake\Connection
- 8.9.x core/tests/fixtures/database_drivers/core/corefake/Connection.php \Drupal\Core\Database\Driver\corefake\Connection
- 8.9.x core/tests/fixtures/database_drivers/custom/corefake/Connection.php \Drupal\Driver\Database\corefake\Connection
- 8.9.x core/tests/fixtures/database_drivers/custom/fake/Connection.php \Drupal\Driver\Database\fake\Connection
- 8.9.x core/lib/Drupal/Core/Database/Driver/sqlite/Connection.php \Drupal\Core\Database\Driver\sqlite\Connection
- 8.9.x core/lib/Drupal/Core/Database/Driver/mysql/Connection.php \Drupal\Core\Database\Driver\mysql\Connection
- 8.9.x core/lib/Drupal/Core/Database/Driver/pgsql/Connection.php \Drupal\Core\Database\Driver\pgsql\Connection
- 8.9.x core/lib/Drupal/Core/Database/Connection.php \Drupal\Core\Database\Connection
- 10 core/modules/sqlite/src/Driver/Database/sqlite/Connection.php \Drupal\sqlite\Driver\Database\sqlite\Connection
- 10 core/modules/mysql/src/Driver/Database/mysql/Connection.php \Drupal\mysql\Driver\Database\mysql\Connection
- 10 core/modules/system/tests/modules/database_statement_monitoring_test/src/sqlite/Connection.php \Drupal\database_statement_monitoring_test\sqlite\Connection
- 10 core/modules/system/tests/modules/database_statement_monitoring_test/src/mysql/Connection.php \Drupal\database_statement_monitoring_test\mysql\Connection
- 10 core/modules/system/tests/modules/database_statement_monitoring_test/src/pgsql/Connection.php \Drupal\database_statement_monitoring_test\pgsql\Connection
- 10 core/modules/system/tests/modules/driver_test/src/Driver/Database/DrivertestMysql/Connection.php \Drupal\driver_test\Driver\Database\DrivertestMysql\Connection
- 10 core/modules/system/tests/modules/driver_test/src/Driver/Database/DrivertestMysqlDeprecatedVersion/Connection.php \Drupal\driver_test\Driver\Database\DrivertestMysqlDeprecatedVersion\Connection
- 10 core/modules/system/tests/modules/driver_test/src/Driver/Database/DrivertestPgsql/Connection.php \Drupal\driver_test\Driver\Database\DrivertestPgsql\Connection
- 10 core/modules/pgsql/src/Driver/Database/pgsql/Connection.php \Drupal\pgsql\Driver\Database\pgsql\Connection
- 10 core/tests/fixtures/database_drivers/module/core_fake/src/Driver/Database/CoreFake/Connection.php \Drupal\core_fake\Driver\Database\CoreFake\Connection
- 10 core/tests/fixtures/database_drivers/module/core_fake/src/Driver/Database/CoreFakeWithAllCustomClasses/Connection.php \Drupal\core_fake\Driver\Database\CoreFakeWithAllCustomClasses\Connection
- 10 core/tests/fixtures/database_drivers/core/CoreFake/Connection.php \Drupal\Core\Database\Driver\CoreFake\Connection
- 10 core/tests/fixtures/database_drivers/custom/CoreFake/Connection.php \Drupal\Driver\Database\CoreFake\Connection
- 10 core/tests/fixtures/database_drivers/custom/fake/Connection.php \Drupal\Driver\Database\fake\Connection
- 10 core/lib/Drupal/Core/Database/Driver/sqlite/Connection.php \Drupal\Core\Database\Driver\sqlite\Connection
- 10 core/lib/Drupal/Core/Database/Driver/mysql/Connection.php \Drupal\Core\Database\Driver\mysql\Connection
- 10 core/lib/Drupal/Core/Database/Driver/pgsql/Connection.php \Drupal\Core\Database\Driver\pgsql\Connection
- 10 core/lib/Drupal/Core/Database/Connection.php \Drupal\Core\Database\Connection
- 11.x core/modules/sqlite/src/Driver/Database/sqlite/Connection.php \Drupal\sqlite\Driver\Database\sqlite\Connection
- 11.x core/modules/mysql/src/Driver/Database/mysql/Connection.php \Drupal\mysql\Driver\Database\mysql\Connection
- 11.x core/modules/system/tests/modules/driver_test/src/Driver/Database/DriverTestMysql/Connection.php \Drupal\driver_test\Driver\Database\DriverTestMysql\Connection
- 11.x core/modules/system/tests/modules/driver_test/src/Driver/Database/DriverTestMysqlDeprecatedVersion/Connection.php \Drupal\driver_test\Driver\Database\DriverTestMysqlDeprecatedVersion\Connection
- 11.x core/modules/system/tests/modules/driver_test/src/Driver/Database/DriverTestPgsql/Connection.php \Drupal\driver_test\Driver\Database\DriverTestPgsql\Connection
- 11.x core/modules/pgsql/src/Driver/Database/pgsql/Connection.php \Drupal\pgsql\Driver\Database\pgsql\Connection
- 11.x core/tests/fixtures/database_drivers/module/core_fake/src/Driver/Database/CoreFake/Connection.php \Drupal\core_fake\Driver\Database\CoreFake\Connection
- 11.x core/tests/fixtures/database_drivers/module/core_fake/src/Driver/Database/CoreFakeWithAllCustomClasses/Connection.php \Drupal\core_fake\Driver\Database\CoreFakeWithAllCustomClasses\Connection
- 11.x core/tests/fixtures/database_drivers/core/CoreFake/Connection.php \Drupal\Core\Database\Driver\CoreFake\Connection
- 11.x core/tests/fixtures/database_drivers/custom/CoreFake/Connection.php \Drupal\Driver\Database\CoreFake\Connection
- 11.x core/tests/fixtures/database_drivers/custom/fake/Connection.php \Drupal\Driver\Database\fake\Connection
- 11.x core/lib/Drupal/Core/Database/Connection.php \Drupal\Core\Database\Connection
SQLite implementation of \Drupal\Core\Database\Connection.
Hierarchy
- class \Drupal\Core\Database\Connection
- class \Drupal\sqlite\Driver\Database\sqlite\Connection extends \Drupal\Core\Database\Connection
Expanded class hierarchy of Connection
8 files declare their use of Connection
- Connection.php in core/
modules/ system/ tests/ modules/ database_statement_monitoring_test/ src/ sqlite/ Connection.php - Connection.php in core/
lib/ Drupal/ Core/ Database/ Driver/ sqlite/ Connection.php - ConnectionTest.php in core/
modules/ sqlite/ tests/ src/ Unit/ ConnectionTest.php - MigrateSqlIdMapTest.php in core/
modules/ migrate/ tests/ src/ Unit/ MigrateSqlIdMapTest.php - MigrateSqlSourceTestBase.php in core/
modules/ migrate/ tests/ src/ Kernel/ MigrateSqlSourceTestBase.php
5 string references to 'Connection'
- DriverSpecificConnectionUnitTestBase::testConnectionOpen in core/
tests/ Drupal/ KernelTests/ Core/ Database/ DriverSpecificConnectionUnitTestBase.php - Tests pdo options override.
- FileTransfer::__get in core/
lib/ Drupal/ Core/ FileTransfer/ FileTransfer.php - Implements the magic __get() method.
- FileTransfer::__isset in core/
lib/ Drupal/ Core/ FileTransfer/ FileTransfer.php - FileTransfer::__set in core/
lib/ Drupal/ Core/ FileTransfer/ FileTransfer.php - FileTransfer::__unset in core/
lib/ Drupal/ Core/ FileTransfer/ FileTransfer.php
File
-
core/
modules/ sqlite/ src/ Driver/ Database/ sqlite/ Connection.php, line 13
Namespace
Drupal\sqlite\Driver\Database\sqliteView source
class Connection extends DatabaseConnection {
/**
* Error code for "Unable to open database file" error.
*/
const DATABASE_NOT_FOUND = 14;
/**
* {@inheritdoc}
*/
protected $statementClass = NULL;
/**
* {@inheritdoc}
*/
protected $statementWrapperClass = NULL;
/**
* Whether or not the active transaction (if any) will be rolled back.
*
* @var bool
*/
protected $willRollback;
/**
* A map of condition operators to SQLite operators.
*
* We don't want to override any of the defaults.
*/
protected static $sqliteConditionOperatorMap = [
'LIKE' => [
'postfix' => " ESCAPE '\\'",
],
'NOT LIKE' => [
'postfix' => " ESCAPE '\\'",
],
'LIKE BINARY' => [
'postfix' => " ESCAPE '\\'",
'operator' => 'GLOB',
],
'NOT LIKE BINARY' => [
'postfix' => " ESCAPE '\\'",
'operator' => 'NOT GLOB',
],
];
/**
* All databases attached to the current database.
*
* This is used to allow prefixes to be safely handled without locking the
* table.
*
* @var array
*/
protected $attachedDatabases = [];
/**
* Whether or not a table has been dropped this request.
*
* The destructor will only try to get rid of unnecessary databases if there
* is potential of them being empty.
*
* This variable is set to public because Schema needs to
* access it. However, it should not be manually set.
*
* @var bool
*/
public $tableDropped = FALSE;
/**
* {@inheritdoc}
*/
protected $transactionalDDLSupport = TRUE;
/**
* {@inheritdoc}
*/
protected $identifierQuotes = [
'"',
'"',
];
/**
* Constructs a \Drupal\sqlite\Driver\Database\sqlite\Connection object.
*/
public function __construct(\PDO $connection, array $connection_options) {
parent::__construct($connection, $connection_options);
// Attach one database for each registered prefix.
$prefixes = $this->prefixes;
foreach ($prefixes as &$prefix) {
// Empty prefix means query the main database -- no need to attach
// anything.
if ($prefix !== '') {
$this->attachDatabase($prefix);
// Add a ., so queries become prefix.table, which is proper syntax for
// querying an attached database.
$prefix .= '.';
}
}
// Regenerate the prefixes replacement table.
$this->setPrefix($prefixes);
}
/**
* {@inheritdoc}
*/
public static function open(array &$connection_options = []) {
// Allow PDO options to be overridden.
$connection_options += [
'pdo' => [],
];
$connection_options['pdo'] += [
\PDO::ATTR_ERRMODE => \PDO::ERRMODE_EXCEPTION,
// Convert numeric values to strings when fetching.
\PDO::ATTR_STRINGIFY_FETCHES => TRUE,
];
try {
$pdo = new PDOConnection('sqlite:' . $connection_options['database'], '', '', $connection_options['pdo']);
} catch (\PDOException $e) {
if ($e->getCode() == static::DATABASE_NOT_FOUND) {
throw new DatabaseNotFoundException($e->getMessage(), $e->getCode(), $e);
}
// SQLite doesn't have a distinct error code for access denied, so don't
// deal with that case.
throw $e;
}
// Create functions needed by SQLite.
$pdo->sqliteCreateFunction('if', [
__CLASS__,
'sqlFunctionIf',
]);
$pdo->sqliteCreateFunction('greatest', [
__CLASS__,
'sqlFunctionGreatest',
]);
$pdo->sqliteCreateFunction('least', [
__CLASS__,
'sqlFunctionLeast',
]);
$pdo->sqliteCreateFunction('pow', 'pow', 2);
$pdo->sqliteCreateFunction('exp', 'exp', 1);
$pdo->sqliteCreateFunction('length', 'strlen', 1);
$pdo->sqliteCreateFunction('md5', 'md5', 1);
$pdo->sqliteCreateFunction('concat', [
__CLASS__,
'sqlFunctionConcat',
]);
$pdo->sqliteCreateFunction('concat_ws', [
__CLASS__,
'sqlFunctionConcatWs',
]);
$pdo->sqliteCreateFunction('substring', [
__CLASS__,
'sqlFunctionSubstring',
], 3);
$pdo->sqliteCreateFunction('substring_index', [
__CLASS__,
'sqlFunctionSubstringIndex',
], 3);
$pdo->sqliteCreateFunction('rand', [
__CLASS__,
'sqlFunctionRand',
]);
$pdo->sqliteCreateFunction('regexp', [
__CLASS__,
'sqlFunctionRegexp',
]);
// SQLite does not support the LIKE BINARY operator, so we overload the
// non-standard GLOB operator for case-sensitive matching. Another option
// would have been to override another non-standard operator, MATCH, but
// that does not support the NOT keyword prefix.
$pdo->sqliteCreateFunction('glob', [
__CLASS__,
'sqlFunctionLikeBinary',
]);
// Create a user-space case-insensitive collation with UTF-8 support.
$pdo->sqliteCreateCollation('NOCASE_UTF8', [
'Drupal\\Component\\Utility\\Unicode',
'strcasecmp',
]);
// Set SQLite init_commands if not already defined. Enable the Write-Ahead
// Logging (WAL) for SQLite. See https://www.drupal.org/node/2348137 and
// https://www.sqlite.org/wal.html.
$connection_options += [
'init_commands' => [],
];
$connection_options['init_commands'] += [
'wal' => "PRAGMA journal_mode=WAL",
];
// Execute sqlite init_commands.
if (isset($connection_options['init_commands'])) {
$pdo->exec(implode('; ', $connection_options['init_commands']));
}
return $pdo;
}
/**
* Destructor for the SQLite connection.
*
* We prune empty databases on destruct, but only if tables have been
* dropped. This is especially needed when running the test suite, which
* creates and destroy databases several times in a row.
*/
public function __destruct() {
if ($this->tableDropped && !empty($this->attachedDatabases)) {
foreach ($this->attachedDatabases as $prefix) {
// Check if the database is now empty, ignore the internal SQLite tables.
try {
$count = $this->query('SELECT COUNT(*) FROM ' . $prefix . '.sqlite_master WHERE type = :type AND name NOT LIKE :pattern', [
':type' => 'table',
':pattern' => 'sqlite_%',
])
->fetchField();
// We can prune the database file if it doesn't have any tables.
if ($count == 0 && $this->connectionOptions['database'] != ':memory:' && file_exists($this->connectionOptions['database'] . '-' . $prefix)) {
// Detach the database.
$this->query('DETACH DATABASE :schema', [
':schema' => $prefix,
]);
// Destroy the database file.
unlink($this->connectionOptions['database'] . '-' . $prefix);
}
} catch (\Exception $e) {
// Ignore the exception and continue. There is nothing we can do here
// to report the error or fail safe.
}
}
}
parent::__destruct();
}
/**
* {@inheritdoc}
*/
public function attachDatabase(string $database) : void {
// Only attach the database once.
if (!isset($this->attachedDatabases[$database])) {
// In memory database use ':memory:' as database name. According to
// http://www.sqlite.org/inmemorydb.html it will open a unique database so
// attaching it twice is not a problem.
$database_file = $this->connectionOptions['database'] !== ':memory:' ? $this->connectionOptions['database'] . '-' . $database : $this->connectionOptions['database'];
$this->query('ATTACH DATABASE :database_file AS :database', [
':database_file' => $database_file,
':database' => $database,
]);
$this->attachedDatabases[$database] = $database;
}
}
/**
* Gets all the attached databases.
*
* @return array
* An array of attached database names.
*
* @see \Drupal\sqlite\Driver\Database\sqlite\Connection::__construct()
*/
public function getAttachedDatabases() {
return $this->attachedDatabases;
}
/**
* SQLite compatibility implementation for the IF() SQL function.
*/
public static function sqlFunctionIf($condition, $expr1, $expr2 = NULL) {
return $condition ? $expr1 : $expr2;
}
/**
* SQLite compatibility implementation for the GREATEST() SQL function.
*/
public static function sqlFunctionGreatest() {
$args = func_get_args();
foreach ($args as $v) {
if (!isset($v)) {
unset($args);
}
}
if (count($args)) {
return max($args);
}
else {
return NULL;
}
}
/**
* SQLite compatibility implementation for the LEAST() SQL function.
*/
public static function sqlFunctionLeast() {
// Remove all NULL, FALSE and empty strings values but leaves 0 (zero) values.
$values = array_filter(func_get_args(), 'strlen');
return count($values) < 1 ? NULL : min($values);
}
/**
* SQLite compatibility implementation for the CONCAT() SQL function.
*/
public static function sqlFunctionConcat() {
$args = func_get_args();
return implode('', $args);
}
/**
* SQLite compatibility implementation for the CONCAT_WS() SQL function.
*
* @see http://dev.mysql.com/doc/refman/5.6/en/string-functions.html#function_concat-ws
*/
public static function sqlFunctionConcatWs() {
$args = func_get_args();
$separator = array_shift($args);
// If the separator is NULL, the result is NULL.
if ($separator === FALSE || is_null($separator)) {
return NULL;
}
// Skip any NULL values after the separator argument.
$args = array_filter($args, function ($value) {
return !is_null($value);
});
return implode($separator, $args);
}
/**
* SQLite compatibility implementation for the SUBSTRING() SQL function.
*/
public static function sqlFunctionSubstring($string, $from, $length) {
return substr($string, $from - 1, $length);
}
/**
* SQLite compatibility implementation for the SUBSTRING_INDEX() SQL function.
*/
public static function sqlFunctionSubstringIndex($string, $delimiter, $count) {
// If string is empty, simply return an empty string.
if (empty($string)) {
return '';
}
$end = 0;
for ($i = 0; $i < $count; $i++) {
$end = strpos($string, $delimiter, $end + 1);
if ($end === FALSE) {
$end = strlen($string);
}
}
return substr($string, 0, $end);
}
/**
* SQLite compatibility implementation for the RAND() SQL function.
*/
public static function sqlFunctionRand($seed = NULL) {
if (isset($seed)) {
mt_srand($seed);
}
return mt_rand() / mt_getrandmax();
}
/**
* SQLite compatibility implementation for the REGEXP SQL operator.
*
* The REGEXP operator is natively known, but not implemented by default.
*
* @see http://www.sqlite.org/lang_expr.html#regexp
*/
public static function sqlFunctionRegexp($pattern, $subject) {
// preg_quote() cannot be used here, since $pattern may contain reserved
// regular expression characters already (such as ^, $, etc). Therefore,
// use a rare character as PCRE delimiter.
$pattern = '#' . addcslashes($pattern, '#') . '#i';
return preg_match($pattern, $subject);
}
/**
* SQLite compatibility implementation for the LIKE BINARY SQL operator.
*
* SQLite supports case-sensitive LIKE operations through the
* 'case_sensitive_like' PRAGMA statement, but only for ASCII characters, so
* we have to provide our own implementation with UTF-8 support.
*
* @see https://sqlite.org/pragma.html#pragma_case_sensitive_like
* @see https://sqlite.org/lang_expr.html#like
*/
public static function sqlFunctionLikeBinary($pattern, $subject) {
// Replace the SQL LIKE wildcard meta-characters with the equivalent regular
// expression meta-characters and escape the delimiter that will be used for
// matching.
$pattern = str_replace([
'%',
'_',
], [
'.*?',
'.',
], preg_quote($pattern, '/'));
return preg_match('/^' . $pattern . '$/', $subject);
}
/**
* {@inheritdoc}
*/
public function prepare($statement, array $driver_options = []) {
@trigger_error('Connection::prepare() is deprecated in drupal:9.1.0 and is removed from drupal:10.0.0. Database drivers should instantiate \\PDOStatement objects by calling \\PDO::prepare in their Connection::prepareStatement method instead. \\PDO::prepare should not be called outside of driver code. See https://www.drupal.org/node/3137786', E_USER_DEPRECATED);
return new Statement($this->connection, $this, $statement, $driver_options);
}
/**
* {@inheritdoc}
*/
protected function handleQueryException(\PDOException $e, $query, array $args = [], $options = []) {
// The database schema might be changed by another process in between the
// time that the statement was prepared and the time the statement was run
// (e.g. usually happens when running tests). In this case, we need to
// re-run the query.
// @see http://www.sqlite.org/faq.html#q15
// @see http://www.sqlite.org/rescode.html#schema
if (!empty($e->errorInfo[1]) && $e->errorInfo[1] === 17) {
@trigger_error('Connection::handleQueryException() is deprecated in drupal:9.2.0 and is removed in drupal:10.0.0. Get a handler through $this->exceptionHandler() instead, and use one of its methods. See https://www.drupal.org/node/3187222', E_USER_DEPRECATED);
return $this->query($query, $args, $options);
}
parent::handleQueryException($e, $query, $args, $options);
}
public function queryRange($query, $from, $count, array $args = [], array $options = []) {
return $this->query($query . ' LIMIT ' . (int) $from . ', ' . (int) $count, $args, $options);
}
/**
* {@inheritdoc}
*/
public function queryTemporary($query, array $args = [], array $options = []) {
// Generate a new temporary table name and protect it from prefixing.
// SQLite requires that temporary tables to be non-qualified.
$tablename = $this->generateTemporaryTableName();
$prefixes = $this->prefixes;
$prefixes[$tablename] = '';
$this->setPrefix($prefixes);
$this->query('CREATE TEMPORARY TABLE ' . $tablename . ' AS ' . $query, $args, $options);
return $tablename;
}
public function driver() {
return 'sqlite';
}
public function databaseType() {
return 'sqlite';
}
/**
* Overrides \Drupal\Core\Database\Connection::createDatabase().
*
* @param string $database
* The name of the database to create.
*
* @throws \Drupal\Core\Database\DatabaseNotFoundException
*/
public function createDatabase($database) {
// Verify the database is writable.
$db_directory = new \SplFileInfo(dirname($database));
if (!$db_directory->isDir() && !\Drupal::service('file_system')->mkdir($db_directory->getPathName(), 0755, TRUE)) {
throw new DatabaseNotFoundException('Unable to create database directory ' . $db_directory->getPathName());
}
}
public function mapConditionOperator($operator) {
return static::$sqliteConditionOperatorMap[$operator] ?? NULL;
}
/**
* {@inheritdoc}
*/
public function prepareStatement(string $query, array $options, bool $allow_row_count = FALSE) : StatementInterface {
if (isset($options['return'])) {
@trigger_error('Passing "return" option to ' . __METHOD__ . '() is deprecated in drupal:9.4.0 and is removed in drupal:11.0.0. For data manipulation operations, use dynamic queries instead. See https://www.drupal.org/node/3185520', E_USER_DEPRECATED);
}
try {
$query = $this->preprocessStatement($query, $options);
$statement = new Statement($this->connection, $this, $query, $options['pdo'] ?? [], $allow_row_count);
} catch (\Exception $e) {
$this->exceptionHandler()
->handleStatementException($e, $query, $options);
}
return $statement;
}
public function nextId($existing_id = 0) {
try {
$this->startTransaction();
} catch (\PDOException $e) {
// $this->exceptionHandler()->handleExecutionException()
// requires a $statement argument, so we cannot use that.
throw new DatabaseExceptionWrapper($e->getMessage(), 0, $e);
}
// We can safely use literal queries here instead of the slower query
// builder because if a given database breaks here then it can simply
// override nextId. However, this is unlikely as we deal with short strings
// and integers and no known databases require special handling for those
// simple cases. If another transaction wants to write the same row, it will
// wait until this transaction commits.
$stmt = $this->prepareStatement('UPDATE {sequences} SET [value] = GREATEST([value], :existing_id) + 1', [], TRUE);
$args = [
':existing_id' => $existing_id,
];
try {
$stmt->execute($args);
} catch (\Exception $e) {
$this->exceptionHandler()
->handleExecutionException($e, $stmt, $args, []);
}
if ($stmt->rowCount() === 0) {
$this->query('INSERT INTO {sequences} ([value]) VALUES (:existing_id + 1)', $args);
}
// The transaction gets committed when the transaction object gets destroyed
// because it gets out of scope.
return $this->query('SELECT [value] FROM {sequences}')
->fetchField();
}
/**
* {@inheritdoc}
*/
public function getFullQualifiedTableName($table) {
$prefix = $this->tablePrefix($table);
// Don't include the SQLite database file name as part of the table name.
return $prefix . $table;
}
/**
* {@inheritdoc}
*/
public static function createConnectionOptionsFromUrl($url, $root) {
$database = parent::createConnectionOptionsFromUrl($url, $root);
// A SQLite database path with two leading slashes indicates a system path.
// Otherwise the path is relative to the Drupal root.
$url_components = parse_url($url);
if ($url_components['path'][0] === '/') {
$url_components['path'] = substr($url_components['path'], 1);
}
if ($url_components['path'][0] === '/' || $url_components['path'] === ':memory:') {
$database['database'] = $url_components['path'];
}
else {
$database['database'] = $root . '/' . $url_components['path'];
}
// User credentials and system port are irrelevant for SQLite.
unset($database['username'], $database['password'], $database['port']);
return $database;
}
/**
* {@inheritdoc}
*/
public static function createUrlFromConnectionOptions(array $connection_options) {
if (!isset($connection_options['driver'], $connection_options['database'])) {
throw new \InvalidArgumentException("As a minimum, the connection options array must contain at least the 'driver' and 'database' keys");
}
$db_url = 'sqlite://localhost/' . $connection_options['database'] . '?module=sqlite';
if (isset($connection_options['prefix']) && $connection_options['prefix'] !== '') {
$db_url .= '#' . $connection_options['prefix'];
}
return $db_url;
}
}
Members
Title Sort descending | Deprecated | Modifiers | Object type | Summary | Overriden Title | Overrides |
---|---|---|---|---|---|---|
Connection::$attachedDatabases | protected | property | All databases attached to the current database. | |||
Connection::$connection | protected | property | The actual client connection. | |||
Connection::$connectionOptions | protected | property | The connection information for this connection object. | |||
Connection::$driverClasses | protected | property | Index of what driver-specific class to use for various operations. | |||
Connection::$escapedAliases | protected | property | List of escaped aliases names, keyed by unescaped aliases. | |||
Connection::$escapedFields | protected | property | List of escaped field names, keyed by unescaped names. | |||
Connection::$escapedNames | Deprecated | protected | property | List of escaped database, table, and field names, keyed by unescaped names. | ||
Connection::$escapedTables | protected | property | List of escaped table names, keyed by unescaped names. | |||
Connection::$identifierQuotes | protected | property | The identifier quote characters for the database type. | Overrides Connection::$identifierQuotes | ||
Connection::$key | protected | property | The key representing this connection. | |||
Connection::$logger | protected | property | The current database logging object for this connection. | |||
Connection::$prefixes | protected | property | The prefixes used by this database connection. | |||
Connection::$prefixReplace | protected | property | List of replacement values for use in prefixTables(). | |||
Connection::$prefixSearch | protected | property | List of search values for use in prefixTables(). | |||
Connection::$rootTransactionEndCallbacks | protected | property | Post-root (non-nested) transaction commit callbacks. | |||
Connection::$schema | protected | property | The schema object for this connection. | |||
Connection::$sqliteConditionOperatorMap | protected static | property | A map of condition operators to SQLite operators. | |||
Connection::$statementClass | protected | property | The name of the Statement class for this connection. | Overrides Connection::$statementClass | ||
Connection::$statementWrapperClass | protected | property | The name of the StatementWrapper class for this connection. | Overrides Connection::$statementWrapperClass | ||
Connection::$tableDropped | public | property | Whether or not a table has been dropped this request. | |||
Connection::$target | protected | property | The database target this connection is for. | |||
Connection::$temporaryNameIndex | Deprecated | protected | property | An index used to generate unique temporary table names. | ||
Connection::$transactionalDDLSupport | protected | property | Whether this database connection supports transactional DDL. | Overrides Connection::$transactionalDDLSupport | ||
Connection::$transactionLayers | protected | property | Tracks the number of "layers" of transactions currently active. | |||
Connection::$unprefixedTablesMap | protected | property | List of un-prefixed table names, keyed by prefixed table names. | |||
Connection::$willRollback | protected | property | Whether or not the active transaction (if any) will be rolled back. | |||
Connection::addRootTransactionEndCallback | public | function | Adds a root transaction end callback. | |||
Connection::attachDatabase | public | function | Allows the connection to access additional databases. | Overrides Connection::attachDatabase | ||
Connection::clientVersion | public | function | Returns the version of the database client. | |||
Connection::commit | public | function | Throws an exception to deny direct access to transaction commits. | |||
Connection::condition | public | function | Prepares and returns a CONDITION query object. | |||
Connection::createConnectionOptionsFromUrl | public static | function | Creates an array of database connection options from a URL. | Overrides Connection::createConnectionOptionsFromUrl | ||
Connection::createDatabase | public | function | Overrides \Drupal\Core\Database\Connection::createDatabase(). | Overrides Connection::createDatabase | ||
Connection::createUrlFromConnectionOptions | public static | function | Creates a URL from an array of database connection options. | Overrides Connection::createUrlFromConnectionOptions | ||
Connection::databaseType | public | function | Returns the name of the database engine accessed by this driver. | Overrides Connection::databaseType | ||
Connection::DATABASE_NOT_FOUND | constant | Error code for "Unable to open database file" error. | ||||
Connection::defaultOptions | protected | function | Returns the default query options for any given query. | |||
Connection::delete | public | function | Prepares and returns a DELETE query object. | |||
Connection::destroy | Deprecated | public | function | Destroys this Connection object. | ||
Connection::doCommit | protected | function | Do the actual commit, invoke post-commit callbacks. | 1 | ||
Connection::driver | public | function | Returns the type of database driver. | Overrides Connection::driver | ||
Connection::escapeAlias | public | function | Escapes an alias name string. | |||
Connection::escapeDatabase | public | function | Escapes a database name string. | |||
Connection::escapeField | public | function | Escapes a field name string. | |||
Connection::escapeLike | public | function | Escapes characters that work as wildcard characters in a LIKE pattern. | |||
Connection::escapeTable | public | function | Escapes a table name string. | |||
Connection::exceptionHandler | public | function | Returns the database exceptions handler. | |||
Connection::expandArguments | protected | function | Expands out shorthand placeholders. | |||
Connection::filterComment | protected | function | Sanitize a query comment string. | |||
Connection::generateTemporaryTableName | Deprecated | protected | function | Generates a temporary table name. | ||
Connection::getAttachedDatabases | public | function | Gets all the attached databases. | |||
Connection::getConnectionOptions | public | function | Returns the connection information for this connection object. | |||
Connection::getDriverClass | public | function | Gets the driver-specific override class if any for the specified class. | |||
Connection::getFullQualifiedTableName | public | function | Get a fully qualified table name. | Overrides Connection::getFullQualifiedTableName | ||
Connection::getKey | public | function | Returns the key this connection is associated with. | |||
Connection::getLogger | public | function | Gets the current logging object for this connection. | |||
Connection::getPagerManager | public | function | Get the pager manager service, if available. | |||
Connection::getProvider | public | function | Get the module name of the module that is providing the database driver. | |||
Connection::getSQLState | protected static | function | Extracts the SQLSTATE error from a PDOException. | |||
Connection::getTarget | public | function | Returns the target this connection is associated with. | |||
Connection::getUnprefixedTablesMap | public | function | Gets a list of individually prefixed table names. | |||
Connection::handleQueryException | protected | function | Wraps and re-throws any PDO exception thrown by static::query(). | Overrides Connection::handleQueryException | ||
Connection::hasJson | public | function | Runs a simple query to validate json datatype support. | 1 | ||
Connection::insert | public | function | Prepares and returns an INSERT query object. | |||
Connection::inTransaction | public | function | Determines if there is an active transaction open. | |||
Connection::lastInsertId | public | function | Returns the ID of the last inserted row or sequence value. | |||
Connection::makeComment | public | function | Flatten an array of query comments into a single comment string. | |||
Connection::makeSequenceName | public | function | Creates the appropriate sequence name for a given table and serial field. | |||
Connection::mapConditionOperator | public | function | Gets any special processing requirements for the condition operator. | Overrides Connection::mapConditionOperator | ||
Connection::merge | public | function | Prepares and returns a MERGE query object. | |||
Connection::nextId | public | function | Retrieves a unique ID from a given sequence. | Overrides Connection::nextId | ||
Connection::open | public static | function | Opens a client connection. | Overrides Connection::open | ||
Connection::popCommittableTransactions | protected | function | Commit all the transaction layers that can commit. | 1 | ||
Connection::popTransaction | public | function | Decreases the depth of transaction nesting. | |||
Connection::prefixTables | public | function | Appends a database prefix to all tables in a query. | |||
Connection::prepare | public | function | Prepares a statement for execution and returns a statement object. | Overrides Connection::prepare | ||
Connection::prepareQuery | Deprecated | public | function | Prepares a query string and returns the prepared statement. | ||
Connection::prepareStatement | public | function | Returns a prepared statement given a SQL string. | Overrides Connection::prepareStatement | ||
Connection::preprocessStatement | protected | function | Returns a string SQL statement ready for preparation. | |||
Connection::pushTransaction | public | function | Increases the depth of transaction nesting. | |||
Connection::query | public | function | Executes a query string against the database. | 1 | ||
Connection::queryRange | public | function | Runs a limited-range query on this database object. | Overrides Connection::queryRange | ||
Connection::queryTemporary | public | function | Runs a SELECT query and stores its results in a temporary table. | Overrides Connection::queryTemporary | ||
Connection::quote | public | function | Quotes a string for use in a query. | |||
Connection::quoteIdentifiers | public | function | Quotes all identifiers in a query. | |||
Connection::rollBack | public | function | Rolls back the transaction entirely or to a named savepoint. | 1 | ||
Connection::schema | public | function | Returns a DatabaseSchema object for manipulating the schema. | |||
Connection::select | public | function | Prepares and returns a SELECT query object. | |||
Connection::setKey | public | function | Tells this connection object what its key is. | |||
Connection::setLogger | public | function | Associates a logging object with this connection. | |||
Connection::setPrefix | protected | function | Set the list of prefixes used by this database connection. | |||
Connection::setTarget | public | function | Tells this connection object what its target value is. | |||
Connection::sqlFunctionConcat | public static | function | SQLite compatibility implementation for the CONCAT() SQL function. | |||
Connection::sqlFunctionConcatWs | public static | function | SQLite compatibility implementation for the CONCAT_WS() SQL function. | |||
Connection::sqlFunctionGreatest | public static | function | SQLite compatibility implementation for the GREATEST() SQL function. | |||
Connection::sqlFunctionIf | public static | function | SQLite compatibility implementation for the IF() SQL function. | |||
Connection::sqlFunctionLeast | public static | function | SQLite compatibility implementation for the LEAST() SQL function. | |||
Connection::sqlFunctionLikeBinary | public static | function | SQLite compatibility implementation for the LIKE BINARY SQL operator. | |||
Connection::sqlFunctionRand | public static | function | SQLite compatibility implementation for the RAND() SQL function. | |||
Connection::sqlFunctionRegexp | public static | function | SQLite compatibility implementation for the REGEXP SQL operator. | |||
Connection::sqlFunctionSubstring | public static | function | SQLite compatibility implementation for the SUBSTRING() SQL function. | |||
Connection::sqlFunctionSubstringIndex | public static | function | SQLite compatibility implementation for the SUBSTRING_INDEX() SQL function. | |||
Connection::startTransaction | public | function | Returns a new DatabaseTransaction object on this connection. | |||
Connection::supportsTransactionalDDL | public | function | Determines if this driver supports transactional DDL. | |||
Connection::supportsTransactions | Deprecated | public | function | Determines if this driver supports transactions. | ||
Connection::tablePrefix | public | function | Find the prefix for a table. | |||
Connection::transactionDepth | public | function | Determines the current transaction depth. | |||
Connection::truncate | public | function | Prepares and returns a TRUNCATE query object. | |||
Connection::update | public | function | Prepares and returns an UPDATE query object. | |||
Connection::upsert | public | function | Prepares and returns an UPSERT query object. | |||
Connection::version | public | function | Returns the version of the database server. | 1 | ||
Connection::__construct | public | function | Constructs a \Drupal\sqlite\Driver\Database\sqlite\Connection object. | Overrides Connection::__construct | ||
Connection::__destruct | public | function | Destructor for the SQLite connection. | Overrides Connection::__destruct | ||
Connection::__sleep | public | function | Prevents the database connection from being serialized. |
Buggy or inaccurate documentation? Please file an issue. Need support? Need help programming? Connect with the Drupal community.