diff --git a/symmetric-client/src/main/java/org/jumpmind/symmetric/db/nuodb/NuoDbSymmetricDialect.java b/symmetric-client/src/main/java/org/jumpmind/symmetric/db/nuodb/NuoDbSymmetricDialect.java index c804d52a37..a08f424da2 100644 --- a/symmetric-client/src/main/java/org/jumpmind/symmetric/db/nuodb/NuoDbSymmetricDialect.java +++ b/symmetric-client/src/main/java/org/jumpmind/symmetric/db/nuodb/NuoDbSymmetricDialect.java @@ -147,7 +147,7 @@ public void enableSyncTriggers(ISqlTransaction transaction) { } public String getSyncTriggersExpression() { - return this.parameterService.getTablePrefix()+ "_get_session_variable('" + SYNC_TRIGGERS_DISABLED_USER_VARIABLE + "') is null"; + return "$(defaultSchema)" + parameterService.getTablePrefix()+ "_get_session_variable('" + SYNC_TRIGGERS_DISABLED_USER_VARIABLE + "') is null"; } public void cleanDatabase() { diff --git a/symmetric-client/src/main/java/org/jumpmind/symmetric/db/nuodb/NuoDbTriggerTemplate.java b/symmetric-client/src/main/java/org/jumpmind/symmetric/db/nuodb/NuoDbTriggerTemplate.java index 871fdf7da3..6f0932fe01 100644 --- a/symmetric-client/src/main/java/org/jumpmind/symmetric/db/nuodb/NuoDbTriggerTemplate.java +++ b/symmetric-client/src/main/java/org/jumpmind/symmetric/db/nuodb/NuoDbTriggerTemplate.java @@ -56,7 +56,7 @@ public NuoDbTriggerTemplate(ISymmetricDialect symmetricDialect) { " $(triggerHistoryId), \n" + " concat($(columns) \n" + " ), \n" + -" $(channelExpression), $(txIdExpression), $(prefixName)_get_session_variable('sync_node_disabled'), \n" + +" $(channelExpression), $(txIdExpression), $(defaultSchema)$(prefixName)_get_session_variable('sync_node_disabled'), \n" + " $(externalSelect), \n" + " CURRENT_TIMESTAMP \n" + " ); \n" + @@ -75,7 +75,7 @@ public NuoDbTriggerTemplate(ISymmetricDialect symmetricDialect) { " 'R', \n" + " $(triggerHistoryId), \n" + " $(newKeys), \n" + -" $(channelExpression), $(txIdExpression), $(prefixName)_get_session_variable('sync_node_disabled'), \n" + +" $(channelExpression), $(txIdExpression), $(defaultSchema)$(prefixName)_get_session_variable('sync_node_disabled'), \n" + " $(externalSelect), \n" + " CURRENT_TIMESTAMP \n" + " ); \n" + @@ -98,7 +98,7 @@ public NuoDbTriggerTemplate(ISymmetricDialect symmetricDialect) { " ), \n" + " concat($(columns)), \n" + " concat($(oldColumns)), \n" + -" $(channelExpression), $(txIdExpression), $(prefixName)_get_session_variable('sync_node_disabled'), \n" + +" $(channelExpression), $(txIdExpression), $(defaultSchema)$(prefixName)_get_session_variable('sync_node_disabled'), \n" + " $(externalSelect), \n" + " CURRENT_TIMESTAMP \n" + " ); \n" + @@ -121,7 +121,7 @@ public NuoDbTriggerTemplate(ISymmetricDialect symmetricDialect) { " ), \n" + " concat($(oldColumns) \n" + " ), \n" + -" $(channelExpression), $(txIdExpression), $(prefixName)_get_session_variable('sync_node_disabled'), \n" + +" $(channelExpression), $(txIdExpression), $(defaultSchema)$(prefixName)_get_session_variable('sync_node_disabled'), \n" + " $(externalSelect), \n" + " CURRENT_TIMESTAMP \n" + " ); \n" +