docs/api/exposed-r2dbc/org.jetbrains.exposed.v1.r2dbc.statements/-r2dbc-connection-impl/index.html
class R2dbcConnectionImpl(val connection: Publisher<out Connection>, vendorDialect: String, typeMapping: R2dbcTypeMapping) : R2dbcExposedConnection<Publisher<out Connection>>
Class representing a wrapped R2DBC database Connection.
Members
Link copied to clipboard
constructor(connection: Publisher<out Connection>, vendorDialect: String, typeMapping: R2dbcTypeMapping)
Link copied to clipboard
open override val connection: Publisher<out Connection>
The underlying database connection object contained by this wrapper.
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 R2dbcExposedDatabaseMetadata implementation as its receiver and returns the retrieved metadata from the database 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 an R2dbcPreparedStatementImpl 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 override fun setTransactionDefinition(definition: TransactionDefinition?)
Sets specific transaction properties to be used together when starting a transaction explicitly. Passing a null argument will force beginTransaction() to be invoked without any transaction definition.
Link copied to clipboard
open suspend override fun setTransactionIsolation(value: IsolationLevel)
Sets the transaction isolation level of the connection.
Generated by Dokka © 2026 Copyright