无阻塞地插入两个集合

Question

我目前正在使用 Spring-WebFlux 学习 Project Reactor。

我创建了一个简单的服务，它将按顺序插入到两个集合中。首先，我的服务将插入到列表集合中，然后插入到详细信息集合中。如果两个操作都成功，它将 return 第一个操作的实例（插入列表集合），如果其中一个操作不成功，它将回滚之前操作创建的任何更改。

这是我的代码片段：

    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 次吗？

谢谢。

Answer 1

我不熟悉 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))
    }        
}

无阻塞地插入两个集合

Inserting Into Two Collections Without Blocking

kotlin

spring-data-mongodb

spring-boot

spring-webflux