Uses of Interface
org.davidmoten.rx.jdbc.Tx

Packages that use Tx

Package	Description
org.davidmoten.rx.jdbc

Uses of Tx in org.davidmoten.rx.jdbc

Methods in org.davidmoten.rx.jdbc that return types with arguments of type Tx

Modifier and Type	Method and Description
default <T> io.reactivex.Flowable<Tx<T>>	GetterTx.autoMap(java.lang.Class<T> cls) Transforms each row of the ResultSet into an instance of T using automapping of the ResultSet columns into corresponding constructor parameters that are assignable.
io.reactivex.Flowable<Tx<CallableResultSet4<T1,T2,T3,T4>>>	TransactedCallableBuilder.CallableResultSets4Builder.build()
io.reactivex.Flowable<Tx<java.lang.Integer>>	TransactedUpdateBuilder.counts()
static <T> io.reactivex.functions.Function<Tx<T>,io.reactivex.Flowable<T>>	Tx.flattenToValuesOnly()
io.reactivex.Flowable<Tx<T>>	TransactedSelectAutomappedBuilder.get()
<T> io.reactivex.Flowable<Tx<T>>	TransactedSelectBuilder.get(ResultSetMapper<? extends T> function)
<T> io.reactivex.Flowable<Tx<T>>	GetterTx.get(ResultSetMapper<? extends T> mapper) Transforms the results using the given function.
<T> io.reactivex.Flowable<Tx<T>>	TransactedReturnGeneratedKeysBuilder.get(ResultSetMapper<? extends T> mapper) Transforms the results using the given function.
default <T> io.reactivex.Flowable<Tx<T>>	GetterTx.getAs(java.lang.Class<T> cls)
default <T1,T2> io.reactivex.Flowable<Tx<Tuple2<T1,T2>>>	GetterTx.getAs(java.lang.Class<T1> cls1, java.lang.Class<T2> cls2) Automaps the columns of the ResultSet into the specified classes.
default <T1,T2,T3> io.reactivex.Flowable<Tx<Tuple3<T1,T2,T3>>>	GetterTx.getAs(java.lang.Class<T1> cls1, java.lang.Class<T2> cls2, java.lang.Class<T3> cls3) Automaps the columns of the ResultSet into the specified classes.
default <T1,T2,T3,T4> io.reactivex.Flowable<Tx<Tuple4<T1,T2,T3,T4>>>	GetterTx.getAs(java.lang.Class<T1> cls1, java.lang.Class<T2> cls2, java.lang.Class<T3> cls3, java.lang.Class<T4> cls4) Automaps the columns of the ResultSet into the specified classes.
default <T1,T2,T3,T4,T5> io.reactivex.Flowable<Tx<Tuple5<T1,T2,T3,T4,T5>>>	GetterTx.getAs(java.lang.Class<T1> cls1, java.lang.Class<T2> cls2, java.lang.Class<T3> cls3, java.lang.Class<T4> cls4, java.lang.Class<T5> cls5) Automaps the columns of the ResultSet into the specified classes.
default <T1,T2,T3,T4,T5,T6> io.reactivex.Flowable<Tx<Tuple6<T1,T2,T3,T4,T5,T6>>>	GetterTx.getAs(java.lang.Class<T1> cls1, java.lang.Class<T2> cls2, java.lang.Class<T3> cls3, java.lang.Class<T4> cls4, java.lang.Class<T5> cls5, java.lang.Class<T6> cls6) Automaps the columns of the ResultSet into the specified classes.
default <T1,T2,T3,T4,T5,T6,T7> io.reactivex.Flowable<Tx<Tuple7<T1,T2,T3,T4,T5,T6,T7>>>	GetterTx.getAs(java.lang.Class<T1> cls1, java.lang.Class<T2> cls2, java.lang.Class<T3> cls3, java.lang.Class<T4> cls4, java.lang.Class<T5> cls5, java.lang.Class<T6> cls6, java.lang.Class<T7> cls7) Automaps the columns of the ResultSet into the specified classes.
default <T> io.reactivex.Flowable<Tx<java.util.Optional<T>>>	GetterTx.getAsOptional(java.lang.Class<T> cls)
default io.reactivex.Flowable<Tx<TupleN<java.lang.Object>>>	GetterTx.getTupleN() Automaps all the columns of the ResultSet into Object .
default <T> io.reactivex.Flowable<Tx<TupleN<T>>>	GetterTx.getTupleN(java.lang.Class<T> cls) Automaps all the columns of the ResultSet into the target class cls.
io.reactivex.Flowable<Tx<T1>>	TransactedCallableBuilder.CallableBuilder1.input(io.reactivex.Flowable<?> f)
io.reactivex.Flowable<Tx<Tuple2<T1,T2>>>	TransactedCallableBuilder.CallableBuilder2.input(io.reactivex.Flowable<?> f)
io.reactivex.Flowable<Tx<Tuple3<T1,T2,T3>>>	TransactedCallableBuilder.CallableBuilder3.input(io.reactivex.Flowable<?> f)
io.reactivex.Flowable<Tx<Tuple4<T1,T2,T3,T4>>>	TransactedCallableBuilder.CallableBuilder4.input(io.reactivex.Flowable<?> f)
io.reactivex.Flowable<Tx<TupleN<java.lang.Object>>>	TransactedCallableBuilder.CallableBuilderN.input(io.reactivex.Flowable<?> f)
io.reactivex.Flowable<Tx<CallableResultSet1<T1>>>	TransactedCallableBuilder.CallableResultSets1Builder.input(io.reactivex.Flowable<?> f)
io.reactivex.Flowable<Tx<CallableResultSet2<T1,T2>>>	TransactedCallableBuilder.CallableResultSets2Builder.input(io.reactivex.Flowable<?> f)
io.reactivex.Flowable<Tx<CallableResultSet3<T1,T2,T3>>>	TransactedCallableBuilder.CallableResultSets3Builder.input(io.reactivex.Flowable<?> f)
io.reactivex.Flowable<Tx<CallableResultSet4<T1,T2,T3,T4>>>	TransactedCallableBuilder.CallableResultSets4Builder.input(io.reactivex.Flowable<?> f)
io.reactivex.Flowable<Tx<CallableResultSetN>>	TransactedCallableBuilder.CallableResultSetsNBuilder.input(io.reactivex.Flowable<?> f)
io.reactivex.Flowable<Tx<T1>>	TransactedCallableBuilder.CallableBuilder1.input(java.lang.Object... objects)
io.reactivex.Flowable<Tx<Tuple2<T1,T2>>>	TransactedCallableBuilder.CallableBuilder2.input(java.lang.Object... objects)
io.reactivex.Flowable<Tx<Tuple3<T1,T2,T3>>>	TransactedCallableBuilder.CallableBuilder3.input(java.lang.Object... objects)
io.reactivex.Flowable<Tx<Tuple4<T1,T2,T3,T4>>>	TransactedCallableBuilder.CallableBuilder4.input(java.lang.Object... objects)
io.reactivex.Flowable<Tx<TupleN<java.lang.Object>>>	TransactedCallableBuilder.CallableBuilderN.input(java.lang.Object... objects)
io.reactivex.Flowable<Tx<CallableResultSet1<T1>>>	TransactedCallableBuilder.CallableResultSets1Builder.input(java.lang.Object... objects)
io.reactivex.Flowable<Tx<CallableResultSet2<T1,T2>>>	TransactedCallableBuilder.CallableResultSets2Builder.input(java.lang.Object... objects)
io.reactivex.Flowable<Tx<CallableResultSet3<T1,T2,T3>>>	TransactedCallableBuilder.CallableResultSets3Builder.input(java.lang.Object... objects)
io.reactivex.Flowable<Tx<CallableResultSet4<T1,T2,T3,T4>>>	TransactedCallableBuilder.CallableResultSets4Builder.input(java.lang.Object... objects)
io.reactivex.Flowable<Tx<CallableResultSetN>>	TransactedCallableBuilder.CallableResultSetsNBuilder.input(java.lang.Object... objects)
static <T> io.reactivex.Flowable<Tx<T>>	Tx.toTx(io.reactivex.Notification<T> n, java.sql.Connection con, Database db)
static <T> io.reactivex.functions.Function<Tx<T>,T>	Tx.toValue()
io.reactivex.Flowable<Tx<?>>	UpdateBuilder.transaction()
io.reactivex.Flowable<Tx<?>>	TransactedUpdateBuilder.tx()
static <T> io.reactivex.functions.Predicate<Tx<T>>	Tx.valuesOnly()

Methods in org.davidmoten.rx.jdbc with parameters of type Tx

Modifier and Type	Method and Description
TransactedBuilder	Database.tx(Tx<?> tx)