在SQLAlchemy里,父对象与子对象一般通过relationship建立关联。当我们需要同时过滤父对象和它所关联的子对象时,不能只在外层写filter,否则子对象集合往往不会被同步筛选。下面介绍几种常见且实用的做法。

使用primaryjoin固定关联条件
可以在定义relationship时,通过primaryjoin把过滤条件写死在关联上,这样每次加载子对象都会自动带上该条件。
from sqlalchemy import Column, Integer, String, ForeignKey, create_engine
from sqlalchemy.orm import relationship, sessionmaker
from sqlalchemy.ext.declarative import declarative_base
Base = declarative_base()
class Parent(Base):
__tablename__ = 'parent'
id = Column(Integer, primary_key=True)
name = Column(String)
# 只关联状态为active的子对象
children = relationship(
'Child',
primaryjoin="and_(Parent.id==Child.parent_id, Child.status=='active')"
)
class Child(Base):
__tablename__ = 'child'
id = Column(Integer, primary_key=True)
parent_id = Column(Integer, ForeignKey('parent.id'))
status = Column(String)
engine = create_engine('sqlite:///:memory:')
Base.metadata.create_all(engine)
Session = sessionmaker(bind=engine)
session = Session()
# 查询父对象时,children里只有status为active的记录
parents = session.query(Parent).all()
使用contains_eager同步过滤
如果过滤条件是动态的,可以先用join过滤子对象,再通过contains_eager告诉SQLAlchemy用查询结果填充关联属性。
from sqlalchemy.orm import contains_eager
# 查询父对象,并且只加载status为active的子对象
query = (
session.query(Parent)
.join(Parent.children)
.filter(Child.status == 'active')
.options(contains_eager(Parent.children))
)
result = query.all()
使用子查询作为过滤条件
当父对象本身也需要根据子对象条件过滤时,可以借助子查询实现父子同时约束。
from sqlalchemy import exists
# 只取有active子对象的父对象,且子对象也被过滤
subq = session.query(Child).filter(
Child.parent_id == Parent.id,
Child.status == 'active'
).exists()
parents = session.query(Parent).filter(exists(subq)).all()
for p in parents:
p.children = session.query(Child).filter(
Child.parent_id == p.id,
Child.status == 'active'
).all()
总结对比
| 方式 | 适用场景 | 是否动态 |
|---|---|---|
| primaryjoin | 关联条件固定 | 否 |
| contains_eager | 一次查询父与子并同步过滤 | 是 |
| 子查询exists | 父对象自身也依赖子对象条件 | 是 |
通过上述方法,你可以根据实际业务灵活选择,在SQLAlchemy中干净地实现父对象及其关联子对象的同时过滤。
SQLAlchemyrelationshipfilter修改时间:2026-07-29 23:45:11