I
- the type of entity IDspublic class JdbcRecordStorage<I>
extends io.spine.server.storage.RecordStorage<I>
JdbcStorageFactory
Modifier and Type | Class and Description |
---|---|
static class |
JdbcRecordStorage.Builder<I>
The builder for
JdbcRecordStorage . |
Modifier | Constructor and Description |
---|---|
protected |
JdbcRecordStorage(JdbcRecordStorage.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> JdbcRecordStorage.Builder<I> |
newBuilder()
Creates the builder for the storage.
|
protected java.util.Iterator<io.spine.server.entity.EntityRecord> |
readAllRecords(io.spine.server.entity.storage.EntityQuery<I> query,
io.spine.client.ResponseFormat format) |
protected java.util.Iterator<io.spine.server.entity.EntityRecord> |
readAllRecords(io.spine.client.ResponseFormat responseFormat) |
protected java.util.Iterator<io.spine.server.entity.EntityRecord> |
readMultipleRecords(java.lang.Iterable<I> ids,
com.google.protobuf.FieldMask fieldMask) |
protected java.util.Optional<io.spine.server.entity.EntityRecord> |
readRecord(I id)
Reads the record by the passed identifier.
|
protected void |
writeRecord(I id,
io.spine.server.entity.storage.EntityRecordWithColumns record) |
protected void |
writeRecords(java.util.Map<I,io.spine.server.entity.storage.EntityRecordWithColumns> records) |
entityColumnCache, entityColumns, entityLifecycleColumns, read, read, readAll, readAll, readAll, readLifecycleFlags, readMultiple, write, write, write, writeLifecycleFlags
checkNotClosed, checkNotClosed, isClosed, isMultitenant, isOpen
protected JdbcRecordStorage(JdbcRecordStorage.Builder<I> builder) throws DatabaseException
builder
- the storage builderDatabaseException
public java.util.Iterator<I> index()
public boolean delete(I id)
delete
in class io.spine.server.storage.RecordStorage<I>
protected java.util.Optional<io.spine.server.entity.EntityRecord> readRecord(I id) throws DatabaseException
readRecord
in class io.spine.server.storage.RecordStorage<I>
EntityRecord
, or Optional.empty()
if nothing foundDatabaseException
- if an error occurs during an interaction with the DBprotected 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 responseFormat)
readAllRecords
in class io.spine.server.storage.RecordStorage<I>
protected java.util.Iterator<io.spine.server.entity.EntityRecord> readAllRecords(io.spine.server.entity.storage.EntityQuery<I> query, io.spine.client.ResponseFormat format)
readAllRecords
in class io.spine.server.storage.RecordStorage<I>
protected void writeRecord(I id, io.spine.server.entity.storage.EntityRecordWithColumns record)
writeRecord
in class io.spine.server.storage.RecordStorage<I>
protected void writeRecords(java.util.Map<I,io.spine.server.entity.storage.EntityRecordWithColumns> records)
writeRecords
in class io.spine.server.storage.RecordStorage<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 static <I> JdbcRecordStorage.Builder<I> newBuilder()