Skip to content

Commit eda3801

Browse files
authored
remove transactions from SimpleQuerydslR2dbcFragment methods (#83)
1 parent fcef418 commit eda3801

1 file changed

Lines changed: 2 additions & 4 deletions

File tree

infobip-spring-data-r2dbc-querydsl/src/main/java/com/infobip/spring/data/r2dbc/SimpleQuerydslR2dbcFragment.java

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -75,8 +75,7 @@ public Mono<Long> update(Function<SQLUpdateClause, SQLUpdateClause> update) {
7575
.collect(Collectors.joining("\n"));
7676
return databaseClient.sql(sql)
7777
.fetch()
78-
.rowsUpdated()
79-
.as(TransactionalOperator.create(reactiveTransactionManager)::transactional);
78+
.rowsUpdated();
8079
}
8180

8281
@Override
@@ -91,8 +90,7 @@ public Mono<Long> deleteWhere(Predicate predicate) {
9190
.collect(Collectors.joining("\n"));
9291
return databaseClient.sql(sql)
9392
.fetch()
94-
.rowsUpdated()
95-
.as(TransactionalOperator.create(reactiveTransactionManager)::transactional);
93+
.rowsUpdated();
9694
}
9795

9896
@Override

0 commit comments

Comments
 (0)