LINQ 到实体通用 == 解决方法

Question

我有一个以下 LINQ-to-entities 查询

IQueryable<History<T>> GetFirstOperationsForEveryId<T>
    (IQueryable<History<T>> ItemHistory)
{
    var q = (from h in ItemHistory
             where h.OperationId ==
                (from h1 in ItemHistory
                 where h1.GenericId == h.GenericId
                 select h1.OperationId).Min()
             select h);
    return q;
}

ItemHistory 是一个通用查询。它可以通过以下方式获得

var history1 = MyEntitiySet1.Select(obj =>
    new History<long>{ obj.OperationId, GenericId = obj.LongId });
var history2 = AnotherEntitiySet.Select(obj =>
    new History<string>{ obj.OperationId, GenericId = obj.StringId });

最后，我希望通用查询能够与可转换为 History 的任何实体集合一起使用。

问题是由于内部查询中的 GenericId 比较，代码无法编译（运算符“==”不能应用于“T”和“T”类型的操作数）。

如果我将 == 更改为 h1.GenericId.Equals(h.GenericId) 我会收到以下 NotSupportedException：

无法将类型“System.Int64”转换为类型“System.Object”。 LINQ to Entities 仅支持转换实体数据模型基元类型。

我尝试进行分组而不是子查询并加入结果。

IQueryable<History<T>> GetFirstOperationsForEveryId<T>
    (IQueryable<History<T>> ItemHistory)
{
    var grouped = (from h1 in ItemHistory
                   group h1 by h1.GenericId into tt
                   select new
                   {
                        GenericId = tt.Key,
                        OperationId = tt.Min(ttt => ttt.OperationId)
                   });

    var q = (from h in ItemHistory
             join g in grouped
                on new { h.OperationId, h.GenericId }
                equals new { g.OperationId, g.GenericId }
             select h);
    return q;
}

它可以编译，因为 GenericId 与 equals 关键字进行比较并且它可以工作，但是使用真实数据的查询太慢（它已经在专用的 postgresql 服务器上运行了 11 个小时）。

有一个选项可以为外部 where 语句构建整个表达式。但代码太长而且不清楚。

是否有任何简单的解决方法可以在 LINQ-to-entities 中与泛型进行相等比较？

Answer 1

试试这个，我认为它应该可以完成你想要的，而不需要额外的查询/连接

IQueryable<History<T>> GetFirstOperationsForEveryId<T>
    (IQueryable<History<T>> ItemHistory)
{
  var q = from h in ItemHistory
          group h by h.GenericId into tt
          let first = (from t in tt
                        orderby t.GenericId
                        select t).FirstOrDefault()
          select first;

  return q;
}

Answer 2

IQueryable<History<T>> GetFirstOperationsForEveryId<T>
(IQueryable<History<T>> ItemHistory)
{
var grouped = (from h1 in ItemHistory
               group t by h1.GenericId into tt
               select new
               {
                    GenericId = tt.Key,
                    OperationId = tt.Min(ttt => ttt.OperationId)
               });

var q = (from h in ItemHistory
         join g in grouped
            on new { h.OperationId, h.GenericId }
            equals new { g.OperationId, g.GenericId }
         select h);
return q;
}

Answer 3

您还可以为实现 GenericId 和 OperationId 属性的 IItemHistory 接口设置 T 的通用约束。

Answer 4

我的问题已经包含了解决方案。如果表已正确索引，则使用组+联接的第二种方法效果很好。从数据库表中检索 370k 行需要 3.28 秒。事实上，在非通用变体中，postgresql 上的第一个查询比第二个查询慢。 26.68 秒 vs 4.75 秒。