.NET Core 6 Web API中如何合并IQueryable记录

核心思路 #

不要先将查询结果加载到内存再合并，而是在IQueryable层面构建合并条件，这样能保留EF Core的延迟执行特性，让所有过滤逻辑在数据库层面完成，既高效又能支持后续的搜索、分页操作。

方案1：简单条件合并（如按Level过滤） #

如果每个角色对应的过滤逻辑只是匹配Level值，直接提取所有允许的Level并使用Contains即可实现多条件OR合并：

// 初始查询
var query = _context.ObjectA.AsQueryable();

// 获取用户角色列表
var rolesFromDb = await _context.User.Include(x => x.Role)
                                    .Where(x => x.Username == "user")
                                    .ToListAsync();

if (rolesFromDb.Any())
{
    // 提取所有角色对应的Level，去重避免重复条件
    var allowedLevels = rolesFromDb.Select(item => item.Role.Level)
                                  .Distinct()
                                  .ToList();
    // 合并条件：只要ObjectA的Level在允许列表中
    query = query.Where(x => allowedLevels.Contains(x.Level));
}

// 后续继续添加搜索过滤条件（示例）
// query = query.Where(x => x.Title.Contains(searchKeyword));

// 分页处理（示例）
var pageNumber = 1;
var pageSize = 10;
var totalCount = await query.CountAsync();
var paginatedData = await query.Skip((pageNumber - 1) * pageSize)
                               .Take(pageSize)
                               .ToListAsync();

方案2：复杂条件合并（每个角色对应不同过滤逻辑） #

如果不同角色需要不同的过滤规则（比如Level=1时还要判断状态，Level=2时要关联用户ID），可以通过构建Expression表达式实现OR合并：

步骤1：实现Expression的Or扩展方法

using System.Linq.Expressions;

public static class ExpressionExtensions
{
    public static Expression<Func<T, bool>> Or<T>(this Expression<Func<T, bool>> left, Expression<Func<T, bool>> right)
    {
        var invokedExpr = Expression.Invoke(right, left.Parameters.Cast<Expression>());
        return Expression.Lambda<Func<T, bool>>(Expression.OrElse(left.Body, invokedExpr), left.Parameters);
    }
}

步骤2：构建合并条件并应用到查询

var query = _context.ObjectA.AsQueryable();
var rolesFromDb = await _context.User.Include(x => x.Role)
                                    .Where(x => x.Username == "user")
                                    .ToListAsync();

if (rolesFromDb.Any())
{
    // 初始化一个默认的false表达式，作为OR合并的起始
    Expression<Func<ObjectA, bool>> combinedCondition = x => false;

    foreach (var item in rolesFromDb)
    {
        Expression<Func<ObjectA, bool>> roleCondition = null;
        if (item.Role.Level == 1)
        {
            // Level=1的自定义过滤逻辑
            roleCondition = x => x.Level == 1 && x.Status == "Active";
        }
        else if (item.Role.Level == 2)
        {
            // Level=2的自定义过滤逻辑（关联当前角色的用户ID）
            roleCondition = x => x.Level == 2 && x.OwnerId == item.Id;
        }
        // 合并当前角色的条件到总条件中（OR逻辑）
        combinedCondition = combinedCondition.Or(roleCondition);
    }

    // 应用合并后的条件到查询
    query = query.Where(combinedCondition);
}

// 后续的搜索、分页操作和方案1一致

为什么你的原方案不可行？ #

你原来的做法是将每个角色的查询结果加载到内存List中，再试图将List转为IQueryable，这样后续的过滤、分页操作会在内存中执行（而非数据库），数据量大时性能会急剧下降，而且失去了EF Core的查询优化能力。

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