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