1 files changed, 78 insertions, 0 deletions
diff --git a/vendor/ipl/sql/src/Adapter/Mssql.php b/vendor/ipl/sql/src/Adapter/Mssql.php
new file mode 100644
index 0000000..c1c4e1c
--- /dev/null
+++ b/vendor/ipl/sql/src/Adapter/Mssql.php
@@ -0,0 +1,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);
+            }
+        });
+    }
+}