Laravel事务在PostgreSQL中无法回滚问题求助

环境信息 #

• Laravel: 10.3.3
• PostgreSQL 10.23

示例代码 #

DB::beginTransaction();
try{
    $parent = new Parent($postAttributes);
    if($parent->save()){
        $child = new Child($postAttributes);
        $child->save(); // 此处故意触发异常

       //其他操作
        DB::table('users')->insert([
            'email' => 'kayla@example.com',
            'status' => 1
        ]);
        
    }
}catch(Exception $ex){
    DB::rollback();
}

DB::commit();

问题描述 #

执行上述代码时，Child模型触发异常，但Parent模型仍被保存，事务未回滚。已尝试使用DB::transaction(function () {})方式，问题依旧。期望出现错误时事务能自动回滚。

1. 错误的事务提交逻辑 #

代码将DB::commit()放在了try-catch块外部，无论是否触发异常都会执行。即使catch块执行了回滚，后续的commit()会破坏事务状态，最终导致部分操作被提交。

修正代码结构：

DB::beginTransaction();
try {
    $parent = new Parent($postAttributes);
    if ($parent->save()) {
        $child = new Child($postAttributes);
        $child->save(); // 触发异常

        DB::table('users')->insert([
            'email' => 'kayla@example.com',
            'status' => 1
        ]);
    }

    // 仅当所有操作无异常时才提交事务
    DB::commit();
} catch (\Exception $ex) {
    DB::rollback();
    // 可选：抛出异常用于日志记录或上层处理
    // throw $ex;
}

2. 异常捕获范围错误 #

如果代码位于自定义命名空间（如App\Http\Controllers）中，catch(Exception $ex)只会捕获当前命名空间下的异常类，而Laravel抛出的数据库异常属于全局命名空间的\Exception（或其子类如QueryException），导致catch块无法触发，事务直接提交。

解决办法：
捕获全局命名空间的异常：

catch (\Exception $ex) {
    DB::rollback();
}

或者精准捕获数据库异常：

catch (\Illuminate\Database\QueryException $ex) {
    DB::rollback();
}

3. 多数据库连接冲突 #

如果Parent和Child模型指定了不同的数据库连接（通过模型的$connection属性），DB::beginTransaction()仅针对默认连接开启事务，另一连接的操作不在事务范围内，异常时无法回滚。

解决办法：
确保所有涉及模型使用同一连接，或针对对应连接开启事务：

// 假设使用"pgsql"连接
DB::connection('pgsql')->beginTransaction();
try {
    $parent = new Parent($postAttributes);
    $parent->save();
    $child = new Child($postAttributes);
    $child->save();

    DB::connection('pgsql')->commit();
} catch (\Exception $ex) {
    DB::connection('pgsql')->rollback();
}

4. 闭包事务的正确用法 #

使用DB::transaction()闭包时，无需手动调用commit/rollback，Laravel会自动处理。同时注意传递外部变量：

DB::transaction(function () use ($postAttributes) {
    $parent = new Parent($postAttributes);
    $parent->save();
    
    $child = new Child($postAttributes);
    $child->save(); // 触发异常
    
    DB::table('users')->insert([
        'email' => 'kayla@example.com',
        'status' => 1
    ]);
});

内容的提问来源于stack exchange，提问作者Rafael Fernando Fiedler