Flask-sqlalchemy增删改查之（更改数据）

Flask-sqlalchemy增删改查之（更改数据）

更新数据有两种方式

1. 先查询, 再更新：对应SQL中的 先select, 再update
2. 基于过滤条件的更新：对应SQL中的 update xx where xx = xx (也称为 update子查询 )

1.先查询, 再更新
这种方式简单易懂, 操作步骤如下:

1. 执行查询语句, 获取目标模型对象
2. 对模型对象的属性进行赋值 (更新数据)
3. 提交会话

代码示例：

from flask import Flask
from flask_sqlalchemy import SQLAlchemy

app = Flask(__name__)

# 相关配置
app.config['SQLALCHEMY_DATABASE_URI'] = 'mysql://root:mysql@127.0.0.1:3306/test'
app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = False
app.config['SQLALCHEMY_ECHO'] = True

# 创建组件对象
db = SQLAlchemy(app)


# 构建模型类  商品表
class Goods(db.Model):
    __tablename__ = 't_good'  # 设置表名
    id = db.Column(db.Integer, primary_key=True)  # 设置主键
    name = db.Column(db.String(20), unique=True)  # 商品名称
    count = db.Column(db.Integer)  # 剩余数量


@app.route('/')
def purchase():
    """购买商品"""

    # 更新方式1: 先查询后更新
    # 缺点: 并发情况下, 容易出现更新丢失问题 (Lost Update)

    # 1.执行查询语句, 获取目标模型对象
    goods = Goods.query.filter(Goods.name == '方便面').first()
    # 2.对模型对象的属性进行赋值 (更新数据)
    goods.count = goods.count - 1
    # 3.提交会话
    db.session.commit()

    return "index"

if __name__ == '__main__':
    # 删除所有继承自的表
    db.drop_all()
    # 创建所有继承自的表
    db.create_all()

    # 添加一条测试数据
    goods = Goods(name='方便面', count=1)
    db.session.add(goods)
    db.session.commit()
    app.run(debug=True)

这种方式的缺点:

• 查询和更新分两条语句, 效率低
• 如果并发更新, 可能出现更新丢失问题(Lost Update)

2.基于过滤条件的更新

这种方式的优点:

• 一条语句, 被网络IO影响程度低, 执行效率更高
• 查询和更新在一条语句中完成, 单条SQL具有原子性, 不会出现更新丢失问题
• 会对满足过滤条件的所有记录进行更新, 可以实现批量更新处理

操作步骤如下:

• 配合 查询过滤器filter() 和 更新执行器update() 进行数据更新
• 提交会话

代码示例：

from flask import Flask
from flask_sqlalchemy import SQLAlchemy

app = Flask(__name__)

# 相关配置
app.config['SQLALCHEMY_DATABASE_URI'] = 'mysql://root:mysql@127.0.0.1:3306/test'
app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = False
app.config['SQLALCHEMY_ECHO'] = True

# 创建组件对象
db = SQLAlchemy(app)


# 构建模型类  商品表
class Goods(db.Model):
    __tablename__ = 't_good'  
    id = db.Column(db.Integer, primary_key=True)  
    name = db.Column(db.String(20), unique=True)  
    count = db.Column(db.Integer) 


@app.route('/')
def purchase():
    """购买商品"""

    # 更新方式2: update子查询   可以避免更新丢失问题   
    # update t_good set count = count - 1 where name = '方便面';
    Goods.query.filter(Goods.name == '方便面').update({'count': Goods.count - 1})
    # 提交会话
    db.session.commit()
    return "index"

if __name__ == '__main__':
    # 重置数据库数据
    db.drop_all()
    db.create_all()

    # 添加一条测试数据
    goods = Goods(name='方便面', count=1)
    db.session.add(goods)
    db.session.commit()
    app.run(debug=True)