15
public class Order
{
   List<OrderItem> Items {get; private set;}

   public AddItem(OrderItem item)
   {
       //логика добавления

       items.Add(item);
   }
}

Следуя методологии DDD вся логика домена находится внутри домена и не выносится в отдельные сервисы. Вопрос в том как сохранять изменения корня агрегации не используя ORM, ну или используя microOrm - Dapper. Как делаете вы?

4
  • 2
    Слишком много умных слов - спрашивая таким языком, вы ответ долго будете получать. Ну и вопрос - почему же таки не используя ORM - чем орм вам не угодил? Что такое microOrm - такой технологии не слышал, и чем же он в корне отличается от ORM, что ORM прямо таки не хочется использовать? 28 мая 2017 в 18:03
  • 1
    Посмотрите в сторону CQRS (разделение ответственности на команды и запросы). Когда за изменение данных будут отвечать отдельные команды, то не важно, что вы используете для DAL, так как реализация команды фактически скрыта. В вышем случае для сохранения Order, вы сможете написать реализацию команды Save так как посчитаете нужным, не привязываясь к ORM. 29 мая 2017 в 8:59
  • @PrimusSingularis, понятно что будет например команда AddItemToOrderCommand, внутри мы достанем Order, создадим Item положив его в Order. Вот и вопрос, как после всех манипуляций сохранить Order со всеми изменениями. Понятно что можно просто положиить item чисто sql insert. Вопрос как сделать, как делают отцы) по феншую) best practics
    – coder
    29 мая 2017 в 11:46
  • @coder Если вы делаете команду AddItemToOrderCommand, то она и будет сохранять Order, либо делаете generic команду SaveCommand<>, которая будет заниматься сохранением 29 мая 2017 в 14:05

1 ответ 1

13
+250

В соответствии с принципами DDD, хранением сущностей ведают хранилища, они же репозитории, которые позволяют читать и писать агрегаты. В данном случае, репозиторий заказов должен уметь прочитать и записать агрегат заказ, включающий позиции заказа.

Поскольку способ хранения сущностей может измениться с большой долей вероятности, мы объявляем в предметной области не реализацию репозитория, а только интерфейс:

public interface IOrderRepository
{
    Order Create();

    Order ReadById(int id);

    void Update(Order order);

    void DeleteById(ind id);
}

Реализация этого интерфейса будет находится в инфраструктурном слое приложения (термин Эрика Эванса). Не в DDD этот слой называют слоем доступа к данным. В соответствии с принципом сокрытия данных, с инфраструктурного слоя нельзя добраться до внутренних данных сущности Заказ.

Пример: у сущности Order есть свойство CreatedAt, то есть дата создания. По правилам предметной области это свойство только для чтения, то есть имеет метод-геттер, но не имеет метода-сеттера. Когда репозиторий заказов загружает данные из базы, он должен установить значения всех свойств, в том числе и CreatedAt. Но он не может этого сделать, потому что не может изменить значение свойства только для чтения.

Похожая проблема описана в GoF, и там для её решения применяют паттерн Memento (Хранитель). Он позволяет сохранить состояние объекта и восстановить его впоследствии. В классической схеме состояние хранится в виде, недоступном для анализа и понимания, но нам нужно кое-что другое.

Если мы используем СУБД, мы хотим, чтобы состояние было в таком виде, который удобно хранить в СУБД. Для этого мы вводим DTO-объекты для наших сущностей. Эти объекты также находятся в слое домена, поскольку являются частью его интерфейса для инфраструктурного уровня.

public class OrderDto
{
    public int Id { get; set; }

    public DateTime CreatedAt { get; set; }

    public OrderItemDto[] Items { get; set; }
}

public class OrderItemDto
{
    public int Id { get; set; }

    public int ProductId { get; set; }

    public decimal Count { get; set; }

    public decimal Amount { get; set; }
}

public class Order
{
     private readonly OrderDto dto;
     private readonly List<OrderItem> items;

     public int Id { get { return dto.Id; } }

     public DateTime CreatedAt { get { return dto.CreatedAt; } }

     public IReadOnlyCollection<OrderItem> Items { . . . }

     internal Order(OrderDto dto)
     {
         this.dto = dto;

         items = new List<OrderItem>();
         foreach (var orderItemDto in dto.Items)
             items.Add(new OrderItem(orderItemDto));
     }

     public void AddItem(Product product, decimal count)
     {
         var itemDto = new OrderItemDto
         {
             Id = 0,
             OrderId = this.Id,
             ProductId = product.Id,
             Count = count,
             Amount = product.Price * count
         };

         dto.Items.Add(itemDto);

         var item = new OrderItem(itemDto);
         items.Add(item);
     }
}

public class OrderItem
{
    internal OrderItem(OrderItemDto dto)
    {
        . . .
    }

    . . .
}

В таком виде, репозиторий загружает данные из базы, преобразует их в DTO-объект и затем из DTO-объекта создает объект предметной области. Либо он получает сущность предметной области, преобразует её в DTO-объект, и сохраняет его.

public class AdoOrderRepository : IOrderRepository
{
    private readonly SqlConnection connection;

    public AdoOrderRepository(SqlConnection connection)
    {
        this.connection = connection;
    }

    public Order ReadById(int id)
    {
        using (var command = connection.CreateCommand())
        {
            // загружаем данные заказа включая агрегированные позиции
            // в объект OrderDto
            OrderDto orderDto = . . .;

            // волшебным образом преобразуем OrderDto в Order
            Order order = . . .;

            return order;
        }
    }

    public void Update(Order order)
    {
        using (var command = connection.CreateCommand())
        {
            // волшебным образом преобразуем Order в OrderDto
            OrderDto orderDto = . . .;

            // обновляем данные из OrderDto
            . . .
        }
    }
}

Зафиксирую ещё раз: слой предметной области описывает сущности предметной области (Order, OrderItem), отдельно он описывает интерфейсы репозиториев (IOrderRepository), которые нужно реализовать в инфраструктурном слое (AdoOrderRepository), и, наконец, он описывает DTO-объекты (OrderDto, OrderItemDto), которые содержат все поля, которые сущность (Order) хочет долговременно хранить. Сущности (Order) содержат логику и скрывают реализацию, DTO-объекты содержат только данные и никакой логики.

Реализации репозиториев умеют работать с DTO-объектами, в частности, могут послать запрос на чтение к базе и записать результаты в DTO-объект, поскольку DTO-объект очень прост. Но как они преобразуют DTO-объект в сущность, и обратно? В примере кода, который я привёл выше, я написал, что это происходит волшебным образом.

Пришло время разобраться, как именно. Сохранять и восстанавливать своё состояние могли бы сами объекты предметной области, такие, как Order. Но у них есть основная функция — это Заказы предметной области. Добавление второй функции нарушит принцип единственной ответственности. Нам нужен отдельный класс, который должен иметь доступ к состоянию сущности Order. Но один класс не должен знать детали реализации другого класса.

Кроме случая, когда этот класс вложенный.

public class Order
{
    private readonly OrderDto dto;

    private Order(OrderDto dto)
    {
        this.dto = dto;
    }

    . . .

    public static class DtoMapper
    {
        public static void Map(Order order, OrderDto orderDto)
        {
            . . .
        }

        public static void Map(OrderDto orderDto, Order order)
        {
            . . .
        }
    }
}

Внутренний класс описан, как публичный, поэтому реализации репозиториев на инфраструктурном уровне могут обращаться к нему.

При таком подходе неважно, как именно реализованы репозитории: через большой ORM вроде Entity Framework, через простой microORM Dapper, или через ADO.

Нужно внимательно обращаться с агрегированными объектами, такими, как коллекции OrderItem/OrderItemDto. Внутри у нас коллекция OrderItemDto, снаружи OrderItem, и они должны соответствовать друг другу. Эта задача не очень сложная.

Наконец, я бы хотел проиллюстрировать различие между объектами предметной области и DTO, потому что иногда кажется, что между ними так много общего, что от DTO можно было бы и отказаться. Иногда общего действительно много, но иногда нет.

Если у нас есть сущность пользователь, у которой есть пароль, то, в предметной области она выглядит так:

public class User
{
    public int Id { get; }

    public DateTime CreatedAt { get; }

    public string Login { get; }

    bool ValidatePassword(string password);

    void ChangePassword(string oldPassword, string newPassword);
}

DTO-объект для неё выглядит кардинально по другому.

public class UserDto
{
    public int Id { get; set; }

    public DateTime CreatedAt { get; set; }

    public string Login { get; set; }

    public byte[] PasswordHash { get; set; }
}

Как видим, DTO-объект открывает доступ к сырым данным, в данном случае к хешу пароля. Объект предметной области скрывает хеш не только для записи, но и для чтения, чтобы избежать возможных проблем с безопасностью. Он предоставляет методы ValidatePassword и ChangePassword, которые подсказывают нам сценарии использования объекта User.

Именно поэтому DTO-объекты и сущности предметной области, не смотря на некоторое дублирование полей, относятся к разным уровням и имеют разное назначения.

Есть несколько советов по тому, как проектировать DTO-объекты. В идеале их нужно делать такими, чтобы их можно было сразу использовать в Entity Framework, NHibernate или Dapper. Это означает, что вы можете использовать и внешние ключи, и навигационные свойства, и атрибуты вроде [Key], [TableName] из пространства имён System.Components.Annotations. Это не обязательно, но упростит реализацию репозиториев. С другой стороны, лучше не ориентироваться на специфичные для конкретных ORM атрибуты и решения, такие как [Index]. Таким образом вы оставляете DTO-объекты непривязанными к конкретным ORM и можете быстро перейти от EF/SQL к MongoDB или Redis.

Наконец, после бесконечной теории, дам конкретный ответ на вопрос — как именно сохранять изменения корня агрегации, не используя ORM. Допишу метод AdoOrderRepository.Update:

public void Update(Order order)
{
    var orderDto = new OrderDto();
    Order.DtoMapper.Map(order, orderDto);

    using (var transaction = connection.BeginTransaction())
    {
        var orderDto = new OrderDto();
        Order.DtoMapper.Map(order, orderDto);

        var command = connection.CreateCommand();
        command.CommandText = "UPDATE [Orders] SET CreatedAt = @CreatedAt WHERE Id = @Id";
        // Поле CreatedAt только для чтения, так что я просто
        // иллюстрирую идею.
        command.Parameters.Add("@CreatedAt", orderDto.CreatedAt);
        command.Parameters.Add("@Id", orderDto.Id);

        command.ExecuteNonQuery();

        command.CommandText = "UPDATE [OrderItems] SET Count = @Count, Amount = @Amount WHERE Id = @Id";
        foreach (var item in dto.Items.Where(x => x.Id != 0))
        {
            command.Parameters.Clear();
            command.Parameters.Add("@Count", item.Count);
            command.Parameters.Add("@Amount", item.Amount);
            command.Parameters.Add("@Id", item.Id);

            command.ExecuteNonQuery();
        }

        command.CommandText = "INSERT [OrderItems] (OrderId, ProductId, Count, Amount) VALUES (@OrderId, @ProductId, @Count, @Amount)";
        foreach (var item in dto.Items.Where(x => x.Id == 0))
        {
            command.Parameters.Clear();
            command.Parameters.Add("@OrderId", item.OrderId);
            command.Parameters.Add("@ProductId", item.ProductId);
            command.Parameters.Add("@Count", item.Count);
            command.Parameters.Add("@Amount", item.Amount);

            item.Id = (int)command.ExecuteScalar();
        }

        transaction.Commit();
    }

    Order.DtoMapper.Map(orderDto, order);
}

В соответствии с DDD мы должны сохранить не только корень агрегата, но и все агрегированные сущности, что мы в этом методе и делаем. Транзакцию создаем, чтобы обеспечить согласованность изменений. Код получился громоздкий, но простой. Чтобы избавиться от громоздкости, как раз можно задействовать Dapper.

6
  • спасибо за такой развернутый ответ, не совсем понял где добавляется новый ItemOrder. Сама идея с dto понятна а вот про добавление в базу нового item в существующем order, не совсем понял.
    – coder
    30 мая 2017 в 15:03
  • Реализации могут быть разные, я привожу одну из возможных, она близка к тому, как мы пишем код у себя в проекте. Новый ItemOrder добавляется в методе Order.AddItem, я его дописал немного, чтобы проиллюстрировать, что происходит. Также дописал метод AdoOrderRepository.Update, чтобы показать, что новые товарные позиции вставляются с помощью INSERT, а не UPDATE. 30 мая 2017 в 15:37
  • Марк спасибо еще раз, очень доходчивый ответ, еще интересует такой вопрос в вашей реализации, получается вы пробегаете по всей коллекции item и обновляете даже те которые не изменились, не слишком ли это накладно? или это просто для примера и используете другой способ?
    – coder
    30 мая 2017 в 16:07
  • Да, конечно, это только иллюстрация. В рабочем коде у нас EF, который мы немного допилили напильниками в самых медленных местах. При записи в базу обновляются только изменённые свойства. С другой стороны, это зависит от предметной области. В некоторых случаях обновления базы не настолько массовые, и можно сделать код проще, просто обновляя всё. 30 мая 2017 в 16:33
  • А нужно ли хранить ссылку на OrderDto в Order? Вроде бы достаточно восстановить свое состояние и "выбросить" дто.
    – andreycha
    31 мая 2017 в 15:19

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge that you have read and understand our privacy policy and code of conduct.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.