自定义CosmosDbProperty特性后，Cosmos DB LINQ查询属性名不匹配问题

这个问题的核心在于：你配置的CosmosDbDefaultContractResolver只负责序列化/反序列化过程中的属性名转换，但Cosmos DB的LINQ查询解析器是基于表达式树直接生成SQL的，它完全不知道你自定义的CosmosDbPropertyAttribute存在，所以会直接使用类的原属性名（比如DocumentType）来生成查询语句，自然匹配不上Cosmos DB里存储的DT。

要解决这个问题，我们需要自定义一个表达式访问器（ExpressionVisitor），用来遍历LINQ表达式树，把所有带有CosmosDbPropertyAttribute的属性访问替换成映射后的属性名，再把修改后的表达式传给DocumentClient。

步骤1：实现自定义ExpressionVisitor #

这个访问器会遍历表达式中的属性访问节点，检查属性是否带有我们的自定义特性，如果有就替换成对应的Cosmos DB属性名：

public class CosmosDbPropertyNameVisitor : ExpressionVisitor
{
    protected override Expression VisitMember(MemberExpression node)
    {
        // 检查当前访问的成员是否是属性，并且带有CosmosDbPropertyAttribute
        if (node.Member is PropertyInfo propertyInfo)
        {
            var cosmosAttr = propertyInfo.GetCustomAttribute<CosmosDbPropertyAttribute>();
            if (cosmosAttr != null)
            {
                // 创建一个新的MemberExpression，使用映射后的属性名
                // 用索引器语法模拟Cosmos DB文档的属性访问
                var constantExpr = Expression.Constant(cosmosAttr.PropertyName);
                var indexExpr = Expression.MakeIndex(
                    node.Expression,
                    typeof(IDictionary<string, object>).GetProperty("Item"),
                    new[] { constantExpr });
                return indexExpr;
            }
        }
        return base.VisitMember(node);
    }
}

步骤2：创建查询扩展方法 #

为了方便复用，我们封装一个扩展方法，自动处理表达式的转换：

public static class CosmosDbQueryExtensions
{
    public static IQueryable<T> WithCosmosPropertyNames<T>(this IQueryable<T> query)
    {
        var visitor = new CosmosDbPropertyNameVisitor();
        // 转换原始查询的表达式树
        var modifiedExpr = visitor.Visit(query.Expression);
        // 返回带有修改后表达式的新查询
        return query.Provider.CreateQuery<T>(modifiedExpr);
    }
}

步骤3：修改你的查询代码 #

现在只需要在原LINQ查询后加上WithCosmosPropertyNames()扩展方法即可：

var _DbClient = new DocumentClient(
    new Uri("_DB URI_"), 
    "_DB KEY_", 
    new JsonSerializerSettings() { ContractResolver = new CosmosDbDefaultContractResolver() }, 
    connectionPolicy);

// 使用扩展方法处理属性名映射
var query = _DbClient.CreateDocumentQuery<T>()
    .Where(a => a.DocumentType == 0)
    .WithCosmosPropertyNames() // 关键：添加这一行
    .AsEnumerable();

原理说明 #

• 当我们调用WithCosmosPropertyNames()时，表达式访问器会把a.DocumentType == 0转换成a["DT"] == 0，这是Cosmos DB LINQ查询支持的索引器语法，解析后会生成使用DT属性名的SQL语句。
• 你的CosmosDbDefaultContractResolver依然负责序列化/反序列化时的属性名转换，两者互不干扰，完美实现了"仅Cosmos DB存储用别名，接口响应保持原属性名"的需求。

额外注意事项 #

• 如果你的查询涉及嵌套属性（比如a.User.Name），需要修改CosmosDbPropertyNameVisitor来处理多层属性的映射，核心逻辑是递归处理每个成员即可。
• 如果你使用的是新的Azure Cosmos DB SDK v3+（旧的DocumentClient已标记为过时，推荐升级），可以用CosmosSerializer实现序列化时的属性映射，再结合类似的表达式访问器处理LINQ查询，逻辑是相通的。

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