org.hswebframework.web.crud.sql

Class DefaultR2dbcExecutor

java.lang.Object

org.hswebframework.ezorm.rdb.executor.reactive.r2dbc.R2dbcReactiveSqlExecutor

org.hswebframework.web.crud.sql.DefaultR2dbcExecutor

All Implemented Interfaces:

org.hswebframework.ezorm.core.meta.Feature, org.hswebframework.ezorm.rdb.executor.reactive.ReactiveSqlExecutor

public class DefaultR2dbcExecutor
extends org.hswebframework.ezorm.rdb.executor.reactive.r2dbc.R2dbcReactiveSqlExecutor

Field Summary

Fields inherited from interface org.hswebframework.ezorm.rdb.executor.reactive.ReactiveSqlExecutor

ID, ID_VALUE

Constructor Summary

Constructors

Constructor and Description
DefaultR2dbcExecutor()

Method Summary

Modifier and Type	Method and Description
protected void	bind(io.r2dbc.spi.Statement statement, int index, Object value)
protected void	bindNull(io.r2dbc.spi.Statement statement, int index, Class type)
protected org.hswebframework.ezorm.rdb.executor.SqlRequest	convertRequest(org.hswebframework.ezorm.rdb.executor.SqlRequest sqlRequest)
reactor.core.publisher.Mono<Void>	execute(org.reactivestreams.Publisher<org.hswebframework.ezorm.rdb.executor.SqlRequest> request)
reactor.core.publisher.Mono<Void>	execute(org.hswebframework.ezorm.rdb.executor.SqlRequest request)
String	getBindSymbol()
protected reactor.core.publisher.Mono<io.r2dbc.spi.Connection>	getConnection()
protected void	releaseConnection(reactor.core.publisher.SignalType type, io.r2dbc.spi.Connection connection)
<E> reactor.core.publisher.Flux<E>	select(org.reactivestreams.Publisher<org.hswebframework.ezorm.rdb.executor.SqlRequest> request, org.hswebframework.ezorm.rdb.executor.wrapper.ResultWrapper<E,?> wrapper)
<E> reactor.core.publisher.Flux<E>	select(org.hswebframework.ezorm.rdb.executor.SqlRequest sqlRequest, org.hswebframework.ezorm.rdb.executor.wrapper.ResultWrapper<E,?> wrapper)
reactor.core.publisher.Flux<Map<String,Object>>	select(String sql, Object... args)
<E> reactor.core.publisher.Flux<E>	select(String sql, org.hswebframework.ezorm.rdb.executor.wrapper.ResultWrapper<E,?> wrapper)
reactor.core.publisher.Mono<Integer>	update(org.reactivestreams.Publisher<org.hswebframework.ezorm.rdb.executor.SqlRequest> request)
reactor.core.publisher.Mono<Integer>	update(org.hswebframework.ezorm.rdb.executor.SqlRequest request)
reactor.core.publisher.Mono<Integer>	update(String sql, Object... args)

Methods inherited from class org.hswebframework.ezorm.rdb.executor.reactive.r2dbc.R2dbcReactiveSqlExecutor

doExecute, doExecute, getBindFirstIndex, getLogger, prepareStatement, setLogger, toFlux

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.hswebframework.ezorm.rdb.executor.reactive.ReactiveSqlExecutor

getId, getName, getType

Constructor Detail

DefaultR2dbcExecutor

public DefaultR2dbcExecutor()

Method Detail

getBindSymbol

public String getBindSymbol()

Overrides:

getBindSymbol in class org.hswebframework.ezorm.rdb.executor.reactive.r2dbc.R2dbcReactiveSqlExecutor

convertRequest

protected org.hswebframework.ezorm.rdb.executor.SqlRequest convertRequest(org.hswebframework.ezorm.rdb.executor.SqlRequest sqlRequest)

Overrides:

convertRequest in class org.hswebframework.ezorm.rdb.executor.reactive.r2dbc.R2dbcReactiveSqlExecutor

bindNull

protected void bindNull(io.r2dbc.spi.Statement statement,
                        int index,
                        Class type)

Overrides:

bindNull in class org.hswebframework.ezorm.rdb.executor.reactive.r2dbc.R2dbcReactiveSqlExecutor

bind

protected void bind(io.r2dbc.spi.Statement statement,
                    int index,
                    Object value)

Overrides:

bind in class org.hswebframework.ezorm.rdb.executor.reactive.r2dbc.R2dbcReactiveSqlExecutor

getConnection

protected reactor.core.publisher.Mono<io.r2dbc.spi.Connection> getConnection()

Specified by:

getConnection in class org.hswebframework.ezorm.rdb.executor.reactive.r2dbc.R2dbcReactiveSqlExecutor

releaseConnection

protected void releaseConnection(reactor.core.publisher.SignalType type,
                                 io.r2dbc.spi.Connection connection)

Specified by:

releaseConnection in class org.hswebframework.ezorm.rdb.executor.reactive.r2dbc.R2dbcReactiveSqlExecutor

execute

@Transactional(propagation=REQUIRES_NEW,
               transactionManager="connectionFactoryTransactionManager")
public reactor.core.publisher.Mono<Void> execute(org.hswebframework.ezorm.rdb.executor.SqlRequest request)

execute

@Transactional(propagation=REQUIRES_NEW,
               transactionManager="connectionFactoryTransactionManager")
public reactor.core.publisher.Mono<Void> execute(org.reactivestreams.Publisher<org.hswebframework.ezorm.rdb.executor.SqlRequest> request)

Specified by:

execute in interface org.hswebframework.ezorm.rdb.executor.reactive.ReactiveSqlExecutor

Overrides:

execute in class org.hswebframework.ezorm.rdb.executor.reactive.r2dbc.R2dbcReactiveSqlExecutor

update

@Transactional(transactionManager="connectionFactoryTransactionManager")
public reactor.core.publisher.Mono<Integer> update(org.reactivestreams.Publisher<org.hswebframework.ezorm.rdb.executor.SqlRequest> request)

Specified by:

update in interface org.hswebframework.ezorm.rdb.executor.reactive.ReactiveSqlExecutor

Overrides:

update in class org.hswebframework.ezorm.rdb.executor.reactive.r2dbc.R2dbcReactiveSqlExecutor

update

@Transactional(transactionManager="connectionFactoryTransactionManager")
public reactor.core.publisher.Mono<Integer> update(org.hswebframework.ezorm.rdb.executor.SqlRequest request)

update

@Transactional(transactionManager="connectionFactoryTransactionManager")
public reactor.core.publisher.Mono<Integer> update(String sql,
                                                                                                                            Object... args)

select

@Transactional(readOnly=true,
               transactionManager="connectionFactoryTransactionManager")
public <E> reactor.core.publisher.Flux<E> select(org.reactivestreams.Publisher<org.hswebframework.ezorm.rdb.executor.SqlRequest> request,
                                                                                                                                                        org.hswebframework.ezorm.rdb.executor.wrapper.ResultWrapper<E,?> wrapper)

Specified by:

select in interface org.hswebframework.ezorm.rdb.executor.reactive.ReactiveSqlExecutor

Overrides:

select in class org.hswebframework.ezorm.rdb.executor.reactive.r2dbc.R2dbcReactiveSqlExecutor

select

@Transactional(readOnly=true,
               transactionManager="connectionFactoryTransactionManager")
public reactor.core.publisher.Flux<Map<String,Object>> select(String sql,
                                                                                                                                                                     Object... args)

select

@Transactional(readOnly=true,
               transactionManager="connectionFactoryTransactionManager")
public <E> reactor.core.publisher.Flux<E> select(String sql,
                                                                                                                                                        org.hswebframework.ezorm.rdb.executor.wrapper.ResultWrapper<E,?> wrapper)

select

@Transactional(readOnly=true,
               transactionManager="connectionFactoryTransactionManager")
public <E> reactor.core.publisher.Flux<E> select(org.hswebframework.ezorm.rdb.executor.SqlRequest sqlRequest,
                                                                                                                                                        org.hswebframework.ezorm.rdb.executor.wrapper.ResultWrapper<E,?> wrapper)