vendor/doctrine/dbal/src/Driver/PDO/MySQL/Driver.php line 40

Open in your IDE?
  1. <?php
  3. namespace Doctrine\DBAL\Driver\PDO\MySQL;
  5. use Doctrine\DBAL\Driver\AbstractMySQLDriver;
  6. use Doctrine\DBAL\Driver\PDO\Connection;
  7. use Doctrine\DBAL\Driver\PDO\Exception;
  8. use PDO;
  9. use PDOException;
  10. use SensitiveParameter;
  12. final class Driver extends AbstractMySQLDriver
  13. {
  14. /**
  15. * {@inheritDoc}
  16. *
  17. * @return Connection
  18. */
  19. public function connect(
  20. #[SensitiveParameter]
  21. array $params
  22. ) {
  23. $driverOptions = $params['driverOptions'] ?? [];
  25. if (! empty($params['persistent'])) {
  26. $driverOptions[PDO::ATTR_PERSISTENT] = true;
  27. }
  29. $safeParams = $params;
  30. unset($safeParams['password'], $safeParams['url']);
  32. try {
  33. $pdo = new PDO(
  34. $this->constructPdoDsn($safeParams),
  35. $params['user'] ?? '',
  36. $params['password'] ?? '',
  37. $driverOptions,
  38. );
  39. } catch (PDOException $exception) {
  40. throw Exception::new($exception);
  41. }
  43. return new Connection($pdo);
  44. }
  46. /**
  47. * Constructs the MySQL PDO DSN.
  48. *
  49. * @param mixed[] $params
  50. */
  51. private function constructPdoDsn(array $params): string
  52. {
  53. $dsn = 'mysql:';
  54. if (isset($params['host']) && $params['host'] !== '') {
  55. $dsn .= 'host=' . $params['host'] . ';';
  56. }
  58. if (isset($params['port'])) {
  59. $dsn .= 'port=' . $params['port'] . ';';
  60. }
  62. if (isset($params['dbname'])) {
  63. $dsn .= 'dbname=' . $params['dbname'] . ';';
  64. }
  66. if (isset($params['unix_socket'])) {
  67. $dsn .= 'unix_socket=' . $params['unix_socket'] . ';';
  68. }
  70. if (isset($params['charset'])) {
  71. $dsn .= 'charset=' . $params['charset'] . ';';
  72. }
  74. return $dsn;
  75. }
  76. }