Package org.hibernate.reactive.pool.impl

Class SqlClientConnection

java.lang.Object

org.hibernate.reactive.pool.impl.SqlClientConnection

All Implemented Interfaces:

ReactiveConnection

public class SqlClientConnection
extends Object
implements ReactiveConnection

A reactive connection based on Vert.x's SqlConnection.

Nested Class Summary

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

ReactiveConnection.Expectation, ReactiveConnection.Result

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, io.vertx.sqlclient.Tuple parameters, Class<T> idClass, String idColumnName)
<T> CompletionStage<T>	insertAndSelectIdentifier(String sql, Object[] paramValues, Class<T> idClass, String idColumnName)
CompletionStage<ResultSet>	insertAndSelectIdentifierAsResultSet(String sql, Object[] parameters, Class<?> idClass, String idColumnName)
CompletionStage<io.vertx.sqlclient.RowSet<io.vertx.sqlclient.Row>>	preparedQuery(String sql)
CompletionStage<io.vertx.sqlclient.RowSet<io.vertx.sqlclient.Row>>	preparedQuery(String sql, io.vertx.sqlclient.Tuple parameters)
CompletionStage<io.vertx.sqlclient.RowSet<io.vertx.sqlclient.Row>>	preparedQuery(String sql, io.vertx.sqlclient.Tuple parameters, io.vertx.sqlclient.PrepareOptions options)
CompletionStage<io.vertx.sqlclient.RowSet<io.vertx.sqlclient.Row>>	preparedQueryBatch(String sql, List<io.vertx.sqlclient.Tuple> parameters)
CompletionStage<io.vertx.sqlclient.RowSet<io.vertx.sqlclient.Row>>	preparedQueryOutsideTransaction(String sql)
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<Integer>	update(String sql)
CompletionStage<Integer>	update(String sql, io.vertx.sqlclient.Tuple parameters)
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[]> batchParamValues)
CompletionStage<int[]>	updateBatch(String sql, List<io.vertx.sqlclient.Tuple> parametersBatch)
ReactiveConnection	withBatchSize(int batchSize)

Methods inherited from class java.lang.Object

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

Method Details

getDatabaseMetadata

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

Specified by:

getDatabaseMetadata 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[]> batchParamValues)

Specified by:

update in interface ReactiveConnection

update

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

Specified by:

update in interface ReactiveConnection

selectIdentifier

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

Specified by:

selectIdentifier 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

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,
 io.vertx.sqlclient.Tuple parameters)

updateBatch

public CompletionStage<int[]> updateBatch(String sql,
 List<io.vertx.sqlclient.Tuple> parametersBatch)

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[] parameters,
 Class<?> idClass,
 String idColumnName)

Specified by:

insertAndSelectIdentifierAsResultSet in interface ReactiveConnection

insertAndSelectIdentifier

public <T> CompletionStage<T> insertAndSelectIdentifier(String sql,
 io.vertx.sqlclient.Tuple parameters,
 Class<T> idClass,
 String idColumnName)

preparedQuery

public CompletionStage<io.vertx.sqlclient.RowSet<io.vertx.sqlclient.Row>> preparedQuery(String sql,
 io.vertx.sqlclient.Tuple parameters)

preparedQuery

public CompletionStage<io.vertx.sqlclient.RowSet<io.vertx.sqlclient.Row>> preparedQuery(String sql,
 io.vertx.sqlclient.Tuple parameters,
 io.vertx.sqlclient.PrepareOptions options)

preparedQueryBatch

public CompletionStage<io.vertx.sqlclient.RowSet<io.vertx.sqlclient.Row>> preparedQueryBatch(String sql,
 List<io.vertx.sqlclient.Tuple> parameters)

preparedQuery

public CompletionStage<io.vertx.sqlclient.RowSet<io.vertx.sqlclient.Row>> preparedQuery(String sql)

preparedQueryOutsideTransaction

public CompletionStage<io.vertx.sqlclient.RowSet<io.vertx.sqlclient.Row>> preparedQueryOutsideTransaction(String sql)

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

withBatchSize

public ReactiveConnection withBatchSize(int batchSize)

Specified by:

withBatchSize in interface ReactiveConnection

executeBatch

public CompletionStage<Void> executeBatch()

Specified by:

executeBatch in interface ReactiveConnection