org.davidmoten.rxjava3.jdbc

Class TransactedUpdateBuilder

java.lang.Object

org.davidmoten.rxjava3.jdbc.TransactedUpdateBuilder

All Implemented Interfaces:

DependsOn<TransactedUpdateBuilder>

public final class TransactedUpdateBuilder
extends Object
implements DependsOn<TransactedUpdateBuilder>

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TransactedUpdateBuilder.TransactedUpdateBuilderValuesOnly

Method Summary

Modifier and Type	Method and Description
TransactedUpdateBuilder	batchSize(int batchSize)
io.reactivex.rxjava3.core.Flowable<Tx<Integer>>	counts()
io.reactivex.rxjava3.core.Flowable<Integer>	countsOnly()
TransactedUpdateBuilder	dependsOn(io.reactivex.rxjava3.core.Flowable<?> dependency)
TransactedUpdateBuilder	parameter(Object value)
TransactedUpdateBuilder	parameter(String name, Object value)
io.reactivex.rxjava3.core.Flowable<List<Object>>	parameterGroupsToFlowable()
TransactedUpdateBuilder	parameterListStream(io.reactivex.rxjava3.core.Flowable<List<?>> valueLists)
TransactedUpdateBuilder	parameters(List<?> values)
TransactedUpdateBuilder	parameters(Object... values)
TransactedUpdateBuilder	parameterStream(io.reactivex.rxjava3.core.Flowable<?> values)
TransactedReturnGeneratedKeysBuilder	returnGeneratedKeys() Returns a builder used to specify how to process the generated keys ResultSet.
TransactedUpdateBuilder	transactedValuesOnly()
io.reactivex.rxjava3.core.Flowable<Tx<?>>	tx()
TransactedUpdateBuilder.TransactedUpdateBuilderValuesOnly	valuesOnly()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.davidmoten.rxjava3.jdbc.DependsOn

dependsOn, dependsOn, dependsOn

Method Detail

parameterStream

public TransactedUpdateBuilder parameterStream(@Nonnull
                                               io.reactivex.rxjava3.core.Flowable<?> values)

parameterListStream

public TransactedUpdateBuilder parameterListStream(@Nonnull
                                                   io.reactivex.rxjava3.core.Flowable<List<?>> valueLists)

parameters

public TransactedUpdateBuilder parameters(@Nonnull
                                          List<?> values)

parameter

public TransactedUpdateBuilder parameter(@Nonnull
                                         String name,
                                         Object value)

parameter

public TransactedUpdateBuilder parameter(Object value)

parameters

public TransactedUpdateBuilder parameters(@Nonnull
                                          Object... values)

dependsOn

public TransactedUpdateBuilder dependsOn(@Nonnull
                                         io.reactivex.rxjava3.core.Flowable<?> dependency)

Specified by:

dependsOn in interface DependsOn<TransactedUpdateBuilder>

batchSize

public TransactedUpdateBuilder batchSize(int batchSize)

returnGeneratedKeys

public TransactedReturnGeneratedKeysBuilder returnGeneratedKeys()

Returns a builder used to specify how to process the generated keys ResultSet. Not all jdbc drivers support this functionality and some have limitations in their support (h2 for instance only returns the last generated key when multiple inserts happen in the one statement).

Returns:

a builder used to specify how to process the generated keys ResultSet

transactedValuesOnly

public TransactedUpdateBuilder transactedValuesOnly()

valuesOnly

public TransactedUpdateBuilder.TransactedUpdateBuilderValuesOnly valuesOnly()

counts

public io.reactivex.rxjava3.core.Flowable<Tx<Integer>> counts()

countsOnly

public io.reactivex.rxjava3.core.Flowable<Integer> countsOnly()

tx

public io.reactivex.rxjava3.core.Flowable<Tx<?>> tx()

parameterGroupsToFlowable

public io.reactivex.rxjava3.core.Flowable<List<Object>> parameterGroupsToFlowable()