@@ -250,20 +250,20 @@ else if ( supportsSchemas ) {
250
250
/**
251
251
* @deprecated currently used by Hibernate Reactive
252
252
* This version of the constructor should handle the case in which we do actually have
253
- * the option to access the DatabaseMetaData, but since Hibernate Reactive is currently
254
- * not making use of it we take a shortcut.
253
+ * the option to access the {@link DatabaseMetaData} , but since Hibernate Reactive is
254
+ * currently not making use of it we take a shortcut.
255
255
*/
256
256
@ Deprecated
257
257
public JdbcEnvironmentImpl (
258
258
ServiceRegistryImplementor serviceRegistry ,
259
259
Dialect dialect ,
260
- DatabaseMetaData databaseMetaData
261
- /*JdbcConnectionAccess jdbcConnectionAccess*/ ) throws SQLException {
262
- this (serviceRegistry , dialect );
260
+ DatabaseMetaData databaseMetaData ) {
261
+ this ( serviceRegistry , dialect );
263
262
}
264
263
265
264
/**
266
- * The main constructor form. Builds a JdbcEnvironment using the available DatabaseMetaData
265
+ * The main constructor form.
266
+ * Builds a {@code JdbcEnvironment} using the available {@link DatabaseMetaData}.
267
267
*
268
268
* @param serviceRegistry The service registry
269
269
* @param dialect The resolved dialect
@@ -336,38 +336,33 @@ private String determineCurrentSchemaName(
336
336
DatabaseMetaData databaseMetaData ,
337
337
ServiceRegistry serviceRegistry ,
338
338
Dialect dialect ) {
339
- final Object setting =
340
- serviceRegistry .requireService ( ConfigurationService .class )
341
- .getSettings ().get ( SCHEMA_NAME_RESOLVER );
342
- final SchemaNameResolver schemaNameResolver ;
343
- if ( setting == null ) {
344
- schemaNameResolver = dialect .getSchemaNameResolver ();
345
- }
346
- else {
347
- schemaNameResolver =
348
- serviceRegistry .requireService ( StrategySelector .class )
349
- .resolveDefaultableStrategy (
350
- SchemaNameResolver .class ,
351
- setting ,
352
- dialect .getSchemaNameResolver ()
353
- );
354
- }
355
-
339
+ final SchemaNameResolver resolver = getSchemaNameResolver ( serviceRegistry , dialect );
356
340
try {
357
- return schemaNameResolver .resolveSchemaName ( databaseMetaData .getConnection (), dialect );
341
+ return resolver .resolveSchemaName ( databaseMetaData .getConnection (), dialect );
358
342
}
359
343
catch (Exception e ) {
360
344
log .debug ( "Unable to resolve connection default schema" , e );
361
345
return null ;
362
346
}
363
347
}
364
348
365
- private SqlExceptionHelper buildSqlExceptionHelper (Dialect dialect , boolean logWarnings ) {
366
- SQLExceptionConversionDelegate dialectDelegate = dialect .buildSQLExceptionConversionDelegate ();
367
- SQLExceptionConversionDelegate [] delegates = dialectDelegate == null
349
+ private static SchemaNameResolver getSchemaNameResolver (ServiceRegistry serviceRegistry , Dialect dialect ) {
350
+ final Object setting =
351
+ serviceRegistry .requireService ( ConfigurationService .class )
352
+ .getSettings ().get ( SCHEMA_NAME_RESOLVER );
353
+ return setting == null
354
+ ? dialect .getSchemaNameResolver ()
355
+ : serviceRegistry .requireService ( StrategySelector .class )
356
+ .resolveDefaultableStrategy ( SchemaNameResolver .class , setting ,
357
+ dialect .getSchemaNameResolver () );
358
+ }
359
+
360
+ private static SqlExceptionHelper buildSqlExceptionHelper (Dialect dialect , boolean logWarnings ) {
361
+ final SQLExceptionConversionDelegate dialectDelegate = dialect .buildSQLExceptionConversionDelegate ();
362
+ final SQLExceptionConversionDelegate [] delegates = dialectDelegate == null
368
363
? new SQLExceptionConversionDelegate [] { new SQLExceptionTypeDelegate ( dialect ), new SQLStateConversionDelegate ( dialect ) }
369
364
: new SQLExceptionConversionDelegate [] { dialectDelegate , new SQLExceptionTypeDelegate ( dialect ), new SQLStateConversionDelegate ( dialect ) };
370
- return new SqlExceptionHelper ( new StandardSQLExceptionConverter (delegates ), logWarnings );
365
+ return new SqlExceptionHelper ( new StandardSQLExceptionConverter ( delegates ), logWarnings );
371
366
}
372
367
373
368
@ Override
0 commit comments