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	setInsertIntoSagaInstanceParticipantsSql(java.lang.String insertIntoSagaInstanceParticipantsSql)
void	setInsertIntoSagaInstanceSql(java.lang.String insertIntoSagaInstanceSql)
void	setSelectFromSagaInstanceParticipantsSql(java.lang.String selectFromSagaInstanceParticipantsSql)
void	setSelectFromSagaInstanceSql(java.lang.String selectFromSagaInstanceSql)
void	setUpdateSagaInstanceSql(java.lang.String updateSagaInstanceSql)
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()

setInsertIntoSagaInstanceSql

public void setInsertIntoSagaInstanceSql(java.lang.String insertIntoSagaInstanceSql)

getInsertIntoSagaInstanceParticipantsSql

public java.lang.String getInsertIntoSagaInstanceParticipantsSql()

setInsertIntoSagaInstanceParticipantsSql

public void setInsertIntoSagaInstanceParticipantsSql(java.lang.String insertIntoSagaInstanceParticipantsSql)

getSelectFromSagaInstanceSql

public java.lang.String getSelectFromSagaInstanceSql()

setSelectFromSagaInstanceSql

public void setSelectFromSagaInstanceSql(java.lang.String selectFromSagaInstanceSql)

getSelectFromSagaInstanceParticipantsSql

public java.lang.String getSelectFromSagaInstanceParticipantsSql()

setSelectFromSagaInstanceParticipantsSql

public void setSelectFromSagaInstanceParticipantsSql(java.lang.String selectFromSagaInstanceParticipantsSql)

getUpdateSagaInstanceSql

public java.lang.String getUpdateSagaInstanceSql()

setUpdateSagaInstanceSql

public void setUpdateSagaInstanceSql(java.lang.String updateSagaInstanceSql)

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