.NET Azure Cosmos SDK：嵌套集合查询的PredicateBuilder实现方案

你的核心问题是误用了Func<Car, bool>而非表达式树构建查询条件，导致Cosmos DB无法解析Invoke操作。以下是数据库端实现嵌套集合多条件过滤的最优方案：

关键问题分析 #

你之前的代码用Func<Car, bool>拼接条件，传入Any()方法时会被转换为包含Invoke的表达式树，但Cosmos DB的LINQ查询提供器不支持Invoke操作，因此报错。必须全程使用Expression<Func<Car, bool>>构建组合条件，才能被正确翻译为Cosmos DB支持的SQL查询。

解决方案代码 #

1. 实现表达式版PredicateBuilder（无需第三方库） #

自己实现极简的表达式组合工具：

public static class ExpressionPredicateBuilder
{
    public static Expression<Func<T, bool>> True<T>() => _ => true;
    public static Expression<Func<T, bool>> And<T>(this Expression<Func<T, bool>> left, Expression<Func<T, bool>> right)
    {
        var parameter = Expression.Parameter(typeof(T));
        var leftBody = Expression.Invoke(left, parameter);
        var rightBody = Expression.Invoke(right, parameter);
        var combined = Expression.AndAlso(leftBody, rightBody);
        return Expression.Lambda<Func<T, bool>>(combined, parameter);
    }
}

2. 重构查询方法 #

用表达式树构建条件，避免Invoke问题：

public static IQueryable<CarMake> CarMakeSearch(this IQueryable<CarMake> queryable, BaseSearchRequest searchRequest)
{
    // 初始化基础表达式：匹配所有Car
    Expression<Func<Car, bool>> carPredicate = ExpressionPredicateBuilder.True<Car>();

    // 拼接价格条件
    if (searchRequest.MaxPrice > 0)
    {
        Expression<Func<Car, bool>> priceFilter = c => c.Price <= searchRequest.MaxPrice;
        carPredicate = carPredicate.And(priceFilter);
    }

    // 拼接其他条件（示例：品牌过滤）
    if (!string.IsNullOrEmpty(searchRequest.Brand))
    {
        Expression<Func<Car, bool>> brandFilter = c => c.Brand.Equals(searchRequest.Brand);
        carPredicate = carPredicate.And(brandFilter);
    }

    // 更多条件以此类推...

    // 组合后的表达式传入Any，Cosmos会正确翻译为SQL
    return queryable.Where(carMake => carMake.Cars.Any(carPredicate));
}

原理说明 #

• 使用Expression<Func<Car, bool>>而非Func<Car, bool>，确保所有条件以表达式树形式存在，能被Cosmos DB的LINQ提供器解析为对应SQL语句。
• 通过And方法组合表达式时，生成的是AndAlso节点的表达式树，而非Invoke，符合Cosmos的查询语法要求。
• 最终生成的SQL类似：SELECT * FROM c WHERE EXISTS(SELECT * FROM c.Cars WHERE c.Cars.Price <= @MaxPrice AND c.Cars.Brand = @Brand)，所有过滤逻辑在数据库端完成，无需客户端二次过滤。

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