Laravel 8：实现用户登录后动态切换数据库连接

<?php

return [
    'default' => env('DB_CONNECTION', 'mysql'), // 默认连接

    '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', ''),
            'charset' => 'utf8mb4',
            'collation' => 'utf8mb4_unicode_ci',
            'prefix' => '',
            'strict' => true,
            'engine' => null,
        ],
        // 可以在这里定义其他静态连接，例如 'tenant_template_db'
        'tenant_template_db' => [
            'driver' => 'mysql',
            'host' => '127.0.0.1',
            'port' => '3306',
            'database' => 'tenant_template',
            'username' => 'root',
            'password' => '',
            'charset' => 'utf8mb4',
            'collation' => 'utf8mb4_unicode_ci',
            'prefix' => '',
            'strict' => true,
            'engine' => null,
        ],
    ],
    // ... 其他配置
];

use Illuminate\Support\Facades\DB;

// 从 'tenant_template_db' 连接中查询数据
$users = DB::connection('tenant_template_db')->table('users')->get();

<?php

namespace App\Http\Middleware;

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

class SetTenantDatabase
{
    /**
     * 处理传入请求。
     *
     * @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)
    {
        // 确保用户已登录
        if (Auth::check()) {
            $user = Auth::user();

            // 假设用户模型中包含了 tenant_id，并通过 tenant_id 获取租户数据库信息
            // 实际应用中，您可能需要从主数据库查询 Tenant 模型来获取这些信息
            $tenant = $user->tenant; // 假设 user 模型与 tenant 模型有关系

            if ($tenant && $tenant->db_name) {
                // 构建租户数据库连接配置
                $tenantDbConfig = [
                    'driver' => 'mysql',
                    'host' => $tenant->db_host ?? env('DB_HOST', '127.0.0.1'), // 允许租户有独立主机
                    'port' => env('DB_PORT', '3306'),
                    'database' => $tenant->db_name,
                    'username' => $tenant->db_username,
                    'password' => $tenant->db_password,
                    'charset' => 'utf8mb4',
                    'collation' => 'utf8mb4_unicode_ci',
                    'prefix' => '',
                    'strict' => true,
                    'engine' => null,
                ];

                // 动态添加一个新的数据库连接配置，命名为 'tenant'
                config(['database.connections.tenant' => $tenantDbConfig]);

                // 将 'tenant' 连接设置为应用程序的默认连接
                config(['database.default' => 'tenant']);

                // 可选：如果需要确保连接立即生效，可以重新连接
                // DB::reconnect('tenant');
            }
        }

        return $next($request);
    }
}

// app/Http/Kernel.php

protected $middlewareGroups = [
    'web' => [
        // ... 其他中间件
        \App\Http\Middleware\SetTenantDatabase::class, // 在这里添加
    ],
    'api' => [
        // ... 其他中间件
        \App\Http\Middleware\SetTenantDatabase::class, // 或者在这里添加
    ],
];

// App\Models\Product.php (未指定 $connection 属性)
namespace App\Models;

use Illuminate\Database\Eloquent\Factories\HasFactory;
use Illuminate\Database\Eloquent\Model;

class Product extends Model
{
    use HasFactory;
    // 此模型将自动使用当前默认连接 (即租户连接)
}

// 在控制器中
use App\Models\Product;

public function index()
{
    // 这将从当前租户的数据库中获取产品
    $products = Product::all();
    return view('products.index', compact('products'));
}

// 访问主数据库的场景 (例如管理用户)
use Illuminate\Support\Facades\DB;

public function showMasterUsers()
{
    // 显式指定 'mysql' 连接来访问主数据库
    $masterUsers = DB::connection('mysql')->table('users')->get();
    return view('admin.master_users', compact('masterUsers'));
}