基于AspNetCore EF与OData8的嵌套实体聚合统计方案问询

安全阿岳

2026-7-15

问题描述

针对包含多层嵌套实体（Entity1至Entity5）的大型关系数据库（各实体数据量超10万，部分Entity1无关联Entity2），需要基于AspNetCore EntityFramework Core 6.0.18和OData 8.2.0实现按根实体Entity1汇总各层级实体计数，以及Entity5中Value字段求和的最优方案，期望输出格式如下：

[ 
   { "E1": "e1_1", "E2_Cnts": 5622, "E3_Cnts": 876, "E4_Cnts": 3242, "E5_Cnts": 12, "E5_Sum":42343},
   { "E1": "e1_2", "E2_Cnts": 64, "E3_Cnts": 978, "E4_Cnts": 321, "E5_Cnts": 0, "E5_Sum":0},
   ...
]

已尝试三种方案，但存在局限：

OData8展开查询：可获取结果但返回数据量过大，需手动映射统计，效率低
OData8 GroupBy聚合：性能优异，但仅能统计Entity5计数，且无法包含无关联Entity5的Entity1
LINQ关联查询：需加载大量数据，查询耗时久

目标是优化OData8 GroupBy方案，实现多层级聚合统计，同时将Entity1名称提升至结果根节点，确保所有Entity1都被包含。

优化方案

1. 基于OData GroupBy的多层聚合+左连接处理空值

OData 8.2.0支持嵌套GroupBy和聚合函数，结合EF Core的左连接特性，可以解决空值Entity1的包含问题，同时实现多层计数和求和。

核心思路：

从Entity1出发，通过左连接关联所有下级实体，确保无关联的Entity1被保留
使用OData的$apply语法，结合groupby和聚合函数（count/sum）实现多层统计
最终投影到目标格式，将Entity1的名称作为根节点字段

具体OData查询示例：

/Entity1?$apply=
groupby(
    (Name), 
    aggregate(
        Entity2/$count as E2_Cnts,
        Entity2/Entity3/$count as E3_Cnts,
        Entity2/Entity3/Entity4/$count as E4_Cnts,
        Entity2/Entity3/Entity4/Entity5/$count as E5_Cnts,
        Entity2/Entity3/Entity4/Entity5/Value with sum as E5_Sum
    )
)&$select=Name,E2_Cnts,E3_Cnts,E4_Cnts,E5_Cnts,E5_Sum

关键说明：

使用$apply替代单纯的$groupby，支持嵌套聚合操作
左连接由EF Core+OData自动处理，当Entity1无关联下级实体时，聚合结果自动返回0（需确保实体导航属性配置为可选）
sum函数在无数据时返回0，需在EF Core模型中配置Value字段为可空类型或设置默认值

2. EF Core模型配置优化

为确保OData查询能生成高效SQL，需在EF Core中正确配置可选导航属性：

// Entity1与Entity2的关联配置
modelBuilder.Entity<Entity1>()
    .HasMany(e => e.Entity2)
    .WithOne(e => e.Entity1)
    .IsRequired(false); // 允许Entity1无关联Entity2

// 下级实体关联同理配置为可选
modelBuilder.Entity<Entity2>()
    .HasMany(e => e.Entity3)
    .WithOne(e => e.Entity2)
    .IsRequired(false);

3. 控制器层轻量映射（可选）

如果OData直接返回的格式需要调整，可在控制器层通过LINQ投影实现（仅生成聚合SQL，不加载全量数据）：

[EnableQuery]
public IQueryable<object> GetAggregatedStats()
{
    return _context.Entity1
        .Select(e1 => new 
        {
            E1 = e1.Name,
            E2_Cnts = e1.Entity2.Count(),
            E3_Cnts = e1.Entity2.SelectMany(e2 => e2.Entity3).Count(),
            E4_Cnts = e1.Entity2.SelectMany(e2 => e2.Entity3).SelectMany(e3 => e3.Entity4).Count(),
            E5_Cnts = e1.Entity2.SelectMany(e2 => e2.Entity3).SelectMany(e3 => e3.Entity4).SelectMany(e4 => e4.Entity5).Count(),
            E5_Sum = e1.Entity2.SelectMany(e2 => e2.Entity3).SelectMany(e3 => e3.Entity4).SelectMany(e4 => e4.Entity5).Sum(e5 => (decimal?)e5.Value) ?? 0
        });
}

性能验证

该方案生成单条聚合SQL查询，避免多次数据库往返
为各实体外键字段创建索引后，可确保超10万数据量下的高效查询
无关联的Entity1会被正确包含，所有聚合字段在无数据时返回0

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