SQLAlchemy ORM多关联查询特定列报错，求Pythonic解决方案

错误原因 #

你遇到的ArgumentError核心问题是混用了SQLAlchemy的两种查询API：

• session.query()是SQLAlchemy旧版ORM查询接口，要求传入列表达式、实体类等作为查询目标
• 你传入的select(...)是SQLAlchemy 2.0+引入的Core/ORM统一查询构造器，本身就是一个完整的查询对象，不能嵌套在session.query()中使用

正确写法 #

方式1：使用SQLAlchemy 2.0+ 推荐的select() API（更Pythonic） #

直接构造select语句，通过session.execute()执行：

from sqlalchemy import select, Date, cast

# 构造查询语句
stmt = select(
    payment_plans.payment_plan_id,
    payment_plans.plan_id,
    payment_plans.amount,
    invoices.promo_code,
    users.sso_guid,
    users.user_id,
).join(users, payment_plans.user_id == users.user_id) \
 .join(invoices, payment_plans.invoice_id == invoices.invoice_id) \
 .where(cast(payment_plans.due_date, Date) < '2022-01-01') \
 .where(payment_plans.status.in_(["pending", "failed"]))

# 执行并获取结果
result = session.execute(stmt)
# 可选：将结果转为字典列表，方便访问
rows = result.mappings().all()

关键细节：

• 原SQL中的due_date::date类型转换，对应ORM里的cast(payment_plans.due_date, Date)
• SQL的IN条件需使用SQLAlchemy提供的in_()方法，而非Python原生in

方式2：使用传统session.query()写法 #

如果习惯旧版语法，直接向session.query()传入要查询的列：

from sqlalchemy import Date, cast

orm_query = session.query(
    payment_plans.payment_plan_id,
    payment_plans.plan_id,
    payment_plans.amount,
    invoices.promo_code,
    users.sso_guid,
    users.user_id,
).join(users, payment_plans.user_id == users.user_id) \
 .join(invoices, payment_plans.invoice_id == invoices.invoice_id) \
 .filter(cast(payment_plans.due_date, Date) < '2022-01-01') \
 .filter(payment_plans.status.in_(["pending", "failed"]))

# 执行查询
rows = orm_query.all()

错误提示补充说明 #

报错信息中提到的use the .subquery() method是指当你需要把一个Select对象作为子查询嵌入到另一个查询时，才需要调用.subquery()，但这不是你当前场景的需求，你只需要直接执行构造好的查询即可。

内容的提问来源于stack exchange，提问作者joween