org.springframework.data.aerospike.core

Class ReactiveAerospikeTemplate

java.lang.Object

org.springframework.data.aerospike.core.ReactiveAerospikeTemplate

All Implemented Interfaces:

ReactiveAerospikeOperations

public class ReactiveAerospikeTemplate
extends java.lang.Object
implements ReactiveAerospikeOperations

Primary implementation of ReactiveAerospikeOperations.

Author:

Oliver Gierke, Peter Milne

Constructor Summary

Constructors

Constructor and Description
ReactiveAerospikeTemplate(ReactiveQueryEngine queryEngine, java.lang.String namespace, MappingAerospikeConverter converter, AerospikeMappingContext mappingContext, AerospikeExceptionTranslator exceptionTranslator) Creates a new ReactiveAerospikeTemplate for the given AerospikeClient.

Method Summary

Modifier and Type	Method and Description
<T> reactor.core.publisher.Mono<T>	add(T objectToAddTo, java.util.Map<java.lang.String,java.lang.Long> values)
<T> reactor.core.publisher.Mono<T>	add(T objectToAddTo, java.lang.String binName, long value)
protected java.util.function.Function<java.lang.Object,AerospikeWriteData>	aerospikeWriteDataFunction()
<T> reactor.core.publisher.Flux<T>	aggregate(com.aerospike.client.query.Filter filter, java.lang.Class<T> outputType, java.lang.String module, java.lang.String function, java.util.List<com.aerospike.client.Value> arguments)
<T> reactor.core.publisher.Mono<T>	append(T objectToAppendTo, java.util.Map<java.lang.String,java.lang.String> values)
<T> reactor.core.publisher.Mono<T>	append(T objectToAppendTo, java.lang.String binName, java.lang.String value)
reactor.core.publisher.Mono<java.lang.Long>	count(java.lang.Class<?> type)
reactor.core.publisher.Mono<java.lang.Long>	count(java.lang.Class<?> type, java.lang.String setName)
reactor.core.publisher.Mono<java.lang.Long>	count(Query query, java.lang.Class<?> type)
protected <T> reactor.core.publisher.Flux<T>	createFlux(org.reactivestreams.Publisher<T> publisher)
<T> reactor.core.publisher.Mono<java.lang.Void>	createIndex(java.lang.Class<T> domainType, java.lang.String indexName, java.lang.String binName, com.aerospike.client.query.IndexType indexType) Creates index by specified name in Aerospike.
protected <T> reactor.core.publisher.Mono<T>	createMono(org.reactivestreams.Publisher<T> publisher)
reactor.core.publisher.Mono<java.lang.Boolean>	delete(java.lang.Class<?> type)
reactor.core.publisher.Mono<java.lang.Boolean>	delete(java.lang.Object objectToDelete)
reactor.core.publisher.Mono<java.lang.Boolean>	delete(java.lang.Object id, java.lang.Class<?> type)
<T> reactor.core.publisher.Mono<java.lang.Void>	deleteIndex(java.lang.Class<T> domainType, java.lang.String indexName) Deletes index by specified name from Aerospike.
<T> reactor.core.publisher.Mono<T>	execute(java.util.function.Supplier<T> supplier) Execute operation against underlying store.
reactor.core.publisher.Mono<java.lang.Boolean>	exists(java.lang.Object id, java.lang.Class<?> type)
reactor.core.publisher.Mono<java.lang.Boolean>	exists(Query query, java.lang.Class<?> type)
<T> reactor.core.publisher.Flux<T>	find(Query query, java.lang.Class<T> type)
<T> reactor.core.publisher.Flux<T>	findAll(java.lang.Class<T> type)
<T> reactor.core.publisher.Flux<T>	findAll(org.springframework.data.domain.Sort sort, java.lang.Class<T> type)
<T> reactor.core.publisher.Mono<T>	findById(java.lang.Object id, java.lang.Class<T> type)
<T> reactor.core.publisher.Flux<T>	findByIds(java.lang.Iterable<?> ids, java.lang.Class<T> type)
<T> reactor.core.publisher.Flux<T>	findInRange(long offset, long limit, org.springframework.data.domain.Sort sort, java.lang.Class<T> type)
com.aerospike.client.AerospikeClient	getAerospikeClient()
protected WritePolicyBuilder	getCasAwareWritePolicyBuilder(AerospikeWriteData data, AerospikePersistentEntity<?> entity, org.springframework.data.mapping.model.ConvertingPropertyAccessor<?> accessor)
protected abstract MappingAerospikeConverter	getConverter()
protected abstract AerospikeExceptionTranslator	getExceptionTranslator()
abstract org.springframework.data.mapping.context.MappingContext<BasicAerospikePersistentEntity<?>,AerospikePersistentProperty>	getMappingContext()
java.lang.String	getNamespace()
protected <T> org.springframework.data.mapping.model.ConvertingPropertyAccessor<T>	getPropertyAccessor(AerospikePersistentEntity<?> entity, T source)
java.lang.String	getSetName(java.lang.Class<?> entityClass) The Set name used for the specified class by this template.
protected WritePolicyBuilder	getWritePolicyBuilder()
reactor.core.publisher.Mono<java.lang.Boolean>	indexExists(java.lang.String indexName) Checks whether index by specified name exists in Aerospike.
<T> reactor.core.publisher.Mono<T>	insert(T document) Insert operation using the WritePolicy.recordExisits policy of CREATE_ONLY
<T> void	insertAll(java.util.Collection<? extends T> documents)
protected <T> T	mapToEntity(com.aerospike.client.Key key, java.lang.Class<T> type, com.aerospike.client.Record record)
<T> reactor.core.publisher.Mono<T>	persist(T document, com.aerospike.client.policy.WritePolicy writePolicy) Persist document using specified WritePolicy
<T> reactor.core.publisher.Mono<T>	prepend(T objectToPrependTo, java.util.Map<java.lang.String,java.lang.String> values)
<T> reactor.core.publisher.Mono<T>	prepend(T objectToPrependTo, java.lang.String fieldName, java.lang.String value)
<T> reactor.core.publisher.Mono<T>	save(T document) Save operation.
protected java.util.function.Function<java.lang.Throwable,java.lang.Exception>	translateException()
<T> reactor.core.publisher.Mono<T>	update(T document) Update operation using the WritePolicy.recordExisits policy of UPDATE_ONLY

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.data.aerospike.core.ReactiveAerospikeOperations

getEngine, getMappingContext

Constructor Detail

ReactiveAerospikeTemplate

public ReactiveAerospikeTemplate(ReactiveQueryEngine queryEngine,
                                 java.lang.String namespace,
                                 MappingAerospikeConverter converter,
                                 AerospikeMappingContext mappingContext,
                                 AerospikeExceptionTranslator exceptionTranslator)

Creates a new ReactiveAerospikeTemplate for the given AerospikeClient.

Parameters:

converter -

mappingContext -

exceptionTranslator -

namespace - must not be null or empty.

Method Detail

createIndex

public <T> reactor.core.publisher.Mono<java.lang.Void> createIndex(java.lang.Class<T> domainType,
                                                                   java.lang.String indexName,
                                                                   java.lang.String binName,
                                                                   com.aerospike.client.query.IndexType indexType)

Description copied from interface: ReactiveAerospikeOperations

Creates index by specified name in Aerospike.

Specified by:

createIndex in interface ReactiveAerospikeOperations

deleteIndex

public <T> reactor.core.publisher.Mono<java.lang.Void> deleteIndex(java.lang.Class<T> domainType,
                                                                   java.lang.String indexName)

Description copied from interface: ReactiveAerospikeOperations

Deletes index by specified name from Aerospike.

Specified by:

deleteIndex in interface ReactiveAerospikeOperations

indexExists

public reactor.core.publisher.Mono<java.lang.Boolean> indexExists(java.lang.String indexName)

Description copied from interface: ReactiveAerospikeOperations

Checks whether index by specified name exists in Aerospike.

Specified by:

indexExists in interface ReactiveAerospikeOperations

Returns:

true if exists

save

public <T> reactor.core.publisher.Mono<T> save(T document)

Description copied from interface: ReactiveAerospikeOperations

Save operation.

If document has version property - CAS algorithm is used for updating record. Version property is used for deciding whether to create new record or update existing. If version is set to zero - new record will be created, creation will fail is such record already exists. If version is greater than zero - existing record will be updated with RecordExistsAction.REPLACE_ONLY policy taking into consideration the version property of the document.

If document does not have version property - record is updated with RecordExistsAction.UPDATE policy. This means that when such record does not exist it will be created, otherwise updated.

Specified by:

save in interface ReactiveAerospikeOperations

persist

public <T> reactor.core.publisher.Mono<T> persist(T document,
                                                  com.aerospike.client.policy.WritePolicy writePolicy)

Description copied from interface: ReactiveAerospikeOperations

Persist document using specified WritePolicy

Specified by:

persist in interface ReactiveAerospikeOperations

insertAll

public <T> void insertAll(java.util.Collection<? extends T> documents)

insert

public <T> reactor.core.publisher.Mono<T> insert(T document)

Description copied from interface: ReactiveAerospikeOperations

Insert operation using the WritePolicy.recordExisits policy of CREATE_ONLY

Specified by:

insert in interface ReactiveAerospikeOperations

update

public <T> reactor.core.publisher.Mono<T> update(T document)

Description copied from interface: ReactiveAerospikeOperations

Update operation using the WritePolicy.recordExisits policy of UPDATE_ONLY

Specified by:

update in interface ReactiveAerospikeOperations

delete

public reactor.core.publisher.Mono<java.lang.Boolean> delete(java.lang.Class<?> type)

Specified by:

delete in interface ReactiveAerospikeOperations

delete

public reactor.core.publisher.Mono<java.lang.Boolean> delete(java.lang.Object id,
                                                             java.lang.Class<?> type)

Specified by:

delete in interface ReactiveAerospikeOperations

delete

public reactor.core.publisher.Mono<java.lang.Boolean> delete(java.lang.Object objectToDelete)

Specified by:

delete in interface ReactiveAerospikeOperations

exists

public reactor.core.publisher.Mono<java.lang.Boolean> exists(java.lang.Object id,
                                                             java.lang.Class<?> type)

Specified by:

exists in interface ReactiveAerospikeOperations

findAll

public <T> reactor.core.publisher.Flux<T> findAll(java.lang.Class<T> type)

Specified by:

findAll in interface ReactiveAerospikeOperations

findById

public <T> reactor.core.publisher.Mono<T> findById(java.lang.Object id,
                                                   java.lang.Class<T> type)

Specified by:

findById in interface ReactiveAerospikeOperations

findByIds

public <T> reactor.core.publisher.Flux<T> findByIds(java.lang.Iterable<?> ids,
                                                    java.lang.Class<T> type)

Specified by:

findByIds in interface ReactiveAerospikeOperations

aggregate

public <T> reactor.core.publisher.Flux<T> aggregate(com.aerospike.client.query.Filter filter,
                                                    java.lang.Class<T> outputType,
                                                    java.lang.String module,
                                                    java.lang.String function,
                                                    java.util.List<com.aerospike.client.Value> arguments)

Specified by:

aggregate in interface ReactiveAerospikeOperations

getSetName

public java.lang.String getSetName(java.lang.Class<?> entityClass)

Description copied from interface: ReactiveAerospikeOperations

The Set name used for the specified class by this template.

Specified by:

getSetName in interface ReactiveAerospikeOperations

Parameters:

entityClass - must not be null.

Returns:

findAll

public <T> reactor.core.publisher.Flux<T> findAll(org.springframework.data.domain.Sort sort,
                                                  java.lang.Class<T> type)

Specified by:

findAll in interface ReactiveAerospikeOperations

Returns:

execute

public <T> reactor.core.publisher.Mono<T> execute(java.util.function.Supplier<T> supplier)

Description copied from interface: ReactiveAerospikeOperations

Execute operation against underlying store.

Specified by:

execute in interface ReactiveAerospikeOperations

Parameters:

supplier - must not be null.

Returns:

exists

public reactor.core.publisher.Mono<java.lang.Boolean> exists(Query query,
                                                             java.lang.Class<?> type)

Specified by:

exists in interface ReactiveAerospikeOperations

count

public reactor.core.publisher.Mono<java.lang.Long> count(Query query,
                                                         java.lang.Class<?> type)

Specified by:

count in interface ReactiveAerospikeOperations

Returns:

find

public <T> reactor.core.publisher.Flux<T> find(Query query,
                                               java.lang.Class<T> type)

Specified by:

find in interface ReactiveAerospikeOperations

getNamespace

public java.lang.String getNamespace()

findInRange

public <T> reactor.core.publisher.Flux<T> findInRange(long offset,
                                                      long limit,
                                                      org.springframework.data.domain.Sort sort,
                                                      java.lang.Class<T> type)

Specified by:

findInRange in interface ReactiveAerospikeOperations

Returns:

count

public reactor.core.publisher.Mono<java.lang.Long> count(java.lang.Class<?> type)

Specified by:

count in interface ReactiveAerospikeOperations

Returns:

getAerospikeClient

public com.aerospike.client.AerospikeClient getAerospikeClient()

count

public reactor.core.publisher.Mono<java.lang.Long> count(java.lang.Class<?> type,
                                                         java.lang.String setName)

Specified by:

count in interface ReactiveAerospikeOperations

Returns:

prepend

public <T> reactor.core.publisher.Mono<T> prepend(T objectToPrependTo,
                                                  java.lang.String fieldName,
                                                  java.lang.String value)

Specified by:

prepend in interface ReactiveAerospikeOperations

prepend

public <T> reactor.core.publisher.Mono<T> prepend(T objectToPrependTo,
                                                  java.util.Map<java.lang.String,java.lang.String> values)

Specified by:

prepend in interface ReactiveAerospikeOperations

append

public <T> reactor.core.publisher.Mono<T> append(T objectToAppendTo,
                                                 java.util.Map<java.lang.String,java.lang.String> values)

Specified by:

append in interface ReactiveAerospikeOperations

append

public <T> reactor.core.publisher.Mono<T> append(T objectToAppendTo,
                                                 java.lang.String binName,
                                                 java.lang.String value)

Specified by:

append in interface ReactiveAerospikeOperations

add

public <T> reactor.core.publisher.Mono<T> add(T objectToAddTo,
                                              java.util.Map<java.lang.String,java.lang.Long> values)

Specified by:

add in interface ReactiveAerospikeOperations

add

public <T> reactor.core.publisher.Mono<T> add(T objectToAddTo,
                                              java.lang.String binName,
                                              long value)

Specified by:

add in interface ReactiveAerospikeOperations

getConverter

protected abstract MappingAerospikeConverter getConverter()

getExceptionTranslator

protected abstract AerospikeExceptionTranslator getExceptionTranslator()

getMappingContext

public abstract org.springframework.data.mapping.context.MappingContext<BasicAerospikePersistentEntity<?>,AerospikePersistentProperty> getMappingContext()

translateException

protected java.util.function.Function<java.lang.Throwable,java.lang.Exception> translateException()

createMono

protected <T> reactor.core.publisher.Mono<T> createMono(org.reactivestreams.Publisher<T> publisher)

createFlux

protected <T> reactor.core.publisher.Flux<T> createFlux(org.reactivestreams.Publisher<T> publisher)

aerospikeWriteDataFunction

protected java.util.function.Function<java.lang.Object,AerospikeWriteData> aerospikeWriteDataFunction()

mapToEntity

protected <T> T mapToEntity(com.aerospike.client.Key key,
                            java.lang.Class<T> type,
                            com.aerospike.client.Record record)

getPropertyAccessor

protected <T> org.springframework.data.mapping.model.ConvertingPropertyAccessor<T> getPropertyAccessor(AerospikePersistentEntity<?> entity,
                                                                                                       T source)

getWritePolicyBuilder

protected WritePolicyBuilder getWritePolicyBuilder()

getCasAwareWritePolicyBuilder

protected WritePolicyBuilder getCasAwareWritePolicyBuilder(AerospikeWriteData data,
                                                           AerospikePersistentEntity<?> entity,
                                                           org.springframework.data.mapping.model.ConvertingPropertyAccessor<?> accessor)