com.github.davidmoten.rx.jdbc

Class QueryUpdate<T>

java.lang.Object

com.github.davidmoten.rx.jdbc.QueryUpdate<T>

Type Parameters:

T - type of returned observable (Integer for count, custom for returning generated keys)

All Implemented Interfaces:

Query

public final class QueryUpdate<T>
extends Object
implements Query

Always emits an Observable of size 1 containing the number of affected records.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	QueryUpdate.Builder Builds a QueryUpdate.
static class	QueryUpdate.ReturnGeneratedKeysBuilder

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<Integer>	count() Returns the results of an update query.
rx.Observable<?>	depends() Returns the Observables that have to complete before this query is started.
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.
ResultSetMapper<? extends T>	returnGeneratedKeysFunction()
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

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:

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:

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:

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

count

public rx.Observable<Integer> count()

Returns the results of an update query. Should be an Observable of size 1 containing the number of records affected by the update (or insert) statement.

Parameters:

query -

Returns:

returnGeneratedKeysFunction

public ResultSetMapper<? extends T> returnGeneratedKeysFunction()