I
- a type of projection IDspublic class JdbcProjectionStorage<I>
extends io.spine.server.projection.ProjectionStorage<I>
JdbcStorageFactory
Modifier and Type | Class and Description |
---|---|
static class |
JdbcProjectionStorage.Builder<I>
The builder for
JdbcProjectionStorage . |
Modifier | Constructor and Description |
---|---|
protected |
JdbcProjectionStorage(JdbcProjectionStorage.Builder<I> builder)
Creates a new instance using the builder.
|
Modifier and Type | Method and Description |
---|---|
void |
close() |
boolean |
delete(I id) |
java.util.Iterator<I> |
index() |
static <I> JdbcProjectionStorage.Builder<I> |
newBuilder()
Creates the builder for the storage.
|
protected java.util.Iterator<io.spine.server.entity.EntityRecord> |
readAllRecords(io.spine.client.ResponseFormat format) |
@Nullable com.google.protobuf.Timestamp |
readLastHandledEventTime() |
protected java.util.Iterator<io.spine.server.entity.EntityRecord> |
readMultipleRecords(java.lang.Iterable<I> ids,
com.google.protobuf.FieldMask fieldMask) |
io.spine.server.storage.RecordStorage<I> |
recordStorage() |
void |
writeLastHandledEventTime(com.google.protobuf.Timestamp time) |
entityColumnCache, readAllRecords, readRecord, writeRecord, writeRecords
entityColumns, entityLifecycleColumns, read, read, readAll, readAll, readAll, readLifecycleFlags, readMultiple, write, write, write, writeLifecycleFlags
checkNotClosed, checkNotClosed, isClosed, isMultitenant, isOpen
protected JdbcProjectionStorage(JdbcProjectionStorage.Builder<I> builder) throws DatabaseException
builder
- the storage builderDatabaseException
public java.util.Iterator<I> index()
public void writeLastHandledEventTime(com.google.protobuf.Timestamp time) throws DatabaseException
writeLastHandledEventTime
in class io.spine.server.projection.ProjectionStorage<I>
DatabaseException
public @Nullable com.google.protobuf.Timestamp readLastHandledEventTime() throws DatabaseException
readLastHandledEventTime
in class io.spine.server.projection.ProjectionStorage<I>
DatabaseException
public io.spine.server.storage.RecordStorage<I> recordStorage()
recordStorage
in class io.spine.server.projection.ProjectionStorage<I>
public void close() throws DatabaseException
close
in interface io.spine.server.storage.Storage<I,io.spine.server.entity.EntityRecord,io.spine.server.storage.RecordReadRequest<I>>
close
in interface java.lang.AutoCloseable
close
in class io.spine.server.storage.AbstractStorage<I,io.spine.server.entity.EntityRecord,io.spine.server.storage.RecordReadRequest<I>>
DatabaseException
public boolean delete(I id)
delete
in class io.spine.server.storage.RecordStorage<I>
protected java.util.Iterator<io.spine.server.entity.EntityRecord> readMultipleRecords(java.lang.Iterable<I> ids, com.google.protobuf.FieldMask fieldMask)
readMultipleRecords
in class io.spine.server.storage.RecordStorage<I>
protected java.util.Iterator<io.spine.server.entity.EntityRecord> readAllRecords(io.spine.client.ResponseFormat format)
readAllRecords
in class io.spine.server.storage.RecordStorage<I>
public static <I> JdbcProjectionStorage.Builder<I> newBuilder()