com.github.davidmoten.rx.jdbc

Class QueryUpdate.Builder

java.lang.Object

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

Enclosing class:

QueryUpdate<T>

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() Clears the parameter inputs for the query.
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	parameter(String name, Object value) Sets a named parameter.
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.
QueryUpdate.ReturnGeneratedKeysBuilder	returnGeneratedKeys() Returns a builder used to specify how to process the generated keys ResultSet.

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

parameter

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

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

returnGeneratedKeys

public QueryUpdate.ReturnGeneratedKeysBuilder returnGeneratedKeys()

Returns a builder used to specify how to process the generated keys ResultSet. Not all jdbc drivers support this functionality and some have limitations in their support (h2 for instance only returns the last generated key when multiple inserts happen in the one statement).

Returns:

a builder used to specify how to process the generated keys ResultSet

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:

operator

clearParameters

public QueryUpdate.Builder clearParameters()

Clears the parameter inputs for the query.

Returns:

the current builder