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() {