Package org.hibernate.reactive.persister.entity.mutation

Class ReactiveInsertCoordinatorStandard

java.lang.Object
org.hibernate.persister.entity.mutation.AbstractMutationCoordinator
org.hibernate.reactive.persister.entity.mutation.ReactiveInsertCoordinatorStandard
All Implemented Interfaces:
org.hibernate.persister.entity.mutation.InsertCoordinator, org.hibernate.persister.entity.mutation.MutationCoordinator, ReactiveInsertCoordinator
@Internal public class ReactiveInsertCoordinatorStandard extends org.hibernate.persister.entity.mutation.AbstractMutationCoordinator implements ReactiveInsertCoordinator, org.hibernate.persister.entity.mutation.InsertCoordinator
See Also:
  • InsertCoordinatorStandard

  • Field Summary

    Fields inherited from class org.hibernate.persister.entity.mutation.AbstractMutationCoordinator

    dialect, entityPersister, factory, mutationExecutorService

  • Constructor Summary

    Constructors
    Constructor
    Description
    ReactiveInsertCoordinatorStandard(org.hibernate.persister.entity.AbstractEntityPersister entityPersister, org.hibernate.engine.spi.SessionFactoryImplementor factory)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    protected void
    breakDownJdbcValue(Object id, org.hibernate.engine.spi.SharedSessionContractImplementor session, org.hibernate.engine.jdbc.mutation.JdbcValueBindings jdbcValueBindings, org.hibernate.persister.entity.mutation.EntityTableMapping tableDetails)
     
    CompletionStage<org.hibernate.generator.values.GeneratedValues>
    coordinateReactiveInsert(Object entity, Object id, Object[] values, org.hibernate.engine.spi.SharedSessionContractImplementor session, boolean isIdentityInsert)
     
    protected void
    decomposeAttribute(Object value, org.hibernate.engine.spi.SharedSessionContractImplementor session, org.hibernate.engine.jdbc.mutation.JdbcValueBindings jdbcValueBindings, org.hibernate.metamodel.mapping.AttributeMapping mapping)
     
    protected CompletionStage<Void>
    decomposeForReactiveInsert(org.hibernate.engine.jdbc.mutation.MutationExecutor mutationExecutor, Object id, Object[] values, org.hibernate.sql.model.MutationOperationGroup mutationGroup, boolean[] propertyInclusions, org.hibernate.engine.jdbc.mutation.TableInclusionChecker tableInclusionChecker, org.hibernate.engine.spi.SharedSessionContractImplementor session)
     
    protected CompletionStage<org.hibernate.generator.values.GeneratedValues>
    doDynamicInserts(Object id, Object[] values, Object object, org.hibernate.engine.spi.SharedSessionContractImplementor session, boolean forceIdentifierBinding, boolean isIdentityInsert)
     
    protected CompletionStage<org.hibernate.generator.values.GeneratedValues>
    doStaticInserts(Object id, Object[] values, Object object, org.hibernate.engine.spi.SharedSessionContractImplementor session, boolean isIdentityInsert)
     
    protected org.hibernate.sql.model.MutationOperationGroup
    generateDynamicInsertSqlGroup(boolean[] insertable, Object object, org.hibernate.engine.spi.SharedSessionContractImplementor session, boolean forceIdentifierBinding)
     
    org.hibernate.sql.model.MutationOperationGroup
    generateStaticOperationGroup()
     
    org.hibernate.engine.jdbc.batch.internal.BasicBatchKey
    getBatchKey()
     
    boolean[]
    getPropertiesToInsert(Object[] fields)
    Transform the array of property indexes to an array of booleans, true when the property is insertable and non-null
    org.hibernate.sql.model.MutationOperationGroup
    getStaticMutationOperationGroup()
    Deprecated.
    protected static org.hibernate.engine.jdbc.mutation.TableInclusionChecker
    getTableInclusionChecker(org.hibernate.persister.entity.mutation.InsertCoordinatorStandard.InsertValuesAnalysis insertValuesAnalysis)
     
    org.hibernate.generator.values.GeneratedValues
    insert(Object entity, Object[] values, org.hibernate.engine.spi.SharedSessionContractImplementor session)
     
    org.hibernate.generator.values.GeneratedValues
    insert(Object entity, Object id, Object[] values, org.hibernate.engine.spi.SharedSessionContractImplementor session)
     
    CompletionStage<org.hibernate.generator.values.GeneratedValues>
    reactiveInsert(Object entity, Object[] values, org.hibernate.engine.spi.SharedSessionContractImplementor session)
     
    CompletionStage<org.hibernate.generator.values.GeneratedValues>
    reactiveInsert(Object entity, Object id, Object[] values, org.hibernate.engine.spi.SharedSessionContractImplementor session)
     
    protected org.hibernate.engine.jdbc.mutation.spi.BatchKeyAccess
    resolveBatchKeyAccess(boolean dynamicUpdate, org.hibernate.engine.spi.SharedSessionContractImplementor session)
     

    Methods inherited from class org.hibernate.persister.entity.mutation.AbstractMutationCoordinator

    applyKeyRestriction, bindPartitionColumnValueBindings, breakDownKeyJdbcValues, createOperation, createOperationGroup, dialect, entityPersister, factory, handleValueGeneration, needsRowId

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • ReactiveInsertCoordinatorStandard

      public ReactiveInsertCoordinatorStandard(org.hibernate.persister.entity.AbstractEntityPersister entityPersister, org.hibernate.engine.spi.SessionFactoryImplementor factory)

  • Method Details

    • insert

      public org.hibernate.generator.values.GeneratedValues insert(Object entity, Object[] values, org.hibernate.engine.spi.SharedSessionContractImplementor session)
      Specified by:
      insert in interface org.hibernate.persister.entity.mutation.InsertCoordinator

    • insert

      public org.hibernate.generator.values.GeneratedValues insert(Object entity, Object id, Object[] values, org.hibernate.engine.spi.SharedSessionContractImplementor session)
      Specified by:
      insert in interface org.hibernate.persister.entity.mutation.InsertCoordinator

    • reactiveInsert

      public CompletionStage<org.hibernate.generator.values.GeneratedValues> reactiveInsert(Object entity, Object[] values, org.hibernate.engine.spi.SharedSessionContractImplementor session)
      Specified by:
      reactiveInsert in interface ReactiveInsertCoordinator

    • reactiveInsert

      public CompletionStage<org.hibernate.generator.values.GeneratedValues> reactiveInsert(Object entity, Object id, Object[] values, org.hibernate.engine.spi.SharedSessionContractImplementor session)
      Specified by:
      reactiveInsert in interface ReactiveInsertCoordinator

    • coordinateReactiveInsert

      public CompletionStage<org.hibernate.generator.values.GeneratedValues> coordinateReactiveInsert(Object entity, Object id, Object[] values, org.hibernate.engine.spi.SharedSessionContractImplementor session, boolean isIdentityInsert)

    • decomposeForReactiveInsert

      protected CompletionStage<Void> decomposeForReactiveInsert(org.hibernate.engine.jdbc.mutation.MutationExecutor mutationExecutor, Object id, Object[] values, org.hibernate.sql.model.MutationOperationGroup mutationGroup, boolean[] propertyInclusions, org.hibernate.engine.jdbc.mutation.TableInclusionChecker tableInclusionChecker, org.hibernate.engine.spi.SharedSessionContractImplementor session)

    • doDynamicInserts

      protected CompletionStage<org.hibernate.generator.values.GeneratedValues> doDynamicInserts(Object id, Object[] values, Object object, org.hibernate.engine.spi.SharedSessionContractImplementor session, boolean forceIdentifierBinding, boolean isIdentityInsert)

    • doStaticInserts

      protected CompletionStage<org.hibernate.generator.values.GeneratedValues> doStaticInserts(Object id, Object[] values, Object object, org.hibernate.engine.spi.SharedSessionContractImplementor session, boolean isIdentityInsert)

    • getTableInclusionChecker

      protected static org.hibernate.engine.jdbc.mutation.TableInclusionChecker getTableInclusionChecker(org.hibernate.persister.entity.mutation.InsertCoordinatorStandard.InsertValuesAnalysis insertValuesAnalysis)

    • resolveBatchKeyAccess

      protected org.hibernate.engine.jdbc.mutation.spi.BatchKeyAccess resolveBatchKeyAccess(boolean dynamicUpdate, org.hibernate.engine.spi.SharedSessionContractImplementor session)
      Overrides:
      resolveBatchKeyAccess in class org.hibernate.persister.entity.mutation.AbstractMutationCoordinator

    • getBatchKey

      public org.hibernate.engine.jdbc.batch.internal.BasicBatchKey getBatchKey()
      Specified by:
      getBatchKey in class org.hibernate.persister.entity.mutation.AbstractMutationCoordinator

    • getStaticMutationOperationGroup

      @Deprecated public org.hibernate.sql.model.MutationOperationGroup getStaticMutationOperationGroup()
      Deprecated.
      Specified by:
      getStaticMutationOperationGroup in interface org.hibernate.persister.entity.mutation.MutationCoordinator

    • decomposeAttribute

      protected void decomposeAttribute(Object value, org.hibernate.engine.spi.SharedSessionContractImplementor session, org.hibernate.engine.jdbc.mutation.JdbcValueBindings jdbcValueBindings, org.hibernate.metamodel.mapping.AttributeMapping mapping)

    • getPropertiesToInsert

      public boolean[] getPropertiesToInsert(Object[] fields)
      Transform the array of property indexes to an array of booleans, true when the property is insertable and non-null

    • generateDynamicInsertSqlGroup

      protected org.hibernate.sql.model.MutationOperationGroup generateDynamicInsertSqlGroup(boolean[] insertable, Object object, org.hibernate.engine.spi.SharedSessionContractImplementor session, boolean forceIdentifierBinding)

    • generateStaticOperationGroup

      public org.hibernate.sql.model.MutationOperationGroup generateStaticOperationGroup()

    • breakDownJdbcValue

      protected void breakDownJdbcValue(Object id, org.hibernate.engine.spi.SharedSessionContractImplementor session, org.hibernate.engine.jdbc.mutation.JdbcValueBindings jdbcValueBindings, org.hibernate.persister.entity.mutation.EntityTableMapping tableDetails)