vendor/doctrine/dbal/src/Driver/PDO/SQLSrv/Driver.php line 48

Open in your IDE?
  1. <?php
  3. namespace Doctrine\DBAL\Driver\PDO\SQLSrv;
  5. use Doctrine\DBAL\Driver\AbstractSQLServerDriver;
  6. use Doctrine\DBAL\Driver\AbstractSQLServerDriver\Exception\PortWithoutHost;
  7. use Doctrine\DBAL\Driver\Exception;
  8. use Doctrine\DBAL\Driver\PDO\Connection as PDOConnection;
  9. use Doctrine\DBAL\Driver\PDO\Exception as PDOException;
  10. use PDO;
  12. use function is_int;
  13. use function sprintf;
  15. final class Driver extends AbstractSQLServerDriver
  16. {
  17.     /**
  18.      * {@inheritdoc}
  19.      *
  20.      * @return Connection
  21.      */
  22.     public function connect(array $params)
  23.     {
  24.         $driverOptions = $dsnOptions = [];
  26.         if (isset($params['driverOptions'])) {
  27.             foreach ($params['driverOptions'] as $option => $value) {
  28.                 if (is_int($option)) {
  29.                     $driverOptions[$option] = $value;
  30.                 } else {
  31.                     $dsnOptions[$option] = $value;
  32.                 }
  33.             }
  34.         }
  36.         if (! empty($params['persistent'])) {
  37.             $driverOptions[PDO::ATTR_PERSISTENT] = true;
  38.         }
  40.         try {
  41.             $pdo = new PDO(
  42.                 $this->constructDsn($params, $dsnOptions),
  43.                 $params['user'] ?? '',
  44.                 $params['password'] ?? '',
  45.                 $driverOptions
  46.             );
  47.         } catch (\PDOException $exception) {
  48.             throw PDOException::new($exception);
  49.         }
  51.         return new Connection(new PDOConnection($pdo));
  52.     }
  54.     /**
  55.      * Constructs the Sqlsrv PDO DSN.
  56.      *
  57.      * @param mixed[]  $params
  58.      * @param string[] $connectionOptions
  59.      *
  60.      * @throws Exception
  61.      */
  62.     private function constructDsn(array $params, array $connectionOptions): string
  63.     {
  64.         $dsn = 'sqlsrv:server=';
  66.         if (isset($params['host'])) {
  67.             $dsn .= $params['host'];
  69.             if (isset($params['port'])) {
  70.                 $dsn .= ',' . $params['port'];
  71.             }
  72.         } elseif (isset($params['port'])) {
  73.             throw PortWithoutHost::new();
  74.         }
  76.         if (isset($params['dbname'])) {
  77.             $connectionOptions['Database'] = $params['dbname'];
  78.         }
  80.         if (isset($params['MultipleActiveResultSets'])) {
  81.             $connectionOptions['MultipleActiveResultSets'] = $params['MultipleActiveResultSets'] ? 'true' : 'false';
  82.         }
  84.         return $dsn . $this->getConnectionOptionsDsn($connectionOptions);
  85.     }
  87.     /**
  88.      * Converts a connection options array to the DSN
  89.      *
  90.      * @param string[] $connectionOptions
  91.      */
  92.     private function getConnectionOptionsDsn(array $connectionOptions): string
  93.     {
  94.         $connectionOptionsDsn = '';
  96.         foreach ($connectionOptions as $paramName => $paramValue) {
  97.             $connectionOptionsDsn .= sprintf(';%s=%s', $paramName, $paramValue);
  98.         }
  100.         return $connectionOptionsDsn;
  101.     }
  102. }