vendor/doctrine/dbal/lib/Doctrine/DBAL/Driver/PDOPgSql/Driver.php line 48

Open in your IDE?
  1. <?php
  3. namespace Doctrine\DBAL\Driver\PDOPgSql;
  5. use Doctrine\DBAL\DBALException;
  6. use Doctrine\DBAL\Driver\AbstractPostgreSQLDriver;
  7. use Doctrine\DBAL\Driver\PDOConnection;
  8. use PDO;
  9. use PDOException;
  10. use function defined;
  12. /**
  13.  * Driver that connects through pdo_pgsql.
  14.  */
  15. class Driver extends AbstractPostgreSQLDriver
  16. {
  17.     /**
  18.      * {@inheritdoc}
  19.      */
  20.     public function connect(array $params, $username = null, $password = null, array $driverOptions = [])
  21.     {
  22.         try {
  23.             $pdo = new PDOConnection(
  24.                 $this->_constructPdoDsn($params),
  25.                 $username,
  26.                 $password,
  27.                 $driverOptions
  28.             );
  30.             if (defined('PDO::PGSQL_ATTR_DISABLE_PREPARES')
  31.                 && (! isset($driverOptions[PDO::PGSQL_ATTR_DISABLE_PREPARES])
  32.                     || $driverOptions[PDO::PGSQL_ATTR_DISABLE_PREPARES] === true
  33.                 )
  34.             ) {
  35.                 $pdo->setAttribute(PDO::PGSQL_ATTR_DISABLE_PREPARES, true);
  36.             }
  38.             /* defining client_encoding via SET NAMES to avoid inconsistent DSN support
  39.              * - the 'client_encoding' connection param only works with postgres >= 9.1
  40.              * - passing client_encoding via the 'options' param breaks pgbouncer support
  41.              */
  42.             if (isset($params['charset'])) {
  43.                 $pdo->exec('SET NAMES \'' . $params['charset'] . '\'');
  44.             }
  46.             return $pdo;
  47.         } catch (PDOException $e) {
  48.             throw DBALException::driverException($this, $e);
  49.         }
  50.     }
  52.     /**
  53.      * Constructs the Postgres PDO DSN.
  54.      *
  55.      * @param mixed[] $params
  56.      *
  57.      * @return string The DSN.
  58.      */
  59.     private function _constructPdoDsn(array $params)
  60.     {
  61.         $dsn = 'pgsql:';
  63.         if (isset($params['host']) && $params['host'] !== '') {
  64.             $dsn .= 'host=' . $params['host'] . ';';
  65.         }
  67.         if (isset($params['port']) && $params['port'] !== '') {
  68.             $dsn .= 'port=' . $params['port'] . ';';
  69.         }
  71.         if (isset($params['dbname'])) {
  72.             $dsn .= 'dbname=' . $params['dbname'] . ';';
  73.         } elseif (isset($params['default_dbname'])) {
  74.             $dsn .= 'dbname=' . $params['default_dbname'] . ';';
  75.         } else {
  76.             // Used for temporary connections to allow operations like dropping the database currently connected to.
  77.             // Connecting without an explicit database does not work, therefore "postgres" database is used
  78.             // as it is mostly present in every server setup.
  79.             $dsn .= 'dbname=postgres;';
  80.         }
  82.         if (isset($params['sslmode'])) {
  83.             $dsn .= 'sslmode=' . $params['sslmode'] . ';';
  84.         }
  86.         if (isset($params['sslrootcert'])) {
  87.             $dsn .= 'sslrootcert=' . $params['sslrootcert'] . ';';
  88.         }
  90.         if (isset($params['sslcert'])) {
  91.             $dsn .= 'sslcert=' . $params['sslcert'] . ';';
  92.         }
  94.         if (isset($params['sslkey'])) {
  95.             $dsn .= 'sslkey=' . $params['sslkey'] . ';';
  96.         }
  98.         if (isset($params['sslcrl'])) {
  99.             $dsn .= 'sslcrl=' . $params['sslcrl'] . ';';
  100.         }
  102.         if (isset($params['application_name'])) {
  103.             $dsn .= 'application_name=' . $params['application_name'] . ';';
  104.         }
  106.         return $dsn;
  107.     }
  109.     /**
  110.      * {@inheritdoc}
  111.      */
  112.     public function getName()
  113.     {
  114.         return 'pdo_pgsql';
  115.     }
  116. }