.net - 使用Entity Framework和DDD时如何实例化新对象？

Question

我正在编写一个相当“纯粹”的 DDD 应用程序。我没有使用 CQRS。持久性是使用 EF6 的基础设施服务。

现在，假设我有一些方法需要创建类型 A 的新实体并将其添加到其他实体 (B) 的导航属性集合中。该方法可能位于域程序集中的某个位置，或者可能位于应用程序服务程序集中。

如果我正在编写一个小型应用程序，我只需调用 DBSet.Create 方法，以确保我获得对代理对象的引用(正在使用延迟加载)，然后我可以将其添加到 B 的导航属性中。

但是，鉴于我的应用程序和域程序集完全没有意识到我正在使用 EF 来实现持久性，我如何确保不会破坏延迟加载？如果我只是调用 A 的构造函数，那么我就没有代理对象。我应该在我的应用程序服务中处理这个事实(感觉完全错误)，或者也许使构造函数受到保护，然后将工厂传递给有问题的域/应用程序服务？

编辑:我做错了吗？也许我可以按如下方式减少/消除我的问题:

• 我习惯于能够添加到 EF 中的导航集合，保存，然后为我填充集合的另一端。但是，在 DDD 中，在创建时，我想我应该填充新实体所具有的任何关系的两端？这将消除我的导航问题。
• 我还需要代理对象吗？我猜大多数情况下不会。在持久化新实体的事务发生之前，无需从数据库中获取任何内容。
• 如果我试图将 DBContext 的生命周期保持在创建(插入)事务之外，那么我需要让持久层将新实体添加到 DBContext(这意味着跟踪已创建的实体) )，或者传入DBContext的DBSet.Create方法作为构造函数供工厂使用。

Answer 1

我认为您的最大问题

reasonably 'pure' DDD application

就是你的坚持胜过一切。如果您还记得蓝皮书及其模式(例如创建聚合的工厂)，那么拥有这些模式的原因是为了创建处于有效状态的域对象。这与坚持无关。

持久性逻辑最好放置在您的存储库中。域应该做它应该做的事情——域逻辑。持久性应该注意你的领域模型以某种方式持续存在。如果您选择 EF 就很好 - 只需进行适当的映射并注意阻抗不匹配。但是，在调用 repository.Add(myNewAggregate) 之前，考虑 EF 内部结构没有什么意义。

如果您对使用 EF 简化、典型地实现某些 DDD 战术模式的示例感兴趣，您可以在下面找到一个示例。

免责声明:我刚刚写的，没有用实际数据库进行测试。没有身份处理，没有 IoC/DI 配置，没有事务。但我希望你能明白。 EF只是实现这些接口(interface)的一种方式，几行代码就可以是NHibernate、Marten、RavenDb或者其他什么。

using System;
using System.Collections.Generic;
using System.Data.Entity;
using System.Linq;
using System.Linq.Expressions;

namespace SomeStuff
{
    public interface IAggregateRoot
    {
        int Id { get; }
    }

    public interface IRepository<T> where T : IAggregateRoot
    {
        IUnitOfWork UnitOfWork { get; }
        void Add(T entity);
        T Load(int id);
    }

    public interface IUnitOfWork
    {
        void Commit();
    }

    public class EntityFrameworkUnitOfWork : IUnitOfWork
    {
        public EntityFrameworkUnitOfWork(DbContext context)
        {
            Context = context;
        }

        public DbContext Context { get; }

        public void Commit() => Context.SaveChanges();
    }

    public class EntityFrameworkRepository<T> : IRepository<T> where T : class, IAggregateRoot
    {
        private readonly DbSet<T> _set;
        public IUnitOfWork UnitOfWork { get; }

        public EntityFrameworkRepository(EntityFrameworkUnitOfWork unitOfWork)
        {
            UnitOfWork = unitOfWork;
            _set = unitOfWork.Context.Set<T>();
        }

        public void Add(T entity) => _set.Add(entity);

        public T Load(int id) => _set.Find(id);

        protected IQueryable<T> Query(Expression<Func<T, bool>> filter) => _set.Where(filter);
    }

    public class Employee : IAggregateRoot
    {
        public int Id { get; set; }
        public string Name { get; private set; }
        public int DepartmentId { get; private set; }

        private Employee(string name)
        {
            Name = name;
        }

        public static Employee Create(string name) =>
            new Employee(name);

        public void AssignToDepartment(int departmentId) => DepartmentId = departmentId;
    }

    public interface IEmployeeRepository : IRepository<Employee>
    {
        IEnumerable<Employee> AllEmployeesForDepartment(int departmentId);
    }

    public class EmployeeRepository : EntityFrameworkRepository<Employee>, IEmployeeRepository
    {
        public EmployeeRepository(EntityFrameworkUnitOfWork unitOfWork) : base(unitOfWork)
        {
        }

        public IEnumerable<Employee> AllEmployeesForDepartment(int departmentId) =>
            Query(e => e.DepartmentId == departmentId);
    }

    public class EmployeeService
    {
        private readonly IEmployeeRepository _repository;

        public EmployeeService(IEmployeeRepository repository)
        {
            _repository = repository;
        }

        public void RegisterEmployee(string name)
        {
            var employee = Employee.Create(name);
            _repository.Add(employee);
            _repository.UnitOfWork.Commit();
        }

        public void AssignEmployeeToDepartment(int employeeId, int departmentId)
        {
            var employee = _repository.Load(employeeId);
            if (employee == null)
                throw new InvalidOperationException("Employee not found");

            employee.AssignToDepartment(departmentId);
            _repository.UnitOfWork.Commit();
        }
    }
}