vertx / io.vertx.kotlin.ext.sql / io.vertx.ext.sql.SQLOperations

Extensions for io.vertx.ext.sql.SQLOperations

callAwait

suspend fun SQLOperations.callAwait(sql: String): ResultSet

Calls the given SQL PROCEDURE which returns the result from the procedure.

callWithParamsAwait

suspend fun SQLOperations.callWithParamsAwait(sql: String, params: JsonArray, outputs: JsonArray): ResultSet

Calls the given SQL PROCEDURE which returns the result from the procedure.

queryAwait

suspend fun SQLOperations.queryAwait(sql: String): ResultSet

Executes the given SQL SELECT statement which returns the results of the query.

querySingleAwait

suspend fun SQLOperations.querySingleAwait(sql: String): JsonArray?

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.

querySingleWithParamsAwait

suspend fun SQLOperations.querySingleWithParamsAwait(sql: String, arguments: JsonArray): JsonArray?

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.

queryStreamAwait

suspend fun SQLOperations.queryStreamAwait(sql: String): SQLRowStream

Executes the given SQL SELECT statement which returns the results of the query as a read stream.

queryStreamWithParamsAwait

suspend fun SQLOperations.queryStreamWithParamsAwait(sql: String, params: JsonArray): SQLRowStream

Executes the given SQL SELECT statement which returns the results of the query as a read stream.

queryWithParamsAwait

suspend fun SQLOperations.queryWithParamsAwait(sql: String, params: JsonArray): ResultSet

Executes the given SQL SELECT prepared statement which returns the results of the query.

updateAwait

suspend fun SQLOperations.updateAwait(sql: String): UpdateResult

Executes the given SQL statement which may be an INSERT, UPDATE, or DELETE statement.

updateWithParamsAwait

suspend fun SQLOperations.updateWithParamsAwait(sql: String, params: JsonArray): UpdateResult

Executes the given prepared statement which may be an INSERT, UPDATE, or DELETE statement with the given parameters