
我理解 sqlalchemy 在事务中,update 不会立刻生效,甚至不会立刻发到服务器上,而是等到 commit 才生效。
举个例子:
with Seesion as session: object = session.query(Table).where(key=param).limit(1) cOntent= "这里是业务逻辑计算的值" # 用取到的对象的 ID 进行更新,只有一个线程能更新成功,我理解 Table.update(Table).set(Table.cOntent= content).where(id = object.id) sessoin.commit() 那么问题来了,如果我想知道我 update 操作(或者说是 commit 操作)是否成功(影响了一行)该怎么办呢? 因为可能还有一些后续操作,需要确认更新成功,拿到锁才能继续
1 gamexg 2018-12-26 20:57:02 +08:00 via Android 很长时间没用 python 了, update 返回值应该是实际更新的函数。 |
2 SleipniR 2018-12-27 09:42:41 +08:00 如果 update 或 commit 不成功,会直接抛出异常吧。 拿到锁才能继续是什么意思? |
3 keakon 2018-12-27 09:53:44 +08:00 1. 你这没有乐观锁 2. update 没在事务中 3. ResultProxy.rowcount 是更新的行数 |
4 lolizeppelin 2018-12-27 10:36:14 +08:00 query= session.query(Table).where(key=param).limit(1) with session.begin(): ____query.update({key: value}) ____session.commt() 这样写才是事务 |
5 15399905591 2018-12-27 10:48:00 +08:00 你的问题没描述清楚,你是需要加锁操作,每次只能有一个对象能够更新 Table ? |