diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/db/AbstractSymmetricDialect.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/db/AbstractSymmetricDialect.java index 38a8433464..82a7422608 100644 --- a/symmetric-core/src/main/java/org/jumpmind/symmetric/db/AbstractSymmetricDialect.java +++ b/symmetric-core/src/main/java/org/jumpmind/symmetric/db/AbstractSymmetricDialect.java @@ -179,10 +179,15 @@ public void dropTablesAndDatabaseObjects() { final public boolean doesTriggerExist(String catalogName, String schema, String tableName, String triggerName) { - try { - return doesTriggerExistOnPlatform(catalogName, schema, tableName, triggerName); - } catch (Exception ex) { - log.warn("Could not figure out if the trigger exists. Assuming that is does not", ex); + if (StringUtils.isNotBlank(triggerName)) { + try { + return doesTriggerExistOnPlatform(catalogName, schema, tableName, triggerName); + } catch (Exception ex) { + log.warn("Could not figure out if the trigger exists. Assuming that is does not", + ex); + return false; + } + } else { return false; } }