Skip to content

Commit 6a8fec6

Browse files
committed
test: update Cassandra tests using the new api
Signed-off-by: Otavio Santana <[email protected]>
1 parent 3778fa6 commit 6a8fec6

File tree

6 files changed

+25
-25
lines changed

6 files changed

+25
-25
lines changed

jnosql-cassandra/src/main/java/org/eclipse/jnosql/databases/cassandra/mapping/CassandraColumnEntityConverter.java

Lines changed: 14 additions & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -23,8 +23,8 @@
2323
import org.eclipse.jnosql.mapping.column.ColumnEntityConverter;
2424
import org.eclipse.jnosql.mapping.column.ColumnFieldValue;
2525
import org.eclipse.jnosql.mapping.metadata.EntitiesMetadata;
26-
import org.eclipse.jnosql.mapping.reflection.FieldMapping;
27-
import org.eclipse.jnosql.mapping.reflection.GenericFieldMapping;
26+
import org.eclipse.jnosql.mapping.metadata.FieldMetadata;
27+
import org.eclipse.jnosql.mapping.metadata.GenericFieldMetadata;
2828

2929
import java.util.Collection;
3030
import java.util.List;
@@ -56,10 +56,10 @@ protected Converters getConverters() {
5656
}
5757

5858
@Override
59-
protected <T> Consumer<String> feedObject(T instance, List<Column> columns, Map<String, FieldMapping> fieldsGroupByName) {
59+
protected <T> Consumer<String> feedObject(T instance, List<Column> columns, Map<String, FieldMetadata> fieldsGroupByName) {
6060
return k -> {
61-
FieldMapping field = fieldsGroupByName.get(k);
62-
if (Objects.nonNull(field.nativeField().getAnnotation(UDT.class))) {
61+
FieldMetadata field = fieldsGroupByName.get(k);
62+
if (field.value(UDT.class).isPresent()) {
6363
Optional<Column> column = columns.stream().filter(c -> c.name().equals(k)).findFirst();
6464
setUDTField(instance, column, field);
6565
} else {
@@ -68,37 +68,34 @@ protected <T> Consumer<String> feedObject(T instance, List<Column> columns, Map<
6868
};
6969
}
7070

71-
private <T> void setUDTField(T instance, Optional<Column> column, FieldMapping field) {
71+
private <T> void setUDTField(T instance, Optional<Column> column, FieldMetadata field) {
7272
if (column.isPresent() && org.eclipse.jnosql.databases.cassandra.communication.UDT.class.isInstance(column.get())) {
7373
org.eclipse.jnosql.databases.cassandra.communication.UDT udt =
7474
org.eclipse.jnosql.databases.cassandra.communication.UDT.class.cast(column.get());
7575
Object columns = udt.get();
7676
if (StreamSupport.stream(Iterable.class.cast(columns).spliterator(), false)
7777
.allMatch(Iterable.class::isInstance)) {
78-
GenericFieldMapping genericField = GenericFieldMapping.class.cast(field);
79-
Collection collection = genericField.getCollectionInstance();
78+
GenericFieldMetadata genericField = GenericFieldMetadata.class.cast(field);
79+
Collection collection = genericField.collectionInstance();
8080
List<List<Column>> embeddable = (List<List<Column>>) columns;
8181
for (List<Column> columnList : embeddable) {
82-
Object element = toEntity(genericField.getElementType(), columnList);
82+
Object element = toEntity(genericField.elementType(), columnList);
8383
collection.add(element);
8484
}
8585
field.write(instance, collection);
8686
} else {
87-
Object value = toEntity(field.nativeField().getType(), (List<Column>) columns);
87+
Object value = toEntity(field.type(), (List<Column>) columns);
8888
field.write(instance, value);
8989
}
9090
}
9191
}
9292

9393
@Override
94-
protected ColumnFieldValue to(FieldMapping field, Object entityInstance) {
94+
protected ColumnFieldValue to(FieldMetadata field, Object entityInstance) {
9595

9696
Object value = field.read(entityInstance);
97-
UDT annotation = field.nativeField().getAnnotation(UDT.class);
98-
if (Objects.isNull(annotation)) {
99-
return super.to(field, entityInstance);
100-
} else {
101-
return new CassandraUDTType(annotation.value(), value, field);
102-
}
97+
Optional<String> annotation = field.value(UDT.class);
98+
return annotation.<ColumnFieldValue>map(v -> new CassandraUDTType(v, value, field))
99+
.orElseGet( () -> super.to(field, entityInstance));
103100
}
104101
}

jnosql-cassandra/src/main/java/org/eclipse/jnosql/databases/cassandra/mapping/CassandraUDTType.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,7 @@
1818
import org.eclipse.jnosql.mapping.Converters;
1919
import org.eclipse.jnosql.mapping.column.ColumnEntityConverter;
2020
import org.eclipse.jnosql.mapping.column.ColumnFieldValue;
21-
import org.eclipse.jnosql.mapping.reflection.FieldMapping;
21+
import org.eclipse.jnosql.mapping.metadata.FieldMetadata;
2222
import org.eclipse.jnosql.databases.cassandra.communication.UDT;
2323

2424
import java.util.ArrayList;
@@ -34,10 +34,10 @@ class CassandraUDTType implements ColumnFieldValue {
3434

3535
private final Object value;
3636

37-
private final FieldMapping field;
37+
private final FieldMetadata field;
3838

3939

40-
CassandraUDTType(String type, Object value, FieldMapping field) {
40+
CassandraUDTType(String type, Object value, FieldMetadata field) {
4141
this.value = value;
4242
this.type = type;
4343
this.field = Objects.requireNonNull(field, "field is required");
@@ -49,7 +49,7 @@ public Object value() {
4949
}
5050

5151
@Override
52-
public FieldMapping field() {
52+
public FieldMetadata field() {
5353
return field;
5454
}
5555

jnosql-cassandra/src/test/java/org/eclipse/jnosql/databases/cassandra/mapping/CassandraColumnEntityConverterTest.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -31,6 +31,7 @@
3131
import org.eclipse.jnosql.databases.cassandra.mapping.model.Movie;
3232
import org.eclipse.jnosql.databases.cassandra.mapping.model.Worker;
3333
import org.eclipse.jnosql.mapping.Convert;
34+
import org.eclipse.jnosql.mapping.Converters;
3435
import org.eclipse.jnosql.mapping.column.JNoSQLColumnTemplate;
3536
import org.eclipse.jnosql.mapping.column.spi.ColumnExtension;
3637
import org.eclipse.jnosql.mapping.reflection.EntityMetadataExtension;
@@ -62,7 +63,7 @@
6263
import static org.junit.jupiter.api.Assertions.assertTrue;
6364

6465
@EnableAutoWeld
65-
@AddPackages(value = {Convert.class, JNoSQLColumnTemplate.class,
66+
@AddPackages(value = {Converters.class, JNoSQLColumnTemplate.class,
6667
CQL.class})
6768
@AddPackages(MockProducer.class)
6869
@AddExtensions({EntityMetadataExtension.class,

jnosql-cassandra/src/test/java/org/eclipse/jnosql/databases/cassandra/mapping/CassandraExtensionTest.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -16,6 +16,7 @@
1616

1717
import jakarta.inject.Inject;
1818
import org.eclipse.jnosql.mapping.Convert;
19+
import org.eclipse.jnosql.mapping.Converters;
1920
import org.eclipse.jnosql.mapping.column.JNoSQLColumnTemplate;
2021
import org.eclipse.jnosql.mapping.column.spi.ColumnExtension;
2122
import org.eclipse.jnosql.mapping.reflection.EntityMetadataExtension;
@@ -26,7 +27,7 @@
2627
import org.junit.jupiter.api.Test;
2728

2829
@EnableAutoWeld
29-
@AddPackages(value = {Convert.class, JNoSQLColumnTemplate.class,
30+
@AddPackages(value = {Converters.class, JNoSQLColumnTemplate.class,
3031
CQL.class})
3132
@AddPackages(MockProducer.class)
3233
@AddExtensions({EntityMetadataExtension.class,

jnosql-cassandra/src/test/java/org/eclipse/jnosql/databases/cassandra/mapping/CassandraRepositoryProxyTest.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -17,6 +17,7 @@
1717
import jakarta.inject.Inject;
1818
import org.eclipse.jnosql.communication.column.ColumnDeleteQuery;
1919
import org.eclipse.jnosql.mapping.Convert;
20+
import org.eclipse.jnosql.mapping.Converters;
2021
import org.eclipse.jnosql.mapping.column.JNoSQLColumnTemplate;
2122
import org.eclipse.jnosql.mapping.column.query.ColumnRepositoryProducer;
2223
import org.eclipse.jnosql.mapping.column.spi.ColumnExtension;
@@ -40,7 +41,7 @@
4041
import static org.mockito.Mockito.when;
4142

4243
@EnableAutoWeld
43-
@AddPackages(value = {Convert.class, JNoSQLColumnTemplate.class,
44+
@AddPackages(value = {Converters.class, JNoSQLColumnTemplate.class,
4445
CQL.class})
4546
@AddPackages(MockProducer.class)
4647
@AddExtensions({EntityMetadataExtension.class,

jnosql-cassandra/src/test/java/org/eclipse/jnosql/databases/cassandra/mapping/DefaultCassandraTemplateTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -55,7 +55,7 @@
5555
import static org.mockito.Mockito.when;
5656

5757
@EnableAutoWeld
58-
@AddPackages(value = {Convert.class, ColumnEntityConverter.class,
58+
@AddPackages(value = {Converters.class, ColumnEntityConverter.class,
5959
CQL.class})
6060
@AddPackages(MockProducer.class)
6161
@AddExtensions({EntityMetadataExtension.class,

0 commit comments

Comments
 (0)