org.noear.solon.data.rx.sql

接口 RxSqlQuerier

所有已知实现类:

SimpleRxSqlQuerier

@Preview(value="3.0")
public interface RxSqlQuerier

Sql 查询器

从以下版本开始:

3.0

方法概要

限定符和类型	方法和说明
RxSqlQuerier	params(java.util.Collection<java.lang.Object[]> argsList) 绑定参数（用于批处理）
<S> RxSqlQuerier	params(java.util.Collection<S> argsList, java.util.function.Supplier<RxStatementBinder<S>> binderSupplier) 绑定参数（用于批处理）
RxSqlQuerier	params(java.lang.Object... args) 绑定参数
<S> RxSqlQuerier	params(S args, RxStatementBinder<S> binder) 绑定参数
<T> reactor.core.publisher.Mono<T>	queryRow(java.lang.Class<T> tClass) 查询并获取行
<T> reactor.core.publisher.Mono<T>	queryRow(RxRowConverter<T> converter) 查询并获取行
<T> reactor.core.publisher.Flux<T>	queryRowList(java.lang.Class<T> tClass) 查询并获取行列表
<T> reactor.core.publisher.Flux<T>	queryRowList(RxRowConverter<T> converter) 查询并获取行列表
<T> reactor.core.publisher.Mono<T>	queryValue(java.lang.Class<T> tClass) 查询并获取值
<T> reactor.core.publisher.Flux<T>	queryValueList(java.lang.Class<T> tClass) 查询并获取值列表
reactor.core.publisher.Mono<java.lang.Long>	update() 更新（插入、或更新、或删除）
reactor.core.publisher.Flux<java.lang.Long>	updateBatch() 批量更新（插入、或更新、或删除）
<T> reactor.core.publisher.Mono<T>	updateReturnKey(java.lang.Class<T> tClass) 更新并返回主键

方法详细资料

params

RxSqlQuerier params(java.lang.Object... args)

绑定参数

params

<S> RxSqlQuerier params(S args,
                        RxStatementBinder<S> binder)

绑定参数

params

RxSqlQuerier params(java.util.Collection<java.lang.Object[]> argsList)

绑定参数（用于批处理）

params

<S> RxSqlQuerier params(java.util.Collection<S> argsList,
                        java.util.function.Supplier<RxStatementBinder<S>> binderSupplier)

绑定参数（用于批处理）

queryValue

@Nullable
<T> reactor.core.publisher.Mono<T> queryValue(java.lang.Class<T> tClass)

查询并获取值

返回:

值

queryValueList

@Nullable
<T> reactor.core.publisher.Flux<T> queryValueList(java.lang.Class<T> tClass)

查询并获取值列表

返回:

值列表

queryRow

@Nullable
<T> reactor.core.publisher.Mono<T> queryRow(java.lang.Class<T> tClass)

查询并获取行

参数:

tClass - Map.class or T.class

返回:

值

queryRow

@Nullable
<T> reactor.core.publisher.Mono<T> queryRow(RxRowConverter<T> converter)

查询并获取行

返回:

值

queryRowList

@Nullable
<T> reactor.core.publisher.Flux<T> queryRowList(java.lang.Class<T> tClass)

查询并获取行列表

参数:

tClass - Map.class or T.class

返回:

值列表

queryRowList

@Nullable
<T> reactor.core.publisher.Flux<T> queryRowList(RxRowConverter<T> converter)

查询并获取行列表

返回:

值列表

update

reactor.core.publisher.Mono<java.lang.Long> update()

更新（插入、或更新、或删除）

返回:

受影响行数

updateReturnKey

@Nullable
<T> reactor.core.publisher.Mono<T> updateReturnKey(java.lang.Class<T> tClass)

更新并返回主键

返回:

主键

updateBatch

reactor.core.publisher.Flux<java.lang.Long> updateBatch()

批量更新（插入、或更新、或删除）

返回:

受影响行数组