Laravel更改到其他数据库的作业连接

// config/database.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', ''),
            'unix_socket' => env('DB_SOCKET', ''),
            'charset' => 'utf8mb4',
            'collation' => 'utf8mb4_unicode_ci',
            'prefix' => '',
            'strict' => true,
            'engine' => null,
        ],

        'other_db' => [
            'driver' => 'mysql',
            'host' => env('OTHER_DB_HOST', '127.0.0.1'),
            'port' => env('OTHER_DB_PORT', '3306'),
            'database' => env('OTHER_DB_DATABASE', 'other_db'),
            'username' => env('OTHER_DB_USERNAME', 'other_user'),
            'password' => env('OTHER_DB_PASSWORD', ''),
            'charset' => 'utf8mb4',
            'collation' => 'utf8mb4_unicode_ci',
            'prefix' => '',
            'strict' => true,
            'engine' => null,
        ],
    ],
];

// app/Jobs/ExampleJob.php

namespace App\Jobs;

use Illuminate\Bus\Queueable;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Queue\SerializesModels;

class ExampleJob implements ShouldQueue
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;

    public function __construct()
    {
        // ...
    }

    public function handle()
    {
        // 使用其他数据库连接
        $users = DB::connection('other_db')->table('users')->get();
        // ...
    }
}

public function handle()
{
    try {
        $users = DB::connection('other_db')->table('users')->get();
        // ...
    } catch (\Exception $e) {
        \Log::error('Error in ExampleJob: ' . $e->getMessage());
    }
}