class AsyncSQLClient extends SQLClient
Represents an asynchronous SQL client
- Alphabetic
- By Inheritance
- AsyncSQLClient
- SQLClient
- SQLOperations
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Instance Constructors
- new AsyncSQLClient(_asJava: AnyRef)
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
asJava: AnyRef
- Definition Classes
- SQLClient → SQLOperations
-
def
call(sql: String, handler: Handler[AsyncResult[ResultSet]]): SQLClient
Calls the given SQL
PROCEDURE
which returns the result from the procedure.Calls the given SQL
PROCEDURE
which returns the result from the procedure. * @param sql the SQL to execute. For example{call getEmpName`
.- handler
the handler which is called once the operation completes. It will return a
ResultSet
.
- Definition Classes
- SQLClient → SQLOperations
-
def
callFuture(sql: String): Future[ResultSet]
Like call but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
Like call but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
- Definition Classes
- SQLClient → SQLOperations
-
def
callWithParams(sql: String, params: JsonArray, outputs: JsonArray, handler: Handler[AsyncResult[ResultSet]]): SQLClient
Calls the given SQL
PROCEDURE
which returns the result from the procedure.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"]
* @param 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.
- handler
the handler which is called once the operation completes. It will return a
ResultSet
.
- Definition Classes
- SQLClient → SQLOperations
-
def
callWithParamsFuture(sql: String, params: JsonArray, outputs: JsonArray): Future[ResultSet]
Like callWithParams but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
Like callWithParams but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
- Definition Classes
- SQLClient → SQLOperations
-
def
clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )
-
def
close(): Unit
Close the client
Close the client
- Definition Classes
- SQLClient
-
def
close(handler: Handler[AsyncResult[Unit]]): Unit
Close the client and release all resources.
Close the client and release all resources. Call the handler when close is complete. * @param handler the handler that will be called when close is complete
- Definition Classes
- SQLClient
-
def
closeFuture(): Future[Unit]
Like close but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
finalize(): Unit
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
def
getConnection(handler: Handler[AsyncResult[SQLConnection]]): SQLClient
Returns a connection that can be used to perform SQL operations on.
Returns a connection that can be used to perform SQL operations on. It's important to remember to close the connection when you are done, so it is returned to the pool. * @param handler the handler which is called when the
JdbcConnection
object is ready for use.- Definition Classes
- SQLClient
-
def
getConnectionFuture(): Future[SQLConnection]
Like getConnection but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
Like getConnection but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
- Definition Classes
- SQLClient
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
def
query(sql: String, handler: Handler[AsyncResult[ResultSet]]): SQLClient
Execute a single SQL statement, this method acquires a connection from the the pool and executes the SQL statement and returns it back after the execution.
Execute a single SQL statement, this method acquires a connection from the the pool and executes the SQL statement and returns it back after the execution. * @param sql the statement to execute
- handler
the result handler
- returns
self
- Definition Classes
- SQLClient → SQLOperations
-
def
queryFuture(sql: String): Future[ResultSet]
Like query but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
Like query but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
- Definition Classes
- SQLClient → SQLOperations
-
def
querySingle(sql: String, handler: Handler[AsyncResult[Option[JsonArray]]]): SQLOperations
Execute a one shot SQL statement that returns a single SQL row.
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
- handler
the result handler
- returns
self
- Definition Classes
- AsyncSQLClient → SQLClient → SQLOperations
-
def
querySingleFuture(sql: String): Future[Option[JsonArray]]
Like querySingle but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
Like querySingle but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
- Definition Classes
- AsyncSQLClient → SQLClient → SQLOperations
-
def
querySingleWithParams(sql: String, arguments: JsonArray, handler: Handler[AsyncResult[Option[JsonArray]]]): SQLOperations
Execute a one shot SQL statement with arguments that returns a single SQL row.
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
- arguments
the arguments
- handler
the result handler
- returns
self
- Definition Classes
- AsyncSQLClient → SQLClient → SQLOperations
-
def
querySingleWithParamsFuture(sql: String, arguments: JsonArray): Future[Option[JsonArray]]
Like querySingleWithParams but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
Like querySingleWithParams but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
- Definition Classes
- AsyncSQLClient → SQLClient → SQLOperations
-
def
queryStream(sql: String, handler: Handler[AsyncResult[SQLRowStream]]): SQLClient
Executes the given SQL
SELECT
statement which returns the results of the query as a read stream.Executes the given SQL
SELECT
statement which returns the results of the query as a read stream. * @param sql the SQL to execute. For exampleSELECT * FROM table ...
.- handler
the handler which is called once the operation completes. It will return a
SQLRowStream
.
- Definition Classes
- SQLClient → SQLOperations
-
def
queryStreamFuture(sql: String): Future[SQLRowStream]
Like queryStream but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
Like queryStream but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
- Definition Classes
- SQLClient → SQLOperations
-
def
queryStreamWithParams(sql: String, params: JsonArray, handler: Handler[AsyncResult[SQLRowStream]]): SQLClient
Executes the given SQL
SELECT
statement which returns the results of the query as a read stream.Executes the given SQL
SELECT
statement which returns the results of the query as a read stream. * @param sql the SQL to execute. For exampleSELECT * 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
.
- Definition Classes
- SQLClient → SQLOperations
-
def
queryStreamWithParamsFuture(sql: String, params: JsonArray): Future[SQLRowStream]
Like queryStreamWithParams but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
Like queryStreamWithParams but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
- Definition Classes
- SQLClient → SQLOperations
-
def
queryWithParams(sql: String, arguments: JsonArray, handler: Handler[AsyncResult[ResultSet]]): SQLClient
Execute a single SQL prepared statement, this method acquires a connection from the the pool and executes the SQL prepared statement and returns it back after the execution.
Execute a single SQL prepared statement, this method acquires a connection from the the pool and executes the SQL prepared statement and returns it back after the execution. * @param sql the statement to execute
- arguments
the arguments to the statement
- handler
the result handler
- returns
self
- Definition Classes
- SQLClient → SQLOperations
-
def
queryWithParamsFuture(sql: String, arguments: JsonArray): Future[ResultSet]
Like queryWithParams but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
Like queryWithParams but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
- Definition Classes
- SQLClient → SQLOperations
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
def
update(sql: String, handler: Handler[AsyncResult[UpdateResult]]): SQLClient
Executes the given SQL statement which may be an
INSERT
,UPDATE
, orDELETE
statement.Executes the given SQL statement which may be an
INSERT
,UPDATE
, orDELETE
statement. * @param sql the SQL to execute. For exampleINSERT INTO table ...
- handler
the handler which is called once the operation completes.
- Definition Classes
- SQLClient → SQLOperations
-
def
updateFuture(sql: String): Future[UpdateResult]
Like update but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
Like update but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
- Definition Classes
- SQLClient → SQLOperations
-
def
updateWithParams(sql: String, params: JsonArray, handler: Handler[AsyncResult[UpdateResult]]): SQLClient
Executes the given prepared statement which may be an
INSERT
,UPDATE
, orDELETE
statement with the given parameters * @param sql the SQL to execute.Executes the given prepared statement which may be an
INSERT
,UPDATE
, orDELETE
statement with the given parameters * @param sql the SQL to execute. For exampleINSERT INTO table ...
- params
these are the parameters to fill the statement.
- handler
the handler which is called once the operation completes.
- Definition Classes
- SQLClient → SQLOperations
-
def
updateWithParamsFuture(sql: String, params: JsonArray): Future[UpdateResult]
Like updateWithParams but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
Like updateWithParams but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
- Definition Classes
- SQLClient → SQLOperations
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )