com.github.davidmoten.rx.jdbc

Class QuerySelect.Builder

java.lang.Object

com.github.davidmoten.rx.jdbc.QuerySelect.Builder

Enclosing class:

QuerySelect

public static final class QuerySelect.Builder
extends Object

Builds a QuerySelect.

Constructor Summary

Constructors

Constructor and Description
QuerySelect.Builder(String sql, Database db) Constructor.

Method Summary

Methods

Modifier and Type	Method and Description
<T> rx.Observable<T>	autoMap(Class<T> cls) Transforms each row of the ResultSet into an instance of T using automapping of the ResultSet columns into corresponding constructor parameters that are assignable.
rx.Observable<Integer>	count()
QuerySelect.Builder	dependsOn(rx.Observable<?> dependency) Appends a dependency to the dependencies that have to complete their emitting before the query is executed.
QuerySelect.Builder	dependsOnLastTransaction() Appends a dependency on the result of the last transaction ( true for commit or false for rollback) to the dependencies that have to complete their emitting before the query is executed.
QuerySelect.OperatorBuilder<Object>	dependsOnOperator() Returns an Observable.Operator to allow the query to be pushed dependencies via the Observable.lift(Operator) method.
<T> rx.Observable<T>	get(ResultSetMapper<? extends T> function) Transforms the results using the given function.
<S> rx.Observable<S>	getAs(Class<S> cls) Automaps the first column of the ResultSet into the target class cls.
<T1,T2> rx.Observable<Tuple2<T1,T2>>	getAs(Class<T1> cls1, Class<T2> cls2) Automaps the columns of the ResultSet into the specified classes.
<T1,T2,T3> rx.Observable<Tuple3<T1,T2,T3>>	getAs(Class<T1> cls1, Class<T2> cls2, Class<T3> cls3) Automaps the columns of the ResultSet into the specified classes.
<T1,T2,T3,T4> rx.Observable<Tuple4<T1,T2,T3,T4>>	getAs(Class<T1> cls1, Class<T2> cls2, Class<T3> cls3, Class<T4> cls4) Automaps the columns of the ResultSet into the specified classes.
<T1,T2,T3,T4,T5> rx.Observable<Tuple5<T1,T2,T3,T4,T5>>	getAs(Class<T1> cls1, Class<T2> cls2, Class<T3> cls3, Class<T4> cls4, Class<T5> cls5) Automaps the columns of the ResultSet into the specified classes.
<T1,T2,T3,T4,T5,T6> rx.Observable<Tuple6<T1,T2,T3,T4,T5,T6>>	getAs(Class<T1> cls1, Class<T2> cls2, Class<T3> cls3, Class<T4> cls4, Class<T5> cls5, Class<T6> cls6) Automaps the columns of the ResultSet into the specified classes.
<T1,T2,T3,T4,T5,T6,T7> rx.Observable<Tuple7<T1,T2,T3,T4,T5,T6,T7>>	getAs(Class<T1> cls1, Class<T2> cls2, Class<T3> cls3, Class<T4> cls4, Class<T5> cls5, Class<T6> cls6, Class<T7> cls7) Automaps the columns of the ResultSet into the specified classes.
<S> rx.Observable<TupleN<Object>>	getTupleN() Automaps all the columns of the ResultSet into Object .
<S> rx.Observable<TupleN<S>>	getTupleN(Class<S> cls) Automaps all the columns of the ResultSet into the target class cls.
QuerySelect.Builder	parameter(Object value) Appends a parameter to the parameter list for the query.
QuerySelect.Builder	parameter(String name, Object value) Sets a named parameter.
QuerySelect.OperatorBuilder<rx.Observable<Object>>	parameterListOperator() Returns an Observable.Operator that runs a select query for each list of parameter objects in the source observable.
QuerySelect.OperatorBuilder<Object>	parameterOperator() Returns an Observable.Operator to allow the query to be pushed parameters via the Observable.lift(Operator) method.
QuerySelect.Builder	parameters(Object... objects) Appends the given parameter values to the parameter list for the query.
<T> QuerySelect.Builder	parameters(rx.Observable<T> parameters) Appends the given parameters to the parameter list for the query.

Methods inherited from class java.lang.Object

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

Constructor Detail

QuerySelect.Builder

public QuerySelect.Builder(String sql,
                   Database db)

Constructor.

Parameters:

sql -

db -

Method Detail

parameters

public <T> QuerySelect.Builder parameters(rx.Observable<T> parameters)

Appends the given parameters to the parameter list for the query. If there are more parameters than required for one execution of the query then more than one execution of the query will occur.

Parameters:

parameters -

Returns:

this

parameters

public QuerySelect.Builder parameters(Object... objects)

Appends the given parameter values to the parameter list for the query. If there are more parameters than required for one execution of the query then more than one execution of the query will occur.

Parameters:

objects -

Returns:

this

parameter

public QuerySelect.Builder parameter(Object value)

Appends a parameter to the parameter list for the query. If there are more parameters than required for one execution of the query then more than one execution of the query will occur.

Parameters:

value -

Returns:

this

parameter

public QuerySelect.Builder parameter(String name,
                            Object value)

Sets a named parameter. If name is null throws a NullPointerException. If value is instance of Observable then throws an IllegalArgumentException.

Parameters:

name - the parameter name. Cannot be null.

value - the parameter value

dependsOn

public QuerySelect.Builder dependsOn(rx.Observable<?> dependency)

Appends a dependency to the dependencies that have to complete their emitting before the query is executed.

Parameters:

dependency -

Returns:

this

dependsOnLastTransaction

public QuerySelect.Builder dependsOnLastTransaction()

Appends a dependency on the result of the last transaction ( true for commit or false for rollback) to the dependencies that have to complete their emitting before the query is executed.

Returns:

this

get

public <T> rx.Observable<T> get(ResultSetMapper<? extends T> function)

Transforms the results using the given function.

Parameters:

function -

Returns:

autoMap

public <T> rx.Observable<T> autoMap(Class<T> cls)

Transforms each row of the ResultSet into an instance of T using automapping of the ResultSet columns into corresponding constructor parameters that are assignable. Beyond normal assignable criteria (for example Integer 123 is assignable to a Double) other conversions exist to facilitate the automapping:

They are:

• java.sql.Blob ➟ byte[]
• java.sql.Blob ➟ java.io.InputStream
• java.sql.Clob ➟ String
• java.sql.Clob ➟ java.io.Reader
• java.sql.Date ➟ java.util.Date
• java.sql.Date ➟ Long
• java.sql.Timestamp ➟ java.util.Date
• java.sql.Timestamp ➟ Long
• java.sql.Time ➟ java.util.Date
• java.sql.Time ➟ Long
• java.math.BigInteger ➟ Short,Integer,Long,Float,Double,BigDecimal
• java.math.BigDecimal ➟ Short,Integer,Long,Float,Double,BigInteger

Parameters:

cls -

Returns:

getAs

public <S> rx.Observable<S> getAs(Class<S> cls)

Automaps the first column of the ResultSet into the target class cls.

Parameters:

cls -

Returns:

getTupleN

public <S> rx.Observable<TupleN<S>> getTupleN(Class<S> cls)

Automaps all the columns of the ResultSet into the target class cls. See autoMap().

Parameters:

cls -

Returns:

getTupleN

public <S> rx.Observable<TupleN<Object>> getTupleN()

Automaps all the columns of the ResultSet into Object . See autoMap().

Parameters:

cls -

Returns:

getAs

public <T1,T2> rx.Observable<Tuple2<T1,T2>> getAs(Class<T1> cls1,
                                         Class<T2> cls2)

Automaps the columns of the ResultSet into the specified classes. See autoMap().

Parameters:

cls1 -

cls2 -

Returns:

getAs

public <T1,T2,T3> rx.Observable<Tuple3<T1,T2,T3>> getAs(Class<T1> cls1,
                                               Class<T2> cls2,
                                               Class<T3> cls3)

Automaps the columns of the ResultSet into the specified classes. See autoMap().

Parameters:

cls1 -

cls2 -

cls3 -

Returns:

getAs

public <T1,T2,T3,T4> rx.Observable<Tuple4<T1,T2,T3,T4>> getAs(Class<T1> cls1,
                                                     Class<T2> cls2,
                                                     Class<T3> cls3,
                                                     Class<T4> cls4)

Automaps the columns of the ResultSet into the specified classes. See autoMap().

Parameters:

cls1 -

cls2 -

cls3 -

cls4 -

Returns:

getAs

public <T1,T2,T3,T4,T5> rx.Observable<Tuple5<T1,T2,T3,T4,T5>> getAs(Class<T1> cls1,
                                                           Class<T2> cls2,
                                                           Class<T3> cls3,
                                                           Class<T4> cls4,
                                                           Class<T5> cls5)

Automaps the columns of the ResultSet into the specified classes. See autoMap().

Parameters:

cls1 -

cls2 -

cls3 -

cls4 -

cls5 -

Returns:

getAs

public <T1,T2,T3,T4,T5,T6> rx.Observable<Tuple6<T1,T2,T3,T4,T5,T6>> getAs(Class<T1> cls1,
                                                                 Class<T2> cls2,
                                                                 Class<T3> cls3,
                                                                 Class<T4> cls4,
                                                                 Class<T5> cls5,
                                                                 Class<T6> cls6)

Automaps the columns of the ResultSet into the specified classes. See autoMap().

Parameters:

cls1 -

cls2 -

cls3 -

cls4 -

cls5 -

cls6 -

Returns:

getAs

public <T1,T2,T3,T4,T5,T6,T7> rx.Observable<Tuple7<T1,T2,T3,T4,T5,T6,T7>> getAs(Class<T1> cls1,
                                                                       Class<T2> cls2,
                                                                       Class<T3> cls3,
                                                                       Class<T4> cls4,
                                                                       Class<T5> cls5,
                                                                       Class<T6> cls6,
                                                                       Class<T7> cls7)

Automaps the columns of the ResultSet into the specified classes. See autoMap().

Parameters:

cls1 -

cls2 -

cls3 -

cls4 -

cls5 -

cls6 -

cls7 -

Returns:

count

public rx.Observable<Integer> count()

parameterOperator

public QuerySelect.OperatorBuilder<Object> parameterOperator()

Returns an Observable.Operator to allow the query to be pushed parameters via the Observable.lift(Operator) method.

Returns:

operator that acts on parameters

dependsOnOperator

public QuerySelect.OperatorBuilder<Object> dependsOnOperator()

Returns an Observable.Operator to allow the query to be pushed dependencies via the Observable.lift(Operator) method.

Returns:

operator that acts on dependencies

parameterListOperator

public QuerySelect.OperatorBuilder<rx.Observable<Object>> parameterListOperator()

Returns an Observable.Operator that runs a select query for each list of parameter objects in the source observable.

Returns: