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<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<Long> updateReturning(String sql, Object[] paramValues)
CompletionStage<ReactiveConnection.Result> select(String sql)
CompletionStage<ReactiveConnection.Result> select(String sql, Object[] paramValues)
CompletionStage<ResultSet> selectJdbc(String sql, Object[] paramValues)
CompletionStage<Long> selectLong(String sql, Object[] paramValues)
CompletionStage<Void> beginTransaction()
CompletionStage<Void> commitTransaction()
CompletionStage<Void> rollbackTransaction()
CompletionStage<Void> executeBatch()
void close()