diff --git a/symmetric-jdbc/src/main/java/org/jumpmind/db/platform/AbstractJdbcDdlReader.java b/symmetric-jdbc/src/main/java/org/jumpmind/db/platform/AbstractJdbcDdlReader.java index 16c078f059..1b19b679a4 100644 --- a/symmetric-jdbc/src/main/java/org/jumpmind/db/platform/AbstractJdbcDdlReader.java +++ b/symmetric-jdbc/src/main/java/org/jumpmind/db/platform/AbstractJdbcDdlReader.java @@ -52,6 +52,7 @@ import org.jumpmind.db.model.PlatformColumn; import org.jumpmind.db.model.Reference; import org.jumpmind.db.model.Table; +import org.jumpmind.db.model.Trigger; import org.jumpmind.db.model.TypeMap; import org.jumpmind.db.model.UniqueIndex; import org.jumpmind.db.sql.IConnectionCallback; @@ -130,6 +131,12 @@ public AbstractJdbcDdlReader(IDatabasePlatform platform) { _columnsForFK = initColumnsForFK(); _columnsForIndex = initColumnsForIndex(); } + + @Override + public List getTriggers(String catalog, String schema, + String tableName) { + return Collections.emptyList(); + } /* * Returns the platform that this model reader belongs to. @@ -1358,7 +1365,10 @@ public List execute(Connection connection) throws SQLException { try { rs = meta.getCatalogs(); while (rs.next()) { - catalogs.add(rs.getString(1)); + String catalog = rs.getString(1); + if (catalog != null) { + catalogs.add(catalog); + } } return catalogs; } finally { @@ -1442,5 +1452,21 @@ public List execute(Connection connection) throws SQLException { } }); } + + public List getListOfTriggers() { + return new ArrayList(); + } + + public Trigger getTriggerFor(Table table, String triggerName) { + Trigger trigger = null; + List triggers = getTriggers(table.getCatalog(), table.getSchema(), table.getName()); + for (Trigger t : triggers) { + if (t.getName().equals(triggerName)) { + trigger = t; + break; + } + } + return trigger; + } }