Elasticsearch .NET 8.12客户端多条件组合查询问题求助

问题背景 #

使用Elasticsearch 8.12版本的.NET客户端，尝试根据传入参数生成动态查询，仅在参数有值时添加对应条件，但调试发现多个有效参数时仅一个条件生效。

DTO类 #

public class ProductSearchDto
{
    public string? Term { get; set; }
    public string? CategoryId { get; set; }
    public int? PriceFrom { get; set; }
    public int? PriceTo { get; set; }
    public int? Stars { get; set; }
    public int Page { get; set; }
    public int PageSize { get; set; }
}

索引实体类 #

public class ProductIndex 
{
    public string Id { get; set; }
    public decimal Price { get; set; }
    public string Title { get; set; }
    public string Description { get; set; }
    public string CategoryId { get; set; }
    public int Stars { get; set; }
    public DateTime IndexedAt { get; set; } = DateTime.UtcNow;
}

原查询代码 #

public async Task<List<ProductIndex>> Search(ProductSearchDto searchDto)
{
    QueryDescriptor<ProductIndex> query = new QueryDescriptor<ProductIndex>();
    if (!string.IsNullOrEmpty(searchDto.Term))
    {
         query
        .Match(r => r.Field(y => y.Description).Query(searchDto.Term));
    }
    if (!string.IsNullOrEmpty(searchDto.CategoryId))
    {
        query
       .Match(r => r.Field(y => y.CategoryId).Query(searchDto.CategoryId));
    }
    if (searchDto.Stars.HasValue)
    {
        query
       .Match(r => r.Field(y => y.Stars).Query(searchDto.Stars.Value.ToString()));
    }
    if (searchDto.PriceFrom.HasValue)
    {
        query
       .Range(r => r.NumberRange(z => z.Field(t => t.Price).From(searchDto.PriceFrom)
       .To(searchDto.PriceTo)));
    }
    var result = await _searchOperation.SearchIndexElastic<ProductIndex>
        (query);
    return result;
}

问题原因 #

QueryDescriptor的方法（如.Match()、.Range()）是不可变的，每次调用都会返回一个新的QueryDescriptor实例，而非修改原实例。原代码中每次调用后未将新实例赋值回query变量，导致只有最后一次调用的条件被保留。同时，多条件查询需要用Bool查询的Must子句组合所有条件，确保所有有效条件同时生效。

解决方法 #

修改后的查询代码（直接构建BoolQuery） #

public async Task<List<ProductIndex>> Search(ProductSearchDto searchDto)
{
    var boolQuery = new BoolQuery();

    // 添加Term匹配条件
    if (!string.IsNullOrEmpty(searchDto.Term))
    {
        boolQuery.Must.Add(new MatchQuery
        {
            Field = Infer.Field<ProductIndex>(f => f.Description),
            Query = searchDto.Term
        });
    }

    // 添加分类ID匹配条件
    if (!string.IsNullOrEmpty(searchDto.CategoryId))
    {
        boolQuery.Must.Add(new MatchQuery
        {
            Field = Infer.Field<ProductIndex>(f => f.CategoryId),
            Query = searchDto.CategoryId
        });
    }

    // 添加星级匹配条件
    if (searchDto.Stars.HasValue)
    {
        boolQuery.Must.Add(new MatchQuery
        {
            Field = Infer.Field<ProductIndex>(f => f.Stars),
            Query = searchDto.Stars.Value.ToString()
        });
    }

    // 添加价格范围条件
    if (searchDto.PriceFrom.HasValue || searchDto.PriceTo.HasValue)
    {
        var rangeQuery = new NumberRangeQuery
        {
            Field = Infer.Field<ProductIndex>(f => f.Price)
        };

        if (searchDto.PriceFrom.HasValue)
            rangeQuery.From = searchDto.PriceFrom;
        if (searchDto.PriceTo.HasValue)
            rangeQuery.To = searchDto.PriceTo;

        boolQuery.Must.Add(rangeQuery);
    }

    // 构建最终查询描述符
    var queryDescriptor = new QueryDescriptor<ProductIndex>().Bool(b => b.Must(boolQuery.Must));

    var result = await _searchOperation.SearchIndexElastic<ProductIndex>(queryDescriptor);
    return result;
}

简洁流畅API写法 #

public async Task<List<ProductIndex>> Search(ProductSearchDto searchDto)
{
    var query = new QueryDescriptor<ProductIndex>()
       .Bool(b => b
           .Must(must => 
           {
               if (!string.IsNullOrEmpty(searchDto.Term))
                   must = must.Match(m => m.Field(f => f.Description).Query(searchDto.Term));
               if (!string.IsNullOrEmpty(searchDto.CategoryId))
                   must = must.Match(m => m.Field(f => f.CategoryId).Query(searchDto.CategoryId));
               if (searchDto.Stars.HasValue)
                   must = must.Match(m => m.Field(f => f.Stars).Query(searchDto.Stars.Value.ToString()));
               if (searchDto.PriceFrom.HasValue || searchDto.PriceTo.HasValue)
                   must = must.Range(r => r
                       .NumberRange(n => n
                           .Field(f => f.Price)
                           .From(searchDto.PriceFrom)
                           .To(searchDto.PriceTo)));
               return must;
           }));

    var result = await _searchOperation.SearchIndexElastic<ProductIndex>(query);
    return result;
}

关键改进点 #

1. 使用BoolQuery的Must集合收集所有有效条件，确保所有条件同时满足（逻辑与）。
2. 两种写法均解决了QueryDescriptor不可变导致的赋值问题，保证所有条件被正确添加。
3. 优化价格范围逻辑：只要PriceFrom或PriceTo任一有值就添加范围查询，分别处理上下限参数。

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