Package | Description |
---|---|
io.vertx.reactivex.ext.sql |
Modifier and Type | Field and Description |
---|---|
static io.vertx.lang.rx.TypeArg<SQLConnection> |
SQLConnection.__TYPE_ARG |
Modifier and Type | Method and Description |
---|---|
SQLConnection |
SQLConnection.batch(List<String> sqlStatements,
Handler<AsyncResult<List<Integer>>> handler)
Batch simple SQL strings and execute the batch where the async result contains a array of Integers.
|
SQLConnection |
SQLConnection.batchCallableWithParams(String sqlStatement,
List<JsonArray> inArgs,
List<JsonArray> outArgs,
Handler<AsyncResult<List<Integer>>> handler)
Batch a callable statement with all entries from the args list.
|
SQLConnection |
SQLConnection.batchWithParams(String sqlStatement,
List<JsonArray> args,
Handler<AsyncResult<List<Integer>>> handler)
Batch a prepared statement with all entries from the args list.
|
SQLConnection |
SQLConnection.call(String sql,
Handler<AsyncResult<ResultSet>> resultHandler)
Calls the given SQL
PROCEDURE which returns the result from the procedure. |
SQLConnection |
SQLConnection.callWithParams(String sql,
JsonArray params,
JsonArray outputs,
Handler<AsyncResult<ResultSet>> resultHandler)
Calls the given SQL
PROCEDURE which returns the result from the procedure. |
SQLConnection |
SQLConnection.commit(Handler<AsyncResult<Void>> handler)
Commits all changes made since the previous commit/rollback.
|
SQLConnection |
SQLConnection.execute(String sql,
Handler<AsyncResult<Void>> resultHandler)
Executes the given SQL statement
|
SQLConnection |
SQLConnection.getTransactionIsolation(Handler<AsyncResult<TransactionIsolation>> handler)
Attempts to return the transaction isolation level for this Connection object to the one given.
|
static SQLConnection |
SQLConnection.newInstance(SQLConnection arg) |
SQLConnection |
SQLConnection.query(String sql,
Handler<AsyncResult<ResultSet>> resultHandler)
Executes the given SQL
SELECT statement which returns the results of the query. |
SQLConnection |
SQLConnection.queryStream(String sql,
Handler<AsyncResult<SQLRowStream>> handler)
Executes the given SQL
SELECT statement which returns the results of the query as a read stream. |
SQLConnection |
SQLConnection.queryStreamWithParams(String sql,
JsonArray params,
Handler<AsyncResult<SQLRowStream>> handler)
Executes the given SQL
SELECT statement which returns the results of the query as a read stream. |
SQLConnection |
SQLConnection.queryWithParams(String sql,
JsonArray params,
Handler<AsyncResult<ResultSet>> resultHandler)
Executes the given SQL
SELECT prepared statement which returns the results of the query. |
SQLConnection |
SQLConnection.rollback(Handler<AsyncResult<Void>> handler)
Rolls back all changes made since the previous commit/rollback.
|
SQLConnection |
SQLConnection.setAutoCommit(boolean autoCommit,
Handler<AsyncResult<Void>> resultHandler)
Sets the auto commit flag for this connection.
|
SQLConnection |
SQLConnection.setOptions(SQLOptions options)
Sets the desired options to be applied to the current connection when statements are executed.
|
SQLConnection |
SQLConnection.setQueryTimeout(int timeoutInSeconds)
Deprecated.
|
SQLConnection |
SQLConnection.setTransactionIsolation(TransactionIsolation isolation,
Handler<AsyncResult<Void>> handler)
Attempts to change the transaction isolation level for this Connection object to the one given.
|
SQLConnection |
SQLConnection.update(String sql,
Handler<AsyncResult<UpdateResult>> resultHandler)
Executes the given SQL statement which may be an
INSERT , UPDATE , or DELETE
statement. |
SQLConnection |
SQLConnection.updateWithParams(String sql,
JsonArray params,
Handler<AsyncResult<UpdateResult>> resultHandler)
Executes the given prepared statement which may be an
INSERT , UPDATE , or DELETE
statement with the given parameters |
Modifier and Type | Method and Description |
---|---|
Single<SQLConnection> |
SQLClient.rxGetConnection()
Returns a connection that can be used to perform SQL operations on.
|
Modifier and Type | Method and Description |
---|---|
static CompletableTransformer |
SQLClientHelper.txCompletableTransformer(SQLConnection sqlConnection)
Creates a
CompletableTransformer decorating a Completable with transaction management for a given SQLConnection . |
static <T> FlowableTransformer<T,T> |
SQLClientHelper.txFlowableTransformer(SQLConnection sqlConnection)
Creates a
FlowableTransformer decorating a Flowable with transaction management for a given SQLConnection . |
static <T> MaybeTransformer<T,T> |
SQLClientHelper.txMaybeTransformer(SQLConnection sqlConnection)
Creates a
MaybeTransformer decorating a Maybe with transaction management for a given SQLConnection . |
static <T> ObservableTransformer<T,T> |
SQLClientHelper.txObservableTransformer(SQLConnection sqlConnection)
Creates a
ObservableTransformer decorating an Observable with transaction management for a given SQLConnection . |
static <T> SingleTransformer<T,T> |
SQLClientHelper.txSingleTransformer(SQLConnection sqlConnection)
Creates a
SingleTransformer decorating a Single with transaction management for a given SQLConnection . |
Modifier and Type | Method and Description |
---|---|
SQLClient |
SQLClient.getConnection(Handler<AsyncResult<SQLConnection>> handler)
Returns a connection that can be used to perform SQL operations on.
|
static Completable |
SQLClientHelper.inTransactionCompletable(SQLClient client,
java.util.function.Function<SQLConnection,Completable> sourceSupplier)
Generates a
Completable from SQLConnection operations executed inside a transaction. |
static <T> Flowable<T> |
SQLClientHelper.inTransactionFlowable(SQLClient client,
java.util.function.Function<SQLConnection,Flowable<T>> sourceSupplier)
Generates a
Flowable from SQLConnection operations executed inside a transaction. |
static <T> Maybe<T> |
SQLClientHelper.inTransactionMaybe(SQLClient client,
java.util.function.Function<SQLConnection,Maybe<T>> sourceSupplier)
Generates a
Maybe from SQLConnection operations executed inside a transaction. |
static <T> Observable<T> |
SQLClientHelper.inTransactionObservable(SQLClient client,
java.util.function.Function<SQLConnection,Observable<T>> sourceSupplier)
Generates a
Observable from SQLConnection operations executed inside a transaction. |
static <T> Single<T> |
SQLClientHelper.inTransactionSingle(SQLClient client,
java.util.function.Function<SQLConnection,Single<T>> sourceSupplier)
Generates a
Single from SQLConnection operations executed inside a transaction. |
static Completable |
SQLClientHelper.usingConnectionCompletable(SQLClient client,
java.util.function.Function<SQLConnection,Completable> sourceSupplier)
Generates a
Completable from SQLConnection operations. |
static <T> Flowable<T> |
SQLClientHelper.usingConnectionFlowable(SQLClient client,
java.util.function.Function<SQLConnection,Flowable<T>> sourceSupplier)
Generates a
Flowable from SQLConnection operations. |
static <T> Maybe<T> |
SQLClientHelper.usingConnectionMaybe(SQLClient client,
java.util.function.Function<SQLConnection,Maybe<T>> sourceSupplier)
Generates a
Maybe from SQLConnection operations. |
static <T> Observable<T> |
SQLClientHelper.usingConnectionObservable(SQLClient client,
java.util.function.Function<SQLConnection,Observable<T>> sourceSupplier)
Generates a
Observable from SQLConnection operations. |
static <T> Single<T> |
SQLClientHelper.usingConnectionSingle(SQLClient client,
java.util.function.Function<SQLConnection,Single<T>> sourceSupplier)
Generates a
Single from SQLConnection operations. |
Copyright © 2023 Eclipse. All rights reserved.