【Laravel】複数のデータベースを簡単に管理する方法を解説

# デフォルトのデータベース接続
DB_CONNECTION=mysql
DB_HOST=127.0.0.1
DB_PORT=3306
DB_DATABASE=main_database
DB_USERNAME=root
DB_PASSWORD=secret

# ログ用データベース接続
LOG_DB_CONNECTION=mysql
LOG_DB_HOST=127.0.0.1
LOG_DB_PORT=3306
LOG_DB_DATABASE=log_database
LOG_DB_USERNAME=root
LOG_DB_PASSWORD=secret

'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,
    ],

    // ログ用データベース接続
    'log_mysql' => [
        'driver' => 'mysql',
        'host' => env('LOG_DB_HOST', '127.0.0.1'),
        'port' => env('LOG_DB_PORT', '3306'),
        'database' => env('LOG_DB_DATABASE', 'forge'),
        'username' => env('LOG_DB_USERNAME', 'forge'),
        'password' => env('LOG_DB_PASSWORD', ''),
        'unix_socket' => env('DB_SOCKET', ''),
        'charset' => 'utf8mb4',
        'collation' => 'utf8mb4_unicode_ci',
        'prefix' => '',
        'strict' => true,
        'engine' => null,
    ],
],

php artisan config:cache

use Illuminate\Support\Facades\DB;

// デフォルトデータベースからデータを取得
$users = DB::connection('mysql')->table('users')->get();

// ログ用データベースからデータを取得
$logs = DB::connection('log_mysql')->table('logs')->get();

// デフォルトデータベースにユーザーを追加
DB::connection('mysql')->table('users')->insert([
    'name' => 'John Doe',
    'email' => 'john@example.com',
    'created_at' => now(),
    'updated_at' => now(),
]);

// ログデータベースにログを追加
DB::connection('log_mysql')->table('logs')->insert([
    'event' => 'User Created',
    'user_id' => 1,
    'created_at' => now(),
]);

try {
    DB::connection('mysql')->beginTransaction();
    DB::connection('log_mysql')->beginTransaction();

    // デフォルトデータベースへの操作
    DB::connection('mysql')->table('users')->update(['status' => 'active']);

    // ログデータベースへの操作
    DB::connection('log_mysql')->table('logs')->insert([
        'event' => 'User Status Updated',
        'created_at' => now(),
    ]);

    // トランザクションのコミット
    DB::connection('mysql')->commit();
    DB::connection('log_mysql')->commit();

} catch (\Exception $e) {
    // ロールバック
    DB::connection('mysql')->rollBack();
    DB::connection('log_mysql')->rollBack();

    // エラー処理
    throw $e;
}

namespace App\Models;

use Illuminate\Database\Eloquent\Model;

class User extends Model
{
    protected $connection = 'mysql'; // デフォルトデータベース
    protected $table = 'users';      // テーブル名
}

class Log extends Model
{
    protected $connection = 'log_mysql'; // ログ用データベース
    protected $table = 'logs';           // テーブル名
}

// デフォルトデータベースからユーザーを取得
$users = User::all();

// ログ用データベースからログを取得
$logs = Log::where('event', 'User Created')->get();

// 新しいユーザーを保存
$user = new User();
$user->name = 'Jane Doe';
$user->email = 'jane@example.com';
$user->save();

// 新しいログを保存
$log = new Log();
$log->event = 'User Registered';
$log->user_id = $user->id;
$log->save();

class User extends Model
{
    protected $connection = 'mysql';

    // ログを取得するカスタムメソッド
    public function logs()
    {
        return Log::where('user_id', $this->id)->get();
    }
}

class Log extends Model
{
    protected $connection = 'log_mysql';
}

$user = User::find(1); // ユーザーを取得
$logs = $user->logs(); // ユーザーのログを取得

use Illuminate\Support\Facades\DB;

try {
    DB::connection('mysql')->beginTransaction();
    DB::connection('log_mysql')->beginTransaction();

    // ユーザーの作成
    $user = User::create([
        'name' => 'John Doe',
        'email' => 'john@example.com',
    ]);

    // ログの作成
    $log = Log::create([
        'event' => 'User Created',
        'user_id' => $user->id,
    ]);

    // トランザクションをコミット
    DB::connection('mysql')->commit();
    DB::connection('log_mysql')->commit();

} catch (\Exception $e) {
    // エラー時にロールバック
    DB::connection('mysql')->rollBack();
    DB::connection('log_mysql')->rollBack();

    throw $e;
}

php artisan migrate --database=log_mysql

mkdir -p database/migrations/main
mkdir -p database/migrations/log

php artisan migrate --database=mysql --path=database/migrations/main
php artisan migrate --database=log_mysql --path=database/migrations/log