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 ed76c4182e..b93f904055 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
@@ -1268,7 +1268,7 @@ public List<String> execute(Connection connection) throws SQLException {
                         if (columnCount > 1) {
                             schemaCatalog = rs.getString(2);
                         }
-                        if (StringUtils.isBlank(catalog) && !schemas.contains(schema)) {
+                        if ((StringUtils.isBlank(schemaCatalog) || StringUtils.isBlank(catalog)) && !schemas.contains(schema)) {
                             schemas.add(schema);
                         } else if (StringUtils.isNotBlank(schemaCatalog)
                                 && schemaCatalog.equals(catalog)) {