public function DatabaseConnection_sqlite::__construct

public DatabaseConnection_sqlite::__construct(array $connection_options = array())

Overrides DatabaseConnection::__construct

File

includes/database/sqlite/database.inc, line 57

Database interface code for SQLite embedded database engine.

Class

DatabaseConnection_sqlite

Specific SQLite implementation of DatabaseConnection.

Code

public function __construct(array $connection_options = array()) {
  // We don't need a specific PDOStatement class here, we simulate it below.
  $this->statementClass = NULL;

  // This driver defaults to transaction support, except if explicitly passed FALSE.
  $this->transactionSupport = $this->transactionalDDLSupport = !isset($connection_options['transactions']) || $connection_options['transactions'] !== FALSE;

  $this->connectionOptions = $connection_options;

  // Allow PDO options to be overridden.
  $connection_options += array(
    'pdo' => array(),
  );
  $connection_options['pdo'] += array(
    // Convert numeric values to strings when fetching.
    PDO::ATTR_STRINGIFY_FETCHES => TRUE,
  );
  parent::__construct('sqlite:' . $connection_options['database'], '', '', $connection_options['pdo']);

  // Attach one database for each registered prefix.
  $prefixes = $this->prefixes;
  foreach ($prefixes as $table => &$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;
        $this->query('ATTACH DATABASE :database AS :prefix', array(':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);

  // Detect support for SAVEPOINT.
  $version = $this->query('SELECT sqlite_version()')->fetchField();
  $this->savepointSupport = (version_compare($version, '3.6.8') >= 0);

  // Create functions needed by SQLite.
  $this->sqliteCreateFunction('if', array($this, 'sqlFunctionIf'));
  $this->sqliteCreateFunction('greatest', array($this, 'sqlFunctionGreatest'));
  $this->sqliteCreateFunction('pow', 'pow', 2);
  $this->sqliteCreateFunction('length', 'strlen', 1);
  $this->sqliteCreateFunction('md5', 'md5', 1);
  $this->sqliteCreateFunction('concat', array($this, 'sqlFunctionConcat'));
  $this->sqliteCreateFunction('substring', array($this, 'sqlFunctionSubstring'), 3);
  $this->sqliteCreateFunction('substring_index', array($this, 'sqlFunctionSubstringIndex'), 3);
  $this->sqliteCreateFunction('rand', array($this, 'sqlFunctionRand'));

  // Execute sqlite init_commands.
  if (isset($connection_options['init_commands'])) {
    $this->exec(implode('; ', $connection_options['init_commands']));
  }
}