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

R2dbcTransaction

class R2dbcTransaction(connection: Connection, closeConnectionAfterTx: Boolean, val encoders: ValueEncoderRegistry, savepoint: String? = null, parent: PostgreSQLImpl.R2dbcTransaction? = null) : Transaction(source)

Constructors

R2dbcTransaction

constructor(connection: Connection, closeConnectionAfterTx: Boolean, encoders: ValueEncoderRegistry, savepoint: String? = null, parent: PostgreSQLImpl.R2dbcTransaction? = null)

Properties

open override val commited: Boolean

open override val encoders: ValueEncoderRegistry

open override val rollbacked: Boolean

open override val status: Transaction.Status

Functions

open fun assertIsOpen()

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

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

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

executeWithResult

open suspend fun executeWithResult(statement: Statement): Result<ExecuteResult>

open suspend fun executeWithResult(sql: String): Result<ExecuteResult>

open fun <T> fetch(statement: Statement, rowMapper: RowMapper<T>, fetchSize: Int): Flow<T>

open fun <T> fetch(sql: String, rowMapper: RowMapper<T>, fetchSize: Int): Flow<T>

open override fun fetch(statement: Statement, fetchSize: Int): Flow<ResultSet.Row>

open override fun fetch(sql: String, fetchSize: Int): Flow<ResultSet.Row>

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(statement: Statement): Result<ResultSet>

open suspend override fun fetchAll(sql: String): Result<ResultSet>

releaseSavepoint

open suspend fun releaseSavepoint(name: String): Result<Unit>

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

rollbackToSavepoint

open suspend fun rollbackToSavepoint(name: String): Result<Unit>

open suspend fun savepoint(name: String): Result<Unit>

open suspend fun <T> savepoint(name: String, f: suspend Transaction.() -> T): Result<T>