EF Core中Join结合GroupBy的LINQ表达式无法转换求助

问题原因 #

你当前的代码中，Join右侧的GroupBy(c => c.CarId).Select(cases => cases.OrderByDescending(c => c.CreatedAt).First())无法被EF Core 7正确转换为SQL。EF Core对GroupBy后的嵌套排序+取首条的组合支持有限，尤其是在作为Join的数据源时，无法解析这种复杂的内存式操作逻辑。

解决方案 #

以下是几种可行的修复方案，按推荐程度排序：

方案1：使用窗口函数（推荐）

EF Core 7支持SQL窗口函数，通过RowNumber()按CarId分区并按CreatedAt倒序编号，取编号为1的记录即为每辆车的最新Case，再与Car关联：

// 先筛选出每辆Car的最新Case
var latestCases = AllActiveCases()
    .Select(c => new
    {
        c.CarId,
        c.Id,
        // 按CarId分组，每组内按CreatedAt倒序排，生成行号
        RowNum = EF.Functions.RowNumber()
            .Over(PartitionBy(c.CarId).OrderByDescending(c.CreatedAt))
    })
    .Where(x => x.RowNum == 1); // 只保留每组的第一条（最新）

// 关联Car和最新Case
var result = await AllActive()
    .Join(latestCases,
        car => car.Id,
        caseRow => caseRow.CarId,
        (car, caseRow) => new OutputModel
        {
            CarId = car.Id,
            CaseId = caseRow.Id
        })
    .AsNoTracking()
    .ToListAsync(cancellationToken);

方案2：使用子查询获取最新Case ID

通过GroupBy+子查询提取每个Car的最新Case ID，再与Car关联，这种方式兼容性更好：

// 先获取每个Car对应的最新Case ID
var latestCaseIds = AllActiveCases()
    .GroupBy(c => c.CarId)
    .Select(g => new
    {
        CarId = g.Key,
        LatestCaseId = g.OrderByDescending(c => c.CreatedAt)
                        .Select(c => c.Id)
                        .FirstOrDefault()
    });

// 关联查询
var result = await AllActive()
    .Join(latestCaseIds,
        car => car.Id,
        latest => latest.CarId,
        (car, latest) => new OutputModel
        {
            CarId = car.Id,
            CaseId = latest.LatestCaseId
        })
    .AsNoTracking()
    .ToListAsync(cancellationToken);

方案3：利用导航属性（如果允许修改实体）

如果可以在Car实体中添加导航属性：

public class Car : IAggregateRoot
{
    public long Id { get; set; }
    public int Doors { get; set; }
    // 添加导航属性
    public ICollection<Case> Cases { get; set; } = new List<Case>();
}

则可以直接通过导航属性编写更简洁的查询：

var result = await AllActive()
    .Select(car => new OutputModel
    {
        CarId = car.Id,
        CaseId = car.Cases
            .Where(c => c.DeletedAt == null)
            .OrderByDescending(c => c.CreatedAt)
            .Select(c => c.Id)
            .FirstOrDefault()
    })
    .AsNoTracking()
    .ToListAsync(cancellationToken);

关于DistinctBy的问题 #

你之前尝试的DistinctBy会触发客户端评估：EF Core会先把所有符合条件的Case加载到内存，再在内存中去重，这不仅效率低，而且如果没有先按CreatedAt倒序排序，DistinctBy只会保留每组中最先被加载的记录，而非最新的，因此无法满足需求。

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