Modifier and Type | Field and Description |
---|---|
static io.vertx.lang.rx.TypeArg<PgPool> |
__TYPE_ARG |
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() |
public static final io.vertx.lang.rx.TypeArg<PgPool> __TYPE_ARG
public PgPool(PgPool delegate)
public PgPool getDelegate()
getDelegate
in class PgClient
public PgPool preparedQuery(String sql, io.vertx.core.Handler<io.vertx.core.AsyncResult<PgRowSet>> handler)
PgClient
preparedQuery
in class PgClient
sql
- the prepared query SQLhandler
- the handler notified with the execution resultpublic Single<PgRowSet> rxPreparedQuery(String sql)
PgClient
rxPreparedQuery
in class PgClient
sql
- the prepared query SQLpublic PgPool query(String sql, io.vertx.core.Handler<io.vertx.core.AsyncResult<PgRowSet>> handler)
PgClient
public Single<PgRowSet> rxQuery(String sql)
PgClient
public PgPool preparedQuery(String sql, Tuple arguments, io.vertx.core.Handler<io.vertx.core.AsyncResult<PgRowSet>> handler)
PgClient
preparedQuery
in class PgClient
sql
- the prepared query SQLarguments
- the list of argumentshandler
- the handler notified with the execution resultpublic Single<PgRowSet> rxPreparedQuery(String sql, Tuple arguments)
PgClient
rxPreparedQuery
in class PgClient
sql
- the prepared query SQLarguments
- the list of argumentspublic PgPool preparedBatch(String sql, List<Tuple> batch, io.vertx.core.Handler<io.vertx.core.AsyncResult<PgRowSet>> handler)
PgClient
preparedBatch
in class PgClient
sql
- the prepared query SQLbatch
- the batch of tupleshandler
- the handler notified with the execution resultpublic Single<PgRowSet> rxPreparedBatch(String sql, List<Tuple> batch)
PgClient
rxPreparedBatch
in class PgClient
sql
- the prepared query SQLbatch
- the batch of tuplespublic void getConnection(io.vertx.core.Handler<io.vertx.core.AsyncResult<PgConnection>> handler)
handler
- the handler that will get the connection resultpublic Single<PgConnection> rxGetConnection()
public void begin(io.vertx.core.Handler<io.vertx.core.AsyncResult<PgTransaction>> handler)
handler
- public Single<PgTransaction> rxBegin()
public void close()
Copyright © 2019 Eclipse. All rights reserved.