领域驱动设计：每个聚合根的存储库？

Question

我正在尝试弄清楚如何完成以下任务：

User can have many Websites

在向用户添加新网站之前，我需要做的是获取网站 URL 并将其传递给一个方法，该方法将检查该网站是否已存在于数据库中（另一个用户具有关联的相同网站），或者是否创建新记录。 <= 原因在于是创建新缩略图还是使用现有缩略图。

问题是存储库应该是每个聚合根的，这意味着我无法执行上面解释的操作？ - 我可以首先获取数据库中的所有用户，然后使用 if 语句进行 foreach 查找，检查用户在何处拥有具有相同 URL 的网站记录，但这会导致无休止且缓慢的过程。

Answer 1

无论您使用哪种存储库方法，您都应该能够以某种方式指定标准。因此，搜索与相关网站关联的用户 - 如果搜索未返回任何用户，则该网站未被使用。

例如，您可以添加具有以下签名的方法（或者将查询对象传递为 本文中描述）：

User GetUser(string hasUrl);

该方法应该生成或多或少像这样的 SQL：

select u.userId
from   User u
join   Website w
on     w.UserId = u.UserId
where  w.Url    = @url

这应该与查询网站 直接上表；无需将所有用户和网站记录加载到内存中。让您的关系数据库承担繁重的工作，并让您的存储库实现（或对象关系映射器）处理翻译。

Answer 2

我认为你的模型存在一个根本问题。如果我理解正确的话，网站是用户聚合组的一部分。这意味着网站实例不具有全局范围，它仅在属于用户的上下文中才有意义。

但现在，当用户想要添加新网站时，在创建新网站之前，您首先要检查“数据库中是否存在该网站”。这意味着网站实际上具有全球范围。否则，每当用户请求新网站时，您都将为该特定用户创建一个新网站，并且该网站在该用户范围内有意义。这里的网站是共享的，因此对许多用户来说有意义，因此不属于用户聚合的一部分。

修复你的模型，你就会解决你的查询困难。

Answer 3

一种策略是实现可以验证约束的服务。

public interface IWebsiteUniquenessValidator 
{
    bool IsWebsiteUnique(string websiteUrl);
}

然后你必须实现它，你如何做到这一点将取决于我不知道的因素，但我建议不要担心通过域。让它变得简单，这只是一个查询（* - 我将在底部添加到此）。

public class WebsiteUniquenessValidator : IWebsiteUniquenessValidator
{
 //.....
}

然后，将其“注入”到需要它的方法中。我说“注入”是因为我们将从域外部将其提供给域对象，但是..我们将使用方法参数而不是构造函数参数来执行此操作（以避免要求我们的实体由 IoC 容器实例化） ）。

public class User 
{
    public void AddWebsite(string websiteUrl, IWebsiteUniquenessValidator uniquenessValidator) 
    {
        if (!uniquenessValidator.IsWebsiteUnique(websiteUrl) {
            throw new ValidationException(...);
        }

        //....
    }
}

无论您的用户及其存储库的使用者是什么 - 如果是服务类或 CommandHandler - 都可以提供唯一性验证器依赖项。该消费者应该已经通过 IoC 连接起来，因为它将使用 UserRepository：

public class UserService 
{
    private readonly IUserRepository _repo;
    private readonly IWebsiteUniquenessValidator _validator;

    public UserService(IUserRepository repo, IWebsiteUniquenessValidator validator) 
    {
        _repo = repo;
        _validator = validator;
    }

    public Result AddWebsiteToUser(Guid userId, string websiteUrl)
    {
        try {
            var user = _repo.Get(userId);
            user.AddWebsite(websiteUrl, _validator);
        }
        catch (AggregateNotFoundException ex) {
          //....
        }
        catch (ValidationException ex) {
          //....
        }
    } 


}

*我提到过使验证变得简单并避免域。

我们构建域来封装与修改数据相关的通常复杂的行为。

经验表明，更改数据的要求与查询数据的要求非常不同。

这似乎是您遇到的一个痛点，因为您试图强制读取通过写入系统。

可以将数据的读取与域、写入端分开，以减轻这些痛点。

CQRS 是该技术的名称。我只想说，当我在 CQRS 的上下文中查看 DDD 时，一大堆灯泡都亮了。我强烈建议尝试理解 CQRS 的概念。