小编Dao*_*eng的帖子

Flask-SQLAlchemy with_for_update()行锁定

我有一个名为'User'的模型,'User'有'Money'.
有一种情况是多个会话可以读取模型"用户"并同时更新"钱".

会话1应在会话1成功更新后读取"钱"值.
我在更新时试图锁定"用户"行.
这是我的代码.

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')
Run Code Online (Sandbox Code Playgroud)

我打开了两个会话来同时运行这段代码,输出

000000
111111
User:1***125.3-0.1 = 125.2
000000
111111
22222
User:1***125.3-0.1 = 125.2
22222
Run Code Online (Sandbox Code Playgroud)

第2节没有读取更新的值.

我真的想知道问题出在哪里.

python mysql locking flask flask-sqlalchemy

4
推荐指数
2
解决办法
6691
查看次数

标签 统计

flask ×1

flask-sqlalchemy ×1

locking ×1

mysql ×1

python ×1