public class DefaultDictionaryService extends GenericReactiveCrudService<DictionaryEntity,String>
| Constructor and Description |
|---|
DefaultDictionaryService() |
| 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) |
getRepositoryclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitcount, count, createQuery, deleteById, findById, findById, findById, findById, insert, query, query, queryPager, queryPager, queryPager, queryPager, save, save, updateByIdpublic reactor.core.publisher.Mono<Integer> insert(org.reactivestreams.Publisher<DictionaryEntity> entityPublisher)
public reactor.core.publisher.Mono<Integer> insertBatch(org.reactivestreams.Publisher<? extends Collection<DictionaryEntity>> entityPublisher)
public reactor.core.publisher.Mono<Integer> updateById(String id, reactor.core.publisher.Mono<DictionaryEntity> entityPublisher)
public reactor.core.publisher.Mono<Integer> deleteById(org.reactivestreams.Publisher<String> idPublisher)
public reactor.core.publisher.Mono<org.hswebframework.ezorm.rdb.mapping.defaults.SaveResult> save(org.reactivestreams.Publisher<DictionaryEntity> entityPublisher)
public org.hswebframework.ezorm.rdb.mapping.ReactiveUpdate<DictionaryEntity> createUpdate()
ReactiveCrudService
Mono<Integer> flux=
service
.createUpdate()
.set(entity::getState)
.where(MyEntity::getName,name)
.in(MyEntity::getState,state1,state2)
.execute()
public org.hswebframework.ezorm.rdb.mapping.ReactiveDelete createDelete()
ReactiveCrudService
Mono<Integer> flux=
service
.createDelete()
.where(MyEntity::getName,name)
.in(MyEntity::getState,state1,state2)
.execute()
public reactor.core.publisher.Mono<DictionaryEntity> findDetailById(String id)
public reactor.core.publisher.Flux<DictionaryEntity> findAllDetail(QueryParamEntity paramEntity)
Copyright © 2016–2021. All rights reserved.