public class EventuateJdbcAccessImpl extends java.lang.Object implements EventuateJdbcAccess
Modifier and Type | Field and Description |
---|---|
protected org.slf4j.Logger |
logger |
Constructor and Description |
---|
EventuateJdbcAccessImpl(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate) |
Modifier and Type | Method and Description |
---|---|
protected void |
checkSnapshotForDuplicateEvent(LoadedSnapshot ss,
EventContext te) |
<T extends Aggregate<T>> |
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,
Int128 entityVersion,
java.util.List<io.eventuate.javaclient.commonimpl.EventTypeAndData> events,
java.util.Optional<io.eventuate.javaclient.commonimpl.AggregateCrudUpdateOptions> updateOptions) |
public EventuateJdbcAccessImpl(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate)
@Transactional 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)
save
in interface EventuateJdbcAccess
@Transactional 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)
find
in interface EventuateJdbcAccess
@Transactional public SaveUpdateResult update(EntityIdAndType entityIdAndType, Int128 entityVersion, java.util.List<io.eventuate.javaclient.commonimpl.EventTypeAndData> events, java.util.Optional<io.eventuate.javaclient.commonimpl.AggregateCrudUpdateOptions> updateOptions)
update
in interface EventuateJdbcAccess
protected void checkSnapshotForDuplicateEvent(LoadedSnapshot ss, EventContext te)
protected java.lang.String snapshotTriggeringEvents(java.util.Optional<LoadedSnapshot> previousSnapshot, java.util.List<EventAndTrigger> events, java.util.Optional<EventContext> eventContext)