Hyperf 3.1 的 saveAll 默认不启用事务，需手动用 DB::transaction 包裹以实现失败整体回滚；支持保存点实现局部回滚；须避免协程连接共享、模型事件异常泄露等问题，并建议前置校验提升健壮性。
Hyperf 3.1 的 ORM（基于 hyperf/database，底层是 illuminate/database）在使用 saveAll 批量保存时，默认不开启事务，也不会自动回滚。如果其中某条记录因唯一约束、字段校验、类型错误等失败，已成功插入/更新的前几条数据会留在数据库中，造成数据不一致——这正是你需要控制的关键点。
要实现“部分失败时整体回滚”，必须显式启用事务，并合理处理异常。以下是具体、可落地的方案：
明确用事务包裹 saveAll 调用
saveAll 本身只是循环调用模型的 save()，它不感知事务上下文。你需手动用 DB::transaction() 包裹整个操作：
use Hyperf\Database\DB;
try {
DB::transaction(function () use ($models) {
foreach ($models as $model) {
$model->save(); // 或 $model->forceFill([...])->save()
}
});
} catch (\Throwable $e) {
// 任一 save() 抛出异常（如 PDOException、ValidationException），整个事务自动回滚
throw $e;
}✅ 优势：简洁、符合 Laravel/Hyperf 习惯，利用了框架对
PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION的默认设置。
⚠️ 注意：确保模型未禁用异常模式；若自定义了$casts或mutators，异常可能提前抛出（如类型转换失败），同样触发回滚。
需要更细粒度控制？用保存点（Savepoint）做局部回滚
比如：批量保存 10 条订单，第 5 条因库存不足失败，但你想保留前 4 条有效订单，只回滚第 5 条及之后的操作——这时要用数据库保存点：
DB::transaction(function () use ($models) {
foreach ($models as $index => $model) {
$spName = "sp_{$index}";
DB::statement("SAVEPOINT {$spName}");
try {
$model->save();
} catch (\Throwable $e) {
// 回滚到当前保存点，不影响前面已成功保存的记录
DB::statement("ROLLBACK TO SAVEPOINT {$spName}");
// 可记录该条失败原因，继续下一条
Log::warning("Model save failed at index {$index}", ['error' => $e->getMessage()]);
continue;
}
}
});✅ 适用场景：允许“尽力而为”式写入，失败项可跳过，不中断整体流程。
⚠️ 注意：MySQL 8.0+、PostgreSQL 支持保存点；SQLite 支持有限；务必测试目标数据库兼容性。
避免常见失效陷阱
-
不要在协程内跨协程共享连接：Hyperf 是协程环境，
DB::connection()默认绑定当前协程。若你在go()中调用saveAll，子协程会拿新连接，事务失效。必须确保所有操作在同一协程内完成。 -
模型事件中勿抛出未捕获异常：若在
creating或saving事件里抛异常，且未被事务块捕获，会导致回滚失败。建议事件中只做校验，失败时return false（由 ORM 中断保存），或统一在事务外预校验。 -
批量插入慎用 insert() 替代 saveAll()：
insert()不触发模型事件和强制类型转换，性能高但绕过业务逻辑。如需完整 ORM 行为（如自动时间戳、属性填充），坚持用saveAll+ 事务。
补充：验证失败原因比盲目回滚更重要
实际项目中，约 70% 的 saveAll 失败源于：
- 数据库字段长度超限（如
varchar(20)存了 25 字符） -
NOT NULL字段传了null - 唯一键冲突（重复手机号、订单号）
- 时间格式非法（
datetime字段传了'2026-13-01'）
建议在 saveAll 前加一层轻量校验：
foreach ($models as $model) {
$validator = \Hyperf\Validation\Contract\ValidatorFactoryInterface::make(
$model->getAttributes(),
$model->rules() // 假设模型定义了 rules()
);
if ($validator->fails()) {
throw new \InvalidArgumentException('Validation failed: ' . json_encode($validator->errors()));
}
}这样能在进入事务前暴露问题，避免无谓的数据库交互和锁等待。
不复杂但容易忽略。
