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:

InsertCoordinator, MutationCoordinator, ReactiveInsertCoordinator

@Internal
public class ReactiveInsertCoordinatorStandard
extends AbstractMutationCoordinator
implements ReactiveInsertCoordinator, 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, JdbcValueBindings jdbcValueBindings, EntityTableMapping tableDetails)
CompletionStage<GeneratedValues>	coordinateReactiveInsert(Object entity, Object id, Object[] values, SharedSessionContractImplementor session, boolean isIdentityInsert)
protected void	decomposeAttribute(Object value, SharedSessionContractImplementor session, JdbcValueBindings jdbcValueBindings, AttributeMapping mapping)
protected CompletionStage<Void>	decomposeForReactiveInsert(MutationExecutor mutationExecutor, Object id, Object[] values, MutationOperationGroup mutationGroup, boolean[] propertyInclusions, TableInclusionChecker tableInclusionChecker, SharedSessionContractImplementor session)
protected CompletionStage<GeneratedValues>	doDynamicInserts(Object id, Object[] values, Object object, SharedSessionContractImplementor session, boolean forceIdentifierBinding, boolean isIdentityInsert)
protected CompletionStage<GeneratedValues>	doStaticInserts(Object id, Object[] values, Object object, SharedSessionContractImplementor session, boolean isIdentityInsert)
protected MutationOperationGroup	generateDynamicInsertSqlGroup(boolean[] insertable, Object object, SharedSessionContractImplementor session, boolean forceIdentifierBinding)
MutationOperationGroup	generateStaticOperationGroup()
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
MutationOperationGroup	getStaticMutationOperationGroup()	Deprecated.
protected static TableInclusionChecker	getTableInclusionChecker(InsertCoordinatorStandard.InsertValuesAnalysis insertValuesAnalysis)
GeneratedValues	insert(Object entity, Object[] values, SharedSessionContractImplementor session)
GeneratedValues	insert(Object entity, Object id, Object[] values, SharedSessionContractImplementor session)
CompletionStage<GeneratedValues>	reactiveInsert(Object entity, Object[] values, SharedSessionContractImplementor session)
CompletionStage<GeneratedValues>	reactiveInsert(Object entity, Object id, Object[] values, SharedSessionContractImplementor session)
protected BatchKeyAccess	resolveBatchKeyAccess(boolean dynamicUpdate, SharedSessionContractImplementor session)

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

applyKeyRestriction, bindPartitionColumnValueBindings, breakDownKeyJdbcValues, 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 Detail

ReactiveInsertCoordinatorStandard

public ReactiveInsertCoordinatorStandard(AbstractEntityPersister entityPersister,
                                         SessionFactoryImplementor factory)

Method Detail

insert

public GeneratedValues insert(Object entity,
                              Object[] values,
                              SharedSessionContractImplementor session)

Specified by:

insert in interface InsertCoordinator

insert

public GeneratedValues insert(Object entity,
                              Object id,
                              Object[] values,
                              SharedSessionContractImplementor session)

Specified by:

insert in interface InsertCoordinator

reactiveInsert

public CompletionStage<GeneratedValues> reactiveInsert(Object entity,
                                                       Object[] values,
                                                       SharedSessionContractImplementor session)

Specified by:

reactiveInsert in interface ReactiveInsertCoordinator

reactiveInsert

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

Specified by:

reactiveInsert in interface ReactiveInsertCoordinator

coordinateReactiveInsert

public CompletionStage<GeneratedValues> coordinateReactiveInsert(Object entity,
                                                                 Object id,
                                                                 Object[] values,
                                                                 SharedSessionContractImplementor session,
                                                                 boolean isIdentityInsert)

decomposeForReactiveInsert

protected CompletionStage<Void> decomposeForReactiveInsert(MutationExecutor mutationExecutor,
                                                           Object id,
                                                           Object[] values,
                                                           MutationOperationGroup mutationGroup,
                                                           boolean[] propertyInclusions,
                                                           TableInclusionChecker tableInclusionChecker,
                                                           SharedSessionContractImplementor session)

doDynamicInserts

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

doStaticInserts

protected CompletionStage<GeneratedValues> doStaticInserts(Object id,
                                                           Object[] values,
                                                           Object object,
                                                           SharedSessionContractImplementor session,
                                                           boolean isIdentityInsert)

getTableInclusionChecker

protected static TableInclusionChecker getTableInclusionChecker(InsertCoordinatorStandard.InsertValuesAnalysis insertValuesAnalysis)

resolveBatchKeyAccess

protected BatchKeyAccess resolveBatchKeyAccess(boolean dynamicUpdate,
                                               SharedSessionContractImplementor session)

Overrides:

resolveBatchKeyAccess in class AbstractMutationCoordinator

getBatchKey

public BasicBatchKey getBatchKey()

Specified by:

getBatchKey in class AbstractMutationCoordinator

getStaticMutationOperationGroup

@Deprecated
public MutationOperationGroup getStaticMutationOperationGroup()

Deprecated.

Specified by:

getStaticMutationOperationGroup in interface MutationCoordinator

decomposeAttribute

protected void decomposeAttribute(Object value,
                                  SharedSessionContractImplementor session,
                                  JdbcValueBindings jdbcValueBindings,
                                  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 MutationOperationGroup generateDynamicInsertSqlGroup(boolean[] insertable,
                                                               Object object,
                                                               SharedSessionContractImplementor session,
                                                               boolean forceIdentifierBinding)

generateStaticOperationGroup

public MutationOperationGroup generateStaticOperationGroup()

breakDownJdbcValue

protected void breakDownJdbcValue(Object id,
                                  SharedSessionContractImplementor session,
                                  JdbcValueBindings jdbcValueBindings,
                                  EntityTableMapping tableDetails)