使用 AsyncEngine 执行任何 SQL 查询时出现 SQLAlchemy v1.4 ObjectNotExecutableError

Question

我正在使用异步引擎。当我尝试执行任何操作时：

async with self.async_engine.connect() as con:
    query = "SELECT id, name FROM item LIMIT 50;"
    result = await con.execute(f"{query}")

我明白了：

Exception has occurred: ObjectNotExecutableError
Not an executable object: 'SELECT id, name FROM item LIMIT 50;'

---

这个问题之前是用户@stilmaniac 提出的，但现在是deleted from SO。

我在 Google 搜索缓存中找到了它，here is copy。

我有同样的问题，所以我重新问一下，但原始版本如下：

---

我正在尝试从元数据创建表，如下所示：

Base = declarative_base()

properties = Table(
    'properties', Base.metadata,
    # ...
    Column('geolocation', Geography(geometry_type='POINT', srid=4326)),
    # ... 
)

engine = create_async_engine("postgresql+asyncpg://user:password@postgres/")
async with engine.begin() as conn:
    await conn.run_sync(Base.metadata.create_all)

给我以下错误：

sqlalchemy.exc.ObjectNotExecutableError: Not an executable object: 'CREATE INDEX "idx_properties_geolocation" ON "properties" USING GIST ("geolocation")'

考虑到这个doc

版本：

• 操作系统：macOS 11.4 ARM
• SQLAlchemy：1.4.22
• Python：3.6

Answer 1

正如异常消息所暗示的，str 'SELECT id, name FROM item LIMIT 50;' 不是可执行对象。要使其可执行，请使用sqlalchemy.text 包装它。

from sqlalchemy import text

async with self.async_engine.connect() as con:
    query = "SELECT id, name FROM item LIMIT 50;"
    result = await con.execute(text(query))

async.connection.execute 要求它的语句参数

[...] 始终是在 ClauseElement 和 可执行的层次结构，包括：

• 选择

• 插入、更新、删除

• TextClause 和 TextualSelect

• DDL 和继承自 DDLElement 的对象

同步 connection.execute 方法允许使用原始字符串，但在 SQLAlchemy 2.0 中已弃用并标记为删除。