4

我已经阅读了几个关于“不允许在查询中显式构造实体类型”错误的问题，以及解决它的各种方法。

我在我的代码中使用 DBML 自动生成的 LINQ to SQL 类，因此能够适当地选择和插入数据会很棒。这是另一篇文章中建议的一种方法；在下面的示例中，e_activeSession 是 DataContext 中表的自动生成表示：

var statistics =
    from record in startTimes
    group record by record.startTime into g
    select new e_activeSession
            {
                workerId = wcopy,
                startTime = g.Key.GetValueOrDefault(),
                totalTasks = g.Count(),
                totalTime = g.Max(o => o.record.timeInSession).GetValueOrDefault(),
                minDwell = g.Min(o => o.record.dwellTime).GetValueOrDefault(),
                maxDwell = g.Max(o => o.record.dwellTime).GetValueOrDefault(),
                avgDwell = g.Average(o => o.record.dwellTime).GetValueOrDefault(),
                stdevDwell = g.Select(o => Convert.ToDouble(o.record.dwellTime)).StdDev(),
                total80 = g.Sum(o => Convert.ToInt16(o.record.correct80) + Convert.ToInt16(o.record.wrong80)),
                correct80 = g.Sum(o => Convert.ToInt16(o.record.correct80)),
                percent80 = Convert.ToDouble(g.Sum(o => Convert.ToInt16(o.record.correct80))) /
                            g.Sum(o => Convert.ToInt16(o.record.correct80) + Convert.ToInt16(o.record.wrong80))
            };

上面抛出了错误，所以我尝试了以下方法：

var groups =
    from record in startTimes
    group record by record.startTime
    into g
    select g;

var statistics = groups.ToList().Select(
    g => new e_activeSession
             {
                 workerId = wcopy,
                 startTime = g.Key.GetValueOrDefault(),
                 totalTasks = g.Count(),
                 totalTime = g.Max(o => o.record.timeInSession).GetValueOrDefault(),
                 minDwell = g.Min(o => o.record.dwellTime).GetValueOrDefault(),
                 maxDwell = g.Max(o => o.record.dwellTime).GetValueOrDefault(),
                 avgDwell = g.Average(o => o.record.dwellTime).GetValueOrDefault(),
                 stdevDwell = g.Select(o => Convert.ToDouble(o.record.dwellTime)).StdDev(),
                 total80 = g.Sum(o => Convert.ToInt16(o.record.correct80) + Convert.ToInt16(o.record.wrong80)),
                 correct80 = g.Sum(o => Convert.ToInt16(o.record.correct80)),
                 percent80 = Convert.ToDouble(g.Sum(o => Convert.ToInt16(o.record.correct80))) /
                             g.Sum(o => Convert.ToInt16(o.record.correct80) + Convert.ToInt16(o.record.wrong80))
             });

然而，这ToList似乎是非常低效的，只是让我的代码在那里呆了很长时间。有一个更好的方法吗？

4

1 回答 1

2

AsEnumerable()将做与将处理引入 linq-to-objects 相同的事情ToList()，但不会浪费时间和内存先存储所有这些。相反，当您遍历它时，它会一次创建一个对象。

作为一项规则，您应该使用AsEnumerable()将操作从另一个源移动到内存中，而不是ToList()除非您真的想要一个列表（例如，如果您将多次访问相同的数据，因此该列表充当缓存）。

到目前为止，我们有：

var statistics = (
  from record in startTimes
  group record by record.startTime
  into g
  select g;
  ).AsEnumerable().Select(
    g => new e_activeSession
    {
      workerId = wcopy,
      startTime = g.Key.GetValueOrDefault(),
      totalTasks = g.Count(),
      totalTime = g.Max(o => o.record.timeInSession).GetValueOrDefault(),
      /* ... */
     });

但还有一个更大的问题。你也要小心group by。当与聚合方法一起完成时，通常没问题，但否则它最终会变成许多数据库调用（一个用于获取键的不同值，然后每个值一个）。

考虑到上述情况（我省略了没有提到每一列）。如果不使用AsEnumerable()（或ToList()你有什么），因为wcopy可能完全在查询之外（我看不到它的定义位置），第一个生成的 SQL 将是（如果允许的话），类似于：

select startTime, count(id), max(timeInSession), /* ... */
from tasks
group by startTime

这应该由数据库非常有效地处理（如果不是，请检查索引并在生成的查询上运行数据库引擎优化顾问）。

但是，在内存中进行分组时，它可能会首先执行：

select distinct startTime from tasks

进而

select timeInSession, /* ... */
from tasks
where startTime = @p0

对于找到的每一个不同的startTime，将其作为@p0. 无论其余代码的效率如何，这很快就会变成灾难性的。

我们有两个选择。哪个是最好的会因情况而异，所以我会给出两者，尽管第二个在这里是最有效的。

有时我们最好的方法是加载所有相关行并在内存中进行分组：

var statistics =
  from record in startTimes.AsEnumerable()
  group record by record.startTime
  into g
  select new e_activeSession
  {
    workerId = wcopy,
    startTime = g.Key.GetValueOrDefault(),
    totalTasks = g.Count(),
    totalTime = g.Max(o => o.record.timeInSession).GetValueOrDefault(),
    /* ... */
  };

我们也许可以通过只选择我们关心的列来提高效率（如果上面使用了表中的每一列，则无关紧要）

var statistics =
  from record in (
    from dbRec in startTimes
    select new {dbRec.startTime, dbRec.timeInSession, /*...*/}).AsEnumerable()
    group record by record.startTime
    into g
    select new e_activeSession
    {
      workerId = wcopy,
      startTime = g.Key.GetValueOrDefault(),
      totalTasks = g.Count(),
      totalTime = g.Max(o => o.record.timeInSession).GetValueOrDefault(),
      /* ... */
    };

不过，我认为这不是最好的情况。我会在我要枚举组的情况下使用它，然后枚举每个组。在您对每个组进行聚合而不枚举它们的情况下，最好将该聚合工作保留在数据库中。数据库擅长它们，它将大大减少通过网络发送的数据总量。在这种情况下，我能想到的最好的方法是强制一个新对象，而不是镜像它的实体类型，但它不被识别为实体。您可以为此创建一个类型（如果您对此进行了多个变体，则很有用），否则只需使用匿名类型：

var statistics = (
  from record in startTimes
  group record by record.startTime
  into g
  select new{
    startTime = g.Key.GetValueOrDefault(),
    totalTasks = g.Count(),
    totalTime = g.Max(o => o.record.timeInSession).GetValueOrDefault(),
    /* ... */
  }).AsEnumerable().Select(
    d => new e_activeSession
    {
      workerId = wcopy,
      startTime = d.startTime,
      totalTasks = d.totalTasks,
      /* ... */
    });

这样做的明显缺点是纯粹的冗长。但是，它将保持操作最好在数据库中完成，在数据库中，同时仍然不会像这样ToList()做那样浪费时间和内存，不会重复访问数据库，并将e_activeSession创建从 linq2sql 拖到 linq2objects 中，因此应该允许。

（顺便说一句，.NET 中的约定是类和成员名称以大写开头。这没有技术原因，但这样做意味着您将匹配更多人的代码，包括 BCL 和您使用的其他库的代码）。

编辑：顺便说一下；我刚刚看到你的另一个问题。请注意，在某种程度上，AsEnumerable()这里是导致该问题的确切原因的变体。了解这一点，您就会对不同的 linq 查询提供程序之间的界限有了很多了解。

于 2012-08-04T01:08:51.413 回答