Flask使用SQLAlchemy添加悲观锁和乐观锁

class Item(db.Model):
    id = db.Column(db.Integer, primary_key=True)
    name = db.Column(db.String(50))
    version = db.Column(db.Integer, default=0)

@app.route('/update_item_pessimistic/<int:item_id>', methods=['POST'])
def update_item_pessimistic(item_id):
    item = db.session.query(Item).with_for_update().filter_by(id=item_id).first()
    if item:
        # 执行更新操作
        item.name = 'New Name'
        db.session.commit()
        return 'Item updated successfully with pessimistic lock', 200
    return 'Item not found', 404

@app.route('/update_item_optimistic/<int:item_id>', methods=['POST'])
def update_item_optimistic(item_id):
    item = db.session.query(Item).filter_by(id=item_id).first()
    if item:
        original_version = item.version
        item.name = 'New Name'
        item.version += 1

        try:
            db.session.commit()
            return 'Item updated successfully with optimistic lock', 200
        except SQLAlchemyError:
            db.session.rollback()
            return 'Update failed due to concurrent modification', 409
    return 'Item not found', 404

举例：双11活动，商城里面id=5的商品的库存num=10了，现在我们要基于乐观锁和悲观锁来解决下单过程中，出现的资源抢夺现象，避免出现超卖（商品数量不能为负数）。

乐观锁：
---> begin;  开启事务
---> 先查看库存，记录当前库存 original_num=10
---> 进行下单操作，买6件 
---> 付款
---> 扣除库存 update from goods set num=num-6 where num=original_num and id=5;  # 增加更新条件，判断库存是否还是原来
       如果执行成功，则表示没有人抢，购买成功
---> commit;
       如果执行失败，则表示已经有人先抢购
---> rollback;

悲观锁：
---> begin; 开启事务
---> 先给id=5的数据，加锁 select * from goods where id=5 for update;
---> 进行下单操作，买6件
---> 付款
---> 扣除库存 update from goods set num=num-6 where id=5;
---> 执行成功解锁
---- commit; 提交事务 """