如何基于Expression创建DbSet<T>以实现EF动态查询服务？

看起来你已经理清了核心思路：轻量客户端构建查询表达式，服务端执行并返回结果。我来针对你的几个核心问题逐一解答，再给你一些实际的实现建议和框架推荐：

核心问题解答 #

1. 能不能通过Expression创建DbSet？ #

不行，DbSet<T>是EF Core中绑定到数据库上下文的实体集合，它包含了数据库连接、状态跟踪等运行时资源，没法直接用Expression创建。但你完全不需要这么做——服务端本身持有自己的DbContext，只需要把客户端传来的查询表达式应用到服务端的DbSet<T>上即可。

2. 能不能序列化DbSet？ #

绝对不可以，也完全没必要。DbSet<T>是和数据库上下文强绑定的对象，包含大量不可序列化的运行时状态。你只需要序列化查询的表达式树（Expression），服务端用自己的DbSet来执行这个表达式就行。

关键实现步骤 #

你的核心痛点是序列化Expression并在服务端转换为EF可执行的查询，这里给你一套可行的流程：

客户端：构建并序列化查询表达式 #

客户端不需要真实的DbContext，可以用空集合创建一个"假"的IQueryable<DTO>来构建查询树，然后提取它的Expression进行序列化：

// 用空集合构建查询容器，仅用于生成表达式树
var query = Enumerable.Empty<MyDto>().AsQueryable()
    .Where(d => d.IsActive)
    .OrderBy(d => d.MySonDto.Date)
    .Take(10);

// 注意：EF的Include方法只对DbSet有效，客户端需要自定义扩展来记录导航属性包含路径
// 比如自己实现一个Include扩展，把需要包含的路径存在查询的Annotations里
var queryWithIncludes = query.IncludeCustom(d => d.MySonDto);

// 序列化表达式树（推荐用专门的Expression序列化库，比如ExpressionSerializer）
var serializedExpr = ExpressionSerializer.Serialize(queryWithIncludes.Expression);
// 同时把Include路径也序列化发送，或者从表达式树中解析

// 发送到服务端
var result = await queryService.ExecuteQueryAsync<MyDto>(serializedExpr, includePaths);

服务端：反序列化并执行查询 #

服务端拿到序列化后的表达式后，需要做两件事：

1. 把针对DTO的表达式转换为针对数据库实体的表达式（如果DTO和实体不一致）
2. 将表达式应用到自己的DbSet上，执行查询后映射回DTO

public async Task<IEnumerable<MyDto>> ExecuteQueryAsync<T>(string serializedExpr, List<string> includePaths)
{
    // 1. 反序列化表达式
    var dtoExpression = ExpressionSerializer.Deserialize<Expression>(serializedExpr);
    
    // 2. 转换DTO表达式为实体表达式（用AutoMapper的ExpressionMapping扩展）
    var mapperConfig = new MapperConfiguration(cfg => 
    {
        cfg.CreateMap<MyEntity, MyDto>();
        cfg.CreateMap<MySonEntity, MySonDto>();
        cfg.AddExpressionMapping(); // 启用表达式映射
    });
    var mapper = mapperConfig.CreateMapper();
    
    // 转换Where、OrderBy等表达式逻辑
    var entityQueryExpr = mapper.MapExpression<Expression<Func<IQueryable<MyEntity>, IQueryable<MyEntity>>>>(dtoExpression);
    
    // 3. 构建EF查询并执行
    using var dbContext = new MyDbContext();
    var query = dbContext.Set<MyEntity>().AsQueryable();
    
    // 应用Include路径
    foreach(var path in includePaths)
    {
        query = query.Include(path);
    }
    
    // 应用转换后的表达式，再映射回DTO
    var result = await query.Provider.CreateQuery<MyEntity>(entityQueryExpr)
        .ProjectTo<MyDto>(mapperConfig)
        .ToListAsync();
    
    return result;
}

推荐框架 #

1. AutoMapper + AutoMapper.Extensions.ExpressionMapping #

这是最适合你场景的组合：

• AutoMapper负责实体和DTO的映射
• ExpressionMapping扩展可以直接把针对DTO的表达式树转换为针对实体的表达式树，完美解决跨层查询逻辑的传递问题

2. OData #

如果你能接受RESTful的查询方式，OData是成熟的开箱即用方案：

• 客户端通过URL参数（比如$filter、$orderby、$expand）构建动态查询
• 服务端用OData库（比如Microsoft.AspNetCore.OData）自动把URL参数转换为EF的IQueryable查询，完全不需要自己处理序列化和表达式转换

3. ExpressionSerializer #

专门用于序列化和反序列化.NET表达式树的库，解决Expression默认序列化不支持复杂节点的问题，比自己写序列化逻辑靠谱得多

注意事项 #

• 安全性：动态查询要做权限校验，限制可访问的实体和属性，防止恶意构造表达式执行危险操作
• 导航属性处理：客户端的Include不能直接用EF的Include，需要自定义扩展记录路径，或者在表达式树中解析导航属性信息
• 类型一致性：DTO和实体的类型定义要在客户端和服务端保持一致，否则序列化/反序列化会出错

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