DataAccess

Main entry point to the data layer, offering a consistent API for database interaction.

This facade enables:

Executing single queries (CRUD) in auto-commit mode, through QueryOperations implementation.
Executing atomic, complex operations within managed transaction blocks.
Running predefined, declarative transaction plans.

Functions

Creates a new PgChannelListener backed by a dedicated database connection.

Starts building a DELETE query.

Executes a sequence of operations (plan) within a single, atomic transaction.

Starts building an INSERT query.

abstract fun notify(channel: String, payload: String? = null): DataResult<Unit>

Sends a notification to the given PostgreSQL channel via pg_notify.

Enables execution of a raw SQL query.

abstract fun select(vararg columns: String): SelectQueryBuilder

Starts building a SELECT query.

abstract fun <T> transaction(propagation: TransactionPropagation = TransactionPropagation.REQUIRED, block: (tx: QueryOperations) -> DataResult<T>): DataResult<T>

Executes the given block of code within a new, managed transaction.

Starts building an UPDATE query.