0003045: Sometimes insert on replicated tables fails on MySQL

JumpMind · Apr 17, 2017 · 4f780ed · 4f780ed
1 parent 976dda9
commit 4f780ed
Showing 1 changed file with 12 additions and 0 deletions.
diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/db/DatabaseUpgradeListener.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/db/DatabaseUpgradeListener.java
@@ -94,6 +94,18 @@ public String beforeUpgrade(ISymmetricDialect symmetricDialect, String tablePref
                 }
             }
         }
+
+        if (engine.getDatabasePlatform().getName().equals(DatabaseNamesConstants.MYSQL)) {
+            String function = tablePrefix + "_transaction_id_post_5_7_6";
+            String select = "select count(*) from information_schema.routines where routine_name='"
+                    + function + "' and routine_schema in (select database())";
+
+            if (engine.getDatabasePlatform().getSqlTemplate().queryForInt(select) > 0) {
+                String drop = "drop function " + function;
+                engine.getDatabasePlatform().getSqlTemplate().update(drop);
+                log.info("Just uninstalled {}", function);
+            }
+        }
         return sb.toString();
     }