flask-sqlalchemy操作（基础）

摘要：以下内容介绍了的基础查询语句，下篇文章将介绍其高级查询聚合自关联连接子查询等模型类用户表地址信息关联表商品信息订单表增一对一构建对象添加对象提交事务一对多主表子表子表赋值对象添加提交多对多生成或获取商品对象生成订单对象订单表与商品表关联添加

以下内容介绍了Sqlalchemy的基础查询语句，下篇文章将介绍其高级查询（聚合、自关联、连接、子查询等）

# 用户表
class User(db.Model):
    __tablename__ = "user"
    uid = db.Column(db.String(32), primary_key=True, nullable=False)
    username = db.Column(db.String(20), nullable=True)
    password = db.Column(db.String(128), nullable=True)
    email = db.Column(db.String(30), nullable=True)
    addresses = db.relationship("Address", backref="user")


# 地址信息
class Address(db.Model):
    __tablename__ = "address"
    aid = db.Column(db.String(32), primary_key=True, nullable=False)
    name = db.Column(db.String(32), nullable=True)
    site = db.Column(db.String(100), nullable=True)
    phone = db.Column(db.Integer, nullable=True)
    uid = db.Column(db.String(32), db.ForeignKey("user.uid"))


# 关联表
OrderItem = db.Table(
    "orderitem",
    db.Column("gid", db.String(32), nullable=True),
    db.Column("product_id", db.String(32), db.ForeignKey("product.pid")),
    db.Column("order_id", db.String(32), db.ForeignKey("order.oid"))
)


# 商品信息
class Product(db.Model):
    __tablename__ = "product"
    pid = db.Column(db.String(32), nullable=False, primary_key=True)
    pname = db.Column(db.String(50), nullable=True)
    market_price = db.Column(db.Float, nullable=True)
    shop_price = db.Column(db.Float, nullable=True)
    pimage = db.Column(db.String(200), nullable=True)
    pdate = db.Column(db.Date, nullable=True)
    is_hot = db.Column(db.Integer, nullable=True)
    pdesc = db.Column(db.String(255), nullable=True)
    pflag = db.Column(db.Integer, nullable=True)
    order = db.relationship("Order", secondary=OrderItem)


# 订单表
class Order(db.Model):
    __tablename__ = "order"
    oid = db.Column(db.String(32), nullable=False, primary_key=True)
    count = db.Column(db.Integer, nullable=True)
    subtotal = db.Column(db.Float, nullable=True)
    ordertime = db.Column(db.DateTime, nullable=True)
    flag = db.Column(db.String(10), nullable=True)

order = models.Orders(oid=orderid, ordertime=datetime.now(), total=pcount, uid=pid) # 构建对象
models.db.session.add(order)  # 添加对象
models.db.session.commit()  # 提交事务

p = models.User(uid="122", username="hello", password="123456", email="1@qq.com")  # 主表
c1 = models.Address(aid="1111111111",site="xxxxxxxxxx")  # 子表
c2 = models.Address(aid="2222222222", site="yyyyyyyyyy")  # 子表
p.addresses = [c1, c2]  # 赋值对象
models.db.session.add(p)  # 添加
models.db.session.commit()  # 提交

p = models.Product(pid="1",pname="hello") # 生成或获取商品对象
o = models.Order(oid="1", )   # 生成订单对象
p.order = [o]  # 订单表与商品表关联
models.db.session.add(p)  # 添加
models.db.session.commit() # 提交

models.Product.query.get(pid)  # 根据主键返回一个对象，必须查询主键
models.Product.query.all()  # 返回全部对象
models.Product.query.filter_by(pid=pid).first()  # 返回第一个对象，检索任何值均可
models.Product.query.filter_by(cid="1").limit(4).all()  # 限制返回对象

# 根据用户获取地址
p = models.user.query.get(uid)  # 根据主键返回一个对象，必须查询主键
p.addresses  # 一对多获取对象
# 根据地址获取用户
u = models.Address.query.get(1)
print(u.user)

p = models.Product.query.get(1)  # 正向查询
print(p.order)
o = models.Order.query.get(1)  # 逆向查询
print(o.product)

good = models.Product.query.filter_by(pid=pid).first() # 获取
good.pflag = 6  # 修改
models.db.session.commit() # 提交

u = models.User.query.get(1)
    for i in u.addresses:
        i.name = "Gage"
models.db.session.commit()

o = models.Order.query.get(1)
    for i in o.product:
        i.pname = "Gage"
models.db.session.commit()

add = models.Address.query.filter_by(aid=aid).first() # 获取
models.db.session.delete(add) # 添加
models.db.session.commit() # 提交

# 根据用户删除地址
# cascade="all" 添加此属性会级联删除
# 用户一个用户对应多个地址，因此需要循环遍历，实际开发需使用filter_by 或 filter进行过滤特定删除
u = models.User.query.get(1)
    for i in u.addresses:
        print(i.aid)
models.db.session.delete(i)
models.db.session.commit()
# 根据地址删除用户
a = models.Address.query.get(1)
models.db.session.delete(a.user)
models.db.session.commit()

# 实际开发也是如此，即只删除依赖
# 根据商品删除所依赖的订单
p = models.Product.query.get(1)
o = models.Order.query.get(1)
p.order.remove(o)
models.db.session.commit()
# 根据订单删除所关联的商品
p = models.Product.query.get(1)
o = models.Order.query.get(1)
o.product.remove(p)
models.db.session.commit()