org.davidmoten.rx.jdbc

Class Call

java.lang.Object

org.davidmoten.rx.jdbc.Call

public final class Call
extends Object

Method Summary

Modifier and Type	Method and Description
static <T1,T2,T3,T4> io.reactivex.Flowable<io.reactivex.Notification<Tuple4<T1,T2,T3,T4>>>	createWithFourOutParameters(io.reactivex.Single<Connection> connection, String sql, io.reactivex.Flowable<List<Object>> parameterGroups, List<org.davidmoten.rx.jdbc.CallableBuilder.ParameterPlaceholder> parameterPlaceholders, Class<T1> cls1, Class<T2> cls2, Class<T3> cls3, Class<T4> cls4)
static <T1,T2,T3,T4> io.reactivex.Flowable<io.reactivex.Notification<CallableBuilder.CallableResultSet4<T1,T2,T3,T4>>>	createWithFourResultSets(io.reactivex.Single<Connection> connection, String sql, io.reactivex.Flowable<List<Object>> parameterGroups, List<org.davidmoten.rx.jdbc.CallableBuilder.ParameterPlaceholder> parameterPlaceholders, io.reactivex.functions.Function<? super ResultSet,? extends T1> f1, io.reactivex.functions.Function<? super ResultSet,? extends T2> f2, io.reactivex.functions.Function<? super ResultSet,? extends T3> f3, io.reactivex.functions.Function<? super ResultSet,? extends T4> f4, int fetchSize)
static io.reactivex.Flowable<?>	createWithNParameters(io.reactivex.Single<Connection> connection, String sql, io.reactivex.Flowable<List<Object>> parameterGroups, List<org.davidmoten.rx.jdbc.CallableBuilder.ParameterPlaceholder> parameterPlaceholders, List<Class<?>> outClasses)
static io.reactivex.Flowable<io.reactivex.Notification<CallableBuilder.CallableResultSetN>>	createWithNResultSets(io.reactivex.Single<Connection> connection, String sql, io.reactivex.Flowable<List<Object>> parameterGroups, List<org.davidmoten.rx.jdbc.CallableBuilder.ParameterPlaceholder> parameterPlaceholders, List<io.reactivex.functions.Function<? super ResultSet,?>> functions, int fetchSize)
static <T1> io.reactivex.Flowable<io.reactivex.Notification<T1>>	createWithOneOutParameter(io.reactivex.Single<Connection> connection, String sql, io.reactivex.Flowable<List<Object>> parameterGroups, List<org.davidmoten.rx.jdbc.CallableBuilder.ParameterPlaceholder> parameterPlaceholders, Class<T1> cls)
static <T1> io.reactivex.Flowable<io.reactivex.Notification<CallableBuilder.CallableResultSet1<T1>>>	createWithOneResultSet(io.reactivex.Single<Connection> connection, String sql, io.reactivex.Flowable<List<Object>> parameterGroups, List<org.davidmoten.rx.jdbc.CallableBuilder.ParameterPlaceholder> parameterPlaceholders, io.reactivex.functions.Function<? super ResultSet,? extends T1> f1, int fetchSize)
static <T1,T2,T3> io.reactivex.Flowable<io.reactivex.Notification<Tuple3<T1,T2,T3>>>	createWithThreeOutParameters(io.reactivex.Single<Connection> connection, String sql, io.reactivex.Flowable<List<Object>> parameterGroups, List<org.davidmoten.rx.jdbc.CallableBuilder.ParameterPlaceholder> parameterPlaceholders, Class<T1> cls1, Class<T2> cls2, Class<T3> cls3)
static <T1,T2,T3> io.reactivex.Flowable<io.reactivex.Notification<CallableBuilder.CallableResultSet3<T1,T2,T3>>>	createWithThreeResultSets(io.reactivex.Single<Connection> connection, String sql, io.reactivex.Flowable<List<Object>> parameterGroups, List<org.davidmoten.rx.jdbc.CallableBuilder.ParameterPlaceholder> parameterPlaceholders, io.reactivex.functions.Function<? super ResultSet,? extends T1> f1, io.reactivex.functions.Function<? super ResultSet,? extends T2> f2, io.reactivex.functions.Function<? super ResultSet,? extends T3> f3, int fetchSize)
static <T1,T2> io.reactivex.Flowable<io.reactivex.Notification<Tuple2<T1,T2>>>	createWithTwoOutParameters(io.reactivex.Single<Connection> connection, String sql, io.reactivex.Flowable<List<Object>> parameterGroups, List<org.davidmoten.rx.jdbc.CallableBuilder.ParameterPlaceholder> parameterPlaceholders, Class<T1> cls1, Class<T2> cls2)
static <T1,T2> io.reactivex.Flowable<io.reactivex.Notification<CallableBuilder.CallableResultSet2<T1,T2>>>	createWithTwoResultSets(io.reactivex.Single<Connection> connection, String sql, io.reactivex.Flowable<List<Object>> parameterGroups, List<org.davidmoten.rx.jdbc.CallableBuilder.ParameterPlaceholder> parameterPlaceholders, io.reactivex.functions.Function<? super ResultSet,? extends T1> f1, io.reactivex.functions.Function<? super ResultSet,? extends T2> f2, int fetchSize)
static io.reactivex.Completable	createWithZeroOutParameters(io.reactivex.Single<Connection> connection, String sql, io.reactivex.Flowable<List<Object>> parameterGroups, List<org.davidmoten.rx.jdbc.CallableBuilder.ParameterPlaceholder> parameterPlaceholders)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

createWithZeroOutParameters

public static io.reactivex.Completable createWithZeroOutParameters(io.reactivex.Single<Connection> connection,
                                                                   String sql,
                                                                   io.reactivex.Flowable<List<Object>> parameterGroups,
                                                                   List<org.davidmoten.rx.jdbc.CallableBuilder.ParameterPlaceholder> parameterPlaceholders)

createWithOneOutParameter

public static <T1> io.reactivex.Flowable<io.reactivex.Notification<T1>> createWithOneOutParameter(io.reactivex.Single<Connection> connection,
                                                                                                  String sql,
                                                                                                  io.reactivex.Flowable<List<Object>> parameterGroups,
                                                                                                  List<org.davidmoten.rx.jdbc.CallableBuilder.ParameterPlaceholder> parameterPlaceholders,
                                                                                                  Class<T1> cls)

createWithTwoOutParameters

public static <T1,T2> io.reactivex.Flowable<io.reactivex.Notification<Tuple2<T1,T2>>> createWithTwoOutParameters(io.reactivex.Single<Connection> connection,
                                                                                                                 String sql,
                                                                                                                 io.reactivex.Flowable<List<Object>> parameterGroups,
                                                                                                                 List<org.davidmoten.rx.jdbc.CallableBuilder.ParameterPlaceholder> parameterPlaceholders,
                                                                                                                 Class<T1> cls1,
                                                                                                                 Class<T2> cls2)

createWithThreeOutParameters

public static <T1,T2,T3> io.reactivex.Flowable<io.reactivex.Notification<Tuple3<T1,T2,T3>>> createWithThreeOutParameters(io.reactivex.Single<Connection> connection,
                                                                                                                         String sql,
                                                                                                                         io.reactivex.Flowable<List<Object>> parameterGroups,
                                                                                                                         List<org.davidmoten.rx.jdbc.CallableBuilder.ParameterPlaceholder> parameterPlaceholders,
                                                                                                                         Class<T1> cls1,
                                                                                                                         Class<T2> cls2,
                                                                                                                         Class<T3> cls3)

createWithFourOutParameters

public static <T1,T2,T3,T4> io.reactivex.Flowable<io.reactivex.Notification<Tuple4<T1,T2,T3,T4>>> createWithFourOutParameters(io.reactivex.Single<Connection> connection,
                                                                                                                              String sql,
                                                                                                                              io.reactivex.Flowable<List<Object>> parameterGroups,
                                                                                                                              List<org.davidmoten.rx.jdbc.CallableBuilder.ParameterPlaceholder> parameterPlaceholders,
                                                                                                                              Class<T1> cls1,
                                                                                                                              Class<T2> cls2,
                                                                                                                              Class<T3> cls3,
                                                                                                                              Class<T4> cls4)

createWithNParameters

public static io.reactivex.Flowable<?> createWithNParameters(io.reactivex.Single<Connection> connection,
                                                             String sql,
                                                             io.reactivex.Flowable<List<Object>> parameterGroups,
                                                             List<org.davidmoten.rx.jdbc.CallableBuilder.ParameterPlaceholder> parameterPlaceholders,
                                                             List<Class<?>> outClasses)

createWithOneResultSet

public static <T1> io.reactivex.Flowable<io.reactivex.Notification<CallableBuilder.CallableResultSet1<T1>>> createWithOneResultSet(io.reactivex.Single<Connection> connection,
                                                                                                                                   String sql,
                                                                                                                                   io.reactivex.Flowable<List<Object>> parameterGroups,
                                                                                                                                   List<org.davidmoten.rx.jdbc.CallableBuilder.ParameterPlaceholder> parameterPlaceholders,
                                                                                                                                   io.reactivex.functions.Function<? super ResultSet,? extends T1> f1,
                                                                                                                                   int fetchSize)

createWithTwoResultSets

public static <T1,T2> io.reactivex.Flowable<io.reactivex.Notification<CallableBuilder.CallableResultSet2<T1,T2>>> createWithTwoResultSets(io.reactivex.Single<Connection> connection,
                                                                                                                                          String sql,
                                                                                                                                          io.reactivex.Flowable<List<Object>> parameterGroups,
                                                                                                                                          List<org.davidmoten.rx.jdbc.CallableBuilder.ParameterPlaceholder> parameterPlaceholders,
                                                                                                                                          io.reactivex.functions.Function<? super ResultSet,? extends T1> f1,
                                                                                                                                          io.reactivex.functions.Function<? super ResultSet,? extends T2> f2,
                                                                                                                                          int fetchSize)

createWithThreeResultSets

public static <T1,T2,T3> io.reactivex.Flowable<io.reactivex.Notification<CallableBuilder.CallableResultSet3<T1,T2,T3>>> createWithThreeResultSets(io.reactivex.Single<Connection> connection,
                                                                                                                                                  String sql,
                                                                                                                                                  io.reactivex.Flowable<List<Object>> parameterGroups,
                                                                                                                                                  List<org.davidmoten.rx.jdbc.CallableBuilder.ParameterPlaceholder> parameterPlaceholders,
                                                                                                                                                  io.reactivex.functions.Function<? super ResultSet,? extends T1> f1,
                                                                                                                                                  io.reactivex.functions.Function<? super ResultSet,? extends T2> f2,
                                                                                                                                                  io.reactivex.functions.Function<? super ResultSet,? extends T3> f3,
                                                                                                                                                  int fetchSize)

createWithFourResultSets

public static <T1,T2,T3,T4> io.reactivex.Flowable<io.reactivex.Notification<CallableBuilder.CallableResultSet4<T1,T2,T3,T4>>> createWithFourResultSets(io.reactivex.Single<Connection> connection,
                                                                                                                                                       String sql,
                                                                                                                                                       io.reactivex.Flowable<List<Object>> parameterGroups,
                                                                                                                                                       List<org.davidmoten.rx.jdbc.CallableBuilder.ParameterPlaceholder> parameterPlaceholders,
                                                                                                                                                       io.reactivex.functions.Function<? super ResultSet,? extends T1> f1,
                                                                                                                                                       io.reactivex.functions.Function<? super ResultSet,? extends T2> f2,
                                                                                                                                                       io.reactivex.functions.Function<? super ResultSet,? extends T3> f3,
                                                                                                                                                       io.reactivex.functions.Function<? super ResultSet,? extends T4> f4,
                                                                                                                                                       int fetchSize)

createWithNResultSets

public static io.reactivex.Flowable<io.reactivex.Notification<CallableBuilder.CallableResultSetN>> createWithNResultSets(io.reactivex.Single<Connection> connection,
                                                                                                                         String sql,
                                                                                                                         io.reactivex.Flowable<List<Object>> parameterGroups,
                                                                                                                         List<org.davidmoten.rx.jdbc.CallableBuilder.ParameterPlaceholder> parameterPlaceholders,
                                                                                                                         List<io.reactivex.functions.Function<? super ResultSet,?>> functions,
                                                                                                                         int fetchSize)