2020import java .util .concurrent .ConcurrentHashMap ;
2121import java .util .function .Consumer ;
2222import java .util .function .Function ;
23- import java .util .function .Supplier ;
2423import java .util .function .UnaryOperator ;
2524import javax .naming .Reference ;
2625import javax .naming .StringRefAddr ;
8382import org .hibernate .integrator .spi .IntegratorService ;
8483import org .hibernate .jpa .internal .ExceptionMapperLegacyJpaImpl ;
8584import org .hibernate .jpa .internal .PersistenceUnitUtilImpl ;
86- import org .hibernate .mapping .Collection ;
8785import org .hibernate .mapping .GeneratorSettings ;
88- import org .hibernate .mapping .PersistentClass ;
8986import org .hibernate .mapping .RootClass ;
9087import org .hibernate .metamodel .MappingMetamodel ;
9188import org .hibernate .metamodel .RepresentationMode ;
9289import org .hibernate .metamodel .internal .RuntimeMetamodelsImpl ;
93- import org .hibernate .metamodel .mapping .JdbcMapping ;
9490import org .hibernate .metamodel .model .domain .EntityDomainType ;
9591import org .hibernate .metamodel .model .domain .internal .MappingMetamodelImpl ;
9692import org .hibernate .metamodel .model .domain .spi .JpaMetamodelImplementor ;
@@ -254,23 +250,23 @@ public SessionFactoryImpl(
254250
255251 jpaPersistenceUnitUtil = new PersistenceUnitUtilImpl ( this );
256252
257- for ( SessionFactoryObserver sessionFactoryObserver : options .getSessionFactoryObservers () ) {
253+ for ( var sessionFactoryObserver : options .getSessionFactoryObservers () ) {
258254 observer .addObserver ( sessionFactoryObserver );
259255 }
260256
261257 filters = new HashMap <>( bootMetamodel .getFilterDefinitions () );
262258
263- final FilterDefinition tenantFilter = filters .get ( TenantIdBinder .FILTER_NAME );
259+ final var tenantFilter = filters .get ( TenantIdBinder .FILTER_NAME );
264260 if ( tenantFilter == null ) {
265261 tenantIdentifierJavaType = options .getDefaultTenantIdentifierJavaType ();
266262 }
267263 else {
268- final JdbcMapping jdbcMapping = tenantFilter .getParameterJdbcMapping ( TenantIdBinder .PARAMETER_NAME );
264+ final var jdbcMapping = tenantFilter .getParameterJdbcMapping ( TenantIdBinder .PARAMETER_NAME );
269265 assert jdbcMapping != null ;
270266 //noinspection unchecked
271267 tenantIdentifierJavaType = jdbcMapping .getJavaTypeDescriptor ();
272268 }
273- for ( Map . Entry < String , FilterDefinition > filterEntry : filters .entrySet () ) {
269+ for ( var filterEntry : filters .entrySet () ) {
274270 if ( filterEntry .getValue ().isAutoEnabled () ) {
275271 autoEnabledFilters .add ( filterEntry .getValue () );
276272 }
@@ -283,7 +279,7 @@ public SessionFactoryImpl(
283279 classLoaderService = serviceRegistry .requireService ( ClassLoaderService .class );
284280 jdbcValuesMappingProducerProvider = serviceRegistry .requireService ( JdbcValuesMappingProducerProvider .class );
285281
286- final IntegratorObserver integratorObserver = new IntegratorObserver ();
282+ final var integratorObserver = new IntegratorObserver ();
287283 observer .addObserver ( integratorObserver );
288284 try {
289285 integrate ( bootMetamodel , bootstrapContext , integratorObserver );
@@ -294,7 +290,7 @@ public SessionFactoryImpl(
294290 primeSecondLevelCacheRegions ( bootMetamodel );
295291
296292 // create the empty runtime metamodels object
297- final RuntimeMetamodelsImpl runtimeMetamodelsImpl = new RuntimeMetamodelsImpl ( typeConfiguration );
293+ final var runtimeMetamodelsImpl = new RuntimeMetamodelsImpl ( typeConfiguration );
298294 runtimeMetamodels = runtimeMetamodelsImpl ;
299295
300296 // we build this before creating the runtime metamodels
@@ -305,7 +301,7 @@ public SessionFactoryImpl(
305301 sqlTranslationEngine = new SqlTranslationEngineImpl ( this , typeConfiguration , fetchProfiles );
306302
307303 // now actually create the mapping and JPA metamodels
308- final MappingMetamodelImpl mappingMetamodelImpl = new MappingMetamodelImpl ( typeConfiguration , serviceRegistry );
304+ final var mappingMetamodelImpl = new MappingMetamodelImpl ( typeConfiguration , serviceRegistry );
309305 runtimeMetamodelsImpl .setMappingMetamodel ( mappingMetamodelImpl );
310306 mappingMetamodelImpl .finishInitialization (
311307 new ModelCreationContext ( bootstrapContext , bootMetamodel , mappingMetamodelImpl , typeConfiguration ) );
@@ -432,22 +428,22 @@ class IntegratorObserver implements SessionFactoryObserver {
432428 private final ArrayList <Integrator > integrators = new ArrayList <>();
433429 @ Override
434430 public void sessionFactoryClosed (SessionFactory factory ) {
435- for ( Integrator integrator : integrators ) {
431+ for ( var integrator : integrators ) {
436432 integrator .disintegrate ( SessionFactoryImpl .this , SessionFactoryImpl .this .serviceRegistry );
437433 }
438434 integrators .clear ();
439435 }
440436 }
441437
442438 private void integrate (MetadataImplementor bootMetamodel , BootstrapContext bootstrapContext , IntegratorObserver integratorObserver ) {
443- for ( Integrator integrator : serviceRegistry .requireService ( IntegratorService .class ).getIntegrators () ) {
439+ for ( var integrator : serviceRegistry .requireService ( IntegratorService .class ).getIntegrators () ) {
444440 integrator .integrate ( bootMetamodel , bootstrapContext , this );
445441 integratorObserver .integrators .add ( integrator );
446442 }
447443 }
448444
449445 private void disintegrate (Exception startupException , IntegratorObserver integratorObserver ) {
450- for ( Integrator integrator : integratorObserver .integrators ) {
446+ for ( var integrator : integratorObserver .integrators ) {
451447 try {
452448 integrator .disintegrate ( this , serviceRegistry );
453449 }
@@ -483,10 +479,9 @@ private void primeSecondLevelCacheRegions(MetadataImplementor mappingMetadata) {
483479 // TODO: ultimately this code can be made more efficient when we have
484480 // a better intrinsic understanding of the hierarchy as a whole
485481
486- for ( PersistentClass bootEntityDescriptor : mappingMetadata .getEntityBindings () ) {
482+ for ( var bootEntityDescriptor : mappingMetadata .getEntityBindings () ) {
487483 final AccessType accessType =
488484 AccessType .fromExternalName ( bootEntityDescriptor .getCacheConcurrencyStrategy () );
489-
490485 if ( accessType != null ) {
491486 if ( bootEntityDescriptor .isCached () ) {
492487 regionConfigBuilders .computeIfAbsent (
@@ -508,8 +503,9 @@ private void primeSecondLevelCacheRegions(MetadataImplementor mappingMetadata) {
508503 }
509504 }
510505
511- for ( Collection collection : mappingMetadata .getCollectionBindings () ) {
512- final AccessType accessType = AccessType .fromExternalName ( collection .getCacheConcurrencyStrategy () );
506+ for ( var collection : mappingMetadata .getCollectionBindings () ) {
507+ final AccessType accessType =
508+ AccessType .fromExternalName ( collection .getCacheConcurrencyStrategy () );
513509 if ( accessType != null ) {
514510 regionConfigBuilders .computeIfAbsent (
515511 collection .getCacheRegionName (),
@@ -525,7 +521,7 @@ private void primeSecondLevelCacheRegions(MetadataImplementor mappingMetadata) {
525521 }
526522 else {
527523 regionConfigs = new HashSet <>();
528- for ( DomainDataRegionConfigImpl . Builder builder : regionConfigBuilders .values () ) {
524+ for ( var builder : regionConfigBuilders .values () ) {
529525 regionConfigs .add ( builder .build () );
530526 }
531527 }
@@ -735,12 +731,12 @@ public boolean isOpen() {
735731
736732 @ Override
737733 public RootGraph <Map <String , ?>> createGraphForDynamicEntity (String entityName ) {
738- final EntityDomainType <?> entity = getJpaMetamodel ().entity ( entityName );
734+ final var entity = getJpaMetamodel ().entity ( entityName );
739735 if ( entity .getRepresentationMode () != RepresentationMode .MAP ) {
740736 throw new IllegalArgumentException ( "Entity '" + entityName + "' is not a dynamic entity" );
741737 }
742738 @ SuppressWarnings ("unchecked" ) //Safe, because we just checked
743- final EntityDomainType < Map < String , ?>> dynamicEntity = (EntityDomainType <Map <String , ?>>) entity ;
739+ final var dynamicEntity = (EntityDomainType <Map <String , ?>>) entity ;
744740 return new RootGraphImpl <>( null , dynamicEntity );
745741 }
746742
@@ -1108,7 +1104,7 @@ public static Interceptor configuredInterceptor(Interceptor interceptor, boolean
11081104 }
11091105
11101106 // then check the Session-scoped interceptor prototype
1111- final Supplier <? extends Interceptor > statelessInterceptorImplementorSupplier =
1107+ final var statelessInterceptorImplementorSupplier =
11121108 options .getStatelessInterceptorImplementorSupplier ();
11131109 if ( statelessInterceptorImplementorSupplier != null ) {
11141110 return statelessInterceptorImplementorSupplier .get ();
0 commit comments