RecordQueries

class RecordQueries(driver: SqlDriver) : SuspendingTransacterImpl

Constructors

Link copied to clipboard
constructor(driver: SqlDriver)

Functions

Link copied to clipboard
fun changes(): ExecutableQuery<Long>
Link copied to clipboard
fun count(): Query<Long>
Link copied to clipboard
suspend fun deleteAllRecords(): Long
Link copied to clipboard
suspend fun deleteRecordByKey(key: String): Long
Link copied to clipboard
suspend fun insertOrUpdateRecord(key: String, chunk_index: Long, record: ByteArray, updated_date: Long): Long
Link copied to clipboard
fun selectRecordsFrom(lastKey: String, lastChunkIndex: Long, limit: Long): Query<SelectRecordsFrom>
fun <T : Any> selectRecordsFrom(lastKey: String, lastChunkIndex: Long, limit: Long, mapper: (key: String, chunk_index: Long, record: ByteArray) -> T): Query<T>
Link copied to clipboard
suspend fun setCacheSize(): Long
Link copied to clipboard
open suspend override fun transaction(noEnclosing: Boolean, body: suspend SuspendingTransactionWithoutReturn.() -> Unit)
Link copied to clipboard
open suspend override fun <R> transactionWithResult(noEnclosing: Boolean, bodyWithReturn: suspend SuspendingTransactionWithReturn<R>.() -> R): R
Link copied to clipboard
suspend fun trimByUpdatedDate(value: Long): Long