SQLAlchemy 2一对多关联查询返回重复行的问题咨询

为什么会出现重复的Location结果？ #

你执行的select(Location).join(Location.facility)在SQL层面会生成内连接查询，因为目标Location关联了2个Facility，SQL会返回2行数据（每行是Location与单个Facility的组合）。虽然SQLAlchemy ORM会把这两行映射为同一个Location实例，但session.scalars()会遍历SQL返回的所有行，所以你得到了两次同一个Location对象。而每个Location的facility属性是ORM维护的关联集合，会自动加载该位置下的所有Facility，所以两个实例的facility列表都包含全部2个设施。

两种需求的解决方式 #

需求1：获取包含所有设施列表的单个Location对象

有两种可行方案：

• 方案一：直接查询Location，利用ORM关联加载
  无需手动join，ORM会自动处理关联关系（懒加载或主动预加载）：

  # 懒加载：访问location.facility时自动触发关联查询
  stmt = select(Location).where(Location.location_pk == 6)
  location = session.scalars(stmt).one()
  # 此时location.facility即为该位置的所有设施列表
  
  # 主动预加载：通过joinedload实现一次查询完成所有数据加载，避免N+1问题
  from sqlalchemy.orm import joinedload
  stmt = select(Location).options(joinedload(Location.facility)).where(Location.location_pk == 6)
  location = session.scalars(stmt).one()
  

• 方案二：保留join，添加distinct去重
  通过distinct()让SQL返回唯一的Location记录：

  stmt = select(Location).join(Location.facility).where(Location.location_pk == 6).distinct()
  location = session.scalars(stmt).one()
  

需求2：获取每个Facility对象单独一行结果

直接查询Facility表，通过外键筛选目标位置的设施：

stmt = select(Facility).where(Facility.location_pk == 6)
facilities = session.scalars(stmt).all()
# facilities是包含2个Facility对象的列表，每个对象对应一个设施

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