exposed-r2dbc/org.jetbrains.exposed.v1.r2dbc.statements/R2dbcConnectionImpl

R2dbcConnectionImpl

class R2dbcConnectionImpl(    val connection: Publisher<out Connection>,     vendorDialect: String,     scope: R2dbcScope,     typeMapperRegistry: TypeMapperRegistry) : R2dbcExposedConnection<Publisher<out Connection>>

Class representing a wrapped R2DBC database Connection.

Constructors

Link copied to clipboard
constructor(connection: Publisher<out Connection>, vendorDialect: String, scope: R2dbcScope, typeMapperRegistry: TypeMapperRegistry)

Properties

Link copied to clipboard
open override val connection: Publisher<out Connection>

The underlying database connection object contained by this wrapper.

Functions

Link copied to clipboard
open suspend override fun close()

Closes the connection and releases any of its database and/or driver resources.

Link copied to clipboard
open suspend override fun commit()

Saves all changes since the last commit or rollback operation.

Link copied to clipboard
open suspend override fun executeInBatch(sqls: List<String>)

Sends a collection of SQL strings to the database for execution as a batch statement.

Link copied to clipboard
open suspend override fun getAutoCommit(): Boolean

Retrieves whether the connection is in auto-commit mode.

Link copied to clipboard
open suspend override fun getCatalog(): String

Retrieves the name of the connection's catalog.

Link copied to clipboard
open suspend override fun getReadOnly(): Boolean

Retrieves whether the connection is in read-only mode.

Link copied to clipboard
open suspend override fun getSchema(): String

Retrieves the name of the connection's schema.

Link copied to clipboard
open suspend override fun getTransactionIsolation(): IsolationLevel

Retrieves the transaction isolation level of the connection.

Link copied to clipboard
open suspend override fun isClosed(): Boolean

Whether the connection has been closed.

Link copied to clipboard
open suspend override fun <T> metadata(body: suspend R2dbcExposedDatabaseMetadata.() -> T): T

Calls the specified function body with an ExposedDatabaseMetadata implementation as its receiver and returns the retrieved metadata as a result.

Link copied to clipboard
open suspend override fun prepareStatement(sql: String, columns: Array<String>): R2dbcPreparedStatementImpl
open suspend override fun prepareStatement(sql: String, returnKeys: Boolean): R2dbcPreparedStatementImpl

Returns a precompiled sql statement stored as a PreparedStatementApi implementation.

Link copied to clipboard
open suspend override fun releaseSavepoint(savepoint: ExposedSavepoint)

Removes the specified savepoint.

Link copied to clipboard
open suspend override fun rollback()

Reverts all changes since the last commit or rollback operation.

open suspend override fun rollback(savepoint: ExposedSavepoint)

Reverts all changes since the specified savepoint was set.

Link copied to clipboard
open suspend override fun setAutoCommit(value: Boolean)

Sets whether the connection is in auto-commit mode or not.

Link copied to clipboard
open suspend override fun setCatalog(value: String)

Sets the name of the connection's catalog.

Link copied to clipboard
open suspend override fun setReadOnly(value: Boolean)

Set whether the connection is in read-only mode.

Link copied to clipboard
open suspend override fun setSavepoint(name: String): ExposedSavepoint

Sets and returns a new savepoint with the specified name.

Link copied to clipboard
open suspend override fun setTransactionIsolation(value: IsolationLevel)

Sets the transaction isolation level of the connection.