java.lang.Object
org.jooq.tools.r2dbc.DefaultConnection
- All Implemented Interfaces:
io.r2dbc.spi.Closeable
,io.r2dbc.spi.Connection
- Direct Known Subclasses:
LoggingConnection
A default R2DBC
Connection
implementation delegating all R2DBC
calls to an internal getDelegate().- Author:
- Lukas Eder
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionorg.reactivestreams.Publisher<Void>
org.reactivestreams.Publisher<Void>
beginTransaction
(io.r2dbc.spi.TransactionDefinition definition) org.reactivestreams.Publisher<Void>
close()
org.reactivestreams.Publisher<Void>
io.r2dbc.spi.Batch
org.reactivestreams.Publisher<Void>
createSavepoint
(String name) io.r2dbc.spi.Statement
createStatement
(String sql) io.r2dbc.spi.Connection
io.r2dbc.spi.ConnectionMetadata
io.r2dbc.spi.IsolationLevel
boolean
org.reactivestreams.Publisher<Void>
releaseSavepoint
(String name) org.reactivestreams.Publisher<Void>
org.reactivestreams.Publisher<Void>
org.reactivestreams.Publisher<Void>
setAutoCommit
(boolean autoCommit) org.reactivestreams.Publisher<Void>
setLockWaitTimeout
(Duration timeout) org.reactivestreams.Publisher<Void>
setStatementTimeout
(Duration timeout) org.reactivestreams.Publisher<Void>
setTransactionIsolationLevel
(io.r2dbc.spi.IsolationLevel isolationLevel) org.reactivestreams.Publisher<Boolean>
validate
(io.r2dbc.spi.ValidationDepth depth)
-
Constructor Details
-
DefaultConnection
public DefaultConnection(io.r2dbc.spi.Connection delegate)
-
-
Method Details
-
getDelegate
public io.r2dbc.spi.Connection getDelegate() -
beginTransaction
- Specified by:
beginTransaction
in interfaceio.r2dbc.spi.Connection
-
beginTransaction
public org.reactivestreams.Publisher<Void> beginTransaction(io.r2dbc.spi.TransactionDefinition definition) - Specified by:
beginTransaction
in interfaceio.r2dbc.spi.Connection
-
close
- Specified by:
close
in interfaceio.r2dbc.spi.Closeable
- Specified by:
close
in interfaceio.r2dbc.spi.Connection
-
commitTransaction
- Specified by:
commitTransaction
in interfaceio.r2dbc.spi.Connection
-
createBatch
public io.r2dbc.spi.Batch createBatch()- Specified by:
createBatch
in interfaceio.r2dbc.spi.Connection
-
createSavepoint
- Specified by:
createSavepoint
in interfaceio.r2dbc.spi.Connection
-
createStatement
- Specified by:
createStatement
in interfaceio.r2dbc.spi.Connection
-
isAutoCommit
public boolean isAutoCommit()- Specified by:
isAutoCommit
in interfaceio.r2dbc.spi.Connection
-
getMetadata
public io.r2dbc.spi.ConnectionMetadata getMetadata()- Specified by:
getMetadata
in interfaceio.r2dbc.spi.Connection
-
getTransactionIsolationLevel
public io.r2dbc.spi.IsolationLevel getTransactionIsolationLevel()- Specified by:
getTransactionIsolationLevel
in interfaceio.r2dbc.spi.Connection
-
releaseSavepoint
- Specified by:
releaseSavepoint
in interfaceio.r2dbc.spi.Connection
-
rollbackTransaction
- Specified by:
rollbackTransaction
in interfaceio.r2dbc.spi.Connection
-
rollbackTransactionToSavepoint
- Specified by:
rollbackTransactionToSavepoint
in interfaceio.r2dbc.spi.Connection
-
setAutoCommit
- Specified by:
setAutoCommit
in interfaceio.r2dbc.spi.Connection
-
setLockWaitTimeout
- Specified by:
setLockWaitTimeout
in interfaceio.r2dbc.spi.Connection
-
setStatementTimeout
- Specified by:
setStatementTimeout
in interfaceio.r2dbc.spi.Connection
-
setTransactionIsolationLevel
public org.reactivestreams.Publisher<Void> setTransactionIsolationLevel(io.r2dbc.spi.IsolationLevel isolationLevel) - Specified by:
setTransactionIsolationLevel
in interfaceio.r2dbc.spi.Connection
-
validate
- Specified by:
validate
in interfaceio.r2dbc.spi.Connection
-