Skip to content

Commit 89611b3

Browse files
authored
Merge pull request #4915 from hansva/main
fixes after XML cleanup
2 parents 79c10d3 + 88b4e2c commit 89611b3

File tree

4 files changed

+27
-9
lines changed

4 files changed

+27
-9
lines changed

plugins/transforms/joinrows/src/main/java/org/apache/hop/pipeline/transforms/joinrows/JoinRowsMeta.java

Lines changed: 7 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -248,11 +248,11 @@ public boolean cleanAfterHopToRemove(TransformMeta fromTransform) {
248248
public static final class ConditionXmlConverter implements IStringObjectConverter {
249249
@Override
250250
public String getString(Object object) throws HopException {
251-
if (!(object instanceof Condition)) {
251+
if (!(object instanceof JRCompare)) {
252252
throw new HopException("We only support XML serialization of Condition objects here");
253253
}
254254
try {
255-
return ((Condition) object).getXml();
255+
return ((JRCompare) object).getCondition().getXml();
256256
} catch (Exception e) {
257257
throw new HopException("Error serializing Condition to XML", e);
258258
}
@@ -261,7 +261,7 @@ public String getString(Object object) throws HopException {
261261
@Override
262262
public Object getObject(String xml) throws HopException {
263263
try {
264-
return new Condition(xml);
264+
return new JRCompare(new Condition(xml));
265265
} catch (Exception e) {
266266
throw new HopException("Error serializing Condition from XML", e);
267267
}
@@ -277,6 +277,10 @@ public static final class JRCompare {
277277
public JRCompare() {
278278
condition = new Condition();
279279
}
280+
281+
public JRCompare(Condition condition) {
282+
this.condition = condition;
283+
}
280284
}
281285

282286
/**

plugins/transforms/pipelineexecutor/src/main/java/org/apache/hop/pipeline/transforms/pipelineexecutor/PipelineExecutorMeta.java

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -39,6 +39,7 @@
3939
import org.apache.hop.core.xml.XmlHandler;
4040
import org.apache.hop.i18n.BaseMessages;
4141
import org.apache.hop.metadata.api.HopMetadataProperty;
42+
import org.apache.hop.metadata.api.HopMetadataPropertyType;
4243
import org.apache.hop.metadata.api.IHopMetadataProvider;
4344
import org.apache.hop.pipeline.ISubPipelineAwareMeta;
4445
import org.apache.hop.pipeline.PipelineMeta;
@@ -83,7 +84,9 @@ public class PipelineExecutorMeta
8384
private boolean filenameInField;
8485

8586
/** Name of the field containing the pipeline file's name */
86-
@HopMetadataProperty(key = "filenameField")
87+
@HopMetadataProperty(
88+
key = "filenameField",
89+
hopMetadataPropertyType = HopMetadataPropertyType.PIPELINE_FILE)
8790
private String filenameField;
8891

8992
/**
@@ -261,6 +264,7 @@ public void loadXml(Node transformNode, IHopMetadataProvider metadataProvider)
261264
@Override
262265
public void setDefault() {
263266
parameters = new ArrayList<>();
267+
resultRows = new ArrayList<>();
264268
filenameInField = false;
265269

266270
groupSize = "1";
@@ -281,7 +285,6 @@ public void setDefault() {
281285
executionExitStatusField = "ExecutionExitStatus";
282286
executionLogTextField = "ExecutionLogText";
283287
executionLogChannelIdField = "ExecutionLogChannelId";
284-
285288
resultFilesFileNameField = "FileName";
286289
}
287290

plugins/transforms/selectvalues/src/main/java/org/apache/hop/pipeline/transforms/selectvalues/SelectValues.java

Lines changed: 7 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -17,6 +17,8 @@
1717

1818
package org.apache.hop.pipeline.transforms.selectvalues;
1919

20+
import static org.apache.hop.core.row.IValueMeta.storageTypeCodes;
21+
2022
import com.google.common.annotations.VisibleForTesting;
2123
import java.util.ArrayList;
2224
import java.util.Arrays;
@@ -356,8 +358,11 @@ synchronized Object[] metadataValues(IRowMeta rowMeta, Object[] rowData) throws
356358
//
357359
try {
358360
if (fromMeta.isStorageBinaryString()
359-
&& meta.getSelectOption().getMeta().get(i).getStorageType()
360-
== ValueMetaFactory.getValueMetaName(IValueMeta.STORAGE_TYPE_NORMAL)) {
361+
&& meta.getSelectOption()
362+
.getMeta()
363+
.get(i)
364+
.getStorageType()
365+
.equals(storageTypeCodes[IValueMeta.STORAGE_TYPE_NORMAL])) {
361366
rowData[index] = fromMeta.convertBinaryStringToNativeType((byte[]) rowData[index]);
362367
}
363368
if (meta.getSelectOption().getMeta().get(i).getType()

plugins/transforms/selectvalues/src/main/java/org/apache/hop/pipeline/transforms/selectvalues/SelectValuesDialog.java

Lines changed: 8 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -17,6 +17,8 @@
1717

1818
package org.apache.hop.pipeline.transforms.selectvalues;
1919

20+
import static org.apache.hop.core.row.IValueMeta.storageTypeCodes;
21+
2022
import java.nio.charset.Charset;
2123
import java.util.ArrayList;
2224
import java.util.Arrays;
@@ -641,7 +643,11 @@ public void getData() {
641643
item.setText(index++, change.getType() != null ? change.getType() : "-");
642644
item.setText(index++, change.getLength() < 0 ? "" : "" + change.getLength());
643645
item.setText(index++, change.getPrecision() < 0 ? "" : "" + change.getPrecision());
644-
item.setText(index++, change.getStorageType());
646+
item.setText(
647+
index++,
648+
change.getStorageType().equals(storageTypeCodes[IValueMeta.STORAGE_TYPE_NORMAL])
649+
? BaseMessages.getString(PKG, CONST_SYSTEM_COMBO_YES)
650+
: BaseMessages.getString(PKG, CONST_SYSTEM_COMBO_NO));
645651
item.setText(index++, Const.NVL(change.getConversionMask(), ""));
646652
item.setText(
647653
index++,
@@ -761,7 +767,7 @@ private void ok() {
761767
}
762768
if (BaseMessages.getString(PKG, CONST_SYSTEM_COMBO_YES)
763769
.equalsIgnoreCase(item.getText(index++))) {
764-
change.setStorageType(ValueMetaFactory.getValueMetaName(IValueMeta.STORAGE_TYPE_NORMAL));
770+
change.setStorageType(storageTypeCodes[IValueMeta.STORAGE_TYPE_NORMAL]);
765771
}
766772

767773
change.setConversionMask(item.getText(index++));

0 commit comments

Comments
 (0)