SQLAlchemy

今天来聊一聊 Python 的 ORM 框架 SQLAlchemy 有些同学已经听说过这个框架的大名了,也听说了 SQLAlchemy 没有 Django 的 Models 好用

我在这里官宣辟谣一下啊, Models 只是配置和使用比较简单(这特么就是废话),因为他是Django自带的ORM框架,也正是因为是Django原生的,所以兼容性远远不如SQLAlchemy

真正算得上全面的ORM框架必然是我们的SQLAlchemy ORM框架,它可以在任何使用SQL查询时使用

当然了,无论是使用什么ORM框架,都是为了方便不熟练数据库的同学使用的,我个人还是比较推崇原生 SQL 

创建数据表

from sqlalchemy.ext.declarative import declarative_base


# 建立基础类  关系 映射 类
Model=declarative_base()

from sqlalchemy import Column
from sqlalchemy import Integer
from sqlalchemy import String


class User(Model):
    # 创建表名
    __tablename__="user"
    id=Column(Integer,primary_key=True)
    #比如字段name  并建立索引
    name=Column(String(32),index=True)


# 创建数据库的引擎
from sqlalchemy.engine import create_engine
engine=create_engine("mysql+pymysql://root:123@127.0.0.1:3306/my_sqlalchemy?charset=utf8")

# 检索所有继承 Model 的Object 并在 engine 指向的数据库中创建 所有的表
Model.metadata.create_all(engine)
# Model.metadata.drop_all(engine)


# engine = create_engine("mysql://scott:tiger@hostname/dbname",encoding='latin1', echo=True)

参考：

# ORM中的数据表是什么呢?
# Object Relation Mapping
# Object - Table 通过 Object 去操纵数据表
# 从而引出了我们的第一步创建数据表 - 创建Object
# 1. 创建Object
# class User(object):
#     pass

# 2. 让Object与数据表产生某种关系 也就是让Object与数据表格式极度相似
# 导入官宣基础模型
from sqlalchemy.ext.declarative import declarative_base
# 实例化官宣模型 - Base 就是 ORM 模型
Base = declarative_base()
# 当前的这个Object继承了Base也就是代表了Object继承了ORM的模型
class User(Base):  # 相当于 Django Models中的 Model
    # 为Table创建名称
    __tablename__ = "user"
    # 创建ID数据字段 , 那么ID是不是一个数据列呢? 也就是说创建ID字段 == 创建ID数据列
    from sqlalchemy import Column,Integer,String
    # id = Column(数据类型,索引,主键,外键,等等)
    # int == Integer
    id = Column(Integer,primary_key=True,autoincrement=True)
    # str == char(长度) == String(长度)
    name = Column(String(32),index=True)

# 3.去数据库中创建数据表? or 先连接数据库?
# 3.去连接数据库 创建数据引擎
from sqlalchemy import create_engine
# 创建的数据库引擎
engine = create_engine("mysql+pymysql://root:DragonFire@127.0.0.1:3306/dragon?charset=utf8")

# Base 自动检索所有继承Base的ORM 对象 并且创建所有的数据表
Base.metadata.create_all(engine)

my_create_table

增删改查

增

1 #insert 为数据表增加数据
 2 # insert One 增加一行数据
 3 # insert into user(name) values ("DragonFire")
 4 # 在ORM中的操作:
 5 # 1.首先导入之间做好的ORM 对象 User
 6 from my_create_table import User
 7 # 2.使用Users ORM模型创建一条数据
 8 user1 = User(name="DragonFire")
 9 # 数据已经创建完了,但是需要写入到数据库中啊,怎么写入呢?
10 # 3.写入数据库:
11 # 首先打开数据库会话 , 说白了就是创建了一个操纵数据库的窗口
12 # 导入 sqlalchemy.orm 中的 sessionmaker
13 from sqlalchemy.orm import sessionmaker
14 # 导入之前创建好的 create_engine
15 from my_create_table import engine
16 # 创建 sessionmaker 会话对象,将数据库引擎 engine 交给 sessionmaker
17 Session = sessionmaker(engine)
18 # 打开会话对象 Session
19 db_session = Session()
20 # 在db_session会话中添加一条 UserORM模型创建的数据
21 db_session.add(user1)
22 # 使用 db_session 会话提交 , 这里的提交是指将db_session中的所有指令一次性提交
23 db_session.commit()
24 
25 # 当然也你也可很任性的提交多条数据
26 # 方法一:
27 user2 = User(name="Dragon")
28 user3 = User(name="Fire")
29 db_session.add(user2)
30 db_session.add(user3)
31 db_session.commit()
32 # 之前说过commit是将db_session中的所有指令一次性提交,现在的db_session中至少有两条指令user2和user3
33 db_session.close()
34 #关闭会话
35 
36 # 如果说你觉得方法一很麻烦,那么方法二一定非常非常适合你
37 # 方法二:
38 user_list = [
39     User(name="Dragon1"),
40     User(name="Dragon2"),
41     User(name="Dragon3")
42 ]
43 db_session.add_all(user_list)
44 db_session.commit()
45 
46 db_session.close()

查

1 # ORM操作查询数据
 2 # 有了刚才Insert增加数据的经验,那么查询之前的准备工作,就不用再重复了吧
 3 # 回想一下刚才Insert时我们的操作
 4 from my_create_table import User, engine
 5 from sqlalchemy.orm import sessionmaker
 6 
 7 Session = sessionmaker(engine)
 8 db_session = Session()
 9 
10 # 1. select * from user 查询user表中的所有数据
11 # 语法是这样的 使用 db_session 会话 执行User表 query(User) 取出全部数据 all()
12 user_all_list = db_session.query(User).all()
13 print(user_all_list)  # [<my_create_table.User object at 0x0000016D7C4BCDD8>]
14 # 如何查看user_all_list其中的数据呢? 循环呗
15 for i in user_all_list:
16     print(i.id, i.name)  # ORM对象 直接使用调用属性的方法 拿出对应字段的值
17 
18 db_session.close()
19 #关闭会话
20 
21 # 2. select * from user where id >= 20
22 # 语法是这样的 使用 db_session 会话 执行User表 query(User) 筛选内容User.id >=20 的数据全部取出 all()
23 user_all_list = db_session.query(User).filter(User.id >= 20).all()
24 print(user_all_list)
25 for i in user_all_list:
26     print(i.id, i.name)
27 
28 db_session.close()
29 #关闭会话
30 
31 # 3. 除了取出全部还可以只取出一条
32 user = db_session.query(User).filter(User.id >= 20).first()
33 print(user.id, user.name)
34 db_session.close()
35 #关闭会话
36 
37 # 4. 乌龙 之 忘了取出数据.......
38 wulong1 = db_session.query(User).filter(User.id >= 20)
39 print(wulong1)
40 #SELECT user.id AS user_id, user.name AS user_name
41 #FROM user
42 #WHERE user.id >= %(id_1)s
43 # Fuck我忘了取出数据了!!!!!!! 哎? wulong1给我显示了原生SQL语句,因祸得福了
44 wulong2 = db_session.query(User)
45 print(wulong2)
46 #SELECT user.id AS user_id, user.name AS user_name
47 #FROM user
48 # Fuck我又忘了取出数据了!!!!!!! 哎? wulong2给我显示了原生SQL语句,因祸得福了
49 db_session.close()
50 #关闭会话

改

# ORM更新数据
# 无论是更新还是删除,首先要做的事情,就应该是查询吧
# 根据之前原有的经验,接下来是不是要导入ORM对象了,是不是要创建db_session会话了
from my_create_table import User,engine
from sqlalchemy.orm import sessionmaker
Session = sessionmaker(engine)
db_session = Session()

# UPDATE user SET name="NBDragon" WHERE id=20 更新一条数据
# 语法是这样的 :
# 使用 db_session 执行User表 query(User) 筛选 User.id = 20 的数据 filter(User.id == 20)
# 将name字段的值改为NBDragon update({"name":"NBDragon"})
res = db_session.query(User).filter(User.id == 20).update({"name":"NBDragon"})
print(res) # 1 res就是我们当前这句更新语句所更新的行数
# 注意注意注意
# 这里一定要将db_session中的执行语句进行提交,因为你这是要对数据中的数据进行操作
# 数据库中 增 改 删 都是操作,也就是说执行以上三种操作的时候一定要commit
db_session.commit()
db_session.close()
#关闭会话

# 更新多条
res = db_session.query(User).filter(User.id <= 20).update({"name":"NBDragon"})
print(res) # 6 res就是我们当前这句更新语句所更新的行数
db_session.commit()
db_session.close()
#关闭会话

orm_update

删

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

# 导入
from sqlalchemy.orm import sessionmaker
from create_table import engine, User

# 创建 sessionmaker 会话对象,将数据库引擎 engine 交给 sessionmaker
session = sessionmaker(engine)
# 打开会话对象
db_session = session()

# 增加数据
# u = User(name="haha")
# db_session.add(u)
# db_session.commit()
# db_session.close()

# 增加多条数据
# u_list = [User(name="xlh1"), User(name="minmin")]
# db_session.add_all(u_list)
# db_session.commit()
# db_session.close()

# 查询数据
# res=db_session.query(User).all()
# print(res)
# for user in res:
#     print(user.id,user.name)
# 带条件查询
# res=db_session.query(User).first()
# print(res.name)
# res=db_session.query(User).filter(User.id<3).all()
# for user in res:
#     print(user.id,user.name)

# 并列条件
# res=db_session.query(User).filter(User.id<3,User.name=="haha").all()
# for user in res:
#     print(user.id,user.name)
#
#
# db_session.close()

# 修改数据
# db_session.query(User).filter(User.id<3).update({"name":"kaixin"})
# db_session.commit()

# 删除数据
# db_session.query(User).filter(User.id==3).delete()
# db_session.commit()

高级查询

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

高级修改

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

一对多  ForeignKey

创建数据

1 from sqlalchemy.ext.declarative import declarative_base
 2 
 3 Base = declarative_base()
 4 
 5 # 这次我们要多导入一个 ForeignKey 字段了,外键关联对了
 6 from sqlalchemy import Column,Integer,String,ForeignKey
 7 # 还要从orm 中导入一个 relationship 关系映射
 8 from sqlalchemy.orm import relationship
 9 
10 class ClassTable(Base):
11     __tablename__="classtable"
12     id = Column(Integer,primary_key=True)
13     name = Column(String(32),index=True)
14 
15 class Student(Base):
16     __tablename__="student"
17     id=Column(Integer,primary_key=True)
18     name = Column(String(32),index=True)
19 
20     # 关联字段,让class_id 与 class 的 id 进行关联,主外键关系(这里的ForeignKey一定要是表名.id不是对象名)
21     class_id = Column(Integer,ForeignKey("classtable.id"))
22 
23     # 将student 与 classtable 创建关系 这个不是字段,只是关系,backref是反向关联的关键字
24     to_class = relationship("ClassTable",backref = "stu2class")
25 
26 from sqlalchemy import create_engine
27 engine = create_engine("mysql+pymysql://root:DragonFire@127.0.0.1:3306/dragon?charset=utf8")
28 
29 Base.metadata.create_all(engine)

增

from my_ForeignKey import Student, ClassTable,engine
# 创建连接
from sqlalchemy.orm import sessionmaker
# 创建数据表操作对象 sessionmaker
DB_session = sessionmaker(engine)
db_session = DB_session()

# 增加数据
# 1.简单增加数据
# 添加两个班级:
# db_session.add_all([
#     ClassTable(name="OldBoyS1"),
#     ClassTable(name="OldBoyS2")
# ])
# db_session.commit()
# 添加一个学生 DragonFire 班级是 OldBoyS1
# 查询要添加到的班级
# class_obj = db_session.query(ClassTable).filter(ClassTable.name == "OldBoyS1").first()
# 创建学生
# stu = Student(name="DragonFire",class_id = class_obj.id)
# db_session.add(stu)
# db_session.commit()

# 2. relationship版 添加数据
# 通过关系列 to_class 可以做到两件事
# 第一件事 在ClassTable表中添加一条数据
# 第二件事 在Student表中添加一条数据并将刚刚添加的ClassTable的数据id填写在Student的class_id中
# stu_cla = Student(name="DragonFire",to_class=ClassTable(name="OldBoyS1"))
# print(stu_cla.name,stu_cla.class_id)
# db_session.add(stu_cla)
# db_session.commit()

# 3.relationship版 反向添加数据
# 首先建立ClassTable数据
class_obj = ClassTable(name="OldBoyS2")
# 通过class_obj中的反向关联字段backref - stu2class
# 向 Student 数据表中添加 2条数据 并将 2条数据的class_id 写成 class_obj的id
# class_obj.stu2class = [Student(name="BMW"),Student(name="Audi")]
# db_session.add(class_obj)
# db_session.commit()

# 关闭连接
db_session.close()

orm_ForeignKey_insert.py

查

from my_ForeignKey import Student, ClassTable,engine

from sqlalchemy.orm import sessionmaker
DB_session = sessionmaker(engine)
db_session = DB_session()

# 1.查询所有数据,并显示班级名称,连表查询
student_list = db_session.query(Student).all()
for row in student_list:
    # row.to_class.name 通过Student对象中的关系字段relationship to_class 获取关联 ClassTable中的name
    print(row.name,row.to_class.name,row.class_id)

# 2.反向查询
class_list = db_session.query(ClassTable).all()
for row in class_list:
    for row2 in row.stu2class:
        print(row.name,row2.name)
# row.stu2class 通过 backref 中的 stu2class 反向关联到 Student 表中根据ID获取name


db_session.close()

orm_ForeignKey_select.py

改

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

删

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

from sqlalchemy.ext.declarative import declarative_base

# 基类
Model=declarative_base()
from sqlalchemy import Column,Integer,String,ForeignKey
from sqlalchemy.orm import relationship
class School(Model):
    __tablename__ = "school"
    id = Column(Integer,primary_key=True)
    name = Column(String(32),nullable=False)

class Student(Model):
    __tablename__="student"
    id=Column(Integer,primary_key=True)
    name = Column(String(32), nullable=False)

    # 主外键关系(这里的ForeignKey一定要是表名.id不是对象名)
    sch_id=Column(Integer,ForeignKey("school.id"))
    # 创建关系
    # 这个不是字段, 只是关系, backref是反向关联的关键字
    stu2sch=relationship("School",backref="sch2stu")

    # 创建数据库的引擎


from sqlalchemy.engine import create_engine

engine = create_engine("mysql+pymysql://root:123@127.0.0.1:3306/my_sqlalchemy?charset=utf8")

# 检索所有继承 Model 的Object 并在 engine 指向的数据库中创建 所有的表
Model.metadata.create_all(engine)

from sqlalchemy.orm  import sessionmaker
from create_table_foreignkey import engine,School,Student

session=sessionmaker(engine)
db_session=session()


# 增
# sc=School(name="daxue")
# db_session.add(sc)
# db_session.commit()
#
# sc_fir=db_session.query(School).filter( School.name=="daxue").first()
# stu=Student(name="xiaokeai",sch_id=sc_fir.id)
# db_session.add(stu)
# db_session.commit()

# 添加数据 之 relationship 正向添加数据
# stu = Student(name="aaa",stu2sch=School(name="向日葵"))
# db_session.add(stu)
# db_session.commit()

# 添加数据 之 relationship 反向添加数据
# sch = School(name="youeryuan")
# sch.sch2stu = [
#     Student(name="bb"),
#     Student(name="ccc")
# ]
#
# db_session.add(sch)
# db_session.commit()


# 查询 的 relationship 正向
# res = db_session.query(Student).all()
# for stu in res:
#     print(stu.id,stu.name,stu.stu2sch.name)

# 查询 的 relationship 反向
res = db_session.query(School).all()
for sch in res:
    # print(sch.name,len(sch.sch2stu))
    for stu in sch.sch2stu:
        print(sch.name,stu.name)

# school_info=db_session.query(School).filter(School.name=="youeryuan").first()
# db_session.query(Student).filter(Student.sch_id==school_info.id).update({"name":"ddd"})
# db_session.commit()

# school_info=db_session.query(School).filter(School.name=="youeryuan").first()
# db_session.query(Student).filter(Student.sch_id==school_info.id).delete()
# db_session.commit()
# db_session.close()

多对多 manytomany

from sqlalchemy.ext.declarative import declarative_base

Model = declarative_base()

from sqlalchemy import Column,Integer,String,ForeignKey
from sqlalchemy.orm import relationship

class Girls(Model):
    __tablename__ = "girl"
    id = Column(Integer,primary_key=True)
    name = Column(String(32),nullable=False)

    # relationship

    g2b = relationship("Boys",backref="b2g",secondary="hotel")

class Boys(Model):
    __tablename__ = "boy"
    id = Column(Integer,primary_key=True)
    name = Column(String(32),nullable=False)


class Hotels(Model):
    __tablename__ = "hotel"
    id = Column(Integer,primary_key=True)

    boy_id = Column(Integer,ForeignKey("boy.id"))
   girl_id = Column(Integer,ForeignKey("girl.id"))


from sqlalchemy.engine import create_engine

engine = create_engine("mysql+pymysql://root:123@127.0.0.1:3306/my_sqlalchemy?charset=utf8")

# 检索所有继承 Model 的Object 并在 engine 指向的数据库中创建 所有的表
Model.metadata.create_all(engine)

增删改查

from sqlalchemy.orm import sessionmaker
from create_table_M2M import engine, Girls, Boys

s = sessionmaker(engine)
db_session = s()


# 添加数据 之 relationship 正向添加数据
# g = Girls(name="vvvv",g2b=[Boys(name="n1"),Boys(name="n2")])
# db_session.add(g)
# db_session.commit()

# 添加数据 之 relationship 反向添加数据
# b = Boys(name="m1")
# b.b2g = [
#     Girls(name="v0"),
#     Girls(name="v9")
# ]
# db_session.add(b)
# db_session.commit()


# 查询数据 之 relationship 正向
# res = db_session.query(Girls).all()
# for g in res:
#     for b in g.g2b:
#         print(g.name,b.name)

# 查询数据 之 relationship 反向
# res = db_session.query(Boys).all()
# for b in res:
#     for g in b.b2g:
#         print(b.name,g.name)

from sqlalchemy.ext.declarative import declarative_base

Base = declarative_base()

from sqlalchemy import Column,Integer,String,ForeignKey
from sqlalchemy.orm import relationship

class Hotel(Base):
    __tablename__="hotel"
    id=Column(Integer,primary_key=True)
    girl_id = Column(Integer,ForeignKey("girl.id"))
    boy_id = Column(Integer,ForeignKey("boy.id"))

class Girl(Base):
    __tablename__="girl"
    id=Column(Integer,primary_key=True)
    name = Column(String(32),index=True)

    #创建关系
    boys = relationship("Boy",secondary="hotel",backref="girl2boy")


class Boy(Base):
    __tablename__="boy"
    id=Column(Integer,primary_key=True)
    name = Column(String(32),index=True)


from sqlalchemy import create_engine
engine = create_engine("mysql+pymysql://root:DragonFire@127.0.0.1:3306/dragon?charset=utf8")

Base.metadata.create_all(engine)

my_M2M.py

增 查

from my_M2M import Girl,Boy,Hotel,engine

# 创建连接
from sqlalchemy.orm import sessionmaker
# 创建数据表操作对象 sessionmaker
DB_session = sessionmaker(engine)
db_session = DB_session()

# 1.通过Boy添加Girl和Hotel数据
boy = Boy(name="DragonFire")
boy.girl2boy = [Girl(name="赵丽颖"),Girl(name="Angelababy")]
db_session.add(boy)
db_session.commit()

# 2.通过Girl添加Boy和Hotel数据
girl = Girl(name="珊珊")
girl.boys = [Boy(name="Dragon")]
db_session.add(girl)
db_session.commit()

orm_M2M_insert.py

from my_M2M import Girl,Boy,Hotel,engine

# 创建连接
from sqlalchemy.orm import sessionmaker
# 创建数据表操作对象 sessionmaker
DB_session = sessionmaker(engine)
db_session = DB_session()

# 1.通过Boy查询约会过的所有Girl
hotel = db_session.query(Boy).all()
for row in hotel:
    for row2 in row.girl2boy:
        print(row.name,row2.name)

# 2.通过Girl查询约会过的所有Boy
hotel = db_session.query(Girl).all()
for row in hotel:
    for row2 in row.boys:
        print(row.name,row2.name)

orm_M2M_select.py