Flask-SQLAlchemy with_for_update()行锁
问题内容:
我有一个名为“用户”的模型,而“用户”有“钱”。
在这种情况下,多个会话可以读取模型“用户”并同时更新“金钱”。
会话1成功更新后,会话2应读取“ money”值。
我尝试在更新时锁定“用户”行。
这是我的代码。
user = User.query.with_for_update().filter_by(id=userid).first()
print('000000')
before_money = user.money
print('111111')
time.sleep(1)
user.money -= 0.1
print('User:' + str(user.id) + '***' + str(before_money) + '-' + str(0.1) + ' = ' + str(user.money))
time.sleep(1)
db.session.commit()
print('22222')
我打开了两个会话以同时运行此代码,输出
000000
111111
User:1***125.3-0.1 = 125.2
000000
111111
22222
User:1***125.3-0.1 = 125.2
22222
会话2未读取更新后的值。
我真的很想知道问题出在哪里。
问题答案:
经过一整天的努力,我发现了问题。
user = User.query.with_for_update().filter_by(id=userid).first()
应该
result = db.session.query(User.money).with_for_update().filter_by(id=userid).first()
money = result[0]
user.money = money - 0.1
是的,很简单但是很烦