org.hswebframework.web.crud.service

Interface EnableCacheReactiveCrudService<E,K>

All Superinterfaces:

ReactiveCrudService<E,K>

All Known Implementing Classes:

GenericReactiveCacheSupportCrudService, OAuth2ClientService

public interface EnableCacheReactiveCrudService<E,K>
extends ReactiveCrudService<E,K>

Method Summary

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

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

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

Method Detail

getCache

ReactiveCache<E> getCache()

findById

default reactor.core.publisher.Mono<E> findById(K id)

Specified by:

findById in interface ReactiveCrudService<E,K>

findById

default reactor.core.publisher.Mono<E> findById(reactor.core.publisher.Mono<K> publisher)

Specified by:

findById in interface ReactiveCrudService<E,K>

updateById

default reactor.core.publisher.Mono<Integer> updateById(K id,
                                                        reactor.core.publisher.Mono<E> entityPublisher)

Specified by:

updateById in interface ReactiveCrudService<E,K>

save

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

Specified by:

save in interface ReactiveCrudService<E,K>

insert

default reactor.core.publisher.Mono<Integer> insert(org.reactivestreams.Publisher<E> entityPublisher)

Specified by:

insert in interface ReactiveCrudService<E,K>

insertBatch

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

Specified by:

insertBatch in interface ReactiveCrudService<E,K>

deleteById

default reactor.core.publisher.Mono<Integer> deleteById(org.reactivestreams.Publisher<K> idPublisher)

Specified by:

deleteById in interface ReactiveCrudService<E,K>

createUpdate

default org.hswebframework.ezorm.rdb.mapping.ReactiveUpdate<E> 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<E,K>

Returns:

动态更新接口

createDelete

default 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<E,K>

Returns:

动态更新接口