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 |
---|---|
void |
begin()
Begin a transaction and returns a
Transaction for controlling and tracking
this transaction. |
void |
begin(Handler<AsyncResult<Transaction>> handler)
Begin a transaction and returns a
Transaction for controlling and tracking
this transaction. |
void |
close()
Close the current connection after all the pending commands have been processed.
|
void |
close(Handler<AsyncResult<Void>> handler)
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) |
SqlConnection |
prepare(String sql)
Create a prepared statement using the given
sql string. |
SqlConnection |
prepare(String sql,
Handler<AsyncResult<PreparedStatement>> handler)
Create a prepared statement using the given
sql string. |
SqlConnection |
prepare(String sql,
PrepareOptions options)
Create a prepared statement using the given
sql string. |
SqlConnection |
prepare(String sql,
PrepareOptions options,
Handler<AsyncResult<PreparedStatement>> handler)
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, 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 SqlConnection prepare(String sql, Handler<AsyncResult<PreparedStatement>> handler)
sql
string.sql
- the sqlhandler
- the handler notified with the prepared query asynchronouslypublic SqlConnection prepare(String sql)
sql
string.sql
- the sqlpublic Single<PreparedStatement> rxPrepare(String sql)
sql
string.sql
- the sqlpublic SqlConnection prepare(String sql, PrepareOptions options, Handler<AsyncResult<PreparedStatement>> handler)
sql
string.sql
- the sqloptions
- handler
- the handler notified with the prepared query asynchronouslypublic SqlConnection 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 void begin(Handler<AsyncResult<Transaction>> handler)
Transaction
for controlling and tracking
this transaction.
When the connection is explicitely closed, any inflight transaction is rollbacked.handler
- public void 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 void close(Handler<AsyncResult<Void>> handler)
public void close()
public Completable rxClose()
public DatabaseMetadata databaseMetadata()
public static SqlConnection newInstance(SqlConnection arg)
Copyright © 2023 Eclipse. All rights reserved.