com.dslplatform.patterns

Interface PersistableRepository<T extends AggregateRoot>

Type Parameters:

T - type of aggregate root

All Superinterfaces:

Repository<T>, SearchableRepository<T>

All Known Implementing Classes:

ClientPersistableRepository

public interface PersistableRepository<T extends AggregateRoot>
extends Repository<T>

Service for doing CRUD operations. It can be used for applying changes on aggregate root to the remote server.

It should be used when Future is a preferred way of interacting with the remote server or bulk operations are required.

Method Summary

Methods

Modifier and Type	Method and Description
java.util.concurrent.Future<?>	delete(java.lang.Iterable<T> delete) Bulk delete.
java.util.concurrent.Future<?>	delete(T... delete)
java.util.concurrent.Future<?>	delete(T delete) Deleting an aggregate.
java.util.concurrent.Future<java.util.List<java.lang.String>>	insert(java.lang.Iterable<T> insert) Bulk insert.
java.util.concurrent.Future<java.util.List<java.lang.String>>	insert(T... insert)
java.util.concurrent.Future<java.lang.String>	insert(T insert) Insert a single aggregate.
java.util.concurrent.Future<java.util.List<java.lang.String>>	persist(java.lang.Iterable<T> insert, java.lang.Iterable<java.util.Map.Entry<T,T>> update, java.lang.Iterable<T> delete) Apply local changes to the remote server.
java.util.concurrent.Future<java.util.List<java.lang.String>>	persist(T[] insert, java.util.Map.Entry<T,T>[] update, T[] delete)
java.util.concurrent.Future<?>	update(java.lang.Iterable<T> update) Bulk update.
java.util.concurrent.Future<?>	update(T... update)
java.util.concurrent.Future<?>	update(T update) Changing state of an aggregate root.

Methods inherited from interface com.dslplatform.patterns.Repository

find, find, find

Methods inherited from interface com.dslplatform.patterns.SearchableRepository

builder, count, countAll, findAll, findAll, findAll, search, search, search

Method Detail

persist

java.util.concurrent.Future<java.util.List<java.lang.String>> persist(java.lang.Iterable<T> insert,
                                                                    java.lang.Iterable<java.util.Map.Entry<T,T>> update,
                                                                    java.lang.Iterable<T> delete)

Apply local changes to the remote server.

Parameters:

insert - new aggregate roots

update - pairs for updating old aggregate to new state

delete - aggregate roots which will be deleted

Returns:

future uris of newly created aggregates

persist

java.util.concurrent.Future<java.util.List<java.lang.String>> persist(T[] insert,
                                                                    java.util.Map.Entry<T,T>[] update,
                                                                    T[] delete)

See Also:

persist(Iterable, Iterable, Iterable)

insert

java.util.concurrent.Future<java.util.List<java.lang.String>> insert(java.lang.Iterable<T> insert)

Bulk insert. Create multiple new aggregates.

Parameters:

insert - new aggregate roots

Returns:

future uris of created aggregate roots

insert

java.util.concurrent.Future<java.util.List<java.lang.String>> insert(T... insert)

See Also:

insert(Iterable)

insert

java.util.concurrent.Future<java.lang.String> insert(T insert)

Insert a single aggregate.

Parameters:

insert - new aggregate root

Returns:

future uri of created aggregate root

update

java.util.concurrent.Future<?> update(java.lang.Iterable<T> update)

Bulk update. Changing state of multiple aggregates.

Parameters:

update - sequence of aggregate roots to update

Returns:

future for error checking

update

java.util.concurrent.Future<?> update(T... update)

See Also:

update(Iterable)

update

java.util.concurrent.Future<?> update(T update)

Changing state of an aggregate root.

Parameters:

update - aggregate root to update

Returns:

future for error checking

delete

java.util.concurrent.Future<?> delete(java.lang.Iterable<T> delete)

Bulk delete. Remote multiple aggregates.

Parameters:

delete - aggregate roots to delete

Returns:

future for error checking

delete

java.util.concurrent.Future<?> delete(T... delete)

See Also:

delete(Iterable)

delete

java.util.concurrent.Future<?> delete(T delete)

Deleting an aggregate.

Parameters:

delete - aggregate root to delete

Returns:

future for error checking