need to detect trigger object in schema

JumpMind · Dec 20, 2007 · 2577981 · 2577981
1 parent be1a6f3
commit 2577981
Showing 1 changed file with 10 additions and 3 deletions.
diff --git a/symmetric/src/main/java/org/jumpmind/symmetric/db/derby/DerbyDbDialect.java b/symmetric/src/main/java/org/jumpmind/symmetric/db/derby/DerbyDbDialect.java
@@ -40,16 +40,23 @@ public boolean isFunctionUpToDate(String name) throws Exception {
         return true;
     }
 
-    @Override
     protected boolean doesTriggerExistOnPlatform(String schema, String tableName, String triggerName) {
-        return true;
+        schema = schema == null ? (getDefaultSchema() == null ? null : getDefaultSchema()) : schema;
+        return jdbcTemplate.queryForInt("select count(*) from sys.systriggers where triggername = ?",
+                new Object[] { triggerName }) > 0;
     }
 
     public void removeTrigger(String schemaName, String triggerName) {
-        throw new RuntimeException("Not implemented.  Use removeTrigger(schema, trigger, table) instead.");
+        schemaName = schemaName == null ? "" : (schemaName + ".");
+        try {
+            jdbcTemplate.update("drop trigger " + schemaName + triggerName);
+        } catch (Exception e) {
+            logger.warn("Trigger does not exist");
+        }
     }
 
     public void removeTrigger(String schemaName, String triggerName, String tableName) {
+        removeTrigger(schemaName, triggerName);
     }
 
     public void disableSyncTriggers() {