如何在Flask-SQLAlchemy应用程序中执行原始SQL

如何在SQLAlchemy中执行原始SQL ?

我有一个python web应用程序，运行在flask和接口到数据库通过SQLAlchemy。

我需要一种方法来运行原始SQL。该查询涉及多个表连接和内联视图。

我试过了:

connection = db.session.connection()
connection.execute( <sql here> )

但是我总是得到网关错误。

当前回答

result = db.engine.execute(text("<sql here>"))

执行<sql在>，但不提交它，除非你在自动提交模式。因此，插入和更新不会反映在数据库中。

要在更改后提交，请执行

result = db.engine.execute(text("<sql here>").execution_options(autocommit=True))

其他回答

如果你想避免元组，另一种方法是调用第一个，一个或所有方法:

query = db.engine.execute("SELECT * FROM blogs "
                           "WHERE id = 1 ")

assert query.first().name == "Welcome to my blog"

Flask-SQLAlchemy v: 3.0。x / SQLAlchemy v: 1.4

users = db.session.execute(db.select(User).order_by(User.title.desc()).limit(150)).scalars()

因此，对于flask-sqlalchemy的最新稳定版本，文档建议将session.execute()方法与db.select(Object)结合使用。

result = db.engine.execute(text("<sql here>"))

执行<sql在>，但不提交它，除非你在自动提交模式。因此，插入和更新不会反映在数据库中。

要在更改后提交，请执行

result = db.engine.execute(text("<sql here>").execution_options(autocommit=True))

你有没有试过:

result = db.engine.execute("<sql here>")

or:

from sqlalchemy import text

sql = text('select name from penguins')
result = db.engine.execute(sql)
names = [row[0] for row in result]
print names

注意，db.engine.execute()是“无连接的”，这在SQLAlchemy 2.0中已弃用。

你试过使用连接吗?执行(文本(<sql here>)， <绑定params here>)和绑定参数描述在文档?这可以帮助解决许多参数格式化和性能问题。也许网关错误是超时?绑定参数往往使复杂的查询执行得更快。

推荐文章