Блог

В настоящее время я изучаю Project Reactor с использованием Spring-WebFlux.

Я создал простой сервис, который будет последовательно вставлять в две коллекции. Во-первых, мой сервис будет вставлен в коллекцию list, а после этого он будет вставлен в коллекцию details. Если обе операции завершатся успешно, будет возвращен экземпляр первой операции (Вставить в коллекцию списков), если одна из них не завершится успешно, будет выполнен откат всех изменений, созданных предшествующей операцией.

Вот мой фрагмент:

     override fun insert(business: Business): Mono<Business> = businessRepository.save(business)
    .doOnSuccess { businezz ->
        val businessDetails = businezz.businessDetails
        businessDetails!!.idBusiness = businezz.id
        businessDetailsService.insert(businessDetails).doOnError {
            businessRepository.delete(businezz).subscribe()
        }.subscribe()
    }
  

Я чувствую, что это своего рода грязный способ создания Mono. Поскольку вторая операция является блочной операцией. Конечно, я мог бы просто вставить список, затем вставить детали, а затем получить список. Но на самом деле это будет вызывать базу данных 3 раза, а не 2 раза, как в моем коде выше.

Есть ли у меня какой-нибудь способ создать неблокирующую операцию и вызвать базу данных только 2 раза?

Спасибо.

Я не знаком с Kotlin, но с Java вы могли бы сделать это следующим образом:

 Mono<Business> insert(Business business) {
    return businessRepository.save(business)
            .flatMap(businezz -> {
                BusinessDetails businessDetails = ...;
                return businessDetailsService.insert(businessDetails)
                        .onErrorResume(throwable -> businessRepository
                                .delete(businezz)
                                .then(Mono.empty()))
                        .then(Mono.just(businezz));
            });
}
  

ОТВЕТ KOTLIN, спасибо, Дэвид:

 override fun insert(business: Business): Mono<Business> {
    return businessRepository.save(business).flatMap { businezz ->
        val businessDetails = businezz.businessDetails
        businessDetailsService.insert(businessDetails!!).onErrorResume { 
            businessRepository.delete(businezz).then(Mono.empty())
        }.then(Mono.just(businezz))
    }        
}