Package org.hibernate.reactive.pool

Class BatchingConnection

java.lang.Object

org.hibernate.reactive.pool.BatchingConnection

All Implemented Interfaces:

ReactiveConnection

public class BatchingConnection
extends Object
implements ReactiveConnection

A 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 JdbcCoordinator and the Batch interface. However, the model used there is not easily adaptable to the reactive paradigm.

Nested Class Summary

Nested classes/interfaces inherited from interface org.hibernate.reactive.pool.ReactiveConnection

ReactiveConnection.Expectation, ReactiveConnection.Result

Constructor Summary

Constructors

Constructor	Description
BatchingConnection(ReactiveConnection delegate, int batchSize)

Method Summary

Modifier and Type	Method	Description
CompletionStage<Void>	beginTransaction()
CompletionStage<Void>	close()
CompletionStage<Void>	commitTransaction()
CompletionStage<Void>	execute(String sql)
CompletionStage<Void>	executeBatch()
CompletionStage<Void>	executeOutsideTransaction(String sql)
CompletionStage<Void>	executeUnprepared(String sql)	Run sql as statement (instead of preparedStatement)
io.vertx.sqlclient.spi.DatabaseMetadata	getDatabaseMetadata()
<T> CompletionStage<T>	insertAndSelectIdentifier(String sql, Object[] paramValues, Class<T> idClass, String idColumnName)
CompletionStage<ResultSet>	insertAndSelectIdentifierAsResultSet(String sql, Object[] paramValues, Class<?> idClass, String idColumnName)
CompletionStage<Void>	rollbackTransaction()
CompletionStage<ReactiveConnection.Result>	select(String sql)
CompletionStage<ReactiveConnection.Result>	select(String sql, Object[] paramValues)
<T> CompletionStage<T>	selectIdentifier(String sql, Object[] paramValues, Class<T> idClass)
CompletionStage<ResultSet>	selectJdbc(String sql, Object[] paramValues)
CompletionStage<ResultSet>	selectJdbcOutsideTransaction(String sql, Object[] paramValues)	This method is intended to be used only for queries returning a ResultSet that must be executed outside of any "current" transaction (i.e with autocommit=true).
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)
ReactiveConnection	withBatchSize(int batchSize)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

BatchingConnection

public BatchingConnection(ReactiveConnection delegate,
                          int batchSize)

Method Detail

getDatabaseMetadata

public io.vertx.sqlclient.spi.DatabaseMetadata getDatabaseMetadata()

Specified by:

getDatabaseMetadata in interface ReactiveConnection

withBatchSize

public ReactiveConnection withBatchSize(int batchSize)

Specified by:

withBatchSize in interface ReactiveConnection

executeBatch

public CompletionStage<Void> executeBatch()

Specified by:

executeBatch in interface ReactiveConnection

update

public CompletionStage<Void> update(String sql,
                                    Object[] paramValues,
                                    boolean allowBatching,
                                    ReactiveConnection.Expectation expectation)

Specified by:

update in interface ReactiveConnection

execute

public CompletionStage<Void> execute(String sql)

Specified by:

execute in interface ReactiveConnection

executeUnprepared

public CompletionStage<Void> executeUnprepared(String sql)

Description copied from interface: ReactiveConnection

Run sql as statement (instead of preparedStatement)

Specified by:

executeUnprepared in interface ReactiveConnection

executeOutsideTransaction

public CompletionStage<Void> executeOutsideTransaction(String sql)

Specified by:

executeOutsideTransaction in interface ReactiveConnection

update

public CompletionStage<Integer> update(String sql)

Specified by:

update in interface ReactiveConnection

update

public CompletionStage<Integer> update(String sql,
                                       Object[] paramValues)

Specified by:

update in interface ReactiveConnection

update

public CompletionStage<int[]> update(String sql,
                                     List<Object[]> paramValues)

Specified by:

update in interface ReactiveConnection

insertAndSelectIdentifier

public <T> CompletionStage<T> insertAndSelectIdentifier(String sql,
                                                        Object[] paramValues,
                                                        Class<T> idClass,
                                                        String idColumnName)

Specified by:

insertAndSelectIdentifier in interface ReactiveConnection

insertAndSelectIdentifierAsResultSet

public CompletionStage<ResultSet> insertAndSelectIdentifierAsResultSet(String sql,
                                                                       Object[] paramValues,
                                                                       Class<?> idClass,
                                                                       String idColumnName)

Specified by:

insertAndSelectIdentifierAsResultSet in interface ReactiveConnection

select

public CompletionStage<ReactiveConnection.Result> select(String sql)

Specified by:

select in interface ReactiveConnection

select

public CompletionStage<ReactiveConnection.Result> select(String sql,
                                                         Object[] paramValues)

Specified by:

select in interface ReactiveConnection

selectJdbc

public CompletionStage<ResultSet> selectJdbc(String sql,
                                             Object[] paramValues)

Specified by:

selectJdbc in interface ReactiveConnection

selectJdbcOutsideTransaction

public CompletionStage<ResultSet> selectJdbcOutsideTransaction(String sql,
                                                               Object[] paramValues)

Description copied from interface: ReactiveConnection

This method is intended to be used only for queries returning a ResultSet that must be executed outside of any "current" transaction (i.e with autocommit=true).

For example, it would be appropriate to use this method when performing queries on information_schema or system tables in order to obtain metadata information about catalogs, schemas, tables, etc.

Specified by:

selectJdbcOutsideTransaction in interface ReactiveConnection

Parameters:

sql - - the query to execute outside of a transaction

paramValues - - a non-null array of parameter values

Returns:

the CompletionStage from executing the query.

selectIdentifier

public <T> CompletionStage<T> selectIdentifier(String sql,
                                               Object[] paramValues,
                                               Class<T> idClass)

Specified by:

selectIdentifier in interface ReactiveConnection

beginTransaction

public CompletionStage<Void> beginTransaction()

Specified by:

beginTransaction in interface ReactiveConnection

commitTransaction

public CompletionStage<Void> commitTransaction()

Specified by:

commitTransaction in interface ReactiveConnection

rollbackTransaction

public CompletionStage<Void> rollbackTransaction()

Specified by:

rollbackTransaction in interface ReactiveConnection

close

public CompletionStage<Void> close()

Specified by:

close in interface ReactiveConnection