feature: Relation purge db operation

3 files changed, 170 insertions, 1 deletions

diff --git a/plugins/org.eclipse.osee.framework.server.admin/META-INF/MANIFEST.MF b/plugins/org.eclipse.osee.framework.server.admin/META-INF/MANIFEST.MF
index 6fecc06..92455c0 100644
--- a/plugins/org.eclipse.osee.framework.server.admin/META-INF/MANIFEST.MF
+++ b/plugins/org.eclipse.osee.framework.server.admin/META-INF/MANIFEST.MF
@@ -40,3 +40,4 @@ Service-Component: OSGI-INF/server.admin.cmds.xml,
  OSGI-INF/search.tagger.cmds.xml,
  OSGI-INF/branch.cmds.xml
 Bundle-RequiredExecutionEnvironment: JavaSE-1.6
+Require-Bundle: org.eclipse.osee.framework.core.model
diff --git a/plugins/org.eclipse.osee.framework.server.admin/src/org/eclipse/osee/framework/server/admin/PurgeRelationType.java b/plugins/org.eclipse.osee.framework.server.admin/src/org/eclipse/osee/framework/server/admin/PurgeRelationType.java
new file mode 100644
index 0000000..fa3b5a8
--- a/dev/null
+++ b/plugins/org.eclipse.osee.framework.server.admin/src/org/eclipse/osee/framework/server/admin/PurgeRelationType.java
@@ -0,0 +1,143 @@
+/*******************************************************************************
+ * Copyright (c) 2011 Boeing.
+ * All rights reserved. This program and the accompanying materials
+ * are made available under the terms of the Eclipse Public License v1.0
+ * which accompanies this distribution, and is available at
+ * http://www.eclipse.org/legal/epl-v10.html
+ *
+ * Contributors:
+ *     Boeing - initial API and implementation
+ *******************************************************************************/
+package org.eclipse.osee.framework.server.admin;
+
+import java.util.ArrayList;
+import java.util.List;
+import org.eclipse.core.runtime.IProgressMonitor;
+import org.eclipse.osee.framework.core.exception.OseeArgumentException;
+import org.eclipse.osee.framework.core.exception.OseeCoreException;
+import org.eclipse.osee.framework.core.model.cache.RelationTypeCache;
+import org.eclipse.osee.framework.core.model.type.RelationType;
+import org.eclipse.osee.framework.core.operation.OperationLogger;
+import org.eclipse.osee.framework.core.services.IOseeCachingService;
+import org.eclipse.osee.framework.database.IOseeDatabaseService;
+import org.eclipse.osee.framework.database.core.AbstractDbTxOperation;
+import org.eclipse.osee.framework.database.core.ConnectionHandler;
+import org.eclipse.osee.framework.database.core.IOseeStatement;
+import org.eclipse.osee.framework.database.core.OseeConnection;
+import org.eclipse.osee.framework.server.admin.internal.Activator;
+
+/**
+ * Purges given relation types.<br/>
+ * <p>
+ * Tables involved:
+ * <li>osee_txs</li>
+ * <li>osee_txs_archived</li>
+ * <li>osee_relation_link</li>
+ * <li>osee_relation_link_type</li>
+ * </p>
+ * <br/>
+ * <p>
+ * To confirm/test results, you can run the following SQL post operation completion: <br/>
+ * <br/>
+ * <code>
+ * SELECT rel_link.rel_link_type_id, rel_link_t.type_name, COUNT(*)
+ * FROM osee_relation_link_type rel_link_t, osee_relation_link rel_link
+ * WHERE rel_link_t.rel_link_type_id = rel_link.rel_link_type_id GROUP BY rel_link.rel_link_type_id, rel_link_t.type_name;
+ * </code> <br/>
+ * <br/>
+ * should not list your deleted type.
+ * </p>
+ * <br/>
+ * 
+ * @author Karol M. Wilk
+ */
+public final class PurgeRelationType extends AbstractDbTxOperation {
+   private static final String RETRIEVE_GAMMAS_OF_REL_LINK_TXS =
+      "SELECT rel_link.gamma_id FROM osee_relation_link rel_link WHERE rel_link.rel_link_type_id = ?";
+
+   private static final String DELETE_BY_GAMMAS = "DELETE FROM %s WHERE gamma_id = ?";
+
+   private static final String DELETE_FROM_CONFLICT_TABLE_SOURCE_SIDE =
+      "DELETE FROM osee_conflict WHERE source_gamma_id = ?";
+   private static final String DELETE_FROM_CONFLICT_TABLE_DEST_SIDE =
+      "DELETE FROM osee_conflict WHERE dest_gamma_id = ?";
+
+   private static final String DELETE_REL_LINK_TYPE =
+      "DELETE FROM osee_relation_link_type type WHERE type.rel_link_type_guid = ?";
+
+   private final RelationTypeCache cache;
+   private final String[] typesToPurge;
+   private final boolean forcePurge;
+   private final List<String[]> relationTypeGuids;
+
+   public PurgeRelationType(IOseeDatabaseService databaseService, IOseeCachingService cachingService, OperationLogger logger, boolean force, String... typesToPurge) {
+      super(databaseService, "Purge Relation Type", Activator.PLUGIN_ID, logger);
+      this.cache = cachingService.getRelationTypeCache();
+      this.forcePurge = force;
+      this.typesToPurge = typesToPurge;
+      this.relationTypeGuids = new ArrayList<String[]>(typesToPurge.length);
+   }
+
+   @Override
+   protected void doTxWork(IProgressMonitor monitor, OseeConnection connection) throws OseeCoreException {
+
+      log();
+      log(!forcePurge ? "Relation Types:" : "Purging relation types:");
+
+      boolean found = collectInfo();
+
+      if (forcePurge && found) {
+         log("Removing from osee_* tables...");
+         processDeletes(connection, retrieveGammaIds());
+      }
+
+      log((found && !forcePurge) ? "To >DELETE Relation DATA!< add --force to confirm." : "Operation finished.");
+   }
+
+   private boolean collectInfo() throws OseeCoreException {
+      for (int i = 0; i < typesToPurge.length; i++) {
+
+         String guid;
+
+         try {
+            RelationType type = cache.getBySoleName(typesToPurge[i]);
+            guid = type.getGuid();
+            logf("Type [%s] found. Guid: [%s]\n", typesToPurge[i], guid);
+            relationTypeGuids.add(new String[] {guid});
+         } catch (OseeArgumentException ex) {
+            logf("Type [%s] NOT found. \n", typesToPurge[i]);
+            log(ex);
+         }
+
+      }
+
+      return !relationTypeGuids.isEmpty();
+   }
+
+   private List<Integer[]> retrieveGammaIds() throws OseeCoreException {
+      List<Integer[]> gammas = new ArrayList<Integer[]>(50000);
+      IOseeStatement chStmt = ConnectionHandler.getStatement();
+
+      try {
+         for (String[] relationTypeId : relationTypeGuids) {
+            chStmt.runPreparedQuery(RETRIEVE_GAMMAS_OF_REL_LINK_TXS, cache.getByGuid(relationTypeId[0]).getId());
+            while (chStmt.next()) {
+               gammas.add(new Integer[] {chStmt.getInt("gamma_id")});
+            }
+         }
+      } finally {
+         chStmt.close();
+      }
+
+      return gammas;
+   }
+
+   private void processDeletes(OseeConnection connection, List<Integer[]> gammas) throws OseeCoreException {
+      ConnectionHandler.runBatchUpdate(connection, String.format(DELETE_BY_GAMMAS, "osee_txs"), gammas);
+      ConnectionHandler.runBatchUpdate(connection, String.format(DELETE_BY_GAMMAS, "osee_txs_archived"), gammas);
+      ConnectionHandler.runBatchUpdate(connection, String.format(DELETE_BY_GAMMAS, "osee_relation_link"), gammas);
+      ConnectionHandler.runBatchUpdate(connection, String.format(DELETE_FROM_CONFLICT_TABLE_SOURCE_SIDE), gammas);
+      ConnectionHandler.runBatchUpdate(connection, String.format(DELETE_FROM_CONFLICT_TABLE_DEST_SIDE), gammas);
+      ConnectionHandler.runBatchUpdate(connection, DELETE_REL_LINK_TYPE, relationTypeGuids);
+   }
+}
\ No newline at end of file
diff --git a/plugins/org.eclipse.osee.framework.server.admin/src/org/eclipse/osee/framework/server/admin/ServerAdminCommandProvider.java b/plugins/org.eclipse.osee.framework.server.admin/src/org/eclipse/osee/framework/server/admin/ServerAdminCommandProvider.java
index 12ea47b..b340130 100644
--- a/plugins/org.eclipse.osee.framework.server.admin/src/org/eclipse/osee/framework/server/admin/ServerAdminCommandProvider.java
+++ b/plugins/org.eclipse.osee.framework.server.admin/src/org/eclipse/osee/framework/server/admin/ServerAdminCommandProvider.java
@@ -10,7 +10,9 @@
  *******************************************************************************/
 package org.eclipse.osee.framework.server.admin;
 
+import java.util.ArrayList;
 import java.util.Arrays;
+import java.util.Collection;
 import java.util.HashSet;
 import java.util.Set;
 import org.eclipse.core.runtime.jobs.ISchedulingRule;
@@ -24,8 +26,8 @@ import org.eclipse.osee.framework.core.operation.IOperation;
 import org.eclipse.osee.framework.core.operation.MutexSchedulingRule;
 import org.eclipse.osee.framework.core.operation.OperationLogger;
 import org.eclipse.osee.framework.core.operation.Operations;
-import org.eclipse.osee.framework.database.operation.PurgeUnusedBackingDataAndTransactions;
 import org.eclipse.osee.framework.database.operation.ConsolidateArtifactVersionTxOperation;
+import org.eclipse.osee.framework.database.operation.PurgeUnusedBackingDataAndTransactions;
 import org.eclipse.osee.framework.jdk.core.util.Strings;
 import org.eclipse.osee.framework.server.admin.internal.Activator;
 import org.eclipse.osee.framework.server.admin.management.SchedulingCommand;
@@ -110,6 +112,28 @@ public class ServerAdminCommandProvider implements CommandProvider {
       return Operations.executeAsJob(new TxCurrentsAndModTypesCommand(logger, archived), false);
    }
 
+   public Job _purge_relation_type(CommandInterpreter ci) {
+      OperationLogger logger = new CommandInterpreterLogger(ci);
+
+      //to be purged
+      final Collection<String> relationTypes = new ArrayList<String>();
+
+      boolean force = false;
+      for (String arg = ci.nextArgument(); Strings.isValid(arg); arg = ci.nextArgument()) {
+         if (arg.equals("-force")) {
+            force = true;
+         } else {
+            relationTypes.add(arg);
+         }
+      }
+
+      IOperation operation =
+         new PurgeRelationType(Activator.getOseeDatabaseService(), Activator.getOseeCachingService(), logger, force,
+            relationTypes.toArray(new String[relationTypes.size()]));
+
+      return Operations.executeAsJob(operation, false);
+   }
+
    public Job _tx_prune(CommandInterpreter ci) {
       OperationLogger logger = new CommandInterpreterLogger(ci);
       return Operations.executeAsJob(new PurgeUnusedBackingDataAndTransactions(logger), false);
@@ -142,6 +166,7 @@ public class ServerAdminCommandProvider implements CommandProvider {
       sb.append("        duplicate_attr - detect and fix duplicate attributes\n");
       sb.append("        osee_shutdown [-oseeOnly] - immediately release the listening port then waits for all existing operations to finish. \n");
       sb.append("        schedule <delay seconds> <iterations> <command> - runs the command after the specified delay and repeat given number of times\n");
+      sb.append("        purge_relation_type -force excute the operation, relationType1 ...\n");
       sb.append(String.format("        reload_cache %s? - reloads server caches\n",
          Arrays.deepToString(OseeCacheEnum.values()).replaceAll(",", " | ")));
       sb.append(String.format("        clear_cache %s? - decaches all objects from the specified caches\n",