Mysql.php 8.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140
  1. <?php
  2. /*
  3. * This file is part of the Symfony package.
  4. *
  5. * (c) Fabien Potencier <fabien@symfony.com>
  6. *
  7. * For the full copyright and license information, please view the LICENSE
  8. * file that was distributed with this source code.
  9. */
  10. namespace Pdo;
  11. use PDO;
  12. if (\PHP_VERSION_ID < 80400 && \extension_loaded('pdo_mysql')) {
  13. // Feature detection for non-mysqlnd; see also https://www.php.net/manual/en/class.pdo-mysql.php#pdo-mysql.constants.attr-max-buffer-size
  14. if (\defined('PDO::MYSQL_ATTR_MAX_BUFFER_SIZE') && \defined('PDO::MYSQL_ATTR_READ_DEFAULT_FILE') && \defined('PDO::MYSQL_ATTR_READ_DEFAULT_GROUP')) {
  15. class Mysql extends \PDO
  16. {
  17. public const ATTR_COMPRESS = \PDO::MYSQL_ATTR_COMPRESS;
  18. public const ATTR_DIRECT_QUERY = \PDO::MYSQL_ATTR_DIRECT_QUERY;
  19. public const ATTR_FOUND_ROWS = \PDO::MYSQL_ATTR_FOUND_ROWS;
  20. public const ATTR_IGNORE_SPACE = \PDO::MYSQL_ATTR_IGNORE_SPACE;
  21. public const ATTR_INIT_COMMAND = \PDO::MYSQL_ATTR_INIT_COMMAND;
  22. public const ATTR_LOCAL_INFILE = \PDO::MYSQL_ATTR_LOCAL_INFILE;
  23. public const ATTR_LOCAL_INFILE_DIRECTORY = \PHP_VERSION_ID >= 80100 ? \PDO::MYSQL_ATTR_LOCAL_INFILE_DIRECTORY : 1015;
  24. public const ATTR_MAX_BUFFER_SIZE = \PDO::MYSQL_ATTR_MAX_BUFFER_SIZE;
  25. public const ATTR_MULTI_STATEMENTS = \PDO::MYSQL_ATTR_MULTI_STATEMENTS;
  26. public const ATTR_READ_DEFAULT_FILE = \PDO::MYSQL_ATTR_READ_DEFAULT_FILE;
  27. public const ATTR_READ_DEFAULT_GROUP = \PDO::MYSQL_ATTR_READ_DEFAULT_GROUP;
  28. public const ATTR_SERVER_PUBLIC_KEY = \PDO::MYSQL_ATTR_SERVER_PUBLIC_KEY;
  29. public const ATTR_SSL_CA = \PDO::MYSQL_ATTR_SSL_CA;
  30. public const ATTR_SSL_CAPATH = \PDO::MYSQL_ATTR_SSL_CAPATH;
  31. public const ATTR_SSL_CERT = \PDO::MYSQL_ATTR_SSL_CERT;
  32. public const ATTR_SSL_CIPHER = \PDO::MYSQL_ATTR_SSL_CIPHER;
  33. public const ATTR_SSL_KEY = \PDO::MYSQL_ATTR_SSL_KEY;
  34. public const ATTR_USE_BUFFERED_QUERY = \PDO::MYSQL_ATTR_USE_BUFFERED_QUERY;
  35. public function __construct(string $dsn, ?string $username = null, ?string $password = null, ?array $options = null)
  36. {
  37. parent::__construct($dsn, $username, $password, $options);
  38. if ('mysql' !== $driver = $this->getAttribute(\PDO::ATTR_DRIVER_NAME)) {
  39. throw new \PDOException(\sprintf('Pdo\Mysql::__construct() cannot be used for connecting to the "%s" driver', $driver));
  40. }
  41. }
  42. public static function connect(string $dsn, ?string $username = null, ?string $password = null, ?array $options = null): self
  43. {
  44. try {
  45. return new self($dsn, $username, $password, $options);
  46. } catch (\PDOException $e) {
  47. throw preg_match('/^Pdo\\\\Mysql::__construct\(\) cannot be used for connecting to the "([a-z]+)" driver/', $e->getMessage(), $matches) ? new \PDOException(\sprintf('Pdo\Mysql::connect() cannot be used for connecting to the "%s" driver', $matches[1])) : $e;
  48. }
  49. }
  50. }
  51. } elseif (\defined('PDO::MYSQL_ATTR_SSL_VERIFY_SERVER_CERT')) {
  52. class Mysql extends \PDO
  53. {
  54. public const ATTR_COMPRESS = \PDO::MYSQL_ATTR_COMPRESS;
  55. public const ATTR_DIRECT_QUERY = \PDO::MYSQL_ATTR_DIRECT_QUERY;
  56. public const ATTR_FOUND_ROWS = \PDO::MYSQL_ATTR_FOUND_ROWS;
  57. public const ATTR_IGNORE_SPACE = \PDO::MYSQL_ATTR_IGNORE_SPACE;
  58. public const ATTR_INIT_COMMAND = \PDO::MYSQL_ATTR_INIT_COMMAND;
  59. public const ATTR_LOCAL_INFILE = \PDO::MYSQL_ATTR_LOCAL_INFILE;
  60. public const ATTR_LOCAL_INFILE_DIRECTORY = \PHP_VERSION_ID >= 80100 ? \PDO::MYSQL_ATTR_LOCAL_INFILE_DIRECTORY : 1015;
  61. // public const ATTR_MAX_BUFFER_SIZE = PDO::MYSQL_ATTR_MAX_BUFFER_SIZE; // disabled for mysqlnd
  62. public const ATTR_MULTI_STATEMENTS = \PDO::MYSQL_ATTR_MULTI_STATEMENTS;
  63. // public const ATTR_READ_DEFAULT_FILE = PDO::MYSQL_ATTR_READ_DEFAULT_FILE; // disabled for mysqlnd
  64. // public const ATTR_READ_DEFAULT_GROUP = PDO::MYSQL_ATTR_READ_DEFAULT_GROUP; // disabled for mysqlnd
  65. public const ATTR_SERVER_PUBLIC_KEY = \PDO::MYSQL_ATTR_SERVER_PUBLIC_KEY;
  66. public const ATTR_SSL_CA = \PDO::MYSQL_ATTR_SSL_CA;
  67. public const ATTR_SSL_CAPATH = \PDO::MYSQL_ATTR_SSL_CAPATH;
  68. public const ATTR_SSL_CERT = \PDO::MYSQL_ATTR_SSL_CERT;
  69. public const ATTR_SSL_CIPHER = \PDO::MYSQL_ATTR_SSL_CIPHER;
  70. public const ATTR_SSL_KEY = \PDO::MYSQL_ATTR_SSL_KEY;
  71. public const ATTR_SSL_VERIFY_SERVER_CERT = \PDO::MYSQL_ATTR_SSL_VERIFY_SERVER_CERT;
  72. public const ATTR_USE_BUFFERED_QUERY = \PDO::MYSQL_ATTR_USE_BUFFERED_QUERY;
  73. public function __construct(string $dsn, ?string $username = null, ?string $password = null, ?array $options = null)
  74. {
  75. parent::__construct($dsn, $username, $password, $options);
  76. if ('mysql' !== $driver = $this->getAttribute(\PDO::ATTR_DRIVER_NAME)) {
  77. throw new \PDOException(\sprintf('Pdo\Mysql::__construct() cannot be used for connecting to the "%s" driver', $driver));
  78. }
  79. }
  80. public static function connect(string $dsn, ?string $username = null, ?string $password = null, ?array $options = null): self
  81. {
  82. try {
  83. return new self($dsn, $username, $password, $options);
  84. } catch (\PDOException $e) {
  85. throw preg_match('/^Pdo\\\\Mysql::__construct\(\) cannot be used for connecting to the "([a-z]+)" driver/', $e->getMessage(), $matches) ? new \PDOException(\sprintf('Pdo\Mysql::connect() cannot be used for connecting to the "%s" driver', $matches[1])) : $e;
  86. }
  87. }
  88. }
  89. } else {
  90. class Mysql extends \PDO
  91. {
  92. public const ATTR_COMPRESS = \PDO::MYSQL_ATTR_COMPRESS;
  93. public const ATTR_DIRECT_QUERY = \PDO::MYSQL_ATTR_DIRECT_QUERY;
  94. public const ATTR_FOUND_ROWS = \PDO::MYSQL_ATTR_FOUND_ROWS;
  95. public const ATTR_IGNORE_SPACE = \PDO::MYSQL_ATTR_IGNORE_SPACE;
  96. public const ATTR_INIT_COMMAND = \PDO::MYSQL_ATTR_INIT_COMMAND;
  97. public const ATTR_LOCAL_INFILE = \PDO::MYSQL_ATTR_LOCAL_INFILE;
  98. public const ATTR_LOCAL_INFILE_DIRECTORY = \PHP_VERSION_ID >= 80100 ? \PDO::MYSQL_ATTR_LOCAL_INFILE_DIRECTORY : 1015;
  99. // public const ATTR_MAX_BUFFER_SIZE = PDO::MYSQL_ATTR_MAX_BUFFER_SIZE; // disabled for mysqlnd
  100. public const ATTR_MULTI_STATEMENTS = \PDO::MYSQL_ATTR_MULTI_STATEMENTS;
  101. // public const ATTR_READ_DEFAULT_FILE = PDO::MYSQL_ATTR_READ_DEFAULT_FILE; // disabled for mysqlnd
  102. // public const ATTR_READ_DEFAULT_GROUP = PDO::MYSQL_ATTR_READ_DEFAULT_GROUP; // disabled for mysqlnd
  103. public const ATTR_SERVER_PUBLIC_KEY = \PDO::MYSQL_ATTR_SERVER_PUBLIC_KEY;
  104. public const ATTR_SSL_CA = \PDO::MYSQL_ATTR_SSL_CA;
  105. public const ATTR_SSL_CAPATH = \PDO::MYSQL_ATTR_SSL_CAPATH;
  106. public const ATTR_SSL_CERT = \PDO::MYSQL_ATTR_SSL_CERT;
  107. public const ATTR_SSL_CIPHER = \PDO::MYSQL_ATTR_SSL_CIPHER;
  108. public const ATTR_SSL_KEY = \PDO::MYSQL_ATTR_SSL_KEY;
  109. public const ATTR_USE_BUFFERED_QUERY = \PDO::MYSQL_ATTR_USE_BUFFERED_QUERY;
  110. public function __construct(string $dsn, ?string $username = null, ?string $password = null, ?array $options = null)
  111. {
  112. parent::__construct($dsn, $username, $password, $options);
  113. if ('mysql' !== $driver = $this->getAttribute(\PDO::ATTR_DRIVER_NAME)) {
  114. throw new \PDOException(\sprintf('Pdo\Mysql::__construct() cannot be used for connecting to the "%s" driver', $driver));
  115. }
  116. }
  117. public static function connect(string $dsn, ?string $username = null, ?string $password = null, ?array $options = null): self
  118. {
  119. try {
  120. return new self($dsn, $username, $password, $options);
  121. } catch (\PDOException $e) {
  122. throw preg_match('/^Pdo\\\\Mysql::__construct\(\) cannot be used for connecting to the "([a-z]+)" driver/', $e->getMessage(), $matches) ? new \PDOException(\sprintf('Pdo\Mysql::connect() cannot be used for connecting to the "%s" driver', $matches[1])) : $e;
  123. }
  124. }
  125. }
  126. }
  127. }