@FunctionalInterface public interface AppendSnapshotStatementBuilder
JdbcEventStorageEngine.storeSnapshot(DomainEventMessage,
Serializer)
.Modifier and Type | Method and Description |
---|---|
PreparedStatement |
build(Connection connection,
EventSchema schema,
Class<?> dataType,
DomainEventMessage<?> snapshot,
Serializer serializer,
TimestampWriter timestampWriter)
Creates a statement to be used at
JdbcEventStorageEngine.storeSnapshot(DomainEventMessage, Serializer) |
PreparedStatement build(Connection connection, EventSchema schema, Class<?> dataType, DomainEventMessage<?> snapshot, Serializer serializer, TimestampWriter timestampWriter) throws SQLException
JdbcEventStorageEngine.storeSnapshot(DomainEventMessage, Serializer)
connection
- The connection to the database.schema
- The EventSchema to be useddataType
- The serialized type of the payload and metadata.snapshot
- The snapshot to be appended.serializer
- The serializer for the payload and metadata.timestampWriter
- Writer responsible for writing timestamp in the correct format for the given database.PreparedStatement
.SQLException
- when an exception occurs while creating the prepared statement.Copyright © 2010–2020. All rights reserved.