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(AbstractEntityPersister entityPersister, SessionFactoryImplementor factory)

Method Summary

Modifier and Type	Method	Description
protected void	breakDownJdbcValue(Object id, 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, SharedSessionContractImplementor session, boolean isIdentityInsert)
protected void	decomposeAttribute(Object value, 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, SharedSessionContractImplementor session)
protected CompletionStage<org.hibernate.generator.values.GeneratedValues>	doDynamicInserts(Object id, Object[] values, Object object, SharedSessionContractImplementor session, boolean forceIdentifierBinding, boolean isIdentityInsert)
protected CompletionStage<org.hibernate.generator.values.GeneratedValues>	doStaticInserts(Object id, Object[] values, Object object, SharedSessionContractImplementor session, boolean isIdentityInsert)
protected org.hibernate.sql.model.MutationOperationGroup	generateDynamicInsertSqlGroup(boolean[] insertable, Object object, 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, SharedSessionContractImplementor session)
org.hibernate.generator.values.GeneratedValues	insert(Object entity, Object id, Object[] values, SharedSessionContractImplementor session)
CompletionStage<org.hibernate.generator.values.GeneratedValues>	reactiveInsert(Object entity, Object[] values, SharedSessionContractImplementor session)
CompletionStage<org.hibernate.generator.values.GeneratedValues>	reactiveInsert(Object entity, Object id, Object[] values, SharedSessionContractImplementor session)
protected org.hibernate.engine.jdbc.mutation.spi.BatchKeyAccess	resolveBatchKeyAccess(boolean dynamicUpdate, 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(AbstractEntityPersister entityPersister,
 SessionFactoryImplementor factory)

Method Details

insert

public org.hibernate.generator.values.GeneratedValues insert(Object entity,
 Object[] values,
 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,
 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,
 SharedSessionContractImplementor session)

Specified by:

reactiveInsert in interface ReactiveInsertCoordinator

reactiveInsert

public CompletionStage<org.hibernate.generator.values.GeneratedValues> reactiveInsert(Object entity,
 Object id,
 Object[] values,
 SharedSessionContractImplementor session)

Specified by:

reactiveInsert in interface ReactiveInsertCoordinator

coordinateReactiveInsert

public CompletionStage<org.hibernate.generator.values.GeneratedValues> coordinateReactiveInsert(Object entity,
 Object id,
 Object[] values,
 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,
 SharedSessionContractImplementor session)

doDynamicInserts

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

doStaticInserts

protected CompletionStage<org.hibernate.generator.values.GeneratedValues> doStaticInserts(Object id,
 Object[] values,
 Object object,
 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,
 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,
 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,
 SharedSessionContractImplementor session,
 boolean forceIdentifierBinding)

generateStaticOperationGroup

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

breakDownJdbcValue

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