一、首先要明白flush和commit区别:
> flush: 写数据库,但不提交,也就是事务未结束
> commit: sqlalchemy会自动创建隐私的事务,先调用flush写数据库,然后提交,结束事务,并开始新的事务
二、对db.session.flush进行探索(现有两张表,一主一外)
class OrderInfo(db.Model):
"""订单表"""
__tablename__ = "order_info"
order_id = db.Column(db.String(128), primary_key=True) # 订单id
total_count = db.Column(db.Integer, default=1) # 商品数量
total_price = db.Column(db.Numeric(10, 2)) # 商品总价
transit_price = db.Column(db.Numeric(10, 2)) # 订单运费
class OrderGoods(db.Model):
"""订单商品表"""
__tablename__ = "order_goods"
id = db.Column(db.Integer, primary_key=True)
order = db.Column(db.String(128), db.ForeignKey('order_info.order_id')) # 订单ID
count = db.Column(db.Integer, default=1) # 商品数目
price = db.Column(db.Numeric(10, 2)) # 商品价格
comment = db.Column(db.Text, default='') # 商品评论
- 创建数据order=OrderInfo(order_id='1', total_price=0, transit_price)
- 这时候 order.字段名 是可以查询到属性的,不需要db.session.add(order)和db.session.flush(), 我查资料时有人说不add和flush不能查询到相应字段数据,我这里实操可以。
- 我再创建goods = OrderGoods(order=1, price=1),这时候报错外键约束,原因是找不到order,这时候加上db.session.add(order)和db.session.flush()成功。 说明这里已经写到数据库,我当时对写入数据库有点误解,我以为select * from xxx后可以查到数据,但这里的写入应该理解成在python程序中能够正常调用刚才创建的数据,数据库并无法查询到。
- 这时候我去msyql删除表delete from orer_goods,mysql报错:ERROR 1205 (HY000): Lock wait timeout exceeded; try restarting transaction。 这里的原因是因为:使用db.session.flush()后,mysql事务开始了,但未结束,此时需要手动结束rollback或db.session.commit()。这样一个事务结束。
- 关于mysql这个报错具体还可了解:https://blog.csdn.net/zhaofuqiangmycomm/article/details/82150815
三、db.session.flush()后会不会覆盖:
order=OrderInfo(order_id='1', total_price=0, transit_price)
db.session.add(order)
db.session.flush()
for i in range(5):
if i > 2:
return jsonify({'errmsg': '错误信息'})
# 两次
goods = OrderGoods(order=i, price=i)
db.session.add(goods)
db.session.flush()
try:
db.session.commit()
except Exception as error:
print(error)
db.session.rollback()
return ''
代码从上往下走,创建了一个order,进入for循环后一共flush了两次goods,假设是goods_1和goods_2,那么循环第二次时生成的goods_2是不是会覆盖掉goods_1呢?以至于循环了2次,也只是创建了一个goods,毕竟事务没有提交,没有真正写入数据库。实操发现:并不会覆盖