CLOUDSTACK-7210: removed duplicated foreign key from async_job_join_map table

Alena Prokharchyk · Alena Prokharchyk · commit 685a58a8433f · 2014-08-01T10:48:36.000-07:00
diff --git a/engine/schema/src/com/cloud/upgrade/dao/Upgrade441to450.java b/engine/schema/src/com/cloud/upgrade/dao/Upgrade441to450.java
@@ -60,6 +60,7 @@ public File[] getPrepareScripts() {
     @Override
     public void performDataMigration(Connection conn) {
         dropInvalidKeyFromStoragePoolTable(conn);
+        dropDuplicatedForeignKeyFromAsyncJobTable(conn);
     }
 
 
@@ -80,9 +81,22 @@ private void dropInvalidKeyFromStoragePoolTable(Connection conn) {
         keys.add("id_2");
         uniqueKeys.put("storage_pool", keys);
 
-        s_logger.debug("Droping id_2 key from storage_pool table");
+        s_logger.debug("Dropping id_2 key from storage_pool table");
         for (Map.Entry<String, List<String>> entry: uniqueKeys.entrySet()) {
             DbUpgradeUtils.dropKeysIfExist(conn,entry.getKey(), entry.getValue(), false);
         }
     }
+
+    private void dropDuplicatedForeignKeyFromAsyncJobTable(Connection conn) {
+        HashMap<String, List<String>> foreignKeys = new HashMap<String, List<String>>();
+        List<String> keys = new ArrayList<String>();
+
+        keys.add("fk_async_job_join_map__join_job_id");
+        foreignKeys.put("async_job_join_map", keys);
+
+        s_logger.debug("Dropping fk_async_job_join_map__join_job_id key from async_job_join_map table");
+        for (Map.Entry<String, List<String>> entry: foreignKeys.entrySet()) {
+            DbUpgradeUtils.dropKeysIfExist(conn,entry.getKey(), entry.getValue(), true);
+        }
+    }
 }
