MySQL Laravel DB::transaction不会在异常情况下回滚

在Laravel中，当我们使用DB::transaction函数来执行数据库事务时，我们期望在事务中发生任何异常时都会回滚。然而，有时我们会发现这个函数似乎不能如预期般正常工作。在这篇文章中，我们会探讨这个问题的原因和解决方式。

阅读更多：MySQL 教程

问题描述

在一个数据库事务中，如果出现了异常，我们期望所有已执行的SQL语句都会被回滚，即数据库不会留下任何影响。然而，当我们使用DB::transaction函数时，即使出现了异常，SQL语句仍然会被执行，导致我们的数据被错误地更改了。

例如，以下代码片段演示了这个问题：

use Illuminate\Support\Facades\DB;

try {
    DB::transaction(function () {
        DB::table('users')->where('id', 1)->update(['name' => 'new name']);
        throw new \Exception('something went wrong');
    });
} catch (\Exception e) {
    // handle the exception
}user = DB::table('users')->where('id', 1)->first();
echo $user->name; // 输出为 'new name'

在上面的例子中，我们尝试将users表中的ID为1的用户的名称更改为new name。然而，我们在transaction中故意抛出了一个异常，导致事务中止。我们期望看到的结果是数据库没有任何更改，但实际上该用户的名称已被更改了，并且我们的应用已受到破坏。

原因

在深入研究之前，我们需要了解一些关于MySQL事务和Laravel框架的基础知识。

MySQL事务

MySQL数据库引擎支持事务，这意味着我们可以将多个SQL语句组合成一个原子操作。如果所有SQL语句都成功执行，则操作被认为是成功的，并且所有更改都被提交到数据库中。如果任何SQL语句失败，则整个操作将被回滚，并且在数据库中不会有任何更改。

一个事务有以下四个特性（也称为ACID特性）：

原子性（Atomicity）：一个事务中的所有操作要么全部成功，要么全部失败。事务是不可分割的操作单元。
一致性（Consistency）：在一个事务中，数据库从一个一致性状态转换到另一个一致性状态。也就是说，如果事务成功提交，那么数据库应该保持一致性。
隔离性（Isolation）：事务的执行是互相隔离的，即一个事务的操作不应该影响另外一个事务的执行。
持久性（Durability）：一旦事务成功提交，它应该是永久性的，即不能因为系统的故障而丢失。

Laravel框架

Laravel是一个流行的PHP框架，它提供了许多有用的功能，包括数据库事务。在Laravel中，我们可以使用DB::transaction函数来执行数据库操作。在事务中执行的查询将被视为一个原子操作，要么全部成功，要么全部失败。

在Laravel中，DB::transaction函数实际上是使用PHP PDO类中的beginTransaction、commit和rollBack函数来实现的，这些函数可以帮助我们执行MySQL事务。

解决方案

现在我们知道了问题的原因，该如何解决呢？有两种解决方案：

方案一：手动回滚事务

每当我们在DB::transaction函数中遇到异常时，我们可以手动回滚事务，以确保所有已执行的SQL语句都被撤销。

修改上面的示例代码，加入手动回滚事务的代码：

use Illuminate\Support\Facades\DB;

try {
    DB::transaction(function () {
        DB::table('users')->where('id', 1)->update(['name' => 'new name']);
        throw new \Exception('something went wrong');
    });
} catch (\Exception e) {
    // 手动回滚事务
    DB::rollBack();
    // 处理异常
}user = DB::table('users')->where('id', 1)->first();
echo $user->name; // 输出为 'old name'

在上面的代码中，我们添加了DB::rollBack()函数，以回滚事务。现在，即使我们在transaction中抛出异常，事务也会被正确地回滚，不会留下任何影响。

方案二：使用try-catch嵌套

另一个解决方案是使用try-catch嵌套，将外部的try-catch语句用于处理异常，内部的try-catch语句用于回滚事务。

修改示例代码，使用try-catch嵌套：

use Illuminate\Support\Facades\DB;

try {
    DB::transaction(function () {
        try {
            DB::table('users')->where('id', 1)->update(['name' => 'new name']);
            throw new \Exception('something went wrong');
        } catch (\Exception e) {
            // 回滚事务
            DB::rollBack();
            // 重新抛出异常
            throwe;
        }
    });
} catch (\Exception e) {
    // 处理异常
}user = DB::table('users')->where('id', 1)->first();
echo $user->name; // 输出为 'old name'