好久没有更新Blog了
今天来聊一聊 Python 的 ORM 框架 SQLAlchemy 有些同学已经听说过这个框架的大名了,也听说了 SQLAlchemy 没有 Django 的 Models 好用
我在这里官宣辟谣一下啊, Models 紧紧只是配置和使用比较简单(这特么就是废话),因为他是Django自带的ORM框架,也正是因为是Django原生的,所以兼容性远远不如SQLAlchemy
真正算得上全面的ORM框架必然是我们的SQLAlchemy ORM框架,它可以在任何使用SQL查询时使用
当然了,无论是使用什么ORM框架,都是为了方便不熟练数据库的同学使用的,我个人还是比较推崇原生 SQL ,也建议每位同学攻克 SQL 的难关
废话不多说,我们来看一下 SQLAlchemy 如何使用:
1.创建数据表
1 # ORM中的数据表是什么呢?
2 # Object Relation Mapping
3 # Object - Table 通过 Object 去操纵数据表
4 # 从而引出了我们的第一步创建数据表 - 创建Object
5 # 1. 创建Object
6 # class User(object):
7 # pass
8
9 # 2. 让Object与数据表产生某种关系 也就是让Object与数据表格式极度相似
10 # 导入官宣基础模型
11 from sqlalchemy.ext.declarative import declarative_base
12 # 实例化官宣模型 - Base 就是 ORM 模型
13 Base = declarative_base()
14 # 当前的这个Object继承了Base也就是代表了Object继承了ORM的模型
15 class User(Base): # 相当于 Django Models中的 Model
16 # 为Table创建名称
17 __tablename__ = "user"
18 # 创建ID数据字段 , 那么ID是不是一个数据列呢? 也就是说创建ID字段 == 创建ID数据列
19 from sqlalchemy import Column,Integer,String
20 # id = Column(数据类型,索引,主键,外键,等等)
21 # int == Integer
22 id = Column(Integer,primary_key=True,autoincrement=True)
23 # str == char(长度) == String(长度)
24 name = Column(String(32),index=True)
25
26 # 3.去数据库中创建数据表? or 先连接数据库?
27 # 3.去连接数据库 创建数据引擎
28 from sqlalchemy import create_engine
29 # 创建的数据库引擎
30 engine = create_engine("mysql+pymysql://root:[email protected]:3306/dragon?charset=utf8")
31
32 # Base 自动检索所有继承Base的ORM 对象 并且创建所有的数据表
33 Base.metadata.create_all(engine)
2.增删改查操作
2.1.增加数据
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="zq")
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="zhang")
28 user3 = User(name="qing")
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="zq1"),
40 User(name="zq2"),
41 User(name="zq3")
42 ]
43 db_session.add_all(user_list)
44 db_session.commit()
45
46 db_session.close()
2.2.查询数据
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 #关闭会话
2.3.修改数据
1 # ORM更新数据
2 # 无论是更新还是删除,首先要做的事情,就应该是查询吧
3 # 根据之前原有的经验,接下来是不是要导入ORM对象了,是不是要创建db_session会话了
4 from my_create_table import User,engine
5 from sqlalchemy.orm import sessionmaker
6 Session = sessionmaker(engine)
7 db_session = Session()
8
9 # UPDATE user SET name="NBDragon" WHERE id=20 更新一条数据
10 # 语法是这样的 :
11 # 使用 db_session 执行User表 query(User) 筛选 User.id = 20 的数据 filter(User.id == 20)
12 # 将name字段的值改为NBDragon update({"name":"NBDragon"})
13 res = db_session.query(User).filter(User.id == 20).update({"name":"NBDragon"})
14 print(res) # 1 res就是我们当前这句更新语句所更新的行数
15 # 注意注意注意
16 # 这里一定要将db_session中的执行语句进行提交,因为你这是要对数据中的数据进行操作
17 # 数据库中 增 改 删 都是操作,也就是说执行以上三种操作的时候一定要commit
18 db_session.commit()
19 db_session.close()
20 #关闭会话
21
22 # 更新多条
23 res = db_session.query(User).filter(User.id <= 20).update({"name":"NBDragon"})
24 print(res) # 6 res就是我们当前这句更新语句所更新的行数
25 db_session.commit()
26 db_session.close()
27 #关闭会话
2.4.删除数据
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 #关闭会话
2.5.搞基!高级版查询操作
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 == ‘zq‘)).all()
13 ret = db_session.query(User).filter(or_(User.id < 2, User.name == ‘zq‘)).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 == "zq").all()
24
25 # 原生SQL筛选条件
26 r4 = db_session.query(User).filter_by(name=‘zq‘).all()
27 r5 = db_session.query(User).filter_by(name=‘zq‘).first()
28
29 # 字符串匹配方式筛选条件 并使用 order_by进行排序
30 r6 = db_session.query(User).filter(text("id<:value and name=:name")).params(value=224, name=‘zq‘).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=‘zq‘).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)