Skip to content

Commit 6389511

Browse files
committed
0006384: Error on registration batch or import of config from newer 3.14
or 3.15
1 parent 845cb67 commit 6389511

File tree

1 file changed

+11
-1
lines changed

1 file changed

+11
-1
lines changed

symmetric-io/src/main/java/org/jumpmind/symmetric/io/data/writer/TransformWriter.java

+11-1
Original file line numberDiff line numberDiff line change
@@ -133,7 +133,8 @@ public void write(CsvData data) {
133133
List<TransformTable> transformTables = activeTransforms;
134134
for (TransformTable transformation : transformTables) {
135135
Table transformedTable = new Table(transformation.getTargetCatalogName(),
136-
transformation.getTargetSchemaName(), transformation.getTargetTableName());
136+
transformation.getTargetSchemaName(), transformation.getTargetTableName(),
137+
getTargetColumnNames(transformation.getTransformColumns()), getTargetColumnNames(transformation.getPrimaryKeyColumns()));
137138
callWriter(transformedTable, data);
138139
}
139140
return;
@@ -208,6 +209,15 @@ protected void callWriter(Table transformedTable, CsvData csvData) {
208209
}
209210
}
210211

212+
protected String[] getTargetColumnNames(List<TransformColumn> columns) {
213+
String[] names = new String[columns.size()];
214+
int i = 0;
215+
for (TransformColumn column : columns) {
216+
names[i++] = column.getTargetColumnName();
217+
}
218+
return names;
219+
}
220+
211221
protected List<TransformedData> transform(DataEventType eventType, DataContext context,
212222
TransformTable transformation, Map<String, String> sourceKeyValues,
213223
Map<String, String> oldSourceValues, Map<String, String> sourceValues) {

0 commit comments

Comments
 (0)