0002017: Log the DDL that installs functions required for SymmetricDS…

… as it is being installed (similar to the way we log table DDL)
JumpMind · Oct 16, 2014 · 6c4ad90 · 6c4ad90
1 parent 2a25fba
commit 6c4ad90
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/symmetric-client/src/main/java/org/jumpmind/symmetric/db/mysql/MySqlSymmetricDialect.java b/symmetric-client/src/main/java/org/jumpmind/symmetric/db/mysql/MySqlSymmetricDialect.java
@@ -99,7 +99,7 @@ public void createRequiredDatabaseObjects() {
         } else {
             String function = this.parameterService.getTablePrefix() + "_" + TRANSACTION_ID + this.functionTemplateKeySuffix;
             if (!installed(SQL_FUNCTION_INSTALLED, function)) {
-           String sql = "create function $(functionName)()                                                                                                                                                                      " + 
+           String sql = "create function $(functionName)()                                                                                               \n" + 
                         " returns varchar(50) NOT DETERMINISTIC READS SQL DATA                                                                           \n" + 
                         " begin                                                                                                                          \n" + 
                         "    declare comm_value varchar(50);                                                                                             \n" + 

diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/db/AbstractSymmetricDialect.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/db/AbstractSymmetricDialect.java
@@ -166,6 +166,7 @@ protected boolean installed(String sql, String objectName) {
 
     protected void install(String sql, String objectName) {
         sql = replaceTokens(sql, objectName);
+        log.info("Installing SymmetricDS database object:\n{}", sql);
         platform.getSqlTemplate().update(sql);
         log.info("Just installed {}", objectName);
     }