postgres-native-sqldelight-driver/app.softwork.sqldelight.postgresdriver/PostgresNativeDriver

PostgresNativeDriver

class PostgresNativeDriver(conn: CPointer<PGconn>, listenerSupport: ListenerSupport) : SqlDriver

Constructors

PostgresNativeDriver

constructor(conn: CPointer<PGconn>, listenerSupport: ListenerSupport)

Functions

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

open override fun close()

fun copy(stdin: Sequence<String>): Long

Each element of stdin can be up to 2 GB.

currentTransaction

open override fun currentTransaction(): Transacter.Transaction?

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

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

executeQueryAsFlow

fun <R> executeQueryAsFlow(identifier: Int?, sql: String, mapper: suspend (PostgresCursor) -> R, parameters: Int, fetchSize: Int = 10, binders: PostgresPreparedStatement.() -> Unit?): Flow<R>

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

notifyListeners

open override fun notifyListeners(vararg queryKeys: String)

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