public class BatchingConnection extends Object implements ReactiveConnection
ReactiveConnection that automatically performs batching of insert, update, and delete statements, relieving the client persister code of the responsibility to manage batching. Actual SQL statements are delegated to a given ReactiveConnection which only supports explicit batching using update(String, List). Note that in Hibernate core, the responsibilities of this class are handled by org.hibernate.engine.jdbc.spi.JdbcCoordinator and the org.hibernate.engine.jdbc.batch.spi.Batch interface. However, the model used there is not easily adaptable to the reactive paradigm.
ReactiveConnection.Expectation, ReactiveConnection.Result| Constructor and Description |
|---|
BatchingConnection(ReactiveConnection delegate, int batchSize) |
public BatchingConnection(ReactiveConnection delegate, int batchSize)
public CompletionStage<Void> executeBatch()
executeBatch in interface ReactiveConnectionpublic CompletionStage<Void> update(String sql, Object[] paramValues, boolean allowBatching, ReactiveConnection.Expectation expectation)
update in interface ReactiveConnectionpublic 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<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 void close()
close in interface ReactiveConnection