org.hswebframework.web.crud.sql

Class DefaultJdbcReactiveExecutor

java.lang.Object

org.hswebframework.ezorm.rdb.executor.jdbc.JdbcSqlExecutor

org.hswebframework.ezorm.rdb.executor.jdbc.JdbcReactiveSqlExecutor

org.hswebframework.web.crud.sql.DefaultJdbcReactiveExecutor

All Implemented Interfaces:

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

public class DefaultJdbcReactiveExecutor
extends org.hswebframework.ezorm.rdb.executor.jdbc.JdbcReactiveSqlExecutor

Field Summary

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

ID, ID_VALUE

Constructor Summary

Constructors

Constructor and Description
DefaultJdbcReactiveExecutor()

Method Summary

Modifier and Type	Method and Description
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)
reactor.core.publisher.Mono<Connection>	getConnection()
protected String	getDatasourceId()
<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.jdbc.JdbcReactiveSqlExecutor

select, toFlux

Methods inherited from class org.hswebframework.ezorm.rdb.executor.jdbc.JdbcSqlExecutor

doExecute, doSelect, doUpdate, getResultValue, releaseResultSet, releaseStatement

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, select, select

Constructor Detail

DefaultJdbcReactiveExecutor

public DefaultJdbcReactiveExecutor()

Method Detail

getDatasourceId

protected String getDatasourceId()

getConnection

public reactor.core.publisher.Mono<Connection> getConnection()

Specified by:

getConnection in class org.hswebframework.ezorm.rdb.executor.jdbc.JdbcReactiveSqlExecutor

select

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

update

@Transactional(transactionManager="connectionFactoryTransactionManager",
               rollbackFor=java.lang.Throwable.class)
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.jdbc.JdbcReactiveSqlExecutor

update

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

update

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

execute

@Transactional(transactionManager="connectionFactoryTransactionManager",
               rollbackFor=java.lang.Throwable.class)
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.jdbc.JdbcReactiveSqlExecutor

execute

@Transactional(transactionManager="connectionFactoryTransactionManager",
               rollbackFor=java.lang.Throwable.class)
public reactor.core.publisher.Mono<Void> execute(org.hswebframework.ezorm.rdb.executor.SqlRequest request)