io.reactiverse.reactivex.pgclient

Class PgPool

java.lang.Object

io.reactiverse.reactivex.pgclient.PgClient

io.reactiverse.reactivex.pgclient.PgPool

public class PgPool
extends PgClient

A pool of connection.

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<PgPool>	__TYPE_ARG

Constructor Summary

Constructors

Constructor and Description
PgPool(PgPool delegate)

Method Summary

Modifier and Type	Method and Description
void	begin(io.vertx.core.Handler<io.vertx.core.AsyncResult<PgTransaction>> handler) Borrow a connection from the pool and begin a transaction, the underlying connection will be returned to the pool when the transaction ends.
void	close() Close the pool and release the associated resources.
boolean	equals(Object o)
void	getConnection(io.vertx.core.Handler<io.vertx.core.AsyncResult<PgConnection>> handler) Get a connection from the pool.
PgPool	getDelegate()
int	hashCode()
static PgPool	newInstance(PgPool arg)
PgPool	preparedBatch(String sql, List<Tuple> batch, io.vertx.core.Handler<io.vertx.core.AsyncResult<PgRowSet>> handler) Prepare and execute a createBatch.
PgPool	preparedQuery(String sql, io.vertx.core.Handler<io.vertx.core.AsyncResult<PgRowSet>> handler) Prepare and execute a query.
PgPool	preparedQuery(String sql, Tuple arguments, io.vertx.core.Handler<io.vertx.core.AsyncResult<PgRowSet>> handler) Prepare and execute a query.
PgPool	query(String sql, io.vertx.core.Handler<io.vertx.core.AsyncResult<PgRowSet>> handler) Execute a simple query.
Single<PgTransaction>	rxBegin() Borrow a connection from the pool and begin a transaction, the underlying connection will be returned to the pool when the transaction ends.
Single<PgConnection>	rxGetConnection() Get a connection from the pool.
Single<PgRowSet>	rxPreparedBatch(String sql, List<Tuple> batch) Prepare and execute a createBatch.
Single<PgRowSet>	rxPreparedQuery(String sql) Prepare and execute a query.
Single<PgRowSet>	rxPreparedQuery(String sql, Tuple arguments) Prepare and execute a query.
Single<PgRowSet>	rxQuery(String sql) Execute a simple query.
String	toString()

Methods inherited from class io.reactiverse.reactivex.pgclient.PgClient

connect, connect, connect, newInstance, pool, pool, pool, pool, pool, pool, rxConnect, rxConnect, rxConnect

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<PgPool> __TYPE_ARG

Constructor Detail

PgPool

public PgPool(PgPool delegate)

Method Detail

toString

public String toString()

Overrides:

toString in class PgClient

equals

public boolean equals(Object o)

Overrides:

equals in class PgClient

hashCode

public int hashCode()

Overrides:

hashCode in class PgClient

getDelegate

public PgPool getDelegate()

Overrides:

getDelegate in class PgClient

preparedQuery

public PgPool preparedQuery(String sql,
                            io.vertx.core.Handler<io.vertx.core.AsyncResult<PgRowSet>> handler)

Description copied from class: PgClient

Prepare and execute a query.

Overrides:

preparedQuery in class PgClient

Parameters:

sql - the prepared query SQL

handler - the handler notified with the execution result

Returns:

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

rxPreparedQuery

public Single<PgRowSet> rxPreparedQuery(String sql)

Description copied from class: PgClient

Prepare and execute a query.

Overrides:

rxPreparedQuery in class PgClient

Parameters:

sql - the prepared query SQL

Returns:

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

query

public PgPool query(String sql,
                    io.vertx.core.Handler<io.vertx.core.AsyncResult<PgRowSet>> handler)

Description copied from class: PgClient

Execute a simple query.

Overrides:

query in class PgClient

Parameters:

sql - the query SQL

handler - the handler notified with the execution result

Returns:

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

rxQuery

public Single<PgRowSet> rxQuery(String sql)

Description copied from class: PgClient

Execute a simple query.

Overrides:

rxQuery in class PgClient

Parameters:

sql - the query SQL

Returns:

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

preparedQuery

public PgPool preparedQuery(String sql,
                            Tuple arguments,
                            io.vertx.core.Handler<io.vertx.core.AsyncResult<PgRowSet>> handler)

Description copied from class: PgClient

Prepare and execute a query.

Overrides:

preparedQuery in class PgClient

Parameters:

sql - the prepared query SQL

arguments - the list of arguments

handler - the handler notified with the execution result

Returns:

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

rxPreparedQuery

public Single<PgRowSet> rxPreparedQuery(String sql,
                                        Tuple arguments)

Description copied from class: PgClient

Prepare and execute a query.

Overrides:

rxPreparedQuery in class PgClient

Parameters:

sql - the prepared query SQL

arguments - the list of arguments

Returns:

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

preparedBatch

public PgPool preparedBatch(String sql,
                            List<Tuple> batch,
                            io.vertx.core.Handler<io.vertx.core.AsyncResult<PgRowSet>> handler)

Description copied from class: PgClient

Prepare and execute a createBatch.

Overrides:

preparedBatch in class PgClient

Parameters:

sql - the prepared query SQL

batch - the batch of tuples

handler - the handler notified with the execution result

Returns:

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

rxPreparedBatch

public Single<PgRowSet> rxPreparedBatch(String sql,
                                        List<Tuple> batch)

Description copied from class: PgClient

Prepare and execute a createBatch.

Overrides:

rxPreparedBatch in class PgClient

Parameters:

sql - the prepared query SQL

batch - the batch of tuples

Returns:

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

getConnection

public void getConnection(io.vertx.core.Handler<io.vertx.core.AsyncResult<PgConnection>> handler)

Get a connection from the pool.

Parameters:

handler - the handler that will get the connection result

rxGetConnection

public Single<PgConnection> rxGetConnection()

Get a connection from the pool.

Returns:

begin

public void begin(io.vertx.core.Handler<io.vertx.core.AsyncResult<PgTransaction>> handler)

Borrow a connection from the pool and begin a transaction, the underlying connection will be returned to the pool when the transaction ends.

Parameters:

handler -

rxBegin

public Single<PgTransaction> rxBegin()

Borrow a connection from the pool and begin a transaction, the underlying connection will be returned to the pool when the transaction ends.

Returns:

the transaction

close

public void close()

Close the pool and release the associated resources.

newInstance

public static PgPool newInstance(PgPool arg)