Order change of quads

timbuctoo-instancev4/src/main/java/nl/knaw/huygens/timbuctoo/server/TimbuctooV4.java

@@ -71,11 +71,11 @@
 import nl.knaw.huygens.timbuctoo.server.tasks.CompressFilesTask;
 import nl.knaw.huygens.timbuctoo.server.tasks.DatabaseValidationTask;
 import nl.knaw.huygens.timbuctoo.server.tasks.DbLogCreatorTask;
-import nl.knaw.huygens.timbuctoo.server.tasks.DumpChangelogsTask;
 import nl.knaw.huygens.timbuctoo.server.tasks.MoveDefaultGraphsTask;
 import nl.knaw.huygens.timbuctoo.server.tasks.MoveEdgesTask;
 import nl.knaw.huygens.timbuctoo.server.tasks.RebuildSchemaTask;
 import nl.knaw.huygens.timbuctoo.server.tasks.ReimportDatasetsTask;
+import nl.knaw.huygens.timbuctoo.server.tasks.RemoveOldStore;
 import nl.knaw.huygens.timbuctoo.server.tasks.UserCreationTask;
 import nl.knaw.huygens.timbuctoo.solr.Webhooks;
 import nl.knaw.huygens.timbuctoo.util.UriHelper;
@@ -432,7 +432,7 @@ public void run(TimbuctooConfiguration configuration, Environment environment) t
     environment.admin().addTask(new ReimportDatasetsTask(dataSetRepository));
     environment.admin().addTask(new CompressFilesTask(dataSetRepository));
     environment.admin().addTask(new RebuildSchemaTask(dataSetRepository));
-    environment.admin().addTask(new DumpChangelogsTask(dataSetRepository, configuration.getDatabases()));
+    environment.admin().addTask(new RemoveOldStore(configuration.getDatabases(), dataSetRepository));
 
     // register health checks
     // Dropwizard Health checks are used to check whether requests should be routed to this instance

timbuctoo-instancev4/src/main/java/nl/knaw/huygens/timbuctoo/server/tasks/RemoveOldStore.java

@@ -0,0 +1,43 @@
+package nl.knaw.huygens.timbuctoo.server.tasks;
+
+import com.sleepycat.je.DatabaseNotFoundException;
+import io.dropwizard.servlets.tasks.Task;
+import nl.knaw.huygens.timbuctoo.v5.berkeleydb.BdbEnvironmentCreator;
+import nl.knaw.huygens.timbuctoo.v5.dataset.DataSetRepository;
+import nl.knaw.huygens.timbuctoo.v5.dataset.dto.DataSet;
+
+import java.io.PrintWriter;
+import java.util.List;
+import java.util.Map;
+
+public class RemoveOldStore extends Task {
+  private final BdbEnvironmentCreator dataStoreFactory;
+  private final DataSetRepository dataSetRepository;
+
+  public RemoveOldStore(BdbEnvironmentCreator dataStoreFactory, DataSetRepository dataSetRepository) {
+    super("removeOldStore");
+    this.dataStoreFactory = dataStoreFactory;
+    this.dataSetRepository = dataSetRepository;
+  }
+
+  @Override
+  public void execute(Map<String, List<String>> parameters, PrintWriter output) throws Exception {
+    for (DataSet dataSet : dataSetRepository.getDataSets()) {
+      output.println("Remove old store from dataset: " + dataSet.getMetadata().getCombinedId());
+      output.flush();
+
+      try {
+        dataStoreFactory.removeDatabase(
+            dataSet.getMetadata().getOwnerId(),
+            dataSet.getMetadata().getDataSetId(),
+            "rdfDataOld"
+        );
+      } catch (DatabaseNotFoundException e) {
+        e.printStackTrace(output);
+      }
+
+      output.println("Removed old store from dataset: " + dataSet.getMetadata().getCombinedId());
+      output.flush();
+    }
+  }
+}

timbuctoo-instancev4/src/main/java/nl/knaw/huygens/timbuctoo/v5/berkeleydb/BdbEnvironmentCreator.java

@@ -1,6 +1,8 @@
 package nl.knaw.huygens.timbuctoo.v5.berkeleydb;
 
 import com.sleepycat.bind.EntryBinding;
+import com.sleepycat.je.Database;
+import com.sleepycat.je.Environment;
 import nl.knaw.huygens.timbuctoo.v5.berkeleydb.exceptions.BdbDbCreationException;
 import nl.knaw.huygens.timbuctoo.v5.berkeleydb.isclean.IsCleanHandler;