@FunctionalInterface public interface ReadEventDataForAggregateStatementBuilder
JdbcEventStorageEngine.fetchDomainEvents(String,
long, int)
Modifier and Type | Method and Description |
---|---|
PreparedStatement |
build(Connection connection,
EventSchema schema,
String identifier,
long firstSequenceNumber,
int batchSize)
Creates a statement to read domain event entries for an aggregate with given identifier starting with the first
entry having a sequence number that is equal or larger than the given
firstSequenceNumber . |
PreparedStatement build(Connection connection, EventSchema schema, String identifier, long firstSequenceNumber, int batchSize) throws SQLException
firstSequenceNumber
.connection
- The connection to the database.schema
- The EventSchema to be usedidentifier
- The identifier of the aggregate.firstSequenceNumber
- The expected sequence number of the first returned entry.batchSize
- The number of items to include in the batch.PreparedStatement
.SQLException
- when an exception occurs while creating the prepared statement.Copyright © 2010–2020. All rights reserved.