public interface ReactiveConnection
CompletionStage
.
It is illegal to perform two non-blocking operations concurrently
with a single ReactiveConnection
. Instead, the second
operation must be chained on completion of the first operation.
This restriction might be relaxed in future, and is due to the
implementation of the ProxyConnection
returned by
SqlClientPool.getProxyConnection()
.
ReactiveConnectionPool
Modifier and Type | Interface and Description |
---|---|
static interface |
ReactiveConnection.Expectation |
static interface |
ReactiveConnection.Result |
CompletionStage<Void> execute(String sql)
CompletionStage<Void> executeOutsideTransaction(String sql)
CompletionStage<Void> executeUnprepared(String sql)
CompletionStage<Integer> update(String sql)
CompletionStage<Integer> update(String sql, Object[] paramValues)
CompletionStage<Void> update(String sql, Object[] paramValues, boolean allowBatching, ReactiveConnection.Expectation expectation)
CompletionStage<int[]> update(String sql, List<Object[]> paramValues)
CompletionStage<ReactiveConnection.Result> select(String sql)
CompletionStage<ReactiveConnection.Result> select(String sql, Object[] paramValues)
CompletionStage<ResultSet> selectJdbc(String sql, Object[] paramValues)
CompletionStage<ResultSet> selectJdbcOutsideTransaction(String sql, Object[] paramValues)
sql
- - the query to execute outside of a transactionparamValues
- - a non-null array of parameter valuesCompletionStage<Long> insertAndSelectIdentifier(String sql, Object[] paramValues)
CompletionStage<Long> selectIdentifier(String sql, Object[] paramValues)
CompletionStage<Void> beginTransaction()
CompletionStage<Void> commitTransaction()
CompletionStage<Void> rollbackTransaction()
ReactiveConnection withBatchSize(int batchSize)
CompletionStage<Void> executeBatch()
CompletionStage<Void> close()
Copyright © 2020-2022 Red Hat, Inc. All Rights Reserved.