Laravel中如何按条件手动回滚数据库事务

• 回滚触发不及时：检测到查询结果数小于2时，仅标记状态没有立刻终止流程，后续循环、插入逻辑仍会全部执行，产生大量无效数据库操作，极端场景下还可能因为后续逻辑修改$status变量导致回滚逻辑失效。
• 异常捕获不全：仅捕获\PDOException，Laravel数据库操作抛出的框架封装异常（如QueryException）、PHP运行错误都不会被捕获，会导致事务无法正常回滚，持续占用数据库连接。
• 不必要的性能损耗：count($request->name)写在for循环判断条件中，每次循环都会重新计算数组长度，属于冗余操作。
• 缺少错误反馈：回滚后没有明确的业务状态返回，调用方无法区分操作成功、结果数不足回滚、数据库异常回滚三种场景。

手动事务版本 #

逻辑更直观，适合需要精细控制流程的场景：

try {
    \DB::beginTransaction();
    $total = count($request->name);

    for ($i = 0; $i < $total; $i++) {
        // 写入Test表记录
        Test::create([
            'id' => $id,
            'name' => $request->name[$i]
        ]);

        // 查询对应有效题目
        $results = Questions::where('active', 'yes')
            ->offset($request->number[$i])
            ->limit($request->range[$i])
            ->get();

        // 结果数不符合要求立刻回滚，终止后续流程
        if ($results->count() < 2) {
            \DB::rollBack();
            return back()->with('error', '第' . ($i + 1) . '组匹配的有效题目数量不足2个，操作已撤销');
        }

        // 校验通过再写入User表记录
        foreach ($results as $row) {
            User::create([
                'id' => $id,
                'name' => $row->name
            ]);
        }
    }

    // 所有流程校验通过，提交事务
    \DB::commit();
    return redirect()->back()->with('success', '批量操作执行成功');

} catch (\Throwable $e) {
    // 捕获所有异常/错误，存在活跃事务则立刻回滚
    if (\DB::transactionLevel() > 0) {
        \DB::rollBack();
    }
    // 按需记录错误日志
    \Log::error('批量操作失败', ['err' => $e->getMessage()]);
    return back()->with('error', '操作失败：' . $e->getMessage());
}

框架封装事务版本（推荐） #

使用Laravel自带的闭包事务，无需手动管理提交/回滚，闭包内抛出任意异常都会自动触发回滚，代码更简洁不易出错：

try {
    \DB::transaction(function () use ($request, $id) {
        $total = count($request->name);
        for ($i = 0; $i < $total; $i++) {
            Test::create([
                'id' => $id,
                'name' => $request->name[$i]
            ]);

            $results = Questions::where('active', 'yes')
                ->offset($request->number[$i])
                ->limit($request->range[$i])
                ->get();

            if ($results->count() < 2) {
                // 抛出异常即可自动回滚事务
                throw new \Exception('第' . ($i + 1) . '组匹配的有效题目数量不足2个');
            }

            foreach ($results as $row) {
                User::create([
                    'id' => $id,
                    'name' => $row->name
                ]);
            }
        }
    });

    // 执行到此处说明事务已自动提交
    return back()->with('success', '批量操作执行成功');
} catch (\Throwable $e) {
    return back()->with('error', '操作失败：' . $e->getMessage());
}

• 校验不通过时不要等所有循环跑完再回滚，立刻终止流程可以减少无效资源消耗
• 捕获异常要使用\Throwable覆盖PHP7+所有错误和异常，避免漏捕获导致事务悬挂
• 回滚前判断事务层级，避免对已提交/已回滚的事务重复执行回滚操作抛出报错
• 批量插入场景如果数据量较大，可以用insert()代替循环create()减少SQL查询次数，进一步提升性能

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