Uses of Class
io.vertx.rxjava.ext.sql.SQLConnection

Packages that use SQLConnection

Package	Description
io.vertx.rxjava.ext.sql

Uses of SQLConnection in io.vertx.rxjava.ext.sql

Fields in io.vertx.rxjava.ext.sql with type parameters of type SQLConnection

Modifier and Type	Field and Description
static io.vertx.lang.rx.TypeArg<SQLConnection>	SQLConnection.__TYPE_ARG

Methods in io.vertx.rxjava.ext.sql that return SQLConnection

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

Methods in io.vertx.rxjava.ext.sql that return types with arguments of type SQLConnection

Modifier and Type	Method and Description
Observable<SQLConnection>	SQLClient.getConnectionObservable() Deprecated. use SQLClient.rxGetConnection() instead
Single<SQLConnection>	SQLClient.rxGetConnection() Returns a connection that can be used to perform SQL operations on.

Methods in io.vertx.rxjava.ext.sql with parameters of type SQLConnection

Modifier and Type	Method and Description
static Completable.Transformer	SQLClientHelper.txCompletableTransformer(SQLConnection sqlConnection) Creates a Completable.Transformer decorating a Completable with transaction management for a given SQLConnection.
static <T> Observable.Transformer<T,T>	SQLClientHelper.txObservableTransformer(SQLConnection sqlConnection) Creates a Observable.Transformer decorating an Observable with transaction management for a given SQLConnection.
static <T> Single.Transformer<T,T>	SQLClientHelper.txSingleTransformer(SQLConnection sqlConnection) Creates a Single.Transformer decorating a Single with transaction management for a given SQLConnection.

Method parameters in io.vertx.rxjava.ext.sql with type arguments of type 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> 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> 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.