@FunctionalInterface public interface ReadEventDataForAggregateStatementBuilder
JdbcEventStorageEngine.fetchDomainEvents(String, long, int)
|Modifier and Type||Method and Description|
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
PreparedStatement build(Connection connection, EventSchema schema, String identifier, long firstSequenceNumber, int batchSize) throws SQLException
connection- The connection to the database.
schema- The EventSchema to be used
identifier- 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.
SQLException- when an exception occurs while creating the prepared statement.
Copyright © 2010–2021. All rights reserved.