fix : issue with @transaction proxy

rajadilipkolli · Nov 8, 2023 · e9b36b5 · e9b36b5
1 parent ccba88d
commit e9b36b5
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/...c/boot-r2dbc-sample/src/main/java/com/example/bootr2dbc/services/ReactivePostService.java b/...c/boot-r2dbc-sample/src/main/java/com/example/bootr2dbc/services/ReactivePostService.java
@@ -66,7 +66,9 @@ public Mono<ResponseEntity<Object>> deleteReactivePostAndCommentsById(Long id) {
                         reactivePost ->
                                 reactiveCommentsRepository
                                         .deleteAllByPostId(reactivePost.getId())
-                                        .then(deleteReactivePostById(reactivePost.getId()))
+                                        .then(
+                                                reactivePostRepository.deleteById(
+                                                        reactivePost.getId()))
                                         .then(Mono.just(ResponseEntity.noContent().build())))
                 .switchIfEmpty(Mono.just(ResponseEntity.notFound().build()));
     }

diff --git a/r2dbc/boot-r2dbc-sample/src/test/java/com/example/bootr2dbc/TestApplication.java b/r2dbc/boot-r2dbc-sample/src/test/java/com/example/bootr2dbc/TestApplication.java
@@ -12,7 +12,7 @@ public class TestApplication {
     @Bean
     @ServiceConnection
     PostgreSQLContainer<?> postgreSQLContainer() {
-        return new PostgreSQLContainer<>("postgres:15.4-alpine");
+        return new PostgreSQLContainer<>("postgres:16.0-alpine");
     }
 
     public static void main(String[] args) {