selekt-java/com.bloomberg.selekt/SQLDatabase

SQLDatabase

@ThreadSafe

class SQLDatabase( val path: String, sqlite: SQLite, configuration: DatabaseConfiguration, key: ByteArray?, random: IRandom = CommonThreadLocalRandom) : SharedCloseable, IDatabase

The use of ThreadLocal underpins SQLDatabase's thread-safety.

A thread can acquire at most one connection session per database instance. Sessions hold at most one connection at any given time, and exclusively. Sessions control all access to a database's connections and each session is thread-bound. This prevents two threads from ever sharing a single connection.

This is the same strategy Google employs in the Android SDK.

Constructors

SQLDatabase

constructor(path: String, sqlite: SQLite, configuration: DatabaseConfiguration, key: ByteArray?, random: IRandom = CommonThreadLocalRandom)

Properties

inTransaction

open override val inTransaction: Boolean

isCurrentThreadSessionActive

val isCurrentThreadSessionActive: Boolean

path

val path: String

version

open override var version: Int

Functions

batch

fun batch(sql: String, bindArgs: Sequence<Array<out Any?>>): Int

beginExclusiveTransaction

open override fun beginExclusiveTransaction()

beginExclusiveTransactionWithListener

open override fun beginExclusiveTransactionWithListener(listener: SQLTransactionListener)

beginImmediateTransaction

open override fun beginImmediateTransaction()

beginImmediateTransactionWithListener

open override fun beginImmediateTransactionWithListener(listener: SQLTransactionListener)

abstract override fun close()

compileStatement

open override fun compileStatement(sql: String, bindArgs: Array<out Any?>?): ISQLStatement

delete

open override fun delete(table: String, whereClause: String, whereArgs: Array<out Any?>): Int

endTransaction

open override fun endTransaction()

exec

open override fun exec(sql: String, bindArgs: Array<out Any?>?)

execute

fun <T> execute(readOnly: Boolean, block: SQLDatabase.() -> T): T

insert

open override fun insert(table: String, values: IContentValues, conflictAlgorithm: IConflictAlgorithm): Long

isOpen

abstract fun isOpen(): Boolean

pragma

fun pragma(key: String): String

fun pragma(key: String, value: Any): String?

query

open override fun query(query: ISQLQuery): ICursor

open override fun query(sql: String, selectionArgs: Array<out Any?>): ICursor

open override fun query( distinct: Boolean, table: String, columns: Array<out String>, selection: String, selectionArgs: Array<out Any?>, groupBy: String?, having: String?, orderBy: String?, limit: Int?): ICursor

readFromBlob

fun readFromBlob(name: String, table: String, column: String, row: Long, offset: Int, limit: Int, stream: OutputStream)

releaseMemory

fun releaseMemory(priority: Priority)

setTransactionSuccessful

open override fun setTransactionSuccessful()

sizeOfBlob

fun sizeOfBlob(name: String, table: String, column: String, row: Long): Int

transact

fun <T> transact(transactionMode: SQLiteTransactionMode = SQLiteTransactionMode.EXCLUSIVE, block: SQLDatabase.() -> T): T

fun <D, T> transact(database: D, transactionMode: SQLiteTransactionMode = SQLiteTransactionMode.EXCLUSIVE, block: D.() -> T): T

update

open override fun update( table: String, values: IContentValues, whereClause: String, whereArgs: Array<out Any?>, conflictAlgorithm: IConflictAlgorithm): Int

upsert

open override fun upsert(table: String, values: IContentValues, columns: Array<out String>, update: String): Long

writeToBlob

fun writeToBlob(name: String, table: String, column: String, row: Long, offset: Int, stream: InputStream)

yieldTransaction

open override fun yieldTransaction(): Boolean

open override fun yieldTransaction(pauseMillis: Long): Boolean

SQLDatabase

See also

Constructors

Properties

Functions