Hyperf数据库事务怎么管理_Hyperf事务提交和回滚说明【技巧】

4次阅读

hyperf 中事务管理推荐使用 db::transaction() 自动处理提交与回滚,所有操作须在闭包内完成且不可跨协程;手动事务需 try-catch 保障完整性;默认隔离级别为 repeatable read,注意避免耗时操作与跨协程事务。

Hyperf数据库事务怎么管理_Hyperf事务提交和回滚说明【技巧】

Hyperf 中事务管理主要通过 Db::transaction() 方法实现,它会自动处理提交和回滚,无需手动调用 commit()rollback() —— 只要闭包内无异常,就自动提交;一旦抛出异常(包括 throw new Exception 或未捕获的错误),框架会自动回滚。

使用 Db::transaction() 包裹业务逻辑

这是最推荐、最安全的方式。所有数据库操作必须在闭包内完成,且不能跨协程或异步任务执行。

  • 事务内所有查询、插入、更新、删除都共享同一个 pdo 连接和事务上下文
  • 若闭包中调用其他 service 方法,需确保这些方法不主动开启新连接或事务(避免嵌套事务失效)
  • 示例:

use HyperfDbConnectionDb;  $result = Db::transaction(function () {     $user = User::create(['name' => 'Alice']);     $profile = Profile::create(['user_id' => $user->id, 'bio' => 'Hello']);          // 若此处抛异常,上面两条记录都会回滚     if (empty($user) || empty($profile)) {         throw new RuntimeException('创建失败');     }          return ['user_id' => $user->id, 'profile_id' => $profile->id]; });

手动控制事务(不推荐,仅特殊场景)

当需要更精细控制(如部分回滚、保存点)时,可手动调用 Db::beginTransaction()Db::commit()Db::rollback()。但要注意:必须成对出现,且不能遗漏异常捕获。

  • 务必用 try-catch 包裹,确保无论成功失败都能释放连接
  • 手动事务不支持超时自动回滚,需自行保障逻辑健壮性
  • 示例:

Db::beginTransaction(); try {     User::create(['name' => 'Bob']);     Profile::create(['user_id' => 100, 'bio' => 'Hi']);     Db::commit(); } catch (Throwable $e) {     Db::rollback();     throw $e; }

事务中的查询也受隔离级别约束

Hyperf 默认使用 mysqlREPEATABLE READ 隔离级别(取决于数据库配置)。这意味着:

  • 事务内多次 select 同一数据,结果一致(不会看到其他事务已提交的变更)
  • 若需读取最新数据,可用 SELECT ... for UPDATESELECT ... LOCK IN SHARE MODE 加锁
  • 注意:Eloquent 的 find()first() 等默认不加锁,如需强一致性请显式加锁

常见陷阱与建议

  • 不要在事务中调用 http 请求、redis 操作或耗时任务——会延长事务持有时间,增加死锁风险
  • 避免在事务内做条件判断后决定是否继续(如先查再删),应尽量用原子 SQL(如 delete WHERE EXISTS)代替
  • 协程环境下,每个协程有独立的数据库连接,事务不会跨协程传播,勿在 go() 内开启事务后等待其他协程结果
  • 单元测试中启用事务时,记得在 tearDown() 中清理或使用 @beforeTransaction 注解重置状态

text=ZqhQzanResources