Support localhost:port notation for tests

tests/ReflectorFactory.php

@@ -43,7 +43,7 @@ public static function create(string $cacheDir): QueryReflector
             $ssl = (string) (getenv('DBA_SSL') ?: $_ENV['DBA_SSL'] ?? '');
             $mode = getenv('DBA_MODE') ?: $_ENV['DBA_MODE'];
             $reflector = getenv('DBA_REFLECTOR') ?: $_ENV['DBA_REFLECTOR'];
-            $platform = getenv('DBA_PLATFORM') ?: $_ENV['DBA_PLATFORM'];
+            $platform = getenv('DBA_PLATFORM') ?: $_ENV['DBA_PLATFORM'] ?? '';
         }
 
         // make env vars available to tests, in case non are defined yet
@@ -74,12 +74,18 @@ public static function create(string $cacheDir): QueryReflector
         if (self::MODE_RECORDING === $mode || self::MODE_REPLAY_AND_RECORDING === $mode) {
             $schemaHasher = null;
 
+            $port = null;
+            if (str_contains($host, ':')) {
+                [$host, $port] = explode(':', $host, 2);
+                $port = (int) $port;
+            }
+
             if ('mysqli' === $reflector) {
                 $mysqli = mysqli_init();
                 if (! $mysqli) {
                     throw new \RuntimeException('Unable to init mysqli');
                 }
-                $mysqli->real_connect($host, $user, $password, $dbname, null, null, $ssl ? MYSQLI_CLIENT_SSL : 0);
+                $mysqli->real_connect($host, $user, $password, $dbname, $port, null, $ssl ? MYSQLI_CLIENT_SSL : 0);
                 $reflector = new MysqliQueryReflector($mysqli);
                 $schemaHasher = new SchemaHasherMysql($mysqli);
             } elseif ('pdo-mysql' === $reflector) {
@@ -88,11 +94,13 @@ public static function create(string $cacheDir): QueryReflector
                     $options[PDO::MYSQL_ATTR_SSL_CA] = $ssl;
                     $options[PDO::MYSQL_ATTR_SSL_VERIFY_SERVER_CERT] = false;
                 }
-                $pdo = new PDO(sprintf('mysql:dbname=%s;host=%s', $dbname, $host), $user, $password, $options);
+                $port = $port !== null ? ';port=' . $port : '';
+                $pdo = new PDO(sprintf('mysql:dbname=%s;host=%s', $dbname, $host) . $port, $user, $password, $options);
                 $reflector = new PdoMysqlQueryReflector($pdo);
                 $schemaHasher = new SchemaHasherMysql($pdo);
             } elseif ('pdo-pgsql' === $reflector) {
-                $pdo = new PDO(sprintf('pgsql:dbname=%s;host=%s', $dbname, $host), $user, $password);
+                $port = $port !== null ? ';port=' . $port : '';
+                $pdo = new PDO(sprintf('pgsql:dbname=%s;host=%s', $dbname, $host) . $port, $user, $password);
                 $reflector = new PdoPgSqlQueryReflector($pdo);
             } else {
                 throw new \RuntimeException('Unknown reflector: ' . $reflector);