如何实现仓储与数据访问解耦并保留IQueryable特性（Azure移动服务场景）

这个场景太常见了——既要把领域层和具体的数据访问技术完全隔离开，又不想丢掉IQueryable带来的服务端查询优化（比如分页、过滤都在云端做，不用拉全量数据）。你遇到的类型不匹配问题，核心原因是Azure Mobile Services的LINQ提供者无法识别跨接口的Cast/OfType操作，必须把针对IDomainObject的表达式树转换成针对AzureDomainObject的版本，才能被正确解析成OData查询。

下面是具体的实现方案：

1. 实现表达式树转换工具 #

我们需要写一个自定义的ExpressionVisitor，把所有针对IDomainObject的表达式节点替换成AzureDomainObject对应的节点，让Azure的LINQ提供者能读懂：

public class DomainToAzureExpressionVisitor : ExpressionVisitor
{
    protected override Expression VisitParameter(ParameterExpression node)
    {
        // 把IDomainObject类型的参数替换成AzureDomainObject
        if (node.Type == typeof(IDomainObject))
        {
            return Expression.Parameter(typeof(AzureDomainObject), node.Name);
        }
        return base.VisitParameter(node);
    }

    protected override Expression VisitMember(MemberExpression node)
    {
        // 把IDomainObject的属性访问替换成AzureDomainObject对应的属性
        if (node.Member.DeclaringType == typeof(IDomainObject))
        {
            var targetProperty = typeof(AzureDomainObject).GetProperty(node.Member.Name);
            return Expression.MakeMemberAccess(Visit(node.Expression), targetProperty);
        }
        return base.VisitMember(node);
    }

    protected override Expression VisitLambda<T>(Expression<T> node)
    {
        // 转换查询函数的整体类型
        if (typeof(T) == typeof(Func<IQueryable<IDomainObject>, IQueryable<IDomainObject>>))
        {
            var convertedBody = Visit(node.Body);
            var convertedParams = node.Parameters.Select(Visit).Cast<ParameterExpression>();
            return Expression.Lambda<Func<IQueryable<AzureDomainObject>, IQueryable<AzureDomainObject>>>(convertedBody, convertedParams);
        }
        return base.VisitLambda(node);
    }
}

2. 改造仓储实现 #

在你的Azure仓储实现中，用上面的访问器转换传入的查询函数，再应用到IMobileServiceTable上：

public class AzureDomainObjectRepository : IDomainObjectRepository
{
    private readonly IMobileServiceTable<AzureDomainObject> _table;

    public AzureDomainObjectRepository(IMobileServiceTable<AzureDomainObject> table)
    {
        _table = table;
    }

    public async Task<IEnumerable<IDomainObject>> GetDomainObjectAsync(Func<IQueryable<IDomainObject>, IQueryable<IDomainObject>> query)
    {
        // 转换查询表达式到Azure兼容的类型
        var visitor = new DomainToAzureExpressionVisitor();
        var azureQueryFunc = visitor.Visit(query) as Func<IQueryable<AzureDomainObject>, IQueryable<AzureDomainObject>>;

        if (azureQueryFunc == null)
        {
            throw new InvalidOperationException("无法将领域查询转换为Azure兼容的查询表达式");
        }

        // 应用查询到Azure表，执行服务端查询
        var azureQuery = azureQueryFunc(_table.Query());
        var azureResults = await azureQuery.ToListAsync();

        // 转换回领域对象（因为AzureDomainObject实现了IDomainObject，直接Cast即可）
        return azureResults.Cast<IDomainObject>();
    }
}

3. 使用示例 #

调用仓储的时候，你完全不用关心Azure的具体实现，只需要基于IDomainObject写查询：

var results = await repository.GetDomainObjectAsync(query => 
    query.Where(d => d.Name.StartsWith("A"))
         .OrderBy(d => d.Name)
         .Take(10)
);

这个查询会被转换成针对AzureDomainObject的表达式，Azure Mobile Services会在云端执行过滤、排序和分页，最后只返回10条符合条件的数据，完美保留了IQueryable的性能优势。

关键注意事项 #

• 如果你的领域对象和Azure实体有属性名称不一致的情况，只需要在VisitMember方法里添加属性映射逻辑即可。
• 这种方式完全隐藏了AzureDomainObject和IMobileServiceTable，领域层只依赖IDomainObject和仓储接口，达到了你想要的隔离效果。
• 相比手动拼接ReadAsync的查询字符串，表达式转换保留了编译时类型检查，避免了拼写错误，也更符合LINQ的使用习惯。

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