SQLAlchemy 增删改查 一对多 多对多

一丶创建数据表

11 # ORM中的数据表是什么呢?
2 2 # Object Relation Mapping
3 3 # Object - Table 通过 Object 去操纵数据表
4 4 # 从而引出了我们的第一步创建数据表 - 创建Object
5 5 # 1. 创建Object
6 6 # class User(object):
7 7 #     pass
8 8 
9 9 # 2. 让Object与数据表产生某种关系 也就是让Object与数据表格式极度相似
1010 # 导入官宣基础模型
1111 from sqlalchemy.ext.declarative import declarative_base
1212 # 实例化官宣模型 - Base 就是 ORM 模型
1313 Base = declarative_base()
1414 # 当前的这个Object继承了Base也就是代表了Object继承了ORM的模型
1515 class User(Base):  # 相当于 Django Models中的 Model
1616     # 为Table创建名称
1717     __tablename__ = "user"
1818     # 创建ID数据字段 , 那么ID是不是一个数据列呢? 也就是说创建ID字段 == 创建ID数据列
1919     from sqlalchemy import Column,Integer,String
2020     # id = Column(数据类型,索引,主键,外键,等等)
2121     # int == Integer
2222     id = Column(Integer,primary_key=True,autoincrement=True)
2323     # str == char(长度) == String(长度)
2424     name = Column(String(32),index=True)
2525 
2626 # 3.去数据库中创建数据表? or 先连接数据库?
2727 # 3.去连接数据库 创建数据引擎
2828 from sqlalchemy import create_engine
2929 # 创建的数据库引擎
3030 engine = create_engine("mysql+pymysql://root:@127.0.0.1:3306/dragon?charset=utf8")
3131 
3232 # Base 自动检索所有继承Base的ORM 对象 并且创建所有的数据表
3333 Base.metadata.create_all(engine)

my_create_table

二丶增删改查操作

　　1.增加数据

1 1 #insert 为数据表增加数据
2 2 # insert One 增加一行数据
3 3 # insert into user(name) values ("DragonFire")
4 4 # 在ORM中的操作:
5 5 # 1.首先导入之间做好的ORM 对象 User
6 6 from my_create_table import User
7 7 # 2.使用Users ORM模型创建一条数据
8 8 user1 = User(name="DragonFire")
9 9 # 数据已经创建完了,但是需要写入到数据库中啊,怎么写入呢?
1010 # 3.写入数据库:
1111 # 首先打开数据库会话 , 说白了就是创建了一个操纵数据库的窗口
1212 # 导入 sqlalchemy.orm 中的 sessionmaker
1313 from sqlalchemy.orm import sessionmaker
1414 # 导入之前创建好的 create_engine
1515 from my_create_table import engine
1616 # 创建 sessionmaker 会话对象,将数据库引擎 engine 交给 sessionmaker
1717 Session = sessionmaker(engine)
1818 # 打开会话对象 Session
1919 db_session = Session()
2020 # 在db_session会话中添加一条 UserORM模型创建的数据
2121 db_session.add(user1)
2222 # 使用 db_session 会话提交 , 这里的提交是指将db_session中的所有指令一次性提交
2323 db_session.commit()
2424 
2525 # 当然也你也可很任性的提交多条数据
2626 # 方法一:
2727 user2 = User(name="Dragon")
2828 user3 = User(name="Fire")
2929 db_session.add(user2)
3030 db_session.add(user3)
3131 db_session.commit()
3232 # 之前说过commit是将db_session中的所有指令一次性提交,现在的db_session中至少有两条指令user2和user3
3333 db_session.close()
3434 #关闭会话
3535 
3636 # 如果说你觉得方法一很麻烦,那么方法二一定非常非常适合你
3737 # 方法二:
3838 user_list = [
3939     User(name="Dragon1"),
4040     User(name="Dragon2"),
4141     User(name="Dragon3")
4242 ]
4343 db_session.add_all(user_list)
4444 db_session.commit()
4545 
4646 db_session.close()
4747 
4848 orm_insert

orm_insert

　　2.查询数据

11 # ORM操作查询数据
2 2 # 有了刚才Insert增加数据的经验,那么查询之前的准备工作,就不用再重复了吧
3 3 # 回想一下刚才Insert时我们的操作
4 4 from my_create_table import User, engine
5 5 from sqlalchemy.orm import sessionmaker
6 6 
7 7 Session = sessionmaker(engine)
8 8 db_session = Session()
9 9 
1010 # 1. select * from user 查询user表中的所有数据
1111 # 语法是这样的 使用 db_session 会话 执行User表 query(User) 取出全部数据 all()
1212 user_all_list = db_session.query(User).all()
1313 print(user_all_list)  # [<my_create_table.User object at 0x0000016D7C4BCDD8>]
1414 # 如何查看user_all_list其中的数据呢? 循环呗
1515 for i in user_all_list:
1616     print(i.id, i.name)  # ORM对象 直接使用调用属性的方法 拿出对应字段的值
1717 
1818 db_session.close()
1919 #关闭会话
2020 
2121 # 2. select * from user where id >= 20
2222 # 语法是这样的 使用 db_session 会话 执行User表 query(User) 筛选内容User.id >=20 的数据全部取出 all()
2323 user_all_list = db_session.query(User).filter(User.id >= 20).all()
2424 print(user_all_list)
2525 for i in user_all_list:
2626     print(i.id, i.name)
2727 
2828 db_session.close()
2929 #关闭会话
3030 
3131 # 3. 除了取出全部还可以只取出一条
3232 user = db_session.query(User).filter(User.id >= 20).first()
3333 print(user.id, user.name)
3434 db_session.close()
3535 #关闭会话
3636 
3737 # 4. 乌龙 之 忘了取出数据.......
3838 wulong1 = db_session.query(User).filter(User.id >= 20)
3939 print(wulong1)
4040 #SELECT user.id AS user_id, user.name AS user_name
4141 #FROM user
4242 #WHERE user.id >= %(id_1)s
4343 # Fuck我忘了取出数据了!!!!!!! 哎? wulong1给我显示了原生SQL语句,因祸得福了
4444 wulong2 = db_session.query(User)
4545 print(wulong2)
4646 #SELECT user.id AS user_id, user.name AS user_name
4747 #FROM user
4848 # Fuck我又忘了取出数据了!!!!!!! 哎? wulong2给我显示了原生SQL语句,因祸得福了
4949 db_session.close()
5050 #关闭会话

orm_select

　　3.修改数据

11 # ORM更新数据
2 2 # 无论是更新还是删除,首先要做的事情,就应该是查询吧
3 3 # 根据之前原有的经验,接下来是不是要导入ORM对象了,是不是要创建db_session会话了
4 4 from my_create_table import User,engine
5 5 from sqlalchemy.orm import sessionmaker
6 6 Session = sessionmaker(engine)
7 7 db_session = Session()
8 8 
9 9 # UPDATE user SET name="NBDragon" WHERE id=20 更新一条数据
1010 # 语法是这样的 :
1111 # 使用 db_session 执行User表 query(User) 筛选 User.id = 20 的数据 filter(User.id == 20)
1212 # 将name字段的值改为NBDragon update({"name":"NBDragon"})
1313 res = db_session.query(User).filter(User.id == 20).update({"name":"NBDragon"})
1414 print(res) # 1 res就是我们当前这句更新语句所更新的行数
1515 # 注意注意注意
1616 # 这里一定要将db_session中的执行语句进行提交,因为你这是要对数据中的数据进行操作
1717 # 数据库中 增 改 删 都是操作,也就是说执行以上三种操作的时候一定要commit
1818 db_session.commit()
1919 db_session.close()
2020 #关闭会话
2121 
2222 # 更新多条
2323 res = db_session.query(User).filter(User.id <= 20).update({"name":"NBDragon"})
2424 print(res) # 6 res就是我们当前这句更新语句所更新的行数
2525 db_session.commit()
2626 db_session.close()
2727 #关闭会话

orm_update

　　4.删除数据

11 # ORM 删除一条多条数据
2 2 # 老规矩
3 3 # 导入 ORM 创建会话
4 4 from my_create_table import User,engine
5 5 from sqlalchemy.orm import sessionmaker
6 6 Session = sessionmaker(engine)
7 7 db_session = Session()
8 8 
9 9 # DELETE FROM `user` WHERE id=20
1010 res = db_session.query(User).filter(User.id==20).delete()
1111 print(res)
1212 # 是删除操作吧,没错吧,那你想什么呢?commit吧
1313 db_session.commit()
1414 
1515 db_session.close()
1616 #关闭会话

orm_delete

　　5.高级版查询操作

1# 高级版查询操作,厉害了哦
2#老规矩
3from my_create_table import User,engine
4from sqlalchemy.orm import sessionmaker
5
6Session = sessionmaker(engine)
7db_session = Session()
8
9# 查询数据表操作
10# and or
11from sqlalchemy.sql import and_ , or_
12ret = db_session.query(User).filter(and_(User.id > 3, User.name == 'DragonFire')).all()
13ret = db_session.query(User).filter(or_(User.id < 2, User.name == 'DragonFire')).all()
14
15# 查询所有数据
16r1 = db_session.query(User).all()
17
18# 查询数据 指定查询数据列 加入别名
19r2 = db_session.query(User.name.label('username'), User.id).first()
20print(r2.id,r2.username) # 15 NBDragon
21
22# 表达式筛选条件
23r3 = db_session.query(User).filter(User.name == "DragonFire").all()
24
25# 原生SQL筛选条件
26r4 = db_session.query(User).filter_by(name='DragonFire').all()
27r5 = db_session.query(User).filter_by(name='DragonFire').first()
28
29# 字符串匹配方式筛选条件 并使用 order_by进行排序
30r6 = db_session.query(User).filter(text("id<:value and name=:name")).params(value=224, name='DragonFire').order_by(User.id).all()
31
32#原生SQL查询
33r7 = db_session.query(User).from_statement(text("SELECT * FROM User where name=:name")).params(name='DragonFire').all()
34
35# 筛选查询列
36# query的时候我们不在使用User ORM对象,而是使用User.name来对内容进行选取
37user_list = db_session.query(User.name).all()
38print(user_list)
39for row in user_list:
40    print(row.name)
41
42# 别名映射  name as nick
43user_list = db_session.query(User.name.label("nick")).all()
44print(user_list)
45for row in user_list:
46    print(row.nick) # 这里要写别名了
47
48# 筛选条件格式
49user_list = db_session.query(User).filter(User.name == "DragonFire").all()
50user_list = db_session.query(User).filter(User.name == "DragonFire").first()
51user_list = db_session.query(User).filter_by(name="DragonFire").first()
52for row in user_list:
53    print(row.nick)
54
55# 复杂查询
56from sqlalchemy.sql import text
57user_list = db_session.query(User).filter(text("id<:value and name=:name")).params(value=3,name="DragonFire")
58
59# 查询语句
60from sqlalchemy.sql import text
61user_list = db_session.query(User).filter(text("select * from User id<:value and name=:name")).params(value=3,name="DragonFire")
62
63# 排序 :
64user_list = db_session.query(User).order_by(User.id).all()
65user_list = db_session.query(User).order_by(User.id.desc()).all()
66for row in user_list:
67    print(row.name,row.id)
68
69#其他查询条件
70"""
71ret = session.query(User).filter_by(name='DragonFire').all()
72ret = session.query(User).filter(User.id > 1, User.name == 'DragonFire').all()
73ret = session.query(User).filter(User.id.between(1, 3), User.name == 'DragonFire').all() # between 大于1小于3的
74ret = session.query(User).filter(User.id.in_([1,3,4])).all() # in_([1,3,4]) 只查询id等于1,3,4的
75ret = session.query(User).filter(~User.id.in_([1,3,4])).all() # ~xxxx.in_([1,3,4]) 查询不等于1,3,4的
76ret = session.query(User).filter(User.id.in_(session.query(User.id).filter_by(name='DragonFire'))).all() 子查询
77from sqlalchemy import and_, or_
78ret = session.query(User).filter(and_(User.id > 3, User.name == 'DragonFire')).all()
79ret = session.query(User).filter(or_(User.id < 2, User.name == 'DragonFire')).all()
80ret = session.query(User).filter(
81    or_(
82        User.id < 2,
83        and_(User.name == 'eric', User.id > 3),
84        User.extra != ""
85    )).all()
86# select * from User where id<2 or (name="eric" and id>3) or extra != "" 
87
88# 通配符
89ret = db_session.query(User).filter(User.name.like('e%')).all()
90ret = db_session.query(User).filter(~User.name.like('e%')).all()
91
92# 限制
93ret = db_session.query(User)[1:2]
94
95# 排序
96ret = db_session.query(User).order_by(User.name.desc()).all()
97ret = db_session.query(User).order_by(User.name.desc(), User.id.asc()).all()
98
99# 分组
100from sqlalchemy.sql import func
101
102ret = db_session.query(User).group_by(User.extra).all()
103ret = db_session.query(
104    func.max(User.id),
105    func.sum(User.id),
106    func.min(User.id)).group_by(User.name).all()
107
108ret = db_session.query(
109    func.max(User.id),
110    func.sum(User.id),
111    func.min(User.id)).group_by(User.name).having(func.min(User.id) >2).all()
112"""
113
114# 关闭连接
115db_session.close()
116
117orm_select_more

orm_select_more

　　6.高级修改数据操作

11 #高级版更新操作
2 2 from my_create_table import User,engine
3 3 from sqlalchemy.orm import sessionmaker
4 4 
5 5 Session = sessionmaker(engine)
6 6 db_session = Session()
7 7 
8 8 #直接修改
9 9 db_session.query(User).filter(User.id > 0).update({"name" : "099"})
1010 
1111 #在原有值基础上添加 - 1
1212 db_session.query(User).filter(User.id > 0).update({User.name: User.name + "099"}, synchronize_session=False)
1313 
1414 #在原有值基础上添加 - 2
1515 db_session.query(User).filter(User.id > 0).update({"age": User.age + 1}, synchronize_session="evaluate")
1616 db_session.commit()

orm_update_more

三丶一对多的操作: ForeignKey

　　1.创建数据表及关系relationship

11 from sqlalchemy.ext.declarative import declarative_base
2 2 
3 3 Base = declarative_base()
4 4 
5 5 # 这次我们要多导入一个 ForeignKey 字段了,外键关联对了
6 6 from sqlalchemy import Column,Integer,String,ForeignKey
7 7 # 还要从orm 中导入一个 relationship 关系映射
8 8 from sqlalchemy.orm import relationship
9 9 
1010 class ClassTable(Base):
1111     __tablename__="classtable"
1212     id = Column(Integer,primary_key=True)
1313     name = Column(String(32),index=True)
1414 
1515 class Student(Base):
1616     __tablename__="student"
1717     id=Column(Integer,primary_key=True)
1818     name = Column(String(32),index=True)
1919 
2020     # 关联字段,让class_id 与 class 的 id 进行关联,主外键关系(这里的ForeignKey一定要是表名.id不是对象名)
2121     class_id = Column(Integer,ForeignKey("classtable.id"))
2222 
2323     # 将student 与 classtable 创建关系 这个不是字段,只是关系,backref是反向关联的关键字
2424     to_class = relationship("ClassTable",backref = "stu2class")
2525 
2626 from sqlalchemy import create_engine
2727 engine = create_engine("mysql+pymysql://root:@127.0.0.1:3306/dragon?charset=utf8")
2828 
2929 Base.metadata.create_all(engine)

my_ForeignKey.py　

　　2.基于relationship增加数据

11 from my_ForeignKey import Student, ClassTable,engine
2 2 # 创建连接
3 3 from sqlalchemy.orm import sessionmaker
4 4 # 创建数据表操作对象 sessionmaker
5 5 DB_session = sessionmaker(engine)
6 6 db_session = DB_session()
7 7 
8 8 # 增加数据
9 9 # 1.简单增加数据
1010 # 添加两个班级:
1111 # db_session.add_all([
1212 #     ClassTable(name="OldBoyS1"),
1313 #     ClassTable(name="OldBoyS2")
1414 # ])
1515 # db_session.commit()
1616 # 添加一个学生 DragonFire 班级是 OldBoyS1
1717 # 查询要添加到的班级
1818 # class_obj = db_session.query(ClassTable).filter(ClassTable.name == "OldBoyS1").first()
1919 # 创建学生
2020 # stu = Student(name="DragonFire",class_id = class_obj.id)
2121 # db_session.add(stu)
2222 # db_session.commit()
2323 
2424 # 2. relationship版 添加数据
2525 # 通过关系列 to_class 可以做到两件事
2626 # 第一件事 在ClassTable表中添加一条数据
2727 # 第二件事 在Student表中添加一条数据并将刚刚添加的ClassTable的数据id填写在Student的class_id中
2828 # stu_cla = Student(name="DragonFire",to_class=ClassTable(name="OldBoyS1"))
2929 # print(stu_cla.name,stu_cla.class_id)
3030 # db_session.add(stu_cla)
3131 # db_session.commit()
3232 
3333 # 3.relationship版 反向添加数据
3434 # 首先建立ClassTable数据
3535 class_obj = ClassTable(name="OldBoyS2")
3636 # 通过class_obj中的反向关联字段backref - stu2class
3737 # 向 Student 数据表中添加 2条数据 并将 2条数据的class_id 写成 class_obj的id
3838 # class_obj.stu2class = [Student(name="BMW"),Student(name="Audi")]
3939 # db_session.add(class_obj)
4040 # db_session.commit()
4141 
4242 # 关闭连接
4343 db_session.close()

orm_ForeignKey_insert.py

　　3.基于relationship查询数据

11 from my_ForeignKey import Student, ClassTable,engine
2 2 
3 3 from sqlalchemy.orm import sessionmaker
4 4 DB_session = sessionmaker(engine)
5 5 db_session = DB_session()
6 6 
7 7 # 1.查询所有数据,并显示班级名称,连表查询
8 8 student_list = db_session.query(Student).all()
9 9 for row in student_list:
1010     # row.to_class.name 通过Student对象中的关系字段relationship to_class 获取关联 ClassTable中的name
1111     print(row.name,row.to_class.name,row.class_id)
1212 
1313 # 2.反向查询
1414 class_list = db_session.query(ClassTable).all()
1515 for row in class_list:
1616     for row2 in row.stu2class:
1717         print(row.name,row2.name)
1818 # row.stu2class 通过 backref 中的 stu2class 反向关联到 Student 表中根据ID获取name
1919 
2020 
2121 db_session.close()

orm_ForeignKey_select.py

　　4.更新数据

11 from my_ForeignKey import Student, ClassTable,engine
2 2 
3 3 from sqlalchemy.orm import sessionmaker
4 4 DB_session = sessionmaker(engine)
5 5 db_session = DB_session()
6 6 
7 7 # 更新
8 8 class_info = db_session.query(ClassTable).filter(ClassTable.name=="OldBoyS1").first()
9 9 db_session.query(Student).filter(Student.class_id == class_info.id).update({"name":"NBDragon"})
1010 db_session.commit()
1111 
1212 db_session.close()

orm_ForeignKey_update

　　5.删除数据

11 from my_ForeignKey import Student, ClassTable,engine
2 2 
3 3 from sqlalchemy.orm import sessionmaker
4 4 DB_session = sessionmaker(engine)
5 5 db_session = DB_session()
6 6 
7 7 # 删除
8 8 class_info = db_session.query(ClassTable).filter(ClassTable.name=="OldBoyS1").first()
9 9 db_session.query(Student).filter(Student.class_id == class_info.id).delete()
1010 db_session.commit()
1111 
1212 db_session.close()

orm_ForeignKey_delete.py

四丶多对多: ManyToMany

　　1.创建表及关系

11 from sqlalchemy.ext.declarative import declarative_base
2 2 
3 3 Base = declarative_base()
4 4 
5 5 from sqlalchemy import Column,Integer,String,ForeignKey
6 6 from sqlalchemy.orm import relationship
7 7 
8 8 class Hotel(Base):
9 9     __tablename__="hotel"
1010     id=Column(Integer,primary_key=True)
1111     girl_id = Column(Integer,ForeignKey("girl.id"))
1212     boy_id = Column(Integer,ForeignKey("boy.id"))
1313 
1414 class Girl(Base):
1515     __tablename__="girl"
1616     id=Column(Integer,primary_key=True)
1717     name = Column(String(32),index=True)
1818 
1919     #创建关系
2020     boys = relationship("Boy",secondary="hotel",backref="girl2boy")
2121 
2222 
2323 class Boy(Base):
2424     __tablename__="boy"
2525     id=Column(Integer,primary_key=True)
2626     name = Column(String(32),index=True)
2727 
2828 
2929 from sqlalchemy import create_engine
3030 engine = create_engine("mysql+pymysql://root:DragonFire@127.0.0.1:3306/dragon?charset=utf8")
3131 
3232 Base.metadata.create_all(engine)

my_M2M.py

　　2.基于relationship增加数据

11 from my_M2M import Girl,Boy,Hotel,engine
2 2 
3 3 # 创建连接
4 4 from sqlalchemy.orm import sessionmaker
5 5 # 创建数据表操作对象 sessionmaker
6 6 DB_session = sessionmaker(engine)
7 7 db_session = DB_session()
8 8 
9 9 # 1.通过Boy添加Girl和Hotel数据
1010 boy = Boy(name="DragonFire")
1111 boy.girl2boy = [Girl(name="赵丽颖"),Girl(name="Angelababy")]
1212 db_session.add(boy)
1313 db_session.commit()
1414 
1515 # 2.通过Girl添加Boy和Hotel数据
1616 girl = Girl(name="珊珊")
1717 girl.boys = [Boy(name="Dragon")]
1818 db_session.add(girl)
1919 db_session.commit()

orm_M2M_insert.py

　　3.基于relationship查询数据

11 from my_M2M import Girl,Boy,Hotel,engine
2 2 
3 3 # 创建连接
4 4 from sqlalchemy.orm import sessionmaker
5 5 # 创建数据表操作对象 sessionmaker
6 6 DB_session = sessionmaker(engine)
7 7 db_session = DB_session()
8 8 
9 9 # 1.通过Boy查询约会过的所有Girl
1010 hotel = db_session.query(Boy).all()
1111 for row in hotel:
1212     for row2 in row.girl2boy:
1313         print(row.name,row2.name)
1414 
1515 # 2.通过Girl查询约会过的所有Boy
1616 hotel = db_session.query(Girl).all()
1717 for row in hotel:
1818     for row2 in row.boys:
1919         print(row.name,row2.name)

orm_M2M_select.py