test: create scenario to return invalid when it is long

Signed-off-by: Otavio Santana <[email protected]>
eclipse-jnosql · Aug 28, 2024 · 66ec9e4 · 66ec9e4
1 parent 18e14e3
commit 66ec9e4
Show file tree

Hide file tree

Showing 2 changed files with 26 additions and 0 deletions.
diff --git a/...est/java/org/eclipse/jnosql/mapping/semistructured/query/CustomRepositoryHandlerTest.java b/...est/java/org/eclipse/jnosql/mapping/semistructured/query/CustomRepositoryHandlerTest.java
@@ -436,4 +436,24 @@ void shouldExecuteExistBy() {
         });
 
     }
+
+    @Test
+    void shouldReturnNotSupportedWhenQueryIsNotSelectAsDelete() {
+        var preparedStatement = Mockito.mock(org.eclipse.jnosql.mapping.semistructured.PreparedStatement.class);
+        Mockito.when(template.prepare(Mockito.anyString())).thenReturn(preparedStatement);
+        Mockito.when(template.query(Mockito.anyString()))
+                .thenReturn(Stream.of(Person.builder().age(26).name("Ada").build()));
+        Assertions.assertThatThrownBy(() ->people.deleteByNameReturnInt())
+                .isInstanceOf(UnsupportedOperationException.class);
+    }
+
+    @Test
+    void shouldReturnNotSupportedWhenQueryIsNotSelectAsUpdate() {
+        var preparedStatement = Mockito.mock(org.eclipse.jnosql.mapping.semistructured.PreparedStatement.class);
+        Mockito.when(template.prepare(Mockito.anyString())).thenReturn(preparedStatement);
+        Mockito.when(template.query(Mockito.anyString()))
+                .thenReturn(Stream.of(Person.builder().age(26).name("Ada").build()));
+        Assertions.assertThatThrownBy(() ->people.updateReturnInt())
+                .isInstanceOf(UnsupportedOperationException.class);
+    }
 }
diff --git a/...-semistructured/src/test/java/org/eclipse/jnosql/mapping/semistructured/query/People.java b/...-semistructured/src/test/java/org/eclipse/jnosql/mapping/semistructured/query/People.java
@@ -97,4 +97,10 @@ public interface People {
     default String defaultMethod() {
         return "default";
     }
+
+    @Query("delete from Person where name = :name")
+    long deleteByNameReturnInt();
+
+    @Query("update Person where name = :name")
+    long updateReturnInt();
 }