Class FlushOperation

java.lang.Object
org.hibernate.action.queue.spi.plan.FlushOperation
All Implemented Interfaces:
OperationResultChecker
@Incubating(since="8.0", group="action-queue") public class FlushOperation extends Object implements OperationResultChecker

Represents a single SQL operation to be executed.

Uses standard MutationOperation from the SQL model package.

Since:
8.0

  • Constructor Details

  • Method Details

    • getMutatingTableDescriptor

      public TableDescriptor getMutatingTableDescriptor()

    • getTableExpression

      public String getTableExpression()

    • getKind

      public MutationKind getKind()

    • getShapeKey

      public StatementShapeKey getShapeKey()

    • getJdbcOperation

      public MutationOperation getJdbcOperation()

    • getBindPlan

      public BindPlan getBindPlan()

    • getOperationResultChecker

      public OperationResultChecker getOperationResultChecker()

    • checkResult

      public boolean checkResult(int affectedRowCount, PreparedStatement statement, int batchPosition, String sqlString, SessionFactoryImplementor sessionFactory) throws SQLException
      Description copied from interface: OperationResultChecker
      Check the result of a JDBC operation
      Specified by:
      checkResult in interface OperationResultChecker
      Parameters:
      affectedRowCount - The number of rows affected by the operation, as reported by the JDBC driver
      statement - The executed statement, including any registered OUT parameters
      batchPosition - The execution's position within the active batch, if one; if not batching, -1 will be passed
      Returns:
      true indicates an execution that is considered successful; false indicates unsuccessful
      Throws:
      SQLException

    • getBindingPatch

      public org.hibernate.action.queue.internal.cyclebreak.BindingPatch getBindingPatch()

    • getIntendedFkValues

      public Map<String,Object> getIntendedFkValues()

    • getIntendedUniqueValues

      public Map<String,Object> getIntendedUniqueValues()

    • hasIntendedFkValues

      public boolean hasIntendedFkValues()

    • hasIntendedUniqueValues

      public boolean hasIntendedUniqueValues()

    • hasIntendedFkValue

      public boolean hasIntendedFkValue(String column)

    • hasIntendedUniqueValue

      public boolean hasIntendedUniqueValue(String column)

    • addIntendedFkValue

      public void addIntendedFkValue(String column, Object value)

    • addIntendedUniqueValue

      public void addIntendedUniqueValue(String column, Object value)

    • getCachedInsertValuesAnalysis

      public Object getCachedInsertValuesAnalysis()

    • getCachedTableInclusionChecker

      public Object getCachedTableInclusionChecker()

    • getOrdinal

      public int getOrdinal()

    • getOrigin

      public String getOrigin()

    • needsIdPrePhase

      public boolean needsIdPrePhase()

    • setBindingPatch

      public void setBindingPatch(org.hibernate.action.queue.internal.cyclebreak.BindingPatch bindingPatch)

    • setCachedInsertValuesAnalysis

      public void setCachedInsertValuesAnalysis(ValuesAnalysis cachedInsertValuesAnalysis)

    • setCachedTableInclusionChecker

      public void setCachedTableInclusionChecker(Object cachedTableInclusionChecker)

    • setOrdinal

      public void setOrdinal(int ordinal)

    • setOrigin

      public void setOrigin(String origin)

    • getPostExecutionCallback

      public PostExecutionCallback getPostExecutionCallback()

    • getPreExecutionCallback

      public PreExecutionCallback getPreExecutionCallback()

    • getExecutionPrerequisite

      public FlushOperation getExecutionPrerequisite()
      An operation whose execution and result checking must precede this operation.

    • setExecutionPrerequisite

      public void setExecutionPrerequisite(FlushOperation executionPrerequisite)

    • getExecutionMonitor

      public OperationExecutionMonitor getExecutionMonitor()

    • setExecutionMonitor

      public void setExecutionMonitor(OperationExecutionMonitor executionMonitor)

    • getCollectionMutationCompletion

      public org.hibernate.action.queue.internal.decompose.collection.CollectionMutationCompletion getCollectionMutationCompletion()

    • getCollectionMutationId

      public CollectionMutationId getCollectionMutationId()

    • setCollectionMutationCompletion

      public void setCollectionMutationCompletion(org.hibernate.action.queue.internal.decompose.collection.CollectionMutationCompletion collectionMutationCompletion)

    • isCollectionMutationFixupReserved

      public boolean isCollectionMutationFixupReserved()

    • setCollectionMutationFixupReserved

      public void setCollectionMutationFixupReserved(boolean collectionMutationFixupReserved)

    • setPreExecutionCallback

      public void setPreExecutionCallback(PreExecutionCallback preExecutionCallback)

    • isExecutionSkipped

      public boolean isExecutionSkipped()

    • setExecutionSkipped

      public void setExecutionSkipped(boolean executionSkipped)

    • setPostExecutionCallback

      public void setPostExecutionCallback(PostExecutionCallback postExecutionCallback)

    • takePostExecutionCallback

      public PostExecutionCallback takePostExecutionCallback()
      Removes and returns the callback currently attached to this operation.