我理解 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 ?
|