driver/io.github.octaviusframework.driver.jdbc/OctaviusConnection

OctaviusConnection

internal class OctaviusConnection(val stream: PgStream, val registryKey: RegistryKey, maxParameterWriterCapacity: Int?, initialParameterWriterCapacity: Int?, logParameterValues: Boolean) : Connection

Represents a connection to a database within the Octavius Framework. It implements the standard JDBC Connection interface but overrides certain behaviors to fit the framework's architecture.

Constructors

OctaviusConnection

constructor(stream: PgStream, registryKey: RegistryKey, maxParameterWriterCapacity: Int?, initialParameterWriterCapacity: Int?, logParameterValues: Boolean)

Properties

autoCommit

open override var autoCommit: Boolean

catalog

open override var catalog: String

clientInfo

open override var clientInfo: Properties

holdability

open override var holdability: Int

isClosed

open override val isClosed: Boolean

isClosedFlag

@Volatile

var isClosedFlag: Boolean

isReadOnly

open override var isReadOnly: Boolean

metaData

open override val metaData: DatabaseMetaData

networkTimeout

open override val networkTimeout: Int

queryExecutor

val queryExecutor: QueryExecutor

registryKey

internal val registryKey: RegistryKey

schema

open override var schema: String

stream

internal val stream: PgStream

transactionIsolation

open override var transactionIsolation: Int

transactionState

val transactionState: TransactionState

typeMap

open override var typeMap: MutableMap<String, Class<*>>

typeRegistry

val typeRegistry: TypeRegistry

warnings

open override val warnings: SQLWarning?

Functions

abort

open override fun abort(executor: Executor?)

beginRequest

open fun beginRequest()

cancelQuery

fun cancelQuery()

checkClosed

fun checkClosed()

clearWarnings

open override fun clearWarnings()

open override fun close()

commit

open override fun commit()

createArrayOf

open override fun createArrayOf(typeName: String?, elements: Array<out Any>?): Array

createBlob

open override fun createBlob(): Blob

createClob

open override fun createClob(): Clob

createNClob

open override fun createNClob(): NClob

createSQLXML

open override fun createSQLXML(): SQLXML

createStatement

open override fun createStatement(): Statement

open override fun createStatement(resultSetType: Int, resultSetConcurrency: Int): Statement

open override fun createStatement(resultSetType: Int, resultSetConcurrency: Int, resultSetHoldability: Int): Statement

createStruct

open override fun createStruct(typeName: String?, attributes: Array<out Any>?): Struct

endRequest

open fun endRequest()

getAutoCommit

open override fun getAutoCommit(): Boolean

getCatalog

open override fun getCatalog(): String

getClientInfo

open override fun getClientInfo(): Properties

open override fun getClientInfo(name: String?): String

getHoldability

open override fun getHoldability(): Int

getMetaData

open override fun getMetaData(): DatabaseMetaData

getNetworkTimeout

open override fun getNetworkTimeout(): Int

getOctaviusSession

fun Connection.getOctaviusSession(ownsConnection: Boolean = true): OctaviusSession

Retrieves a new OctaviusSession from this Connection.

getSchema

open override fun getSchema(): String

getSearchPath

fun getSearchPath(): List<String>

Retrieves the current search path. Since we enforce PostgreSQL 18+, this value is always kept up-to-date automatically via ParameterStatus messages from the server.

getTransactionIsolation

open override fun getTransactionIsolation(): Int

getTypeMap