From 9f944175e7ecc3a81becb4bd2f601b797f8c2e5d Mon Sep 17 00:00:00 2001 From: chenson42 Date: Fri, 29 May 2015 13:16:16 +0000 Subject: [PATCH] 0002306: Add a trim() column transform --- .../data/transform/TrimColumnTransform.java | 37 +++++++++++++++++++ 1 file changed, 37 insertions(+) create mode 100644 symmetric-io/src/main/java/org/jumpmind/symmetric/io/data/transform/TrimColumnTransform.java diff --git a/symmetric-io/src/main/java/org/jumpmind/symmetric/io/data/transform/TrimColumnTransform.java b/symmetric-io/src/main/java/org/jumpmind/symmetric/io/data/transform/TrimColumnTransform.java new file mode 100644 index 0000000000..62ccaf4440 --- /dev/null +++ b/symmetric-io/src/main/java/org/jumpmind/symmetric/io/data/transform/TrimColumnTransform.java @@ -0,0 +1,37 @@ +package org.jumpmind.symmetric.io.data.transform; + +import java.util.Map; + +import org.jumpmind.db.platform.IDatabasePlatform; +import org.jumpmind.extension.IBuiltInExtensionPoint; +import org.jumpmind.symmetric.io.data.DataContext; + +public class TrimColumnTransform implements ISingleNewAndOldValueColumnTransform, IBuiltInExtensionPoint { + + public static final String NAME = "trim"; + + public String getName() { + return NAME; + } + + public boolean isExtractColumnTransform() { + return true; + } + + public boolean isLoadColumnTransform() { + return true; + } + + public NewAndOldValue transform(IDatabasePlatform platform, DataContext context, + TransformColumn column, TransformedData data, Map sourceValues, String newValue, String oldValue) + throws IgnoreColumnException, IgnoreRowException { + if (newValue != null) { + newValue = newValue.trim(); + } + if (oldValue != null) { + oldValue = oldValue.trim(); + } + return new NewAndOldValue(newValue, oldValue); + } + +} \ No newline at end of file