public class SqlConnection extends SqlClient
original
non RX-ified interface using Vert.x codegen.Modifier and Type | Field and Description |
---|---|
static TypeArg<SqlConnection> |
__TYPE_ARG |
Constructor and Description |
---|
SqlConnection(Object delegate) |
SqlConnection(io.vertx.sqlclient.SqlConnection delegate) |
Modifier and Type | Method and Description |
---|---|
io.reactivex.rxjava3.core.Single<Transaction> |
begin()
Begin a transaction and returns a
Transaction for controlling and tracking
this transaction. |
io.reactivex.rxjava3.core.Completable |
close()
Close the current connection after all the pending commands have been processed.
|
SqlConnection |
closeHandler(io.vertx.core.Handler<Void> handler)
Set an handler called when the connection is closed.
|
DatabaseMetadata |
databaseMetadata() |
boolean |
equals(Object o) |
SqlConnection |
exceptionHandler(io.vertx.core.Handler<Throwable> handler)
Set an handler called with connection errors.
|
io.vertx.sqlclient.SqlConnection |
getDelegate() |
int |
hashCode() |
boolean |
isSSL() |
static SqlConnection |
newInstance(io.vertx.sqlclient.SqlConnection arg) |
io.reactivex.rxjava3.core.Single<PreparedStatement> |
prepare(String sql)
Create a prepared statement using the given
sql string. |
io.reactivex.rxjava3.core.Single<Transaction> |
rxBegin()
Begin a transaction and returns a
Transaction for controlling and tracking
this transaction. |
io.reactivex.rxjava3.core.Completable |
rxClose()
Close the current connection after all the pending commands have been processed.
|
io.reactivex.rxjava3.core.Single<PreparedStatement> |
rxPrepare(String sql)
Create a prepared statement using the given
sql string. |
String |
toString() |
newInstance, preparedQuery, query
public static final TypeArg<SqlConnection> __TYPE_ARG
public SqlConnection(io.vertx.sqlclient.SqlConnection delegate)
public SqlConnection(Object delegate)
public io.vertx.sqlclient.SqlConnection getDelegate()
getDelegate
in class SqlClient
public io.reactivex.rxjava3.core.Single<PreparedStatement> prepare(String sql)
sql
string.sql
- the sqlpublic io.reactivex.rxjava3.core.Single<PreparedStatement> rxPrepare(String sql)
sql
string.sql
- the sqlpublic SqlConnection exceptionHandler(io.vertx.core.Handler<Throwable> handler)
handler
- the handlerpublic SqlConnection closeHandler(io.vertx.core.Handler<Void> handler)
handler
- the handlerpublic io.reactivex.rxjava3.core.Single<Transaction> begin()
Transaction
for controlling and tracking
this transaction.
When the connection is explicitely closed, any inflight transaction is rollbacked.public io.reactivex.rxjava3.core.Single<Transaction> rxBegin()
Transaction
for controlling and tracking
this transaction.
When the connection is explicitely closed, any inflight transaction is rollbacked.public boolean isSSL()
public io.reactivex.rxjava3.core.Completable close()
public io.reactivex.rxjava3.core.Completable rxClose()
public DatabaseMetadata databaseMetadata()
public static SqlConnection newInstance(io.vertx.sqlclient.SqlConnection arg)
Copyright © 2022 Eclipse. All rights reserved.