Add ReactiveConnection#isTransactionInProgress

Author: DavideD

hibernate-reactive-core/src/main/java/org/hibernate/reactive/pool/BatchingConnection.java

@@ -52,6 +52,11 @@ public DatabaseMetadata getDatabaseMetadata() {
 		return delegate.getDatabaseMetadata();
 	}
 
+	@Override
+	public boolean isTransactionInProgress() {
+		return delegate.isTransactionInProgress();
+	}
+
 	@Override
 	public ReactiveConnection withBatchSize(int batchSize) {
 		if ( batchSize <= 1 ) {

hibernate-reactive-core/src/main/java/org/hibernate/reactive/pool/ReactiveConnection.java

@@ -30,6 +30,8 @@
 @Incubating
 public interface ReactiveConnection {
 
+	boolean isTransactionInProgress();
+
 	@FunctionalInterface
 	interface Expectation {
 		void verifyOutcome(int rowCount, int batchPosition, String sql);

hibernate-reactive-core/src/main/java/org/hibernate/reactive/pool/impl/SqlClientConnection.java

@@ -74,6 +74,11 @@ public DatabaseMetadata getDatabaseMetadata() {
 		return client().databaseMetadata();
 	}
 
+	@Override
+	public boolean isTransactionInProgress() {
+		return connection.transaction() != null;
+	}
+
 	@Override
 	public CompletionStage<Integer> update(String sql, Object[] paramValues) {
 		translateNulls( paramValues );

hibernate-reactive-core/src/main/java/org/hibernate/reactive/session/impl/ReactiveSessionImpl.java

@@ -189,6 +189,12 @@ public SessionImplementor getSharedContract() {
 		return this;
 	}
 
+	@Override
+	public boolean isTransactionInProgress() {
+		return isOpenOrWaitingForAutoClose()
+				&& reactiveConnection.isTransactionInProgress();
+	}
+
 	@Override
 	public Dialect getDialect() {
 		threadCheck();