Class ReactiveTableBasedInsertHandler
java.lang.Object
org.hibernate.query.sqm.mutation.internal.AbstractMutationHandler
org.hibernate.query.sqm.mutation.internal.temptable.TableBasedInsertHandler
org.hibernate.reactive.query.sqm.mutation.internal.temptable.ReactiveTableBasedInsertHandler
- All Implemented Interfaces:
org.hibernate.query.sqm.mutation.internal.Handler,org.hibernate.query.sqm.mutation.internal.InsertHandler,org.hibernate.query.sqm.mutation.spi.MultiTableHandler,ReactiveHandler
public class ReactiveTableBasedInsertHandler
extends org.hibernate.query.sqm.mutation.internal.temptable.TableBasedInsertHandler
implements ReactiveHandler
-
Nested Class Summary
Nested classes/interfaces inherited from class org.hibernate.query.sqm.mutation.internal.temptable.TableBasedInsertHandler
org.hibernate.query.sqm.mutation.internal.temptable.TableBasedInsertHandler.RootTableInserter -
Constructor Summary
ConstructorsConstructorDescriptionReactiveTableBasedInsertHandler(org.hibernate.query.sqm.tree.insert.SqmInsertStatement<?> sqmInsert, org.hibernate.query.sqm.internal.DomainParameterXref domainParameterXref, org.hibernate.dialect.temptable.TemporaryTable entityTable, org.hibernate.dialect.temptable.TemporaryTableStrategy temporaryTableStrategy, boolean forceDropAfterUse, Function<org.hibernate.engine.spi.SharedSessionContractImplementor, String> sessionUidAccess, org.hibernate.query.spi.DomainQueryExecutionContext context, org.hibernate.internal.util.MutableObject<org.hibernate.sql.exec.spi.JdbcParameterBindings> firstJdbcParameterBindingsConsumer) -
Method Summary
Modifier and TypeMethodDescriptionreactiveExecute(org.hibernate.sql.exec.spi.JdbcParameterBindings jdbcParameterBindings, org.hibernate.query.spi.DomainQueryExecutionContext context) Execute the multi-table update or delete indicated by the SQM AST passed in when this Handler was created.Methods inherited from class org.hibernate.query.sqm.mutation.internal.temptable.TableBasedInsertHandler
createJdbcParameterBindings, dependsOnParameterBindings, execute, getAfterUseAction, getEntityTable, getNonRootTableInserts, getRootTableInserter, getSessionUidAccess, getSessionUidParameter, getSqmInsertStatement, getTemporaryTableInsert, getTemporaryTableStrategy, isCompatibleWithMethods inherited from class org.hibernate.query.sqm.mutation.internal.AbstractMutationHandler
getEntityDescriptor, getSessionFactory, getSqmStatementMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface org.hibernate.query.sqm.mutation.internal.Handler
dependsOnParameterBindings, isCompatibleWithMethods inherited from interface org.hibernate.query.sqm.mutation.spi.MultiTableHandler
createJdbcParameterBindingsMethods inherited from interface org.hibernate.reactive.query.sqm.mutation.internal.ReactiveHandler
execute, execute, reactiveExecute
-
Constructor Details
-
ReactiveTableBasedInsertHandler
public ReactiveTableBasedInsertHandler(org.hibernate.query.sqm.tree.insert.SqmInsertStatement<?> sqmInsert, org.hibernate.query.sqm.internal.DomainParameterXref domainParameterXref, org.hibernate.dialect.temptable.TemporaryTable entityTable, org.hibernate.dialect.temptable.TemporaryTableStrategy temporaryTableStrategy, boolean forceDropAfterUse, Function<org.hibernate.engine.spi.SharedSessionContractImplementor, String> sessionUidAccess, org.hibernate.query.spi.DomainQueryExecutionContext context, org.hibernate.internal.util.MutableObject<org.hibernate.sql.exec.spi.JdbcParameterBindings> firstJdbcParameterBindingsConsumer)
-
-
Method Details
-
reactiveExecute
public CompletionStage<Integer> reactiveExecute(org.hibernate.sql.exec.spi.JdbcParameterBindings jdbcParameterBindings, org.hibernate.query.spi.DomainQueryExecutionContext context) Description copied from interface:ReactiveHandlerExecute the multi-table update or delete indicated by the SQM AST passed in when this Handler was created.- Specified by:
reactiveExecutein interfaceReactiveHandler- Parameters:
jdbcParameterBindings- The parameter bindings for JDBC parameterscontext- Contextual information needed for execution- Returns:
- The "number of rows affected" count
-