org.davidmoten.rx.jdbc

Class SelectBuilder

java.lang.Object

org.davidmoten.rx.jdbc.SelectBuilder

All Implemented Interfaces:

DependsOn<SelectBuilder>, Getter

public final class SelectBuilder
extends java.lang.Object
implements Getter, DependsOn<SelectBuilder>

Method Summary

Modifier and Type	Method and Description
SelectBuilder	dependsOn(io.reactivex.Flowable<?> flowable)
SelectBuilder	fetchSize(int size) Sets the fetchSize for the JDBC statement.
<T> io.reactivex.Flowable<T>	get(ResultSetMapper<? extends T> mapper) Transforms the results using the given function.
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)
SelectBuilder	queryTimeoutSec(int timeoutSec)
TransactedSelectBuilder	transacted()
TransactedSelectBuilder	transactedValuesOnly()

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.Getter

autoMap, count, getAs, getAs, getAs, getAs, getAs, getAs, getAs, getAsOptional, getTupleN, getTupleN

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

dependsOn, dependsOn, dependsOn

Method Detail

fetchSize

public SelectBuilder fetchSize(int size)

Sets the fetchSize for the JDBC statement. If 0 then fetchSize is not set and the default fetchSize for the JDBC driver you are using will be used.

Parameters:

size - sets the fetchSize or chooses default value if 0

Returns:

this

queryTimeoutSec

public SelectBuilder queryTimeoutSec(int timeoutSec)

transacted

public TransactedSelectBuilder transacted()

transactedValuesOnly

public TransactedSelectBuilder transactedValuesOnly()

get

public <T> io.reactivex.Flowable<T> get(@Nonnull
                                        ResultSetMapper<? extends T> mapper)

Description copied from interface: Getter

Transforms the results using the given function.

Specified by:

get in interface Getter

Type Parameters:

T - the type being mapped to

Parameters:

mapper - transforms ResultSet rows to an object of type T

Returns:

the results of the query as an Observable

dependsOn

public SelectBuilder dependsOn(@Nonnull
                               io.reactivex.Flowable<?> flowable)

Specified by:

dependsOn in interface DependsOn<SelectBuilder>

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)