Uses of Class
org.axonframework.eventsourcing.eventstore.jdbc.EventSchema

Packages that use EventSchema

Package	Description
org.axonframework.eventsourcing.eventstore.jdbc	JDBC Implementation of the EventStore.
org.axonframework.eventsourcing.eventstore.jdbc.statements

Uses of EventSchema in org.axonframework.eventsourcing.eventstore.jdbc

Methods in org.axonframework.eventsourcing.eventstore.jdbc that return EventSchema

Modifier and Type	Method and Description
EventSchema	EventSchema.Builder.build() Builds a new EventSchema from builder values.
protected EventSchema	JdbcEventStorageEngine.schema() Returns the EventSchema that defines the table and column names of event tables in the database.

Methods in org.axonframework.eventsourcing.eventstore.jdbc with parameters of type EventSchema

Modifier and Type	Method and Description
PreparedStatement	Oracle11EventTableFactory.createDomainEventTable(Connection connection, EventSchema schema)
PreparedStatement	EventTableFactory.createDomainEventTable(Connection connection, EventSchema schema) Creates a PreparedStatement that allows for the creation of the table to store Event entries.
PreparedStatement	AbstractEventTableFactory.createDomainEventTable(Connection connection, EventSchema schema)
PreparedStatement	Oracle11EventTableFactory.createSnapshotEventTable(Connection connection, EventSchema schema)
PreparedStatement	EventTableFactory.createSnapshotEventTable(Connection connection, EventSchema schema) Creates a PreparedStatement that allows for the creation of the table to store Snapshots.
PreparedStatement	AbstractEventTableFactory.createSnapshotEventTable(Connection connection, EventSchema schema)
JdbcEventStorageEngine.Builder	JdbcEventStorageEngine.Builder.schema(EventSchema schema) Sets the EventSchema describing the database schema of event entries.

Method parameters in org.axonframework.eventsourcing.eventstore.jdbc with type arguments of type EventSchema

Modifier and Type	Method and Description
EventSchema.Builder	EventSchema.Builder.domainEventFields(Function<EventSchema,String> domainEventFields) Set a comma separated list of domain event column names to select from an event or snapshot entry.
EventSchema.Builder	EventSchema.Builder.trackedEventFields(Function<EventSchema,String> trackedEventFields) Set a comma separated list of tracked domain event column names to select from an event entry.

Uses of EventSchema in org.axonframework.eventsourcing.eventstore.jdbc.statements

Methods in org.axonframework.eventsourcing.eventstore.jdbc.statements with parameters of type EventSchema

Modifier and Type	Method and Description
static PreparedStatement	JdbcEventStorageEngineStatements.appendEvents(Connection connection, EventSchema schema, Class<?> dataType, List<? extends EventMessage<?>> events, Serializer serializer, TimestampWriter timestampWriter) Set the PreparedStatement to be used on JdbcEventStorageEngine.appendEvents(List, Serializer).
static PreparedStatement	JdbcEventStorageEngineStatements.appendSnapshot(Connection connection, EventSchema schema, Class<?> dataType, DomainEventMessage<?> snapshot, Serializer serializer, TimestampWriter timestampWriter) Set the PreparedStatement to be used on JdbcEventStorageEngine.storeSnapshot(DomainEventMessage, Serializer) .
PreparedStatement	CreateTailTokenStatementBuilder.build(Connection connection, EventSchema schema) Creates a statement to be used at JdbcEventStorageEngine.createTailToken().
PreparedStatement	CreateHeadTokenStatementBuilder.build(Connection connection, EventSchema schema) Creates a statement to be used at JdbcEventStorageEngine.createHeadToken().
PreparedStatement	AppendSnapshotStatementBuilder.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	AppendEventsStatementBuilder.build(Connection connection, EventSchema schema, Class<?> dataType, List<? extends EventMessage<?>> events, Serializer serializer, TimestampWriter timestampWriter) Build a statement to be used at JdbcEventStorageEngine.appendEvents(List, Serializer)
PreparedStatement	CreateTokenAtStatementBuilder.build(Connection connection, EventSchema schema, Instant dateTime) Creates a statement to be used at JdbcEventStorageEngine.createTokenAt(Instant).
PreparedStatement	FetchTrackedEventsStatementBuilder.build(Connection connection, EventSchema schema, long index) Creates a statement to be used at JdbcEventStorageEngine.fetchTrackedEvents(TrackingToken, int)
PreparedStatement	ReadEventDataWithoutGapsStatementBuilder.build(Connection connection, EventSchema schema, long globalIndex, int batchSize) Creates a statement to be used at JdbcEventStorageEngine.fetchTrackedEvents(TrackingToken, int)
PreparedStatement	ReadEventDataWithGapsStatementBuilder.build(Connection connection, EventSchema schema, long globalIndex, int batchSize, List<Long> gaps) Creates a statement to be used at JdbcEventStorageEngine.fetchTrackedEvents(TrackingToken, int)
PreparedStatement	CleanGapsStatementBuilder.build(Connection connection, EventSchema schema, SortedSet<Long> gaps) Creates a statement to be used at JdbcEventStorageEngine.cleanGaps(TrackingToken)
PreparedStatement	ReadSnapshotDataStatementBuilder.build(Connection connection, EventSchema schema, String identifier) Creates a statement to be used at JdbcEventStorageEngine.readSnapshotData(String)
PreparedStatement	LastSequenceNumberForStatementBuilder.build(Connection connection, EventSchema schema, String aggregateIdentifier) Creates a statement to be used at JdbcEventStorageEngine.lastSequenceNumberFor(String)
PreparedStatement	DeleteSnapshotsStatementBuilder.build(Connection connection, EventSchema schema, String aggregateIdentifier, long sequenceNumber) Creates a statement to be used at JdbcEventStorageEngine.storeSnapshot(DomainEventMessage, Serializer)
PreparedStatement	ReadEventDataForAggregateStatementBuilder.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.
static PreparedStatement	JdbcEventStorageEngineStatements.cleanGaps(Connection connection, EventSchema schema, SortedSet<Long> gaps) Set the PreparedStatement to be used on internal cleanGaps operation.
static PreparedStatement	JdbcEventStorageEngineStatements.createHeadToken(Connection connection, EventSchema schema) Set the PreparedStatement to be used on JdbcEventStorageEngine.createHeadToken().
static PreparedStatement	JdbcEventStorageEngineStatements.createTailToken(Connection connection, EventSchema schema) Set the PreparedStatement to be used on JdbcEventStorageEngine.createTailToken().
static PreparedStatement	JdbcEventStorageEngineStatements.createTokenAt(Connection connection, EventSchema schema, Instant dateTime) Build the PreparedStatement to be used on JdbcEventStorageEngine.createTokenAt(Instant).
static PreparedStatement	JdbcEventStorageEngineStatements.deleteSnapshots(Connection connection, EventSchema schema, String aggregateIdentifier, long sequenceNumber) Set the PreparedStatement to be used on JdbcEventStorageEngine.storeSnapshot(DomainEventMessage, Serializer) .
static PreparedStatement	JdbcEventStorageEngineStatements.fetchTrackedEvents(Connection connection, EventSchema schema, long index) Set the PreparedStatement to be used on JdbcEventStorageEngine.fetchTrackedEvents(TrackingToken, int).
static PreparedStatement	JdbcEventStorageEngineStatements.lastSequenceNumberFor(Connection connection, EventSchema schema, String aggregateIdentifier) Set the PreparedStatement to be used on JdbcEventStorageEngine.lastSequenceNumberFor(String).
static PreparedStatement	JdbcEventStorageEngineStatements.readEventDataForAggregate(Connection connection, EventSchema schema, String identifier, long firstSequenceNumber, int batchSize) Set the PreparedStatement to be used on JdbcEventStorageEngine.fetchDomainEvents(String, long, int) "SELECT [trackedEventFields] FROM [domainEventTable] WHERE [aggregateIdentifierColumn] = ?1 AND [sequenceNumberColumn] >= ?2 AND [sequenceNumberColumn] < ?3 ORDER BY [sequenceNumberColumn] ASC" NOTE: "?1" is the identifier, "?2" is the firstSequenceNumber and "?3" is based on batchSize parameters from JdbcEventStorageEngine.fetchDomainEvents(String, long, int) and they should always be present for the PreparedStatement to work.
static PreparedStatement	JdbcEventStorageEngineStatements.readEventDataWithGaps(Connection connection, EventSchema schema, long globalIndex, int batchSize, List<Long> gaps) Set the PreparedStatement to be used on JdbcEventStorageEngine.fetchTrackedEvents(TrackingToken, int) when there are gaps on the GapAwareTrackingToken.
static PreparedStatement	JdbcEventStorageEngineStatements.readEventDataWithoutGaps(Connection connection, EventSchema schema, long globalIndex, int batchSize) Set the PreparedStatement to be used on JdbcEventStorageEngine.fetchTrackedEvents(TrackingToken, int) when there is no gaps on the GapAwareTrackingToken.
static PreparedStatement	JdbcEventStorageEngineStatements.readSnapshotData(Connection connection, EventSchema schema, String identifier) Set the PreparedStatement to be used on JdbcEventStorageEngine.readSnapshotData(String).