runtime/io.github.sufarook.kiln.runtime/KilnDriver

KilnDriver

interface KilnDriver : AutoCloseable

Inheritors

BaseKilnDriver

Functions

addListener

abstract fun addListener(vararg queryKeys: String, listener: KilnListener)

abstract override fun close()

currentTransaction

abstract fun currentTransaction(): KilnTransaction?

execute

abstract fun execute(identifier: Int?, sql: String, parameters: Int, binders: KilnPreparedStatement.() -> Unit? = null): Long

executeQuery

abstract fun <R> executeQuery(identifier: Int?, sql: String, mapper: (KilnCursor) -> R, parameters: Int, binders: KilnPreparedStatement.() -> Unit? = null): R

newTransaction

abstract fun newTransaction(): KilnTransaction

notifyListeners

abstract fun notifyListeners(vararg queryKeys: String)

notifyOrDefer

suspend fun KilnDriver.notifyOrDefer(tableName: String)

Inside a transaction, records tableName as dirty so its notification is sent once, after the outermost commit — or not at all if the transaction rolls back. Outside a transaction, calls KilnDriver.notifyListeners immediately (preserving the existing per-operation behaviour).

removeListener

abstract fun removeListener(vararg queryKeys: String, listener: KilnListener)

withTransaction

suspend fun KilnDriver.withTransaction(context: CoroutineContext = Dispatchers.Default, block: suspend () -> Unit)

Executes block inside a single SQLite transaction.

withTransactionAwareContext

suspend fun <T> KilnDriver.withTransactionAwareContext(context: CoroutineContext, block: suspend CoroutineScope.() -> T): T

Runs block like withContext(context, block), unless a transaction is open: