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

Class ReactiveInsertCoordinator

java.lang.Object

org.hibernate.persister.entity.mutation.AbstractMutationCoordinator

org.hibernate.persister.entity.mutation.InsertCoordinator

org.hibernate.reactive.persister.entity.mutation.ReactiveInsertCoordinator

@Internal
public class ReactiveInsertCoordinator
extends InsertCoordinator

Nested Class Summary

Nested classes/interfaces inherited from class org.hibernate.persister.entity.mutation.InsertCoordinator

InsertCoordinator.InsertValuesAnalysis

Field Summary

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

dialect, entityPersister, factory, mutationExecutorService

Constructor Summary

Constructors

Constructor	Description
ReactiveInsertCoordinator(AbstractEntityPersister entityPersister, SessionFactoryImplementor factory)

Method Summary

Modifier and Type	Method	Description
Object	coordinateInsert(Object id, Object[] values, Object entity, SharedSessionContractImplementor session)
CompletionStage<Object>	coordinateReactiveInsert(Object id, Object[] currentValues, Object entity, SharedSessionContractImplementor session)
protected void	decomposeForInsert(MutationExecutor mutationExecutor, Object id, Object[] values, MutationOperationGroup mutationGroup, boolean[] propertyInclusions, TableInclusionChecker tableInclusionChecker, SharedSessionContractImplementor session)
protected CompletionStage<Void>	decomposeForReactiveInsert(MutationExecutor mutationExecutor, Object id, Object[] values, MutationOperationGroup mutationGroup, boolean[] propertyInclusions, TableInclusionChecker tableInclusionChecker, SharedSessionContractImplementor session)
protected CompletionStage<Object>	doDynamicInserts(Object id, Object[] values, Object object, SharedSessionContractImplementor session)
protected CompletionStage<Object>	doStaticInserts(Object id, Object[] values, Object object, SharedSessionContractImplementor session)

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

breakDownJdbcValue, decomposeAttribute, generateDynamicInsertSqlGroup, generateStaticOperationGroup, getBatchKey, getInsertBatchKey, getPropertiesToInsert, getStaticInsertGroup, getTableInclusionChecker, preInsertInMemoryValueGeneration

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

bindPartitionColumnValueBindings, createOperationGroup, dialect, entityPersister, factory, resolveBatchKeyAccess

Methods inherited from class java.lang.Object

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

Constructor Detail

ReactiveInsertCoordinator

public ReactiveInsertCoordinator(AbstractEntityPersister entityPersister,
                                 SessionFactoryImplementor factory)

Method Detail

coordinateInsert

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

Overrides:

coordinateInsert in class InsertCoordinator

coordinateReactiveInsert

public CompletionStage<Object> coordinateReactiveInsert(Object id,
                                                        Object[] currentValues,
                                                        Object entity,
                                                        SharedSessionContractImplementor session)

decomposeForInsert

protected void decomposeForInsert(MutationExecutor mutationExecutor,
                                  Object id,
                                  Object[] values,
                                  MutationOperationGroup mutationGroup,
                                  boolean[] propertyInclusions,
                                  TableInclusionChecker tableInclusionChecker,
                                  SharedSessionContractImplementor session)

Overrides:

decomposeForInsert in class InsertCoordinator

decomposeForReactiveInsert

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

doDynamicInserts

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

Overrides:

doDynamicInserts in class InsertCoordinator

doStaticInserts

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

Overrides:

doStaticInserts in class InsertCoordinator