SQLAlchemy事务中查询行为疑惑：为何未读取到未提交更新？

核心原因是你使用了Query.update()这种批量更新方式，它直接生成SQL语句操作数据库，但不会同步SQLAlchemy Session内部的缓存（Identity Map），导致后续查询从缓存读取旧值。

两种更新方式的区别 #

• 对象属性赋值更新：直接修改Session缓存中的对象实例，同一Session内的查询会优先读取缓存的新值，无需提交事务：

  # 对象级更新示例
  user = session.query(User).filter_by(id=1).one()
  user.name = "u2"
  # 无需commit，直接查询即可获取新值
  user = session.query(User).filter_by(id=1).one()
  print(user.name) # 输出"u2"
  

• Query.update()批量更新：这种方式会直接向数据库发送UPDATE语句，但SQLAlchemy无法自动追踪哪些对象被修改，因此不会更新Session缓存中的实例。后续查询会直接从缓存取出之前加载的旧对象，而非从数据库读取最新数据。

解决办法 #

如果必须使用Query.update()，且需要在同一Session中立即看到更新结果，可以通过以下方式处理：

1. 使用populate_existing()跳过缓存：强制查询从数据库读取最新数据，忽略Session缓存：

   session.query(User).filter_by(id=1).update({"name": "u2"})
   # 用populate_existing()绕过缓存
   user = session.query(User).filter_by(id=1).populate_existing().one()
   print(user.name) # 输出"u2"
   

2. 失效Session缓存：让缓存中的所有对象失效，下次查询会重新从数据库加载：

   session.query(User).filter_by(id=1).update({"name": "u2"})
   # 使缓存中所有对象失效
   session.expire_all()
   user = session.query(User).filter_by(id=1).one()
   print(user.name) # 输出"u2"
   

3. 手动刷新指定对象：如果已经持有目标对象实例，可以直接刷新它：

   user = session.query(User).filter_by(id=1).one()
   session.query(User).filter_by(id=1).update({"name": "u2"})
   # 刷新指定对象
   session.refresh(user)
   print(user.name) # 输出"u2"
   

补充说明 #

SQLAlchemy的Session缓存（Identity Map）设计目的是减少重复查询、保证对象一致性。批量更新/删除这类操作因为是直接操作数据库，无法自动关联到缓存中的对象，所以需要开发者手动处理缓存同步。

内容的提问来源于stack exchange，提问作者Ryan M