fix transaction

ZeusbaseJAVA · Aug 12, 2024 · 8f7dbf3 · 8f7dbf3
1 parent 6f6d388
commit 8f7dbf3
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/main/java/com/example/r2dbc/service/CustomerService.java b/src/main/java/com/example/r2dbc/service/CustomerService.java
@@ -52,12 +52,12 @@ private Mono<CustomerDTO> getOrdersForCustomer(Customer customer) {
 
         return Mono.just(customer)
                 .zipWith(orderRepository.findAllByCustomerId(customer.getId()).collectList())
+                .as(transactionalOperator::transactional)
                 .map(result -> new CustomerDTO(
                         result.getT1().getId(),
                         result.getT1().getName(),
                         result.getT1().getEmail(),
-                        result.getT2()))
-                .as(transactionalOperator::transactional);
+                        result.getT2()));
 
     }