一、orm架構簡介
對象-關系映射（Object/Relation Mapping，簡稱ORM），是随着面向對象的軟體開發方法發展而産生的。面向對象的開發方法是當今企業級應用開發環境中的主流開發方法，關系資料庫是企業級應用環境中永久存放資料的主流資料存儲系統。對象和關系資料是業務實體的兩種表現形式，業務實體在記憶體中表現為對象，在資料庫中表現為關系資料。記憶體中的對象之間存在關聯和繼承關系，而在資料庫中，關系資料無法直接表達多對多關聯和繼承關系。是以，對象-關系映射(ORM)系統一般以中間件的形式存在，主要實作程式對象到關系資料庫資料的映射。
1、ORM方法論基于三個核心原則：
- 簡單性：以最基本的形式模組化資料。
- 傳達性：資料庫結構被任何人都能了解的語言文檔化。
- 精确性：基于資料模型建立正确标準化了的結構。
面向對象是從軟體工程基本原則(如耦合、聚合、封裝)的基礎上發展起來的，而關系資料庫則是從數學理論發展而來的，兩套理論存在顯著的差別。為了解決這個不比對的現象,對象關系映射技術應運而生。O/R中字母O起源于"對象"(Object),而R則來自于"關系"(Relational)。幾乎所有的程式裡面，都存在對象和關系資料庫。在業務邏輯層和使用者界面層中，我們是面向對象的。當對象資訊發生變化的時候，我們需要把對象的資訊儲存在關系資料庫中。
當開發一個應用程式的時候(不使用O/R Mapping),可能會寫不少資料通路層的代碼，用來從資料庫儲存，删除，讀取對象資訊，等等。在DAL中寫了很多的方法來讀取對象資料，改變狀态對象等等任務。而這些代碼寫起來總是重複的。
如果打開你最近的程式，看看DAL代碼，肯定會看到很多近似的通用的模式。我們以儲存對象的方法為例，傳入一個對象，為SqlCommand對象添加SqlParameter，把所有屬性和對象對應，設定SqlCommand的CommandText屬性為存儲過程，然後運作SqlCommand。對于每個對象都要重複的寫這些代碼。除此之外，還有更好的辦法嗎？有，引入一個O/R Mapping。實質上，一個O/R Mapping會為你生成DAL。與其自己寫DAL代碼，不如用O/R Mapping。用O/R Mapping儲存，删除，讀取對象，O/R Mapping負責生成SQL，你隻需要關心對象就好。對象關系映射成功運用在不同的面向對象持久層産品中。
2、一般的ORM包括以下四部分
- 一個對持久類對象進行CRUD操作的API；
- 一個語言或API用來規定與類和類屬性相關的查詢；
- 一個規定mapping metadata的工具；
- 一種技術可以讓ORM的實作同僚務對象一起進行dirty checking, lazy association fetching以及其他的優化操作；
3、ORM把關系資料庫的表結構映射到對象上，我們先來看一個例子：
如果我們從資料庫查出來幾條資料，需要你在python中表示出來，如果你沒有接觸過ORM技術，你或許會使用下面的形式來存儲這個資料：
[
(1, 'feng'),
(2, 'shang'),
(3, 'huo'),
]
如果你想知道表結構是什麼樣的，是不是就費勁了，如果你想快速的取出其中的元素，就需要聽聽ORM的思想了。
資料庫中每次查出來的資料都用一個類表示，這個類的屬性和資料庫中表的字段一一對應。多條資料，就是一個list，每一行資料都是一個類來表示，如下所示：
class User(object):
def __init__(self, id, name):
self.id = id
self.name = name
[
User(1, "feng"),
User(2, "shang"),
User(3, "huo"),
]
當我們需要獲得id，或者name的時候，隻需要通過循環擷取到對象，直接通過user1.id或者user1.name就可以擷取到id和name的屬性。并且使得資料的存取非常的規範，這樣ORM架構應運而生。
二、SQLAlchemy介紹
Python中最有名的ORM架構就是SQLAlchemy，我們主要來學習SQLAlchemy的使用。
1、安裝
pip install sqlalchemy
2、建立資料表
my_create_table.py
# 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:[email protected]:3306/wll?charset=utf8")
# mysql+pymysql：指定是哪種資料庫連接配接
# root：使用者名
# 123456：root使用者對應的密碼
# 127.0.0.1:3306：資料庫的ip和端口号
# wll：連接配接的資料庫的名字
# charset=utf8：資料庫字元集
# Base 自動檢索所有繼承Base的ORM 對象 并且建立所有的資料表
Base.metadata.create_all(engine)
my_create_table.py
3、增删改查操作
3.1、添加資料
orm_insert.py
# insert 為資料表增加資料
# insert One 增加一行資料
# insert into user(name) values ("張三")
# 在ORM中的操作:
# 1.首先導入之間做好的ORM 對象 User
from my_create_table import User
# 2.使用Users ORM模型建立一條資料
user1 = User(name="張三")
# 資料已經建立完了,但是需要寫入到資料庫中啊,怎麼寫入呢?
# 3.寫入資料庫:
# 首先打開資料庫會話 , 說白了就是建立了一個操縱資料庫的視窗
# 導入 sqlalchemy.orm 中的 sessionmaker
from sqlalchemy.orm import sessionmaker
# 導入之前建立好的 create_engine
from my_create_table import engine
# 建立 sessionmaker 會話對象,将資料庫引擎 engine 交給 sessionmaker
Session = sessionmaker(engine)
# 打開會話對象 Session
db_session = Session()
# 在db_session會話中添加一條 UserORM模型建立的資料
db_session.add(user1)
# 使用 db_session 會話送出 , 這裡的送出是指将db_session中的所有指令一次性送出
db_session.commit()
db_session.close() # 關閉會話
# 當然也你也可很任性的送出多條資料
# 方法一:
user2 = User(name="李四")
user3 = User(name="王五")
db_session.add(user2)
db_session.add(user3)
db_session.commit()
# 之前說過commit是将db_session中的所有指令一次性送出,現在的db_session中至少有兩條指令user2和user3
db_session.close()
# 如果說你覺得方法一很麻煩,那麼方法二一定非常非常适合你
# 方法二:
user_list = [
User(name="小明"),
User(name="小紅"),
User(name="小蘭")
]
db_session.add_all(user_list) # add_all方法中傳入可疊代對象，可一次性添加多條資料
db_session.commit()
db_session.close()
orm_insert.py
3.2、查詢資料
orm_select.py
# ORM操作查詢資料
# 有了剛才Insert增加資料的經驗,那麼查詢之前的準備工作,就不用再重複了吧
# 回想一下剛才Insert時我們的操作
from my_create_table import User, engine
from sqlalchemy.orm import sessionmaker
Session = sessionmaker(engine)
db_session = Session()
# 1. select * from user 查詢user表中的所有資料
# 文法是這樣的 使用 db_session 會話 執行User表 query(User) 取出全部資料 all()
user_all_list = db_session.query(User).all()
print(user_all_list) # [<my_create_table.User object at 0x0000016D7C4BCDD8>, ......]
# 如何檢視user_all_list其中的資料呢? 循環呗
for obj in user_all_list:
print(obj.id, obj.name) # ORM對象 直接使用調用屬性的方法 拿出對應字段的值
db_session.close() # 關閉會話
# 2. select * from user where id >= 5
# 文法是這樣的 使用 db_session 會話 執行User表 query(User) 篩選内容User.id >=20 的資料全部取出 all()
user_all_list = db_session.query(User).filter(User.id >= 5).all()
print(user_all_list)
for obj in user_all_list:
print(obj.id, obj.name)
db_session.close() # 關閉會話
# 3. 除了取出全部還可以隻取出一條，不用循環，直接通過調用屬性方法得到字段值
user = db_session.query(User).filter(User.id >= 5).first()
print(user.id, user.name)
db_session.close() # 關閉會話
# 4. 烏龍 之 忘了取出資料......
wulong1 = db_session.query(User).filter(User.id >= 5)
print(wulong1)
# SELECT user.id AS user_id, user.name AS user_name
# FROM user
# WHERE user.id >= %(id_1)s
# 我忘了取出資料了!!!哎? wulong1給我顯示了原生SQL語句,因禍得福了
wulong2 = db_session.query(User)
print(wulong2)
# SELECT user.id AS user_id, user.name AS user_name
# FROM user
# 我又忘了取出資料了!!! 哎? wulong2給我顯示了原生SQL語句,因禍得福了
db_session.close() # 關閉會話
orm_select.py
3.3、修改資料
orm_update.py
# 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="NB李四" WHERE id=2 更新一條資料
# 文法是這樣的 :
# 使用 db_session 執行User表 query(User) 篩選 User.id = 2 的資料 filter(User.id == 2)
# 将name字段的值改為"NB李四" update({"name":"NB李四"})
res = db_session.query(User).filter(User.id == 2).update({"name":"NB李四"})
print(res) # 1 res就是我們目前這句更新語句所更新的行數
# 注意注意注意
# 這裡一定要将db_session中的執行語句進行送出,因為你這是要對資料中的資料進行操作
# 資料庫中 增 改 删 都是操作,也就是說執行以上三種操作的時候一定要commit
db_session.commit()
db_session.close()
# 更新多條
res = db_session.query(User).filter(User.id <= 3).update({"name":"NB李四"})
print(res) # 3 res就是我們目前這句更新語句所更新的行數
db_session.commit()
db_session.close()
orm_update.py
3.4、删除資料
# ORM 删除一條多條資料
# 老規矩
# 導入 ORM 建立會話
from my_create_table import User,engine
from sqlalchemy.orm import sessionmaker
Session = sessionmaker(engine)
db_session = Session()
# DELETE FROM `user` WHERE id=2
res = db_session.query(User).filter(User.id==2).delete()
print(res) # 1 res表示執行此語句更改的資料行數
db_session.commit() # 删除操作記得commit
db_session.close() # 關閉會話
orm_delete.py
3.5、進階查詢資料操作（部分查詢實際項目中可以用到，但目前未用過）
orm_select_more.py
# 進階版查詢操作,厲害了哦
# 老規矩
from my_create_table import User, engine
from sqlalchemy.orm import sessionmaker
Session = sessionmaker(engine)
db_session = Session()
# 查詢資料表操作
# and or
from sqlalchemy.sql import and_ , or_
ret = db_session.query(User).filter(and_(User.id > 3, User.name == '小紅')).all()
print(ret) # [<my_create_table.User object at 0x000001E2D67DCCF8>]
ret = db_session.query(User).filter(or_(User.id < 2, User.name == '小紅')).all()
print(ret) # [<my_create_table.User object at 0x000001E2D67DCCF8>]
# 查詢資料 指定查詢資料列 加入别名映射 name as username
r2 = db_session.query(User.name.label('username'), User.id).first()
print(r2.id, r2.username) # 這裡要寫别名"username"了
# 表達式篩選條件
r3 = db_session.query(User).filter(User.name == "小蘭").all()
print(r3) # [<my_create_table.User object at 0x0000024985DD0128>]
# 原生SQL篩選條件
r4 = db_session.query(User).filter_by(name='王五').all()
r5 = db_session.query(User).filter_by(name='王五').first()
print(r4) # [<my_create_table.User object at 0x0000026545B9D3C8>]
print(r5) # <my_create_table.User object at 0x0000026545B9D3C8>
# 字元串比對方式篩選條件 并使用 order_by進行排序
from sqlalchemy.sql import text
r6 = db_session.query(User).filter(text("id<:value and name=:name")).params(value=10, name='小紅').order_by(User.id).all()
print(r6) # [<my_create_table.User object at 0x0000028C032ABDD8>]
#原生SQL查詢
r7 = db_session.query(User).from_statement(text("SELECT * FROM User where name=:name")).params(name='DragonFire').all()
print(r7) # [<my_create_table.User object at 0x0000028C032ABDD8>]
# 篩選查詢列
# query的時候我們不再使用User ORM對象,而是使用User.name來對内容進行選取
user_list = db_session.query(User.name).all()
print(user_list)
# [('NB李四',), ('何炅',), ('孫紅雷',), ('小蘭',), ('小紅',), ......]
for row in user_list:
print(row.name)
# 排序 :
user_list = db_session.query(User).order_by(User.id).all() # 預設升序 # 也可以使用 asc() 方法升序
user_list = db_session.query(User).order_by(User.id.desc()).all() # 根據id降序
for row in user_list:
print(row.name,row.id)
# 其他查詢條件
"""
ret = session.query(User).filter_by(name='DragonFire').all()
ret = session.query(User).filter(User.id > 1, User.name == 'DragonFire').all()
ret = session.query(User).filter(User.id.between(1, 3), User.name == 'DragonFire').all() # between 大于1小于3的
ret = session.query(User).filter(User.id.in_([1,3,4])).all() # in_([1,3,4]) 隻查詢id等于1,3,4的
ret = session.query(User).filter(~User.id.in_([1,3,4])).all() # ~xxxx.in_([1,3,4]) 查詢不等于1,3,4的
ret = session.query(User).filter(User.id.in_(session.query(User.id).filter_by(name='DragonFire'))).all() 子查詢
from sqlalchemy import and_, or_
ret = session.query(User).filter(and_(User.id > 3, User.name == 'DragonFire')).all()
ret = session.query(User).filter(or_(User.id < 2, User.name == 'DragonFire')).all()
ret = session.query(User).filter(
or_(
User.id < 2,
and_(User.name == 'eric', User.id > 3),
User.extra != ""
)).all()
# select * from User where id<2 or (name="eric" and id>3) or extra != ""
# 通配符
ret = db_session.query(User).filter(User.name.like('e%')).all()
ret = db_session.query(User).filter(~User.name.like('e%')).all()
# 限制
ret = db_session.query(User)[1:2]
# 排序
ret = db_session.query(User).order_by(User.name.desc()).all()
ret = db_session.query(User).order_by(User.name.desc(), User.id.asc()).all()
# 分組
from sqlalchemy.sql import func
ret = db_session.query(User).group_by(User.extra).all()
ret = db_session.query(
func.max(User.id),
func.sum(User.id),
func.min(User.id)).group_by(User.name).all()
ret = db_session.query(
func.max(User.id),
func.sum(User.id),
func.min(User.id)).group_by(User.name).having(func.min(User.id) >2).all()
"""
db_session.close() # 關閉連接配接
orm_select_more.py
3.6、進階修改資料操作 （進階的優秀操作，适用于給表中的資料添加部分相同的頭或者尾之類的）
orm_update_more.py
#進階版更新操作
from my_create_table import User,engine
from sqlalchemy.orm import sessionmaker
Session = sessionmaker(engine)
db_session = Session()
#直接修改
db_session.query(User).filter(User.id > 0).update({"name" : "099"})
#在原有值基礎上添加 - 1
db_session.query(User).filter(User.id > 0).update({User.name: User.name + "099"}, synchronize_session=False)
#在原有值基礎上添加 - 2
db_session.query(User).filter(User.id > 0).update({"age": User.age + 1}, synchronize_session="evaluate")
db_session.commit()
orm_update_more.py
4、一對多的操作：ForeignKey
4.1、建立資料表及關系relationship
relationship 不是字段,隻是關系,backref是反向關聯的關鍵字
查出來是個清單
my_ForeignKey.py
from sqlalchemy.ext.declarative import declarative_base
Base = declarative_base()
# 這次我們要多導入一個 ForeignKey 字段了,外鍵關聯對了
from sqlalchemy import Column, Integer, String, ForeignKey
# 還要從orm 中導入一個 relationship 關系映射
from sqlalchemy.orm import relationship
class ClassTable(Base):
__tablename__="classtable"
id = Column(Integer, primary_key=True)
name = Column(String(32), index=True)
class Student(Base):
__tablename__="student"
id = Column(Integer, primary_key=True)
name = Column(String(32), index=True)
# 關聯字段,讓class_id 與 class 的 id 進行關聯,主外鍵關系(這裡的ForeignKey一定要是表名.id不是對象名)
class_id = Column(Integer, ForeignKey("classtable.id"))
# 将student 與 classtable 建立關系 這個不是字段,隻是關系,backref是反向關聯的關鍵字
stu2class = relationship("ClassTable", backref="class2stu")
from sqlalchemy import create_engine
engine = create_engine("mysql+pymysql://root:[email protected]:3306/wll?charset=utf8")
Base.metadata.create_all(engine)
my_ForeignKey.py
4.2、基于relationship添加資料 （relationship的正反向應用）
orm_ForeignKey_insert.py
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()
# 添加一個學生 "孫紅雷" 班級是 OldBoyS1
# 查詢要添加到的班級
class_obj = db_session.query(ClassTable).filter(ClassTable.name == "OldBoyS1").first()
# 建立學生
stu = Student(name="孫紅雷",class_id = class_obj.id)
db_session.add(stu)
db_session.commit()
# 2. relationship版 正向添加資料
# 通過關系列 stu2class 可以做到兩件事
# 第一件事 在ClassTable表中添加一條資料
# 第二件事 在Student表中添加一條資料并将剛剛添加的ClassTable的資料id填寫在Student的class_id中
stu_cla = Student(name="黃渤", stu2class=ClassTable(name="OldBoyS3"))
db_session.add(stu_cla)
db_session.commit()
# 3.relationship版 反向添加資料
# 首先建立ClassTable資料
class_obj = ClassTable(name="OldBoyS4")
# 通過class_obj中的反向關聯字段backref - class2stu
# 向 Student 資料表中添加 2條資料 并将 2條資料的class_id 寫成 class_obj的id
class_obj.class2stu = [Student(name="BMW"),Student(name="Audi")]
db_session.add(class_obj)
db_session.commit()
db_session.close() # 關閉連接配接
orm_ForeignKey_insert.py
4.3、基于relationship查詢資料 relationship的正反向查詢應用）
orm_ForeignKey_select.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 stu in student_list:
# stu.stu2class.name 通過Student對象中的關系字段relationship stu2class 擷取關聯 ClassTable中的name
print(stu.name, stu.stu2class.name, stu.class_id)
# 孫紅雷 OldBoyS1 1
# 黃渤 OldBoyS3 3
# BMW OldBoyS4 4
# Audi OldBoyS4 4
# 2.反向查詢
class_list = db_session.query(ClassTable).all()
for cla in class_list:
for stu in cla.class2stu:
print(cla.name, stu.name)
# cla.class2stu 通過 backref 中的 class2stu 反向關聯到 Student 表中根據ID擷取name
# OldBoyS1 孫紅雷
# OldBoyS3 黃渤
# OldBoyS4 BMW
# OldBoyS4 Audi
db_session.close()
orm_ForeignKey_select.py
4.4、更新資料
orm_ForeignKey_update.py
from my_ForeignKey import Student, ClassTable, engine
from sqlalchemy.orm import sessionmaker
DB_session = sessionmaker(engine)
db_session = DB_session()
# 更新
class_obj = db_session.query(ClassTable).filter(ClassTable.name=="OldBoyS1").first()
db_session.query(Student).filter(Student.class_id == class_obj.id).update({"name":"孫雷雷"})
db_session.commit()
db_session.close()
orm_ForeignKey_update.py
4.5、删除資料
from my_ForeignKey import Student, ClassTable,engine
from sqlalchemy.orm import sessionmaker
DB_session = sessionmaker(engine)
db_session = DB_session()
# 删除
class_obj = db_session.query(ClassTable).filter(ClassTable.name=="OldBoyS1").first()
db_session.query(Student).filter(Student.class_id == class_obj.id).delete()
db_session.commit()
db_session.close()
orm_ForeignKey_delete.py
5、多對多的操作：ManyToMany
5.1、建立表及關系
my_M2M.py
from sqlalchemy.ext.declarative import declarative_base
Base = declarative_base()
from sqlalchemy import Column,Integer,String,ForeignKey
from sqlalchemy.orm import relationship
class Girl(Base):
__tablename__="girl"
id = Column(Integer, primary_key=True)
name = Column(String(32), index=True)
# 建立關系
girl2boy = relationship("Boy", secondary="hotel", backref="boy2girl")
class Boy(Base):
__tablename__="boy"
id = Column(Integer, primary_key=True)
name = Column(String(32), index=True)
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"))
from sqlalchemy import create_engine
engine = create_engine("mysql+pymysql://root:[email protected]:3306/wll?charset=utf8")
Base.metadata.create_all(engine)
my_M2M.py
5.2、基于relationship添加資料
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資料 反向
boy_obj = Boy(name="DragonFire")
boy_obj.boy2girl = [Girl(name="趙麗穎"),Girl(name="Angelababy")]
db_session.add(boy_obj)
db_session.commit()
db_session.close()
# 2.通過Girl添加Boy和Hotel資料 正向
girl_obj = Girl(name="珊珊", girl2boy=[Boy(name="鋼蛋兒"), Boy(name="糞球兒")])
db_session.add(girl_obj)
db_session.commit()
db_session.close()
orm_M2M_insert.py
5.3、基于relationship查詢資料
orm_M2M_select.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
boys = db_session.query(Boy).all()
for boy in boys:
for girl in boy.boy2girl:
print(boy.name, girl.name)
# 2.通過Girl查詢約會過的所有Boy
girls = db_session.query(Girl).all()
for girl in girls:
for boy in girl.girl2boy:
print(girl.name, boy.name)
orm_M2M_select.py
6. db加載位置的差別
如圖，當使用方式二加載db時 ，需要依靠上下文環境。而使用方式一時，不需要。
原因是 通過方式二建立的db，開始并沒有拿到app裡面儲存的config資料庫資訊。是後面加載進來的，而後加載進來的不會儲存到db裡面，導緻每次查詢都需要在上下文環境中通過current_app方式去找配置資訊
可通過這種方式解決：
建立外鍵的時候注意：
注意
ForeignKey
要傳遞的是資料庫中的真實表名和字段名
關聯查詢
- 使用
ForeignKey
其實
ForeignKey
的作用就基本是SQL原生語句中的
left jion
的作用
class User(db.Model):
...
profile = db.relationship('UserProfile', uselist=False)
followings = db.relationship('Relation')
## 一對一
class UserProfile(db.Model):
id = db.Column('user_id', db.Integer, db.ForeignKey('user_basic.user_id'), primary_key=True, doc='使用者ID')
...
class Relation(db.Model):
user_id = db.Column(db.Integer, db.ForeignKey('user_basic.user_id'), doc='使用者ID')
...
# 測試
user = User.query.get(1)
user.profile.gender
user.followings
# user1 -> User
# user1.mobile
#
# user1.profile -> user1資料有關 關聯表UserProfile中具體資料 UserProfile類的對象
外鍵的形式有一對一， 一對多， 多對多
實際上将一對多加上條件
unique=True
，就是一對一的外鍵
因為外鍵(ForeignKey)始終定義在多的一方.如果relationship定義在多的一方,那就是多對一,一對多與多對一的差別在于其關聯(relationship)的屬性在多的一方還是一的一方，如果relationship定義在一的一方那就是一對多.
外鍵在子表中建立，
relationship
在主表中建立, 以誰為主，就在誰中建立relationship，有可能兩張表都分别建立
模型類中有外鍵，僅僅是查詢時指明相關聯的字段
解讀：建立外鍵是使
UserProfile
的
id
與
user_basic.user_id
産生關聯關系，如果想要觸發關聯查詢，需要在主表中，設定關聯關系
relationship
去額外聲明一個字段
profile
。當
user1.profile
時，就會觸發關聯查詢，把從表中的資料查出來
relationship
是為了簡化聯合查詢join等，建立的兩個表之間的虛拟關系，這種關系與标的結構時無關的。他與外鍵十分相似，必須在外鍵的基礎上才允許使用
relationship的使用：
- 使兩個表之間産生管理，類似于合成一張表，可以直接取出關聯的表，進行擷取資料，而不需要
join
- 隻使用外鍵，需要使用join才可以取出資料
#上面不存在relationship
ret = session.query(Father.name.label('kkk'),Son.name.label("ppp")).join(Son).all()#使用Join才可以擷取對方資料
print(ret)#是一個清單，清單中存在所要擷取的資料（以元組存在）
- 在外鍵基礎上使用
relationship
#使用了relationship
ret = session.query(Father).filter_by(id=1).first()
print(ret.son)#是一個對象清單，其中包含了所有查詢資料
執行個體：
查詢使用者1 的關注者的資料資訊
class UserProfile(db.Model):
"""
使用者資料表
"""
__tablename__ = 'user_profile'
class GENDER:
MALE = 0
FEMALE = 1
id = db.Column('user_id', db.Integer, primary_key=True, doc='使用者ID')
gender = db.Column(db.Integer, default=0, doc='性别')
birthday = db.Column(db.Date, doc='生日')
real_name = db.Column(db.String, doc='真實姓名')
id_number = db.Column(db.String, doc='身份證号')
id_card_front = db.Column(db.String, doc='身份證正面')
id_card_back = db.Column(db.String, doc='身份證背面')
id_card_handheld = db.Column(db.String, doc='手持身份證')
ctime = db.Column('create_time', db.DateTime, default=datetime.now, doc='建立時間')
utime = db.Column('update_time', db.DateTime, default=datetime.now, onupdate=datetime.now, doc='更新時間')
register_media_time = db.Column(db.DateTime, doc='注冊自媒體時間')
area = db.Column(db.String, doc='地區')
company = db.Column(db.String, doc='公司')
career = db.Column(db.String, doc='職業')
class Relation(db.Model):
"""
使用者關系表
"""
__tablename__ = 'user_relation'
class RELATION:
DELETE = 0
FOLLOW = 1
BLACKLIST = 2
id = db.Column('relation_id', db.Integer, primary_key=True, doc='主鍵ID')
user_id = db.Column(db.Integer, doc='使用者ID')
target_user_id = db.Column(db.Integer, doc='目标使用者ID')
relation = db.Column(db.Integer, doc='關系')
ctime = db.Column('create_time', db.DateTime, default=datetime.now, doc='建立時間')
utime = db.Column('update_time', db.DateTime, default=datetime.now, onupdate=datetime.now, doc='更新時間')
# `relationship`在主表中建立, 以誰為主，就在誰中建立relationship，有可能兩張表都分别建立
user = db.relationship('User', primaryjoin='Relation.target_user_id==foreign(User.id)')
# user1 -> User
# user1.mobile
#
# user1.profile -> user1資料有關 關聯表UserProfile中具體資料 UserProfile類的對象
# user1.following
# user_id=1 > target_user_id = 1,2,3
# select a.user_id,a.target_user_id,b.user_name from user_relation as a inner join user_basic as b on a.target_user_id=b.user_id where a.user_id=1;
# ret = Relation.query.join(Relation.user).options(load_only(Relation.user_id, Relation.target_user_id),
# contains_eager(Relation.user).load_only(User.name)).filter(Relation.user_id==1).all()
# [<Relation obj> <Relation obj>..]
更新
方式一
user = User.query.get(1)
user.name = 'Python'
db.session.add(user)
db.session.commit()
方式二
注意：
update({'name':'python'})
中是一個字典
User.query.filter_by(id=1).update({'name':'python'})
db.session.commit()
4 删除
方式一
user = User.query.order_by(User.id.desc()).first()
db.session.delete(user)
db.session.commit()
方式二
User.query.filter(User.mobile='18512345678').delete()
db.session.commit()