Laravel事務詳解

來源：千鋒教育

發布人：xqq

時間： 2023-11-21 15:42:41 1700552561

Laravel是一個流行的PHP框架，它具有強大而豐富的數據庫操作功能。這些數據庫操作功能包括查詢構建器和ORM（對象關系映射器），同時也包含了事務操作。在Laravel中，通過一系列的方法調用，可以輕松地開啟、提交和回滾數據庫事務。本文將詳細介紹Laravel事務相關的知識點，從理論到實踐，包涵代碼示例，力求讓大家深入理解Laravel事務的使用方法及其重要性。

一、事務概述

數據庫事務是一組數據庫操作，被看作是一個單一的工作單元，并且這些操作要么全部執行成功要么全部回滾。對于需要在多個數據庫表中進行操作的復雜業務流程，使用數據庫事務可以保證業務的數據一致性。

Laravel的數據庫事務提供了一種簡單、方便的方法來實現這種原子性，可以保證在一系列數據庫操作失敗的情況下回滾到初始狀態，以避免產生臟數據。

二、事務的使用方法

在Laravel中，開啟事務需要使用DB類的beginTransaction()方法，提交事務使用commit()方法，回滾事務使用rollback()方法。下面是一個基本的事務操作示例：


DB::beginTransaction();

try {
    // 數據庫操作1
    // 數據庫操作2
    // ...
    DB::commit();
} catch (\Exception $e) {
    DB::rollback();
    throw $e;
}

beginTransaction()方法用來啟動事務；

try塊用來包含需要執行的數據庫操作；

commit()方法用來提交事務；

catch塊用來處理數據庫操作中異常情況，并通過rollback()方法回到事務初始狀態。

需要注意的是，Laravel中只有在包含在事務操作中的數據庫操作才能受到事務的保護。如果在事務之外執行數據庫操作，那么這些操作是不會受到事務的影響。

三、事務的性質

Laravel中的事務操作具有ACID特性（原子性、一致性、隔離性和持久性），它們將保證數據操作過程中的一系列問題引起的異常狀態。

原子性

事務中的所有操作將視為一個原子單元，要么全部執行成功要么全部失敗。如果在任何時候發生錯誤，所有操作都將回滾到事務的開始狀態。這種特性保證了事務中的所有操作是不可分割和原子性的。

一致性

事務的執行不會使數據庫處于不一致的狀態。在執行事務時，它們將遵循數據庫模式的完整性約束。

隔離性

事務的隔離性指的是如果多個事務并發執行，那么每一個事務對于其他事務執行的數據操作是不可見的。這種策略確保了并發訪問時數據的一致性，避免了鎖等待。

持久性

一旦事務成功提交，它所做的更改將永久保存在數據庫中，并且即使在系統崩潰的情況下也是如此。

四、代碼示例

下面是一個實際的數據庫事務案例，演示了如何使用Laravel中的事務處理來確保用戶在存款和提款操作中擁有足夠的余額。


public function transfer(Request $request)
{
    // 獲取當前用戶
    $user = Auth::user();

    // 獲取轉出賬號和轉入賬號
    $sender_account = $request->input('sender_account');
    $receiver_account = $request->input('receiver_account');

    // 獲取余額，并計算轉出金額
    $balance = $user->balance;
    $amount = $request->input('amount');
    $balance_after_transfer = $balance - $amount;

    // 檢查余額是否充足
    if ($balance_after_transfer < 0) {
        return response()->json([
            'message' => '您的余額不足'
        ], 400);
    }

    //開始事務
    DB::beginTransaction();

    try {
        // 計算轉出賬號余額，并插入轉賬記錄
        $sender_balance = DB::table('accounts')->where('account_number', $sender_account)->lockForUpdate()->value('balance');
        $sender_balance_after_transfer = $sender_balance - $amount;

        DB::table('accounts')->where('account_number', $sender_account)->update([
            'balance' => $sender_balance_after_transfer
        ]);

        DB::table('transactions')->insert([
            'account_number' => $sender_account,
            'type' => 'OUT',
            'amount' => $amount,
            'created_at' => Carbon::now()
        ]);

        // 計算轉入賬號余額，并插入轉入記錄
        $receiver_balance = DB::table('accounts')->where('account_number', $receiver_account)->lockForUpdate()->value('balance');
        $receiver_balance_after_transfer = $receiver_balance + $amount;

        DB::table('accounts')->where('account_number', $receiver_account)->update([
            'balance' => $receiver_balance_after_transfer
        ]);

        DB::table('transactions')->insert([
            'account_number' => $receiver_account,
            'type' => 'IN',
            'amount' => $amount,
            'created_at' => Carbon::now()
        ]);

        // 更新用戶余額
        $user->balance = $balance_after_transfer;
        $user->save();

        //提交事務
        DB::commit();

        return response()->json([
            'message' => '轉賬成功'
        ]);
    } catch (\Exception $e) {
        // 回滾事務
        DB::rollback();

        return response()->json([
            'message' => '服務器錯誤：' . $e->getMessage()
        ], 500);
    }
}