Django自定义Athena管理器where_conditions未重置致SQL无效问题

在开发与Athena交互的自定义DRF管理器时，每次携带过滤器请求接口，_where_conditions列表会持续追加条件而非重置，生成的SQL语句因此失效，需要实现每次请求时重置该列表。

问题根源 #

查询对象（BaseModelQuery）可能被跨请求复用，或者filter/order_by等方法仅追加条件未清空旧状态，导致多次请求的条件累积。现有filter方法虽尝试重置_where_conditions，但order_by、分页等方法未同步处理状态重置，且未从根源确保每个请求使用独立的查询实例。

解决方案 #

1. 完善条件重置逻辑

修改BaseModelQueryset中的filter和order_by方法，确保每次调用时先清空对应条件列表：

def filter(self, filter_input=None, **kwargs):
    # 每次filter时清空where条件
    self._query._where_conditions = []
    if filter_input:
        self._query.add_where(filter_input)
    else:
        self._query.add_where(ModelQueryUtils.FilterInput(kwargs, ModelQueryUtils.FilterInput.JoinOperator.AND))
    return self

def order_by(self, *args, order_input=None):
    # 每次order_by时清空排序条件
    self._query._order_conditions = []
    if order_input:
        self._query.add_order(order_input)
    else:
        self._query.add_order(ModelQueryUtils.OrderInput(args))
    return self

2. 分页参数同步重置

在__getitem__方法中设置分页参数前，先重置原有分页状态：

def __getitem__(self, key):
    # 重置分页参数
    self._query.set_offset(None)
    self._query.set_limit(None)
    
    if isinstance(key, slice):
        if key.start:
            self._query.set_offset(key.start)
        if key.stop:
            self._query.set_limit(key.stop - (key.start or 0))
    else:
        self._query.set_offset(key)
        self._query.set_limit(1)
    return self

3. 确保每个请求使用独立查询实例

在管理器中实现get_queryset方法，确保每次请求创建新的BaseModelQuery和BaseModelQueryset实例：

# manager/__init__.py
class LineIntrusionAnalyticsMananger(BaseModelManager):
    def __init__(self):
        super().__init__(queryset_class=queryset.LineIntrusionAnalyticsQueryset)
    
    def get_queryset(self, model):
        # 每次请求生成全新的查询实例
        query = BaseModelQuery(model)
        return self.queryset_class(query)

4. 统一重置方法（优雅实现）

在BaseModelQuery中添加统一的状态重置方法，集中管理所有查询参数的重置：

# manager/query/base.py
class BaseModelQuery:
    # ... 原有代码 ...
    
    def reset_query_state(self):
        """重置所有查询条件至初始状态"""
        self._where_conditions = []
        self._order_conditions = []
        self._offset = None
        self._limit = None

之后在需要重置的方法中调用该方法，比如filter：

def filter(self, filter_input=None, **kwargs):
    self._query.reset_query_state()
    if filter_input:
        self._query.add_where(filter_input)
    else:
        self._query.add_where(ModelQueryUtils.FilterInput(kwargs, ModelQueryUtils.FilterInput.JoinOperator.AND))
    return self

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