IPostgresSQL

Types

abstract suspend fun acquire(): Result<Connection>

abstract suspend fun begin(): Result<Transaction>

abstract suspend fun close(): Result<Unit>

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

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

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

abstract suspend fun fetchAll(sql: String): 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>>

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

Listens for notifications on a specified PostgreSQL channel and executes a callback for each received notification.

abstract suspend fun listen(channels: List<String>, f: suspend (Notification) -> Unit)

Listens for notifications on specified PostgreSQL channels and executes a callback for each received notification.

abstract suspend fun migrate(supplier: () -> List<MigrationFile>, table: String, schema: String?, createSchema: Boolean, afterStatementExecution: suspend (Statement, Duration) -> Unit, afterFileMigration: suspend (Migration, Duration) -> Unit): Result<Migrator.Results>

abstract suspend fun migrate(path: String, table: String, schema: String?, createSchema: Boolean, afterStatementExecution: suspend (Statement, Duration) -> Unit, afterFileMigration: suspend (Migration, Duration) -> Unit): Result<Migrator.Results>

abstract suspend fun migrate(files: List<MigrationFile>, table: String, schema: String?, createSchema: Boolean, afterStatementExecution: suspend (Statement, Duration) -> Unit, afterFileMigration: suspend (Migration, Duration) -> Unit): Result<Migrator.Results>

abstract suspend fun notify(channel: String, value: String)

Publishes a notification to a specified PostgreSQL channel.

abstract fun poolIdleSize(): Int

abstract fun poolSize(): Int

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

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

Validates the name of a PostgreSQL channel to ensure it adheres to the naming rules.