Реализация репозитория, ориентированного на коллекцию (DDD), с помощью mybatis

Я хочу реализовать репозиторий на основе коллекции на основе mybatis в качестве основного хранилища постоянства. В разделе «Реализация дизайна, управляемого доменом» (см. Главу 12) указано, что интерфейс репозитория должен имитировать Set:

Например:

interface FlightRepository{
   boolean add(Flight f);
   boolean remove(Flight f);
   // finder methods
   Flight findById(Integer id);
}

Реализация mybatis будет выглядеть примерно так (при условии реализации весенней загрузки):

@Mapper
interface FlightMapper{
      int createOrUpdate(Flight flight);
      Flight read(int id);
      int delete(Flight flight);
}

@Component
@Transactional
class FlightRepositoryImpl implements FlightRepository {
    @AutoWired FlightMapper mapper;

    boolean add(Flight f){
        int affectedRows = mapper.createOrUpdate(f);
        if (affectedRows == 1) return true 
        else return false;
    }

    boolean remove(Flight f){
        int affectedRows = mapper.delete(f);
        if (affectedRows == 1) return true
        else return false;
    }

    Flight findById(){
        return mapper.read(id);
    }

}

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

Flight f = flightRepository.findById(1);

f.setDepartureTime(...);
f.setArrivalTime(...);

// flightRepository.saveChanges(); ??

Одним из вариантов реализации было бы создание репозитория копии исходного объекта Flight перед его возвратом клиенту. Когда приходит время сохранять изменения, он сравнивает свою внутреннюю копию с объектом полета, возвращаемым клиенту. Если внутренняя копия не соответствует объекту, возвращенному клиенту, то хранилище сохраняемости будет обновлено версией клиента (с использованием flightMapper.createOrUpdate()).

Однако как я могу запустить эту логику без явного вызова клиентом метода saveChanges()? Это означало бы, что мне нужно было бы каким-то образом подключиться к времени жизни объекта Repository, используя весеннюю загрузку (другими словами, запускать обновления до того, как транзакция будет зафиксирована.

Похоже, что в Java атрибут @Transactional работает с ORM и метод saveChanges вызывается автоматически. stackoverflow.com/questions/46708063/…

Muflix 05.08.2019 21:15
Пользовательский скаляр GraphQL
Пользовательский скаляр GraphQL
Листовые узлы системы типов GraphQL называются скалярами. Достигнув скалярного типа, невозможно спуститься дальше по иерархии типов. Скалярный тип...
Поднятие тревоги для долго выполняющихся методов в Spring Boot
Поднятие тревоги для долго выполняющихся методов в Spring Boot
Приходилось ли вам сталкиваться с требованиями, в которых вас могли попросить поднять тревогу или выдать ошибку, когда метод Java занимает больше...
Версия Java на основе версии загрузки
Версия Java на основе версии загрузки
Если вы зайдете на официальный сайт Spring Boot , там представлен start.spring.io , который упрощает создание проектов Spring Boot, как показано ниже.
Документирование API с помощью Swagger на Springboot
Документирование API с помощью Swagger на Springboot
В предыдущей статье мы уже узнали, как создать Rest API с помощью Springboot и MySql .
1
1
614
1

Ответы 1

Вы можете сделать что-нибудь перед фиксацией, реализовав ТранзакцияСинхронизация с помощью TransactionSynchronizationAdapter для удобства:

@Bean
public class TransactionEventsListener extends TransactionSynchronizationAdapter {

    @Override
    public void beforeCompletion() {
        // do something before commit
    }
}

Другие вопросы по теме