org.seedstack.jpa

Class BaseJpaRepository<A extends AggregateRoot<I>,I>

java.lang.Object

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

org.seedstack.jpa.BaseJpaRepository<A,I>

Type Parameters:

A - Aggregate root class

I - Identifier class

All Implemented Interfaces:

Repository<A,I>

public abstract class BaseJpaRepository<A extends AggregateRoot<I>,I>
extends BaseRepository<A,I>

This class can serve as a base class for the JPA repositories. It provides methods for common CRUD operations as well as access to the entity manager through the getEntityManager() protected method.

Nested Class Summary

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

Repository.Option

Constructor Summary

Constructors

Modifier	Constructor and Description
	BaseJpaRepository() Default constructor.
protected	BaseJpaRepository(Class<A> aggregateRootClass, Class<I> idClass) This protected constructor is intended to be used by JPA repositories that already know their aggregate root and key classes.

Method Summary

Modifier and Type	Method and Description
void	add(A aggregate) Adds an aggregate to the repository.
void	clear() Removes all aggregates from the repository.
boolean	contains(A aggregate) Checks that the specified aggregate is present in the repository.
boolean	contains(I 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(I 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 javax.persistence.EntityManager	getEntityManager() Provides access to the entity manager for implementing custom data access methods.
boolean	isEmpty() Return true if the repository is empty (i.e.
void	remove(A aggregate) Removes the specified aggregate from the repository.
void	remove(I 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

addOrUpdate

Constructor Detail

BaseJpaRepository

public BaseJpaRepository()

Default constructor.

BaseJpaRepository

protected BaseJpaRepository(Class<A> aggregateRootClass,
                            Class<I> idClass)

This protected constructor is intended to be used by JPA repositories that already know their aggregate root and key classes. It is notably used internally by DefaultJpaRepository for providing a default JPA repository for all aggregates.

Parameters:

aggregateRootClass - the aggregate root class.

idClass - the id class.

Method Detail

getEntityManager

protected javax.persistence.EntityManager getEntityManager()

Provides access to the entity manager for implementing custom data access methods.

Returns:

the entity manager.

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(I 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(I 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.

contains

public boolean contains(A aggregate)

Description copied from interface: Repository

Checks that the specified aggregate is present in the repository. The check is only done on the aggregate identity, so this method is equivalent to calling contains(aggregate.getId() ).

Parameters:

aggregate - 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.

isEmpty

public boolean isEmpty()

Description copied from interface: Repository

Return true if the repository is empty (i.e. contains no aggregate) and false otherwise (i.e. contains at least one aggregate).

Returns:

true if repository is empty, false otherwise.

remove

public long remove(Specification<A> specification)

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.

remove

public void remove(I 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.

remove

public void remove(A aggregate)
            throws AggregateNotFoundException

Description copied from interface: Repository

Removes the specified aggregate from the repository.

Parameters:

aggregate - 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.

clear

public void clear()

Description copied from interface: Repository

Removes all aggregates from the repository.