io.vertx.rxjava3.sqlclient

Class Pool

java.lang.Object

io.vertx.rxjava3.sqlclient.SqlClient

io.vertx.rxjava3.sqlclient.Pool

Direct Known Subclasses:

DB2Pool, JDBCPool, MSSQLPool, MySQLPool, OraclePool, PgPool

public class Pool
extends SqlClient

A connection pool which reuses a number of SQL connections.

NOTE: This class has been automatically generated from the original non RX-ified interface using Vert.x codegen.

Field Summary

Fields

Modifier and Type	Field and Description
static io.vertx.lang.rx.TypeArg<Pool>	__TYPE_ARG

Constructor Summary

Constructors

Constructor and Description
Pool(Object delegate)
Pool(Pool delegate)

Method Summary

Modifier and Type	Method and Description
Completable	close() Close the pool and release the associated resources.
Pool	connectHandler(Handler<SqlConnection> handler) Set an handler called when the pool has established a connection to the database.
Pool	connectionProvider(java.util.function.Function<Context,Single<SqlConnection>> provider) Replace the default pool connection provider, the new provider returns a future connection for a given .
boolean	equals(Object o)
Single<SqlConnection>	getConnection() Get a connection from the pool.
Pool	getDelegate()
int	hashCode()
static Pool	newInstance(Pool arg)
static Pool	pool(SqlConnectOptions connectOptions) Like pool(io.vertx.sqlclient.SqlConnectOptions) with default options.
static Pool	pool(SqlConnectOptions database, PoolOptions options) Like pool(io.vertx.sqlclient.SqlConnectOptions) with a Vert.x instance created automatically.
static Pool	pool(Vertx vertx, SqlConnectOptions database, PoolOptions options) Create a connection pool to the database with the given options.
PreparedQuery<RowSet<Row>>	preparedQuery(String sql) A connection is borrowed from the connection pool when the query is executed and then immediately returned to the pool after it completes.
Query<RowSet<Row>>	query(String sql) A connection is borrowed from the connection pool when the query is executed and then immediately returned to the pool after it completes.
Completable	rxClose() Close the pool and release the associated resources.
Single<SqlConnection>	rxGetConnection() Get a connection from the pool.
<T> Maybe<T>	rxWithConnection(java.util.function.Function<SqlConnection,Maybe<T>> function) Get a connection from the pool and execute the given function.
<T> Maybe<T>	rxWithTransaction(java.util.function.Function<SqlConnection,Maybe<T>> function) Execute the given function within a transaction.
<T> Maybe<T>	rxWithTransaction(TransactionPropagation txPropagation, java.util.function.Function<SqlConnection,Maybe<T>> function) Like withTransaction(java.util.function.Function<io.vertx.rxjava3.sqlclient.SqlConnection, io.reactivex.rxjava3.core.Maybe<T>>) but allows for setting the mode, defining how the acquired connection is managed during the execution of the function.
int	size()
String	toString()
<T> Maybe<T>	withConnection(java.util.function.Function<SqlConnection,Maybe<T>> function) Get a connection from the pool and execute the given function.
<T> Maybe<T>	withTransaction(java.util.function.Function<SqlConnection,Maybe<T>> function) Execute the given function within a transaction.
<T> Maybe<T>	withTransaction(TransactionPropagation txPropagation, java.util.function.Function<SqlConnection,Maybe<T>> function) Like withTransaction(java.util.function.Function<io.vertx.rxjava3.sqlclient.SqlConnection, io.reactivex.rxjava3.core.Maybe<T>>) but allows for setting the mode, defining how the acquired connection is managed during the execution of the function.

Methods inherited from class io.vertx.rxjava3.sqlclient.SqlClient

newInstance, preparedQuery

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

__TYPE_ARG

public static final io.vertx.lang.rx.TypeArg<Pool> __TYPE_ARG

Constructor Detail

Pool

public Pool(Pool delegate)

Pool

public Pool(Object delegate)

Method Detail

toString

public String toString()

Overrides:

toString in class SqlClient

equals

public boolean equals(Object o)

Overrides:

equals in class SqlClient

hashCode

public int hashCode()

Overrides:

hashCode in class SqlClient

getDelegate

public Pool getDelegate()

Overrides:

getDelegate in class SqlClient

pool

public static Pool pool(SqlConnectOptions connectOptions)

Like pool(io.vertx.sqlclient.SqlConnectOptions) with default options.

Parameters:

connectOptions -

Returns:

pool

public static Pool pool(SqlConnectOptions database,
                        PoolOptions options)

Like pool(io.vertx.sqlclient.SqlConnectOptions) with a Vert.x instance created automatically.

Parameters:

database -

options -

Returns:

pool

public static Pool pool(Vertx vertx,
                        SqlConnectOptions database,
                        PoolOptions options)

Create a connection pool to the database with the given options.

A will be selected among the drivers found on the classpath returning true when applied to the first options of the list.

Parameters:

vertx - the Vertx instance to be used with the connection pool

database - the options used to create the connection pool, such as database hostname

options - the options for creating the pool

Returns:

the connection pool

getConnection

public Single<SqlConnection> getConnection()

Get a connection from the pool.

Returns:

rxGetConnection

public Single<SqlConnection> rxGetConnection()

Get a connection from the pool.

Returns:

query

public Query<RowSet<Row>> query(String sql)

A connection is borrowed from the connection pool when the query is executed and then immediately returned to the pool after it completes.

Overrides:

query in class SqlClient

Parameters:

sql -

Returns:

preparedQuery

public PreparedQuery<RowSet<Row>> preparedQuery(String sql)

A connection is borrowed from the connection pool when the query is executed and then immediately returned to the pool after it completes.

Overrides:

preparedQuery in class SqlClient

Parameters:

sql -

Returns:

withTransaction

public <T> Maybe<T> withTransaction(java.util.function.Function<SqlConnection,Maybe<T>> function)

Execute the given function within a transaction.

The function is passed a client executing all operations within a transaction. When the future returned by the function

• succeeds the transaction commits
• fails the transaction rollbacks

The handler is given a success result when the function returns a succeeded futures and the transaction commits. Otherwise it is given a failure result.

Parameters:

function - the code to execute

Returns:

rxWithTransaction

public <T> Maybe<T> rxWithTransaction(java.util.function.Function<SqlConnection,Maybe<T>> function)

Execute the given function within a transaction.

The function is passed a client executing all operations within a transaction. When the future returned by the function

• succeeds the transaction commits
• fails the transaction rollbacks

The handler is given a success result when the function returns a succeeded futures and the transaction commits. Otherwise it is given a failure result.

Parameters:

function - the code to execute

Returns:

withTransaction

public <T> Maybe<T> withTransaction(TransactionPropagation txPropagation,
                                    java.util.function.Function<SqlConnection,Maybe<T>> function)

Like withTransaction(java.util.function.Function<io.vertx.rxjava3.sqlclient.SqlConnection, io.reactivex.rxjava3.core.Maybe<T>>) but allows for setting the mode, defining how the acquired connection is managed during the execution of the function.

Parameters:

txPropagation -

function -

Returns:

rxWithTransaction

public <T> Maybe<T> rxWithTransaction(TransactionPropagation txPropagation,
                                      java.util.function.Function<SqlConnection,Maybe<T>> function)

Like withTransaction(java.util.function.Function<io.vertx.rxjava3.sqlclient.SqlConnection, io.reactivex.rxjava3.core.Maybe<T>>) but allows for setting the mode, defining how the acquired connection is managed during the execution of the function.

Parameters:

txPropagation -

function -

Returns:

withConnection

public <T> Maybe<T> withConnection(java.util.function.Function<SqlConnection,Maybe<T>> function)

Get a connection from the pool and execute the given function.

When the future returned by the function completes, the connection is returned to the pool.

The handler is given a success result when the function returns a succeeded futures. Otherwise it is given a failure result.

Parameters:

function - the code to execute

Returns:

rxWithConnection

public <T> Maybe<T> rxWithConnection(java.util.function.Function<SqlConnection,Maybe<T>> function)

Get a connection from the pool and execute the given function.

When the future returned by the function completes, the connection is returned to the pool.

The handler is given a success result when the function returns a succeeded futures. Otherwise it is given a failure result.

Parameters:

function - the code to execute

Returns:

close

public Completable close()

Close the pool and release the associated resources.

Overrides:

close in class SqlClient

Returns:

rxClose

public Completable rxClose()

Close the pool and release the associated resources.

Overrides:

rxClose in class SqlClient

Returns:

connectHandler

public Pool connectHandler(Handler<SqlConnection> handler)

Set an handler called when the pool has established a connection to the database.

This handler allows interactions with the database before the connection is added to the pool.

When the handler has finished, it must call SqlClient.close() to release the connection to the pool.

Parameters:

handler - the handler

Returns:

a reference to this, so the API can be used fluently

connectionProvider

public Pool connectionProvider(java.util.function.Function<Context,Single<SqlConnection>> provider)

Replace the default pool connection provider, the new provider returns a future connection for a given .

A ConnectionFactory can be used as connection provider.

Parameters:

provider - the new connection provider

Returns:

a reference to this, so the API can be used fluently

size

public int size()

Returns:

the current pool size approximation

newInstance

public static Pool newInstance(Pool arg)