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

Package-level declarations

Types

ByteArrayEncoder

object ByteArrayEncoder : ValueEncoder<ByteArray>

PostgreSQL-specific ValueEncoder for ByteArray.

IPostgresSQL

interface IPostgresSQL : Driver, Migrator.Driver

Notification

data class Notification(val channel: String, val value: ResultSet.Row.Column)

Represents a notification received from a PostgreSQL listen/notify channel.

PostgreSQL

class PostgreSQL(url: String, username: String, password: String, options: ConnectionPool.Options = ConnectionPool.Options(), val encoders: ValueEncoderRegistry = ValueEncoderRegistry()) : IPostgresSQL

PostgreSQL class provides mechanisms to interact with a PostgreSQL database. It implements Driver, Driver.Pool, and Driver.Transactional interfaces, offering functionalities such as connection pooling, executing queries, fetching data, and handling transactions.

PostgreSQLImpl

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

Properties

val fn: CPointer<CFunction<(CValue<Sqlx4kPostgresPtr>, CPointer<Sqlx4kPostgresResult>?) -> Unit>>

Functions

postgreSQL

expect fun postgreSQL(url: String, username: String, password: String, options: ConnectionPool.Options = ConnectionPool.Options(), encoders: ValueEncoderRegistry = ValueEncoderRegistry()): IPostgresSQL

actual fun postgreSQL(url: String, username: String, password: String, options: ConnectionPool.Options, encoders: ValueEncoderRegistry): IPostgresSQL

rowsAffectedOrError

fun CPointer<Sqlx4kPostgresResult>?.rowsAffectedOrError(): Long

rtOrError

fun CPointer<Sqlx4kPostgresResult>?.rtOrError(): CPointer<out CPointed>

sqlx

inline suspend fun sqlx(crossinline operation: (continuationPtr: CPointer<out CPointed>) -> Unit): CPointer<Sqlx4kPostgresResult>?

throwIfError

fun CPointer<Sqlx4kPostgresResult>?.throwIfError()

fun Sqlx4kPostgresResult.throwIfError()

toResultSet

fun Sqlx4kPostgresResult.toResultSet(): ResultSet

use

inline fun <T> CPointer<Sqlx4kPostgresResult>?.use(block: (Sqlx4kPostgresResult) -> T): T