org.hibernate.engine
Class ActionQueue

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

All Implemented Interfaces:

Serializable

public class ActionQueue

extends Object

implements Serializable

Responsible for maintaing the queue of actions related to events.

The ActionQueue holds the DML operations queued as part of a session's transactional-write-behind semantics. DML operations are queued here until a flush forces them to be executed against the database.

Author:

Steve Ebersole

See Also:

Serialized Form

Constructor Summary

ActionQueue(SessionImplementor session)
Constructs an action queue bound to the given session.

Method Summary

void	addAction(BulkOperationCleanupAction cleanupAction)
void	addAction(CollectionRecreateAction action)
void	addAction(CollectionRemoveAction action)
void	addAction(CollectionUpdateAction action)
void	addAction(EntityDeleteAction action)
void	addAction(EntityIdentityInsertAction insert)
void	addAction(EntityInsertAction action)
void	addAction(EntityUpdateAction action)
void	afterTransactionCompletion(boolean success) Performs cleanup of any held cache softlocks.
boolean	areInsertionsOrDeletionsQueued()
boolean	areTablesToBeUpdated(Set tables) Check whether the given tables/query-spaces are to be executed against given the currently queued actions.
void	clear()
void	clearFromFlushNeededCheck(int previousCollectionRemovalSize)
ArrayList	cloneDeletions()
void	execute(Executable executable)
void	executeActions() Perform all currently queued actions.
void	executeInserts() Perform all currently queued entity-insertion actions.
boolean	hasAnyQueuedActions()
int	numberOfCollectionCreations()
int	numberOfCollectionRemovals()
int	numberOfCollectionUpdates()
int	numberOfDeletions()
int	numberOfInsertions()
int	numberOfUpdates()
void	prepareActions() Prepares the internal action queues for execution.
void	sortCollectionActions()
void	sortUpdateActions()
String	toString() Returns a string representation of the object.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

ActionQueue

public ActionQueue(SessionImplementor session)

Constructs an action queue bound to the given session.

Parameters:

session - The session "owning" this queue.

Method Detail

clear

public void clear()

addAction

public void addAction(EntityInsertAction action)

addAction

public void addAction(EntityDeleteAction action)

addAction

public void addAction(EntityUpdateAction action)

addAction

public void addAction(CollectionRecreateAction action)

addAction

public void addAction(CollectionRemoveAction action)

addAction

public void addAction(CollectionUpdateAction action)

addAction

public void addAction(EntityIdentityInsertAction insert)

addAction

public void addAction(BulkOperationCleanupAction cleanupAction)

executeInserts

public void executeInserts()
                    throws HibernateException

Perform all currently queued entity-insertion actions.

Throws:

HibernateException - error executing queued insertion actions.

executeActions

public void executeActions()
                    throws HibernateException

Perform all currently queued actions.

Throws:

HibernateException - error executing queued actions.

prepareActions

public void prepareActions()
                    throws HibernateException

Prepares the internal action queues for execution.

Throws:

HibernateException - error preparing actions.

afterTransactionCompletion

public void afterTransactionCompletion(boolean success)

Performs cleanup of any held cache softlocks.

Parameters:

success - Was the transaction successful.

areTablesToBeUpdated

public boolean areTablesToBeUpdated(Set tables)

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

Parameters:

tables - The table/query-spaces to check.

Returns:

areInsertionsOrDeletionsQueued

public boolean areInsertionsOrDeletionsQueued()

execute

public void execute(Executable executable)

toString

public String toString()

Returns a string representation of the object.

Returns:

a string representation of the object.

numberOfCollectionRemovals

public int numberOfCollectionRemovals()

numberOfCollectionUpdates

public int numberOfCollectionUpdates()

numberOfCollectionCreations

public int numberOfCollectionCreations()

numberOfDeletions

public int numberOfDeletions()

numberOfUpdates

public int numberOfUpdates()

numberOfInsertions

public int numberOfInsertions()

sortCollectionActions

public void sortCollectionActions()

sortUpdateActions

public void sortUpdateActions()

cloneDeletions

public ArrayList cloneDeletions()

clearFromFlushNeededCheck

public void clearFromFlushNeededCheck(int previousCollectionRemovalSize)

hasAnyQueuedActions

public boolean hasAnyQueuedActions()