final class ProxyConnection extends Object implements ReactiveConnection
ReactiveConnection that initializes the underlying connection lazily.ReactiveConnection.Expectation, ReactiveConnection.Result| Constructor and Description |
|---|
ProxyConnection(ReactiveConnectionPool sqlClientPool) |
ProxyConnection(ReactiveConnectionPool sqlClientPool, String tenantId) |
public ProxyConnection(ReactiveConnectionPool sqlClientPool)
public ProxyConnection(ReactiveConnectionPool sqlClientPool, String tenantId)
public CompletionStage<Void> execute(String sql)
execute in interface ReactiveConnectionpublic CompletionStage<Void> executeOutsideTransaction(String sql)
executeOutsideTransaction in interface ReactiveConnectionpublic CompletionStage<Integer> update(String sql)
update in interface ReactiveConnectionpublic CompletionStage<Integer> update(String sql, Object[] paramValues)
update in interface ReactiveConnectionpublic CompletionStage<Void> update(String sql, Object[] paramValues, boolean allowBatching, ReactiveConnection.Expectation expectation)
update in interface ReactiveConnectionpublic CompletionStage<int[]> update(String sql, List<Object[]> paramValues)
update in interface ReactiveConnectionpublic CompletionStage<Long> updateReturning(String sql, Object[] paramValues)
updateReturning in interface ReactiveConnectionpublic CompletionStage<ReactiveConnection.Result> select(String sql)
select in interface ReactiveConnectionpublic CompletionStage<ReactiveConnection.Result> select(String sql, Object[] paramValues)
select in interface ReactiveConnectionpublic CompletionStage<ResultSet> selectJdbc(String sql, Object[] paramValues)
selectJdbc in interface ReactiveConnectionpublic CompletionStage<Long> selectLong(String sql, Object[] paramValues)
selectLong in interface ReactiveConnectionpublic CompletionStage<Void> beginTransaction()
beginTransaction in interface ReactiveConnectionpublic CompletionStage<Void> commitTransaction()
commitTransaction in interface ReactiveConnectionpublic CompletionStage<Void> rollbackTransaction()
rollbackTransaction in interface ReactiveConnectionpublic CompletionStage<Void> executeBatch()
executeBatch in interface ReactiveConnectionpublic void close()
close in interface ReactiveConnection