知識(shí)要點(diǎn)：

1.多表查詢

2.原生SQL的查詢

多表查詢

在MySQL中我們講了多表查詢，在SQLAlchemy中也有多表查詢的概念

將我們之前創(chuàng)建好的五張表導(dǎo)入進(jìn)來(lái)，這五張表有些有聯(lián)系，有些表之間是沒(méi)有聯(lián)系的。

from db_connect import  Base,session
from info import Department,Student,Course,Stu_details,stu_course

# 無(wú)聯(lián)系的兩張的查詢，只要給出關(guā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的操作

在實(shí)際的使用過(guò)程中，有些時(shí)候可能會(huì)遇到用SQLAlchemy不能夠很好利用數(shù)據(jù)庫(kù)的特性，或者需要寫很多關(guān)聯(lián)的時(shí)候，我們也可以寫原生的SQL，然后使用SQLAlchemy去執(zhí)行。

第一種：使用 Engine/ConnectionPooling/Dialect 進(jìn)行數(shù)據(jù)庫(kù)操作，Engine使用ConnectionPooling連接數(shù)據(jù)庫(kù)，然后再通過(guò)Dialect執(zhí)行SQL語(yǔ)句。

from db_connect import  engine

# 插入數(shù)據(jù)
engine.execute(
    "INSERT INTO department(d_name) VALUES('設(shè)計(jì)')"
)
engine.execute(
    "INSERT INTO course(c_name) VALUES ('音樂(lè)鑒賞'),('就業(yè)指導(dǎo)')"
)

# 改
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 進(jìn)行數(shù)據(jù)庫(kù)操作。Engine使用Schema Type創(chuàng)建一個(gè)特定的結(jié)構(gòu)對(duì)象，之后通過(guò)SQL Expression Language將該對(duì)象轉(zhuǎn)換成SQL語(yǔ)句，然后通過(guò) ConnectionPooling 連接數(shù)據(jù)庫(kù)，再然后通過(guò) Dialect 執(zhí)行SQL，并獲取結(jié)果。

from db_connect import  engine,Base
from sqlalchemy import Column,Integer,String,ForeignKey,Table

#創(chuàng)建user數(shù)據(jù)表
user = Table('user',Base.metadata,
             Column('id',Integer,primary_key=True),
             Column('name',String(20)),
             )

Base.metadata.create_all()

# 創(chuàng)建連接
conn = engine.connect()

# 插入數(shù)據(jù)
sql = user.insert().values(name='rose')
conn.execute(sql)
conn.close()

# 刪除數(shù)據(jù)
sql = user.delete().where(user.c.id==2)
conn.execute(sql)
conn.close()

# 更新數(shù)據(jù)
sql = user.update().where(user.c.name=='xiaoming').values(name='xiaohong')
conn.execute(sql)
conn.close()