Laravel Excel使用OnEachRow时数据库错误无法回滚第二张表数据

问题根源 #

OnEachRow默认逐行执行handleRow逻辑，若Agent与Payment的操作未处于同一事务上下文，就会出现单条数据导入失败时，仅Agent操作回滚、Payment操作无法回滚的情况——比如Agent的创建在事务内，而Payment的创建脱离了事务范围，或者每行事务独立导致前序行的Payment已提交。

具体解决方法 #

方法一：全局事务包裹整个导入流程

重写导入类的import方法，用Laravel数据库事务包裹全部导入操作，确保任意行出错时，所有已执行的导入操作全部回滚。适合数据量较小的场景，避免大事务锁表影响性能。

use Maatwebsite\Excel\Concerns\OnEachRow;
use Maatwebsite\Excel\Row;
use Illuminate\Support\Facades\DB;
use Maatwebsite\Excel\Facades\Excel;

class AgentImport implements OnEachRow
{
    public function import(string $filePath)
    {
        // 全局事务包裹整个导入流程
        DB::transaction(function () use ($filePath) {
            Excel::import($this, $filePath);
        });
    }

    public function onEachRow(Row $row)
    {
        $rowData = $row->toArray();
        
        // 创建Agent
        $agent = \App\Models\Agent::create([
            'name' => $rowData['name'],
            'status' => $rowData['status'],
            // 其他字段
        ]);

        // 创建关联Payment
        $agent->payments()->create([
            'amount' => $rowData['amount'],
            // 其他字段
        ]);
    }
}

方法二：单条数据操作包裹事务

若仅需回滚出错行的操作（不影响已成功导入的行），可在onEachRow内将Agent与Payment的创建逻辑放在同一事务中：

public function onEachRow(Row $row)
{
    $rowData = $row->toArray();

    // 单条数据的事务包裹
    DB::transaction(function () use ($rowData) {
        $agent = \App\Models\Agent::create([
            'name' => $rowData['name'],
            'status' => $rowData['status'],
            // 其他字段
        ]);

        $agent->payments()->create([
            'amount' => $rowData['amount'],
            // 其他字段
        ]);
    });
}

方法三：使用模型事务（ORM风格）

利用Laravel模型自带的transaction方法，效果与数据库事务一致，更贴合ORM使用习惯：

public function onEachRow(Row $row)
{
    $rowData = $row->toArray();

    \App\Models\Agent::transaction(function () use ($rowData) {
        $agent = \App\Models\Agent::create([
            'name' => $rowData['name'],
            'status' => $rowData['status'],
            // 其他字段
        ]);

        $agent->payments()->create([
            'amount' => $rowData['amount'],
            // 其他字段
        ]);
    });
}

额外注意事项 #

• 确保数据库引擎支持事务：必须使用InnoDB（MyISAM不支持事务），这是事务生效的基础。
• 分块导入的事务处理：若使用WithChunkReading分块，需注意每个块的事务范围，避免块间事务隔离问题。
• 自定义错误处理：可捕获异常记录错误行信息，按需选择是否中断导入：

public function onEachRow(Row $row)
{
    try {
        DB::transaction(function () use ($row) {
            $rowData = $row->toArray();
            // 业务逻辑
        });
    } catch (\Exception $e) {
        // 记录错误日志
        \Log::error("导入第{$row->getIndex()}行失败: {$e->getMessage()}");
        // 若需中断导入，直接抛出异常
        throw $e;
    }
}

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