io.eventuate.tram.sagas.orchestration

Class SagaInstanceRepositoryJdbc

java.lang.Object

io.eventuate.tram.sagas.orchestration.SagaInstanceRepositoryJdbc

All Implemented Interfaces:

SagaInstanceRepository

public class SagaInstanceRepositoryJdbc
extends java.lang.Object
implements SagaInstanceRepository

Constructor Summary

Constructors

Constructor and Description
SagaInstanceRepositoryJdbc(io.eventuate.common.jdbc.EventuateJdbcStatementExecutor eventuateJdbcStatementExecutor, io.eventuate.common.id.IdGenerator idGenerator, io.eventuate.common.jdbc.EventuateSchema eventuateSchema)

Method Summary

Modifier and Type	Method and Description
SagaInstance	find(java.lang.String sagaType, java.lang.String sagaId)
java.lang.String	getInsertIntoSagaInstanceParticipantsSql()
java.lang.String	getInsertIntoSagaInstanceSql()
java.lang.String	getSelectFromSagaInstanceParticipantsSql()
java.lang.String	getSelectFromSagaInstanceSql()
java.lang.String	getUpdateSagaInstanceSql()
void	save(SagaInstance sagaInstance)
void	update(SagaInstance sagaInstance)

Methods inherited from class java.lang.Object

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

Constructor Detail

SagaInstanceRepositoryJdbc

public SagaInstanceRepositoryJdbc(io.eventuate.common.jdbc.EventuateJdbcStatementExecutor eventuateJdbcStatementExecutor,
                                  io.eventuate.common.id.IdGenerator idGenerator,
                                  io.eventuate.common.jdbc.EventuateSchema eventuateSchema)

Method Detail

getInsertIntoSagaInstanceSql

public java.lang.String getInsertIntoSagaInstanceSql()

getInsertIntoSagaInstanceParticipantsSql

public java.lang.String getInsertIntoSagaInstanceParticipantsSql()

getSelectFromSagaInstanceSql

public java.lang.String getSelectFromSagaInstanceSql()

getSelectFromSagaInstanceParticipantsSql

public java.lang.String getSelectFromSagaInstanceParticipantsSql()

getUpdateSagaInstanceSql

public java.lang.String getUpdateSagaInstanceSql()

save

public void save(SagaInstance sagaInstance)

Specified by:

save in interface SagaInstanceRepository

find

public SagaInstance find(java.lang.String sagaType,
                         java.lang.String sagaId)

Specified by:

find in interface SagaInstanceRepository

update

public void update(SagaInstance sagaInstance)

Specified by:

update in interface SagaInstanceRepository