基于DDD模式与EF Core查询嵌套聚合根关联数据的问题

问题背景 #

在DDD结构实践中对模式理解不深，当前数据库ERD为App Orders ERD，包含三个聚合根：AppOrders、AppTests、AppAntibiotics。AppOrders包含嵌套列表AppOrderItems，与AppMicrobiologicalReportResults为一对一关联（EF采用TPT表策略），后者拥有Sensitive、Intermediate、Resistant三个与AppAntibiotics的多对多关联列表，这是核心问题所在。需要基于DDD最佳实践，用EF Core查询出指定结构的输出数据，避免与DDD模式冲突。

技术栈 #

• Abp Framework、.Net Core 7、SqlLite

当前代码与配置 #

现有Action Method代码 #

public async Task<MicrobiologicalReportResultDto> GetMicrobiologicalReport(Guid id,Guid itemId)
{
    
    var itemsQuery = await _itemsRepository.WithDetailsAsync();
    itemsQuery = itemsQuery.Where(x => x.OrderId == id && x.Id == itemId);

    var testQuery = await _testRepository.GetQueryableAsync();
    
    // This is Antibiotic Query
    var antibioticsQuery = await _antibioticsRepository.GetQueryableAsync();

    var query = 
        from item in itemsQuery 
        join test in testQuery 
            on item.TestId equals test.Id
        select new { item, test};

    var entity = await AsyncExecuter.FirstOrDefaultAsync(query);

    if (entity is null)
    {
        throw new EntityNotFoundException();
    }
    if (entity.item is not MicrobiologicalReportResult)
    {
        throw new BusinessException("Error Types");
    }

    var rc = ObjectMapper.Map<MicrobiologicalReportResult,MicrobiologicalReportResultDto>(
        entity.item.As<MicrobiologicalReportResult>());
    
    rc.TestName = entity.test.Name;

    return rc;
}

EF Fluent API配置 #

builder
    .HasMany(x => x.Sensitive)
    .WithMany()
    .UsingEntity<MicrobiologicalAntibiotic>("MicrobiologicalReportSensitiveAntibiotics",
        l=>l.HasOne<Antibiotic>()
            .WithMany()
            .HasForeignKey(c=>c.AntibioticId),
        r=>r.HasOne<MicrobiologicalReportResult>()
            .WithMany(x=>x.SensitiveItems)
            .HasForeignKey(c=>c.OrderItemId));

// Others Removed for lack of complexity

测试用SQL语句 #

select * from AppOrderItems itemsQuery
left outer join AppTests testsQuery
on testsQuery.Id = itemsQuery.TestId
left outer join MicrobiologicalReportSensitiveAntibiotics sens
on sens.OrderItemId = itemsQuery.Id
left outer join AppAntibiotics antbiotic 
on sens.AntibioticId = antbiotic.Id

解决方案 #

优化后的查询实现 #

结合DDD聚合根规则与EF Core导航属性特性，重构查询代码如下：

public async Task<MicrobiologicalReportResultDto> GetMicrobiologicalReport(Guid id, Guid itemId)
{
    // 直接查询目标类型，同时预加载多对多关联的抗生素列表
    var reportResult = await _itemsRepository
        .WithDetailsAsync(x => 
            ((MicrobiologicalReportResult)x).Sensitive,
            ((MicrobiologicalReportResult)x).Intermediate,
            ((MicrobiologicalReportResult)x).Resistant)
        .Where(x => x.OrderId == id && x.Id == itemId)
        .OfType<MicrobiologicalReportResult>()
        .FirstOrDefaultAsync();

    if (reportResult == null)
    {
        throw new EntityNotFoundException();
    }

    // 跨聚合根查询：通过ID单独获取Test聚合根，符合DDD交互原则
    var test = await _testRepository.GetAsync(reportResult.TestId);

    var dto = ObjectMapper.Map<MicrobiologicalReportResult, MicrobiologicalReportResultDto>(reportResult);
    dto.TestName = test.Name;

    return dto;
}

关键说明 #

1. DDD合规性

   • 聚合根MicrobiologicalReportResult关联的抗生素列表，通过EF导航属性加载，避免手动跨聚合join。如果AppAntibiotics是独立聚合根，建议仅映射必要字段（如ID、名称），而非整个实体，减少聚合边界泄露。
   • 跨聚合查询AppTests时，通过ID单独获取，符合聚合根之间仅通过ID交互的DDD原则。

2. EF Core查询优化

   • 使用WithDetailsAsync指定预加载的导航属性，避免N+1查询问题，生成的SQL逻辑与你提供的测试SQL一致。
   • OfType<MicrobiologicalReportResult>直接过滤TPT继承中的目标类型，省去后续类型判断步骤。

3. 多对多关联处理

   • 你的Fluent API已正确配置多对多关系，通过WithDetailsAsync加载后，reportResult.Sensitive、Intermediate、Resistant会自动填充关联数据，无需手动group或join操作。

进一步优化建议 #

若AppAntibiotics为独立聚合根，可创建精简的AntibioticDto，仅包含前端需要的字段，映射时避免暴露完整聚合根内部状态：

// 添加映射配置
CreateMap<Antibiotic, AntibioticDto>();

// 在查询后映射抗生素列表
dto.SensitiveAntibiotics = ObjectMapper.Map<List<Antibiotic>, List<AntibioticDto>>(reportResult.Sensitive.ToList());
dto.IntermediateAntibiotics = ObjectMapper.Map<List<Antibiotic>, List<AntibioticDto>>(reportResult.Intermediate.ToList());
dto.ResistantAntibiotics = ObjectMapper.Map<List<Antibiotic>, List<AntibioticDto>>(reportResult.Resistant.ToList());

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