Modifier and Type	Class and Description
private static class	ActionQueue.AfterTransactionCompletionProcessQueue
private static class	ActionQueue.BeforeTransactionCompletionProcessQueue
private class	ActionQueue.InsertActionSorter Sorts the insert actions using more hashes.

Modifier and Type	Field and Description
private ActionQueue.AfterTransactionCompletionProcessQueue	afterTransactionProcesses
private ActionQueue.BeforeTransactionCompletionProcessQueue	beforeTransactionProcesses
private ArrayList<E>	collectionCreations
private ArrayList<E>	collectionRemovals
private ArrayList<E>	collectionUpdates
private ArrayList<E>	deletions
private static final int	INIT_QUEUE_LIST_SIZE
private ArrayList<E>	insertions
private static final Logger	log
private SessionImplementor	session
private ArrayList<E>	updates

Access	Constructor and Description
public	ActionQueue(SessionImplementor The session "owning" this queue. session) Constructs an action queue bound to the given session.

Method Summary

Modifier and Type	Method and Description
public void	addAction(EntityInsertAction action)
public void	addAction(EntityDeleteAction action)
public void	addAction(EntityUpdateAction action)
public void	addAction(CollectionRecreateAction action)
public void	addAction(CollectionRemoveAction action)
public void	addAction(CollectionUpdateAction action)
public void	addAction(EntityIdentityInsertAction insert)
public void	addAction(BulkOperationCleanupAction cleanupAction)
public void	afterTransactionCompletion(boolean Was the transaction successful. success) Performs cleanup of any held cache softlocks.
public boolean	Returns: True if insertions or deletions are currently queued; false otherwise. areInsertionsOrDeletionsQueued() Check whether any insertion or deletion actions are currently queued.
public boolean	Returns: True if we contain pending actions against any of the given tables; false otherwise. areTablesToBeUpdated(Set<E> The table/query-spaces to check. tables) Check whether the given tables/query-spaces are to be executed against given the currently queued actions.
private static boolean	areTablesToUpdated(List<E> actions, Set<E> tableSpaces)
public void	beforeTransactionCompletion() Execute any registered `BeforeTransactionCompletionProcess`
public void	clear()
public void	clearFromFlushNeededCheck(int previousCollectionRemovalSize)
public ArrayList<E>	cloneDeletions()
public static ActionQueue	Returns: The deserialized action queue deserialize(ObjectInputStream The stream from which to read the action queue ois, SessionImplementor The session to which the action queue belongs session) Used by the owning session to explicitly control deserialization of the action queue
public void	execute(Executable executable)
public void	executeActions() Perform all currently queued actions.
private void	executeActions(List<E> list)
public void	executeInserts() Perform all currently queued entity-insertion actions.
public boolean	hasAfterTransactionActions()
public boolean	hasAnyQueuedActions()
public boolean	hasBeforeTransactionActions()
private void	init()
public int	numberOfCollectionCreations()
public int	numberOfCollectionRemovals()
public int	numberOfCollectionUpdates()
public int	numberOfDeletions()
public int	numberOfInsertions()
public int	numberOfUpdates()
public void	prepareActions() Prepares the internal action queues for execution.
private void	prepareActions(List<E> queue)
private void	registerCleanupActions(Executable executable)
public void	registerProcess(AfterTransactionCompletionProcess process)
public void	registerProcess(BeforeTransactionCompletionProcess process)
public void	serialize(ObjectOutputStream The stream to which the action queue should get written oos) Used by the owning session to explicitly control serialization of the action queue
public void	sortActions()
public void	sortCollectionActions()
private void	sortInsertActions() Order the `insertions` queue such that we group inserts against the same entity together (without violating constraints).
public String	Returns: a string representation of the object. toString() Overrides java.lang.Object.toString. Returns a string representation of the object.
public void	unScheduleDeletion(EntityEntry entry, Object rescuedEntity)

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll wait wait wait

Field Detail

afterTransactionProcesses	back to summary
private ActionQueue.AfterTransactionCompletionProcessQueue afterTransactionProcesses

beforeTransactionProcesses	back to summary
private ActionQueue.BeforeTransactionCompletionProcessQueue beforeTransactionProcesses

collectionCreations	back to summary
private ArrayList<E> collectionCreations

collectionRemovals	back to summary
private ArrayList<E> collectionRemovals

collectionUpdates	back to summary
private ArrayList<E> collectionUpdates

deletions	back to summary
private ArrayList<E> deletions

INIT_QUEUE_LIST_SIZE	back to summary
private static final int INIT_QUEUE_LIST_SIZE

insertions	back to summary
private ArrayList<E> insertions

log	back to summary
private static final Logger log

session	back to summary
private SessionImplementor session

updates	back to summary
private ArrayList<E> updates

Constructor Detail

ActionQueue	back to summary
public ActionQueue(SessionImplementor session) Constructs an action queue bound to the given session. Parameters session:SessionImplementor The session "owning" this queue.

ActionQueue

back to summary

public ActionQueue(SessionImplementor session)

Constructs an action queue bound to the given session.

Parameters

session:SessionImplementor: The session "owning" this queue.

Method Detail

addAction	back to summary
public void addAction(EntityInsertAction action) Annotations @SuppressWarnings:unchecked

addAction	back to summary
public void addAction(EntityDeleteAction action) Annotations @SuppressWarnings:unchecked

addAction	back to summary
public void addAction(EntityUpdateAction action) Annotations @SuppressWarnings:unchecked

addAction	back to summary
public void addAction(CollectionRecreateAction action) Annotations @SuppressWarnings:unchecked

addAction	back to summary
public void addAction(CollectionRemoveAction action) Annotations @SuppressWarnings:unchecked

addAction	back to summary
public void addAction(CollectionUpdateAction action) Annotations @SuppressWarnings:unchecked

addAction	back to summary
public void addAction(EntityIdentityInsertAction insert) Annotations @SuppressWarnings:unchecked

addAction	back to summary
public void addAction(BulkOperationCleanupAction cleanupAction)

afterTransactionCompletion	back to summary
public void afterTransactionCompletion(boolean success) Performs cleanup of any held cache softlocks. Parameters success:boolean Was the transaction successful.

afterTransactionCompletion

back to summary

public void afterTransactionCompletion(boolean success)

Performs cleanup of any held cache softlocks.

Parameters

success:boolean: Was the transaction successful.

areInsertionsOrDeletionsQueued	back to summary
public boolean areInsertionsOrDeletionsQueued() Check whether any insertion or deletion actions are currently queued. Returns:boolean True if insertions or deletions are currently queued; false otherwise.

areInsertionsOrDeletionsQueued

back to summary

public boolean areInsertionsOrDeletionsQueued()

Check whether any insertion or deletion actions are currently queued.

Returns:boolean: True if insertions or deletions are currently queued; false otherwise.

areTablesToBeUpdated	back to summary
public boolean areTablesToBeUpdated(Set<E> tables) Check whether the given tables/query-spaces are to be executed against given the currently queued actions. Parameters tables:Set<E> The table/query-spaces to check. Returns:boolean True if we contain pending actions against any of the given tables; false otherwise.

areTablesToBeUpdated

back to summary

public boolean areTablesToBeUpdated(Set<E> tables)

Check whether the given tables/query-spaces are to be executed against given the currently queued actions.

Parameters

tables:Set<E>: The table/query-spaces to check.

Returns:boolean

True if we contain pending actions against any of the given tables; false otherwise.

areTablesToUpdated	back to summary
private static boolean areTablesToUpdated(List<E> actions, Set<E> tableSpaces) Annotations @SuppressWarnings:unchecked

beforeTransactionCompletion	back to summary
public void beforeTransactionCompletion() Execute any registered `BeforeTransactionCompletionProcess`

clear	back to summary
public void clear()

clearFromFlushNeededCheck	back to summary
public void clearFromFlushNeededCheck(int previousCollectionRemovalSize)

cloneDeletions	back to summary
public ArrayList<E> cloneDeletions() Annotations @SuppressWarnings:UnusedDeclaration

deserialize	back to summary
public static ActionQueue deserialize(ObjectInputStream ois, SessionImplementor session) throws IOException, ClassNotFoundException Used by the owning session to explicitly control deserialization of the action queue Parameters ois:ObjectInputStream The stream from which to read the action queue session:SessionImplementor The session to which the action queue belongs Returns:ActionQueue The deserialized action queue Annotations @SuppressWarnings:unchecked Exceptions IOException: indicates a problem reading from the stream ClassNotFoundException: Generally means we were unable to locate user classes.

deserialize

back to summary

public static ActionQueue deserialize(ObjectInputStream ois, SessionImplementor session) throws IOException, ClassNotFoundException

Used by the owning session to explicitly control deserialization of the action queue

Parameters

ois:ObjectInputStream: The stream from which to read the action queue
session:SessionImplementor: The session to which the action queue belongs

Returns:ActionQueue

The deserialized action queue

Annotations

@SuppressWarnings:unchecked

Exceptions

IOException:: indicates a problem reading from the stream
ClassNotFoundException:: Generally means we were unable to locate user classes.

execute	back to summary
public void execute(Executable executable)

executeActions	back to summary
public void executeActions() throws HibernateException Perform all currently queued actions. Exceptions HibernateException: error executing queued actions.

executeActions

back to summary

public void executeActions() throws HibernateException

Perform all currently queued actions.

Exceptions

HibernateException:: error executing queued actions.

executeActions	back to summary
private void executeActions(List<E> list) throws HibernateException

executeInserts	back to summary
public void executeInserts() throws HibernateException Perform all currently queued entity-insertion actions. Exceptions HibernateException: error executing queued insertion actions.

executeInserts

back to summary

public void executeInserts() throws HibernateException

Perform all currently queued entity-insertion actions.

Exceptions

HibernateException:: error executing queued insertion actions.

hasAfterTransactionActions	back to summary
public boolean hasAfterTransactionActions() Annotations @SuppressWarnings:UnusedDeclaration

hasAnyQueuedActions	back to summary
public boolean hasAnyQueuedActions()

hasBeforeTransactionActions	back to summary
public boolean hasBeforeTransactionActions()

init	back to summary
private void init()

numberOfCollectionCreations	back to summary
public int numberOfCollectionCreations()

numberOfCollectionRemovals	back to summary
public int numberOfCollectionRemovals()

numberOfCollectionUpdates	back to summary
public int numberOfCollectionUpdates()

numberOfDeletions	back to summary
public int numberOfDeletions()

numberOfInsertions	back to summary
public int numberOfInsertions()

numberOfUpdates	back to summary
public int numberOfUpdates()

prepareActions	back to summary
public void prepareActions() throws HibernateException Prepares the internal action queues for execution. Exceptions HibernateException: error preparing actions.

prepareActions

back to summary

public void prepareActions() throws HibernateException

Prepares the internal action queues for execution.

Exceptions

HibernateException:: error preparing actions.

prepareActions	back to summary
private void prepareActions(List<E> queue) throws HibernateException Annotations @SuppressWarnings:unchecked

registerCleanupActions	back to summary
private void registerCleanupActions(Executable executable)

registerProcess	back to summary
public void registerProcess(AfterTransactionCompletionProcess process)

registerProcess	back to summary
public void registerProcess(BeforeTransactionCompletionProcess process)

serialize

back to summary

public void serialize(ObjectOutputStream oos) throws IOException

Used by the owning session to explicitly control serialization of the action queue

Parameters

oos:ObjectOutputStream: The stream to which the action queue should get written

Exceptions

IOException:: Indicates an error writing to the stream

sortActions	back to summary
public void sortActions() Annotations @SuppressWarnings:unchecked

sortCollectionActions	back to summary
public void sortCollectionActions() Annotations @SuppressWarnings:unchecked

sortInsertActions back to summary

private void sortInsertActions()

Order the insertions queue such that we group inserts against the same entity together (without violating constraints). The original order is generated by cascade order, which in turn is based on the directionality of foreign-keys. So even though we will be changing the ordering here, we need to make absolutely certain that we do not circumvent this FK ordering to the extent of causing constraint violations

toString

back to summary

public String toString()

Overrides java.lang.Object.toString.

Returns a string representation of the object.

Returns:String: a string representation of the object.

unScheduleDeletion	back to summary
public void unScheduleDeletion(EntityEntry entry, Object rescuedEntity)

org.hibernate.engine back to summary

private Class ActionQueue.AfterTransactionCompletionProcessQueue

Class Inheritance

extends Object

java.lang.Object
org.hibernate.engine.ActionQueue.AfterTransactionCompletionProcessQueue

Field Summary

Modifier and Type	Field and Description
private List<AfterTransactionCompletionProcess>	processes
private Set<String>	querySpacesToInvalidate
private SessionImplementor	session

Constructor Summary

Access	Constructor and Description
private	AfterTransactionCompletionProcessQueue(SessionImplementor session)

Method Summary

Modifier and Type	Method and Description
public void	addSpacesToInvalidate(String[] spaces)
public void	addSpaceToInvalidate(String space)
public void	afterTransactionCompletion(boolean success)
public void	register(AfterTransactionCompletionProcess process)

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

processes	back to summary
private List<AfterTransactionCompletionProcess> processes

querySpacesToInvalidate	back to summary
private Set<String> querySpacesToInvalidate

session	back to summary
private SessionImplementor session

Constructor Detail

AfterTransactionCompletionProcessQueue	back to summary
private AfterTransactionCompletionProcessQueue(SessionImplementor session)

Method Detail

addSpacesToInvalidate	back to summary
public void addSpacesToInvalidate(String[] spaces)

addSpaceToInvalidate	back to summary
public void addSpaceToInvalidate(String space)

afterTransactionCompletion	back to summary
public void afterTransactionCompletion(boolean success)

register	back to summary
public void register(AfterTransactionCompletionProcess process)

org.hibernate.engine back to summary

private Class ActionQueue.BeforeTransactionCompletionProcessQueue

Class Inheritance

extends Object

java.lang.Object
org.hibernate.engine.ActionQueue.BeforeTransactionCompletionProcessQueue

Field Summary

Modifier and Type	Field and Description
private List<BeforeTransactionCompletionProcess>	processes
private SessionImplementor	session

Constructor Summary

Access	Constructor and Description
private	BeforeTransactionCompletionProcessQueue(SessionImplementor session)

Method Summary

Modifier and Type	Method and Description
public void	beforeTransactionCompletion()
public void	register(BeforeTransactionCompletionProcess process)

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

processes	back to summary
private List<BeforeTransactionCompletionProcess> processes

session	back to summary
private SessionImplementor session

Constructor Detail

BeforeTransactionCompletionProcessQueue	back to summary
private BeforeTransactionCompletionProcessQueue(SessionImplementor session)

Method Detail

beforeTransactionCompletion	back to summary
public void beforeTransactionCompletion()

register	back to summary
public void register(BeforeTransactionCompletionProcess process)

org.hibernate.engine back to summary

private Class ActionQueue.InsertActionSorter

Class Inheritance

extends Object

java.lang.Object
org.hibernate.engine.ActionQueue.InsertActionSorter

Sorts the insert actions using more hashes.

Author: Jay Erb

Field Summary

Modifier and Type	Field and Description
private HashMap<K, V>	actionBatches
private HashMap<K, V>	entityBatchNumber
private HashMap<K, V>	latestBatches

Constructor Summary

Access	Constructor and Description
public	InsertActionSorter()

Method Summary

Modifier and Type	Method and Description
private void	addToBatch(Integer batchNumber, EntityInsertAction action)
private Integer	Returns: An appropriate batch number; todo document this process better findBatchNumber(EntityInsertAction The action being sorted action, String The name of the entity affected by the action entityName) Finds an acceptable batch for this entity to be a member as part of the `InsertActionSorter`
public void	sort() Sort the insert actions.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

actionBatches	back to summary
private HashMap<K, V> actionBatches

entityBatchNumber	back to summary
private HashMap<K, V> entityBatchNumber

latestBatches	back to summary
private HashMap<K, V> latestBatches

Constructor Detail

InsertActionSorter	back to summary
public InsertActionSorter()

Method Detail

addToBatch	back to summary
private void addToBatch(Integer batchNumber, EntityInsertAction action) Annotations @SuppressWarnings:unchecked

findBatchNumber back to summary

private Integer findBatchNumber(EntityInsertAction action, String entityName)

Finds an acceptable batch for this entity to be a member as part of the InsertActionSorter

Parameters

action:EntityInsertAction: The action being sorted
entityName:String: The name of the entity affected by the action

Returns:Integer

An appropriate batch number; todo document this process better

Annotations

@SuppressWarnings:UnnecessaryBoxing, unchecked

sort

back to summary

public void sort()

Sort the insert actions.

Annotations

@SuppressWarnings:unchecked, UnnecessaryBoxing

public Class ActionQueue

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private Class ActionQueue.AfterTransactionCompletionProcessQueue

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private Class ActionQueue.BeforeTransactionCompletionProcessQueue

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private Class ActionQueue.InsertActionSorter

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail