public function Connection::__construct in Drupal 9

Same name in this branch

1. 9 core/lib/Drupal/Core/Database/Connection.php \Drupal\Core\Database\Connection::__construct()
2. 9 core/lib/Drupal/Core/Database/Driver/sqlite/Connection.php \Drupal\Core\Database\Driver\sqlite\Connection::__construct()
3. 9 core/lib/Drupal/Core/Database/Driver/pgsql/Connection.php \Drupal\Core\Database\Driver\pgsql\Connection::__construct()
4. 9 core/lib/Drupal/Core/Database/Driver/mysql/Connection.php \Drupal\Core\Database\Driver\mysql\Connection::__construct()

Same name and namespace in other branches

1. 8 core/lib/Drupal/Core/Database/Driver/sqlite/Connection.php \Drupal\Core\Database\Driver\sqlite\Connection::__construct()

Constructs a \Drupal\Core\Database\Driver\sqlite\Connection object.

Overrides Connection::__construct

File

core/lib/Drupal/Core/Database/Driver/sqlite/Connection.php, line 84

Class

Connection

SQLite implementation of \Drupal\Core\Database\Connection.

Namespace

Drupal\Core\Database\Driver\sqlite

Code

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 (!empty($prefix)) {

      // Only attach the database once.
      if (!isset($this->attachedDatabases[$prefix])) {
        $this->attachedDatabases[$prefix] = $prefix;
        if ($connection_options['database'] === ':memory:') {

          // 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.
          $this
            ->query('ATTACH DATABASE :database AS :prefix', [
            ':database' => $connection_options['database'],
            ':prefix' => $prefix,
          ]);
        }
        else {
          $this
            ->query('ATTACH DATABASE :database AS :prefix', [
            ':database' => $connection_options['database'] . '-' . $prefix,
            ':prefix' => $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);
}