Tests for cancelCurrentException()

Author: greenrobot

tests/objectbox-java-test/src/test/java/io/objectbox/TransactionTest.java

@@ -192,6 +192,26 @@ public void testCommitReadTxException_exceptionListener() {
         }
     }
 
+    @Test(expected = IllegalStateException.class)
+    public void testCancelExceptionOutsideDbExceptionListener() {
+        DbExceptionListener.cancelCurrentException();
+    }
+
+    @Test
+    public void testCommitReadTxException_cancelException() {
+        final Exception[] exs = {null};
+        DbExceptionListener exceptionListener = e -> {
+            if (exs[0] != null) throw new RuntimeException("Called more than once");
+            exs[0] = e;
+            DbExceptionListener.cancelCurrentException();
+        };
+        Transaction tx = store.beginReadTx();
+        store.setDbExceptionListener(exceptionListener);
+        tx.commit();
+        tx.abort();
+        assertNotNull(exs[0]);
+    }
+
     /*
     @Test
     public void testTransactionUsingAfterStoreClosed() {

tests/objectbox-java-test/src/test/java/io/objectbox/query/QueryTest.java

@@ -702,6 +702,24 @@ public void testFailedUnique_exceptionListener() {
         }
     }
 
+    @Test
+    public void testFailedUnique_cancelException() {
+        final Exception[] exs = {null};
+        DbExceptionListener exceptionListener = e -> {
+            if (exs[0] != null) throw new RuntimeException("Called more than once");
+            exs[0] = e;
+            DbExceptionListener.cancelCurrentException();
+        };
+        putTestEntitiesStrings();
+        Query<TestEntity> query = box.query().build();
+        store.setDbExceptionListener(exceptionListener);
+
+        TestEntity object = query.findUnique();
+        assertNull(object);
+        assertNotNull(exs[0]);
+        assertEquals(exs[0].getClass(), NonUniqueResultException.class);
+    }
+
     @Test
     public void testDescribe() {
         // Note: description string correctness is fully asserted in core library.