Issue #9344 has been fixed.

orientechnologies · Aug 3, 2020 · 5969c27 · 5969c27
1 parent 4943965
commit 5969c27
Show file tree

Hide file tree

Showing 3 changed files with 208 additions and 42 deletions.
diff --git a/core/src/main/java/com/orientechnologies/orient/core/db/OrientDBEmbedded.java b/core/src/main/java/com/orientechnologies/orient/core/db/OrientDBEmbedded.java
@@ -23,6 +23,7 @@
 import static com.orientechnologies.orient.core.config.OGlobalConfiguration.FILE_DELETE_RETRY;
 import static com.orientechnologies.orient.core.config.OGlobalConfiguration.WARNING_DEFAULT_USERS;
 
+
 import com.orientechnologies.common.concur.lock.OModificationOperationProhibitedException;
 import com.orientechnologies.common.exception.OException;
 import com.orientechnologies.common.io.OIOUtils;
@@ -1008,6 +1009,18 @@ public synchronized void initCustomStorage(
     }
   }
 
+  @Override
+  public void rollbackOperationsFromThread(final Thread thread) {
+    synchronized (this) {
+      final Thread currentThread = Thread.currentThread();
+
+      for (final OAbstractPaginatedStorage storage : storages.values()) {
+        storage.rollbackOperationsFromThread(thread);
+      }
+    }
+  }
+
+
   public synchronized void removeShutdownHook() {
     orient.removeOrientDB(this);
   }

diff --git a/core/src/main/java/com/orientechnologies/orient/core/db/OrientDBInternal.java b/core/src/main/java/com/orientechnologies/orient/core/db/OrientDBInternal.java
@@ -328,4 +328,8 @@ default OResultSet executeServerStatement(
       String script, String user, String pw, Object... params) {
     throw new UnsupportedOperationException();
   }
+
+  default void rollbackOperationsFromThread(final Thread thread) {
+    throw new UnsupportedOperationException();
+  }
 }