We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 81b5a20 commit 898eb17Copy full SHA for 898eb17
src/jmh/java/io/r2dbc/postgresql/StatementBenchmarks.java
@@ -26,6 +26,7 @@
26
import org.openjdk.jmh.annotations.State;
27
import org.openjdk.jmh.infra.Blackhole;
28
import reactor.core.publisher.Flux;
29
+import reactor.core.publisher.Mono;
30
31
import java.sql.Connection;
32
import java.sql.PreparedStatement;
@@ -72,6 +73,7 @@ public ConnectionHolder() {
72
73
jdbc.setAutoCommit(false);
74
75
r2dbc = new PostgresqlConnectionFactory(extension.getConnectionConfiguration()).create().block();
76
+ Mono.from(r2dbc.setAutoCommit(false)).block();
77
} catch (SQLException e) {
78
throw new RuntimeException(e);
79
}
0 commit comments