sqlx4k-postgres/io.github.smyrgeorge.sqlx4k.postgres/PostgreSQLImpl

PostgreSQLImpl

class PostgreSQLImpl(pool: ConnectionPool, connectionFactory: PostgresqlConnectionFactory, val encoders: ValueEncoderRegistry = ValueEncoderRegistry()) : IPostgresSQL(source)

Constructors

PostgreSQLImpl

constructor(pool: ConnectionPool, connectionFactory: PostgresqlConnectionFactory, encoders: ValueEncoderRegistry = ValueEncoderRegistry())

Types

Companion

object Companion

R2dbcConnection

class R2dbcConnection(connection: Connection, val encoders: ValueEncoderRegistry) : Connection

R2dbcTransaction

class R2dbcTransaction(connection: Connection, closeConnectionAfterTx: Boolean, val encoders: ValueEncoderRegistry) : Transaction

Properties

encoders

open override val encoders: ValueEncoderRegistry

Functions

acquire

open suspend override fun acquire(): Result<Connection>

begin

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

open suspend override fun close(): Result<Unit>

execute

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

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

fetchAll

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>

listen

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

Listens for notifications from a specified PostgreSQL channel.

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

Listens for notifications from the specified PostgreSQL channels.

migrate

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

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

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

notify

open suspend override fun notify(channel: String, value: String)

Sends a notification to a specific PostgreSQL channel with the given value.

poolIdleSize

open override fun poolIdleSize(): Int

poolSize

open override fun poolSize(): Int

transaction

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

transactionCatching

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

validateChannelName

open fun validateChannelName(channel: String)

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