vendor/doctrine/dbal/lib/Doctrine/DBAL/Driver/AbstractPostgreSQLDriver.php line 45

Open in your IDE?
  1. <?php
  3. namespace Doctrine\DBAL\Driver;
  5. use Doctrine\DBAL\Connection;
  6. use Doctrine\DBAL\Driver;
  7. use Doctrine\DBAL\Driver\DriverException as DeprecatedDriverException;
  8. use Doctrine\DBAL\Exception;
  9. use Doctrine\DBAL\Exception\ConnectionException;
  10. use Doctrine\DBAL\Exception\DeadlockException;
  11. use Doctrine\DBAL\Exception\DriverException;
  12. use Doctrine\DBAL\Exception\ForeignKeyConstraintViolationException;
  13. use Doctrine\DBAL\Exception\InvalidFieldNameException;
  14. use Doctrine\DBAL\Exception\NonUniqueFieldNameException;
  15. use Doctrine\DBAL\Exception\NotNullConstraintViolationException;
  16. use Doctrine\DBAL\Exception\SyntaxErrorException;
  17. use Doctrine\DBAL\Exception\TableExistsException;
  18. use Doctrine\DBAL\Exception\TableNotFoundException;
  19. use Doctrine\DBAL\Exception\UniqueConstraintViolationException;
  20. use Doctrine\DBAL\Platforms\PostgreSQL100Platform;
  21. use Doctrine\DBAL\Platforms\PostgreSQL91Platform;
  22. use Doctrine\DBAL\Platforms\PostgreSQL92Platform;
  23. use Doctrine\DBAL\Platforms\PostgreSQL94Platform;
  24. use Doctrine\DBAL\Platforms\PostgreSqlPlatform;
  25. use Doctrine\DBAL\Schema\PostgreSqlSchemaManager;
  26. use Doctrine\DBAL\VersionAwarePlatformDriver;
  28. use function assert;
  29. use function preg_match;
  30. use function strpos;
  31. use function version_compare;
  33. /**
  34.  * Abstract base implementation of the {@link Driver} interface for PostgreSQL based drivers.
  35.  */
  36. abstract class AbstractPostgreSQLDriver implements Driver, ExceptionConverterDriver, VersionAwarePlatformDriver
  37. {
  38.     /**
  39.      * {@inheritdoc}
  40.      *
  41.      * @deprecated
  42.      *
  43.      * @link http://www.postgresql.org/docs/9.3/static/errcodes-appendix.html
  44.      */
  45.     public function convertException($message, DeprecatedDriverException $exception)
  46.     {
  47.         $sqlState = $exception->getSQLState();
  49.         switch ($sqlState) {
  50.             case '40001':
  51.             case '40P01':
  52.                 return new DeadlockException($message, $exception);
  54.             case '0A000':
  55.                 // Foreign key constraint violations during a TRUNCATE operation
  56.                 // are considered "feature not supported" in PostgreSQL.
  57.                 if (strpos($exception->getMessage(), 'truncate') !== false) {
  58.                     return new ForeignKeyConstraintViolationException($message, $exception);
  59.                 }
  61.                 break;
  63.             case '23502':
  64.                 return new NotNullConstraintViolationException($message, $exception);
  66.             case '23503':
  67.                 return new ForeignKeyConstraintViolationException($message, $exception);
  69.             case '23505':
  70.                 return new UniqueConstraintViolationException($message, $exception);
  72.             case '42601':
  73.                 return new SyntaxErrorException($message, $exception);
  75.             case '42702':
  76.                 return new NonUniqueFieldNameException($message, $exception);
  78.             case '42703':
  79.                 return new InvalidFieldNameException($message, $exception);
  81.             case '42P01':
  82.                 return new TableNotFoundException($message, $exception);
  84.             case '42P07':
  85.                 return new TableExistsException($message, $exception);
  87.             case '08006':
  88.                 return new Exception\ConnectionException($message, $exception);
  90.             case '7':
  91.                 // Prior to fixing https://bugs.php.net/bug.php?id=64705 (PHP 7.3.22 and PHP 7.4.10),
  92.                 // in some cases (mainly connection errors) the PDO exception wouldn't provide a SQLSTATE via its code.
  93.                 // The exception code would be always set to 7 here.
  94.                 // We have to match against the SQLSTATE in the error message in these cases.
  95.                 if (strpos($exception->getMessage(), 'SQLSTATE[08006]') !== false) {
  96.                     return new ConnectionException($message, $exception);
  97.                 }
  99.                 break;
  100.         }
  102.         return new DriverException($message, $exception);
  103.     }
  105.     /**
  106.      * {@inheritdoc}
  107.      */
  108.     public function createDatabasePlatformForVersion($version)
  109.     {
  110.         if (! preg_match('/^(?P<major>\d+)(?:\.(?P<minor>\d+)(?:\.(?P<patch>\d+))?)?/', $version, $versionParts)) {
  111.             throw Exception::invalidPlatformVersionSpecified(
  112.                 $version,
  113.                 '<major_version>.<minor_version>.<patch_version>'
  114.             );
  115.         }
  117.         $majorVersion = $versionParts['major'];
  118.         $minorVersion = $versionParts['minor'] ?? 0;
  119.         $patchVersion = $versionParts['patch'] ?? 0;
  120.         $version      = $majorVersion . '.' . $minorVersion . '.' . $patchVersion;
  122.         switch (true) {
  123.             case version_compare($version, '10.0', '>='):
  124.                 return new PostgreSQL100Platform();
  125.             case version_compare($version, '9.4', '>='):
  126.                 return new PostgreSQL94Platform();
  127.             case version_compare($version, '9.2', '>='):
  128.                 return new PostgreSQL92Platform();
  129.             case version_compare($version, '9.1', '>='):
  130.                 return new PostgreSQL91Platform();
  131.             default:
  132.                 return new PostgreSqlPlatform();
  133.         }
  134.     }
  136.     /**
  137.      * {@inheritdoc}
  138.      *
  139.      * @deprecated Use Connection::getDatabase() instead.
  140.      */
  141.     public function getDatabase(Connection $conn)
  142.     {
  143.         $params = $conn->getParams();
  145.         if (isset($params['dbname'])) {
  146.             return $params['dbname'];
  147.         }
  149.         $database = $conn->query('SELECT CURRENT_DATABASE()')->fetchColumn();
  151.         assert($database !== false);
  153.         return $database;
  154.     }
  156.     /**
  157.      * {@inheritdoc}
  158.      */
  159.     public function getDatabasePlatform()
  160.     {
  161.         return new PostgreSqlPlatform();
  162.     }
  164.     /**
  165.      * {@inheritdoc}
  166.      */
  167.     public function getSchemaManager(Connection $conn)
  168.     {
  169.         return new PostgreSqlSchemaManager($conn);
  170.     }
  171. }