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

类 SimpleRxSqlQuerier

java.lang.Object

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

所有已实现的接口:

RxSqlQuerier

public class SimpleRxSqlQuerier
extends java.lang.Object
implements RxSqlQuerier

Sql 查询器简单实现

从以下版本开始:

3.0

构造器概要

构造器

构造器和说明
SimpleRxSqlQuerier(io.r2dbc.spi.ConnectionFactory dataSource, java.lang.String sql)

方法概要

限定符和类型	方法和说明
protected org.reactivestreams.Publisher<? extends io.r2dbc.spi.Result>	buildStatement(io.r2dbc.spi.Connection conn, RxSqlCommand command, boolean returnKeys)
protected org.reactivestreams.Publisher<? extends io.r2dbc.spi.Connection>	getConnection() 获取连接（为转换提供重写机会）
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) 查询并获取行
protected <T> reactor.core.publisher.Mono<T>	queryRowDo(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) 查询并获取行列表
protected <T> reactor.core.publisher.Flux<T>	queryRowListDo(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() 批量更新（插入、或更新、或删除）
protected reactor.core.publisher.Flux<java.lang.Long>	updateBatchDo()
protected reactor.core.publisher.Mono<java.lang.Long>	updateDo()
<T> reactor.core.publisher.Mono<T>	updateReturnKey(java.lang.Class<T> tClass) 更新并返回主键
protected reactor.core.publisher.Mono	updateReturnKeyDo()

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

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

构造器详细资料

SimpleRxSqlQuerier

public SimpleRxSqlQuerier(io.r2dbc.spi.ConnectionFactory dataSource,
                          java.lang.String sql)

方法详细资料

params

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

从接口复制的说明: RxSqlQuerier

绑定参数

指定者:

params 在接口中 RxSqlQuerier

params

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

从接口复制的说明: RxSqlQuerier

绑定参数

指定者:

params 在接口中 RxSqlQuerier

params

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

从接口复制的说明: RxSqlQuerier

绑定参数（用于批处理）

指定者:

params 在接口中 RxSqlQuerier

params

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

从接口复制的说明: RxSqlQuerier

绑定参数（用于批处理）

指定者:

params 在接口中 RxSqlQuerier

queryValue

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

从接口复制的说明: RxSqlQuerier

查询并获取值

指定者:

queryValue 在接口中 RxSqlQuerier

返回:

值

queryValueList

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

从接口复制的说明: RxSqlQuerier

查询并获取值列表

指定者:

queryValueList 在接口中 RxSqlQuerier

返回:

值列表

queryRow

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

从接口复制的说明: RxSqlQuerier

查询并获取行

指定者:

queryRow 在接口中 RxSqlQuerier

参数:

tClass - Map.class or T.class

返回:

值

queryRow

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

从接口复制的说明: RxSqlQuerier

查询并获取行

指定者:

queryRow 在接口中 RxSqlQuerier

返回:

值

queryRowDo

protected <T> reactor.core.publisher.Mono<T> queryRowDo(RxRowConverter<T> converter)

queryRowList

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

从接口复制的说明: RxSqlQuerier

查询并获取行列表

指定者:

queryRowList 在接口中 RxSqlQuerier

参数:

tClass - Map.class or T.class

返回:

值列表

queryRowList

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

从接口复制的说明: RxSqlQuerier

查询并获取行列表

指定者:

queryRowList 在接口中 RxSqlQuerier

返回:

值列表

queryRowListDo

protected <T> reactor.core.publisher.Flux<T> queryRowListDo(RxRowConverter<T> converter)

update

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

从接口复制的说明: RxSqlQuerier

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

指定者:

update 在接口中 RxSqlQuerier

返回:

受影响行数

updateDo

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

updateReturnKey

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

从接口复制的说明: RxSqlQuerier

更新并返回主键

指定者:

updateReturnKey 在接口中 RxSqlQuerier

返回:

主键

updateReturnKeyDo

protected reactor.core.publisher.Mono updateReturnKeyDo()

updateBatch

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

从接口复制的说明: RxSqlQuerier

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

指定者:

updateBatch 在接口中 RxSqlQuerier

返回:

受影响行数组

updateBatchDo

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

buildStatement

protected org.reactivestreams.Publisher<? extends io.r2dbc.spi.Result> buildStatement(io.r2dbc.spi.Connection conn,
                                                                                      RxSqlCommand command,
                                                                                      boolean returnKeys)

getConnection

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

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