【Laravel】ロック用のテーブルでテーブルロックする方法！

use Illuminate\Database\Migrations\Migration;
use Illuminate\Database\Schema\Blueprint;
use Illuminate\Support\Facades\Schema;
use Illuminate\Support\Facades\DB;

return new class extends Migration {
    public function up(): void
    {
        Schema::create('process_locks', function (Blueprint $table) {
            $table->id();
            $table->string('name')->unique();
            $table->timestamps();
        });

        // 初期データを挿入
        DB::table('process_locks')->insert([
            ['name' => 'user_balance_update', 'created_at' => now(), 'updated_at' => now()],
            ['name' => 'order_processing', 'created_at' => now(), 'updated_at' => now()],
            // 他の処理があれば追加
        ]);
    }

    public function down(): void
    {
        Schema::dropIfExists('process_locks');
    }
};

DB::beginTransaction();

try {
    DB::statement("SET LOCAL idle_in_transaction_session_timeout = '30s'");

    // 処理ごとのロック
    $lock = DB::table('process_locks')
        ->where('name', 'user_balance_update')
        ->lockForUpdate()
        ->first();

    // ロックが取れたら安全に処理
    DB::table('users')
        ->where('id', 1)
        ->update([
            'balance' => DB::raw('balance + 100'),
            'updated_at' => now(),
        ]);

    DB::commit();

} catch (Throwable $e) {
    if (DB::transactionLevel() > 0) {
        DB::rollBack();
    }
    throw $e;
}