org.noear.solon.data.rx.sql

接口 RxSqlExecutor

所有已知实现类:

SimpleRxSqlExecutor

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

Sql 执行器

从以下版本开始:

3.0

方法概要

限定符和类型	方法和说明
<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() 更新（插入、或更新、或删除）
<S> reactor.core.publisher.Mono<java.lang.Long>	update(S args, RxStatementBinder<S> binder) 批量更新（插入、或更新、或删除）
reactor.core.publisher.Flux<java.lang.Long>	updateBatch(java.util.Collection<java.lang.Object[]> argsList) 批量更新（插入、或更新、或删除）
<S> reactor.core.publisher.Flux<java.lang.Long>	updateBatch(java.util.Collection<S> argsList, RxStatementBinder<S> binder) 批量更新（插入、或更新、或删除）
<T> reactor.core.publisher.Mono<T>	updateReturnKey(java.lang.Class<T> tClass) 更新并返回主键
<T,S> reactor.core.publisher.Mono<T>	updateReturnKey(java.lang.Class<T> tClass, S args, RxStatementBinder<S> binder) 更新并返回主键

方法详细资料

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()

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

返回:

受影响行数

update

<S> reactor.core.publisher.Mono<java.lang.Long> update(S args,
                                                       RxStatementBinder<S> binder)

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

参数:

args - 参数

binder - 绑定器

返回:

受影响行数组

updateReturnKey

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

更新并返回主键

返回:

主键

updateReturnKey

@Nullable
<T,S> reactor.core.publisher.Mono<T> updateReturnKey(java.lang.Class<T> tClass,
                                                               S args,
                                                               RxStatementBinder<S> binder)

更新并返回主键

返回:

主键

updateBatch

reactor.core.publisher.Flux<java.lang.Long> updateBatch(java.util.Collection<java.lang.Object[]> argsList)

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

参数:

argsList - 参数集合

返回:

受影响行数组

updateBatch

<S> reactor.core.publisher.Flux<java.lang.Long> updateBatch(java.util.Collection<S> argsList,
                                                            RxStatementBinder<S> binder)

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

参数:

argsList - 参数集合

binder - 绑定器

返回:

受影响行数组