diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/io/data/transform/BshColumnTransform.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/io/data/transform/BshColumnTransform.java index 3af20d8e72..7fb2559eca 100644 --- a/symmetric-core/src/main/java/org/jumpmind/symmetric/io/data/transform/BshColumnTransform.java +++ b/symmetric-core/src/main/java/org/jumpmind/symmetric/io/data/transform/BshColumnTransform.java @@ -143,13 +143,14 @@ public NewAndOldValue transform(IDatabasePlatform platform, interpreter.unset(columnName); } - if (result == null) { - return null; - } - else if (result instanceof String) { + if (result instanceof String) { return new NewAndOldValue((String) result, null); - } else { + } else if (result instanceof NewAndOldValue) { return (NewAndOldValue) result; + } else if (result != null) { + return new NewAndOldValue(result.toString(), null); + } else { + return null; } } catch (TargetError evalEx) { Throwable ex = evalEx.getTarget();