Overview | Package | Class | Use | Tree | Deprecated | Index | Help
PREV CLASS NEXT CLASS | FRAMES NO FRAMES
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD

## org.hibernate.engine
Class ActionQueue

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

    public class ActionQueue

extends Object

Responsible for maintaining 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

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()` Check whether any insertion or deletion actions are currently queued.
`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()`
`static ActionQueue` | `deserialize(ObjectInputStream ois, SessionImplementor session)` Used by the owning session to explicitly control deserialization of the action queue
`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` | `serialize(ObjectOutputStream oos)` Used by the owning session to explicitly control serialization of the action queue
`void` | `sortActions()`
`void` | `sortCollectionActions()`
`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:
    True if we contain pending actions against any of the given tables; false otherwise.

### areInsertionsOrDeletionsQueued

    public boolean areInsertionsOrDeletionsQueued()

  Check whether any insertion or deletion actions are currently queued.

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

### execute

    public void execute(Executable executable)

### toString

    public String toString()

  Returns a string representation of the object.

  Overrides:
    `toString` in class `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()

### sortActions

    public void sortActions()

### cloneDeletions

    public ArrayList cloneDeletions()

### clearFromFlushNeededCheck

    public void clearFromFlushNeededCheck(int previousCollectionRemovalSize)

### hasAnyQueuedActions

    public boolean hasAnyQueuedActions()

### serialize

    public void serialize(ObjectOutputStream oos)
                   throws IOException

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

  Parameters:
    `oos` - The stream to which the action queue should get written
  Throws:
    `IOException`

### deserialize

    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` - The stream from which to read the action queue
  Throws:
    `IOException`
    `ClassNotFoundException`

Overview | Package | Class | Use | Tree | Deprecated | Index | Help
PREV CLASS NEXT CLASS | FRAMES NO FRAMES
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD