com.github.davidmoten.rx.jdbc

Class QueryUpdate

java.lang.Object

com.github.davidmoten.rx.jdbc.QueryUpdate

All Implemented Interfaces:

Query

public final class QueryUpdate
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.

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

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:

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: