Skip to content

Commit 9d78b13

Browse files
committed
NIFI-14861: Escape single-quotes in string values
1 parent ca4e825 commit 9d78b13

File tree

2 files changed

+8
-1
lines changed

2 files changed

+8
-1
lines changed

nifi-extension-bundles/nifi-graph-bundle/nifi-graph-processors/src/main/java/org/apache/nifi/processors/graph/EnrichGraphRecord.java

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -287,6 +287,13 @@ public void onTrigger(final ProcessContext context, final ProcessSession session
287287
} else if (RecordFieldType.RECORD.equals(rawValueType)) {
288288
MapRecord mapRecord = (MapRecord) rawValue;
289289
dynamicPropertyMap.put(fieldName, mapRecord.toMap(true));
290+
} else if (RecordFieldType.STRING.equals(rawValueType)) {
291+
// Escape single quotes
292+
String stringValue = (String) rawValue;
293+
if (rawValue != null) {
294+
stringValue = stringValue.replace('\'', '\\');
295+
dynamicPropertyMap.put(fieldName, stringValue);
296+
}
290297
} else {
291298
dynamicPropertyMap.put(fieldName, rawValue);
292299
}

nifi-extension-bundles/nifi-graph-bundle/nifi-graph-processors/src/test/java/org/apache/nifi/processors/graph/TestEnrichGraphRecord.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -19,9 +19,9 @@
1919
import org.apache.nifi.graph.GraphClientService;
2020
import org.apache.nifi.json.JsonTreeReader;
2121
import org.apache.nifi.processor.Processor;
22-
import org.apache.nifi.serialization.record.Record;
2322
import org.apache.nifi.serialization.RecordReader;
2423
import org.apache.nifi.serialization.record.MockRecordWriter;
24+
import org.apache.nifi.serialization.record.Record;
2525
import org.apache.nifi.util.MockComponentLog;
2626
import org.apache.nifi.util.MockFlowFile;
2727
import org.apache.nifi.util.TestRunner;

0 commit comments

Comments
 (0)