DRY

Author: gavinking

hibernate-agroal/src/main/java/org/hibernate/agroal/internal/AgroalConnectionProvider.java

@@ -40,6 +40,8 @@
 import static java.util.stream.Collectors.toMap;
 import static org.hibernate.cfg.AgroalSettings.AGROAL_CONFIG_PREFIX;
 import static org.hibernate.engine.jdbc.connections.internal.ConnectionProviderInitiator.toIsolationNiceName;
+import static org.hibernate.engine.jdbc.connections.internal.DatabaseConnectionInfoImpl.getFetchSize;
+import static org.hibernate.engine.jdbc.connections.internal.DatabaseConnectionInfoImpl.getIsolation;
 import static org.hibernate.engine.jdbc.env.internal.JdbcEnvironmentInitiator.allowJdbcMetadataAccess;
 
 /**
@@ -187,26 +189,6 @@ public DatabaseConnectionInfo getDatabaseConnectionInfo(Dialect dialect) {
 		);
 	}
 
-	private static Integer getFetchSize(DataSource dataSource) {
-		try ( var conn = dataSource.getConnection() ) {
-			try ( var statement = conn.createStatement() ) {
-				return statement.getFetchSize();
-			}
-		}
-		catch ( SQLException ignored ) {
-			return null;
-		}
-	}
-
-	private static Integer getIsolation(DataSource dataSource) {
-		try ( var conn = dataSource.getConnection() ) {
-			return conn.getTransactionIsolation();
-		}
-		catch ( SQLException ignored ) {
-			return null;
-		}
-	}
-
 	private String extractDriverNameFromMetadata() {
 		if (isMetadataAccessAllowed) {
 			try ( Connection conn = getConnection() ) {

hibernate-c3p0/src/main/java/org/hibernate/c3p0/internal/C3P0ConnectionProvider.java

@@ -43,6 +43,8 @@
 import static org.hibernate.engine.jdbc.connections.internal.ConnectionProviderInitiator.extractSetting;
 import static org.hibernate.engine.jdbc.connections.internal.ConnectionProviderInitiator.getConnectionProperties;
 import static org.hibernate.engine.jdbc.connections.internal.ConnectionProviderInitiator.toIsolationNiceName;
+import static org.hibernate.engine.jdbc.connections.internal.DatabaseConnectionInfoImpl.getFetchSize;
+import static org.hibernate.engine.jdbc.connections.internal.DatabaseConnectionInfoImpl.getIsolation;
 import static org.hibernate.internal.util.config.ConfigurationHelper.getBoolean;
 import static org.hibernate.internal.util.config.ConfigurationHelper.getInteger;
 
@@ -176,26 +178,6 @@ public void configure(Map<String, Object> properties) {
 		);
 	}
 
-	private static Integer getFetchSize(DataSource dataSource) {
-		try ( var conn = dataSource.getConnection() ) {
-			try ( var statement = conn.createStatement() ) {
-				return statement.getFetchSize();
-			}
-		}
-		catch ( SQLException ignored ) {
-			return null;
-		}
-	}
-
-	private static Integer getIsolation(DataSource dataSource) {
-		try ( var conn = dataSource.getConnection() ) {
-			return conn.getTransactionIsolation();
-		}
-		catch ( SQLException ignored ) {
-			return null;
-		}
-	}
-
 	private DataSource createDataSource(String jdbcUrl, Properties connectionProps, Map<String, Object> poolProperties) {
 		try {
 			return pooledDataSource( unpooledDataSource( jdbcUrl, connectionProps ), poolProperties );

hibernate-core/src/main/java/org/hibernate/engine/jdbc/connections/internal/DatabaseConnectionInfoImpl.java

@@ -4,6 +4,7 @@
  */
 package org.hibernate.engine.jdbc.connections.internal;
 
+import java.sql.SQLException;
 import java.util.Map;
 
 import org.checkerframework.checker.nullness.qual.Nullable;
@@ -15,6 +16,8 @@
 import org.hibernate.internal.util.NullnessHelper;
 import org.hibernate.internal.util.config.ConfigurationHelper;
 
+import javax.sql.DataSource;
+
 import static org.hibernate.dialect.SimpleDatabaseVersion.ZERO_VERSION;
 import static org.hibernate.engine.jdbc.connections.internal.ConnectionProviderInitiator.interpretIsolation;
 import static org.hibernate.engine.jdbc.connections.internal.ConnectionProviderInitiator.toIsolationNiceName;
@@ -80,6 +83,26 @@ public DatabaseConnectionInfoImpl(Dialect dialect) {
 		this( null, null, null, dialect.getVersion(), null, null, null, null, null );
 	}
 
+	public static Integer getFetchSize(DataSource dataSource) {
+		try ( var conn = dataSource.getConnection() ) {
+			try ( var statement = conn.createStatement() ) {
+				return statement.getFetchSize();
+			}
+		}
+		catch ( SQLException ignored ) {
+			return null;
+		}
+	}
+
+	public static Integer getIsolation(DataSource dataSource) {
+		try ( var conn = dataSource.getConnection() ) {
+			return conn.getTransactionIsolation();
+		}
+		catch ( SQLException ignored ) {
+			return null;
+		}
+	}
+
 	@Override
 	public String getJdbcUrl() {
 		return jdbcUrl;

hibernate-hikaricp/src/main/java/org/hibernate/hikaricp/internal/HikariCPConnectionProvider.java

@@ -25,6 +25,8 @@
 import com.zaxxer.hikari.HikariDataSource;
 
 import static org.hibernate.engine.jdbc.connections.internal.ConnectionProviderInitiator.toIsolationNiceName;
+import static org.hibernate.engine.jdbc.connections.internal.DatabaseConnectionInfoImpl.getFetchSize;
+import static org.hibernate.engine.jdbc.connections.internal.DatabaseConnectionInfoImpl.getIsolation;
 import static org.hibernate.engine.jdbc.env.internal.JdbcEnvironmentInitiator.allowJdbcMetadataAccess;
 import static org.hibernate.hikaricp.internal.HikariConfigurationUtil.loadConfiguration;
 import static org.hibernate.internal.util.StringHelper.isBlank;
@@ -115,26 +117,6 @@ public DatabaseConnectionInfo getDatabaseConnectionInfo(Dialect dialect) {
 		);
 	}
 
-	private static Integer getFetchSize(DataSource dataSource) {
-		try ( var conn = dataSource.getConnection() ) {
-			try ( var statement = conn.createStatement() ) {
-				return statement.getFetchSize();
-			}
-		}
-		catch ( SQLException ignored ) {
-			return null;
-		}
-	}
-
-	private static Integer getIsolation(DataSource dataSource) {
-		try ( var conn = dataSource.getConnection() ) {
-			return conn.getTransactionIsolation();
-		}
-		catch ( SQLException ignored ) {
-			return null;
-		}
-	}
-
 	private String extractDriverNameFromMetadata() {
 		if ( isMetadataAccessAllowed ) {
 			try ( Connection conn = getConnection() ) {