org.seedstack.mongodb.morphia

Class BaseMorphiaRepository<A extends AggregateRoot<ID>,ID>

java.lang.Object

org.seedstack.business.domain.BaseRepository<A,ID>

org.seedstack.mongodb.morphia.BaseMorphiaRepository<A,ID>

Type Parameters:

A - Aggregate root class.

ID - Identifier class.

All Implemented Interfaces:

Repository<A,ID>

public abstract class BaseMorphiaRepository<A extends AggregateRoot<ID>,ID>
extends BaseRepository<A,ID>

This class can serve as a base class for Morphia repositories. It provides methods for common CRUD operations as well as access to the data store through the getDatastore() ()} protected method.

Nested Class Summary

Nested classes/interfaces inherited from interface org.seedstack.business.domain.Repository

Repository.Option

Constructor Summary

Constructors

Constructor and Description
BaseMorphiaRepository()
BaseMorphiaRepository(Class<A> aggregateRootClass, Class<ID> kClass)

Method Summary

Modifier and Type	Method and Description
void	add(A aggregate) Adds an aggregate to the repository.
A	addOrUpdate(A aggregate) Adds an aggregate to the repository or updates it if it already exists.
void	clear() Removes all aggregates from the repository.
boolean	contains(ID id) Checks that the aggregate identified by the specified identifier is present in the repository.
boolean	contains(Specification<A> specification) Check if at least one aggregate satisfying the specified specification is present in the repository.
long	count(Specification<A> specification) Count the number of aggregates in the repository satisfying the given specification.
Optional<A>	get(ID id) Gets an aggregate identified by its identifier.
Stream<A>	get(Specification<A> specification, Repository.Option... options) Finds all aggregates in the repository satisfying the given specification.
protected org.mongodb.morphia.Datastore	getDatastore() Provides access to the Morphia data store for implementing custom data access methods.
void	remove(ID id) Removes the existing aggregate identified with the specified identifier.
long	remove(Specification<A> specification) Removes all aggregates in the repository satisfying the given specification.
long	size() Returns the number of aggregates in the repository.
A	update(A aggregate) Updates an existing aggregate with the specified instance.

Methods inherited from class org.seedstack.business.domain.BaseRepository

getAggregateRootClass, getIdentifierClass, getSpecificationBuilder

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.seedstack.business.domain.Repository

contains, isEmpty, remove

Constructor Detail

BaseMorphiaRepository

public BaseMorphiaRepository()

BaseMorphiaRepository

public BaseMorphiaRepository(Class<A> aggregateRootClass,
                             Class<ID> kClass)

Method Detail

getDatastore

protected org.mongodb.morphia.Datastore getDatastore()

Provides access to the Morphia data store for implementing custom data access methods.

Returns:

the Morphia data store.

add

public void add(A aggregate)
         throws AggregateExistsException

Description copied from interface: Repository

Adds an aggregate to the repository.

Parameters:

aggregate - the aggregate to add.

Throws:

AggregateExistsException - if the repository already contains the aggregate.

get

public Stream<A> get(Specification<A> specification,
                     Repository.Option... options)

Description copied from interface: Repository

Finds all aggregates in the repository satisfying the given specification. Options can be specified to alter the returned stream (order, limits, ...).

Parameters:

specification - the specification aggregates must satisfy.

options - result options.

Returns:

a stream of aggregates.

See Also:

Repository.Option

get

public Optional<A> get(ID id)

Description copied from interface: Repository

Gets an aggregate identified by its identifier.

Parameters:

id - the aggregate identifier.

Returns:

an optional of the corresponding aggregate.

contains

public boolean contains(Specification<A> specification)

Description copied from interface: Repository

Check if at least one aggregate satisfying the specified specification is present in the repository.

Parameters:

specification - the specification.

Returns:

true if at least one aggregate satisfying the specification is present, false otherwise.

contains

public boolean contains(ID id)

Description copied from interface: Repository

Checks that the aggregate identified by the specified identifier is present in the repository.

Parameters:

id - the aggregate identifier.

Returns:

true if the aggregate is present, false otherwise.

count

public long count(Specification<A> specification)

Description copied from interface: Repository

Count the number of aggregates in the repository satisfying the given specification.

Parameters:

specification - the specification aggregates must satisfy.

Returns:

the number of aggregates in the repository satisfying the specification.

size

public long size()

Description copied from interface: Repository

Returns the number of aggregates in the repository.

Returns:

the number of aggregates in the repository.

remove

public long remove(Specification<A> specification)
            throws AggregateNotFoundException

Description copied from interface: Repository

Removes all aggregates in the repository satisfying the given specification.

Parameters:

specification - the specification aggregates must satisfy.

Returns:

the number of aggregates removed from the repository.

Throws:

AggregateNotFoundException - if the repository doesn't contain the aggregate.

remove

public void remove(ID id)
            throws AggregateNotFoundException

Description copied from interface: Repository

Removes the existing aggregate identified with the specified identifier.

Parameters:

id - the identifier of the aggregate to remove.

Throws:

AggregateNotFoundException - if the repository doesn't contain the aggregate.

update

public A update(A aggregate)
         throws AggregateNotFoundException

Description copied from interface: Repository

Updates an existing aggregate with the specified instance.

Parameters:

aggregate - the aggregate to update.

Returns:

the update aggregate.

Throws:

AggregateNotFoundException - if the repository doesn't contain the aggregate.

addOrUpdate

public A addOrUpdate(A aggregate)

Description copied from interface: Repository

Adds an aggregate to the repository or updates it if it already exists. This operation can be useful in some circumstances but operations with clearer semantics like Repository.add(A) and Repository.update(AggregateRoot) should be preferred.

Parameters:

aggregate - the aggregate to update.

Returns:

the update aggregate.

clear

public void clear()

Description copied from interface: Repository

Removes all aggregates from the repository.