Peewee未执行MySQL事务，是我的使用方式有误吗？

核心问题分析 #

你遇到的问题本质是异步环境下Peewee的事务上下文没有正确绑定到异步连接，导致atomic()/transaction()没有触发START TRANSACTION，同时多协程操作时因连接管理混乱引发死锁。

解决步骤 #

• 必须使用异步版Peewee适配器
  不能用同步Peewee，要选择对应数据库的异步实现，比如PostgreSQL用AsyncPostgresqlDatabase，SQLite用AsyncSqliteDatabase：

  from playhouse.async_postgres import AsyncPostgresqlDatabase
  
  db = AsyncPostgresqlDatabase(
      'your_db_name',
      user='db_user',
      password='db_pass',
      host='localhost'
  )
  

• 使用异步事务上下文管理器
  异步环境下必须用async with语法调用db.atomic()，它会自动处理连接获取、事务开启（执行START TRANSACTION）、提交/回滚及连接归还：

  async def process_transaction():
      async with db.atomic():
          # 执行多表操作，示例：
          await User.create(username="alex")
          await Order.create(user_id=1, total=99.9)
          # 无需手动rollback，异常时上下文管理器自动回滚
  

• 消除死锁的关键规则

  • 所有事务操作表的顺序必须统一：比如所有修改都先操作User表，再操作Order表，避免交叉锁导致死锁。
  • 配置事务超时：在数据库连接参数中设置超时，比如PostgreSQL添加options='-c statement_timeout=10000'（10秒超时），防止事务长期占用资源。
  • 避免不必要的事务嵌套：仅在需要保存点时嵌套atomic()，否则会增加锁冲突概率。

• 验证事务执行状态
  开启SQL日志确认START TRANSACTION是否触发：

  import logging
  logging.basicConfig(level=logging.DEBUG)
  db.set_logging_level(logging.DEBUG)
  

  执行事务后，日志中应能看到START TRANSACTION、COMMIT或ROLLBACK的SQL语句。

错误写法修正 #

你之前的同步风格写法在异步环境下完全不适用，手动调用transaction.rollback()是冗余操作，异步上下文管理器会自动处理异常回滚逻辑。

常见误区规避 #

• 禁止混用同步/异步API：比如用同步db.execute_sql()代替异步await db.execute_sql()，会导致连接池混乱。
• 不要在协程间共享连接：异步Peewee的连接池会自动为每个协程分配独立连接，手动共享连接必然引发锁问题。

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