Module org.jooq
Package org.jooq.tools.r2dbc

Class LoggingConnection

java.lang.Object
org.jooq.tools.r2dbc.DefaultConnection
org.jooq.tools.r2dbc.LoggingConnection
All Implemented Interfaces:
io.r2dbc.spi.Closeable, io.r2dbc.spi.Connection
public class LoggingConnection extends DefaultConnection
An R2DBC Connection proxy that logs all statements that are prepared or executed using it.
Author:
Lukas Eder

  • Constructor Details

    • LoggingConnection

      public LoggingConnection(io.r2dbc.spi.Connection delegate)

  • Method Details

    • beginTransaction

      public org.reactivestreams.Publisher<Void> beginTransaction()
      Specified by:
      beginTransaction in interface io.r2dbc.spi.Connection
      Overrides:
      beginTransaction in class DefaultConnection

    • beginTransaction

      public org.reactivestreams.Publisher<Void> beginTransaction(io.r2dbc.spi.TransactionDefinition definition)
      Specified by:
      beginTransaction in interface io.r2dbc.spi.Connection
      Overrides:
      beginTransaction in class DefaultConnection

    • close

      public org.reactivestreams.Publisher<Void> close()
      Specified by:
      close in interface io.r2dbc.spi.Closeable
      Specified by:
      close in interface io.r2dbc.spi.Connection
      Overrides:
      close in class DefaultConnection

    • commitTransaction

      public org.reactivestreams.Publisher<Void> commitTransaction()
      Specified by:
      commitTransaction in interface io.r2dbc.spi.Connection
      Overrides:
      commitTransaction in class DefaultConnection

    • createBatch

      public io.r2dbc.spi.Batch createBatch()
      Specified by:
      createBatch in interface io.r2dbc.spi.Connection
      Overrides:
      createBatch in class DefaultConnection

    • createSavepoint

      public org.reactivestreams.Publisher<Void> createSavepoint(String name)
      Specified by:
      createSavepoint in interface io.r2dbc.spi.Connection
      Overrides:
      createSavepoint in class DefaultConnection

    • createStatement

      public io.r2dbc.spi.Statement createStatement(String sql)
      Specified by:
      createStatement in interface io.r2dbc.spi.Connection
      Overrides:
      createStatement in class DefaultConnection

    • releaseSavepoint

      public org.reactivestreams.Publisher<Void> releaseSavepoint(String name)
      Specified by:
      releaseSavepoint in interface io.r2dbc.spi.Connection
      Overrides:
      releaseSavepoint in class DefaultConnection

    • rollbackTransaction

      public org.reactivestreams.Publisher<Void> rollbackTransaction()
      Specified by:
      rollbackTransaction in interface io.r2dbc.spi.Connection
      Overrides:
      rollbackTransaction in class DefaultConnection

    • rollbackTransactionToSavepoint

      public org.reactivestreams.Publisher<Void> rollbackTransactionToSavepoint(String name)
      Specified by:
      rollbackTransactionToSavepoint in interface io.r2dbc.spi.Connection
      Overrides:
      rollbackTransactionToSavepoint in class DefaultConnection

    • setAutoCommit

      public org.reactivestreams.Publisher<Void> setAutoCommit(boolean autoCommit)
      Specified by:
      setAutoCommit in interface io.r2dbc.spi.Connection
      Overrides:
      setAutoCommit in class DefaultConnection

    • setLockWaitTimeout

      public org.reactivestreams.Publisher<Void> setLockWaitTimeout(Duration timeout)
      Specified by:
      setLockWaitTimeout in interface io.r2dbc.spi.Connection
      Overrides:
      setLockWaitTimeout in class DefaultConnection

    • setStatementTimeout

      public org.reactivestreams.Publisher<Void> setStatementTimeout(Duration timeout)
      Specified by:
      setStatementTimeout in interface io.r2dbc.spi.Connection
      Overrides:
      setStatementTimeout in class DefaultConnection

    • setTransactionIsolationLevel

      public org.reactivestreams.Publisher<Void> setTransactionIsolationLevel(io.r2dbc.spi.IsolationLevel isolationLevel)
      Specified by:
      setTransactionIsolationLevel in interface io.r2dbc.spi.Connection
      Overrides:
      setTransactionIsolationLevel in class DefaultConnection

    • validate

      public org.reactivestreams.Publisher<Boolean> validate(io.r2dbc.spi.ValidationDepth depth)
      Specified by:
      validate in interface io.r2dbc.spi.Connection
      Overrides:
      validate in class DefaultConnection