知識要點:
1.多表查詢
2.原生SQL的查詢
多表查詢
在MySQL中我們講了多表查詢遥椿,在SQLAlchemy中也有多表查詢的概念
將我們之前創(chuàng)建好的五張表導入進來嗦篱,這五張表有些有聯(lián)系,有些表之間是沒有聯(lián)系的耗溜。
from db_connect import Base,session
from info import Department,Student,Course,Stu_details,stu_course
# 無聯(lián)系的兩張的查詢痴鳄,只要給出關聯(lián)條件就可以查詢
rs = session.query(Department.d_id,Department.d_name,
Course.c_id,Course.c_name).filter(Department.d_id==Course.c_id).all()
#也可以使用join
rs = session.query(Student.s_name,Course.c_name).join(Course,
Student.d_id==Course.c_id).all()
#多表查詢
rs = session.query(Student.s_name,Course.c_name).join(stu_course).filter(Student.s_id==stu_course.c.s_id,
Course.c_id==stu_course.c.c_id).all()
print(rs)
原生SQL的操作
在實際的使用過程中,有些時候可能會遇到用SQLAlchemy不能夠很好利用數據庫的特性县貌,或者需要寫很多關聯(lián)的時候术陶,我們也可以寫原生的SQL,然后使用SQLAlchemy去執(zhí)行煤痕。
第一種:使用 Engine/ConnectionPooling/Dialect 進行數據庫操作梧宫,Engine使用ConnectionPooling連接數據庫征候,然后再通過Dialect執(zhí)行SQL語句。
from db_connect import engine
# 插入數據
engine.execute(
"INSERT INTO department(d_name) VALUES('設計')"
)
engine.execute(
"INSERT INTO course(c_name) VALUES ('音樂鑒賞'),('就業(yè)指導')"
)
# 改
engine.execute(
"UPDATE student SET d_id=3 WHERE s_id=4"
)
# 刪
engine.execute(
"DELETE FROM course WHERE c_id=4"
)
# 查
rs = engine.execute(
"SELECT * FROM student"
)
print(rs.fetchone())
print(rs.fetchall())
第二種:使用 Schema Type/SQL Expression Language/Engine/ConnectionPooling/Dialect 進行數據庫操作祟敛。Engine使用Schema Type創(chuàng)建一個特定的結構對象疤坝,之后通過SQL Expression Language將該對象轉換成SQL語句,然后通過 ConnectionPooling 連接數據庫馆铁,再然后通過 Dialect 執(zhí)行SQL跑揉,并獲取結果。
from db_connect import engine,Base
from sqlalchemy import Column,Integer,String,ForeignKey,Table
#創(chuàng)建user數據表
user = Table('user',Base.metadata,
Column('id',Integer,primary_key=True),
Column('name',String(20)),
)
Base.metadata.create_all()
# 創(chuàng)建連接
conn = engine.connect()
# 插入數據
sql = user.insert().values(name='rose')
conn.execute(sql)
conn.close()
# 刪除數據
sql = user.delete().where(user.c.id==2)
conn.execute(sql)
conn.close()
# 更新數據
sql = user.update().where(user.c.name=='xiaoming').values(name='xiaohong')
conn.execute(sql)
conn.close()