add escaping for backslashes, fixes influxdata#718

oliverrahner · May 24, 2024 · 22407a5 · 22407a5
1 parent dc1d442
commit 22407a5
Show file tree

Hide file tree

Showing 2 changed files with 13 additions and 0 deletions.
diff --git a/client/src/main/java/com/influxdb/client/write/Point.java b/client/src/main/java/com/influxdb/client/write/Point.java
@@ -442,6 +442,9 @@ private void escapeKey(@Nonnull final StringBuilder sb, @Nonnull final String ke
     private void escapeKey(@Nonnull final StringBuilder sb, @Nonnull final String key, final boolean escapeEqual) {
         for (int i = 0; i < key.length(); i++) {
             switch (key.charAt(i)) {
+                case '\\':
+                    sb.append("\\\\");
+                    continue;
                 case '\n':
                     sb.append("\\n");
                     continue;

diff --git a/client/src/test/java/com/influxdb/client/write/PointTest.java b/client/src/test/java/com/influxdb/client/write/PointTest.java
@@ -182,6 +182,16 @@ void fieldEscape() {
         Assertions.assertThat(point.toLineProtocol()).isEqualTo("h2o,location=europe level=\"string esc\\\"ape value\"");
     }
 
+    @Test
+    void tagEscape() {
+        Point point = Point.measurement("h2o")
+                .addTag("location", "\\")
+                .addTag("zone", "europe")
+                .addField("level", "dummy value");
+
+        Assertions.assertThat(point.toLineProtocol()).isEqualTo("h2o,location=\\\\,zone=europe level=\"dummy value\"");
+    }
+
     @Test
     void time() {