diff --git a/symmetric/src/main/java/org/jumpmind/symmetric/db/AbstractDbDialect.java b/symmetric/src/main/java/org/jumpmind/symmetric/db/AbstractDbDialect.java
index b6b2560b39..b02cdc2177 100644
--- a/symmetric/src/main/java/org/jumpmind/symmetric/db/AbstractDbDialect.java
+++ b/symmetric/src/main/java/org/jumpmind/symmetric/db/AbstractDbDialect.java
@@ -468,4 +468,8 @@ public int getStreamingResultsFetchSize() {
     public void setStreamingResultsFetchSize(int streamingResultsFetchSize) {
         this.streamingResultsFetchSize = streamingResultsFetchSize;
     }
+
+    public JdbcTemplate getJdbcTemplate() {
+        return jdbcTemplate;
+    }
 }
diff --git a/symmetric/src/main/java/org/jumpmind/symmetric/db/IDbDialect.java b/symmetric/src/main/java/org/jumpmind/symmetric/db/IDbDialect.java
index 67a41c3917..cfc62ba974 100644
--- a/symmetric/src/main/java/org/jumpmind/symmetric/db/IDbDialect.java
+++ b/symmetric/src/main/java/org/jumpmind/symmetric/db/IDbDialect.java
@@ -26,6 +26,7 @@
 import org.jumpmind.symmetric.model.DataEventType;
 import org.jumpmind.symmetric.model.TriggerHistory;
 import org.jumpmind.symmetric.model.Trigger;
+import org.springframework.jdbc.core.JdbcTemplate;
 import org.springframework.jdbc.support.SQLErrorCodeSQLExceptionTranslator;
 
 public interface IDbDialect {
@@ -75,4 +76,6 @@ public void initTrigger(DataEventType dml, Trigger config,
     
     public int getStreamingResultsFetchSize();
     
+    public JdbcTemplate getJdbcTemplate();
+    
 }