diff --git a/symmetric-jdbc/src/main/java/org/jumpmind/db/platform/mssql/MsSqlDdlReader.java b/symmetric-jdbc/src/main/java/org/jumpmind/db/platform/mssql/MsSqlDdlReader.java
index 8b43cc4e23..1ce929e05d 100644
--- a/symmetric-jdbc/src/main/java/org/jumpmind/db/platform/mssql/MsSqlDdlReader.java
+++ b/symmetric-jdbc/src/main/java/org/jumpmind/db/platform/mssql/MsSqlDdlReader.java
@@ -333,7 +333,7 @@ public Trigger mapRow(Row row) {
 		}, tableName, schema);
 	}
     
-    protected IConnectionHandler getConnectionHandler() {
-        return new ChangeCatalogConnectionHandler(platform.getDefaultCatalog());
+    protected IConnectionHandler getConnectionHandler(String catalog) {
+        return new ChangeCatalogConnectionHandler(catalog == null ? platform.getDefaultCatalog() : catalog);
     }
 }