org.hswebframework.web.dictionary.service

Class DefaultDictionaryService

java.lang.Object

org.hswebframework.web.crud.service.GenericReactiveCrudService<DictionaryEntity,String>

org.hswebframework.web.dictionary.service.DefaultDictionaryService

All Implemented Interfaces:

ReactiveCrudService<DictionaryEntity,String>

public class DefaultDictionaryService
extends GenericReactiveCrudService<DictionaryEntity,String>

Constructor Summary

Constructors

Constructor and Description
DefaultDictionaryService()

Method Summary

Modifier and Type	Method and Description
org.hswebframework.ezorm.rdb.mapping.ReactiveDelete	createDelete() 创建一个DSL动态删除接口,可使用DSL方式进行链式调用来构造动态删除条件.例如:
org.hswebframework.ezorm.rdb.mapping.ReactiveUpdate<DictionaryEntity>	createUpdate() 创建一个DSL动态更新接口,可使用DSL方式进行链式调用来构造动态更新条件.例如:
reactor.core.publisher.Mono<Integer>	deleteById(org.reactivestreams.Publisher<String> idPublisher)
reactor.core.publisher.Flux<DictionaryEntity>	findAllDetail(QueryParamEntity paramEntity)
reactor.core.publisher.Mono<DictionaryEntity>	findDetailById(String id)
reactor.core.publisher.Mono<Integer>	insert(org.reactivestreams.Publisher<DictionaryEntity> entityPublisher)
reactor.core.publisher.Mono<Integer>	insertBatch(org.reactivestreams.Publisher<? extends Collection<DictionaryEntity>> entityPublisher)
reactor.core.publisher.Mono<org.hswebframework.ezorm.rdb.mapping.defaults.SaveResult>	save(org.reactivestreams.Publisher<DictionaryEntity> entityPublisher)
reactor.core.publisher.Mono<Integer>	updateById(String id, reactor.core.publisher.Mono<DictionaryEntity> entityPublisher)

Methods inherited from class org.hswebframework.web.crud.service.GenericReactiveCrudService

getRepository

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.hswebframework.web.crud.service.ReactiveCrudService

count, count, createQuery, deleteById, findById, findById, findById, findById, insert, query, query, queryPager, queryPager, queryPager, queryPager, save, save, updateById

Constructor Detail

DefaultDictionaryService

public DefaultDictionaryService()

Method Detail

insert

public reactor.core.publisher.Mono<Integer> insert(org.reactivestreams.Publisher<DictionaryEntity> entityPublisher)

insertBatch

public reactor.core.publisher.Mono<Integer> insertBatch(org.reactivestreams.Publisher<? extends Collection<DictionaryEntity>> entityPublisher)

updateById

public reactor.core.publisher.Mono<Integer> updateById(String id,
                                                       reactor.core.publisher.Mono<DictionaryEntity> entityPublisher)

deleteById

public reactor.core.publisher.Mono<Integer> deleteById(org.reactivestreams.Publisher<String> idPublisher)

save

public reactor.core.publisher.Mono<org.hswebframework.ezorm.rdb.mapping.defaults.SaveResult> save(org.reactivestreams.Publisher<DictionaryEntity> entityPublisher)

createUpdate

public org.hswebframework.ezorm.rdb.mapping.ReactiveUpdate<DictionaryEntity> createUpdate()

Description copied from interface: ReactiveCrudService

创建一个DSL动态更新接口,可使用DSL方式进行链式调用来构造动态更新条件.例如:

 Mono<Integer> flux=
     service
     .createUpdate()
     .set(entity::getState)
     .where(MyEntity::getName,name)
     .in(MyEntity::getState,state1,state2)
     .execute()
 

Returns:

动态更新接口

createDelete

public org.hswebframework.ezorm.rdb.mapping.ReactiveDelete createDelete()

Description copied from interface: ReactiveCrudService

创建一个DSL动态删除接口,可使用DSL方式进行链式调用来构造动态删除条件.例如:

 Mono<Integer> flux=
     service
     .createDelete()
     .where(MyEntity::getName,name)
     .in(MyEntity::getState,state1,state2)
     .execute()
 

Returns:

动态更新接口

findDetailById

public reactor.core.publisher.Mono<DictionaryEntity> findDetailById(String id)

findAllDetail

public reactor.core.publisher.Flux<DictionaryEntity> findAllDetail(QueryParamEntity paramEntity)