/*
* Copyright 2014 Red Hat, Inc.
*
* Red Hat licenses this file to you under the Apache License, version 2.0
* (the "License"); you may not use this file except in compliance with the
* License. You may obtain a copy of the License at:
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
* WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
* License for the specific language governing permissions and limitations
* under the License.
*/
package io.vertx.reactivex.ext.sql;
import java.util.Map;
import io.reactivex.Observable;
import io.reactivex.Flowable;
import io.reactivex.Single;
import io.reactivex.Completable;
import io.reactivex.Maybe;
import io.vertx.core.json.JsonArray;
import io.vertx.ext.sql.UpdateResult;
import io.vertx.ext.sql.ResultSet;
import io.vertx.core.AsyncResult;
import io.vertx.core.Handler;
Represents a SQL query interface to a database
NOTE: This class has been automatically generated from the original
non RX-ified interface using Vert.x codegen. /**
* Represents a SQL query interface to a database
*
* <p/>
* NOTE: This class has been automatically generated from the {@link io.vertx.ext.sql.SQLOperations original} non RX-ified interface using Vert.x codegen.
*/
@io.vertx.lang.rx.RxGen(io.vertx.ext.sql.SQLOperations.class)
public interface SQLOperations {
io.vertx.ext.sql.SQLOperations getDelegate();
Executes the given SQL SELECT
statement which returns the results of the query.
Params: - sql – the SQL to execute. For example
SELECT * FROM table ...
. - resultHandler – the handler which is called once the operation completes. It will return a
ResultSet
.
Returns:
/**
* Executes the given SQL <code>SELECT</code> statement which returns the results of the query.
* @param sql the SQL to execute. For example <code>SELECT * FROM table ...</code>.
* @param resultHandler the handler which is called once the operation completes. It will return a <code>ResultSet</code>.
* @return
*/
public io.vertx.reactivex.ext.sql.SQLOperations query(String sql, Handler<AsyncResult<ResultSet>> resultHandler);
Executes the given SQL SELECT
prepared statement which returns the results of the query.
Params: - sql – the SQL to execute. For example
SELECT * FROM table ...
. - params – these are the parameters to fill the statement.
- resultHandler – the handler which is called once the operation completes. It will return a
ResultSet
.
Returns:
/**
* Executes the given SQL <code>SELECT</code> prepared statement which returns the results of the query.
* @param sql the SQL to execute. For example <code>SELECT * FROM table ...</code>.
* @param params these are the parameters to fill the statement.
* @param resultHandler the handler which is called once the operation completes. It will return a <code>ResultSet</code>.
* @return
*/
public io.vertx.reactivex.ext.sql.SQLOperations queryWithParams(String sql, JsonArray params, Handler<AsyncResult<ResultSet>> resultHandler);
Executes the given SQL SELECT
statement which returns the results of the query as a read stream.
Params: - sql – the SQL to execute. For example
SELECT * FROM table ...
. - handler – the handler which is called once the operation completes. It will return a
SQLRowStream
.
Returns:
/**
* Executes the given SQL <code>SELECT</code> statement which returns the results of the query as a read stream.
* @param sql the SQL to execute. For example <code>SELECT * FROM table ...</code>.
* @param handler the handler which is called once the operation completes. It will return a <code>SQLRowStream</code>.
* @return
*/
public io.vertx.reactivex.ext.sql.SQLOperations queryStream(String sql, Handler<AsyncResult<io.vertx.reactivex.ext.sql.SQLRowStream>> handler);
Executes the given SQL SELECT
statement which returns the results of the query as a read stream.
Params: - sql – the SQL to execute. For example
SELECT * FROM table ...
. - params – these are the parameters to fill the statement.
- handler – the handler which is called once the operation completes. It will return a
SQLRowStream
.
Returns:
/**
* Executes the given SQL <code>SELECT</code> statement which returns the results of the query as a read stream.
* @param sql the SQL to execute. For example <code>SELECT * FROM table ...</code>.
* @param params these are the parameters to fill the statement.
* @param handler the handler which is called once the operation completes. It will return a <code>SQLRowStream</code>.
* @return
*/
public io.vertx.reactivex.ext.sql.SQLOperations queryStreamWithParams(String sql, JsonArray params, Handler<AsyncResult<io.vertx.reactivex.ext.sql.SQLRowStream>> handler);
Execute a one shot SQL statement that returns a single SQL row. This method will reduce the boilerplate code by
getting a connection from the pool (this object) and return it back after the execution. Only the first result
from the result set is returned.
Params: - sql – the statement to execute
- handler – the result handler
Returns: self
/**
* Execute a one shot SQL statement that returns a single SQL row. This method will reduce the boilerplate code by
* getting a connection from the pool (this object) and return it back after the execution. Only the first result
* from the result set is returned.
* @param sql the statement to execute
* @param handler the result handler
* @return self
*/
public io.vertx.reactivex.ext.sql.SQLOperations querySingle(String sql, Handler<AsyncResult<JsonArray>> handler);
Execute a one shot SQL statement with arguments that returns a single SQL row. This method will reduce the
boilerplate code by getting a connection from the pool (this object) and return it back after the execution.
Only the first result from the result set is returned.
Params: - sql – the statement to execute
- arguments – the arguments
- handler – the result handler
Returns: self
/**
* Execute a one shot SQL statement with arguments that returns a single SQL row. This method will reduce the
* boilerplate code by getting a connection from the pool (this object) and return it back after the execution.
* Only the first result from the result set is returned.
* @param sql the statement to execute
* @param arguments the arguments
* @param handler the result handler
* @return self
*/
public io.vertx.reactivex.ext.sql.SQLOperations querySingleWithParams(String sql, JsonArray arguments, Handler<AsyncResult<JsonArray>> handler);
Executes the given SQL statement which may be an INSERT
, UPDATE
, or DELETE
statement.
Params: - sql – the SQL to execute. For example
INSERT INTO table ...
- resultHandler – the handler which is called once the operation completes.
Returns:
/**
* Executes the given SQL statement which may be an <code>INSERT</code>, <code>UPDATE</code>, or <code>DELETE</code>
* statement.
* @param sql the SQL to execute. For example <code>INSERT INTO table ...</code>
* @param resultHandler the handler which is called once the operation completes.
* @return
*/
public io.vertx.reactivex.ext.sql.SQLOperations update(String sql, Handler<AsyncResult<UpdateResult>> resultHandler);
Executes the given prepared statement which may be an INSERT
, UPDATE
, or DELETE
statement with the given parameters
Params: - sql – the SQL to execute. For example
INSERT INTO table ...
- params – these are the parameters to fill the statement.
- resultHandler – the handler which is called once the operation completes.
Returns:
/**
* Executes the given prepared statement which may be an <code>INSERT</code>, <code>UPDATE</code>, or <code>DELETE</code>
* statement with the given parameters
* @param sql the SQL to execute. For example <code>INSERT INTO table ...</code>
* @param params these are the parameters to fill the statement.
* @param resultHandler the handler which is called once the operation completes.
* @return
*/
public io.vertx.reactivex.ext.sql.SQLOperations updateWithParams(String sql, JsonArray params, Handler<AsyncResult<UpdateResult>> resultHandler);
Calls the given SQL PROCEDURE
which returns the result from the procedure.
Params: - sql – the SQL to execute. For example
{call getEmpName}
. - resultHandler – the handler which is called once the operation completes. It will return a
ResultSet
.
Returns:
/**
* Calls the given SQL <code>PROCEDURE</code> which returns the result from the procedure.
* @param sql the SQL to execute. For example <code>{call getEmpName}</code>.
* @param resultHandler the handler which is called once the operation completes. It will return a <code>ResultSet</code>.
* @return
*/
public io.vertx.reactivex.ext.sql.SQLOperations call(String sql, Handler<AsyncResult<ResultSet>> resultHandler);
Calls the given SQL PROCEDURE
which returns the result from the procedure.
The index of params and outputs are important for both arrays, for example when dealing with a prodecure that
takes the first 2 arguments as input values and the 3 arg as an output then the arrays should be like:
params = [VALUE1, VALUE2, null]
outputs = [null, null, "VARCHAR"]
Params: - sql – the SQL to execute. For example
{call getEmpName (?, ?)}
. - params – these are the parameters to fill the statement.
- outputs – these are the outputs to fill the statement.
- resultHandler – the handler which is called once the operation completes. It will return a
ResultSet
.
Returns:
/**
* Calls the given SQL <code>PROCEDURE</code> which returns the result from the procedure.
*
* The index of params and outputs are important for both arrays, for example when dealing with a prodecure that
* takes the first 2 arguments as input values and the 3 arg as an output then the arrays should be like:
*
* <pre>
* params = [VALUE1, VALUE2, null]
* outputs = [null, null, "VARCHAR"]
* </pre>
* @param sql the SQL to execute. For example <code>{call getEmpName (?, ?)}</code>.
* @param params these are the parameters to fill the statement.
* @param outputs these are the outputs to fill the statement.
* @param resultHandler the handler which is called once the operation completes. It will return a <code>ResultSet</code>.
* @return
*/
public io.vertx.reactivex.ext.sql.SQLOperations callWithParams(String sql, JsonArray params, JsonArray outputs, Handler<AsyncResult<ResultSet>> resultHandler);
public static SQLOperations newInstance(io.vertx.ext.sql.SQLOperations arg) {
return arg != null ? new SQLOperationsImpl(arg) : null;
}
}
class SQLOperationsImpl implements SQLOperations {
private final io.vertx.ext.sql.SQLOperations delegate;
public SQLOperationsImpl(io.vertx.ext.sql.SQLOperations delegate) {
this.delegate = delegate;
}
public io.vertx.ext.sql.SQLOperations getDelegate() {
return delegate;
}
Executes the given SQL SELECT
statement which returns the results of the query.
Params: - sql – the SQL to execute. For example
SELECT * FROM table ...
. - resultHandler – the handler which is called once the operation completes. It will return a
ResultSet
.
Returns:
/**
* Executes the given SQL <code>SELECT</code> statement which returns the results of the query.
* @param sql the SQL to execute. For example <code>SELECT * FROM table ...</code>.
* @param resultHandler the handler which is called once the operation completes. It will return a <code>ResultSet</code>.
* @return
*/
public io.vertx.reactivex.ext.sql.SQLOperations query(String sql, Handler<AsyncResult<ResultSet>> resultHandler) {
delegate.query(sql, resultHandler);
return this;
}
Executes the given SQL SELECT
statement which returns the results of the query.
Params: - sql – the SQL to execute. For example
SELECT * FROM table ...
.
Returns:
/**
* Executes the given SQL <code>SELECT</code> statement which returns the results of the query.
* @param sql the SQL to execute. For example <code>SELECT * FROM table ...</code>.
* @return
*/
public Single<ResultSet> rxQuery(String sql) {
return io.vertx.reactivex.impl.AsyncResultSingle.toSingle(handler -> {
query(sql, handler);
});
}
Executes the given SQL SELECT
prepared statement which returns the results of the query.
Params: - sql – the SQL to execute. For example
SELECT * FROM table ...
. - params – these are the parameters to fill the statement.
- resultHandler – the handler which is called once the operation completes. It will return a
ResultSet
.
Returns:
/**
* Executes the given SQL <code>SELECT</code> prepared statement which returns the results of the query.
* @param sql the SQL to execute. For example <code>SELECT * FROM table ...</code>.
* @param params these are the parameters to fill the statement.
* @param resultHandler the handler which is called once the operation completes. It will return a <code>ResultSet</code>.
* @return
*/
public io.vertx.reactivex.ext.sql.SQLOperations queryWithParams(String sql, JsonArray params, Handler<AsyncResult<ResultSet>> resultHandler) {
delegate.queryWithParams(sql, params, resultHandler);
return this;
}
Executes the given SQL SELECT
prepared statement which returns the results of the query.
Params: - sql – the SQL to execute. For example
SELECT * FROM table ...
. - params – these are the parameters to fill the statement.
Returns:
/**
* Executes the given SQL <code>SELECT</code> prepared statement which returns the results of the query.
* @param sql the SQL to execute. For example <code>SELECT * FROM table ...</code>.
* @param params these are the parameters to fill the statement.
* @return
*/
public Single<ResultSet> rxQueryWithParams(String sql, JsonArray params) {
return io.vertx.reactivex.impl.AsyncResultSingle.toSingle(handler -> {
queryWithParams(sql, params, handler);
});
}
Executes the given SQL SELECT
statement which returns the results of the query as a read stream.
Params: - sql – the SQL to execute. For example
SELECT * FROM table ...
. - handler – the handler which is called once the operation completes. It will return a
SQLRowStream
.
Returns:
/**
* Executes the given SQL <code>SELECT</code> statement which returns the results of the query as a read stream.
* @param sql the SQL to execute. For example <code>SELECT * FROM table ...</code>.
* @param handler the handler which is called once the operation completes. It will return a <code>SQLRowStream</code>.
* @return
*/
public io.vertx.reactivex.ext.sql.SQLOperations queryStream(String sql, Handler<AsyncResult<io.vertx.reactivex.ext.sql.SQLRowStream>> handler) {
delegate.queryStream(sql, new Handler<AsyncResult<io.vertx.ext.sql.SQLRowStream>>() {
public void handle(AsyncResult<io.vertx.ext.sql.SQLRowStream> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.ext.sql.SQLRowStream.newInstance(ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
Executes the given SQL SELECT
statement which returns the results of the query as a read stream.
Params: - sql – the SQL to execute. For example
SELECT * FROM table ...
.
Returns:
/**
* Executes the given SQL <code>SELECT</code> statement which returns the results of the query as a read stream.
* @param sql the SQL to execute. For example <code>SELECT * FROM table ...</code>.
* @return
*/
public Single<io.vertx.reactivex.ext.sql.SQLRowStream> rxQueryStream(String sql) {
return io.vertx.reactivex.impl.AsyncResultSingle.toSingle(handler -> {
queryStream(sql, handler);
});
}
Executes the given SQL SELECT
statement which returns the results of the query as a read stream.
Params: - sql – the SQL to execute. For example
SELECT * FROM table ...
. - params – these are the parameters to fill the statement.
- handler – the handler which is called once the operation completes. It will return a
SQLRowStream
.
Returns:
/**
* Executes the given SQL <code>SELECT</code> statement which returns the results of the query as a read stream.
* @param sql the SQL to execute. For example <code>SELECT * FROM table ...</code>.
* @param params these are the parameters to fill the statement.
* @param handler the handler which is called once the operation completes. It will return a <code>SQLRowStream</code>.
* @return
*/
public io.vertx.reactivex.ext.sql.SQLOperations queryStreamWithParams(String sql, JsonArray params, Handler<AsyncResult<io.vertx.reactivex.ext.sql.SQLRowStream>> handler) {
delegate.queryStreamWithParams(sql, params, new Handler<AsyncResult<io.vertx.ext.sql.SQLRowStream>>() {
public void handle(AsyncResult<io.vertx.ext.sql.SQLRowStream> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.ext.sql.SQLRowStream.newInstance(ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
Executes the given SQL SELECT
statement which returns the results of the query as a read stream.
Params: - sql – the SQL to execute. For example
SELECT * FROM table ...
. - params – these are the parameters to fill the statement.
Returns:
/**
* Executes the given SQL <code>SELECT</code> statement which returns the results of the query as a read stream.
* @param sql the SQL to execute. For example <code>SELECT * FROM table ...</code>.
* @param params these are the parameters to fill the statement.
* @return
*/
public Single<io.vertx.reactivex.ext.sql.SQLRowStream> rxQueryStreamWithParams(String sql, JsonArray params) {
return io.vertx.reactivex.impl.AsyncResultSingle.toSingle(handler -> {
queryStreamWithParams(sql, params, handler);
});
}
Execute a one shot SQL statement that returns a single SQL row. This method will reduce the boilerplate code by
getting a connection from the pool (this object) and return it back after the execution. Only the first result
from the result set is returned.
Params: - sql – the statement to execute
- handler – the result handler
Returns: self
/**
* Execute a one shot SQL statement that returns a single SQL row. This method will reduce the boilerplate code by
* getting a connection from the pool (this object) and return it back after the execution. Only the first result
* from the result set is returned.
* @param sql the statement to execute
* @param handler the result handler
* @return self
*/
public io.vertx.reactivex.ext.sql.SQLOperations querySingle(String sql, Handler<AsyncResult<JsonArray>> handler) {
delegate.querySingle(sql, handler);
return this;
}
Execute a one shot SQL statement that returns a single SQL row. This method will reduce the boilerplate code by
getting a connection from the pool (this object) and return it back after the execution. Only the first result
from the result set is returned.
Params: - sql – the statement to execute
Returns: self
/**
* Execute a one shot SQL statement that returns a single SQL row. This method will reduce the boilerplate code by
* getting a connection from the pool (this object) and return it back after the execution. Only the first result
* from the result set is returned.
* @param sql the statement to execute
* @return self
*/
public Maybe<JsonArray> rxQuerySingle(String sql) {
return io.vertx.reactivex.impl.AsyncResultMaybe.toMaybe(handler -> {
querySingle(sql, handler);
});
}
Execute a one shot SQL statement with arguments that returns a single SQL row. This method will reduce the
boilerplate code by getting a connection from the pool (this object) and return it back after the execution.
Only the first result from the result set is returned.
Params: - sql – the statement to execute
- arguments – the arguments
- handler – the result handler
Returns: self
/**
* Execute a one shot SQL statement with arguments that returns a single SQL row. This method will reduce the
* boilerplate code by getting a connection from the pool (this object) and return it back after the execution.
* Only the first result from the result set is returned.
* @param sql the statement to execute
* @param arguments the arguments
* @param handler the result handler
* @return self
*/
public io.vertx.reactivex.ext.sql.SQLOperations querySingleWithParams(String sql, JsonArray arguments, Handler<AsyncResult<JsonArray>> handler) {
delegate.querySingleWithParams(sql, arguments, handler);
return this;
}
Execute a one shot SQL statement with arguments that returns a single SQL row. This method will reduce the
boilerplate code by getting a connection from the pool (this object) and return it back after the execution.
Only the first result from the result set is returned.
Params: - sql – the statement to execute
- arguments – the arguments
Returns: self
/**
* Execute a one shot SQL statement with arguments that returns a single SQL row. This method will reduce the
* boilerplate code by getting a connection from the pool (this object) and return it back after the execution.
* Only the first result from the result set is returned.
* @param sql the statement to execute
* @param arguments the arguments
* @return self
*/
public Maybe<JsonArray> rxQuerySingleWithParams(String sql, JsonArray arguments) {
return io.vertx.reactivex.impl.AsyncResultMaybe.toMaybe(handler -> {
querySingleWithParams(sql, arguments, handler);
});
}
Executes the given SQL statement which may be an INSERT
, UPDATE
, or DELETE
statement.
Params: - sql – the SQL to execute. For example
INSERT INTO table ...
- resultHandler – the handler which is called once the operation completes.
Returns:
/**
* Executes the given SQL statement which may be an <code>INSERT</code>, <code>UPDATE</code>, or <code>DELETE</code>
* statement.
* @param sql the SQL to execute. For example <code>INSERT INTO table ...</code>
* @param resultHandler the handler which is called once the operation completes.
* @return
*/
public io.vertx.reactivex.ext.sql.SQLOperations update(String sql, Handler<AsyncResult<UpdateResult>> resultHandler) {
delegate.update(sql, resultHandler);
return this;
}
Executes the given SQL statement which may be an INSERT
, UPDATE
, or DELETE
statement.
Params: - sql – the SQL to execute. For example
INSERT INTO table ...
Returns:
/**
* Executes the given SQL statement which may be an <code>INSERT</code>, <code>UPDATE</code>, or <code>DELETE</code>
* statement.
* @param sql the SQL to execute. For example <code>INSERT INTO table ...</code>
* @return
*/
public Single<UpdateResult> rxUpdate(String sql) {
return io.vertx.reactivex.impl.AsyncResultSingle.toSingle(handler -> {
update(sql, handler);
});
}
Executes the given prepared statement which may be an INSERT
, UPDATE
, or DELETE
statement with the given parameters
Params: - sql – the SQL to execute. For example
INSERT INTO table ...
- params – these are the parameters to fill the statement.
- resultHandler – the handler which is called once the operation completes.
Returns:
/**
* Executes the given prepared statement which may be an <code>INSERT</code>, <code>UPDATE</code>, or <code>DELETE</code>
* statement with the given parameters
* @param sql the SQL to execute. For example <code>INSERT INTO table ...</code>
* @param params these are the parameters to fill the statement.
* @param resultHandler the handler which is called once the operation completes.
* @return
*/
public io.vertx.reactivex.ext.sql.SQLOperations updateWithParams(String sql, JsonArray params, Handler<AsyncResult<UpdateResult>> resultHandler) {
delegate.updateWithParams(sql, params, resultHandler);
return this;
}
Executes the given prepared statement which may be an INSERT
, UPDATE
, or DELETE
statement with the given parameters
Params: - sql – the SQL to execute. For example
INSERT INTO table ...
- params – these are the parameters to fill the statement.
Returns:
/**
* Executes the given prepared statement which may be an <code>INSERT</code>, <code>UPDATE</code>, or <code>DELETE</code>
* statement with the given parameters
* @param sql the SQL to execute. For example <code>INSERT INTO table ...</code>
* @param params these are the parameters to fill the statement.
* @return
*/
public Single<UpdateResult> rxUpdateWithParams(String sql, JsonArray params) {
return io.vertx.reactivex.impl.AsyncResultSingle.toSingle(handler -> {
updateWithParams(sql, params, handler);
});
}
Calls the given SQL PROCEDURE
which returns the result from the procedure.
Params: - sql – the SQL to execute. For example
{call getEmpName}
. - resultHandler – the handler which is called once the operation completes. It will return a
ResultSet
.
Returns:
/**
* Calls the given SQL <code>PROCEDURE</code> which returns the result from the procedure.
* @param sql the SQL to execute. For example <code>{call getEmpName}</code>.
* @param resultHandler the handler which is called once the operation completes. It will return a <code>ResultSet</code>.
* @return
*/
public io.vertx.reactivex.ext.sql.SQLOperations call(String sql, Handler<AsyncResult<ResultSet>> resultHandler) {
delegate.call(sql, resultHandler);
return this;
}
Calls the given SQL PROCEDURE
which returns the result from the procedure.
Params: - sql – the SQL to execute. For example
{call getEmpName}
.
Returns:
/**
* Calls the given SQL <code>PROCEDURE</code> which returns the result from the procedure.
* @param sql the SQL to execute. For example <code>{call getEmpName}</code>.
* @return
*/
public Single<ResultSet> rxCall(String sql) {
return io.vertx.reactivex.impl.AsyncResultSingle.toSingle(handler -> {
call(sql, handler);
});
}
Calls the given SQL PROCEDURE
which returns the result from the procedure.
The index of params and outputs are important for both arrays, for example when dealing with a prodecure that
takes the first 2 arguments as input values and the 3 arg as an output then the arrays should be like:
params = [VALUE1, VALUE2, null]
outputs = [null, null, "VARCHAR"]
Params: - sql – the SQL to execute. For example
{call getEmpName (?, ?)}
. - params – these are the parameters to fill the statement.
- outputs – these are the outputs to fill the statement.
- resultHandler – the handler which is called once the operation completes. It will return a
ResultSet
.
Returns:
/**
* Calls the given SQL <code>PROCEDURE</code> which returns the result from the procedure.
*
* The index of params and outputs are important for both arrays, for example when dealing with a prodecure that
* takes the first 2 arguments as input values and the 3 arg as an output then the arrays should be like:
*
* <pre>
* params = [VALUE1, VALUE2, null]
* outputs = [null, null, "VARCHAR"]
* </pre>
* @param sql the SQL to execute. For example <code>{call getEmpName (?, ?)}</code>.
* @param params these are the parameters to fill the statement.
* @param outputs these are the outputs to fill the statement.
* @param resultHandler the handler which is called once the operation completes. It will return a <code>ResultSet</code>.
* @return
*/
public io.vertx.reactivex.ext.sql.SQLOperations callWithParams(String sql, JsonArray params, JsonArray outputs, Handler<AsyncResult<ResultSet>> resultHandler) {
delegate.callWithParams(sql, params, outputs, resultHandler);
return this;
}
Calls the given SQL PROCEDURE
which returns the result from the procedure.
The index of params and outputs are important for both arrays, for example when dealing with a prodecure that
takes the first 2 arguments as input values and the 3 arg as an output then the arrays should be like:
params = [VALUE1, VALUE2, null]
outputs = [null, null, "VARCHAR"]
Params: - sql – the SQL to execute. For example
{call getEmpName (?, ?)}
. - params – these are the parameters to fill the statement.
- outputs – these are the outputs to fill the statement.
Returns:
/**
* Calls the given SQL <code>PROCEDURE</code> which returns the result from the procedure.
*
* The index of params and outputs are important for both arrays, for example when dealing with a prodecure that
* takes the first 2 arguments as input values and the 3 arg as an output then the arrays should be like:
*
* <pre>
* params = [VALUE1, VALUE2, null]
* outputs = [null, null, "VARCHAR"]
* </pre>
* @param sql the SQL to execute. For example <code>{call getEmpName (?, ?)}</code>.
* @param params these are the parameters to fill the statement.
* @param outputs these are the outputs to fill the statement.
* @return
*/
public Single<ResultSet> rxCallWithParams(String sql, JsonArray params, JsonArray outputs) {
return io.vertx.reactivex.impl.AsyncResultSingle.toSingle(handler -> {
callWithParams(sql, params, outputs, handler);
});
}
}