persistence/com.wire.kalium.persistence.db/AppleSuspensionSqlDriver

AppleSuspensionSqlDriver

internal class AppleSuspensionSqlDriver(delegate: SqlDriver, databaseKind: String, diagnostics: DatabaseOperationDiagnostics = SuspensionDatabaseOperations) : SqlDriver

Observes API operations, including standalone reads outside account write admission. These are not VFS lock counts. Native synchronous results stay synchronous. Async results remain outstanding until await completes; a transaction stays outstanding until SQLDelight's commit/rollback callback, or an observed post-commit listener failure. If native transaction end fails, its missing end remains visible rather than claiming release.

Constructors

constructor(delegate: SqlDriver, databaseKind: String, diagnostics: DatabaseOperationDiagnostics = SuspensionDatabaseOperations)

Functions

addListener

open override fun addListener(vararg queryKeys: String, listener: Query.Listener)

checkFKViolations

actual suspend fun SqlDriver.checkFKViolations(): Boolean

expect suspend fun SqlDriver.checkFKViolations(): Boolean

actual suspend fun SqlDriver.checkFKViolations(): Boolean

open override fun close()

currentTransaction

open override fun currentTransaction(): Transacter.Transaction?

execute

open override fun execute(identifier: Int?, sql: String, parameters: Int, binders: SqlPreparedStatement.() -> Unit?): QueryResult<Long>

executeQuery

open override fun <R> executeQuery(identifier: Int?, sql: String, mapper: (SqlCursor) -> QueryResult<R>, parameters: Int, binders: SqlPreparedStatement.() -> Unit?): QueryResult<R>

migrate

actual suspend fun SqlDriver.migrate(sqlSchema: SqlSchema<QueryResult.AsyncValue<Unit>>): Boolean

expect suspend fun SqlDriver.migrate(sqlSchema: SqlSchema<QueryResult.AsyncValue<Unit>>): Boolean

actual suspend fun SqlDriver.migrate(sqlSchema: SqlSchema<QueryResult.AsyncValue<Unit>>): Boolean

migrateSchema

internal suspend fun SqlDriver.migrateSchema(sqlSchema: SqlSchema<QueryResult.AsyncValue<Unit>>): Boolean

newTransaction

open override fun newTransaction(): QueryResult<Transacter.Transaction>

notifyListeners

open override fun notifyListeners(vararg queryKeys: String)

removeListener

open override fun removeListener(vararg queryKeys: String, listener: Query.Listener)