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

Class DefaultConnection

java.lang.Object
org.jooq.tools.r2dbc.DefaultConnection
All Implemented Interfaces:
io.r2dbc.spi.Closeable, io.r2dbc.spi.Connection
Direct Known Subclasses:
LoggingConnection
public class DefaultConnection extends Object implements io.r2dbc.spi.Connection
A default R2DBC Connection implementation delegating all R2DBC calls to an internal getDelegate().
Author:
Lukas Eder

  • Constructor Details

    • DefaultConnection

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

  • Method Details

    • getDelegate

      public io.r2dbc.spi.Connection getDelegate()

    • beginTransaction

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

    • beginTransaction

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

    • 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

    • commitTransaction

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

    • createBatch

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

    • createSavepoint

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

    • createStatement

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

    • isAutoCommit

      public boolean isAutoCommit()
      Specified by:
      isAutoCommit in interface io.r2dbc.spi.Connection

    • getMetadata

      public io.r2dbc.spi.ConnectionMetadata getMetadata()
      Specified by:
      getMetadata in interface io.r2dbc.spi.Connection

    • getTransactionIsolationLevel

      public io.r2dbc.spi.IsolationLevel getTransactionIsolationLevel()
      Specified by:
      getTransactionIsolationLevel in interface io.r2dbc.spi.Connection

    • releaseSavepoint

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

    • rollbackTransaction

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

    • rollbackTransactionToSavepoint

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

    • setAutoCommit

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

    • setLockWaitTimeout

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

    • setStatementTimeout

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

    • setTransactionIsolationLevel

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

    • validate

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