如何使用LINQ对Azure Cosmos DB SQL API实现高效动态查询？

下面是三种经过验证的可用方案，可根据你的技术栈偏好选择：

方案1：直接使用参数化原生SQL查询（最推荐） #

你已经验证原生SQL可以正常执行，该方案灵活度最高，完全适配动态属性的查询需求：

• 从UI获取动态属性路径（比如DynamicContent.MailingAddress.City）和查询关键字后，构造参数化查询语句
• 避免直接拼接用户输入到SQL字符串，防止注入风险
  示例代码：

var propertyPath = "DynamicContent.MailingAddress.City"; // UI传入的动态属性路径
var keyword = "PORT"; // UI传入的查询关键字
var queryDefinition = new QueryDefinition($"SELECT * FROM c WHERE c.{propertyPath} LIKE CONCAT('%', @keyword, '%')")
    .WithParameter("@keyword", keyword);
var queryResultSet = container.GetItemQueryIterator<CosmosDocument>(queryDefinition);
var results = new List<CosmosDocument>();
while (queryResultSet.HasMoreResults)
{
    var response = await queryResultSet.ReadNextAsync();
    results.AddRange(response.ToList());
}

方案2：动态构建LINQ表达式树 #

如果需要保持LINQ的链式写法，可以通过构建表达式树实现动态属性过滤：

• 写通用扩展方法，根据传入的属性路径字符串和查询值，构造Expression<Func<CosmosDocument, bool>>类型的过滤条件
• 直接将构造好的表达式传入Where()方法即可
  示例核心逻辑：

public static Expression<Func<CosmosDocument, bool>> BuildDynamicContainsPredicate(string propertyPath, string keyword)
{
    var parameter = Expression.Parameter(typeof(CosmosDocument), "c");
    Expression property = parameter;
    foreach (var propName in propertyPath.Split('.'))
    {
        property = Expression.PropertyOrField(property, propName);
    }
    var containsMethod = typeof(string).GetMethod("Contains", new[] { typeof(string) });
    var keywordConstant = Expression.Constant(keyword, typeof(string));
    var containsCall = Expression.Call(property, containsMethod, keywordConstant);
    return Expression.Lambda<Func<CosmosDocument, bool>>(containsCall, parameter);
}

// 调用方式
var predicate = BuildDynamicContainsPredicate("DynamicContent.MailingAddress.City", "PORT");
var results = query.Where(predicate).ToList();

方案3：将dynamic类型替换为JsonElement #

dynamic类型在LINQ查询中存在较多限制，你可以将DynamicContent的类型改为JsonElement，SDK原生支持该类型的LINQ查询解析：
修改实体类定义：

public partial class CosmosDocument
{
    [JsonProperty("Id")]
    public long Id { get; set; }
    [JsonProperty("AttentionName")]
    public string AttentionName { get; set; }
    [JsonProperty("DynamicContent")]
    public JsonElement DynamicContent { get; set; }
}

查询写法示例：

var results = query.Where(c => 
    c.DynamicContent.GetProperty("MailingAddress")
    .GetProperty("City")
    .GetString()
    .Contains("PORT")).ToList();

如果不确定属性是否存在，可以使用TryGetProperty方法判断，避免运行时抛异常。

• 高频查询的动态属性路径建议提前在Cosmos DB索引策略中配置对应路径的索引，可大幅提升查询性能，降低RU消耗
• 所有用户输入的查询参数都要做参数化处理，禁止直接拼接进SQL语句

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