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<PreparedStatement> |
prepare(String sql,
PrepareOptions options)
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. |
Single<PreparedStatement> |
rxPrepare(String sql,
PrepareOptions options)
Create a prepared statement using the given
sql string. |
String |
toString() |
newInstance, preparedQuery, preparedQuery, querypublic static final io.vertx.lang.rx.TypeArg<SqlConnection> __TYPE_ARG
public SqlConnection(SqlConnection delegate)
public SqlConnection(Object delegate)
public SqlConnection getDelegate()
getDelegate in class SqlClientpublic Single<PreparedStatement> prepare(String sql)
sql string.sql - the sqlpublic Single<PreparedStatement> rxPrepare(String sql)
sql string.sql - the sqlpublic Single<PreparedStatement> prepare(String sql, PrepareOptions options)
sql string.sql - the sqloptions - public Single<PreparedStatement> rxPrepare(String sql, PrepareOptions options)
sql string.sql - the sqloptions - public 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 © 2022 Eclipse. All rights reserved.