1

我通过 FluentNHibernate 映射了以下域

class Point
{
    public int Id { get; set; }
    public string Label { get; set; }
}

class PointData
{
    public int Id { get; set; }        
    public DateTime Hour { get; set; } 
    public decimal Value { get; set; }
    public Point Location { get; set; }
    public DateTime Available { get; set; } // Data arrival (data tracking)
}

PointData 表将频繁更新插入一个 Hour 的新值（不支持更新），但并非所有点都以相同的频率写入 PointData。

我需要在 startTime 和 endTime 之间以及 timeOfSnapshot（可用）之前的所有小时内获取每个 Point 的最新 PointData。

到目前为止，我使用 group by 使用 Linq to Nhibernate 的查询不起作用：

Query.Where(x => x.Available <= available && x.Hour >= startHour && x.Hour < endHour)
                    .OrderByDescending(x => x.Available)
                    .GroupBy(x => new {x.Location, x.Hour})
                    .Select(g => g.First())
                    .ToList();

到目前为止，所有搜索都只提出了 SQL 查询，这并不是我想要的。

有帮助

4

2 回答 2

1

将 group by 结果与原始行连接并返回行：

rows.Join(
   rows.GroupBy(x => new {x.Location, x.Hour}), 
   x => new {x.Location, x.Hour, x.Available}, 
   g => new {g.Key.Location, g.Key.Hour, Available = g.Max(p=>p.Available)},
   (x1,g1) => x1
)

放上探查器，您将看到以下 sql：

SELECT [t0].*
FROM [rows] AS [t0]
INNER JOIN (
    SELECT MAX([t1].[Available]) AS [value], [t1].[Location], [t1].[Hour]
    FROM [rows] AS [t1]
    GROUP BY [t1].[Location], [t1].[Hour]) 
AS [t2] ON (
    [t0].[Location] = [t2].[Location]) 
    AND ([t0].[Hour] = [t2].[Hour]) 
    AND ([t0].[Available] = [t2].[value]
)
于 2013-02-08T07:26:16.683 回答
0

在分组依据之后，您不能提取比分组键或聚合中使用的更多的列。如果我正确理解您的问题，通常的模式是使用一个子查询来选择感兴趣的行的标识符，然后是一个外部查询来获取这些行的所有列。尝试这样的事情：

var latestPointId =
    Query.Where(x => x.Available <= available && x.Hour >= startHour && x.Hour < endHour)
        .OrderByDescending(x => x.Available)
        .GroupBy(x => new {x.Location, x.Hour})
        .Select(g => g.Max(pd => pd.Id));

session.Query<PointData>
    .Where(pd => latestPointId.Contains(pd.Id)
    .ToList();
于 2013-02-06T07:45:01.257 回答