Ensure TypeContributor registered JdbcType has precedence over fallback and preferred types

Author: beikov

hibernate-core/src/main/java/org/hibernate/boot/model/process/spi/MetadataBuildingProcess.java

@@ -391,6 +391,11 @@ private static void handleTypes(BootstrapContext bootstrapContext, MetadataBuild
 		// add Dialect contributed types
 		final Dialect dialect = options.getServiceRegistry().getService( JdbcServices.class ).getDialect();
 		dialect.contributeTypes( typeContributions, options.getServiceRegistry() );
+		// Capture the dialect configured JdbcTypes so that we can detect if a TypeContributor overwrote them,
+		// which has precedence over the fallback and preferred type registrations
+		final JdbcType dialectUuidDescriptor = jdbcTypeRegistry.findDescriptor( SqlTypes.UUID );
+		final JdbcType dialectArrayDescriptor = jdbcTypeRegistry.findDescriptor( SqlTypes.ARRAY );
+		final JdbcType dialectIntervalDescriptor = jdbcTypeRegistry.findDescriptor( SqlTypes.INTERVAL_SECOND );
 
 		// add TypeContributor contributed types.
 		for ( TypeContributor contributor : classLoaderService.loadJavaServices( TypeContributor.class ) ) {
@@ -400,23 +405,38 @@ private static void handleTypes(BootstrapContext bootstrapContext, MetadataBuild
 		// add fallback type descriptors
 		final int preferredSqlTypeCodeForUuid = getPreferredSqlTypeCodeForUuid( serviceRegistry );
 		if ( preferredSqlTypeCodeForUuid != SqlTypes.UUID ) {
-			adaptToPreferredSqlTypeCode( jdbcTypeRegistry, SqlTypes.UUID, preferredSqlTypeCodeForUuid );
+			adaptToPreferredSqlTypeCode(
+					jdbcTypeRegistry,
+					dialectUuidDescriptor,
+					SqlTypes.UUID,
+					preferredSqlTypeCodeForUuid
+			);
 		}
 		else {
 			addFallbackIfNecessary( jdbcTypeRegistry, SqlTypes.UUID, SqlTypes.BINARY );
 		}
 
 		final int preferredSqlTypeCodeForArray = getPreferredSqlTypeCodeForArray( serviceRegistry );
 		if ( preferredSqlTypeCodeForArray == SqlTypes.ARRAY ) {
-			adaptToPreferredSqlTypeCode( jdbcTypeRegistry, null, SqlTypes.ARRAY, SqlTypes.VARBINARY );
+			adaptToPreferredSqlTypeCode( jdbcTypeRegistry, dialectArrayDescriptor, SqlTypes.ARRAY, SqlTypes.VARBINARY );
 		}
 		else {
-			adaptToPreferredSqlTypeCode( jdbcTypeRegistry, SqlTypes.ARRAY, preferredSqlTypeCodeForArray );
+			adaptToPreferredSqlTypeCode(
+					jdbcTypeRegistry,
+					dialectArrayDescriptor,
+					SqlTypes.ARRAY,
+					preferredSqlTypeCodeForArray
+			);
 		}
 
 		final int preferredSqlTypeCodeForDuration = getPreferredSqlTypeCodeForDuration( serviceRegistry );
 		if ( preferredSqlTypeCodeForDuration != SqlTypes.INTERVAL_SECOND ) {
-			adaptToPreferredSqlTypeCode( jdbcTypeRegistry, SqlTypes.INTERVAL_SECOND, preferredSqlTypeCodeForDuration );
+			adaptToPreferredSqlTypeCode(
+					jdbcTypeRegistry,
+					dialectIntervalDescriptor,
+					SqlTypes.INTERVAL_SECOND,
+					preferredSqlTypeCodeForDuration
+			);
 		}
 		else {
 			addFallbackIfNecessary( jdbcTypeRegistry, SqlTypes.INTERVAL_SECOND, SqlTypes.NUMERIC );
@@ -471,18 +491,6 @@ private static void handleTypes(BootstrapContext bootstrapContext, MetadataBuild
 		}
 	}
 
-	private static void adaptToPreferredSqlTypeCode(
-			JdbcTypeRegistry jdbcTypeRegistry,
-			int defaultSqlTypeCode,
-			int preferredSqlTypeCode) {
-		adaptToPreferredSqlTypeCode(
-				jdbcTypeRegistry,
-				jdbcTypeRegistry.findDescriptor( defaultSqlTypeCode ),
-				defaultSqlTypeCode,
-				preferredSqlTypeCode
-		);
-	}
-
 	private static void adaptToPreferredSqlTypeCode(
 			JdbcTypeRegistry jdbcTypeRegistry,
 			JdbcType dialectUuidDescriptor,
@@ -494,6 +502,7 @@ private static void adaptToPreferredSqlTypeCode(
 					jdbcTypeRegistry.getDescriptor( preferredSqlTypeCode )
 			);
 		}
+		// else warning?
 	}
 
 	private static void adaptToPreferredSqlTypeCodeForInstant(