操作步骤

第一步：获得会话对象

在sqlalchemy中除了利用Connection对象进行原生sql操作外，还可以通过Session对象进行原生sql操作。

from sqlalchemy import create_engine
from sqlalchemy.orm import Session
# 创建数据库引擎
dburl = 'mysql+pymysql://root:123456@127.0.0.1:3306/testdb'
engine = create_engine(url=dburl)
# 创建会话对象
session = Session(engine)

第二步：利用text函数创建原生sql

利用sqlalchemy中的text函数将sql字符串加工为原生sql。

from sqlalchemy import text
sql_text = text("SELECT name, age FROM student")

第三步：利用Session对象执行原生sql

利用Session实例对象的execute函数可以与数据库进行事务交互。

students = session.execute(sql_text)

第四步：关闭Session对象

由于Session对象也是一种资源，所以在事务处理完后要及时关闭资源。

session.close()

步骤整合

可以利用Python的上下文管理器的方式使用会话对象，用完后会话对象自动关闭。

with Session(engine) as session:students = session.execute(sql_text)for name, age in students:print(name,age)

数据库操作示例

参见Connection对象进行原生sql操作，而将connection改为session即可。

词库加载错误:未能找到文件“E:\highferrum_mysql\Configuration\Dict_Stopwords.txt”。

上一篇：金科股份：全力以“付”，兑现城市美好生活金科股份永不止步将美好延续金科股份商业地产

下一篇：年报解读 | 保利置业：控杠杆以防风险，稳经营而后谋发展一图看懂保利置业2022年度业绩保利房地产第三季度报告

sqlalchemy_No4_利用原生SQL与数据库交互_Session对象实现

文章目录