如何使用ElasticSearch .NET客户端动态添加查询条件？

问题说明 #

原代码用于统计Elasticsearch索引中文档数量，但存在逻辑缺陷：当eventName为空字符串时，CountAsync会忽略日期范围查询，直接返回索引所有文档的总数。需要实现仅在eventName非空时，才添加Event字段的Match过滤条件，同时保证日期范围查询始终生效。

解决方案1：动态拼接QueryContainer #

通过QueryContainerDescriptor先构建基础的日期范围查询，再根据eventName的非空状态追加Match条件：

public async Task<long> GetCount(DateTimeOffset? startDate, DateTimeOffset? endDate, string eventName)
{
    // 初始化日期范围查询
    var baseQuery = new QueryContainerDescriptor<OemCatalogModel>()
        .DateRange(p => p.Field(t => t.Timestamp)
            .Format("epoch_second")
            .GreaterThanOrEquals(startDate)
            .LessThanOrEquals(endDate));

    // 非空时追加Match查询
    if (!string.IsNullOrEmpty(eventName))
    {
        baseQuery &= q => q.Match(m => m.Field(f => f.Event).Query(eventName));
    }

    var countResponse = await _elasticClient.CountAsync<OemCatalogModel>(c => c
        .Index(indexName)
        .Query(q => baseQuery));

    return countResponse.Count;
}

解决方案2：使用Bool查询组合条件 #

借助Elasticsearch的Bool查询，将日期范围设为必选条件，仅当eventName非空时，将Match查询加入必选条件集合：

public async Task<long> GetCount(DateTimeOffset? startDate, DateTimeOffset? endDate, string eventName)
{
    var countResponse = await _elasticClient.CountAsync<OemCatalogModel>(c => c
        .Index(indexName)
        .Query(q => q.Bool(b => 
        {
            // 强制加入日期范围查询
            b.Must(m => m.DateRange(p => p.Field(t => t.Timestamp)
                .Format("epoch_second")
                .GreaterThanOrEquals(startDate)
                .LessThanOrEquals(endDate)));
            
            // 非空时追加Match条件
            if (!string.IsNullOrEmpty(eventName))
            {
                b.Must(m => m.Match(match => match.Field(f => f.Event).Query(eventName)));
            }

            return b;
        })));

    return countResponse.Count;
}

核心原理 #

两种方案都确保了日期范围查询始终被执行，避免了原代码中因空eventName导致查询失效的问题：

• 方案1通过QueryContainer的&=操作符，将多个查询逻辑与（AND）组合；
• 方案2利用Bool查询的Must集合，所有加入的条件都会被同时满足。

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