kotlin-common-vertx/com.huanshankeji.vertx.sqlclient

Package-level declarations

Functions

setUpConventionally

fun SqlConnectOptions.setUpConventionally()

Optimized for throughput.

sortDataAndExecuteBatch

fun <QueryResultT, DataT, SelectorResultT : Comparable<SelectorResultT>> PreparedQuery<QueryResultT>.sortDataAndExecuteBatch(dataList: List<DataT>, selector: (DataT) -> SelectorResultT, toTuple: DataT.() -> Tuple): Future<QueryResultT>

There can easily be deadlocks when batch-updating data concurrently in multiple event loops if they are overlapped and unsorted.

sortTuplesAndExecuteBatch

inline fun <QueryResultT, SelectorResultT : Comparable<SelectorResultT>> PreparedQuery<QueryResultT>.sortTuplesAndExecuteBatch(batch: List<Tuple>, crossinline selector: (Tuple) -> SelectorResultT): Future<QueryResultT>

inline fun <QueryResultT, SelectorResultT : Comparable<SelectorResultT>> PreparedQuery<QueryResultT>.sortTuplesAndExecuteBatch(batch: List<Tuple>, selectorPosition: Int): Future<QueryResultT>

fun <QueryResultT> PreparedQuery<QueryResultT>.sortTuplesAndExecuteBatch(batch: List<Tuple>, selectorPositions: List<Int>): Future<QueryResultT>

fun Tuple.toList(): List<Any>

Converts a Tuple to a List.

withCoConnectHandler

fun ClientBuilder<*>.withCoConnectHandler(handler: suspend (SqlConnection) -> Unit): ClientBuilder<out Any>

A coroutine variant of ClientBuilder.withConnectHandler. With this function, you don't need to call SqlConnection.close in handler.