support mariadb driver

Author: harryqt

Diff for: src/Connectors/ConnectionFactory.php

@@ -2,18 +2,17 @@
 
 namespace Hoyvoy\CrossDatabase\Connectors;
 
+use Hoyvoy\CrossDatabase\MariaDbConnection;
 use Hoyvoy\CrossDatabase\MySqlConnection;
 use Hoyvoy\CrossDatabase\PostgresConnection;
 use Hoyvoy\CrossDatabase\SqlServerConnection;
 use Illuminate\Database\Connection;
-use Illuminate\Database\Connectors\ConnectionFactory as IlluminateConnectionFactory;
-use PDO;
 
-class ConnectionFactory extends IlluminateConnectionFactory
+class ConnectionFactory extends \Illuminate\Database\Connectors\ConnectionFactory
 {
     /**
      * @param string       $driver
-     * @param \Closure|PDO $connection
+     * @param \Closure|\PDO $connection
      * @param string       $database
      * @param string       $prefix
      * @param array        $config
@@ -26,14 +25,12 @@ protected function createConnection($driver, $connection, $database, $prefix = '
             return $resolver($connection, $database, $prefix, $config);
         }
 
-        switch ($driver) {
-            case 'mysql':
-                return new MySqlConnection($connection, $database, $prefix, $config);
-            case 'pgsql':
-                return new PostgresConnection($connection, $database, $prefix, $config);
-            case 'sqlsrv':
-                return new SqlServerConnection($connection, $database, $prefix, $config);
-        }
+        return match ($driver) {
+            'mysql' => new MySqlConnection($connection, $database, $prefix, $config),
+            'mariadb' => new MariaDbConnection($connection, $database, $prefix, $config),
+            'pgsql' => new PostgresConnection($connection, $database, $prefix, $config),
+            'sqlsrv' => new SqlServerConnection($connection, $database, $prefix, $config),
+        };
 
         return parent::createConnection($driver, $connection, $database, $prefix, $config);
     }

Diff for: src/MariaDbConnection.php

@@ -0,0 +1,16 @@
+<?php
+
+namespace Hoyvoy\CrossDatabase;
+
+class MariaDbConnection extends \Illuminate\Database\MariaDbConnection implements CanCrossDatabaseShazaamInterface
+{
+    /**
+     * Get the default query grammar instance.
+     *
+     * @return \Illuminate\Database\Query\Grammars\MySqlGrammar
+     */
+    protected function getDefaultQueryGrammar()
+    {
+        return $this->withTablePrefix(new \Hoyvoy\CrossDatabase\Query\Grammars\MariaDbGrammar());
+    }
+}

Diff for: src/Query/Grammars/MariaDbGrammar.php

@@ -0,0 +1,33 @@
+<?php
+
+namespace Hoyvoy\CrossDatabase\Query\Grammars;
+
+use Illuminate\Database\Query\Builder;
+
+class MariaDbGrammar extends \Illuminate\Database\Query\Grammars\MariaDbGrammar
+{
+    /**
+     * Compile the "from" portion of the query.
+     *
+     * @param \Illuminate\Database\Query\Builder $query
+     * @param string                             $table
+     *
+     * @return string
+     */
+    protected function compileFrom(Builder $query, $table)
+    {
+        // Check for cross database query to attach database name
+        if (strpos($table, '<-->') !== false) {
+            list($prefix, $table, $database) = explode('<-->', $table);
+            $wrappedTable = $this->wrapTable($table, true);
+            $wrappedTablePrefixed = $this->wrap($prefix.$table, true);
+            if ($wrappedTable != $wrappedTablePrefixed) {
+                return 'from '.$this->wrap($database).'.'.$wrappedTablePrefixed.' as '.$wrappedTable;
+            }
+
+            return 'from '.$this->wrap($database).'.'.$wrappedTablePrefixed;
+        }
+
+        return 'from '.$this->wrapTable($table);
+    }
+}