The ActionQueue holds the DML operations queued as part of a session's transactional-write-behind semantics.
The DML operations are queued here until a flush forces them to be executed against the database.
| Modifier and Type | Class and Description |
|---|---|
| private abstract static class | |
| private static class | ActionQueue.AfterTransactionCompletionProcessQueue
Encapsulates behavior needed for after transaction processing |
| private static class | ActionQueue.BeforeTransactionCompletionProcessQueue
Encapsulates behavior needed for before transaction processing |
| private static class | ActionQueue.InsertActionSorter
Order the |
| private static enum | |
| public static class | ActionQueue.TransactionCompletionProcesses
Wrapper class allowing to bind the same transaction completion process queues in different sessions. |
| Modifier and Type | Field and Description |
|---|---|
| private ActionQueue. | |
| private ActionQueue. | |
| private ExecutableList | |
| private ExecutableList | |
| private ExecutableList | |
| private ExecutableList | |
| private ExecutableList | |
| private ExecutableList | |
| private transient boolean | |
| private static final CoreMessageLogger | |
| private static final ActionQueue. | |
| private ExecutableList | |
| private ExecutableList | |
| private final SessionImplementor | |
| private UnresolvedEntityInsertActions | |
| private ExecutableList |
| Access | Constructor and Description |
|---|---|
| public | ActionQueue(SessionImplementor
The session "owning" this queue. session)Constructs an action queue bound to the given session. |
| Modifier and Type | Method and Description |
|---|---|
| public void | addAction(EntityInsertAction
The action representing the entity insertion action)Adds an entity insert action |
| public void | addAction(EntityIdentityInsertAction
The action representing the entity insertion action)Adds an entity (IDENTITY) insert action |
| public void | addAction(EntityDeleteAction
The action representing the entity deletion action)Adds an entity delete action |
| public void | addAction(final OrphanRemovalAction
The action representing the orphan removal action)Adds an orphan removal action |
| public void | addAction(final EntityUpdateAction
The action representing the entity update action)Adds an entity update action |
| public void | addAction(final CollectionRecreateAction
The action representing the (re)creation of a collection action)Adds a collection (re)create action |
| public void | addAction(final CollectionRemoveAction
The action representing the removal of a collection action)Adds a collection remove action |
| public void | addAction(final CollectionUpdateAction
The action representing the update of a collection action)Adds a collection update action |
| public void | addAction(QueuedOperationCollectionAction
The action representing the queued operation action)Adds an action relating to a collection queued operation (extra lazy). |
| public void | addAction(BulkOperationCleanupAction
The action representing the queued operation action)Adds an action defining a cleanup relating to a bulk operation (HQL/JPQL or Criteria based update/delete) |
| private void | |
| private void | |
| public void | afterTransactionCompletion(boolean
Was the transaction successful. success)Performs cleanup of any held cache soft locks. |
| public boolean | Returns: true if insertions or deletions are currently queued; false otherwise.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.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 | |
| private static boolean | areTablesToBeUpdated(UnresolvedEntityInsertActions actions, Set<? extends Serializable> tableSpaces)
|
| public void | |
| public void | checkNoUnresolvedActionsAfterOperation()
Throws |
| public void | |
| public void | |
| public static ActionQueue | Returns: The deserialized action queueThe stream from which to read the action queue ois, EventSource The session to which the action queue belongs session)Used by the owning session to explicitly control deserialization of the action queue. |
| public <E extends Executable & Comparable | |
| public void | |
| private <E extends ComparableExecutable> void | executeActions(@Nullable ExecutableList<E>
The list of Executable elements to be performed list)Perform |
| public void | |
| public ActionQueue. | |
| public boolean | |
| public boolean | |
| public boolean | |
| public boolean | Returns: true, if there are unresolved entity insert actions that depend on non-nullable associations with a transient entity; false, otherwiseAre there unresolved entity insert actions that depend on non-nullable associations with a transient entity? |
| private void | invalidateSpaces(@Nullable String[]
The spaces to invalidate spaces)This method is now called once per execution of an ExecutableList or once for execution of an Execution. |
| private boolean | |
| private boolean | |
| private boolean | |
| public int | |
| public int | |
| public int | |
| public int | |
| public int | |
| public int | |
| public void | |
| private void | |
| private void | |
| public void | |
| public void | |
| 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 | setTransactionCompletionProcesses(ActionQueue.
Transaction completion processes. processes,Flag indicating shared transaction context. isTransactionCoordinatorShared)Bind transaction completion processes to make them shared between primary and secondary session. |
| public void | |
| public void | |
| public String | Returns: a string representation of the object.Overrides java. |
| private static String | |
| public void | |
| public void |