多JOIN的SQLAlchemy查询按降序返回重复行，升序无重复

针对你遇到的SQLAlchemy多表JOIN查询升序无重复、降序重复的问题，以下是具体排查方向和解决办法：

可能的原因 #

• JOIN关联条件不严谨：如果关联时未指定明确的外键或匹配条件，会触发笛卡尔积，导致结果集产生大量重复行。升序时重复行连续排列可能被误判为无重复，而降序时行顺序打乱后重复问题凸显。
• 排序键存在重复值：当table1.c.column1有大量重复值时，数据库返回的结果集顺序不稳定，可能导致你误以为是行重复（实际是相同排序键的行顺序变化）。
• Core查询的行对象展示问题：使用Core查询返回Row对象时，若仅关注主表字段，可能忽略关联表的差异，误将主表字段相同但关联表字段不同的行视为重复。

解决方案 #

1. 校验并修正JOIN关联条件 #

确保每个JOIN都有明确的关联逻辑，避免隐式或错误的关联：

# 示例：明确指定关联键
stmt = select([table1, table2, table3]).select_from(
    table1.join(table2, table1.c.id == table2.c.table1_id)
          .join(table3, table2.c.id == table3.c.table2_id)
).order_by(table1.c.column1.desc())

2. 使用distinct()强制去重 #

如果需要返回唯一的主表行，可指定主表主键作为去重依据；若要基于所有选中字段去重，直接调用distinct()：

# 按主表主键去重
stmt = select([table1, table2, table3]).select_from(
    table1.join(table2).join(table3)
).order_by(table1.c.column1.desc()).distinct(table1.c.id)

# 按所有选中字段去重
stmt = select([table1, table2, table3]).select_from(
    table1.join(table2).join(table3)
).order_by(table1.c.column1.desc()).distinct()

3. 改用ORM查询关联加载（推荐） #

如果使用SQLAlchemy ORM，通过joinedload加载关联对象，SQLAlchemy会自动处理主表行的重复问题：

from sqlalchemy.orm import joinedload

# 假设Table1是ORM模型类，关联Table2和Table3
stmt = select(Table1).options(
    joinedload(Table1.table2),
    joinedload(Table1.table2.table3)
).order_by(Table1.column1.desc())

4. 验证结果集的实际差异 #

打印升序和降序结果的完整字段，确认是否真的是重复行：

# 执行升序查询并打印前5行
stmt_asc = select([table1, table2, table3]).select_from(
    table1.join(table2).join(table3)
).order_by(table1.c.column1.asc())
for row in conn.execute(stmt_asc).fetchall()[:5]:
    print(row)

# 执行降序查询并打印前5行
stmt_desc = select([table1, table2, table3]).select_from(
    table1.join(table2).join(table3)
).order_by(table1.c.column1.desc())
for row in conn.execute(stmt_desc).fetchall()[:5]:
    print(row)

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