Skip to content

Commit 4881cac

Browse files
authored
Merge pull request #120 from SpineEventEngine/entity-column-update
Entity column API update
2 parents 7f13589 + 62f5248 commit 4881cac

File tree

11 files changed

+117
-333
lines changed

11 files changed

+117
-333
lines changed

datastore/src/main/java/io/spine/server/storage/datastore/DsFilters.java

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -390,18 +390,18 @@ private Filter getFilter() {
390390
// Only non-faulty values are used.
391391
private StructuredQuery.Filter toFilter(FilterAdapter adapter) {
392392
Value<?> value = adapter.toValue(column, columnFilter);
393-
String columnIdentifier = column.storedName();
393+
String columnName = column.name();
394394
switch (columnFilter.getOperator()) {
395395
case EQUAL:
396-
return eq(columnIdentifier, value);
396+
return eq(columnName, value);
397397
case GREATER_THAN:
398-
return gt(columnIdentifier, value);
398+
return gt(columnName, value);
399399
case LESS_THAN:
400-
return lt(columnIdentifier, value);
400+
return lt(columnName, value);
401401
case GREATER_OR_EQUAL:
402-
return ge(columnIdentifier, value);
402+
return ge(columnName, value);
403403
case LESS_OR_EQUAL:
404-
return le(columnIdentifier, value);
404+
return le(columnName, value);
405405
default:
406406
throw new IllegalStateException(columnFilter.getOperator()
407407
.name());

datastore/src/main/java/io/spine/server/storage/datastore/type/AbstractDatastoreColumnType.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,7 @@ public abstract class AbstractDatastoreColumnType<J, C> implements DatastoreColu
3939
/**
4040
* {@inheritDoc}
4141
*
42-
* <p>Delegates the call to the Datastore-native {@link BaseEntity.Builder#setNull setNull}.
42+
* <p>Delegates the call to the Datastore-native {@code setNull}.
4343
*/
4444
@Override
4545
public void setNull(BaseEntity.Builder<Key, Entity.Builder> storageRecord,

datastore/src/main/java/io/spine/server/storage/datastore/type/DatastoreColumnType.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,7 @@
3030
/**
3131
* The contract of a {@link ColumnType} used by the Datastore storage.
3232
*
33-
* <p>Uses {@link Entity.Builder} as the record type and {@code String} as
33+
* <p>Uses {@code Entity.Builder} as the record type and {@code String} as
3434
* the column identifier type.
3535
*/
3636
@SPI

datastore/src/test/java/io/spine/server/storage/datastore/DsFiltersTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -186,7 +186,7 @@ void testEmptyParameters() {
186186
@DisplayName("generate filters for `null` column value")
187187
void testNullFilters() {
188188
EntityColumn column = mock(EntityColumn.class);
189-
when(column.storedName()).thenReturn(ID_STRING_COLUMN_NAME);
189+
when(column.name()).thenReturn(ID_STRING_COLUMN_NAME);
190190
when(column.type()).thenReturn(String.class);
191191
when(column.persistedType()).thenReturn(String.class);
192192
when(column.toPersistedValue(any())).thenReturn(null);

datastore/src/test/java/io/spine/server/storage/datastore/DsProjectionStorageTest.java

Lines changed: 1 addition & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -45,7 +45,7 @@ class DsProjectionStorageTest extends ProjectionStorageTest {
4545

4646
@Override
4747
protected Class<? extends TestCounterEntity> getTestEntityClass() {
48-
return TestEntity.class;
48+
return TestCounterEntity.class;
4949
}
5050

5151
@Override
@@ -71,11 +71,4 @@ protected ProjectionStorage<ProjectId> newStorage(Class<? extends Entity<?, ?>>
7171
datastoreFactory.createProjectionStorage(singleTenantSpec(), projectionClass);
7272
return result;
7373
}
74-
75-
public static class TestEntity extends TestCounterEntity {
76-
77-
protected TestEntity(ProjectId id) {
78-
super(id);
79-
}
80-
}
8174
}

datastore/src/test/java/io/spine/server/storage/datastore/DsRecordStorageTest.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -46,7 +46,6 @@
4646
import io.spine.server.storage.datastore.given.CollegeEntity;
4747
import io.spine.server.storage.datastore.given.DsRecordStorageTestEnv;
4848
import io.spine.server.storage.datastore.given.DsRecordStorageTestEnv.EntityWithCustomColumnName;
49-
import io.spine.server.storage.datastore.given.DsRecordStorageTestEnv.TestEntity;
5049
import io.spine.server.storage.datastore.given.TestConstCounterEntity;
5150
import io.spine.server.storage.given.RecordStorageTestEnv.TestCounterEntity;
5251
import io.spine.test.datastore.College;
@@ -144,7 +143,7 @@ protected DsRecordStorage<ProjectId> newStorage(Class<? extends Entity<?, ?>> en
144143

145144
@Override
146145
protected Class<? extends TestCounterEntity> getTestEntityClass() {
147-
return TestEntity.class;
146+
return TestCounterEntity.class;
148147
}
149148

150149
@Override

datastore/src/test/java/io/spine/server/storage/datastore/given/DsRecordStorageTestEnv.java

Lines changed: 0 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -426,13 +426,6 @@ public static EntityId newEntityId(Message message) {
426426
* Test Entity types
427427
************************/
428428

429-
public static class TestEntity extends RecordStorageTestEnv.TestCounterEntity {
430-
431-
protected TestEntity(ProjectId id) {
432-
super(id);
433-
}
434-
}
435-
436429
public static class EntityWithCustomColumnName extends AbstractEntity<ProjectId, Project> {
437430

438431
public EntityWithCustomColumnName(ProjectId id) {

0 commit comments

Comments
 (0)