test(Database): isolate database name per test component to prevent race conditions during parallel run

Author: gr8man

tests/_support/Config/Registrar.php

@@ -13,6 +13,10 @@
 
 namespace Tests\Support\Config;
 
+use mysqli;
+use PDO;
+use Throwable;
+
 /**
  * Class Registrar
  *
@@ -137,7 +141,63 @@ public static function Database(): array
         // so that we can test against multiple databases.
         $group = env('DB', 'SQLite3');
 
-        $config['tests'] = self::$dbConfig[$group] ?? [];
+        $dbParams = self::$dbConfig[$group] ?? [];
+
+        if (! empty($dbParams) && $group !== 'SQLite3') {
+            $componentName = '';
+
+            foreach ($_SERVER['argv'] ?? [] as $arg) {
+                if (str_contains($arg, 'tests/system/')) {
+                    $parts = explode('tests/system/', $arg);
+                    if (isset($parts[1])) {
+                        $componentName = explode('/', $parts[1])[0];
+                        break;
+                    }
+                }
+            }
+
+            if ($componentName !== '') {
+                $dbParams['database'] = 'test_' . strtolower($componentName);
+
+                try {
+                    if ($group === 'MySQLi') {
+                        $conn = @new mysqli(
+                            $dbParams['hostname'],
+                            $dbParams['username'],
+                            $dbParams['password'],
+                            '',
+                            (int) $dbParams['port'],
+                        );
+                        if (! $conn->connect_error) {
+                            $conn->query('CREATE DATABASE IF NOT EXISTS ' . $conn->real_escape_string($dbParams['database']));
+                            $conn->close();
+                        }
+                    } elseif ($group === 'Postgre') {
+                        $dsn = 'pgsql:host=' . $dbParams['hostname'] . ';port=' . $dbParams['port'] . ';user=' . $dbParams['username'] . ';password=' . $dbParams['password'];
+                        $pdo = new PDO($dsn);
+                        $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
+                        $stmt = $pdo->prepare('SELECT 1 FROM pg_database WHERE datname = ?');
+                        $stmt->execute([$dbParams['database']]);
+                        if (! $stmt->fetchColumn()) {
+                            $pdo->exec('CREATE DATABASE ' . $pdo->quote($dbParams['database']));
+                        }
+                    } elseif ($group === 'SQLSRV') {
+                        $dsn = 'sqlsrv:Server=' . $dbParams['hostname'] . ',' . $dbParams['port'] . ';Encrypt=False;TrustServerCertificate=True';
+                        $pdo = new PDO($dsn, $dbParams['username'], $dbParams['password']);
+                        $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
+                        $stmt = $pdo->prepare('SELECT 1 FROM sys.databases WHERE name = ?');
+                        $stmt->execute([$dbParams['database']]);
+                        if (! $stmt->fetchColumn()) {
+                            $pdo->exec('CREATE DATABASE [' . str_replace(']', ']]', $dbParams['database']) . ']');
+                        }
+                    }
+                } catch (Throwable $e) {
+                    // Ignore any error and let the connection fail naturally
+                }
+            }
+        }
+
+        $config['tests'] = $dbParams;
 
         return $config;
     }