0000731: Redo the derby database triggers so they can handle tables w…

…ith more columns
JumpMind · Jul 26, 2012 · ac4fa66 · ac4fa66
1 parent f8cf5b9
commit ac4fa66
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/symmetric-client/src/main/java/org/jumpmind/symmetric/db/derby/DerbyFunctions.java b/symmetric-client/src/main/java/org/jumpmind/symmetric/db/derby/DerbyFunctions.java
@@ -37,7 +37,6 @@
 import org.apache.derby.iapi.db.TriggerExecutionContext;
 import org.apache.derby.iapi.sql.conn.LanguageConnectionContext;
 import org.apache.derby.impl.jdbc.EmbedConnection;
-import org.jumpmind.symmetric.io.data.CsvUtils;
 
 public class DerbyFunctions {
 
@@ -135,8 +134,8 @@ public static void insertData(int enabled, String schemaName, String prefixName,
             String rowData = null;
             String pkData = null;
             String oldData = null;
-            String[] parsedColumnNames = CsvUtils.tokenizeCsvData(columnNames);
-            String[] parsedPkColumnNames = CsvUtils.tokenizeCsvData(pkColumnNames);
+            String[] parsedColumnNames = StringUtils.splitPreserveAllTokens(columnNames, ',');
+            String[] parsedPkColumnNames = StringUtils.splitPreserveAllTokens(pkColumnNames, ',');
             if (dmlType.equals("I") || dmlType.equals("U")) {
                 StringBuilder dataBuilder = new StringBuilder();
                 appendCsvString(tableName, parsedColumnNames, parsedPkColumnNames,