c# - 动态添加新的 lambda 表达式以创建过滤器

Question

我需要对 ObjectSet 进行一些过滤以获得我需要的实体:

query = this.ObjectSet.Where(x => x.TypeId == 3); // this is just an example;

在代码的后面(在启动延迟执行之前)我再次像这样过滤查询:

query = query.Where(<another lambda here ...>);

到目前为止效果很好。

这是我的问题:

实体包含一个DateFrom 属性和一个DateTo 属性，它们都是DataTime 类型。它们代表一个时间段。

我需要过滤实体以仅获取属于时间段的集合的实体。集合中的句点不一定是连续的，因此，检索实体的逻辑如下所示:

entities.Where(x => x.DateFrom >= Period1.DateFrom and x.DateTo <= Period1.DateTo)
||
entities.Where(x => x.DateFrom >= Period2.DateFrom and x.DateTo <= Period2.DateTo)
||

... 以及集合中的所有时期。

我试过这样做:

foreach (var ratePeriod in ratePeriods)
{
    var period = ratePeriod;

    query = query.Where(de =>
        de.Date >= period.DateFrom && de.Date <= period.DateTo);
}

但是一旦我启动延迟执行，它就会像我想要的那样将其转换为 SQL(每个时间段都有一个过滤器，集合中有多个时间段)，但是，它转换为 AND 比较OR 比较，它根本不返回任何实体，因为很明显，一个实体不能属于多个时间段。

我需要在这里构建某种动态 linq 来聚合周期过滤器。

---

更新

根据 hatten 的回答，我添加了以下成员:

private Expression<Func<T, bool>> CombineWithOr<T>(Expression<Func<T, bool>> firstExpression, Expression<Func<T, bool>> secondExpression)
{
    // Create a parameter to use for both of the expression bodies.
    var parameter = Expression.Parameter(typeof(T), "x");
    // Invoke each expression with the new parameter, and combine the expression bodies with OR.
    var resultBody = Expression.Or(Expression.Invoke(firstExpression, parameter), Expression.Invoke(secondExpression, parameter));
    // Combine the parameter with the resulting expression body to create a new lambda expression.
    return Expression.Lambda<Func<T, bool>>(resultBody, parameter);
}

声明了一个新的 CombineWithOr 表达式:

Expression<Func<DocumentEntry, bool>> resultExpression = n => false;

并像这样在我的周期收集迭代中使用它:

foreach (var ratePeriod in ratePeriods)
{
    var period = ratePeriod;
    Expression<Func<DocumentEntry, bool>> expression = de => de.Date >= period.DateFrom && de.Date <= period.DateTo;
    resultExpression = this.CombineWithOr(resultExpression, expression);
}

var documentEntries = query.Where(resultExpression.Compile()).ToList();

我查看了生成的 SQL，好像表达式根本没有效果。生成的 SQL 返回先前编程的过滤器，但不返回组合过滤器。为什么？

---

更新 2

我想试试 feO2x 的建议，所以我重写了我的过滤器查询:

query = query.AsEnumerable()
    .Where(de => ratePeriods
        .Any(rp => rp.DateFrom <= de.Date && rp.DateTo >= de.Date))

如您所见，我添加了 AsEnumerable() 但编译器给我一个错误，它无法将 IEnumerable 转换回 IQueryable，因此我添加了 ToQueryable() 在我的查询结束时:

query = query.AsEnumerable()
    .Where(de => ratePeriods
        .Any(rp => rp.DateFrom <= de.Date && rp.DateTo >= de.Date))
            .ToQueryable();

一切正常。我可以编译代码并启动此查询。但是，它不符合我的需求。

在分析生成的 SQL 时，我可以看到过滤不是 SQL 查询的一部分，因为它会在此过程中过滤内存中的日期。我想您已经知道了，这就是您打算提出的建议。

你的建议有效，但是，因为它在内存中过滤它们之前从数据库中获取所有实体(并且有成千上万的实体)，所以返回那么大的实体真的很慢来自数据库的金额。

我真正想要的是发送句点过滤作为生成的 SQL 查询的一部分，这样它就不会在完成过滤过程之前返回大量实体。

Answer 1

尽管有很好的建议，我还是不得不选择 LinqKit。原因之一是我将不得不在代码的许多其他地方重复相同类型的谓词聚合。使用 LinqKit 是最简单的，更何况我只需编写几行代码即可完成。

以下是我使用 LinqKit 解决问题的方法:

var predicate = PredicateBuilder.False<Document>();
foreach (var submittedPeriod in submittedPeriods)
{
    var period = period;
    predicate = predicate.Or(d =>
        d.Date >= period.DateFrom && d.Date <= period.DateTo);
}

然后我启动延迟执行(请注意，我之前调用了 AsExpandable()):

var documents = this.ObjectSet.AsExpandable().Where(predicate).ToList();

我查看了生成的 SQL，它在将我的谓词转换为 SQL 方面做得很好。