重用 linq 查询的部分内容

Question

我们有一个使用 Linq-To-Sql 的程序，并对我们的表执行许多类似的查询。特别是，我们有一个时间戳列，我们提取最近的时间戳来查看自上次查询以来表是否已更改。

System.Data.Linq.Binary ts;
ts = context.Documents
    .Select(r => r.m_Timestamp)
    .OrderByDescending(r => r)
    .FirstOrDefault();

我们经常在与当前表单/查询相关的不同表上重复此查询。我想做的是创建一个“函数”或可以重复此查询的最后 3 行的东西（理想情况下适用于每个表）。这是我想写的：

System.Data.Linq.Binary ts;
ts = context.Documents
    .GetMostRecentTimestamp();

但我不知道如何创建这个“GetMostRecentTimestamp”。而且，这些查询从来都不是这么简单。他们通常按客户或当前订单进行过滤，因此更有效的查询可能是

ts = context.Documents
    .Where(r => r.CustomerID == ThisCustomerID)
    .GetMostRecentTiemstamp(); 

有帮助吗？谢谢！

---

更新[解决方案]

我选择了 Bala R 的答案，这里是更新的代码，因此可以编译：

public static System.Data.Linq.Binary GetMostRecentTimestamp(this IQueryable<Data.Document> docs)
{
    return docs
        .Select(r => r.m_Timestamp)
        .OrderByDescending(r => r)
        .FirstOrDefault();
    }

这个解决方案的唯一缺点是我必须为每个表编写这个函数。如果 Tejs 的答案确实有效的话，我会很喜欢它，但我不会为此重新设计我的数据库。另外，DateTime 并不是一种处理时间戳的好方法。

---

更新＃2（不太快）

虽然我可以执行诸如 Documents.Where( ... ).GetMostRecentTimestamp() 之类的查询，但如果我尝试执行基于关联的查询（例如 MyCustomer.Orders.GetMostRecentTimestamp() ），此解决方案将失败，或 MyCustomer.Orders.AsQueryable().GetMostRecentTimestamp();

Answer 1

这实际上很容易做到。您只需要在您希望为其提供此接口的实体上定义一个接口：

public class MyEntity : ITimestamp

然后，您的扩展方法：

public static DateTime GetMostRecentTimestamp<T>(this IQueryable<T> queryable)
    where T : ITimestamp
{
     return queryable.Select(x => x.m_Timestamp)
            .OrderByDescending(r => r)
            .FirstOrDefault()
}

这对于与该接口匹配的任何实体都很有用：

context.Documents.GetMostRecentTimestamp()
context.SomeOtherEntity.GetMostRecentTimestamp()

Answer 2

像这样的扩展怎么样

public static DateTime GetMostRecentTimestamp (this IQueryable<Document> docs)
{
    return docs.Select(r => r.m_Timestamp)
               .OrderByDescending(r => r)
               .FirstOrDefault();
}

Answer 3

唔...

DateTime timeStamp1 = dataContext.Customers.Max(c => c.TimeStamp);
DateTime timeStamp2 = dataContext.Orders.Max(c => c.TimeStamp);
DateTime timeStamp3 = dataContext.Details.Max(c => c.TimeStamp);

Answer 4

我创建了一对可以帮助您的扩展方法：ObjectWithMin 和 ObjectWithMax：

public static T ObjectWithMax<T, TResult>(this IEnumerable<T> elements, Func<T, TResult> projection)
        where TResult : IComparable<TResult>
    {
        if (elements == null) throw new ArgumentNullException("elements", "Sequence is null.");
        if (!elements.Any()) throw new ArgumentException("Sequence contains no elements.");

        var seed = elements.Select(t => new {Object = t, Projection = projection(t)}).First();

        return elements.Aggregate(seed,
                                  (s, x) =>
                                  projection(x).CompareTo(s.Projection) >= 0
                                      ? new {Object = x, Projection = projection(x)}
                                      : s
            ).Object;
    }

public static T ObjectWithMin<T, TResult>(this IEnumerable<T> elements, Func<T, TResult> projection)
        where TResult : IComparable<TResult>
    {
        if (elements == null) throw new ArgumentNullException("elements", "Sequence is null.");
        if (!elements.Any()) throw new ArgumentException("Sequence contains no elements.");

        var seed = elements.Select(t => new {Object = t, Projection = projection(t)}).First();

        return elements.Aggregate(seed,
                                  (s, x) =>
                                  projection(x).CompareTo(s.Projection) < 0
                                      ? new {Object = x, Projection = projection(x)}
                                      : s
            ).Object;
    }

当用于内存集合时，这两个方法比 OrderBy().FirstOrDefault() 更有效；然而 IQueryable 提供者无法解析它们。您可以像这样使用它们：

ts = context.Documents
    .Where(r => r.CustomerID == ThisCustomerID)
    .ObjectWithMax(r=>r.m_Timestamp);

ts 现在是具有最新时间戳的对象，因此您不需要第二个查询来获取它。