Add MariaDB driver (#50146)

Author: staudenmeir

config/database.php

@@ -59,7 +59,7 @@
         ],
 
         'mariadb' => [
-            'driver' => 'mysql',
+            'driver' => 'mariadb',
             'url' => env('DB_URL'),
             'host' => env('DB_HOST', '127.0.0.1'),
             'port' => env('DB_PORT', '3306'),

src/Illuminate/Database/Connectors/ConnectionFactory.php

@@ -4,6 +4,7 @@
 
 use Illuminate\Contracts\Container\Container;
 use Illuminate\Database\Connection;
+use Illuminate\Database\MariaDbConnection;
 use Illuminate\Database\MySqlConnection;
 use Illuminate\Database\PostgresConnection;
 use Illuminate\Database\SQLiteConnection;
@@ -241,6 +242,7 @@ public function createConnector(array $config)
 
         return match ($config['driver']) {
             'mysql' => new MySqlConnector,
+            'mariadb' => new MariaDbConnector,
             'pgsql' => new PostgresConnector,
             'sqlite' => new SQLiteConnector,
             'sqlsrv' => new SqlServerConnector,
@@ -268,6 +270,7 @@ protected function createConnection($driver, $connection, $database, $prefix = '
 
         return match ($driver) {
             'mysql' => new MySqlConnection($connection, $database, $prefix, $config),
+            'mariadb' => new MariaDbConnection($connection, $database, $prefix, $config),
             'pgsql' => new PostgresConnection($connection, $database, $prefix, $config),
             'sqlite' => new SQLiteConnection($connection, $database, $prefix, $config),
             'sqlsrv' => new SqlServerConnection($connection, $database, $prefix, $config),

src/Illuminate/Database/Connectors/MariaDbConnector.php

@@ -0,0 +1,20 @@
+<?php
+
+namespace Illuminate\Database\Connectors;
+
+use PDO;
+
+class MariaDbConnector extends MySqlConnector implements ConnectorInterface
+{
+    /**
+     * Get the query to enable strict mode.
+     *
+     * @param  \PDO  $connection
+     * @param  array  $config
+     * @return string
+     */
+    protected function strictMode(PDO $connection, $config)
+    {
+        return "set session sql_mode='ONLY_FULL_GROUP_BY,STRICT_TRANS_TABLES,NO_ZERO_IN_DATE,NO_ZERO_DATE,ERROR_FOR_DIVISION_BY_ZERO,NO_ENGINE_SUBSTITUTION'";
+    }
+}

src/Illuminate/Database/Console/DatabaseInspectionCommand.php

@@ -4,6 +4,7 @@
 
 use Illuminate\Console\Command;
 use Illuminate\Database\ConnectionInterface;
+use Illuminate\Database\MariaDbConnection;
 use Illuminate\Database\MySqlConnection;
 use Illuminate\Database\PostgresConnection;
 use Illuminate\Database\SQLiteConnection;
@@ -24,6 +25,7 @@ protected function getConnectionName(ConnectionInterface $connection, $database)
         return match (true) {
             $connection instanceof MySqlConnection && $connection->isMaria() => 'MariaDB',
             $connection instanceof MySqlConnection => 'MySQL',
+            $connection instanceof MariaDbConnection => 'MariaDB',
             $connection instanceof PostgresConnection => 'PostgreSQL',
             $connection instanceof SQLiteConnection => 'SQLite',
             $connection instanceof SqlServerConnection => 'SQL Server',

src/Illuminate/Database/Console/DbCommand.php

@@ -130,7 +130,7 @@ public function commandEnvironment(array $connection)
     public function getCommand(array $connection)
     {
         return [
-            'mysql' => 'mysql',
+            'mysql', 'mariadb' => 'mysql',
             'pgsql' => 'psql',
             'sqlite' => 'sqlite3',
             'sqlsrv' => 'sqlcmd',
@@ -156,6 +156,17 @@ protected function getMysqlArguments(array $connection)
         ], $connection), [$connection['database']]);
     }
 
+    /**
+     * Get the arguments for the MariaDB CLI.
+     *
+     * @param  array  $connection
+     * @return array
+     */
+    protected function getMariaDbArguments(array $connection)
+    {
+        return $this->getMysqlArguments($connection);
+    }
+
     /**
      * Get the arguments for the Postgres CLI.
      *

src/Illuminate/Database/Console/Migrations/MigrateCommand.php

@@ -148,7 +148,7 @@ protected function repositoryExists()
                 if (
                     $e->getPrevious() instanceof PDOException &&
                     $e->getPrevious()->getCode() === 1049 &&
-                    $connection->getDriverName() === 'mysql') {
+                    in_array($connection->getDriverName(), ['mysql', 'mariadb'])) {
                     return $this->createMissingMysqlDatabase($connection);
                 }
 

src/Illuminate/Database/DatabaseManager.php

@@ -361,13 +361,13 @@ public function setDefaultConnection($name)
     }
 
     /**
-     * Get all of the support drivers.
+     * Get all of the supported drivers.
      *
      * @return string[]
      */
     public function supportedDrivers()
     {
-        return ['mysql', 'pgsql', 'sqlite', 'sqlsrv'];
+        return ['mysql', 'mariadb', 'pgsql', 'sqlite', 'sqlsrv'];
     }
 
     /**

src/Illuminate/Database/MariaDbConnection.php

@@ -0,0 +1,94 @@
+<?php
+
+namespace Illuminate\Database;
+
+use Illuminate\Database\Query\Grammars\MariaDbGrammar as QueryGrammar;
+use Illuminate\Database\Query\Processors\MariaDbProcessor;
+use Illuminate\Database\Schema\Grammars\MariaDbGrammar as SchemaGrammar;
+use Illuminate\Database\Schema\MariaDbBuilder;
+use Illuminate\Database\Schema\MariaDbSchemaState;
+use Illuminate\Filesystem\Filesystem;
+use Illuminate\Support\Str;
+
+class MariaDbConnection extends MySqlConnection
+{
+    /**
+     * Determine if the connected database is a MariaDB database.
+     *
+     * @return bool
+     */
+    public function isMaria()
+    {
+        return true;
+    }
+
+    /**
+     * Get the server version for the connection.
+     *
+     * @return string
+     */
+    public function getServerVersion(): string
+    {
+        return Str::between(parent::getServerVersion(), '5.5.5-', '-MariaDB');
+    }
+
+    /**
+     * Get the default query grammar instance.
+     *
+     * @return \Illuminate\Database\Query\Grammars\MariaDbGrammar
+     */
+    protected function getDefaultQueryGrammar()
+    {
+        ($grammar = new QueryGrammar)->setConnection($this);
+
+        return $this->withTablePrefix($grammar);
+    }
+
+    /**
+     * Get a schema builder instance for the connection.
+     *
+     * @return \Illuminate\Database\Schema\MariaDbBuilder
+     */
+    public function getSchemaBuilder()
+    {
+        if (is_null($this->schemaGrammar)) {
+            $this->useDefaultSchemaGrammar();
+        }
+
+        return new MariaDbBuilder($this);
+    }
+
+    /**
+     * Get the default schema grammar instance.
+     *
+     * @return \Illuminate\Database\Schema\Grammars\MariaDbGrammar
+     */
+    protected function getDefaultSchemaGrammar()
+    {
+        ($grammar = new SchemaGrammar)->setConnection($this);
+
+        return $this->withTablePrefix($grammar);
+    }
+
+    /**
+     * Get the schema state for the connection.
+     *
+     * @param  \Illuminate\Filesystem\Filesystem|null  $files
+     * @param  callable|null  $processFactory
+     * @return \Illuminate\Database\Schema\MariaDbSchemaState
+     */
+    public function getSchemaState(Filesystem $files = null, callable $processFactory = null)
+    {
+        return new MariaDbSchemaState($this, $files, $processFactory);
+    }
+
+    /**
+     * Get the default post processor instance.
+     *
+     * @return \Illuminate\Database\Query\Processors\MariaDbProcessor
+     */
+    protected function getDefaultPostProcessor()
+    {
+        return new MariaDbProcessor;
+    }
+}

src/Illuminate/Database/Query/Grammars/MariaDbGrammar.php

@@ -0,0 +1,19 @@
+<?php
+
+namespace Illuminate\Database\Query\Grammars;
+
+use Illuminate\Database\Query\Builder;
+
+class MariaDbGrammar extends MySqlGrammar
+{
+    /**
+     * Determine whether to use a legacy group limit clause for MySQL < 8.0.
+     *
+     * @param  \Illuminate\Database\Query\Builder  $query
+     * @return bool
+     */
+    public function useLegacyGroupLimit(Builder $query)
+    {
+        return false;
+    }
+}

src/Illuminate/Database/Query/Processors/MariaDbProcessor.php

@@ -0,0 +1,8 @@
+<?php
+
+namespace Illuminate\Database\Query\Processors;
+
+class MariaDbProcessor extends MySqlProcessor
+{
+    //
+}