core/org.octavius.database/DatabaseAccess

DatabaseAccess

internal class DatabaseAccess(jdbcTemplate: JdbcTemplate, transactionManager: DataSourceTransactionManager, typeRegistry: TypeRegistry, kotlinToPostgresConverter: KotlinToPostgresConverter, listenerConnectionFactory: () -> Connection) : DataAccess

Constructors

constructor(jdbcTemplate: JdbcTemplate, transactionManager: DataSourceTransactionManager, typeRegistry: TypeRegistry, kotlinToPostgresConverter: KotlinToPostgresConverter, listenerConnectionFactory: () -> Connection)

Types

object Companion

Properties

transactionPlanExecutor

val transactionPlanExecutor: TransactionPlanExecutor

Functions

createChannelListener

open override fun createChannelListener(): PgChannelListener

open override fun deleteFrom(table: String): DeleteQueryBuilder

executeTransactionPlan

open override fun executeTransactionPlan(plan: TransactionPlan, propagation: TransactionPropagation): DataResult<TransactionPlanResult>

open override fun insertInto(table: String): InsertQueryBuilder

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

open override fun rawQuery(sql: String): RawQueryBuilder

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

open override fun <T> transaction(propagation: TransactionPropagation, block: (tx: QueryOperations) -> DataResult<T>): DataResult<T>

open override fun update(table: String): UpdateQueryBuilder