io.eventuate.javaclient.jdbc

Class EventuateJdbcAccessImpl

java.lang.Object

io.eventuate.javaclient.jdbc.EventuateJdbcAccessImpl

All Implemented Interfaces:

EventuateJdbcAccess

public class EventuateJdbcAccessImpl
extends java.lang.Object
implements EventuateJdbcAccess

Field Summary

Fields

Modifier and Type	Field and Description
protected org.slf4j.Logger	logger

Constructor Summary

Constructors

Constructor and Description
EventuateJdbcAccessImpl(io.eventuate.common.jdbc.EventuateTransactionTemplate eventuateTransactionTemplate, io.eventuate.common.jdbc.EventuateJdbcStatementExecutor eventuateJdbcStatementExecutor, io.eventuate.common.jdbc.EventuateCommonJdbcOperations eventuateCommonJdbcOperations)
EventuateJdbcAccessImpl(io.eventuate.common.jdbc.EventuateTransactionTemplate eventuateTransactionTemplate, io.eventuate.common.jdbc.EventuateJdbcStatementExecutor eventuateJdbcStatementExecutor, io.eventuate.common.jdbc.EventuateCommonJdbcOperations eventuateCommonJdbcOperations, io.eventuate.common.jdbc.EventuateSchema eventuateSchema)

Method Summary

Modifier and Type	Method and Description
protected void	checkSnapshotForDuplicateEvent(LoadedSnapshot ss, EventContext te)
<T extends Aggregate<T>> io.eventuate.javaclient.commonimpl.LoadedEvents	find(java.lang.String aggregateType, java.lang.String entityId, java.util.Optional<io.eventuate.javaclient.commonimpl.AggregateCrudFindOptions> findOptions)
SaveUpdateResult	save(java.lang.String aggregateType, java.util.List<io.eventuate.javaclient.commonimpl.EventTypeAndData> events, java.util.Optional<io.eventuate.javaclient.commonimpl.AggregateCrudSaveOptions> saveOptions)
protected java.lang.String	snapshotTriggeringEvents(java.util.Optional<LoadedSnapshot> previousSnapshot, java.util.List<EventAndTrigger> events, java.util.Optional<EventContext> eventContext)
SaveUpdateResult	update(EntityIdAndType entityIdAndType, io.eventuate.common.id.Int128 entityVersion, java.util.List<io.eventuate.javaclient.commonimpl.EventTypeAndData> events, java.util.Optional<io.eventuate.javaclient.commonimpl.AggregateCrudUpdateOptions> updateOptions)
SaveUpdateResult	updateWithoutTransaction(EntityIdAndType entityIdAndType, io.eventuate.common.id.Int128 entityVersion, java.util.List<io.eventuate.javaclient.commonimpl.EventTypeAndData> events, java.util.Optional<io.eventuate.javaclient.commonimpl.AggregateCrudUpdateOptions> updateOptions)

Methods inherited from class java.lang.Object

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

Field Detail

logger

protected org.slf4j.Logger logger

Constructor Detail

EventuateJdbcAccessImpl

public EventuateJdbcAccessImpl(io.eventuate.common.jdbc.EventuateTransactionTemplate eventuateTransactionTemplate,
                               io.eventuate.common.jdbc.EventuateJdbcStatementExecutor eventuateJdbcStatementExecutor,
                               io.eventuate.common.jdbc.EventuateCommonJdbcOperations eventuateCommonJdbcOperations)

EventuateJdbcAccessImpl

public EventuateJdbcAccessImpl(io.eventuate.common.jdbc.EventuateTransactionTemplate eventuateTransactionTemplate,
                               io.eventuate.common.jdbc.EventuateJdbcStatementExecutor eventuateJdbcStatementExecutor,
                               io.eventuate.common.jdbc.EventuateCommonJdbcOperations eventuateCommonJdbcOperations,
                               io.eventuate.common.jdbc.EventuateSchema eventuateSchema)

Method Detail

save

public SaveUpdateResult save(java.lang.String aggregateType,
                             java.util.List<io.eventuate.javaclient.commonimpl.EventTypeAndData> events,
                             java.util.Optional<io.eventuate.javaclient.commonimpl.AggregateCrudSaveOptions> saveOptions)

Specified by:

save in interface EventuateJdbcAccess

find

public <T extends Aggregate<T>> io.eventuate.javaclient.commonimpl.LoadedEvents find(java.lang.String aggregateType,
                                                                                     java.lang.String entityId,
                                                                                     java.util.Optional<io.eventuate.javaclient.commonimpl.AggregateCrudFindOptions> findOptions)

Specified by:

find in interface EventuateJdbcAccess

update

public SaveUpdateResult update(EntityIdAndType entityIdAndType,
                               io.eventuate.common.id.Int128 entityVersion,
                               java.util.List<io.eventuate.javaclient.commonimpl.EventTypeAndData> events,
                               java.util.Optional<io.eventuate.javaclient.commonimpl.AggregateCrudUpdateOptions> updateOptions)

Specified by:

update in interface EventuateJdbcAccess

updateWithoutTransaction

public SaveUpdateResult updateWithoutTransaction(EntityIdAndType entityIdAndType,
                                                 io.eventuate.common.id.Int128 entityVersion,
                                                 java.util.List<io.eventuate.javaclient.commonimpl.EventTypeAndData> events,
                                                 java.util.Optional<io.eventuate.javaclient.commonimpl.AggregateCrudUpdateOptions> updateOptions)

checkSnapshotForDuplicateEvent

protected void checkSnapshotForDuplicateEvent(LoadedSnapshot ss,
                                              EventContext te)

snapshotTriggeringEvents

protected java.lang.String snapshotTriggeringEvents(java.util.Optional<LoadedSnapshot> previousSnapshot,
                                                    java.util.List<EventAndTrigger> events,
                                                    java.util.Optional<EventContext> eventContext)