summaryrefslogtreecommitdiffstats
path: root/vendor/ipl/sql/src/Adapter/Mssql.php
blob: c1c4e1c03c5e2f213f53dd7158b43a2fcc993751 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
<?php

namespace ipl\Sql\Adapter;

use ipl\Sql\Config;
use ipl\Sql\QueryBuilder;
use ipl\Sql\Select;
use PDO;
use RuntimeException;

class Mssql extends BaseAdapter
{
    protected $quoteCharacter = ['[', ']'];

    protected $escapeCharacter = '[[]';

    public function getDsn(Config $config)
    {
        $drivers = array_intersect(['sqlsrv', 'dblib', 'mssql', 'sybase'], PDO::getAvailableDrivers());

        if (empty($drivers)) {
            throw new RuntimeException('No PDO driver available for connecting to a Microsoft SQL Server');
        }

        $driver = reset($drivers); // array_intersect preserves keys, so the first may not be indexed at 0

        $isSqlSrv = $driver === 'sqlsrv';
        if ($isSqlSrv) {
            $hostOption = 'Server';
            $dbOption = 'Database';
        } else {
            $hostOption = 'host';
            $dbOption = 'dbname';
        }

        $dsn = "{$driver}:{$hostOption}={$config->host}";

        if (! empty($config->port)) {
            if ($isSqlSrv || strtoupper(substr(PHP_OS, 0, 3)) === 'WIN') {
                $seperator = ',';
            } else {
                $seperator = ':';
            }

            $dsn .= "{$seperator}{$config->port}";
        }

        $dsn .= ";{$dbOption}={$config->dbname}";

        if (! empty($config->charset) && ! $isSqlSrv) {
            $dsn .= ";charset={$config->charset}";
        }

        if (isset($config->use_ssl) && $isSqlSrv) {
            $dsn .= ';Encrypt=' . ($config->use_ssl ? 'true' : 'false');
        }

        if (isset($config->ssl_do_not_verify_server_cert) && $isSqlSrv) {
            $dsn .= ';TrustServerCertificate=' . ($config->ssl_do_not_verify_server_cert ? 'true' : 'false');
        }

        return $dsn;
    }

    public function registerQueryBuilderCallbacks(QueryBuilder $queryBuilder)
    {
        parent::registerQueryBuilderCallbacks($queryBuilder);

        $queryBuilder->on(QueryBuilder::ON_ASSEMBLE_SELECT, function (Select $select) {
            if (
                ($select->hasLimit() || $select->hasOffset())
                && ! $select->hasOrderBy()
            ) {
                $select->orderBy(1);
            }
        });
    }
}