Hibernate
/
hibernate-orm
mirror of https://github.com/hibernate/hibernate-orm
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

HHH-15346 @ManyToOne associations not loaded correctly with default EAGER and batch fetch property set

This commit is contained in:
Andrea Boriero 2022-06-22 19:03:12 +02:00 committed by Andrea Boriero
parent a70150fe2e
commit f5be0e1f07
1 changed files with 15 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
hibernate-core/src/main/java/org/hibernate/sql/results/graph/entity/internal/BatchEntitySelectFetchInitializer.java
View File

@ -6,7 +6,9 @@
*/
package org.hibernate.sql.results.graph.entity.internal;
import java.util.LinkedHashMap;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.function.Consumer;
@ -47,7 +49,7 @@ public class BatchEntitySelectFetchInitializer extends AbstractFetchParentAccess
protected Object entityInstance;
private EntityKey entityKey;
private Map<EntityKey, Object> toBatchLoad = new LinkedHashMap<>();
private Map<EntityKey, List<Object>> toBatchLoad = new HashMap<>();
private boolean isInitialized;
@ -76,7 +78,6 @@ public class BatchEntitySelectFetchInitializer extends AbstractFetchParentAccess
@Override
public void resolveKey(RowProcessingState rowProcessingState) {
}
@Override
@ -147,7 +148,13 @@ public class BatchEntitySelectFetchInitializer extends AbstractFetchParentAccess
}
persistenceContext.getBatchFetchQueue().addBatchLoadableEntityKey( entityKey );
toBatchLoad.put( entityKey, parentAccess.getInitializedInstance() );
List<Object> objects = toBatchLoad.get( entityKey );
if ( objects == null ) {
objects = new ArrayList<>();
toBatchLoad.put( entityKey, objects );
}
objects.add( parentAccess.getInitializedInstance() );
isInitialized = true;
}
@ -215,15 +222,17 @@ public class BatchEntitySelectFetchInitializer extends AbstractFetchParentAccess
@Override
public void endLoading(ExecutionContext context) {
final int propertyIndex = ( (UniqueKeyLoadable) ( (AbstractEntityInitializer) parentAccess ).getEntityDescriptor() )
.getPropertyIndex( referencedModelPart.getPartName() );
toBatchLoad.forEach(
(entityKey, parentInstance) -> {
(entityKey, parentInstances) -> {
final Object instance = context.getSession().internalLoad(
entityKey.getEntityName(),
entityKey.getIdentifier(),
true,
referencedModelPart.isInternalLoadNullable()
);
if ( instance != null ) {
for ( Object parentInstance : parentInstances ) {
( (AbstractEntityPersister) referencedModelPart.getDeclaringType() ).setPropertyValue(
parentInstance,
referencedModelPart.getPartName(),
@ -232,8 +241,6 @@ public class BatchEntitySelectFetchInitializer extends AbstractFetchParentAccess
final EntityEntry entry = context.getSession()
.getPersistenceContext()
.getEntry( parentInstance );
final int propertyIndex = ( (UniqueKeyLoadable) ( (AbstractEntityInitializer) parentAccess ).getEntityDescriptor() ).getPropertyIndex(
referencedModelPart.getPartName() );
if ( entry != null ) {
final Object[] loadedState = entry.getLoadedState();
if ( loadedState != null ) {