在SQLAlchemy的ORM查询场景中，动态WHERE子句的构建是非常常见的需求。当业务需要根据用户传入的可选参数灵活调整查询过滤条件时，固定的查询语句无法适配多变的筛选逻辑，因此需要掌握动态拼接条件的方法。
基础条件收集法
这种方法的核心思路是先创建一个空的条件列表，然后根据实际传入的参数判断是否需要添加对应的过滤条件，最后将列表中的条件传入查询的filter方法中。
首先定义基础的模型类，以下面的用户模型为例：
from sqlalchemy import create_engine, Column, Integer, String, Boolean
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy.orm import sessionmaker
Base = declarative_base()
class User(Base):
__tablename__ = 'users'
id = Column(Integer, primary_key=True)
name = Column(String(50))
is_active = Column(Boolean, default=True)
age = Column(Integer)
接下来实现动态查询函数，根据传入的可选参数构建条件：
def query_users(session, name=None, is_active=None, age_min=None):
# 初始化条件列表
filters = []
# 根据参数动态添加条件
if name is not None:
filters.append(User.name == name)
if is_active is not None:
filters.append(User.is_active == is_active)
if age_min is not None:
filters.append(User.age >= age_min)
# 执行查询，将条件列表展开传入filter
query = session.query(User)
if filters:
query = query.filter(*filters)
return query.all()
这种方法的优势是逻辑简单直观，适合条件数量不多且逻辑简单的场景。当所有条件都是AND关系时，使用起来非常方便。
使用and_和or_组合复杂条件
当动态条件中需要同时存在AND和OR的逻辑关系时，就需要用到SQLAlchemy提供的and_和or_函数来组合条件。
首先导入对应的函数：
from sqlalchemy import and_, or_
假设业务需求是查询满足以下条件的用户：名称为指定值，并且（状态为激活 或者 年龄大于指定值），对应的动态查询实现如下：
def query_users_complex(session, name=None, is_active=None, age_min=None):
filters = []
# 处理名称条件
if name is not None:
filters.append(User.name == name)
# 处理OR组合的条件
or_conditions = []
if is_active is not None:
or_conditions.append(User.is_active == is_active)
if age_min is not None:
or_conditions.append(User.age >= age_min)
# 如果有OR条件，将其添加到总条件列表
if or_conditions:
filters.append(or_(*or_conditions))
# 执行查询
query = session.query(User)
if filters:
# 多个顶层条件默认是AND关系，也可以用and_显式包裹
query = query.filter(and_(*filters))
return query.all()
这种方式可以灵活组合多层嵌套的条件逻辑，满足复杂的动态筛选需求。
字典参数动态生成条件
如果动态条件的参数以字典形式传入，也可以通过遍历字典的方式自动生成对应的过滤条件，减少重复的判空代码。
实现示例如下：
def query_users_by_dict(session, filter_dict):
filters = []
# 定义字段和模型属性的映射关系
field_map = {
'name': User.name,
'is_active': User.is_active,
'age': User.age
}
for field, value in filter_dict.items():
if field in field_map and value is not None:
# 这里可以根据需求扩展不同的比较逻辑，比如大于、小于等
filters.append(field_map[field] == value)
query = session.query(User)
if filters:
query = query.filter(*filters)
return query.all()
使用时只需要传入对应的字典参数即可：
# 查询名称为张三且状态为激活的用户
result = query_users_by_dict(session, {'name': '张三', 'is_active': True})
注意事项
- 动态构建条件时要注意避免SQL注入风险，SQLAlchemy的ORM条件拼接是参数化的，只要不直接拼接字符串作为条件就不会有问题。
- 如果条件中包含范围查询（比如时间范围、数值范围），需要单独处理比较符号，不要统一使用等于判断。
- 当条件列表为空时，直接调用filter不会报错，会返回全量数据，需要根据业务需求决定是否要添加默认条件。
通过以上几种方法，可以覆盖大部分SQLAlchemy动态WHERE子句的构建场景，开发者可以根据实际的业务复杂度选择合适的方式。
SQLAlchemy动态_WHERE_子句ORMPython数据库查询修改时间：2026-07-04 22:39:23