function Connection::open

Overrides Connection::open

File

core/modules/mysqli/src/Driver/Database/mysqli/Connection.php, line 58

Class

Connection

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

Namespace

Code

public static function open(array &$connection_options = []) {
  // Sets mysqli error reporting mode to report errors from mysqli function
  // calls and to throw mysqli_sql_exception for errors.
  // @see https://www.php.net/manual/en/mysqli-driver.report-mode.php
  mysqli_report(MYSQLI_REPORT_ERROR | MYSQLI_REPORT_STRICT);
  // Allow PDO options to be overridden.
  $connection_options += [
    'pdo' => [],
  ];
  try {
    $mysqli = @new \mysqli($connection_options['host'], $connection_options['username'], $connection_options['password'], $connection_options['database'] ?? '', !empty($connection_options['port']) ? (int) $connection_options['port'] : 3306, $connection_options['unix_socket'] ?? '');
    if (!$mysqli->set_charset('utf8mb4')) {
      throw new InvalidCharsetException('Invalid charset utf8mb4');
    }
  } catch (\mysqli_sql_exception $e) {
    if ($e->getCode() === static::DATABASE_NOT_FOUND) {
      throw new DatabaseNotFoundException($e->getMessage(), $e->getCode(), $e);
    }
    elseif ($e->getCode() === static::ACCESS_DENIED) {
      throw new DatabaseAccessDeniedException($e->getMessage(), $e->getCode(), $e);
    }
    throw new ConnectionNotDefinedException('Invalid database connection: ' . $e->getMessage(), $e->getCode(), $e);
  }
  // Force MySQL to use the UTF-8 character set. Also set the collation, if a
  // certain one has been set; otherwise, MySQL defaults to
  // 'utf8mb4_0900_ai_ci' for the 'utf8mb4' character set.
  if (!empty($connection_options['collation'])) {
    $mysqli->query('SET NAMES utf8mb4 COLLATE ' . $connection_options['collation']);
  }
  else {
    $mysqli->query('SET NAMES utf8mb4');
  }
  // Set MySQL init_commands if not already defined.  Default Drupal's MySQL
  // behavior to conform more closely to SQL standards.  This allows Drupal
  // to run almost seamlessly on many different kinds of database systems.
  // These settings force MySQL to behave the same as postgresql, or sqlite
  // in regard to syntax interpretation and invalid data handling.  See
  // https://www.drupal.org/node/344575 for further discussion. Also, as MySQL
  // 5.5 changed the meaning of TRADITIONAL we need to spell out the modes one
  // by one.
  $connection_options += [
    'init_commands' => [],
  ];
  $connection_options['init_commands'] += [
    'sql_mode' => "SET sql_mode = 'ANSI,TRADITIONAL'",
  ];
  if (!empty($connection_options['isolation_level'])) {
    $connection_options['init_commands'] += [
      'isolation_level' => 'SET SESSION TRANSACTION ISOLATION LEVEL ' . strtoupper($connection_options['isolation_level']),
    ];
  }
  // Execute initial commands.
  foreach ($connection_options['init_commands'] as $sql) {
    $mysqli->query($sql);
  }
  return $mysqli;
}