exposed-jdbc/src/main/kotlin/org/jetbrains/exposed/v1/jdbc/transactions/Transactions.kt [43:77]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - val currentStatement = transaction.currentStatement transaction.rollbackLoggingException { exposedLogger.warn( "Transaction rollback failed: ${it.message}. Statement: $currentStatement", it ) } throw cause } catch (cause: Throwable) { if (shouldCommit) { val currentStatement = transaction.currentStatement transaction.rollbackLoggingException { exposedLogger.warn( "Transaction rollback failed: ${it.message}. Statement: $currentStatement", it ) } } throw cause } } /** * Resolves the database to use for a transaction. * * Resolution order: * 1. The explicitly provided [db] parameter * 2. The database from the current transaction (if within an existing transaction) * 3. The current default database from [TransactionManager.primaryDatabase] * * @param db Optional database explicitly specified by the caller * @return The resolved database instance * @throws IllegalStateException If no database can be resolved */ @OptIn(InternalApi::class) - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - exposed-r2dbc/src/main/kotlin/org/jetbrains/exposed/v1/r2dbc/transactions/Transactions.kt [44:78]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - val currentStatement = transaction.currentStatement transaction.rollbackLoggingException { exposedLogger.warn( "Transaction rollback failed: ${it.message}. Statement: $currentStatement", it ) } throw cause } catch (cause: Throwable) { if (shouldCommit) { val currentStatement = transaction.currentStatement transaction.rollbackLoggingException { exposedLogger.warn( "Transaction rollback failed: ${it.message}. Statement: $currentStatement", it ) } } throw cause } } /** * Resolves the R2DBC database to use for a transaction. * * Resolution order: * 1. The explicitly provided [db] parameter * 2. The database from the current transaction (if within an existing transaction) * 3. The current default database from [TransactionManager.primaryDatabase] * * @param db Optional database explicitly specified by the caller * @return The resolved database instance * @throws IllegalStateException If no database can be resolved */ @OptIn(InternalApi::class) - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -