for update

SQLAlchemy 的 Query 支持 select … for update / share

1
2
session.Query(User).with_for_update().first()
session.Query(User).with_for_update(read=True).first()

完整形式

1
with_for_update(read=False, nowait=False, of=None)

  • read

    是标识加互斥锁还是共享锁. 当为 True 时, 即 for share 的语句, 是共享锁. 多个事务可以获取共享锁, 互斥锁只能一个事务获取.
    有”多个地方”都希望是”这段时间我获取的数据不能被修改, 我也不会改”, 那么只能使用共享锁.

  • nowait

    其它事务碰到锁, 是否不等待直接”报错”.

  • of

    指明上锁的表, 如果不指明, 则查询中涉及的所有表(行)都会加锁.

扩展

with_for_update实际对应mysql的 SELECT ... FOR UPDATE 语句, 但是在使用时要注意, 由于InnoDB 预设是Row-Level
Lock，所以只有「明确」的指定主键或者其他索引的键，MySQL 才会执行Row lock (只锁住被选取的数据) ，否则mysql 将会执行Table
Lock (将整个数据表单给锁住)。