org.davidmoten.rx.jdbc

Class UpdateBuilder

java.lang.Object

org.davidmoten.rx.jdbc.UpdateBuilder

All Implemented Interfaces:

DependsOn<UpdateBuilder>

public final class UpdateBuilder
extends java.lang.Object
implements DependsOn<UpdateBuilder>

Method Summary

Modifier and Type	Method and Description
UpdateBuilder	batchSize(int batchSize)
io.reactivex.Completable	complete()
io.reactivex.Flowable<java.lang.Integer>	counts()
UpdateBuilder	dependsOn(io.reactivex.Flowable<?> flowable)
T	parameter(java.lang.Object value)
T	parameter(java.lang.String name, java.lang.Object value)
T	parameterListStream(io.reactivex.Flowable<java.util.List<?>> valueLists)
T	parameters(java.util.List<?> values)
T	parameters(java.lang.Object... values)
T	parameterStream(io.reactivex.Flowable<?> values)
UpdateBuilder	queryTimeoutSec(int queryTimeoutSec)
ReturnGeneratedKeysBuilder	returnGeneratedKeys() Returns a builder used to specify how to process the generated keys ResultSet.
TransactedUpdateBuilder	transacted()
io.reactivex.Flowable<Tx<?>>	transaction()

Methods inherited from class java.lang.Object

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

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

dependsOn, dependsOn, dependsOn

Method Detail

dependsOn

public UpdateBuilder dependsOn(io.reactivex.Flowable<?> flowable)

Specified by:

dependsOn in interface DependsOn<UpdateBuilder>

batchSize

public UpdateBuilder batchSize(int batchSize)

queryTimeoutSec

public UpdateBuilder queryTimeoutSec(int queryTimeoutSec)

returnGeneratedKeys

public ReturnGeneratedKeysBuilder 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

counts

public io.reactivex.Flowable<java.lang.Integer> counts()

transacted

public TransactedUpdateBuilder transacted()

transaction

public io.reactivex.Flowable<Tx<?>> transaction()

complete

public io.reactivex.Completable complete()

parameterStream

public final T parameterStream(@Nonnull
                               io.reactivex.Flowable<?> values)

parameterListStream

public final T parameterListStream(@Nonnull
                                   io.reactivex.Flowable<java.util.List<?>> valueLists)

parameters

public final T parameters(@Nonnull
                          java.util.List<?> values)

parameter

public final T parameter(@Nonnull
                         java.lang.String name,
                         java.lang.Object value)

parameter

public final T parameter(java.lang.Object value)

parameters

public final T parameters(@Nonnull
                          java.lang.Object... values)