org.axonframework.eventhandling.saga.repository.jdbc

Class JdbcSagaStore

java.lang.Object

org.axonframework.eventhandling.saga.repository.jdbc.JdbcSagaStore

All Implemented Interfaces:

SagaStore<Object>

public class JdbcSagaStore
extends Object
implements SagaStore<Object>

Jdbc implementation of the Saga Repository.

Since:

2.1

Author:

Allard Buijze, Kristian Rosenvold

Nested Class Summary

Nested classes/interfaces inherited from interface org.axonframework.eventhandling.saga.repository.SagaStore

SagaStore.Entry<T>

Constructor Summary

Constructors

Constructor and Description
JdbcSagaStore(ConnectionProvider connectionProvider) Initializes a Saga Repository, using given connectionProvider to obtain connections to the database, using a Generic SQL Schema.
JdbcSagaStore(ConnectionProvider connectionProvider, SagaSqlSchema sqldef) Initializes a Saga Repository, using given connectionProvider to obtain connections to the database, and given sqldef to execute SQL statements.
JdbcSagaStore(ConnectionProvider connectionProvider, SagaSqlSchema sqldef, Serializer serializer) Initializes a Saga Repository, using given connectionProvider to obtain connections to the database, and given sqldef to execute SQL statements and serializer to serialize Sagas.
JdbcSagaStore(DataSource dataSource, SagaSqlSchema sqldef) Initializes a Saga Repository, using given dataSource to obtain connections to the database, and given sqldef to execute SQL statements.

Method Summary

Modifier and Type	Method and Description
void	createSchema() Creates the SQL Schema required to store Sagas and their associations,.
void	deleteSaga(Class<?> sagaType, String sagaIdentifier, Set<AssociationValue> associationValues) Deletes a Saga with given sagaType and sagaIdentifier and all its associations.
Set<String>	findSagas(Class<?> sagaType, AssociationValue associationValue) Returns identifiers of saga instances of the given sagaType that have been associated with the given associationValue.
void	insertSaga(Class<?> sagaType, String sagaIdentifier, Object saga, TrackingToken token, Set<AssociationValue> associationValues) Adds a new Saga and its initial association values to the store.
<S> SagaStore.Entry<S>	loadSaga(Class<S> sagaType, String sagaIdentifier) Loads a known saga SagaStore.Entry instance with given sagaType and unique sagaIdentifier.
void	setSerializer(Serializer serializer) Sets the Serializer instance to serialize Sagas with.
void	updateSaga(Class<?> sagaType, String sagaIdentifier, Object saga, TrackingToken token, AssociationValues associationValues) Updates a given Saga after its state was modified.

Methods inherited from class java.lang.Object

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

Constructor Detail

JdbcSagaStore

public JdbcSagaStore(ConnectionProvider connectionProvider)

Initializes a Saga Repository, using given connectionProvider to obtain connections to the database, using a Generic SQL Schema.

Parameters:

connectionProvider - The data source to obtain connections from

JdbcSagaStore

public JdbcSagaStore(DataSource dataSource,
                     SagaSqlSchema sqldef)

Initializes a Saga Repository, using given dataSource to obtain connections to the database, and given sqldef to execute SQL statements.

Parameters:

dataSource - The data source to obtain connections from

sqldef - The definition of SQL operations to execute

JdbcSagaStore

public JdbcSagaStore(ConnectionProvider connectionProvider,
                     SagaSqlSchema sqldef)

Initializes a Saga Repository, using given connectionProvider to obtain connections to the database, and given sqldef to execute SQL statements.

Parameters:

connectionProvider - The provider to obtain connections from

sqldef - The definition of SQL operations to execute

JdbcSagaStore

public JdbcSagaStore(ConnectionProvider connectionProvider,
                     SagaSqlSchema sqldef,
                     Serializer serializer)

Initializes a Saga Repository, using given connectionProvider to obtain connections to the database, and given sqldef to execute SQL statements and serializer to serialize Sagas.

Parameters:

connectionProvider - The provider to obtain connections from

sqldef - The definition of SQL operations to execute

serializer - The serializer to serialize and deserialize Saga instances with

Method Detail

loadSaga

public <S> SagaStore.Entry<S> loadSaga(Class<S> sagaType,
                                       String sagaIdentifier)

Description copied from interface: SagaStore

Loads a known saga SagaStore.Entry instance with given sagaType and unique sagaIdentifier.

Due to the concurrent nature of Sagas, it is not unlikely for a Saga to have ceased to exist after it has been found based on associations. Therefore, a repository should return null in case a Saga doesn't exists, as opposed to throwing an exception.

Specified by:

loadSaga in interface SagaStore<Object>

Parameters:

sagaType - The type of the returned saga entry

sagaIdentifier - The unique identifier of the returned saga entry

Returns:

The saga entry, or null if no such saga exists

findSagas

public Set<String> findSagas(Class<?> sagaType,
                             AssociationValue associationValue)

Description copied from interface: SagaStore

Returns identifiers of saga instances of the given sagaType that have been associated with the given associationValue.

Specified by:

findSagas in interface SagaStore<Object>

Parameters:

sagaType - The type of the returned sagas

associationValue - The value that the returned sagas must be associated with

Returns:

A set of identifiers of sagas having the correct type and association value

deleteSaga

public void deleteSaga(Class<?> sagaType,
                       String sagaIdentifier,
                       Set<AssociationValue> associationValues)

Description copied from interface: SagaStore

Deletes a Saga with given sagaType and sagaIdentifier and all its associations. For convenience all known association values are passed along as well, which has the advantage that the saga store is not required to keep an index of association value to saga identifier.

Specified by:

deleteSaga in interface SagaStore<Object>

Parameters:

sagaType - The type of saga to delete

sagaIdentifier - The identifier of the saga to delete

associationValues - The known associations of the saga

updateSaga

public void updateSaga(Class<?> sagaType,
                       String sagaIdentifier,
                       Object saga,
                       TrackingToken token,
                       AssociationValues associationValues)

Description copied from interface: SagaStore

Updates a given Saga after its state was modified. The tracking token of the event last handled by the Saga is also passed as a parameter. Note that the given token may be null if the Saga is not tracking the event store.

Specified by:

updateSaga in interface SagaStore<Object>

Parameters:

sagaType - The type of the Saga

sagaIdentifier - The identifier of the Saga

saga - The Saga instance

token - The tracking token of the event last handled by the Saga. May be null.

associationValues - The initial association values of the Saga

insertSaga

public void insertSaga(Class<?> sagaType,
                       String sagaIdentifier,
                       Object saga,
                       TrackingToken token,
                       Set<AssociationValue> associationValues)

Description copied from interface: SagaStore

Adds a new Saga and its initial association values to the store. The tracking token of the event last handled by the Saga (usually the event that started the Saga) is also passed as a parameter. Note that the given token may be null if the Saga is not tracking the event store.

Specified by:

insertSaga in interface SagaStore<Object>

Parameters:

sagaType - The type of the Saga

sagaIdentifier - The identifier of the Saga

saga - The Saga instance

token - The tracking token of the event last handled by the Saga. May be null.

associationValues - The initial association values of the Saga

setSerializer

public void setSerializer(Serializer serializer)

Sets the Serializer instance to serialize Sagas with. Defaults to the XStream Serializer.

Parameters:

serializer - the Serializer instance to serialize Sagas with

createSchema

public void createSchema()
                  throws SQLException

Creates the SQL Schema required to store Sagas and their associations,.

Throws:

SQLException - When an error occurs preparing of executing the required statements