【发布时间】:2013-04-26 16:00:05
【问题描述】:
我需要对 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 查询的一部分,这样它就不会在完成过滤过程之前返回大量实体。
【问题讨论】:
-
你为什么要
query = query.AsEnumerable()?这就是为什么您的查询不是您的 SQL 查询的一部分?我不明白将其转换为可枚举然后返回可查询的原因。 -
这是我尝试让 Linq-To-Entities 提供程序理解查询的众多方法之一。不幸的是,省略 AsEnumerable() 调用会使查询在 Linq-To-Entities 上下文中不可用。我得到这个执行:LINQ to Entities 不支持 LINQ 表达式节点类型“Invoke”。
标签: c# linq linq-to-entities linq-expressions