vendor/doctrine/dbal/src/Driver/PDO/MySQL/Driver.php line 43

Open in your IDE?
  1. <?php
  3. namespace Doctrine\DBAL\Driver\PDO\MySQL;
  5. use Doctrine\DBAL\Driver\AbstractMySQLDriver;
  6. use Doctrine\DBAL\Driver\PDO\Connection;
  7. use Doctrine\DBAL\Driver\PDO\Exception;
  8. use Doctrine\DBAL\Driver\PDO\PDOConnect;
  9. use PDO;
  10. use PDOException;
  11. use SensitiveParameter;
  13. final class Driver extends AbstractMySQLDriver
  14. {
  15.     use PDOConnect;
  17.     /**
  18.      * {@inheritDoc}
  19.      *
  20.      * @return Connection
  21.      */
  22.     public function connect(
  23.         #[SensitiveParameter]
  24.         array $params
  25.     ) {
  26.         $driverOptions = $params['driverOptions'] ?? [];
  28.         if (! empty($params['persistent'])) {
  29.             $driverOptions[PDO::ATTR_PERSISTENT] = true;
  30.         }
  32.         $safeParams = $params;
  33.         unset($safeParams['password'], $safeParams['url']);
  35.         try {
  36.             $pdo = $this->doConnect(
  37.                 $this->constructPdoDsn($safeParams),
  38.                 $params['user'] ?? '',
  39.                 $params['password'] ?? '',
  40.                 $driverOptions,
  41.             );
  42.         } catch (PDOException $exception) {
  43.             throw Exception::new($exception);
  44.         }
  46.         return new Connection($pdo);
  47.     }
  49.     /**
  50.      * Constructs the MySQL PDO DSN.
  51.      *
  52.      * @param mixed[] $params
  53.      */
  54.     private function constructPdoDsn(array $params): string
  55.     {
  56.         $dsn = 'mysql:';
  57.         if (isset($params['host']) && $params['host'] !== '') {
  58.             $dsn .= 'host=' . $params['host'] . ';';
  59.         }
  61.         if (isset($params['port'])) {
  62.             $dsn .= 'port=' . $params['port'] . ';';
  63.         }
  65.         if (isset($params['dbname'])) {
  66.             $dsn .= 'dbname=' . $params['dbname'] . ';';
  67.         }
  69.         if (isset($params['unix_socket'])) {
  70.             $dsn .= 'unix_socket=' . $params['unix_socket'] . ';';
  71.         }
  73.         if (isset($params['charset'])) {
  74.             $dsn .= 'charset=' . $params['charset'] . ';';
  75.         }
  77.         return $dsn;
  78.     }
  79. }