DatabaseStorage.php
Same filename in this branch
Same filename in other branches
- 8.9.x core/lib/Drupal/Core/Config/DatabaseStorage.php
- 8.9.x core/lib/Drupal/Core/KeyValueStore/DatabaseStorage.php
- 10 core/lib/Drupal/Core/Config/DatabaseStorage.php
- 10 core/lib/Drupal/Core/KeyValueStore/DatabaseStorage.php
- 11.x core/lib/Drupal/Core/Config/DatabaseStorage.php
- 11.x core/lib/Drupal/Core/KeyValueStore/DatabaseStorage.php
Namespace
Drupal\Core\ConfigFile
-
core/
lib/ Drupal/ Core/ Config/ DatabaseStorage.php
View source
<?php
namespace Drupal\Core\Config;
use Drupal\Core\Database\Database;
use Drupal\Core\Database\Connection;
use Drupal\Core\Database\DatabaseException;
use Drupal\Core\DependencyInjection\DependencySerializationTrait;
/**
* Defines the Database storage.
*/
class DatabaseStorage implements StorageInterface {
use DependencySerializationTrait;
/**
* The database connection.
*
* @var \Drupal\Core\Database\Connection
*/
protected $connection;
/**
* The database table name.
*
* @var string
*/
protected $table;
/**
* Additional database connection options to use in queries.
*
* @var array
*/
protected $options = [];
/**
* The storage collection.
*
* @var string
*/
protected $collection = StorageInterface::DEFAULT_COLLECTION;
/**
* Constructs a new DatabaseStorage.
*
* @param \Drupal\Core\Database\Connection $connection
* A Database connection to use for reading and writing configuration data.
* @param string $table
* A database table name to store configuration data in.
* @param array $options
* (optional) Any additional database connection options to use in queries.
* @param string $collection
* (optional) The collection to store configuration in. Defaults to the
* default collection.
*/
public function __construct(Connection $connection, $table, array $options = [], $collection = StorageInterface::DEFAULT_COLLECTION) {
$this->connection = $connection;
$this->table = $table;
$this->options = $options;
$this->collection = $collection;
}
/**
* {@inheritdoc}
*/
public function exists($name) {
try {
return (bool) $this->connection
->queryRange('SELECT 1 FROM {' . $this->connection
->escapeTable($this->table) . '} WHERE [collection] = :collection AND [name] = :name', 0, 1, [
':collection' => $this->collection,
':name' => $name,
], $this->options)
->fetchField();
} catch (\Exception $e) {
// If we attempt a read without actually having the database or the table
// available, just return FALSE so the caller can handle it.
return FALSE;
}
}
/**
* {@inheritdoc}
*/
public function read($name) {
$data = FALSE;
try {
$raw = $this->connection
->query('SELECT [data] FROM {' . $this->connection
->escapeTable($this->table) . '} WHERE [collection] = :collection AND [name] = :name', [
':collection' => $this->collection,
':name' => $name,
], $this->options)
->fetchField();
if ($raw !== FALSE) {
$data = $this->decode($raw);
}
} catch (\Exception $e) {
// If we attempt a read without actually having the database or the table
// available, just return FALSE so the caller can handle it.
}
return $data;
}
/**
* {@inheritdoc}
*/
public function readMultiple(array $names) {
$list = [];
try {
$list = $this->connection
->query('SELECT [name], [data] FROM {' . $this->connection
->escapeTable($this->table) . '} WHERE [collection] = :collection AND [name] IN ( :names[] )', [
':collection' => $this->collection,
':names[]' => $names,
], $this->options)
->fetchAllKeyed();
foreach ($list as &$data) {
$data = $this->decode($data);
}
} catch (\Exception $e) {
// If we attempt a read without actually having the database or the table
// available, just return an empty array so the caller can handle it.
}
return $list;
}
/**
* {@inheritdoc}
*/
public function write($name, array $data) {
$data = $this->encode($data);
try {
return $this->doWrite($name, $data);
} catch (\Exception $e) {
// If there was an exception, try to create the table.
if ($this->ensureTableExists()) {
return $this->doWrite($name, $data);
}
// Some other failure that we can not recover from.
throw new StorageException($e->getMessage(), 0, $e);
}
}
/**
* Helper method so we can re-try a write.
*
* @param string $name
* The config name.
* @param string $data
* The config data, already dumped to a string.
*
* @return bool
*/
protected function doWrite($name, $data) {
// @todo Remove the 'return' option in Drupal 11.
// @see https://www.drupal.org/project/drupal/issues/3256524
$options = [
'return' => Database::RETURN_AFFECTED,
] + $this->options;
return (bool) $this->connection
->merge($this->table, $options)
->keys([
'collection',
'name',
], [
$this->collection,
$name,
])
->fields([
'data' => $data,
])
->execute();
}
/**
* Check if the config table exists and create it if not.
*
* @return bool
* TRUE if the table was created, FALSE otherwise.
*
* @throws \Drupal\Core\Config\StorageException
* If a database error occurs.
*/
protected function ensureTableExists() {
try {
$this->connection
->schema()
->createTable($this->table, static::schemaDefinition());
} catch (DatabaseException $e) {
return TRUE;
} catch (\Exception $e) {
return FALSE;
}
return TRUE;
}
/**
* Defines the schema for the configuration table.
*
* @internal
*/
protected static function schemaDefinition() {
$schema = [
'description' => 'The base table for configuration data.',
'fields' => [
'collection' => [
'description' => 'Primary Key: Config object collection.',
'type' => 'varchar_ascii',
'length' => 255,
'not null' => TRUE,
'default' => '',
],
'name' => [
'description' => 'Primary Key: Config object name.',
'type' => 'varchar_ascii',
'length' => 255,
'not null' => TRUE,
'default' => '',
],
'data' => [
'description' => 'A serialized configuration object data.',
'type' => 'blob',
'not null' => FALSE,
'size' => 'big',
],
],
'primary key' => [
'collection',
'name',
],
];
return $schema;
}
/**
* Implements Drupal\Core\Config\StorageInterface::delete().
*
* @throws \PDOException
*
* @todo Ignore replica targets for data manipulation operations.
*/
public function delete($name) {
// @todo Remove the 'return' option in Drupal 11.
// @see https://www.drupal.org/project/drupal/issues/3256524
$options = [
'return' => Database::RETURN_AFFECTED,
] + $this->options;
return (bool) $this->connection
->delete($this->table, $options)
->condition('collection', $this->collection)
->condition('name', $name)
->execute();
}
/**
* Implements Drupal\Core\Config\StorageInterface::rename().
*
* @throws \PDOException
*/
public function rename($name, $new_name) {
// @todo Remove the 'return' option in Drupal 11.
// @see https://www.drupal.org/project/drupal/issues/3256524
$options = [
'return' => Database::RETURN_AFFECTED,
] + $this->options;
return (bool) $this->connection
->update($this->table, $options)
->fields([
'name' => $new_name,
])
->condition('name', $name)
->condition('collection', $this->collection)
->execute();
}
/**
* {@inheritdoc}
*/
public function encode($data) {
return serialize($data);
}
/**
* Implements Drupal\Core\Config\StorageInterface::decode().
*
* @throws \ErrorException
* The unserialize() call will trigger E_NOTICE if the string cannot
* be unserialized.
*/
public function decode($raw) {
$data = @unserialize($raw);
return is_array($data) ? $data : FALSE;
}
/**
* {@inheritdoc}
*/
public function listAll($prefix = '') {
try {
$query = $this->connection
->select($this->table);
$query->fields($this->table, [
'name',
]);
$query->condition('collection', $this->collection, '=');
$query->condition('name', $prefix . '%', 'LIKE');
$query->orderBy('collection')
->orderBy('name');
return $query->execute()
->fetchCol();
} catch (\Exception $e) {
return [];
}
}
/**
* {@inheritdoc}
*/
public function deleteAll($prefix = '') {
try {
// @todo Remove the 'return' option in Drupal 11.
// @see https://www.drupal.org/project/drupal/issues/3256524
$options = [
'return' => Database::RETURN_AFFECTED,
] + $this->options;
return (bool) $this->connection
->delete($this->table, $options)
->condition('name', $prefix . '%', 'LIKE')
->condition('collection', $this->collection)
->execute();
} catch (\Exception $e) {
return FALSE;
}
}
/**
* {@inheritdoc}
*/
public function createCollection($collection) {
return new static($this->connection, $this->table, $this->options, $collection);
}
/**
* {@inheritdoc}
*/
public function getCollectionName() {
return $this->collection;
}
/**
* {@inheritdoc}
*/
public function getAllCollectionNames() {
try {
return $this->connection
->query('SELECT DISTINCT [collection] FROM {' . $this->connection
->escapeTable($this->table) . '} WHERE [collection] <> :collection ORDER by [collection]', [
':collection' => StorageInterface::DEFAULT_COLLECTION,
])
->fetchCol();
} catch (\Exception $e) {
return [];
}
}
}
Classes
Title | Deprecated | Summary |
---|---|---|
DatabaseStorage | Defines the Database storage. |
Buggy or inaccurate documentation? Please file an issue. Need support? Need help programming? Connect with the Drupal community.