added panicModeRemoveAllObjects()

greenrobot · greenrobot · commit 157ec8541846 · 2018-03-04T10:15:30.000+01:00
diff --git a/objectbox-java/src/main/java/io/objectbox/Box.java b/objectbox-java/src/main/java/io/objectbox/Box.java
@@ -29,6 +29,7 @@
 import javax.annotation.concurrent.ThreadSafe;
 
 import io.objectbox.annotation.apihint.Beta;
+import io.objectbox.annotation.apihint.Experimental;
 import io.objectbox.annotation.apihint.Internal;
 import io.objectbox.annotation.apihint.Temporary;
 import io.objectbox.exception.DbException;
@@ -468,6 +469,7 @@ public void remove(T object) {
     /**
      * Removes (deletes) the given Objects in a single transaction.
      */
+    @SuppressWarnings("Duplicates") // Detected duplicate has different type
     public void remove(@Nullable T... objects) {
         if (objects == null || objects.length == 0) {
             return;
@@ -487,6 +489,7 @@ public void remove(@Nullable T... objects) {
     /**
      * Removes (deletes) the given Objects in a single transaction.
      */
+    @SuppressWarnings("Duplicates") // Detected duplicate has different type
     public void remove(@Nullable Collection<T> objects) {
         if (objects == null || objects.isEmpty()) {
             return;
@@ -516,6 +519,17 @@ public void removeAll() {
         }
     }
 
+    /**
+     * WARNING: this method should generally be avoided as it is not transactional and thus may leave the DB in an
+     * inconsistent state. It may be the a last resort option to recover from a full DB.
+     * Like removeAll(), it removes all objects, returns the count of objects removed.
+     * Logs progress using warning log level.
+     */
+    @Experimental
+    public long panicModeRemoveAll() {
+        return store.panicModeRemoveAllObjects(getEntityInfo().getEntityId());
+    }
+
     /**
      * Returns a builder to create queries for Object matching supplied criteria.
      */
diff --git a/objectbox-java/src/main/java/io/objectbox/BoxStore.java b/objectbox-java/src/main/java/io/objectbox/BoxStore.java
@@ -135,9 +135,12 @@ static native void nativeRegisterCustomType(long store, int entityId, int proper
     public static native boolean isObjectBrowserAvailable();
 
     public static String getVersion() {
+
         return VERSION;
     }
 
+    native long nativePanicModeRemoveAllObjects(long store, int entityId);
+
     private final File directory;
     private final String canonicalPath;
     private final long handle;
@@ -910,4 +913,8 @@ void setDebugFlags(int debugFlags) {
         nativeSetDebugFlags(handle, debugFlags);
     }
 
+    long panicModeRemoveAllObjects(int entityId) {
+        return nativePanicModeRemoveAllObjects(handle, entityId);
+    }
+
 }
diff --git a/tests/objectbox-java-test/src/main/java/io/objectbox/BoxTest.java b/tests/objectbox-java-test/src/main/java/io/objectbox/BoxTest.java
@@ -136,6 +136,14 @@ public void testRemoveMany() {
         assertEquals(0, box.count());
     }
 
+    @Test
+    public void testPanicModeRemoveAllObjects() {
+        assertEquals(0, box.panicModeRemoveAll());
+        putTestEntities(7);
+        assertEquals(7, box.panicModeRemoveAll());
+        assertEquals(0, box.count());
+    }
+
     @Test
     public void testRunInTx() {
         final long[] counts = {0, 0};

Original file line number	Diff line number	Diff line change
`@@ -135,9 +135,12 @@ static native void nativeRegisterCustomType(long store, int entityId, int proper`
`135`	`135`	`public static native boolean isObjectBrowserAvailable();`
`136`	`136`
`137`	`137`	`public static String getVersion() {`
	`138`	`+`
`138`	`139`	`return VERSION;`
`139`	`140`	`}`
`140`	`141`
	`142`	`+ native long nativePanicModeRemoveAllObjects(long store, int entityId);`
	`143`	`+`
`141`	`144`	`private final File directory;`
`142`	`145`	`private final String canonicalPath;`
`143`	`146`	`private final long handle;`
`@@ -910,4 +913,8 @@ void setDebugFlags(int debugFlags) {`
`910`	`913`	`nativeSetDebugFlags(handle, debugFlags);`
`911`	`914`	`}`
`912`	`915`
	`916`	`+ long panicModeRemoveAllObjects(int entityId) {`
	`917`	`+ return nativePanicModeRemoveAllObjects(handle, entityId);`
	`918`	`+ }`
	`919`	`+`
`913`	`920`	`}`