com.github.davidmoten.rx.jdbc

Class QuerySelect

java.lang.Object

com.github.davidmoten.rx.jdbc.QuerySelect

All Implemented Interfaces:

Query

public final class QuerySelect
extends Object
implements Query

A query and its executable context.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	QuerySelect.Builder Builds a QuerySelect.
static class	QuerySelect.OperatorBuilder<R> Builder pattern for select query Observable.Operator.

Method Summary

Methods

Modifier and Type	Method and Description
com.github.davidmoten.rx.jdbc.QueryContext	context() Returns the query context including ConnectionProvider and Scheduler.
rx.Observable<?>	depends() Returns the Observables that have to complete before this query is started.
<T> rx.Observable<T>	execute(ResultSetMapper<? extends T> function) Returns the results of running a select query with all sets of parameters.
List<String>	names() Returns the list of names corresponding positionally to the ? characters in the sql.
rx.Observable<com.github.davidmoten.rx.jdbc.Parameter>	parameters() Returns the parameters for the query in order of appearance as ? markers in the sql.
String	sql() Returns the sql statement for this query following JDBC format (? for parameters for instance).
String	toString()

Methods inherited from class java.lang.Object

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

Method Detail

sql

public String sql()

Description copied from interface: Query

Returns the sql statement for this query following JDBC format (? for parameters for instance).

Specified by:

sql in interface Query

Returns:

jdbc sql

context

public com.github.davidmoten.rx.jdbc.QueryContext context()

Description copied from interface: Query

Returns the query context including ConnectionProvider and Scheduler.

Specified by:

context in interface Query

Returns:

parameters

public rx.Observable<com.github.davidmoten.rx.jdbc.Parameter> parameters()

Description copied from interface: Query

Returns the parameters for the query in order of appearance as ? markers in the sql. May emit more than the number of parameters in one run of the query in which case the query would be run multiple times.

Specified by:

parameters in interface Query

Returns:

names

public List<String> names()

Description copied from interface: Query

Returns the list of names corresponding positionally to the ? characters in the sql. If names were not used then returns an empty list.

Specified by:

names in interface Query

Returns:

ist of names corresponding positionally to the ? characters in the sql

toString

public String toString()

Overrides:

toString in class Object

depends

public rx.Observable<?> depends()

Description copied from interface: Query

Returns the Observables that have to complete before this query is started.

Specified by:

depends in interface Query

Returns:

execute

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

Returns the results of running a select query with all sets of parameters.

Returns: