我需要对 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 查询的一部分发送,因此在完成过滤过程之前它不会返回大量实体。