[#487] Add SessionFactoryManager class

We will use it to handle a unique session factory
for tests in the same class.

Author: DavideD

hibernate-reactive-core/src/test/java/org/hibernate/reactive/testing/SessionFactoryManager.java

@@ -0,0 +1,53 @@
+/* Hibernate, Relational Persistence for Idiomatic Java
+ *
+ * SPDX-License-Identifier: LGPL-2.1-or-later
+ * Copyright: Red Hat Inc. and Hibernate Authors
+ */
+package org.hibernate.reactive.testing;
+
+import java.util.function.Supplier;
+
+import org.hibernate.SessionFactory;
+import org.hibernate.engine.spi.SessionFactoryImplementor;
+import org.hibernate.reactive.pool.ReactiveConnectionPool;
+
+/**
+ * Managed the creation of a {@link SessionFactory} that can shared among tests.
+ */
+public class SessionFactoryManager {
+
+	private SessionFactory sessionFactory;
+	private ReactiveConnectionPool poolProvider;
+
+	public SessionFactoryManager() {
+	}
+
+	private boolean needsStart() {
+		return sessionFactory == null || sessionFactory.isClosed();
+	}
+
+	public void start(Supplier<SessionFactory> supplier) {
+		if ( needsStart() ) {
+			sessionFactory = supplier.get();
+			poolProvider = sessionFactory
+					.unwrap( SessionFactoryImplementor.class )
+					.getServiceRegistry().getService( ReactiveConnectionPool.class );
+		}
+	}
+
+	public SessionFactory getHibernateSessionFactory() {
+		return sessionFactory;
+	}
+
+	public ReactiveConnectionPool getReactiveConnectionPool() {
+		return poolProvider;
+	}
+
+	public void stop() {
+		if ( sessionFactory != null && sessionFactory.isOpen() ) {
+			sessionFactory.close();
+		}
+		poolProvider = null;
+		sessionFactory = null;
+	}
+}