com.github.davidmoten.rx.jdbc

Class QueryUpdate.Builder

java.lang.Object

com.github.davidmoten.rx.jdbc.QueryUpdate.Builder

Enclosing class:

QueryUpdate

public static final class QueryUpdate.Builder
extends Object

Builds a QueryUpdate.

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
QueryUpdate.Builder	clearParameters()
rx.Observable<Integer>	count() Returns an Observable with the count of rows affected by the update statement.
QueryUpdate.Builder	dependsOn(rx.Observable<?> dependency) Appends a dependency to the dependencies that have to complete their emitting before the query is executed.
QueryUpdate.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.
rx.Observable.Operator<Integer,Object>	dependsOnOperator() Returns an Observable.Operator to allow the query to be pushed dependencies via the Observable.lift(Operator) method.
QueryUpdate.Builder	parameter(Object value) Appends a parameter to the parameter list for the query.
QueryUpdate.Builder	parameterBlob(byte[] bytes) Appends a parameter to the parameter list for the query for a CLOB parameter and handles null appropriately.
QueryUpdate.Builder	parameterClob(String value) Appends a parameter to the parameter list for the query for a CLOB parameter and handles null appropriately.
rx.Observable.Operator<rx.Observable<Integer>,rx.Observable<Object>>	parameterListOperator() Returns an Observable.Operator to allow the query to be run once per parameter list in the source.
rx.Observable.Operator<Integer,Object>	parameterOperator() Returns an Observable.Operator to allow the query to be pushed parameters via the Observable.lift(Operator) method.
QueryUpdate.Builder	parameters(Object... objects) Appends the given parameter values to the parameter list for the query.
<T> QueryUpdate.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

QueryUpdate.Builder

public QueryUpdate.Builder(String sql,
                   Database db)

Constructor.

Parameters:

sql -

db -

Method Detail

parameters

public <T> QueryUpdate.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 QueryUpdate.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 QueryUpdate.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

parameterClob

public QueryUpdate.Builder parameterClob(String value)

Appends a parameter to the parameter list for the query for a CLOB parameter and handles null appropriately. 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 - the string to insert in the CLOB column

Returns:

this

parameterBlob

public QueryUpdate.Builder parameterBlob(byte[] bytes)

Appends a parameter to the parameter list for the query for a CLOB parameter and handles null appropriately. 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

dependsOn

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

count

public rx.Observable<Integer> count()

Returns an Observable with the count of rows affected by the update statement.

Returns:

parameterOperator

public rx.Observable.Operator<Integer,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 rx.Observable.Operator<Integer,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 rx.Observable.Operator<rx.Observable<Integer>,rx.Observable<Object>> parameterListOperator()

Returns an Observable.Operator to allow the query to be run once per parameter list in the source.

Returns:

clearParameters

public QueryUpdate.Builder clearParameters()