c# - EntityFramework GroupBy 与 DBFunctions 或替代

Question

我有 100 行不同日期的数据。我想每隔 30 分钟按相同日期对结果进行分组。

相反:
结果一，2016-02-02 13:00:24
结果一，2016-02-02 13:01:24
结果一，2016-02-02 13:02:24
结果一，2016-02-02 13:33:24

需要:

结果一，2016-02-02 13:00:24
结果一，2016-02-02 13:33:24

原始查询:

    return await loc.Where(p => p.ReadTime >= df && p.ReadTime <= dt)
        .OrderBy(p => p.ReadTime)
        .ProjectTo<LocationModel>().ToListAsync();

我尝试过的:

    return await loc.Where(p => p.ReadTime >= df && p.ReadTime <= dt)
        .GroupBy(p => DbFunctions.TruncateTime(p.ReadTime))
        .Select(p => new LocationModel
        {
            Lng = p.FirstOrDefault().Lng,
            Lat = p.FirstOrDefault().Lat
        })
        .ToListAsync();

堆栈跟踪错误:

.ThrowForNonSuccess(Task task)\r\n at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification (Task task)\r\n at System.Runtime.CompilerServices.TaskAwaiter1.GetResult()\r\n at
System.Web.Http
.Dispatcher.HttpControllerDispatcher.<SendAsync>d__1.MoveNext()","innerException":{"message":"An
error has occurred.","exceptionMessage":"Timeout expired. The
timeout period elapsed prior to completion of the operation or the
server is not
responding.","exceptionType":"System.Data.SqlClient.SqlException"
,"stackTrace":" at
System.Data.SqlClient.SqlCommand.<>c.<ExecuteDbDataReaderAsync>b__167_0(Task1 result )\r\n at System.Threading.Tasks.ContinuationResultTaskFromResultTask`2.InnerInvoke()\r\n at System .Threading.Tasks.Task.Execute()\r\n--- End of stack trace from previous location where exception was thrown ---\r\n at System.Runtime.CompilerServices.TaskAwaiter.ThrowForNonSuccess(Task task)\r\n at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)\r \n at System.Data.Entity.Core.EntityClient.Internal.EntityCommandDefinition.

d__c.MoveNext()","innerException":{"message":"An error has occurred.","exceptionMessage":"The wait operation timed out","exceptionType":"System.ComponentModel.Win32Exception","stackTrace":null}}}

Answer 1

除了将所有数据加载到内存中并根据需要手动格式化外，我能想到的唯一可行的方法是将行放入预定义的日期“桶”中从每个桶中选择一行。

桶的最合乎逻辑的选择是在整点和整点半，因为您正在寻找 30 分钟的间隔，例如:

Result 1, 2016-02-02 13:00:24, 2016-02-02 13:00:00 (bucket 1)
Result 1, 2016-02-02 13:01:24, 2016-02-02 13:00:00 (bucket 1)
Result 1, 2016-02-02 13:02:24, 2016-02-02 13:00:00 (bucket 1)
Result 1, 2016-02-02 13:33:24, 2016-02-02 13:30:00 (bucket 2)

下一个要解决的问题是为每个桶选择使用哪一行。您可以使用的一种方法是确定最接近桶(最小)的日期并使用它:

from l in loc
join bucket in (
    from l in loc
    group l by new DateTime(l.ReadTime.Year, l.ReadTime.Month, l.ReadTime.Day, l.ReadTime.Hour, l.ReadTime.Minute < 30 ? 0 : 30, 0) into g
    select g.Min(m => m.ReadTime)
) on l.ReadTime equals bucket
select new LocationModel
{
    Lng = l.FirstOrDefault().Lng,
    Lat = l.FirstOrDefault().Lat
}

使用这种方法时需要小心，因为如果有具有相同日期/时间值的行，您最终可能会得到重复项。如果实体/表使用标识列作为其主键，并且行以日期/时间顺序的方式插入到表中，您可以使用键来确定每个存储桶的行，因为键实际上是按日期升序排列的:

from l in loc
join bucket in (
    from l in loc
    group l by new DateTime(l.ReadTime.Year, l.ReadTime.Month, l.ReadTime.Day, l.ReadTime.Hour, l.ReadTime.Minute < 30 ? 0 : 30, 0) into g
    select g.Min(m => m.Id)
) on l.Id equals bucket
select new LocationModel
{
    Lng = l.FirstOrDefault().Lng,
    Lat = l.FirstOrDefault().Lat
}

这将确保没有重复。否则，您要么需要过滤代码中的重复项，要么进一步扩展查询。不过，我对您的特定领域了解不够，所以我将把这部分留给您解决。

我还应该指出，Linq to SQL 支持上述查询，但是如果某些内容不受支持(例如 DbFunctions.CreateDateTime)，您可能需要将 DbFunctions 类用于 EF 的 DateTime 位。