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
-
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
-
-
-
-
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 classInsertCoordinator
-
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 classInsertCoordinator
-
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 classInsertCoordinator
-
doStaticInserts
protected CompletionStage<Object> doStaticInserts(Object id, Object[] values, Object object, SharedSessionContractImplementor session)
- Overrides:
doStaticInserts
in classInsertCoordinator
-
-