vendor/doctrine/dbal/lib/Doctrine/DBAL/Driver/PDOMySql/Driver.php line 28

Open in your IDE?
  1. <?php
  3. namespace Doctrine\DBAL\Driver\PDOMySql;
  5. use Doctrine\DBAL\DBALException;
  6. use Doctrine\DBAL\Driver\AbstractMySQLDriver;
  7. use Doctrine\DBAL\Driver\PDOConnection;
  8. use PDOException;
  10. /**
  11.  * PDO MySql driver.
  12.  */
  13. class Driver extends AbstractMySQLDriver
  14. {
  15.     /**
  16.      * {@inheritdoc}
  17.      */
  18.     public function connect(array $params, $username = null, $password = null, array $driverOptions = [])
  19.     {
  20.         try {
  21.             $conn = new PDOConnection(
  22.                 $this->constructPdoDsn($params),
  23.                 $username,
  24.                 $password,
  25.                 $driverOptions
  26.             );
  27.         } catch (PDOException $e) {
  28.             throw DBALException::driverException($this, $e);
  29.         }
  31.         return $conn;
  32.     }
  34.     /**
  35.      * Constructs the MySql PDO DSN.
  36.      *
  37.      * @param mixed[] $params
  38.      *
  39.      * @return string The DSN.
  40.      */
  41.     protected function constructPdoDsn(array $params)
  42.     {
  43.         $dsn = 'mysql:';
  44.         if (isset($params['host']) && $params['host'] !== '') {
  45.             $dsn .= 'host=' . $params['host'] . ';';
  46.         }
  47.         if (isset($params['port'])) {
  48.             $dsn .= 'port=' . $params['port'] . ';';
  49.         }
  50.         if (isset($params['dbname'])) {
  51.             $dsn .= 'dbname=' . $params['dbname'] . ';';
  52.         }
  53.         if (isset($params['unix_socket'])) {
  54.             $dsn .= 'unix_socket=' . $params['unix_socket'] . ';';
  55.         }
  56.         if (isset($params['charset'])) {
  57.             $dsn .= 'charset=' . $params['charset'] . ';';
  58.         }
  60.         return $dsn;
  61.     }
  63.     /**
  64.      * {@inheritdoc}
  65.      */
  66.     public function getName()
  67.     {
  68.         return 'pdo_mysql';
  69.     }
  70. }