diff --git a/core/includes/install.inc b/core/includes/install.inc
index 544101ab99d753a0bbcfa994bb9cfa40cd0a579e..587480dbe6e80e984065bf020ebef20c9ce19def 100644
--- a/core/includes/install.inc
+++ b/core/includes/install.inc
@@ -1091,12 +1091,12 @@ function install_profile_info($profile, $langcode = 'en') {
function db_installer_object($driver) {
// We cannot use Database::getConnection->getDriverClass() here, because
// the connection object is not yet functional.
- $task_class = "Drupal\\Core\\Database\\Driver\\{$driver}\\Install\\Tasks";
+ $task_class = "Drupal\\Driver\\Database\\{$driver}\\Install\\Tasks";
if (class_exists($task_class)) {
return new $task_class();
}
else {
- $task_class = "Drupal\\Driver\\Database\\{$driver}\\Install\\Tasks";
+ $task_class = "Drupal\\Core\\Database\\Driver\\{$driver}\\Install\\Tasks";
return new $task_class();
}
}
diff --git a/core/lib/Drupal/Core/Database/Database.php b/core/lib/Drupal/Core/Database/Database.php
index d13ea80862a325bd391125b6034d825309ce304e..173caf3ece548b0c238601ea72af6ffc2add2c64 100644
--- a/core/lib/Drupal/Core/Database/Database.php
+++ b/core/lib/Drupal/Core/Database/Database.php
@@ -457,14 +457,14 @@ public static function convertDbUrlToConnectionInfo($url, $root) {
}
$driver = $matches[1];
- // Discover if the URL has a valid driver scheme. Try with core drivers
- // first.
- $connection_class = "Drupal\\Core\\Database\\Driver\\{$driver}\\Connection";
+ // Discover if the URL has a valid driver scheme. Try with custom drivers
+ // first, since those can override/extend the core ones.
+ $connection_class = $custom_connection_class = "Drupal\\Driver\\Database\\{$driver}\\Connection";
if (!class_exists($connection_class)) {
- // If the URL is not relative to a core driver, try with custom ones.
- $connection_class = "Drupal\\Driver\\Database\\{$driver}\\Connection";
+ // If the URL is not relative to a custom driver, try with core ones.
+ $connection_class = "Drupal\\Core\\Database\\Driver\\{$driver}\\Connection";
if (!class_exists($connection_class)) {
- throw new \InvalidArgumentException("Can not convert '$url' to a database connection, class '$connection_class' does not exist");
+ throw new \InvalidArgumentException("Can not convert '$url' to a database connection, class '$custom_connection_class' does not exist");
}
}
diff --git a/core/tests/Drupal/Tests/Core/Database/InstallerObjectTest.php b/core/tests/Drupal/Tests/Core/Database/InstallerObjectTest.php
new file mode 100644
index 0000000000000000000000000000000000000000..87cf3208a86e49f71ffbb644d67ce21694b17976
--- /dev/null
+++ b/core/tests/Drupal/Tests/Core/Database/InstallerObjectTest.php
@@ -0,0 +1,68 @@
+<?php
+
+namespace Drupal\Tests\Core\Database;
+
+use Composer\Autoload\ClassLoader;
+use Drupal\Core\Database\Driver\mysql\Install\Tasks as MysqlInstallTasks;
+use Drupal\Driver\Database\fake\Install\Tasks as FakeInstallTasks;
+use Drupal\Driver\Database\corefake\Install\Tasks as CustomCoreFakeInstallTasks;
+use Drupal\Tests\UnitTestCase;
+
+/**
+ * Tests the db_installer_object() function that is used during installation.
+ *
+ * These tests run in isolation to prevent the autoloader additions from
+ * affecting other tests.
+ *
+ * @covers ::db_installer_object
+ *
+ * @runTestsInSeparateProcesses
+ * @preserveGlobalState disabled
+ *
+ * @group Database
+ */
+class InstallerObjectTest extends UnitTestCase {
+
+ /**
+ * {@inheritdoc}
+ */
+ protected function setUp() {
+ parent::setUp();
+ require_once __DIR__ . '/../../../../../includes/install.inc';
+ $additional_class_loader = new ClassLoader();
+ $additional_class_loader->addPsr4("Drupal\\Driver\\Database\\fake\\", __DIR__ . "/../../../../../tests/fixtures/database_drivers/custom/fake");
+ $additional_class_loader->addPsr4("Drupal\\Core\\Database\\Driver\\corefake\\", __DIR__ . "/../../../../../tests/fixtures/database_drivers/core/corefake");
+ $additional_class_loader->addPsr4("Drupal\\Driver\\Database\\corefake\\", __DIR__ . "/../../../../../tests/fixtures/database_drivers/custom/corefake");
+ $additional_class_loader->register(TRUE);
+ }
+
+ /**
+ * @dataProvider providerDbInstallerObject
+ */
+ public function testDbInstallerObject($driver, $expected_class_name) {
+ $object = db_installer_object($driver);
+ $this->assertEquals(get_class($object), $expected_class_name);
+ }
+
+ /**
+ * Dataprovider for testDbUrltoConnectionConversion().
+ *
+ * @return array
+ * Array of arrays with the following elements:
+ * - driver: The driver name.
+ * - class: The fully qualified class name of the expected install task.
+ */
+ public function providerDbInstallerObject() {
+ return [
+ // A driver only in the core namespace.
+ ['mysql', MysqlInstallTasks::class],
+
+ // A driver only in the custom namespace.
+ ['fake', FakeInstallTasks::class],
+
+ // A driver in both namespaces. The custom one takes precedence.
+ ['corefake', CustomCoreFakeInstallTasks::class],
+ ];
+ }
+
+}
diff --git a/core/tests/Drupal/Tests/Core/Database/UrlConversionTest.php b/core/tests/Drupal/Tests/Core/Database/UrlConversionTest.php
index b48e5c05146bb923ba9af785d35e2f69e1f3cd49..8f9b9705b045b6607838246fc3f255f203855e82 100644
--- a/core/tests/Drupal/Tests/Core/Database/UrlConversionTest.php
+++ b/core/tests/Drupal/Tests/Core/Database/UrlConversionTest.php
@@ -27,7 +27,9 @@ class UrlConversionTest extends UnitTestCase {
protected function setUp() {
parent::setUp();
$additional_class_loader = new ClassLoader();
- $additional_class_loader->addPsr4("Drupal\\Driver\\Database\\fake\\", __DIR__ . "/fixtures/driver/fake");
+ $additional_class_loader->addPsr4("Drupal\\Driver\\Database\\fake\\", __DIR__ . "/../../../../../tests/fixtures/database_drivers/custom/fake");
+ $additional_class_loader->addPsr4("Drupal\\Core\\Database\\Driver\\corefake\\", __DIR__ . "/../../../../../tests/fixtures/database_drivers/core/corefake");
+ $additional_class_loader->addPsr4("Drupal\\Driver\\Database\\corefake\\", __DIR__ . "/../../../../../tests/fixtures/database_drivers/custom/corefake");
$additional_class_loader->register(TRUE);
}
@@ -127,6 +129,19 @@ public function providerConvertDbUrlToConnectionInfo() {
'namespace' => 'Drupal\Driver\Database\fake',
],
],
+ 'Fake core driver with custom override, without prefix' => [
+ '',
+ 'corefake://fake_user:fake_pass@fake_host:3456/fake_database',
+ [
+ 'driver' => 'corefake',
+ 'username' => 'fake_user',
+ 'password' => 'fake_pass',
+ 'host' => 'fake_host',
+ 'database' => 'fake_database',
+ 'port' => 3456,
+ 'namespace' => 'Drupal\Driver\Database\corefake',
+ ],
+ ],
];
}
diff --git a/core/tests/fixtures/database_drivers/core/corefake/Connection.php b/core/tests/fixtures/database_drivers/core/corefake/Connection.php
new file mode 100644
index 0000000000000000000000000000000000000000..b3228a2137dbc4c95d4e6f223831a6ec3bfb7f91
--- /dev/null
+++ b/core/tests/fixtures/database_drivers/core/corefake/Connection.php
@@ -0,0 +1,14 @@
+<?php
+
+namespace Drupal\Core\Database\Driver\corefake;
+
+use Drupal\Driver\Database\fake\Connection as BaseConnection;
+
+class Connection extends BaseConnection {
+
+ /**
+ * {@inheritdoc}
+ */
+ public $driver = 'corefake';
+
+}
diff --git a/core/tests/fixtures/database_drivers/core/corefake/Install/Tasks.php b/core/tests/fixtures/database_drivers/core/corefake/Install/Tasks.php
new file mode 100644
index 0000000000000000000000000000000000000000..4cb9083ffa19c65f648b4e7660c4d9b2c9713216
--- /dev/null
+++ b/core/tests/fixtures/database_drivers/core/corefake/Install/Tasks.php
@@ -0,0 +1,16 @@
+<?php
+
+namespace Drupal\Core\Database\Driver\corefake\Install;
+
+use Drupal\Core\Database\Install\Tasks as InstallTasks;
+
+class Tasks extends InstallTasks {
+
+ /**
+ * {@inheritdoc}
+ */
+ public function name() {
+ return 'corefake';
+ }
+
+}
diff --git a/core/tests/fixtures/database_drivers/custom/corefake/Connection.php b/core/tests/fixtures/database_drivers/custom/corefake/Connection.php
new file mode 100644
index 0000000000000000000000000000000000000000..4c5188085e70a6f1c6f185f81dd9fc140849cfef
--- /dev/null
+++ b/core/tests/fixtures/database_drivers/custom/corefake/Connection.php
@@ -0,0 +1,7 @@
+<?php
+
+namespace Drupal\Driver\Database\corefake;
+
+use Drupal\Core\Database\Driver\corefake\Connection as CoreFakeConnection;
+
+class Connection extends CoreFakeConnection {}
diff --git a/core/tests/fixtures/database_drivers/custom/corefake/Install/Tasks.php b/core/tests/fixtures/database_drivers/custom/corefake/Install/Tasks.php
new file mode 100644
index 0000000000000000000000000000000000000000..d131a3f1c7bc2c2d34abc295164e8badf983b9c4
--- /dev/null
+++ b/core/tests/fixtures/database_drivers/custom/corefake/Install/Tasks.php
@@ -0,0 +1,9 @@
+<?php
+
+namespace Drupal\Driver\Database\corefake\Install;
+
+use Drupal\Core\Database\Driver\corefake\Install\Tasks as BaseInstallTasks;
+
+class Tasks extends BaseInstallTasks {
+
+}
diff --git a/core/tests/Drupal/Tests/Core/Database/fixtures/driver/fake/Connection.php b/core/tests/fixtures/database_drivers/custom/fake/Connection.php
similarity index 100%
rename from core/tests/Drupal/Tests/Core/Database/fixtures/driver/fake/Connection.php
rename to core/tests/fixtures/database_drivers/custom/fake/Connection.php
diff --git a/core/tests/fixtures/database_drivers/custom/fake/Install/Tasks.php b/core/tests/fixtures/database_drivers/custom/fake/Install/Tasks.php
new file mode 100644
index 0000000000000000000000000000000000000000..2cd65190a50fcff35c02bb7a635756889e6ab7de
--- /dev/null
+++ b/core/tests/fixtures/database_drivers/custom/fake/Install/Tasks.php
@@ -0,0 +1,16 @@
+<?php
+
+namespace Drupal\Driver\Database\fake\Install;
+
+use Drupal\Core\Database\Install\Tasks as InstallTasks;
+
+class Tasks extends InstallTasks {
+
+ /**
+ * {@inheritdoc}
+ */
+ public function name() {
+ return 'fake';
+ }
+
+}