feat: add validation of null at cassandra

Signed-off-by: Otavio Santana <[email protected]>

Author: otaviojava

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

@@ -60,7 +60,9 @@ public boolean isNotEmpty() {
 
     @Override
     public List<Column> toColumn(ColumnEntityConverter converter, Converters converters) {
-        if (Iterable.class.isInstance(value)) {
+        if (value == null) {
+            return singletonList(Column.of(field.name(), null));
+        } else if (Iterable.class.isInstance(value)) {
             List<Iterable<Column>> columns = new ArrayList<>();
             stream(Iterable.class.cast(value).spliterator(), false)
                     .forEach(c -> columns.add(converter.toColumn(c).columns()));

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

@@ -80,17 +80,17 @@ public class DefaultCassandraTemplateTest {
     private CassandraColumnManager manager;
 
     @BeforeEach
-    public void setUp() {
+    void setUp() {
         this.manager = mock(CassandraColumnManager.class);
         Instance instance = mock(Instance.class);
         when(instance.get()).thenReturn(manager);
         template = new DefaultCassandraTemplate(instance, converter, persistManager, entities, converters);
     }
 
     @Test
-    public void shouldSaveConsistency() {
+    void shouldSaveConsistency() {
         ColumnEntity entity = ColumnEntity.of("Person", asList(Column.of("name", "Name"), Column.of("age", 20)));
-
+        entity.addNull("home");
         ArgumentCaptor<ColumnEntity> captor = ArgumentCaptor.forClass(ColumnEntity.class);
 
         ConsistencyLevel level = ConsistencyLevel.THREE;
@@ -110,9 +110,9 @@ public void shouldSaveConsistency() {
     }
 
     @Test
-    public void shouldSaveConsistencyIterable() {
+    void shouldSaveConsistencyIterable() {
         ColumnEntity entity = ColumnEntity.of("Person", asList(Column.of("name", "Name"), Column.of("age", 20)));
-
+        entity.addNull("home");
         ArgumentCaptor<ColumnEntity> captor = ArgumentCaptor.forClass(ColumnEntity.class);
 
         ConsistencyLevel level = ConsistencyLevel.THREE;
@@ -131,10 +131,10 @@ public void shouldSaveConsistencyIterable() {
     }
 
     @Test
-    public void shouldSaveConsntencyDuration() {
+    void shouldSaveConsntencyDuration() {
         Duration duration = Duration.ofHours(2);
         ColumnEntity entity = ColumnEntity.of("Person", asList(Column.of("name", "Name"), Column.of("age", 20)));
-
+        entity.addNull("home");
         ArgumentCaptor<ColumnEntity> captor = ArgumentCaptor.forClass(ColumnEntity.class);
 
         ConsistencyLevel level = ConsistencyLevel.THREE;
@@ -153,10 +153,10 @@ public void shouldSaveConsntencyDuration() {
     }
 
     @Test
-    public void shouldSaveConsntencyDurationIterable() {
+    void shouldSaveConsistencyDurationIterable() {
         Duration duration = Duration.ofHours(2);
         ColumnEntity entity = ColumnEntity.of("Person", asList(Column.of("name", "Name"), Column.of("age", 20)));
-
+        entity.addNull("home");
         ArgumentCaptor<ColumnEntity> captor = ArgumentCaptor.forClass(ColumnEntity.class);
 
         ConsistencyLevel level = ConsistencyLevel.THREE;
@@ -174,7 +174,7 @@ public void shouldSaveConsntencyDurationIterable() {
     }
 
     @Test
-    public void shouldDelete() {
+    void shouldDelete() {
 
 
         ColumnDeleteQuery query = ColumnDeleteQuery.delete().from("columnFamily").build();
@@ -185,7 +185,7 @@ public void shouldDelete() {
 
 
     @Test
-    public void shouldFind() {
+    void shouldFind() {
         Person person = new Person();
         person.setName("Name");
         person.setAge(20);
@@ -200,7 +200,7 @@ public void shouldFind() {
     }
 
     @Test
-    public void shouldFindCQL() {
+    void shouldFindCQL() {
         Person person = new Person();
         person.setName("Name");
         person.setAge(20);
@@ -214,7 +214,7 @@ public void shouldFindCQL() {
     }
 
     @Test
-    public void shouldFindSimpleStatement() {
+    void shouldFindSimpleStatement() {
         SimpleStatement statement = QueryBuilder.selectFrom("Person").all().build();
         Person person = new Person();
         person.setName("Name");