Laravel 8 运行时全局切换数据库连接实现读写分离

// 尝试一：断开当前连接，修改默认连接名，然后重连指定连接
DB::disconnect();
Config::set('database.default', 'mysql_readonly');
DB::reconnect('mysql_readonly');

// 尝试二：修改默认连接名，并清除指定连接
Config::set('database.default', 'mysql_readonly');
DB::purge('mysql_readonly');

// 尝试三：断开当前连接，修改默认连接名，然后获取指定连接实例
DB::disconnect();
Config::set('database.default', 'mysql_readonly');
DB::connection('mysql_readonly');

<?php

namespace App\Http\Middleware;

use Closure;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\Config;
use Illuminate\Support\Facades\DB;

class DatabaseConnectionSwitcher
{
    /**
     * 处理传入请求。
     *
     * @param  \Illuminate\Http\Request  $request
     * @param  \Closure(\Illuminate\Http\Request): (\Symfony\Component\HttpFoundation\Response)  $next
     * @return \Symfony\Component\HttpFoundation\Response
     */
    public function handle(Request $request, Closure $next)
    {
        // 检查请求方法，如果是 GET 请求，则切换到只读数据库
        if ($request->isMethod('GET')) {
            // 1. 获取只读数据库的连接配置
            $readOnlyConfig = config('database.connections.mysql_readonly');

            // 2. 关键步骤：将主数据库（默认连接）的配置替换为只读数据库的配置
            //    这会影响所有后续通过 DB::connection('mysql') 或隐式使用默认连接的操作
            Config::set('database.connections.mysql', $readOnlyConfig);

            // 3. 清除所有已建立的数据库连接实例
            //    这会强制 Laravel 在下一次数据库操作时，根据最新的配置重新建立连接
            DB::purge();
        }
        // 对于非 GET 请求（如 POST, PUT, DELETE 等），
        // 保持使用默认的主数据库连接，无需额外操作，
        // 因为我们只在 GET 请求时修改了 'mysql' 连接的配置。
        // 如果需要，也可以在此处显式地将 'mysql' 配置重置回主库的原始配置。

        return $next($request);
    }
}

'connections' => [
    'mysql' => [ // 这是你的主数据库配置
        'driver' => 'mysql',
        'host' => env('DB_HOST', '127.0.0.1'),
        'port' => env('DB_PORT', '3306'),
        'database' => env('DB_DATABASE', 'forge'),
        'username' => env('DB_USERNAME', 'forge'),
        'password' => env('DB_PASSWORD', ''),
        'unix_socket' => env('DB_SOCKET', ''),
        'charset' => 'utf8mb4',
        'collation' => 'utf8mb4_unicode_ci',
        'prefix' => '',
        'prefix_indexes' => true,
        'strict' => true,
        'engine' => null,
        'options' => extension_loaded('pdo_mysql') ? array_filter([
            PDO::MYSQL_ATTR_SSL_CA => env('MYSQL_ATTR_SSL_CA'),
        ]) : [],
    ],
    'mysql_readonly' => [ // 这是你的只读数据库副本配置
        'driver' => 'mysql',
        'host' => env('DB_READONLY_HOST', '127.0.0.1'), // 使用不同的环境变量或直接配置
        'port' => env('DB_READONLY_PORT', '3306'),
        'database' => env('DB_READONLY_DATABASE', 'forge_readonly'),
        'username' => env('DB_READONLY_USERNAME', 'forge_readonly'),
        'password' => env('DB_READONLY_PASSWORD', ''),
        'unix_socket' => env('DB_READONLY_SOCKET', ''),
        'charset' => 'utf8mb4',
        'collation' => 'utf8mb4_unicode_ci',
        'prefix' => '',
        'prefix_indexes' => true,
        'strict' => true,
        'engine' => null,
        'options' => extension_loaded('pdo_mysql') ? array_filter([
            PDO::MYSQL_ATTR_SSL_CA => env('MYSQL_ATTR_SSL_CA'),
        ]) : [],
    ],
    // ... 其他连接
],