Laravel 8 运行时动态切换数据库连接：实现读写分离的全局策略

// config/database.php
'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', ''),
        // ... 其他配置
    ],
    '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', ''),
        // ... 其他配置
    ],
    // ...
],

<?php

use Illuminate\Support\Facades\Config;
use Illuminate\Support\Facades\DB;

// 获取只读数据库的完整配置
$readOnlyConfig = Config::get('database.connections.mysql_readonly');

// 将默认的 'mysql' 连接配置替换为只读数据库的配置
Config::set('database.connections.mysql', $readOnlyConfig);

// 清除所有已建立的数据库连接，强制 Laravel 在下次操作时重新建立连接
DB::purge();

// 此时，所有后续使用默认连接（或显式指定 'mysql'）的数据库操作都将指向只读库
// 例如：
// User::all(); // 将从只读库查询

php artisan make:middleware DatabaseSwitcher

<?php

namespace App\Http\Middleware;

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

class DatabaseSwitcher
{
    /**
     * 处理传入请求。
     *
     * @param  \Illuminate\Http\Request  $request
     * @param  \Closure(\Illuminate\Http\Request): (\Illuminate\Http\Response|\Illuminate\Http\RedirectResponse)  $next
     * @return \Illuminate\Http\Response|\Illuminate\Http\RedirectResponse
     */
    public function handle(Request $request, Closure $next)
    {
        // 记录原始的默认连接配置，以便请求结束后恢复
        // 注意：这里获取的是当前生效的 'mysql' 配置，可能是默认主库，也可能是已被其他中间件修改过的
        $originalDefaultConfig = Config::get('database.connections.mysql');

        // 如果是 GET 请求，则切换到只读数据库
        if ($request->isMethod('GET')) {
            $readOnlyConfig = Config::get('database.connections.mysql_readonly');
            Config::set('database.connections.mysql', $readOnlyConfig);
            DB::purge(); // 清除现有连接，强制使用只读配置
        }

        // 处理请求
        $response = $next($request);

        // 在请求处理完毕后，无论之前是否切换，都恢复到原始的默认数据库配置
        // 这样可以确保后续的请求（特别是异步任务、队列等）不会受到影响
        Config::set('database.connections.mysql', $originalDefaultConfig);
        DB::purge(); // 再次清除连接，确保恢复到原始配置

        return $response;
    }
}

// app/Http/Kernel.php

protected $middlewareGroups = [
    'web' => [
        // ... 其他中间件
        \App\Http\Middleware\DatabaseSwitcher::class, // 添加到 web 组
    ],

    'api' => [
        // ... 其他中间件
        // \App\Http\Middleware\DatabaseSwitcher::class, // 如果API也需要，