如何将.Net Core中EF Core的单体复杂查询拆分为更易管理的模块化组件？

1. 原生分步拼接查询（无第三方依赖） #

利用EF Core的延迟执行特性，IQueryable在调用ToList/Count等触发执行的方法前，所有Where/OrderBy操作都是拼接表达式树，不会真的查询数据库，完全可以把不同维度的筛选条件拆成独立的判断块：

// 1. 初始化基础查询
IQueryable<OrderEntity> query = context.Order.AsNoTracking();

// 2. 处理区域筛选
if (regionFilter.Any() || districtFilter.Any())
{
    query = query.Where(o => locationFiltersToLocationIdList.Contains(o.locationId));
}

// 3. 处理截止日期筛选
if (dueToDate != null)
{
    query = query.Where(o => 
        o.OrderPaymentDueDate != null ? o.OrderPaymentDueDate <= DateTime.Now :
        o.OrderDate != null && o.PaymentTerms != null && 
        o.OrderDate.Value.AddDays(Convert.ToInt32(o.paymentInterval)) >= DateTime.Now
    );
}

// 最后触发查询
List<OrderEntity> entities = query.OrderBy(o => o.OrderDate).ToList();

2. 公共筛选逻辑抽成可复用表达式树 #

把重复用到的判断逻辑（比如示例里的订单逾期判断）封装成独立的表达式，既减少重复代码，也方便统一修改：

// 单独定义订单逾期的判断表达式，全局复用
public static Expression<Func<OrderEntity, bool>> IsOrderLate()
{
    return o => o.Status != "Paid" && 
    (
        o.OrderPaymentDueDate != null ? 
            ((DateTime)o.OrderPaymentDueDate) < DateTime.Now :
            o.OrderDate != null && o.PaymentTerms != null && 
            o.OrderDate.Value.AddDays(Convert.ToInt32(o.paymentInterval)) < DateTime.Now
    );
}

// 使用时直接拼接
if (orderStatusList.Contains("Late"))
{
    query = query.Where(IsOrderLate());
}

3. 复杂与或逻辑用PredicateBuilder拼接 #

如果需要拼接多组OR条件，原生IQueryable拼接比较麻烦，可以用LinqKit的PredicateBuilder工具简化操作，不用手动写表达式树拼接逻辑：

var statusPredicate = PredicateBuilder.New<OrderEntity>();
if (orderStatusList.Contains("Paid"))
{
    statusPredicate = statusPredicate.Or(o => o.Status == "Paid");
}
if (orderStatusList.Contains("Late"))
{
    statusPredicate = statusPredicate.Or(IsOrderLate());
}
// 只要有状态筛选条件就拼到主查询上
if (orderStatusList.Any())
{
    query = query.Where(statusPredicate);
}

4. 封装查询构建类实现完全解耦 #

如果筛选维度特别多，可以把所有查询逻辑封装到专门的查询构建类里，和业务逻辑层完全分离：

public class OrderQueryBuilder
{
    private IQueryable<OrderEntity> _query;
    private OrderFilterDto _filter;

    public OrderQueryBuilder(IQueryable<OrderEntity> baseQuery, OrderFilterDto filter)
    {
        _query = baseQuery.AsNoTracking();
        _filter = filter;
    }

    public OrderQueryBuilder ApplyRegionFilter()
    {
        if (_filter.RegionFilter.Any() || _filter.DistrictFilter.Any())
        {
            var locationIds = GetLocationIdList(_filter.RegionFilter, _filter.DistrictFilter);
            _query = _query.Where(o => locationIds.Contains(o.locationId));
        }
        return this;
    }

    public OrderQueryBuilder ApplyStatusFilter()
    {
        // 单独处理状态筛选逻辑
        return this;
    }

    public IQueryable<OrderEntity> Build()
    {
        return _query.OrderBy(o => o.OrderDate);
    }
}

// 业务层调用非常简洁
var query = new OrderQueryBuilder(context.Order, filter)
    .ApplyRegionFilter()
    .ApplyStatusFilter()
    .ApplyDateFilter()
    .Build();
var entities = query.ToList();

注意事项 #

• EF Core 3.1对客户端评估默认是抛出异常，抽出来的表达式要确保可以被EF翻译成SQL，不要在表达式里调用无法翻译的自定义方法
• 只查数据不修改的场景统一加AsNoTracking()，可以大幅提升查询性能
• 每个拆分出来的筛选逻辑都可以单独写单元测试验证正确性，不用耦合整个大查询

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