Top Description Fields Constructors Methods
org.hibernate.engine.spi

public Class BatchFetchQueue

extends Object
Class Inheritance
Imports
java.io.Serializable, java.util.HashMap, .LinkedHashMap, .LinkedHashSet, .Map, .Map.Entry, org.hibernate.EntityMode, org.hibernate.cache.spi.access.CollectionDataAccess, .EntityDataAccess, org.hibernate.collection.spi.PersistentCollection, org.hibernate.engine.internal.CacheHelper, org.hibernate.internal.CoreLogging, org.hibernate.persister.collection.CollectionPersister, org.hibernate.persister.entity.EntityPersister, org.jboss.logging.Logger
Tracks entity and collection keys that are available for batch fetching, and the queries which were used to load entities, which can be re-used as a subquery for loading owned collections.
Authors
Gavin King, Steve Ebersole, Guenther Demetz

Field Summary

Modifier and TypeField and Description
private Map<String, LinkedHashMap<CollectionEntry, PersistentCollection>>
batchLoadableCollections

Used to hold information about the collections that are currently eligible for batch-fetching.

private Map<String, LinkedHashSet<EntityKey>>
batchLoadableEntityKeys

Used to hold information about the entities that are currently eligible for batch-fetching.

private final PersistenceContext
context

private static final Logger
LOG

private Map<EntityKey, SubselectFetch>
subselectsByEntityKey

A map of subselect-fetch descriptors keyed by the EntityKey against which the descriptor is registered.

Constructor Summary

AccessConstructor and Description
public
BatchFetchQueue(PersistenceContext
The owning context.
context)

Constructs a queue for the given context.

Method Summary

Modifier and TypeMethod and Description
public void
addBatchLoadableCollection(PersistentCollection collection, CollectionEntry ce)

If a CollectionEntry represents a batch loadable collection, add it to the queue.

public void
addBatchLoadableEntityKey(EntityKey key)

If an EntityKey represents a batch loadable entity, add it to the queue.

public void
addSubselect(EntityKey
The entity for which to register the subselect fetch.
key, SubselectFetch
The fetch descriptor.
subquery)

Adds a subselect fetch descriptor for the given entity key.

public void
clear()

Clears all entries from this fetch queue.

public boolean
containsEntityKey(EntityKey key)

Intended for test usage.

public Serializable[]

Returns:

an array of collection keys, of length batchSize (padded with nulls)
getCollectionBatch(final CollectionPersister
The persister for the collection role.
collectionPersister, final Serializable
A key that must be included in the batch fetch
id, final int
the maximum number of keys to return
batchSize)

Get a batch of uninitialized collection keys for a given role

public Serializable[]

Returns:

an array of identifiers, of length batchSize (possibly padded with nulls)
getEntityBatch(final EntityPersister
The persister for the entities being loaded.
persister, final Serializable
The identifier of the entity currently demanding load.
id, final int
The maximum number of keys to return
batchSize, final EntityMode entityMode)

Get a batch of unloaded identifiers for this class, using a slightly complex algorithm that tries to grab keys registered immediately after the given key.

public SubselectFetch

Returns:

The fetch descriptor; may return null if no subselect fetch queued for this entity key.
getSubselect(EntityKey
The entity key for which to locate any defined subselect fetch.
key)

Retrieve the fetch descriptor associated with the given entity key.

private boolean
isCached(EntityKey entityKey, EntityPersister persister)

private boolean
isCached(Serializable collectionKey, CollectionPersister persister)

public void
removeBatchLoadableCollection(CollectionEntry ce)

After a collection was initialized or evicted, we don't need to batch fetch it anymore, remove it from the queue if necessary

public void
removeBatchLoadableEntityKey(EntityKey key)

After evicting or deleting or loading an entity, we don't need to batch fetch it anymore, remove it from the queue if necessary

public void
removeSubselect(EntityKey key)

After evicting or deleting an entity, we don't need to know the query that was used to load it anymore (don't call this after loading the entity, since we might still need to load its collections)

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

batchLoadableCollectionsback to summary
private Map<String, LinkedHashMap<CollectionEntry, PersistentCollection>> batchLoadableCollections

Used to hold information about the collections that are currently eligible for batch-fetching. Ultimately used by getCollectionBatch to build collection load batches.

batchLoadableEntityKeysback to summary
private Map<String, LinkedHashSet<EntityKey>> batchLoadableEntityKeys

Used to hold information about the entities that are currently eligible for batch-fetching. Ultimately used by getEntityBatch to build entity load batches.

A Map structure is used to segment the keys by entity type since loading can only be done for a particular entity type at a time.

contextback to summary
private final PersistenceContext context
LOGback to summary
private static final Logger LOG
subselectsByEntityKeyback to summary
private Map<EntityKey, SubselectFetch> subselectsByEntityKey

A map of subselect-fetch descriptors keyed by the EntityKey against which the descriptor is registered.

Constructor Detail

BatchFetchQueueback to summary
public BatchFetchQueue(PersistenceContext context)

Constructs a queue for the given context.

Parameters
context:PersistenceContext

The owning context.

Method Detail

addBatchLoadableCollectionback to summary
public void addBatchLoadableCollection(PersistentCollection collection, CollectionEntry ce)

If a CollectionEntry represents a batch loadable collection, add it to the queue.

addBatchLoadableEntityKeyback to summary
public void addBatchLoadableEntityKey(EntityKey key)

If an EntityKey represents a batch loadable entity, add it to the queue.

Note that the contract here is such that any key passed in should previously have been been checked for existence within the PersistenceContext; failure to do so may cause the referenced entity to be included in a batch even though it is already associated with the PersistenceContext.

addSubselectback to summary
public void addSubselect(EntityKey key, SubselectFetch subquery)

Adds a subselect fetch descriptor for the given entity key.

Parameters
key:EntityKey

The entity for which to register the subselect fetch.

subquery:SubselectFetch

The fetch descriptor.

clearback to summary
public void clear()

Clears all entries from this fetch queue.

Called after flushing or clearing the session.

containsEntityKeyback to summary
public boolean containsEntityKey(EntityKey key)

Intended for test usage. Really has no use-case in Hibernate proper.

getCollectionBatchback to summary
public Serializable[] getCollectionBatch(final CollectionPersister collectionPersister, final Serializable id, final int batchSize)

Get a batch of uninitialized collection keys for a given role

Parameters
collectionPersister:CollectionPersister

The persister for the collection role.

id:Serializable

A key that must be included in the batch fetch

batchSize:int

the maximum number of keys to return

Returns:Serializable[]

an array of collection keys, of length batchSize (padded with nulls)

getEntityBatchback to summary
public Serializable[] getEntityBatch(final EntityPersister persister, final Serializable id, final int batchSize, final EntityMode entityMode)

Get a batch of unloaded identifiers for this class, using a slightly complex algorithm that tries to grab keys registered immediately after the given key.

Parameters
persister:EntityPersister

The persister for the entities being loaded.

id:Serializable

The identifier of the entity currently demanding load.

batchSize:int

The maximum number of keys to return

Returns:Serializable[]

an array of identifiers, of length batchSize (possibly padded with nulls)

getSubselectback to summary
public SubselectFetch getSubselect(EntityKey key)

Retrieve the fetch descriptor associated with the given entity key.

Parameters
key:EntityKey

The entity key for which to locate any defined subselect fetch.

Returns:SubselectFetch

The fetch descriptor; may return null if no subselect fetch queued for this entity key.

isCachedback to summary
private boolean isCached(EntityKey entityKey, EntityPersister persister)
isCachedback to summary
private boolean isCached(Serializable collectionKey, CollectionPersister persister)
removeBatchLoadableCollectionback to summary
public void removeBatchLoadableCollection(CollectionEntry ce)

After a collection was initialized or evicted, we don't need to batch fetch it anymore, remove it from the queue if necessary

removeBatchLoadableEntityKeyback to summary
public void removeBatchLoadableEntityKey(EntityKey key)

After evicting or deleting or loading an entity, we don't need to batch fetch it anymore, remove it from the queue if necessary

removeSubselectback to summary
public void removeSubselect(EntityKey key)

After evicting or deleting an entity, we don't need to know the query that was used to load it anymore (don't call this after loading the entity, since we might still need to load its collections)