java.lang.Object
org.jooq.tools.r2dbc.DefaultConnection
org.jooq.tools.r2dbc.LoggingConnection
- All Implemented Interfaces:
io.r2dbc.spi.Closeable
,io.r2dbc.spi.Connection
An R2DBC
Connection
proxy that logs all statements that are prepared
or executed using it.- 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) 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) Methods inherited from class org.jooq.tools.r2dbc.DefaultConnection
getDelegate, getMetadata, getTransactionIsolationLevel, isAutoCommit
-
Constructor Details
-
LoggingConnection
public LoggingConnection(io.r2dbc.spi.Connection delegate)
-
-
Method Details
-
beginTransaction
- Specified by:
beginTransaction
in interfaceio.r2dbc.spi.Connection
- Overrides:
beginTransaction
in classDefaultConnection
-
beginTransaction
public org.reactivestreams.Publisher<Void> beginTransaction(io.r2dbc.spi.TransactionDefinition definition) - Specified by:
beginTransaction
in interfaceio.r2dbc.spi.Connection
- Overrides:
beginTransaction
in classDefaultConnection
-
close
- Specified by:
close
in interfaceio.r2dbc.spi.Closeable
- Specified by:
close
in interfaceio.r2dbc.spi.Connection
- Overrides:
close
in classDefaultConnection
-
commitTransaction
- Specified by:
commitTransaction
in interfaceio.r2dbc.spi.Connection
- Overrides:
commitTransaction
in classDefaultConnection
-
createBatch
public io.r2dbc.spi.Batch createBatch()- Specified by:
createBatch
in interfaceio.r2dbc.spi.Connection
- Overrides:
createBatch
in classDefaultConnection
-
createSavepoint
- Specified by:
createSavepoint
in interfaceio.r2dbc.spi.Connection
- Overrides:
createSavepoint
in classDefaultConnection
-
createStatement
- Specified by:
createStatement
in interfaceio.r2dbc.spi.Connection
- Overrides:
createStatement
in classDefaultConnection
-
releaseSavepoint
- Specified by:
releaseSavepoint
in interfaceio.r2dbc.spi.Connection
- Overrides:
releaseSavepoint
in classDefaultConnection
-
rollbackTransaction
- Specified by:
rollbackTransaction
in interfaceio.r2dbc.spi.Connection
- Overrides:
rollbackTransaction
in classDefaultConnection
-
rollbackTransactionToSavepoint
- Specified by:
rollbackTransactionToSavepoint
in interfaceio.r2dbc.spi.Connection
- Overrides:
rollbackTransactionToSavepoint
in classDefaultConnection
-
setAutoCommit
- Specified by:
setAutoCommit
in interfaceio.r2dbc.spi.Connection
- Overrides:
setAutoCommit
in classDefaultConnection
-
setLockWaitTimeout
- Specified by:
setLockWaitTimeout
in interfaceio.r2dbc.spi.Connection
- Overrides:
setLockWaitTimeout
in classDefaultConnection
-
setStatementTimeout
- Specified by:
setStatementTimeout
in interfaceio.r2dbc.spi.Connection
- Overrides:
setStatementTimeout
in classDefaultConnection
-
setTransactionIsolationLevel
public org.reactivestreams.Publisher<Void> setTransactionIsolationLevel(io.r2dbc.spi.IsolationLevel isolationLevel) - Specified by:
setTransactionIsolationLevel
in interfaceio.r2dbc.spi.Connection
- Overrides:
setTransactionIsolationLevel
in classDefaultConnection
-
validate
- Specified by:
validate
in interfaceio.r2dbc.spi.Connection
- Overrides:
validate
in classDefaultConnection
-