在DDD与EF Core中通过聚合根Post获取指定ID的Category及关联Post

这是一个简单博客系统，包含以下实体：Posts - PostsCategories - Categories，Post与Category为多对多关系。

实体代码 #

Post 实体 #

// Post
public Id { get; private set; }
public Title { get; private set; }
public IReadOnlyCollection<PostsCategories> Categories => _categories;
private List<PostsCategories> _categories = new();

Category 实体 #

// Category
public Id { get; private set; }
public Title { get; private set; }
public IReadOnlyCollection<PostsCategories> Posts => _posts;
private List<PostsCategories> _posts = new();

PostsCategories 值对象 #

// PostsCategories (这是值对象)
public Guid PostId { get; private set; }
public Post Post { get; protected set; }

public Guid CategoryId { get; private set; }
public Category Category { get; protected set; }

聚合规则说明 #

这三个实体属于Blog聚合：Post为聚合根，Category为实体，PostsCategories为值对象。根据DDD规则，每个聚合根对应一个仓库，其他成员不能拥有独立仓库。

如何在PostsRepository.cs中通过Category ID获取单个包含其关联Post的Category？

以下查询是否正确？（从性能与规范角度）

var category = await Entity
.Include(x => x.Categories)
.ThenInclude(x => x.Category)SelectMany(x => x.Categories)
.Select(x => x.Category)
.FirstOrDefaultAsync(x => string.Equals(x.Slug.Value, slug, StringComparison.OrdinalIgnoreCase));

先看你给出的查询问题 #

你的代码存在语法错误：ThenInclude(x => x.Category)和SelectMany(x => x.Categories)之间缺少点号，修正后代码如下：

var category = await Entity
    .Include(x => x.Categories)
    .ThenInclude(x => x.Category)
    .SelectMany(x => x.Categories)
    .Select(x => x.Category)
    .FirstOrDefaultAsync(x => string.Equals(x.Slug.Value, slug, StringComparison.OrdinalIgnoreCase));

但即便修正语法，这个查询仍有明显问题：

1. 性能问题：先加载所有Post及其关联的Categories再展开筛选，会拉取大量无关数据，Post数量较多时性能会严重下降。
2. DDD规范问题：从聚合根Post反向查询Category，绕过了聚合根的边界设计，逻辑上不符合聚合的使用初衷。

正确实现方式 #

方式一：EF Core直接查询（性能优先）

虽然Category属于Post聚合，但在EF Core中可以直接通过DbContext查询Category实体，同时关联加载其关联的Post。在PostsRepository中注入DbContext后，写如下查询：

public async Task<Category> GetCategoryWithPostsByIdAsync(Guid categoryId)
{
    return await _dbContext.Categories
        .Include(c => c.Posts)
        .ThenInclude(pc => pc.Post)
        .FirstOrDefaultAsync(c => c.Id == categoryId);
}

该查询直接定位目标Category，仅加载所需数据，性能最优，实际项目中这种实现方式非常普遍。

方式二：严格遵循DDD聚合边界（规范优先）

如果要严格贴合DDD聚合边界要求，可先查询所有关联目标Category的Post，再从中提取唯一的Category：

public async Task<Category> GetCategoryWithPostsByIdAsync(Guid categoryId)
{
    var posts = await _dbContext.Posts
        .Include(p => p.Categories)
        .ThenInclude(pc => pc.Category)
        .Where(p => p.Categories.Any(pc => pc.CategoryId == categoryId))
        .ToListAsync();

    return posts.SelectMany(p => p.Categories)
        .Select(pc => pc.Category)
        .FirstOrDefault();
}

这种方式严格从聚合根Post出发，但会加载所有关联该Category的Post，适合数据量小且对DDD规范要求极高的场景。

总结 #

• 优先选方式一：兼顾性能与实现可行性，是实际项目中的主流做法。
• 若严格遵循DDD边界且数据量小，可选择方式二。
• 你最初的查询存在语法、性能、规范三重问题，不建议使用。

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