1 files changed, 120 insertions, 0 deletions
diff --git a/vendor/ipl/sql/src/Adapter/BaseAdapter.php b/vendor/ipl/sql/src/Adapter/BaseAdapter.php
new file mode 100644
index 0000000..f062f63
--- /dev/null
+++ b/vendor/ipl/sql/src/Adapter/BaseAdapter.php
@@ -0,0 +1,120 @@
+<?php
+
+namespace ipl\Sql\Adapter;
+
+use DateTime;
+use DateTimeZone;
+use ipl\Sql\Config;
+use ipl\Sql\Connection;
+use ipl\Sql\Contract\Adapter;
+use ipl\Sql\QueryBuilder;
+use ipl\Sql\Select;
+use PDO;
+use UnexpectedValueException;
+
+abstract class BaseAdapter implements Adapter
+{
+    /**
+     * Quote character to use for quoting identifiers
+     *
+     * The default quote character is the double quote (") which is used by databases that behave close to ANSI SQL.
+     *
+     * @var array
+     */
+    protected $quoteCharacter = ['"', '"'];
+
+    /** @var string Character to use for escaping quote characters */
+    protected $escapeCharacter = '\\"';
+
+    /** @var array Default PDO connect options */
+    protected $options = [
+        PDO::ATTR_CASE => PDO::CASE_NATURAL,
+        PDO::ATTR_EMULATE_PREPARES => false,
+        PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
+        PDO::ATTR_ORACLE_NULLS => PDO::NULL_NATURAL,
+        PDO::ATTR_STRINGIFY_FETCHES => false
+    ];
+
+    public function getDsn(Config $config)
+    {
+        $dsn = "{$config->db}:";
+
+        $parts = [];
+
+        foreach (['host', 'dbname', 'port'] as $part) {
+            if (! empty($config->$part)) {
+                $parts[] = "{$part}={$config->$part}";
+            }
+        }
+
+        return $dsn . implode(';', $parts);
+    }
+
+    public function getOptions(Config $config)
+    {
+        if (is_array($config->options)) {
+            return $config->options + $this->options;
+        }
+
+        return $this->options;
+    }
+
+    public function setClientTimezone(Connection $db)
+    {
+        return $this;
+    }
+
+    public function quoteIdentifier($identifiers)
+    {
+        if (is_string($identifiers)) {
+            $identifiers = explode('.', $identifiers);
+        }
+
+        foreach ($identifiers as $i => $identifier) {
+            if ($identifier === '*') {
+                continue;
+            }
+
+            $identifiers[$i] = $this->quoteCharacter[0]
+                . str_replace($this->quoteCharacter[0], $this->escapeCharacter, $identifier)
+                . $this->quoteCharacter[1];
+        }
+
+        return implode('.', $identifiers);
+    }
+
+    public function registerQueryBuilderCallbacks(QueryBuilder $queryBuilder)
+    {
+        $queryBuilder->on(QueryBuilder::ON_ASSEMBLE_SELECT, function (Select $select): void {
+            if ($select->hasOrderBy()) {
+                foreach ($select->getOrderBy() as list($_, $direction)) {
+                    switch (strtolower($direction ?? '')) {
+                        case '':
+                        case 'asc':
+                        case 'desc':
+                            break;
+                        default:
+                            throw new UnexpectedValueException(
+                                sprintf('Invalid direction "%s" in ORDER BY', $direction)
+                            );
+                    }
+                }
+            }
+        });
+
+        return $this;
+    }
+
+    protected function getTimezoneOffset()
+    {
+        $tz = new DateTimeZone(date_default_timezone_get());
+        $offset = $tz->getOffset(new DateTime());
+        $prefix = $offset >= 0 ? '+' : '-';
+        $offset = abs($offset);
+
+        $hours = (int) floor($offset / 3600);
+        $minutes = (int) floor(($offset % 3600) / 60);
+
+        return sprintf('%s%d:%02d', $prefix, $hours, $minutes);
+    }
+}