Laravel 9单代码适配多数据库时创建数据库遇方法未定义错误求助

需求背景 #

在Laravel 9中为每家餐厅搭建独立数据库：

• 管理员添加新客户时，自动创建对应数据库、执行迁移并初始化用户
• 用户登录时，验证所属客户并切换到对应数据库，实现单代码适配多租户

此前在原生PHP中实现过多数据库动态连接，但Laravel环境下首次操作，遇到以下报错：

报错信息 #

Call to undefined method Illuminate\Database\PostgresConnection::getConnection()
（触发时机：尝试创建新数据库时）

相关代码 #

private function createDB($dbName)
{
    try {
        $outputLog = '';
        DB::getConnection()->statement("CREATE DATABASE :$dbName", array('schema' => "schema"));
        $this->migrate($outputLog);
    } catch(Exception $e) {
        return $this->response($e->getMessage(), 'error', $outputLog);
    }
    return $this->response('Installation finished', 'success',$outputLog);
}

/// migrate database for new system
private function migrate($outputLog)
{
    try {
        Artisan::call('migrate', ["--force"=> true], $outputLog);
    } catch(Exception $e){
        return $this->response($e->getMessage(), 'error', $outputLog);
    }
    return $this->seed($outputLog);
}
// run seed folder after migration
private function seed($outputLog)
{
    try {
        // Artisan::call('db:seed', ['--force' => true], $outputLog);
        Artisan::call('db:seed', array_filter([
            '--class' => 'Database\\Seeders\\DatabaseSeeder',
            '--force' => true,
        ]));
    } catch(Exception $e) {
        return $this->response($e->getMessage(), 'error', $outputLog);
    }
    return $this->response('Installation finished', 'success', $outputLog);
}

问题分析与修复 #

1. 修复创建数据库的报错 #

报错原因：

• DB::getConnection()已返回数据库连接实例，无需再次调用getConnection()方法
• PostgreSQL的CREATE DATABASE语句不支持参数绑定，原写法的参数绑定逻辑也错误

修改后的createDB方法：

private function createDB($dbName)
{
    try {
        $outputLog = '';
        // 过滤数据库名称，仅保留字母、数字、下划线，防止SQL注入
        $safeDbName = preg_replace('/[^a-zA-Z0-9_]/', '', $dbName);
        // 执行创建数据库语句
        DB::statement("CREATE DATABASE \"$safeDbName\"");
        
        // 临时配置租户数据库连接，用于后续迁移
        Config::set('database.connections.tenant', [
            'driver' => 'pgsql',
            'host' => env('DB_HOST'),
            'port' => env('DB_PORT'),
            'database' => $safeDbName,
            'username' => env('DB_USERNAME'),
            'password' => env('DB_PASSWORD'),
            'charset' => 'utf8',
            'prefix' => '',
            'schema' => 'public',
            'sslmode' => 'prefer',
        ]);
        
        $this->migrate($outputLog, $safeDbName);
    } catch(Exception $e) {
        return $this->response($e->getMessage(), 'error', $outputLog);
    }
    return $this->response('Installation finished', 'success',$outputLog);
}

2. 修改迁移与填充方法，指定租户连接 #

原迁移逻辑默认使用系统默认数据库连接，需修改为指向新创建的租户数据库：

/// migrate database for new system
private function migrate($outputLog, $dbName)
{
    try {
        Artisan::call('migrate', [
            "--force" => true,
            "--database" => "tenant" // 指定使用临时配置的租户连接
        ], $outputLog);
    } catch(Exception $e){
        return $this->response($e->getMessage(), 'error', $outputLog);
    }
    return $this->seed($outputLog, $dbName);
}

// run seed folder after migration
private function seed($outputLog, $dbName)
{
    try {
        Artisan::call('db:seed', array_filter([
            '--class' => 'Database\\Seeders\\DatabaseSeeder',
            '--force' => true,
            "--database" => "tenant" // 指定租户连接
        ]));
    } catch(Exception $e) {
        return $this->response($e->getMessage(), 'error', $outputLog);
    }
    return $this->response('Installation finished', 'success', $outputLog);
}

3. 用户登录时动态切换数据库 #

登录验证通过后，根据用户关联的数据库名称，动态切换系统数据库连接：

public function login(Request $request)
{
    if (Auth::attempt($request->only('email', 'password'))) {
        $user = Auth::user();
        // 假设用户表中存储了所属数据库名称的字段db_name
        $dbName = $user->db_name;
        
        // 配置租户连接
        Config::set('database.connections.tenant', [
            'driver' => 'pgsql',
            'host' => env('DB_HOST'),
            'port' => env('DB_PORT'),
            'database' => $dbName,
            'username' => env('DB_USERNAME'),
            'password' => env('DB_PASSWORD'),
            'charset' => 'utf8',
            'prefix' => '',
            'schema' => 'public',
            'sslmode' => 'prefer',
        ]);
        
        // 清除旧连接缓存，设置默认连接为租户库
        DB::purge('tenant');
        DB::setDefaultConnection('tenant');
        
        return redirect()->intended('/dashboard');
    }
    
    return back()->withErrors(['email' => '登录失败']);
}

4. 中间件全局切换数据库（可选） #

若需所有请求自动适配用户所属数据库，可创建全局中间件：

// 生成中间件：php artisan make:middleware TenantDatabaseMiddleware

public function handle(Request $request, Closure $next)
{
    if (Auth::check()) {
        $user = Auth::user();
        $dbName = $user->db_name;
        
        Config::set('database.connections.tenant', [
            // 同上述租户连接配置
        ]);
        
        DB::purge('tenant');
        DB::setDefaultConnection('tenant');
    }
    
    return $next($request);
}

在app/Http/Kernel.php中将该中间件注册到web组或全局组即可。

内容的提问来源于stack exchange，提问作者Francois Keou