Driver.php 2.33 KB
Newer Older
1 2 3 4
<?php

namespace Doctrine\DBAL\Driver\PDOSqlsrv;

5
use Doctrine\DBAL\Driver\AbstractSQLServerDriver;
6
use PDO;
7 8
use function is_int;
use function sprintf;
Steve Müller's avatar
Steve Müller committed
9

10 11 12
/**
 * The PDO-based Sqlsrv driver.
 */
13
class Driver extends AbstractSQLServerDriver
14
{
Benjamin Morel's avatar
Benjamin Morel committed
15 16 17
    /**
     * {@inheritdoc}
     */
18
    public function connect(array $params, $username = null, $password = null, array $driverOptions = [])
19
    {
Sergei Morozov's avatar
Sergei Morozov committed
20 21 22 23 24 25 26 27 28
        $pdoOptions = $dsnOptions = [];

        foreach ($driverOptions as $option => $value) {
            if (is_int($option)) {
                $pdoOptions[$option] = $value;
            } else {
                $dsnOptions[$option] = $value;
            }
        }
29

30 31 32 33
        if (! empty($params['persistent'])) {
            $pdoOptions[PDO::ATTR_PERSISTENT] = true;
        }

Juozas Kaziukenas's avatar
Juozas Kaziukenas committed
34
        return new Connection(
Sergei Morozov's avatar
Sergei Morozov committed
35
            $this->_constructPdoDsn($params, $dsnOptions),
36 37
            $username,
            $password,
Sergei Morozov's avatar
Sergei Morozov committed
38
            $pdoOptions
39 40 41 42 43 44
        );
    }

    /**
     * Constructs the Sqlsrv PDO DSN.
     *
45
     * @param mixed[]  $params
46
     * @param string[] $connectionOptions
Benjamin Morel's avatar
Benjamin Morel committed
47 48
     *
     * @return string The DSN.
49
     */
50
    private function _constructPdoDsn(array $params, array $connectionOptions)
51
    {
52
        $dsn = 'sqlsrv:server=';
53

54 55 56
        if (isset($params['host'])) {
            $dsn .= $params['host'];
        }
57

58
        if (isset($params['port'])) {
59 60
            $dsn .= ',' . $params['port'];
        }
61

62
        if (isset($params['dbname'])) {
63
            $connectionOptions['Database'] = $params['dbname'];
64 65 66
        }

        if (isset($params['MultipleActiveResultSets'])) {
67
            $connectionOptions['MultipleActiveResultSets'] = $params['MultipleActiveResultSets'] ? 'true' : 'false';
68
        }
69

70
        return $dsn . $this->getConnectionOptionsDsn($connectionOptions);
71 72
    }

73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88
    /**
     * Converts a connection options array to the DSN
     *
     * @param string[] $connectionOptions
     */
    private function getConnectionOptionsDsn(array $connectionOptions) : string
    {
        $connectionOptionsDsn = '';

        foreach ($connectionOptions as $paramName => $paramValue) {
            $connectionOptionsDsn .= sprintf(';%s=%s', $paramName, $paramValue);
        }

        return $connectionOptionsDsn;
    }

Benjamin Morel's avatar
Benjamin Morel committed
89 90
    /**
     * {@inheritdoc}
91 92
     *
     * @deprecated
Benjamin Morel's avatar
Benjamin Morel committed
93
     */
94 95 96 97
    public function getName()
    {
        return 'pdo_sqlsrv';
    }
98
}