This is an automated email from the ASF dual-hosted git repository.
SvenO3 pushed a commit to branch
4650-file-adapter-string-parsing-fails-for-quoted-delimiter
in repository https://gitbox.apache.org/repos/asf/streampipes.git
The following commit(s) were added to
refs/heads/4650-file-adapter-string-parsing-fails-for-quoted-delimiter by this
push:
new d67244c695 Add tests
d67244c695 is described below
commit d67244c695baabafa72979cebcca8fb0a70ed108
Author: Sven Oehler <[email protected]>
AuthorDate: Wed Jul 8 11:43:09 2026 +0200
Add tests
---
.../connect/adapter/parser/CsvParserTest.java | 30 ++++++++++++++++++++++
1 file changed, 30 insertions(+)
diff --git
a/streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/connect/adapter/parser/CsvParserTest.java
b/streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/connect/adapter/parser/CsvParserTest.java
index 283bd362ea..b4cbd85609 100644
---
a/streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/connect/adapter/parser/CsvParserTest.java
+++
b/streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/connect/adapter/parser/CsvParserTest.java
@@ -76,4 +76,34 @@ public class CsvParserTest extends ParserTest {
verify(mockEventHandler, times(1)).handle(expectedEvent);
}
+ @Test
+ public void parseHeaderWithQuotedDelimiter() {
+ var event = toStream("column1,column2,\"column2,5\"\n1,2,3");
+ var mockEventHandler = mock(IParserEventHandler.class);
+
+ var parser = new CsvParser(true, ',');
+ parser.parse(event, mockEventHandler);
+
+ Map<String, Object> expectedEvent = new HashMap<>();
+ expectedEvent.put("column1", 1);
+ expectedEvent.put("column2", 2);
+ expectedEvent.put("column2,5", 3);
+ verify(mockEventHandler).handle(expectedEvent);
+ }
+
+ @Test
+ public void parseValueWithQuotedDelimiter() {
+ var event = toStream("k1,k2,k3\nv1,\"2,5\",3");
+ var mockEventHandler = mock(IParserEventHandler.class);
+
+ var parser = new CsvParser(true, ',');
+ parser.parse(event, mockEventHandler);
+
+ Map<String, Object> expectedEvent = new HashMap<>();
+ expectedEvent.put(K1, "v1");
+ expectedEvent.put(K2, "2,5");
+ expectedEvent.put("k3", 3);
+ verify(mockEventHandler).handle(expectedEvent);
+ }
+
}