core/io.github.octaviusframework.db.core/DatabaseAccess

DatabaseAccess

internal class DatabaseAccess(jdbcTemplate: JdbcTemplate, transactionProvider: JdbcTransactionProvider, typeRegistry: TypeRegistry, kotlinToPostgresConverter: KotlinToPostgresConverter, listenerConnectionFactory: () -> Connection, val json: Json, onClose: () -> Unit? = null) : DataAccess

Constructors

constructor(jdbcTemplate: JdbcTemplate, transactionProvider: JdbcTransactionProvider, typeRegistry: TypeRegistry, kotlinToPostgresConverter: KotlinToPostgresConverter, listenerConnectionFactory: () -> Connection, json: Json, onClose: () -> Unit? = null)

Types

object Companion

Properties

enumSerializers

open override val enumSerializers: SerializersModule

open override val json: Json

Functions

open override fun close()

createChannelListener

open override fun createChannelListener(): PgChannelListener

open override fun deleteFrom(table: String): DeleteQueryBuilder

executeTransactionPlan

open override fun executeTransactionPlan(plan: TransactionPlan, propagation: TransactionPropagation, isolation: IsolationLevel, readOnly: Boolean, statementTimeout: Duration?, transactionTimeout: Duration?): DataResult<TransactionPlanResult>

open override fun insertInto(table: String): InsertQueryBuilder

open override fun notify(channel: String, payload: String?): DataResult<Unit>

open override fun notifyStep(channel: String, payload: String?): TransactionStep<Unit>

open override fun rawQuery(sql: String): RawQueryBuilder

open override fun select(vararg columns: String): SelectQueryBuilder

open override fun toDynamicDto(value: Any, json: Json?): DynamicDto

open override fun <T> transaction(propagation: TransactionPropagation, isolation: IsolationLevel, readOnly: Boolean, statementTimeout: Duration?, transactionTimeout: Duration?, block: QueryOperations.() -> DataResult<T>): DataResult<T>

open override fun update(table: String): UpdateQueryBuilder