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

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