org.hswebframework.web.dictionary.service

Class DefaultDictionaryItemService

java.lang.Object

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

org.hswebframework.web.dictionary.service.DefaultDictionaryItemService

All Implemented Interfaces:

ReactiveCrudService<DictionaryItemEntity,String>, ReactiveTreeSortEntityService<DictionaryItemEntity,String>

public class DefaultDictionaryItemService
extends GenericReactiveCrudService<DictionaryItemEntity,String>
implements ReactiveTreeSortEntityService<DictionaryItemEntity,String>

Field Summary

Fields

Modifier and Type	Field and Description
org.springframework.context.ApplicationEventPublisher	eventPublisher

Constructor Summary

Constructors

Constructor and Description
DefaultDictionaryItemService()

Method Summary

Modifier and Type	Method and Description
org.hswebframework.ezorm.rdb.mapping.ReactiveDelete	createDelete() 创建一个DSL动态删除接口,可使用DSL方式进行链式调用来构造动态删除条件.例如:
org.hswebframework.ezorm.rdb.mapping.ReactiveUpdate<DictionaryItemEntity>	createUpdate() 创建一个DSL动态更新接口,可使用DSL方式进行链式调用来构造动态更新条件.例如:
reactor.core.publisher.Mono<Integer>	deleteById(org.reactivestreams.Publisher<String> idPublisher)
IDGenerator<String>	getIDGenerator()
reactor.core.publisher.Mono<Integer>	insert(org.reactivestreams.Publisher<DictionaryItemEntity> entityPublisher)
reactor.core.publisher.Mono<Integer>	insertBatch(org.reactivestreams.Publisher<? extends Collection<DictionaryItemEntity>> entityPublisher)
reactor.core.publisher.Mono<org.hswebframework.ezorm.rdb.mapping.defaults.SaveResult>	save(org.reactivestreams.Publisher<DictionaryItemEntity> entityPublisher)
void	setChildren(DictionaryItemEntity entity, List<DictionaryItemEntity> children)
reactor.core.publisher.Mono<Integer>	updateById(String id, reactor.core.publisher.Mono<DictionaryItemEntity> 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.ReactiveTreeSortEntityService

applyTreeProperty, checkCyclicDependency, createRootNodePredicate, getChildren, isRootNode, queryIncludeChildren, queryIncludeChildren, queryIncludeChildrenTree, queryIncludeParent, queryResultToTree, queryResultToTree, refactorChildPath, save, save, tryRefactorPath

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

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

Field Detail

eventPublisher

@Autowired
public org.springframework.context.ApplicationEventPublisher eventPublisher

Constructor Detail

DefaultDictionaryItemService

public DefaultDictionaryItemService()

Method Detail

getIDGenerator

public IDGenerator<String> getIDGenerator()

Specified by:

getIDGenerator in interface ReactiveTreeSortEntityService<DictionaryItemEntity,String>

setChildren

public void setChildren(DictionaryItemEntity entity,
                        List<DictionaryItemEntity> children)

Specified by:

setChildren in interface ReactiveTreeSortEntityService<DictionaryItemEntity,String>

insert

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

Specified by:

insert in interface ReactiveCrudService<DictionaryItemEntity,String>

Specified by:

insert in interface ReactiveTreeSortEntityService<DictionaryItemEntity,String>

insertBatch

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

Specified by:

insertBatch in interface ReactiveCrudService<DictionaryItemEntity,String>

Specified by:

insertBatch in interface ReactiveTreeSortEntityService<DictionaryItemEntity,String>

updateById

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

Specified by:

updateById in interface ReactiveCrudService<DictionaryItemEntity,String>

Specified by:

updateById in interface ReactiveTreeSortEntityService<DictionaryItemEntity,String>

deleteById

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

Specified by:

deleteById in interface ReactiveCrudService<DictionaryItemEntity,String>

Specified by:

deleteById in interface ReactiveTreeSortEntityService<DictionaryItemEntity,String>

save

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

Specified by:

save in interface ReactiveCrudService<DictionaryItemEntity,String>

Specified by:

save in interface ReactiveTreeSortEntityService<DictionaryItemEntity,String>

createUpdate

public org.hswebframework.ezorm.rdb.mapping.ReactiveUpdate<DictionaryItemEntity> 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()
 

Specified by:

createUpdate in interface ReactiveCrudService<DictionaryItemEntity,String>

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()
 

Specified by:

createDelete in interface ReactiveCrudService<DictionaryItemEntity,String>

Returns:

动态更新接口