Schedulers.io().ResultSet into an instance of
T using automapping of the ResultSet columns into
corresponding constructor parameters that are assignable.ResultSet into an instance of
T using automapping of the ResultSet columns into
corresponding constructor parameters that are assignable.Database.Database.Builder.ConnectionProvider
for the database.Observables but the first
sequence will be emitted in its entirety and ignored before o2 starts
emitting.DataSource.Connections from a url (using
DriverManager.getConnection()).ConnectionProvider and
Scheduler.Observable with the count of rows affected by the
update statement.Action1 that increments a counter when the call method
is called.Database.true for commit or false for rollback) to
the dependencies that have to complete their emitting before the
query is executed.true for commit or false for rollback) to
the dependencies that have to complete their emitting before the
query is executed.Observable.Operator to allow the query to be pushed
dependencies via the Observable.lift(Operator) method.Observable.Operator to allow the query to be pushed
dependencies via the Observable.lift(Operator) method.Observable.Operator that flattens a sequence of
Observable into a flat sequence of the items from the
Observables.Database based on a jdbc connection string.Database based on a jdbc connection string.Database based on connections obtained from a
DataSource based on looking up the current ContextDatabase based on connections obtained from a
DataSourceConnection (perhaps from a Connection pool).n to requested field and returns the value prior to
addition once the addition is successful (uses CAS semantics).n to requested and returns the value prior to addition once the
addition is successful (uses CAS semantics).cls.ResultSet into the specified
classes.ResultSet into the specified
classes.ResultSet into the specified
classes.ResultSet into the specified
classes.ResultSet into the specified
classes.ResultSet into the specified
classes.cls.ResultSet into the specified
classes.ResultSet into the specified
classes.ResultSet into the specified
classes.ResultSet into the specified
classes.ResultSet into the specified
classes.ResultSet into the specified
classes.cls.ResultSet into the specified
classes.ResultSet into the specified
classes.ResultSet into the specified
classes.ResultSet into the specified
classes.ResultSet into the specified
classes.ResultSet into the specified
classes.ConnectionProvider.ResultSet into the target
class cls.ResultSet into the target
class cls.ResultSet into the target
class cls.Logger.Schedulers.trampoline().PreparedStatement.setObject(int, Object) with a null
we call PreparedStatement.setNull(int, int) with
Types.CLOB.PreparedStatement.setObject(int, Object) with a null
we call PreparedStatement.setNull(int, int) with
Types.CLOB.Observable.Operator that runs a select query for each list of
parameter objects in the source observable.Observable.Operator to allow the query to be run once per
parameter list in the source.Observable.Operator to allow the query to be pushed
parameters via the Observable.lift(Operator) method.Observable.Operator to allow the query to be pushed
parameters via the Observable.lift(Operator) method.ConnectionProvider to use a connection pool with the
given jdbc url and pool size.ConnectionProvider to use a connection pool with the
given jdbc url and min pool size of 0, max pool size of 10.QuerySelect.Observable.Operator.QueryUpdate.Reader into a String.ResultSet.Observable that is the result of running a sequence of
update commands (insert/update/delete, ddl) read from the given
Observable sequence.Observable.Operator version of Database.run(Observable).Observable that is the result of running a sequence of
update commands (insert/update/delete, ddl) commands read from an
InputStream using the given delimiter as the statement delimiter (for
example semicolon).Observable that is the result of running a sequence of
update commands (insert/update/delete, ddl) commands read from an
InputStream with the given Charset using the given
delimiter as the statement delimiter (for example semicolon).QuerySelect.Builder builder based on the given select
statement sql.QuerySelect.Builder builder and defers specifying sql
to the `autoMap` Class parameter.Func1 that returns an empty Observable.Observable.Operator suitable for use with
Observable.lift(Operator) for instance.QueryUpdate.Builder builder based on the given
update/insert/delete/DDL statement sql.Copyright © 2014–2015. All rights reserved.