关于CosmosDB从Linq查询转SqlQuerySpec的动态查询需求问询

我在几个项目里都碰到过类似的问题——放弃Linq转用SqlQuerySpec后，动态构建查询确实容易变得杂乱。下面几个方案亲测好用，你可以根据团队的技术栈和需求复杂度来选：

这是最直接的方式，把查询拆成可拼接的片段，根据传入参数决定是否添加对应的逻辑。核心是严格做参数化，避免SQL注入和查询计划缓存失效。

示例代码：

// 1. 动态构建SELECT子句（处理部分字段选择场景）
var selectFields = new List<string> { "c.id", "c.name", "c.createdDate" };
if (shouldIncludeLargeField) // 传入的控制参数
{
    selectFields.Add("c.largeContent"); // 按需添加大字段
}
var selectClause = $"SELECT {string.Join(", ", selectFields)} FROM c";

// 2. 动态构建WHERE条件
var whereClauses = new List<string>();
var parameters = new SqlParameterCollection();

// 根据参数添加过滤条件
if (!string.IsNullOrEmpty(filterByName))
{
    whereClauses.Add("c.name = @name");
    parameters.Add(new SqlParameter("@name", filterByName));
}
if (minCreatedDate.HasValue)
{
    whereClauses.Add("c.createdDate >= @minDate");
    parameters.Add(new SqlParameter("@minDate", minCreatedDate.Value));
}

// 3. 拼接完整查询
var queryText = selectClause;
if (whereClauses.Any())
{
    queryText += $" WHERE {string.Join(" AND ", whereClauses)}";
}

// 生成最终的SqlQuerySpec
var querySpec = new SqlQuerySpec(queryText, parameters);

注意点：

• 所有用户输入或动态参数必须通过SqlParameter传递，绝对不能直接拼进字符串
• 可以把常用的字段组合封装成枚举（比如DocumentFieldSets.Basic、DocumentFieldSets.WithLargeContent），减少重复代码

如果追求类型安全、避免字符串拼写错误，可以用表达式树动态构建逻辑，再转换成对应的SQL片段。适合复杂的动态查询场景。

示例思路：

// 定义文档实体和投影类
public class MyDocument { public string Id { get; set; } public string Name { get; set; } public string LargeContent { get; set; } }
public class BasicProjection { public string Id { get; set; } public string Name { get; set; } }
public class FullProjection : BasicProjection { public string LargeContent { get; set; } }

// 动态构建字段选择表达式
var parameter = Expression.Parameter(typeof(MyDocument), "c");
List<MemberBinding> bindings = new List<MemberBinding>
{
    Expression.Bind(typeof(BasicProjection).GetProperty(nameof(BasicProjection.Id)), 
                   Expression.Property(parameter, nameof(MyDocument.Id))),
    Expression.Bind(typeof(BasicProjection).GetProperty(nameof(BasicProjection.Name)), 
                   Expression.Property(parameter, nameof(MyDocument.Name)))
};

if (shouldIncludeLargeField)
{
    bindings.Add(Expression.Bind(typeof(FullProjection).GetProperty(nameof(FullProjection.LargeContent)), 
                                 Expression.Property(parameter, nameof(MyDocument.LargeContent))));
}

// 转换成SELECT子句（可以自己写ExpressionVisitor解析，或者用轻量库辅助）
var selectFields = bindings.Select(b => $"c.{((MemberBinding)b).Member.Name}");
var selectClause = $"SELECT {string.Join(", ", selectFields)} FROM c";

// 后续WHERE条件也可以用类似方式通过表达式树生成，再转成SQL片段

优势：

• 编译时就能检查字段名是否正确，避免运行时拼写错误
• 适合需要复用复杂过滤逻辑的场景

如果团队允许引入第三方库，像Cosmonaut这类专门针对Cosmos DB的ORM已经封装了动态查询能力，能直接生成优化的SqlQuerySpec，同时保留Linq的语法优势。

示例代码：

// 假设已经初始化了CosmosStore
var query = cosmosStore.Query<MyDocument>()
    .SelectFields(f => new { f.Id, f.Name }) // 默认返回基础字段
    .WhereIf(!string.IsNullOrEmpty(filterByName), f => f.Name == filterByName)
    .WhereIf(minCreatedDate.HasValue, f => f.CreatedDate >= minCreatedDate.Value);

// 按需添加大字段
if (shouldIncludeLargeField)
{
    query = query.SelectFields(f => new { f.LargeContent });
}

// 直接转换成SqlQuerySpec
var querySpec = query.ToSqlQuerySpec();

优势：

• 不用自己维护QueryBuilder的复杂逻辑
• 自动处理参数化和查询优化，减少出错概率

1. 验证查询性能：每次调整动态查询后，用Cosmos DB的查询分析器检查RU消耗，避免因为动态拼接导致全表扫描
2. 缓存常用查询模板：对于高频使用的查询模板，可以提前预定义，只动态替换参数，提升查询计划缓存效率
3. 关联查询优化：如果是跨容器关联，尽量把条件限制在分区键上；如果是嵌入式文档，用ARRAY_CONTAINS等函数高效过滤嵌套数据

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