PgMqDbAdapterImpl

Constructors

constructor(pg: IPostgresSQL)

open suspend override fun begin(): Result<Transaction>

open suspend fun execute(statement: Statement): Result<Long>

open suspend override fun execute(sql: String): Result<Long>

open suspend fun fetchAll(statement: Statement): Result<ResultSet>

open suspend fun <T> fetchAll(statement: Statement, rowMapper: RowMapper<T>): Result<List<T>>

open suspend fun <T> fetchAll(sql: String, rowMapper: RowMapper<T>): Result<List<T>>

open suspend override fun fetchAll(sql: String): Result<ResultSet>

open suspend override fun listen(channel: String, f: suspend (Notification) -> Unit)

open suspend fun <T> transaction(f: suspend Transaction.() -> T): T

open suspend fun <T> transactionCatching(f: suspend Transaction.() -> T): Result<T>