如何在SQLAlchemy中连接来自不同查询的两个表

AI 小北

2026-8-30

错误根因

你的代码逻辑存在两个明显问题：

db.session.execute(query) 返回的是数据库结果游标对象，不是你类型标注里写的实体列表，直接把这个对象丢给query()方法，ORM无法将其识别为可查询的数据源。
你先单独执行两次查询把数据拉到内存，后面又调用ORM的查询接口做数据库层面的join，逻辑完全割裂——内存中的Python列表不能直接作为ORM查询的表参数使用。

修复方案

二选一即可，优先选方案1性能更好。

方案1：数据库侧完成join（推荐）

不要拆分两次查询，直接把两个查询作为子查询，在数据库端完成关联后再拉取结果，减少网络IO开销：

# 将两个预定义查询转为可关联的子查询
t1_sub = query1.subquery()
t2_sub = query2.subquery()

# 基于id字段做join，子查询字段通过.c属性访问
result = db.session.query(t1_sub, t2_sub).join(
    t2_sub, t1_sub.c.id == t2_sub.c.id
).all()

方案2：内存侧做关联（适配必须提前单独查两个列表的场景）

如果你因为业务逻辑必须先拿到两个独立的结果列表，就不要再走ORM查询接口，直接在Python内存中做匹配：

# 先把execute返回的游标结果转成实际的ORM实体列表
table1: List[Table1] = db.session.execute(query1).scalars().all()
table2: List[Table2] = db.session.execute(query2).scalars().all()

# 构建id到table2记录的索引，避免双层循环的性能损耗
t2_index = {}
for item in table2:
    t2_index.setdefault(item.id, []).append(item)

# 遍历匹配关联结果
join_result = []
for t1_item in table1:
    for t2_item in t2_index.get(t1_item.id, []):
        join_result.append( (t1_item, t2_item) )