MySQL Laravel DB::transaction事务不会在发生异常时回滚

在使用Laravel框架进行MySQL数据库操作时，我们通常会使用DB类的transaction方法创建事务来保证数据的一致性。在正常情况下，这个方法能够正确地回滚事务，确保数据的可靠性。但是，如果在执行这个方法的过程中发生了异常，MySQL数据库并不会自动回滚事务，而是将它们保留下来，导致数据不一致。本文将介绍有关MySQL Laravel DB::transaction方法不回滚异常的原因，并给出解决方案。

阅读更多：MySQL 教程

问题分析

先来看一段例子代码：

try {
    DB::transaction(function() {
        // 创建一个新用户
         $user = new User();$ user->name = 'John Doe';
         $user->email = 'johndoe@example.com';$ user->save();

        // 创建一个新订单
         $order = new Order();$ order->user_id =  $user->id;$ order->no = '20191023001';
         $order->amount = 100;$ order->save();

        // 抛出一个异常
        throw new Exception();
    });
} catch(Exception  $e) { // 打印异常消息 echo$ e->getMessage();
}

在上面的代码中，我们通过DB::transaction方法将两个操作组合在一个事务中：先创建一个新用户，然后创建一个新订单。最后，我们手动抛出一个异常，以测试事务是否能够自动回滚。理论上，当我们抛出这个异常时，事务应该自动回滚，这样新用户和新订单都不应该被添加到数据库中。

但是，当我们运行这个代码时，就会发现新用户和新订单都被添加到了数据库中。这是因为DB::transaction方法并没有在异常发生时自动回滚事务导致的。

那么，问题出在哪里呢？

在Laravel的源代码中，DB::transaction方法会执行以下步骤：

开始一个新的数据库事务。
执行传递给方法的闭包体。
如果闭包执行过程中没有发生异常，则提交事务。
如果发生异常，则回滚事务。

换句话说，确保事务正常完成就是提交事务，而回滚事务是种情况。

在我们的例子中，当我们抛出异常时，DB::transaction方法无法正常完成，因此并没有回滚事务。

解决方案

那么，在发生异常时如何回滚事务呢？

一个解决方案是通过catch语句中手动触发事务回滚来解决这个问题。在我们的示例代码中，我们可以在catch语句中添加以下代码：

DB::rollBack();

这个语句将回滚最近执行的事务。当我们捕获到异常时，我们就可以手动回滚事务了。所以，我们的新代码将是这样的：

try {
    DB::transaction(function() {
        // 创建一个新用户
         $user = new User();$ user->name = 'John Doe';
         $user->email = 'johndoe@example.com';$ user->save();

        // 创建一个新订单
         $order = new Order();$ order->user_id =  $user->id;$ order->no = '20191023001';
         $order->amount = 100;$ order->save();

        // 抛出一个异常
        throw new Exception();
    });
} catch(Exception  $e) { // 打印异常消息 echo$ e->getMessage();

    // 事务回滚
    DB::rollBack();
}

这样一来，当我们运行这个代码时，我们会看到新用户和新订单都没有被添加到数据库中了。事实上，除了手动回滚事务外，还有其他的解决方案可以让DB::transaction方法在发生异常时自动回滚事务。这里介绍两种主要的方案，它们分别是：

通过重写DB类的transaction方法来确保事务被回滚。
使用Laravel框架提供的try和catch语句。

重写`transaction`方法

通过重写DB类的transaction方法，我们可以在异常发生时自动回滚事务。为了实现这个目的，我们需要依次执行以下步骤：

开始一个新的数据库事务。
执行传递给方法的闭包体。
如果闭包执行过程中没有发生异常，则提交事务。
如果发生异常，则回滚事务，并将异常重新抛出。

使用这种方法的示例代码如下所示：

use Illuminate\Support\Facades\DB;
use Exception;

DB::reconnect();

DB::transaction(function () {
    // 创建一个新用户
     $user = new User();$ user->name = 'John Doe';
     $user->email = 'johndoe@example.com';$ user->save();

    // 创建一个新订单
     $order = new Order();$ order->user_id =  $user->id;$ order->no = '20191023001';
     $order->amount = 100;$ order->save();

    // 抛出一个异常
    throw new Exception();
});

这段代码中，我们使用use语句导入了DB类，并通过DB::reconnect()方法重新连接到数据库以确保连接的可靠性。之后，我们使用DB::transaction方法执行代码。在方法的闭包中，我们创建了一个新用户和一个新订单。最后，我们故意抛出一个异常，以验证事务是否会被回滚。

如果您运行这段代码，您将发现当异常抛出时，事务没有提交，而且新用户和新订单都没有保存到数据库中。

使用`try`和`catch`语句

使用try和catch语句也是一种解决方案。这种方法比较简单，但需要确保异常被捕获。在我们的示例代码中，我们可以这样做：

DB::beginTransaction();

try {
    // 创建一个新用户
     $user = new User();$ user->name = 'John Doe';
     $user->email = 'johndoe@example.com';$ user->save();

    // 创建一个新订单
     $order = new Order();$ order->user_id =  $user->id;$ order->no = '20191023001';
     $order->amount = 100;$ order->save();

    // 抛出一个异常
    throw new Exception();
} catch(Exception  $e) { // 打印异常消息 echo$ e->getMessage();

    // 事务回滚
    DB::rollBack();
}

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

在这个实现中，我们首先使用DB::beginTransaction()方法开始一个新的事务。之后，我们在try语句块中添加了所有需要执行的代码，包括新用户和新订单的创建以及异常的抛出。在catch语句块中，我们打印异常消息，回滚事务并重新抛出异常。在最后，我们提交事务并结束代码。

值得注意的是，我们需要在异常发生时手动回滚事务，因为在try语句块中，使用DB::transaction方法并不能保证事务正确回滚。

总结

Laravel框架的DB::transaction方法在发生异常时不会自动回滚事务，这是因为异常会导致方法无法正常完成，从而无法自动回滚事务。为了解决这个问题，我们可以手动回滚事务，或者使用其他的解决方案，例如重写DB类的transaction方法或使用try和catch语句。无论使用哪种方法，我们都应该确保事务在异常发生时能够正确回滚，以确保数据的一致性和可靠性。