diff --git a/orcas_core/build_source/orcas_diff/src/main/java/de/opitzconsulting/orcas/diff/JdbcConnectionHandler.java b/orcas_core/build_source/orcas_diff/src/main/java/de/opitzconsulting/orcas/diff/JdbcConnectionHandler.java
index 3546396f..e8a640f4 100644
--- a/orcas_core/build_source/orcas_diff/src/main/java/de/opitzconsulting/orcas/diff/JdbcConnectionHandler.java
+++ b/orcas_core/build_source/orcas_diff/src/main/java/de/opitzconsulting/orcas/diff/JdbcConnectionHandler.java
@@ -127,6 +127,9 @@ public static CallableStatementProviderImpl createCallableStatementProvider(
             }
             throw new RuntimeException(e);
         }
+
+        pParameters.getConnectionInitializer().accept(lCallableStatementProvider);
+
         return lCallableStatementProvider;
     }
 
diff --git a/orcas_core/build_source/orcas_diff/src/main/java/de/opitzconsulting/orcas/diff/Parameters.java b/orcas_core/build_source/orcas_diff/src/main/java/de/opitzconsulting/orcas/diff/Parameters.java
index 4b9bff4a..d4816d83 100644
--- a/orcas_core/build_source/orcas_diff/src/main/java/de/opitzconsulting/orcas/diff/Parameters.java
+++ b/orcas_core/build_source/orcas_diff/src/main/java/de/opitzconsulting/orcas/diff/Parameters.java
@@ -6,6 +6,7 @@
 import java.nio.charset.StandardCharsets;
 import java.util.Collections;
 import java.util.List;
+import java.util.function.Consumer;
 import java.util.function.UnaryOperator;
 
 import org.eclipse.emf.ecore.EObject;
@@ -13,6 +14,10 @@
 import de.opitzconsulting.orcas.sql.CallableStatementProvider;
 
 public abstract class Parameters {
+    public Consumer<CallableStatementProvider> getConnectionInitializer() {
+        return connectionInitializer;
+    }
+
     public static class JdbcConnectParameters {
         String _jdbcDriver;
         String _jdbcUrl;
@@ -73,6 +78,13 @@ public void setMultiSchemaConnectionManager(MultiSchemaConnectionManager pMultiS
     protected Boolean _indexmovetablespace;
     protected Boolean _tablemovetablespace;
 
+    public void setConnectionInitializer(Consumer<CallableStatementProvider> pConnectionInitializer) {
+        connectionInitializer = pConnectionInitializer;
+    }
+
+    private Consumer<CallableStatementProvider> connectionInitializer = p -> {
+    };
+
     public int getStaticsSpoolMaxLineLength() {
         return staticsSpoolMaxLineLength;
     }