SQLAlchemy 增刪改查 一對多 多對多
很久沒有更新Blog了html
今天來聊一聊 Python 的 ORM 框架 SQLAlchemy 有些同窗已經據說過這個框架的大名了,也據說了 SQLAlchemy 沒有 Django 的 Models 好用mysql
我在這裏官宣闢謠一下啊, Models 牢牢只是配置和使用比較簡單(這特麼就是廢話),由於他是Django自帶的ORM框架,也正是由於是Django原生的,因此兼容性遠遠不如SQLAlchemysql
真正算得上全面的ORM框架必然是咱們的SQLAlchemy ORM框架,它能夠在任何使用SQL查詢時使用數據庫
固然了,不管是使用什麼ORM框架,都是爲了方便不熟練數據庫的同窗使用的,我我的仍是比較推崇原生 SQL ,也建議每位同窗攻克 SQL 的難關session
廢話很少說,咱們來看一下 SQLAlchemy 如何使用:app
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:DragonFire@127.0.0.1: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="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()
2.2.查詢數據ide
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.修改數據post
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.刪除數據lua
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 == '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()
2.6.高級修改數據操做
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()
3.一對多的操做 : ForeignKey
3.1.建立數據表及關係relationship:
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)
3.2.基於relationship增長數據
1 from my_ForeignKey import Student, ClassTable,engine 2 # 建立鏈接 3 from sqlalchemy.orm import sessionmaker 4 # 建立數據表操做對象 sessionmaker 5 DB_session = sessionmaker(engine) 6 db_session = DB_session() 7 8 # 增長數據 9 # 1.簡單增長數據 10 # 添加兩個班級: 11 # db_session.add_all([ 12 # ClassTable(name="OldBoyS1"), 13 # ClassTable(name="OldBoyS2") 14 # ]) 15 # db_session.commit() 16 # 添加一個學生 DragonFire 班級是 OldBoyS1 17 # 查詢要添加到的班級 18 # class_obj = db_session.query(ClassTable).filter(ClassTable.name == "OldBoyS1").first() 19 # 建立學生 20 # stu = Student(name="DragonFire",class_id = class_obj.id) 21 # db_session.add(stu) 22 # db_session.commit() 23 24 # 2. relationship版 添加數據 25 # 經過關係列 to_class 能夠作到兩件事 26 # 第一件事 在ClassTable表中添加一條數據 27 # 第二件事 在Student表中添加一條數據並將剛剛添加的ClassTable的數據id填寫在Student的class_id中 28 # stu_cla = Student(name="DragonFire",to_class=ClassTable(name="OldBoyS1")) 29 # print(stu_cla.name,stu_cla.class_id) 30 # db_session.add(stu_cla) 31 # db_session.commit() 32 33 # 3.relationship版 反向添加數據 34 # 首先創建ClassTable數據 35 class_obj = ClassTable(name="OldBoyS2") 36 # 經過class_obj中的反向關聯字段backref - stu2class 37 # 向 Student 數據表中添加 2條數據 並將 2條數據的class_id 寫成 class_obj的id 38 # class_obj.stu2class = [Student(name="BMW"),Student(name="Audi")] 39 # db_session.add(class_obj) 40 # db_session.commit() 41 42 # 關閉鏈接 43 db_session.close()
3.3.基於relationship查詢數據
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 # 1.查詢全部數據,並顯示班級名稱,連表查詢 8 student_list = db_session.query(Student).all() 9 for row in student_list: 10 # row.to_class.name 經過Student對象中的關係字段relationship to_class 獲取關聯 ClassTable中的name 11 print(row.name,row.to_class.name,row.class_id) 12 13 # 2.反向查詢 14 class_list = db_session.query(ClassTable).all() 15 for row in class_list: 16 for row2 in row.stu2class: 17 print(row.name,row2.name) 18 # row.stu2class 經過 backref 中的 stu2class 反向關聯到 Student 表中根據ID獲取name 19 20 21 db_session.close()
3.4.更新數據
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()
3.5.刪除數據
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()
4.多對多 : ManyToMany
4.1.建立表及關係
1 from sqlalchemy.ext.declarative import declarative_base 2 3 Base = declarative_base() 4 5 from sqlalchemy import Column,Integer,String,ForeignKey 6 from sqlalchemy.orm import relationship 7 8 class Hotel(Base): 9 __tablename__="hotel" 10 id=Column(Integer,primary_key=True) 11 girl_id = Column(Integer,ForeignKey("girl.id")) 12 boy_id = Column(Integer,ForeignKey("boy.id")) 13 14 class Girl(Base): 15 __tablename__="girl" 16 id=Column(Integer,primary_key=True) 17 name = Column(String(32),index=True) 18 19 #建立關係 20 boys = relationship("Boy",secondary="hotel",backref="girl2boy") 21 22 23 class Boy(Base): 24 __tablename__="boy" 25 id=Column(Integer,primary_key=True) 26 name = Column(String(32),index=True) 27 28 29 from sqlalchemy import create_engine 30 engine = create_engine("mysql+pymysql://root:DragonFire@127.0.0.1:3306/dragon?charset=utf8") 31 32 Base.metadata.create_all(engine)
4.2.基於relationship增長數據
1 from my_M2M import Girl,Boy,Hotel,engine 2 3 # 建立鏈接 4 from sqlalchemy.orm import sessionmaker 5 # 建立數據表操做對象 sessionmaker 6 DB_session = sessionmaker(engine) 7 db_session = DB_session() 8 9 # 1.經過Boy添加Girl和Hotel數據 10 boy = Boy(name="DragonFire") 11 boy.girl2boy = [Girl(name="趙麗穎"),Girl(name="Angelababy")] 12 db_session.add(boy) 13 db_session.commit() 14 15 # 2.經過Girl添加Boy和Hotel數據 16 girl = Girl(name="珊珊") 17 girl.boys = [Boy(name="Dragon")] 18 db_session.add(girl) 19 db_session.commit()
4.3.基於relationship查詢數據
1 from my_M2M import Girl,Boy,Hotel,engine 2 3 # 建立鏈接 4 from sqlalchemy.orm import sessionmaker 5 # 建立數據表操做對象 sessionmaker 6 DB_session = sessionmaker(engine) 7 db_session = DB_session() 8 9 # 1.經過Boy查詢約會過的全部Girl 10 hotel = db_session.query(Boy).all() 11 for row in hotel: 12 for row2 in row.girl2boy: 13 print(row.name,row2.name) 14 15 # 2.經過Girl查詢約會過的全部Boy 16 hotel = db_session.query(Girl).all() 17 for row in hotel: 18 for row2 in row.boys: 19 print(row.name,row2.name)