public class SQLConnection extends Object implements SQLOperations
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 | 
|---|---|
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 | 
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 | 
batchWithParams(String sqlStatement,
               List<JsonArray> args,
               Handler<AsyncResult<List<Integer>>> handler)
Batch a prepared statement with all entries from the args list. 
 | 
SQLConnection | 
call(String sql,
    Handler<AsyncResult<ResultSet>> resultHandler)
Calls the given SQL  
PROCEDURE which returns the result from the procedure. | 
SQLConnection | 
callWithParams(String sql,
              JsonArray params,
              JsonArray outputs,
              Handler<AsyncResult<ResultSet>> resultHandler)
Calls the given SQL  
PROCEDURE which returns the result from the procedure. | 
void | 
close()
Closes the connection. 
 | 
void | 
close(Handler<AsyncResult<Void>> handler)
Closes the connection. 
 | 
SQLConnection | 
commit(Handler<AsyncResult<Void>> handler)
Commits all changes made since the previous commit/rollback. 
 | 
boolean | 
equals(Object o)  | 
SQLConnection | 
execute(String sql,
       Handler<AsyncResult<Void>> resultHandler)
Executes the given SQL statement 
 | 
SQLConnection | 
getDelegate()  | 
SQLConnection | 
getTransactionIsolation(Handler<AsyncResult<TransactionIsolation>> handler)
Attempts to return the transaction isolation level for this Connection object to the one given. 
 | 
int | 
hashCode()  | 
static SQLConnection | 
newInstance(SQLConnection arg)  | 
SQLConnection | 
query(String sql,
     Handler<AsyncResult<ResultSet>> resultHandler)
Executes the given SQL  
SELECT statement which returns the results of the query. | 
SQLOperations | 
querySingle(String sql,
           Handler<AsyncResult<JsonArray>> handler)
Execute a one shot SQL statement that returns a single SQL row. 
 | 
SQLOperations | 
querySingleWithParams(String sql,
                     JsonArray arguments,
                     Handler<AsyncResult<JsonArray>> handler)
Execute a one shot SQL statement with arguments that returns a single SQL row. 
 | 
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 | 
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 | 
queryWithParams(String sql,
               JsonArray params,
               Handler<AsyncResult<ResultSet>> resultHandler)
Executes the given SQL  
SELECT prepared statement which returns the results of the query. | 
SQLConnection | 
rollback(Handler<AsyncResult<Void>> handler)
Rolls back all changes made since the previous commit/rollback. 
 | 
Single<List<Integer>> | 
rxBatch(List<String> sqlStatements)
Batch simple SQL strings and execute the batch where the async result contains a array of Integers. 
 | 
Single<List<Integer>> | 
rxBatchCallableWithParams(String sqlStatement,
                         List<JsonArray> inArgs,
                         List<JsonArray> outArgs)
Batch a callable statement with all entries from the args list. 
 | 
Single<List<Integer>> | 
rxBatchWithParams(String sqlStatement,
                 List<JsonArray> args)
Batch a prepared statement with all entries from the args list. 
 | 
Single<ResultSet> | 
rxCall(String sql)
Calls the given SQL  
PROCEDURE which returns the result from the procedure. | 
Single<ResultSet> | 
rxCallWithParams(String sql,
                JsonArray params,
                JsonArray outputs)
Calls the given SQL  
PROCEDURE which returns the result from the procedure. | 
Completable | 
rxClose()
Closes the connection. 
 | 
Completable | 
rxCommit()
Commits all changes made since the previous commit/rollback. 
 | 
Completable | 
rxExecute(String sql)
Executes the given SQL statement 
 | 
Single<TransactionIsolation> | 
rxGetTransactionIsolation()
Attempts to return the transaction isolation level for this Connection object to the one given. 
 | 
Single<ResultSet> | 
rxQuery(String sql)
Executes the given SQL  
SELECT statement which returns the results of the query. | 
Maybe<JsonArray> | 
rxQuerySingle(String sql)
Execute a one shot SQL statement that returns a single SQL row. 
 | 
Maybe<JsonArray> | 
rxQuerySingleWithParams(String sql,
                       JsonArray arguments)
Execute a one shot SQL statement with arguments that returns a single SQL row. 
 | 
Single<SQLRowStream> | 
rxQueryStream(String sql)
Executes the given SQL  
SELECT statement which returns the results of the query as a read stream. | 
Single<SQLRowStream> | 
rxQueryStreamWithParams(String sql,
                       JsonArray params)
Executes the given SQL  
SELECT statement which returns the results of the query as a read stream. | 
Single<ResultSet> | 
rxQueryWithParams(String sql,
                 JsonArray params)
Executes the given SQL  
SELECT prepared statement which returns the results of the query. | 
Completable | 
rxRollback()
Rolls back all changes made since the previous commit/rollback. 
 | 
Completable | 
rxSetAutoCommit(boolean autoCommit)
Sets the auto commit flag for this connection. 
 | 
Completable | 
rxSetTransactionIsolation(TransactionIsolation isolation)
Attempts to change the transaction isolation level for this Connection object to the one given. 
 | 
Single<UpdateResult> | 
rxUpdate(String sql)
Executes the given SQL statement which may be an  
INSERT, UPDATE, or DELETE
 statement. | 
Single<UpdateResult> | 
rxUpdateWithParams(String sql,
                  JsonArray params)
Executes the given prepared statement which may be an  
INSERT, UPDATE, or DELETE
 statement with the given parameters | 
SQLConnection | 
setAutoCommit(boolean autoCommit,
             Handler<AsyncResult<Void>> resultHandler)
Sets the auto commit flag for this connection. 
 | 
SQLConnection | 
setOptions(SQLOptions options)
Sets the desired options to be applied to the current connection when statements are executed. 
 | 
SQLConnection | 
setQueryTimeout(int timeoutInSeconds)
Deprecated.  
 | 
SQLConnection | 
setTransactionIsolation(TransactionIsolation isolation,
                       Handler<AsyncResult<Void>> handler)
Attempts to change the transaction isolation level for this Connection object to the one given. 
 | 
String | 
toString()  | 
SQLConnection | 
update(String sql,
      Handler<AsyncResult<UpdateResult>> resultHandler)
Executes the given SQL statement which may be an  
INSERT, UPDATE, or DELETE
 statement. | 
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 | 
clone, finalize, getClass, notify, notifyAll, wait, wait, waitnewInstancepublic static final io.vertx.lang.rx.TypeArg<SQLConnection> __TYPE_ARG
public SQLConnection(SQLConnection delegate)
public SQLConnection(Object delegate)
public SQLConnection getDelegate()
getDelegate in interface SQLOperationspublic SQLOperations querySingle(String sql, Handler<AsyncResult<JsonArray>> handler)
querySingle in interface SQLOperationssql - the statement to executehandler - the result handlerpublic Maybe<JsonArray> rxQuerySingle(String sql)
sql - the statement to executepublic SQLOperations querySingleWithParams(String sql, JsonArray arguments, Handler<AsyncResult<JsonArray>> handler)
querySingleWithParams in interface SQLOperationssql - the statement to executearguments - the argumentshandler - the result handlerpublic Maybe<JsonArray> rxQuerySingleWithParams(String sql, JsonArray arguments)
sql - the statement to executearguments - the argumentspublic SQLConnection setOptions(SQLOptions options)
options - the options to modify the unwrapped connection.public SQLConnection setAutoCommit(boolean autoCommit, Handler<AsyncResult<Void>> resultHandler)
autoCommit - the autoCommit flag, true by default.resultHandler - the handler which is called once this operation completes.public Completable rxSetAutoCommit(boolean autoCommit)
autoCommit - the autoCommit flag, true by default.public SQLConnection execute(String sql, Handler<AsyncResult<Void>> resultHandler)
sql - the SQL to execute. For example CREATE TABLE IF EXISTS table ...resultHandler - the handler which is called once this operation completes.public Completable rxExecute(String sql)
sql - the SQL to execute. For example CREATE TABLE IF EXISTS table ...public SQLConnection query(String sql, Handler<AsyncResult<ResultSet>> resultHandler)
SELECT statement which returns the results of the query.query in interface SQLOperationssql - the SQL to execute. For example SELECT * FROM table ....resultHandler - the handler which is called once the operation completes. It will return a ResultSet.public Single<ResultSet> rxQuery(String sql)
SELECT statement which returns the results of the query.sql - the SQL to execute. For example SELECT * FROM table ....public SQLConnection queryStream(String sql, Handler<AsyncResult<SQLRowStream>> handler)
SELECT statement which returns the results of the query as a read stream.queryStream in interface SQLOperationssql - the SQL to execute. For example SELECT * FROM table ....handler - the handler which is called once the operation completes. It will return a SQLRowStream.public Single<SQLRowStream> rxQueryStream(String sql)
SELECT statement which returns the results of the query as a read stream.sql - the SQL to execute. For example SELECT * FROM table ....public SQLConnection queryWithParams(String sql, JsonArray params, Handler<AsyncResult<ResultSet>> resultHandler)
SELECT prepared statement which returns the results of the query.queryWithParams in interface SQLOperationssql - 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.public Single<ResultSet> rxQueryWithParams(String sql, JsonArray params)
SELECT prepared statement which returns the results of the query.sql - the SQL to execute. For example SELECT * FROM table ....params - these are the parameters to fill the statement.public SQLConnection queryStreamWithParams(String sql, JsonArray params, Handler<AsyncResult<SQLRowStream>> handler)
SELECT statement which returns the results of the query as a read stream.queryStreamWithParams in interface SQLOperationssql - 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.public Single<SQLRowStream> rxQueryStreamWithParams(String sql, JsonArray params)
SELECT statement which returns the results of the query as a read stream.sql - the SQL to execute. For example SELECT * FROM table ....params - these are the parameters to fill the statement.public SQLConnection update(String sql, Handler<AsyncResult<UpdateResult>> resultHandler)
INSERT, UPDATE, or DELETE
 statement.update in interface SQLOperationssql - the SQL to execute. For example INSERT INTO table ...resultHandler - the handler which is called once the operation completes.public Single<UpdateResult> rxUpdate(String sql)
INSERT, UPDATE, or DELETE
 statement.sql - the SQL to execute. For example INSERT INTO table ...public SQLConnection updateWithParams(String sql, JsonArray params, Handler<AsyncResult<UpdateResult>> resultHandler)
INSERT, UPDATE, or DELETE
 statement with the given parametersupdateWithParams in interface SQLOperationssql - 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.public Single<UpdateResult> rxUpdateWithParams(String sql, JsonArray params)
INSERT, UPDATE, or DELETE
 statement with the given parameterssql - the SQL to execute. For example INSERT INTO table ...params - these are the parameters to fill the statement.public SQLConnection call(String sql, Handler<AsyncResult<ResultSet>> resultHandler)
PROCEDURE which returns the result from the procedure.call in interface SQLOperationssql - the SQL to execute. For example {call getEmpName}.resultHandler - the handler which is called once the operation completes. It will return a ResultSet.public Single<ResultSet> rxCall(String sql)
PROCEDURE which returns the result from the procedure.sql - the SQL to execute. For example {call getEmpName}.public SQLConnection callWithParams(String sql, JsonArray params, JsonArray outputs, Handler<AsyncResult<ResultSet>> resultHandler)
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"]
callWithParams in interface SQLOperationssql - 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.public Single<ResultSet> rxCallWithParams(String sql, JsonArray params, JsonArray outputs)
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"]
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.public void close(Handler<AsyncResult<Void>> handler)
handler - the handler called when this operation completes.public Completable rxClose()
public void close()
public SQLConnection commit(Handler<AsyncResult<Void>> handler)
handler - the handler called when this operation completes.public Completable rxCommit()
public SQLConnection rollback(Handler<AsyncResult<Void>> handler)
handler - the handler called when this operation completes.public Completable rxRollback()
@Deprecated public SQLConnection setQueryTimeout(int timeoutInSeconds)
timeoutInSeconds - the max amount of seconds the query can take to execute.public SQLConnection batch(List<String> sqlStatements, Handler<AsyncResult<List<Integer>>> handler)
sqlStatements - sql statementhandler - the result handlerpublic Single<List<Integer>> rxBatch(List<String> sqlStatements)
sqlStatements - sql statementpublic SQLConnection batchWithParams(String sqlStatement, List<JsonArray> args, Handler<AsyncResult<List<Integer>>> handler)
sqlStatement - sql statementargs - the prepared statement argumentshandler - the result handlerpublic Single<List<Integer>> rxBatchWithParams(String sqlStatement, List<JsonArray> args)
sqlStatement - sql statementargs - the prepared statement argumentspublic SQLConnection batchCallableWithParams(String sqlStatement, List<JsonArray> inArgs, List<JsonArray> outArgs, Handler<AsyncResult<List<Integer>>> handler)
sqlStatement - sql statementinArgs - the callable statement input argumentsoutArgs - the callable statement output argumentshandler - the result handlerpublic Single<List<Integer>> rxBatchCallableWithParams(String sqlStatement, List<JsonArray> inArgs, List<JsonArray> outArgs)
sqlStatement - sql statementinArgs - the callable statement input argumentsoutArgs - the callable statement output argumentspublic SQLConnection setTransactionIsolation(TransactionIsolation isolation, Handler<AsyncResult<Void>> handler)
isolation - the level of isolationhandler - the handler called when this operation completes.public Completable rxSetTransactionIsolation(TransactionIsolation isolation)
isolation - the level of isolationpublic SQLConnection getTransactionIsolation(Handler<AsyncResult<TransactionIsolation>> handler)
handler - the handler called when this operation completes.public Single<TransactionIsolation> rxGetTransactionIsolation()
public static SQLConnection newInstance(SQLConnection arg)
Copyright © 2020 Eclipse. All rights reserved.