com.dslplatform.client

Class ClientPersistableRepository<T extends AggregateRoot>

java.lang.Object

com.dslplatform.client.ClientSearchableRepository<T>

com.dslplatform.client.ClientRepository<T>

com.dslplatform.client.ClientPersistableRepository<T>

Type Parameters:

T - aggregate root type

All Implemented Interfaces:

PersistableRepository<T>, Repository<T>, SearchableRepository<T>

public abstract class ClientPersistableRepository<T extends AggregateRoot>
extends ClientRepository<T>
implements PersistableRepository<T>

Common base implementation for persistable repository. It redirects calls to proxy services. It shouldn't be used or resolved. Instead domain model repositories should be resolved.

DSL example:

 module Todo {
   aggregate Task;
 }
 

Java usage:

 ServiceLocator locator;
 PersistableRepository<Todo.Task> repository = locator.resolve(Todo.TaskRepository.class);
 

Constructor Summary

Constructors

Constructor and Description
ClientPersistableRepository(java.lang.Class<T> manifest, ServiceLocator locator) Generated class will provide class manifest and locator

Method Summary

Methods

Modifier and Type	Method and Description
java.util.concurrent.Future<?>	delete(java.lang.Iterable<T> deletes) Bulk delete.
java.util.concurrent.Future<?>	delete(T... deletes)
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> inserts) Bulk insert.
java.util.concurrent.Future<java.util.List<java.lang.String>>	insert(T... inserts)
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> inserts, java.lang.Iterable<java.util.Map.Entry<T,T>> updates, java.lang.Iterable<T> deletes) Apply local changes to the remote server.
java.util.concurrent.Future<java.util.List<java.lang.String>>	persist(T[] inserts, java.util.Map.Entry<T,T>[] updates, T[] deletes)
java.util.concurrent.Future<java.util.List<java.lang.String>>	update(java.lang.Iterable<T> updates) Bulk update.
java.util.concurrent.Future<java.util.List<java.lang.String>>	update(T... updates)
java.util.concurrent.Future<T>	update(T update) Changing state of an aggregate root.

Methods inherited from class com.dslplatform.client.ClientRepository

find, find, find

Methods inherited from class com.dslplatform.client.ClientSearchableRepository

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

Methods inherited from class java.lang.Object

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

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

Constructor Detail

ClientPersistableRepository

public ClientPersistableRepository(java.lang.Class<T> manifest,
                           ServiceLocator locator)

Generated class will provide class manifest and locator

Parameters:

manifest - domain object type

locator - context in which domain object lives

Method Detail

persist

public java.util.concurrent.Future<java.util.List<java.lang.String>> persist(java.lang.Iterable<T> inserts,
                                                                    java.lang.Iterable<java.util.Map.Entry<T,T>> updates,
                                                                    java.lang.Iterable<T> deletes)

Description copied from interface: PersistableRepository

Apply local changes to the remote server.

Specified by:

persist in interface PersistableRepository<T extends AggregateRoot>

Parameters:

inserts - new aggregate roots

updates - pairs for updating old aggregate to new state

deletes - aggregate roots which will be deleted

Returns:

future uris of newly created aggregates

persist

public java.util.concurrent.Future<java.util.List<java.lang.String>> persist(T[] inserts,
                                                                    java.util.Map.Entry<T,T>[] updates,
                                                                    T[] deletes)

Specified by:

persist in interface PersistableRepository<T extends AggregateRoot>

See Also:

PersistableRepository.persist(Iterable, Iterable, Iterable)

insert

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

Specified by:

insert in interface PersistableRepository<T extends AggregateRoot>

See Also:

PersistableRepository.insert(Iterable)

insert

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

Description copied from interface: PersistableRepository

Bulk insert. Create multiple new aggregates.

Specified by:

insert in interface PersistableRepository<T extends AggregateRoot>

Parameters:

inserts - new aggregate roots

Returns:

future uris of created aggregate roots

insert

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

Description copied from interface: PersistableRepository

Insert a single aggregate.

Specified by:

insert in interface PersistableRepository<T extends AggregateRoot>

Parameters:

insert - new aggregate root

Returns:

future uri of created aggregate root

update

public java.util.concurrent.Future<java.util.List<java.lang.String>> update(java.lang.Iterable<T> updates)

Description copied from interface: PersistableRepository

Bulk update. Changing state of multiple aggregates.

Specified by:

update in interface PersistableRepository<T extends AggregateRoot>

Parameters:

updates - sequence of aggregate roots to update

Returns:

future for error checking

update

public java.util.concurrent.Future<java.util.List<java.lang.String>> update(T... updates)

Specified by:

update in interface PersistableRepository<T extends AggregateRoot>

See Also:

PersistableRepository.update(Iterable)

update

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

Description copied from interface: PersistableRepository

Changing state of an aggregate root.

Specified by:

update in interface PersistableRepository<T extends AggregateRoot>

Parameters:

update - aggregate root to update

Returns:

future for error checking

delete

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

Description copied from interface: PersistableRepository

Bulk delete. Remote multiple aggregates.

Specified by:

delete in interface PersistableRepository<T extends AggregateRoot>

Parameters:

deletes - aggregate roots to delete

Returns:

future for error checking

delete

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

Specified by:

delete in interface PersistableRepository<T extends AggregateRoot>

See Also:

PersistableRepository.delete(Iterable)

delete

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

Description copied from interface: PersistableRepository

Deleting an aggregate.

Specified by:

delete in interface PersistableRepository<T extends AggregateRoot>

Parameters:

delete - aggregate root to delete

Returns:

future for error checking