如何将指定MSSQL查询转换为LINQ表达式？

首先，你的现有代码已经完成了「获取每个IP最近5条记录」的核心逻辑，但还有几个关键环节需要补充：关联ReputationIps和ReputationMonitorGroups获取分组名称、给每条记录标记行号，最后按行号和分组名称聚合计算平均值。

以下是适配原SQL逻辑的完整LINQ实现（假设你使用Entity Framework，且仓储层能正确提供对应表的数据）：

var lastRecordNum = 5;
var result = 
    from rh in reputationHistoryRepository.GetAll()
    // 完成原SQL的两个INNER JOIN关联，获取分组名称
    join ip in reputationIpRepository.GetAll() on rh.ReputationIpId equals ip.Id
    join ipGroup in reputationMonitorGroupRepository.GetAll() on ip.ReputationMonitorGroupId equals ipGroup.Id
    // 按IP分组，对应原SQL的PARTITION BY ReputationIpId
    group new { rh, ipGroup.Name } by rh.ReputationIpId into ipRecordGroup
    // 给每个IP组内的记录按时间倒序生成行号，过滤最近5条
    from rankedRecord in ipRecordGroup
        .OrderByDescending(x => x.rh.CheckDateTime) // 时间倒序，最近的记录排最前
        .Select((item, index) => new {
            item.rh.Reputation,
            item.Name,
            RowNum = index + 1 // 生成从1开始的行号，对应原SQL的ROW_NUMBER()
        })
        .Where(x => x.RowNum <= lastRecordNum)
    // 按行号和分组名称聚合，计算平均值
    group rankedRecord by new { rankedRecord.RowNum, rankedRecord.Name } into finalGroup
    orderby finalGroup.Key.RowNum
    select new {
        finalGroup.Key.RowNum,
        finalGroup.Key.Name,
        AvgReputation = finalGroup.Average(x => x.Reputation)
    };

关键细节说明： #

• 表关联优化：如果你的实体类配置了导航属性（比如ReputationHistory包含ReputationIp属性，ReputationIp包含ReputationMonitorGroup属性），可以把join替换成导航属性访问，代码会更简洁：

  // 替换JOIN部分的写法
  let groupName = rh.ReputationIp.ReputationMonitorGroup.Name
  

• 行号生成逻辑：使用Select((item, index))的重载方法，给每个IP组内的记录生成行号，完美对应原SQL的ROW_NUMBER() OVER (PARTITION BY ... ORDER BY ... DESC)。
• 性能优化建议：你的原代码用了OrderBy(gr => gr.CheckDateTime).TakeLast(lastRecordNum)，建议改成OrderByDescending(...).Take(lastRecordNum)——因为EF对TakeLast的支持有限（多数情况需要客户端内存评估），而OrderByDescending+Take可以直接转换为SQL的TOP语句，性能更优。

内容的提问来源于stack exchange，提问作者grinay