sql - 从 SQLAlchemy 中的文件执行 SQL

Question

如何使用 SQLAlchemy 将整个 sql 文件执行到数据库中？文件中可以有许多不同的 sql 查询，包括 begin 和 commit/rollback。

Answer 1

sqlalchemy.text 或 sqlalchemy.sql.text

• text 构造提供了一种直接执行 .sql 文件的简单方法。

from sqlalchemy import create_engine
from sqlalchemy import text
# or from sqlalchemy.sql import text

engine = create_engine('mysql://{USR}:{PWD}@localhost:3306/db', echo=True)

with engine.connect() as con:
    with open("src/models/query.sql") as file:
        query = text(file.read())
        con.execute(query)

• SQLAlchemy: Using Textual SQL
  • text()