Package org.hibernate.reactive.sql.exec.spi

Interface ReactiveSelectExecutor

public interface ReactiveSelectExecutor

See Also:

• JdbcSelectExecutor

Method Summary

Modifier and Type	Method	Description
default <T, R> CompletionStage<T>	executeQuery(JdbcOperationQuerySelect jdbcSelect, JdbcParameterBindings jdbcParameterBindings, ExecutionContext executionContext, RowTransformer<R> rowTransformer, Class<R> domainResultType, int resultCountEstimate, ReactiveResultsConsumer<T,R> resultsConsumer)
<T, R> CompletionStage<T>	executeQuery(JdbcOperationQuerySelect jdbcSelect, JdbcParameterBindings jdbcParameterBindings, ExecutionContext executionContext, RowTransformer<R> rowTransformer, Class<R> domainResultType, int resultCountEstimate, JdbcSelectExecutor.StatementCreator statementCreator, ReactiveResultsConsumer<T,R> resultsConsumer)
<R> CompletionStage<List<R>>	list(JdbcOperationQuerySelect jdbcSelect, JdbcParameterBindings jdbcParameterBindings, ExecutionContext executionContext, RowTransformer<R> rowTransformer, Class<R> domainResultType, ReactiveListResultsConsumer.UniqueSemantic uniqueSemantic)

Method Details

executeQuery

default <T,
R> CompletionStage<T> executeQuery(JdbcOperationQuerySelect jdbcSelect,
 JdbcParameterBindings jdbcParameterBindings,
 ExecutionContext executionContext,
 RowTransformer<R> rowTransformer,
 Class<R> domainResultType,
 int resultCountEstimate,
 ReactiveResultsConsumer<T,R> resultsConsumer)

Since:

2.4 (and Hibernate ORM 6.6)

executeQuery

<T,
R> CompletionStage<T> executeQuery(JdbcOperationQuerySelect jdbcSelect,
 JdbcParameterBindings jdbcParameterBindings,
 ExecutionContext executionContext,
 RowTransformer<R> rowTransformer,
 Class<R> domainResultType,
 int resultCountEstimate,
 JdbcSelectExecutor.StatementCreator statementCreator,
 ReactiveResultsConsumer<T,R> resultsConsumer)

list

<R> CompletionStage<List<R>> list(JdbcOperationQuerySelect jdbcSelect,
 JdbcParameterBindings jdbcParameterBindings,
 ExecutionContext executionContext,
 RowTransformer<R> rowTransformer,
 Class<R> domainResultType,
 ReactiveListResultsConsumer.UniqueSemantic uniqueSemantic)