Laravel Eloquent事务实现：商品添加异常时回滚关联表操作

嘿，我来帮你搞定这个Laravel事务失效的问题！你遇到的情况很典型——涉及关联模型创建和文件上传时，普通事务没法覆盖文件系统操作，而且Eloquent事务如果写法不对也会不生效，下面给你一步步的解决方案：

一、先排查事务不生效的常见原因 #

• 是不是没用到Laravel推荐的闭包式事务？手动管理beginTransaction()/commit()/rollBack()时很容易漏写回滚逻辑
• 关联模型是不是用了不同的数据库连接？事务是基于数据库连接的，跨连接的操作没法被同一个事务覆盖
• 有没有在事务外提前执行了数据库操作？比如验证后就先存了数据，再开事务，那这部分操作就不在事务范围内

二、正确的事务实现方案（包含关联模型+文件上传） #

因为文件上传不属于数据库事务的管理范围，所以必须在事务失败时手动删除已上传的文件，才能保证完全的原子性。

方案1：闭包式事务（最推荐，自动处理提交/回滚） #

Laravel的闭包事务会自动捕获异常并回滚，不用手动处理提交和回滚，出错概率最低：

use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Storage;

public function store(Request $request)
{
    // 第一步：先做请求验证，把这步放在事务外面，避免无效事务消耗资源
    $validated = $request->validate([
        'name' => 'required|string|max:255',
        'barcode' => 'required|string|unique:item_barcodes',
        'price' => 'required|numeric|min:0',
        'image' => 'required|image|max:2048',
        // 你的其他字段验证规则...
    ]);

    // 初始化文件路径变量，用于后续回滚时删除文件
    $uploadedImagePath = null;

    try {
        DB::transaction(function () use ($request, $validated, &$uploadedImagePath) {
            // 1. 创建主表Item记录
            $item = \App\Models\Item::create([
                'name' => $validated['name'],
                // 其他Item表字段...
            ]);

            // 2. 处理关联表ItemBarcode
            $item->itemBarcode()->create([
                'barcode' => $validated['barcode'],
                // 其他关联字段...
            ]);

            // 3. 处理ItemCategory关联（如果是多对多用attach，一对一/一对多用create）
            $item->itemCategory()->attach($request->input('category_ids'));

            // 4. 处理ItemPrice
            $item->itemPrice()->create([
                'price' => $validated['price'],
                'currency' => 'CNY',
                // 其他价格字段...
            ]);

            // 5. 处理图片上传
            if ($request->hasFile('image')) {
                $uploadedImagePath = $request->file('image')->store('item_images', 'public');
                // 把图片路径更新到Item模型
                $item->update(['image_path' => $uploadedImagePath]);
            }
        });

        // 事务执行成功，跳转或返回响应
        return redirect()->route('items.index')->with('success', '商品创建成功！');
    } catch (\Exception $e) {
        // 事务失败：删除已上传的图片（如果有的话）
        if ($uploadedImagePath && Storage::disk('public')->exists($uploadedImagePath)) {
            Storage::disk('public')->delete($uploadedImagePath);
        }

        // 返回错误信息给前端
        return redirect()->back()->withErrors(['error' => "商品创建失败：{$e->getMessage()}"]);
    }
}

方案2：手动管理事务（适合需要更细粒度控制的场景） #

如果你需要在事务中做一些额外的判断逻辑，可以手动管理事务，但一定要确保任何异常都触发回滚：

use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Storage;

public function store(Request $request)
{
    $validated = $request->validate([/* 你的验证规则 */]);
    $uploadedImagePath = null;

    // 开启事务
    DB::beginTransaction();

    try {
        // 1. 创建Item主记录
        $item = \App\Models\Item::create([
            'name' => $validated['name'],
            // 其他字段...
        ]);

        // 2. 处理所有关联表操作
        $item->itemBarcode()->create($validated['barcode_data']);
        $item->itemPrice()->create($validated['price_data']);
        $item->itemCategory()->sync($request->category_ids);

        // 3. 上传图片
        if ($request->hasFile('image')) {
            $uploadedImagePath = $request->file('image')->store('item_images', 'public');
            $item->update(['image_path' => $uploadedImagePath]);
        }

        // 提交事务
        DB::commit();
        return redirect()->route('items.index')->with('success', '商品创建成功！');
    } catch (\Exception $e) {
        // 回滚所有数据库操作
        DB::rollBack();

        // 删除已上传的文件
        if ($uploadedImagePath && Storage::disk('public')->exists($uploadedImagePath)) {
            Storage::disk('public')->delete($uploadedImagePath);
        }

        return redirect()->back()->withErrors(['error' => "商品创建失败：{$e->getMessage()}"]);
    }
}

三、必须注意的几个关键点 #

• 验证逻辑放在事务外：如果用户输入不合法，根本没必要开启事务，节省数据库资源
• 文件上传的回滚：数据库事务管不了文件系统，所以catch块里一定要手动删除已上传的文件
• 关联模型的操作方式：必须使用$item->关联()->create()/attach()/sync()这类关联方法，它们会自动使用当前事务的数据库连接，确保关联操作在事务范围内
• 捕获所有异常：一定要捕获\Exception或者更具体的数据库异常（比如Illuminate\Database\QueryException），避免漏过任何错误导致事务未回滚
• 模型连接一致性：所有涉及的模型（Item、ItemBarcode等）必须使用同一个数据库连接，否则跨连接的操作无法被事务覆盖

四、验证事务是否生效的小技巧 #

你可以故意制造一个错误来测试，比如在关联表创建时传入一个不存在的字段：

// 在事务里加入错误代码
$item->itemBarcode()->create([
    'non_existent_field' => 'test', // 这个字段在item_barcodes表中不存在，会抛出异常
]);

执行后如果Item主表没有新增记录，上传的图片也被删除了，说明事务已经正常生效啦！

内容的提问来源于stack exchange，提问作者Awar Pulldozer