Package io.github.zero88.jooqx.rxjava3

Class JooqxTx

java.lang.Object
io.github.zero88.jooqx.rxjava3.JooqxConn
io.github.zero88.jooqx.rxjava3.JooqxTx
public class JooqxTx extends JooqxConn
Represents for a reactive SQL transaction executor

NOTE: This class has been automatically generated from the original non RX-ified interface using Vert.x codegen.

  • Field Details

    • __TYPE_ARG

      public static final io.vertx.lang.rx.TypeArg<JooqxTx> __TYPE_ARG

  • Constructor Details

    • JooqxTx

      public JooqxTx(JooqxTx delegate)

    • JooqxTx

      public JooqxTx(Object delegate)

  • Method Details

    • toString

      public String toString()
      Overrides:
      toString in class JooqxConn

    • equals

      public boolean equals(Object o)
      Overrides:
      equals in class JooqxConn

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class JooqxConn

    • getDelegate

      public JooqxTx getDelegate()
      Overrides:
      getDelegate in class JooqxConn

    • sql

      public io.reactivex.rxjava3.core.Single<Integer> sql(String statement)
      Execute the plain SQL statement without result (e.g: SET, INSERT, UPDATE, etc...)
      Overrides:
      sql in class JooqxConn
      Parameters:
      statement - the plain SQL statement without result
      Returns:

    • rxSql

      public io.reactivex.rxjava3.core.Single<Integer> rxSql(String statement)
      Execute the plain SQL statement without result (e.g: SET, INSERT, UPDATE, etc...)
      Overrides:
      rxSql in class JooqxConn
      Parameters:
      statement - the plain SQL statement without result
      Returns:

    • transaction

      public JooqxTx transaction()
      Overrides:
      transaction in class JooqxConn

    • run

      public <X> io.reactivex.rxjava3.core.Single<X> run(Function<JooqxTx,io.reactivex.rxjava3.core.Single<X>> transactionFn)

    • rxRun

      public <X> io.reactivex.rxjava3.core.Single<X> rxRun(Function<JooqxTx,io.reactivex.rxjava3.core.Single<X>> transactionFn)

    • batchResult

      public <T, R> io.reactivex.rxjava3.core.Single<BatchReturningResult<R>> batchResult(Function<org.jooq.DSLContext,org.jooq.Query> queryFunction, BindBatchValues bindBatchValues, SQLResultListAdapter<T,R> adapter)
      Result batch execute
      Overrides:
      batchResult in class JooqxConn
      Parameters:
      queryFunction - query function
      bindBatchValues - bind batch values
      adapter -
      Returns:

    • rxBatchResult

      public <T, R> io.reactivex.rxjava3.core.Single<BatchReturningResult<R>> rxBatchResult(Function<org.jooq.DSLContext,org.jooq.Query> queryFunction, BindBatchValues bindBatchValues, SQLResultListAdapter<T,R> adapter)
      Result batch execute
      Overrides:
      rxBatchResult in class JooqxConn
      Parameters:
      queryFunction - query function
      bindBatchValues - bind batch values
      adapter -
      Returns:

    • batchResult

      public <T, R> io.reactivex.rxjava3.core.Single<BatchReturningResult<R>> batchResult(org.jooq.Query query, BindBatchValues bindBatchValues, SQLResultListAdapter<T,R> adapter)
      Execute batch statements then receive results
      Overrides:
      batchResult in class JooqxConn
      Parameters:
      query - jOOQ query
      bindBatchValues - bind batch values
      adapter - result adapter
      Returns:

    • rxBatchResult

      public <T, R> io.reactivex.rxjava3.core.Single<BatchReturningResult<R>> rxBatchResult(org.jooq.Query query, BindBatchValues bindBatchValues, SQLResultListAdapter<T,R> adapter)
      Execute batch statements then receive results
      Overrides:
      rxBatchResult in class JooqxConn
      Parameters:
      query - jOOQ query
      bindBatchValues - bind batch values
      adapter - result adapter
      Returns:

    • routine

      public <T> io.reactivex.rxjava3.core.Single<T> routine(Function<org.jooq.DSLContext,org.jooq.Routine<T>> routineFunction)
      Overrides:
      routine in class JooqxConn

    • rxRoutine

      public <T> io.reactivex.rxjava3.core.Single<T> rxRoutine(Function<org.jooq.DSLContext,org.jooq.Routine<T>> routineFunction)
      Overrides:
      rxRoutine in class JooqxConn

    • routine

      public <T> io.vertx.core.Future<T> routine(org.jooq.Routine<T> routine, io.vertx.core.Handler<io.vertx.core.AsyncResult<T>> handler)
      Overrides:
      routine in class JooqxConn

    • routineResult

      public <T> io.reactivex.rxjava3.core.Single<RoutineResult> routineResult(org.jooq.Routine<T> routine)
      Overrides:
      routineResult in class JooqxConn

    • rxRoutineResult

      public <T> io.reactivex.rxjava3.core.Single<RoutineResult> rxRoutineResult(org.jooq.Routine<T> routine)
      Overrides:
      rxRoutineResult in class JooqxConn

    • routineResultSet

      public <T, X, R> io.vertx.core.Future<R> routineResultSet(org.jooq.Routine<T> routine, SQLResultAdapter<X,R> resultAdapter, io.vertx.core.Handler<io.vertx.core.AsyncResult<R>> handler)
      Overrides:
      routineResultSet in class JooqxConn

    • block

      public io.reactivex.rxjava3.core.Single<BlockResult> block(Function<org.jooq.DSLContext,BlockQuery> blockQueryFn)
      Block execute
      Overrides:
      block in class JooqxConn
      Parameters:
      blockQueryFn - the block of SQL queries function
      Returns:

    • rxBlock

      public io.reactivex.rxjava3.core.Single<BlockResult> rxBlock(Function<org.jooq.DSLContext,BlockQuery> blockQueryFn)
      Block execute
      Overrides:
      rxBlock in class JooqxConn
      Parameters:
      blockQueryFn - the block of SQL queries function
      Returns:

    • block

      public io.reactivex.rxjava3.core.Single<BlockResult> block(BlockQuery blockQuery)
      Block execute
      Overrides:
      block in class JooqxConn
      Parameters:
      blockQuery - the block of SQL queries
      Returns:

    • rxBlock

      public io.reactivex.rxjava3.core.Single<BlockResult> rxBlock(BlockQuery blockQuery)
      Block execute
      Overrides:
      rxBlock in class JooqxConn
      Parameters:
      blockQuery - the block of SQL queries
      Returns:

    • sql

      public io.reactivex.rxjava3.core.Single<Integer> sql(Function<org.jooq.DSLContext,String> sqlFunction)
      Execute the plain SQL statement without result (e.g: SET, INSERT, UPDATE, etc...)
      Overrides:
      sql in class JooqxConn
      Parameters:
      sqlFunction - the plain SQL function products a plain SQL statement without result
      Returns:

    • rxSql

      public io.reactivex.rxjava3.core.Single<Integer> rxSql(Function<org.jooq.DSLContext,String> sqlFunction)
      Execute the plain SQL statement without result (e.g: SET, INSERT, UPDATE, etc...)
      Overrides:
      rxSql in class JooqxConn
      Parameters:
      sqlFunction - the plain SQL function products a plain SQL statement without result
      Returns:

    • sqlQuery

      public <T, R> io.reactivex.rxjava3.core.Maybe<R> sqlQuery(Function<org.jooq.DSLContext,String> sqlFunction, SQLResultAdapter<T,R> adapter)
      Execute the plain SQL statement with results (e.g: SELECT, etc...)
      Overrides:
      sqlQuery in class JooqxConn
      Parameters:
      sqlFunction - the plain SQL function products a plain SQL statement with results
      adapter - the result adapter
      Returns:

    • rxSqlQuery

      public <T, R> io.reactivex.rxjava3.core.Maybe<R> rxSqlQuery(Function<org.jooq.DSLContext,String> sqlFunction, SQLResultAdapter<T,R> adapter)
      Execute the plain SQL statement with results (e.g: SELECT, etc...)
      Overrides:
      rxSqlQuery in class JooqxConn
      Parameters:
      sqlFunction - the plain SQL function products a plain SQL statement with results
      adapter - the result adapter
      Returns:

    • sqlQuery

      public <T, R> io.reactivex.rxjava3.core.Maybe<R> sqlQuery(String statement, SQLResultAdapter<T,R> adapter)
      Execute the plain SQL statement with results (e.g: SELECT, etc...)
      Overrides:
      sqlQuery in class JooqxConn
      Parameters:
      statement - the plain SQL statement with results
      adapter - the result adapter
      Returns:

    • rxSqlQuery

      public <T, R> io.reactivex.rxjava3.core.Maybe<R> rxSqlQuery(String statement, SQLResultAdapter<T,R> adapter)
      Execute the plain SQL statement with results (e.g: SELECT, etc...)
      Overrides:
      rxSqlQuery in class JooqxConn
      Parameters:
      statement - the plain SQL statement with results
      adapter - the result adapter
      Returns:

    • batch

      public io.reactivex.rxjava3.core.Single<BatchResult> batch(Function<org.jooq.DSLContext,org.jooq.Query> queryFunction, BindBatchValues bindBatchValues)
      Batch execute
      Overrides:
      batch in class JooqxConn
      Parameters:
      queryFunction - query function
      bindBatchValues - bind batch values
      Returns:

    • rxBatch

      public io.reactivex.rxjava3.core.Single<BatchResult> rxBatch(Function<org.jooq.DSLContext,org.jooq.Query> queryFunction, BindBatchValues bindBatchValues)
      Batch execute
      Overrides:
      rxBatch in class JooqxConn
      Parameters:
      queryFunction - query function
      bindBatchValues - bind batch values
      Returns:

    • batch

      public io.reactivex.rxjava3.core.Single<BatchResult> batch(org.jooq.Query query, BindBatchValues bindBatchValues)
      Batch execute
      Overrides:
      batch in class JooqxConn
      Parameters:
      query - query
      bindBatchValues - bind batch values
      Returns:

    • rxBatch

      public io.reactivex.rxjava3.core.Single<BatchResult> rxBatch(org.jooq.Query query, BindBatchValues bindBatchValues)
      Batch execute
      Overrides:
      rxBatch in class JooqxConn
      Parameters:
      query - query
      bindBatchValues - bind batch values
      Returns:

    • execute

      public <T, R> io.reactivex.rxjava3.core.Maybe<R> execute(Function<org.jooq.DSLContext,org.jooq.Query> queryFunction, SQLResultAdapter<T,R> resultAdapter)
      Execute jOOQ query then return async result
      Overrides:
      execute in class JooqxConn
      Parameters:
      queryFunction - the jOOQ query function
      resultAdapter - the result adapter
      Returns:

    • rxExecute

      public <T, R> io.reactivex.rxjava3.core.Maybe<R> rxExecute(Function<org.jooq.DSLContext,org.jooq.Query> queryFunction, SQLResultAdapter<T,R> resultAdapter)
      Execute jOOQ query then return async result
      Overrides:
      rxExecute in class JooqxConn
      Parameters:
      queryFunction - the jOOQ query function
      resultAdapter - the result adapter
      Returns:

    • execute

      public <T, R> io.reactivex.rxjava3.core.Maybe<R> execute(org.jooq.Query query, SQLResultAdapter<T,R> resultAdapter)
      Execute jOOQ query then return async result
      Overrides:
      execute in class JooqxConn
      Parameters:
      query - the jOOQ query
      resultAdapter - the result adapter
      Returns:

    • rxExecute

      public <T, R> io.reactivex.rxjava3.core.Maybe<R> rxExecute(org.jooq.Query query, SQLResultAdapter<T,R> resultAdapter)
      Execute jOOQ query then return async result
      Overrides:
      rxExecute in class JooqxConn
      Parameters:
      query - the jOOQ query
      resultAdapter - the result adapter
      Returns:

    • execute

      public io.reactivex.rxjava3.core.Single<Integer> execute(Function<org.jooq.DSLContext,org.jooq.RowCountQuery> rowCountQueryFn)
      Execute row count query statement
      Overrides:
      execute in class JooqxConn
      Parameters:
      rowCountQueryFn - A function produces row count query statement
      Returns:

    • rxExecute

      public io.reactivex.rxjava3.core.Single<Integer> rxExecute(Function<org.jooq.DSLContext,org.jooq.RowCountQuery> rowCountQueryFn)
      Execute row count query statement
      Overrides:
      rxExecute in class JooqxConn
      Parameters:
      rowCountQueryFn - A function produces row count query statement
      Returns:

    • execute

      public io.reactivex.rxjava3.core.Single<Integer> execute(org.jooq.RowCountQuery statement)
      Execute row count query statement
      Overrides:
      execute in class JooqxConn
      Parameters:
      statement - a row count query statement
      Returns:

    • rxExecute

      public io.reactivex.rxjava3.core.Single<Integer> rxExecute(org.jooq.RowCountQuery statement)
      Execute row count query statement
      Overrides:
      rxExecute in class JooqxConn
      Parameters:
      statement - a row count query statement
      Returns:

    • ddl

      public io.reactivex.rxjava3.core.Single<Integer> ddl(Function<org.jooq.DSLContext,org.jooq.DDLQuery> ddlFunction)
      Execute DDL statement
      Overrides:
      ddl in class JooqxConn
      Parameters:
      ddlFunction - DDL function produces DDL statement
      Returns:

    • rxDdl

      public io.reactivex.rxjava3.core.Single<Integer> rxDdl(Function<org.jooq.DSLContext,org.jooq.DDLQuery> ddlFunction)
      Execute DDL statement
      Overrides:
      rxDdl in class JooqxConn
      Parameters:
      ddlFunction - DDL function produces DDL statement
      Returns:

    • ddl

      public io.reactivex.rxjava3.core.Single<Integer> ddl(org.jooq.DDLQuery statement)
      Execute DDL statement
      Overrides:
      ddl in class JooqxConn
      Parameters:
      statement - DDL statement
      Returns:

    • rxDdl

      public io.reactivex.rxjava3.core.Single<Integer> rxDdl(org.jooq.DDLQuery statement)
      Execute DDL statement
      Overrides:
      rxDdl in class JooqxConn
      Parameters:
      statement - DDL statement
      Returns:

    • newInstance

      public static JooqxTx newInstance(JooqxTx arg)