vendor/doctrine/dbal/lib/Doctrine/DBAL/Driver/AbstractMySQLDriver.php line 93

Open in your IDE?
  1. <?php
  3. namespace Doctrine\DBAL\Driver;
  5. use Doctrine\DBAL\Connection;
  6. use Doctrine\DBAL\DBALException;
  7. use Doctrine\DBAL\Driver;
  8. use Doctrine\DBAL\Exception;
  9. use Doctrine\DBAL\Platforms\MariaDb1027Platform;
  10. use Doctrine\DBAL\Platforms\MySQL57Platform;
  11. use Doctrine\DBAL\Platforms\MySQL80Platform;
  12. use Doctrine\DBAL\Platforms\MySqlPlatform;
  13. use Doctrine\DBAL\Schema\MySqlSchemaManager;
  14. use Doctrine\DBAL\VersionAwarePlatformDriver;
  15. use function preg_match;
  16. use function stripos;
  17. use function version_compare;
  19. /**
  20.  * Abstract base implementation of the {@link Doctrine\DBAL\Driver} interface for MySQL based drivers.
  21.  */
  22. abstract class AbstractMySQLDriver implements Driver, ExceptionConverterDriver, VersionAwarePlatformDriver
  23. {
  24.     /**
  25.      * {@inheritdoc}
  26.      *
  27.      * @link http://dev.mysql.com/doc/refman/5.7/en/error-messages-client.html
  28.      * @link http://dev.mysql.com/doc/refman/5.7/en/error-messages-server.html
  29.      */
  30.     public function convertException($message, DriverException $exception)
  31.     {
  32.         switch ($exception->getErrorCode()) {
  33.             case '1213':
  34.                 return new Exception\DeadlockException($message, $exception);
  35.             case '1205':
  36.                 return new Exception\LockWaitTimeoutException($message, $exception);
  37.             case '1050':
  38.                 return new Exception\TableExistsException($message, $exception);
  40.             case '1051':
  41.             case '1146':
  42.                 return new Exception\TableNotFoundException($message, $exception);
  44.             case '1216':
  45.             case '1217':
  46.             case '1451':
  47.             case '1452':
  48.             case '1701':
  49.                 return new Exception\ForeignKeyConstraintViolationException($message, $exception);
  51.             case '1062':
  52.             case '1557':
  53.             case '1569':
  54.             case '1586':
  55.                 return new Exception\UniqueConstraintViolationException($message, $exception);
  57.             case '1054':
  58.             case '1166':
  59.             case '1611':
  60.                 return new Exception\InvalidFieldNameException($message, $exception);
  62.             case '1052':
  63.             case '1060':
  64.             case '1110':
  65.                 return new Exception\NonUniqueFieldNameException($message, $exception);
  67.             case '1064':
  68.             case '1149':
  69.             case '1287':
  70.             case '1341':
  71.             case '1342':
  72.             case '1343':
  73.             case '1344':
  74.             case '1382':
  75.             case '1479':
  76.             case '1541':
  77.             case '1554':
  78.             case '1626':
  79.                 return new Exception\SyntaxErrorException($message, $exception);
  81.             case '1044':
  82.             case '1045':
  83.             case '1046':
  84.             case '1049':
  85.             case '1095':
  86.             case '1142':
  87.             case '1143':
  88.             case '1227':
  89.             case '1370':
  90.             case '1429':
  91.             case '2002':
  92.             case '2005':
  93.                 return new Exception\ConnectionException($message, $exception);
  95.             case '1048':
  96.             case '1121':
  97.             case '1138':
  98.             case '1171':
  99.             case '1252':
  100.             case '1263':
  101.             case '1364':
  102.             case '1566':
  103.                 return new Exception\NotNullConstraintViolationException($message, $exception);
  104.         }
  106.         return new Exception\DriverException($message, $exception);
  107.     }
  109.     /**
  110.      * {@inheritdoc}
  111.      *
  112.      * @throws DBALException
  113.      */
  114.     public function createDatabasePlatformForVersion($version)
  115.     {
  116.         $mariadb = stripos($version, 'mariadb') !== false;
  117.         if ($mariadb && version_compare($this->getMariaDbMysqlVersionNumber($version), '10.2.7', '>=')) {
  118.             return new MariaDb1027Platform();
  119.         }
  121.         if (! $mariadb) {
  122.             $oracleMysqlVersion = $this->getOracleMysqlVersionNumber($version);
  123.             if (version_compare($oracleMysqlVersion, '8', '>=')) {
  124.                 return new MySQL80Platform();
  125.             }
  126.             if (version_compare($oracleMysqlVersion, '5.7.9', '>=')) {
  127.                 return new MySQL57Platform();
  128.             }
  129.         }
  131.         return $this->getDatabasePlatform();
  132.     }
  134.     /**
  135.      * Get a normalized 'version number' from the server string
  136.      * returned by Oracle MySQL servers.
  137.      *
  138.      * @param string $versionString Version string returned by the driver, i.e. '5.7.10'
  139.      *
  140.      * @throws DBALException
  141.      */
  142.     private function getOracleMysqlVersionNumber(string $versionString) : string
  143.     {
  144.         if (! preg_match(
  145.             '/^(?P<major>\d+)(?:\.(?P<minor>\d+)(?:\.(?P<patch>\d+))?)?/',
  146.             $versionString,
  147.             $versionParts
  148.         )) {
  149.             throw DBALException::invalidPlatformVersionSpecified(
  150.                 $versionString,
  151.                 '<major_version>.<minor_version>.<patch_version>'
  152.             );
  153.         }
  154.         $majorVersion = $versionParts['major'];
  155.         $minorVersion = $versionParts['minor'] ?? 0;
  156.         $patchVersion = $versionParts['patch'] ?? null;
  158.         if ($majorVersion === '5' && $minorVersion === '7' && $patchVersion === null) {
  159.             $patchVersion = '9';
  160.         }
  162.         return $majorVersion . '.' . $minorVersion . '.' . $patchVersion;
  163.     }
  165.     /**
  166.      * Detect MariaDB server version, including hack for some mariadb distributions
  167.      * that starts with the prefix '5.5.5-'
  168.      *
  169.      * @param string $versionString Version string as returned by mariadb server, i.e. '5.5.5-Mariadb-10.0.8-xenial'
  170.      *
  171.      * @throws DBALException
  172.      */
  173.     private function getMariaDbMysqlVersionNumber(string $versionString) : string
  174.     {
  175.         if (! preg_match(
  176.             '/^(?:5\.5\.5-)?(mariadb-)?(?P<major>\d+)\.(?P<minor>\d+)\.(?P<patch>\d+)/i',
  177.             $versionString,
  178.             $versionParts
  179.         )) {
  180.             throw DBALException::invalidPlatformVersionSpecified(
  181.                 $versionString,
  182.                 '^(?:5\.5\.5-)?(mariadb-)?<major_version>.<minor_version>.<patch_version>'
  183.             );
  184.         }
  186.         return $versionParts['major'] . '.' . $versionParts['minor'] . '.' . $versionParts['patch'];
  187.     }
  189.     /**
  190.      * {@inheritdoc}
  191.      */
  192.     public function getDatabase(Connection $conn)
  193.     {
  194.         $params = $conn->getParams();
  196.         return $params['dbname'] ?? $conn->query('SELECT DATABASE()')->fetchColumn();
  197.     }
  199.     /**
  200.      * {@inheritdoc}
  201.      *
  202.      * @return MySqlPlatform
  203.      */
  204.     public function getDatabasePlatform()
  205.     {
  206.         return new MySqlPlatform();
  207.     }
  209.     /**
  210.      * {@inheritdoc}
  211.      *
  212.      * @return MySqlSchemaManager
  213.      */
  214.     public function getSchemaManager(Connection $conn)
  215.     {
  216.         return new MySqlSchemaManager($conn);
  217.     }
  218. }