org.noear.solon.data.rx.sql.impl

类 SimpleRxSqlExecutor

java.lang.Object

org.noear.solon.data.rx.sql.impl.SimpleRxSqlExecutor

所有已实现的接口:

RxSqlExecutor

public class SimpleRxSqlExecutor
extends java.lang.Object
implements RxSqlExecutor

Sql 执行器简单实现

从以下版本开始:

3.0

构造器概要

构造器

构造器和说明
SimpleRxSqlExecutor(io.r2dbc.spi.ConnectionFactory dataSource, java.lang.String sql, java.lang.Object[] args)

方法概要

限定符和类型	方法和说明
protected org.reactivestreams.Publisher<? extends io.r2dbc.spi.Connection>	getConnection() 获取连接（为转换提供重写机会）
<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) 批量更新（插入、或更新、或删除）
<T> reactor.core.publisher.Flux<java.lang.Long>	updateBatch(java.util.Collection<T> argsList, RxStatementBinder<T> 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) 更新并返回主键

从类继承的方法 java.lang.Object

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

构造器详细资料

SimpleRxSqlExecutor

public SimpleRxSqlExecutor(io.r2dbc.spi.ConnectionFactory dataSource,
                           java.lang.String sql,
                           java.lang.Object[] args)

方法详细资料

queryValue

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

从接口复制的说明: RxSqlExecutor

查询并获取值

指定者:

queryValue 在接口中 RxSqlExecutor

返回:

值

queryValueList

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

从接口复制的说明: RxSqlExecutor

查询并获取值列表

指定者:

queryValueList 在接口中 RxSqlExecutor

返回:

值列表

queryRow

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

从接口复制的说明: RxSqlExecutor

查询并获取行

指定者:

queryRow 在接口中 RxSqlExecutor

参数:

tClass - Map.class or T.class

返回:

值

queryRow

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

从接口复制的说明: RxSqlExecutor

查询并获取行

指定者:

queryRow 在接口中 RxSqlExecutor

返回:

值

queryRowList

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

从接口复制的说明: RxSqlExecutor

查询并获取行列表

指定者:

queryRowList 在接口中 RxSqlExecutor

参数:

tClass - Map.class or T.class

返回:

值列表

queryRowList

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

从接口复制的说明: RxSqlExecutor

查询并获取行列表

指定者:

queryRowList 在接口中 RxSqlExecutor

返回:

值列表

update

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

从接口复制的说明: RxSqlExecutor

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

指定者:

update 在接口中 RxSqlExecutor

返回:

受影响行数

update

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

从接口复制的说明: RxSqlExecutor

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

指定者:

update 在接口中 RxSqlExecutor

参数:

args - 参数

binder - 绑定器

返回:

受影响行数组

updateReturnKey

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

从接口复制的说明: RxSqlExecutor

更新并返回主键

指定者:

updateReturnKey 在接口中 RxSqlExecutor

返回:

主键

updateReturnKey

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

从接口复制的说明: RxSqlExecutor

更新并返回主键

指定者:

updateReturnKey 在接口中 RxSqlExecutor

返回:

主键

updateBatch

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

从接口复制的说明: RxSqlExecutor

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

指定者:

updateBatch 在接口中 RxSqlExecutor

参数:

argsList - 参数集合

返回:

受影响行数组

updateBatch

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

从接口复制的说明: RxSqlExecutor

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

指定者:

updateBatch 在接口中 RxSqlExecutor

参数:

argsList - 参数集合

binder - 绑定器

返回:

受影响行数组

getConnection

protected org.reactivestreams.Publisher<? extends io.r2dbc.spi.Connection> getConnection()

获取连接（为转换提供重写机会）