feat: update influxdb-client-java to 2.2.0

CHANGELOG.md

@@ -1,5 +1,8 @@
 ## v1.11.0 [unreleased]
 
+### Others
+1. [#54](https://github.com/influxdata/nifi-influxdb-bundle/pull/54): Update `influxdb-client-java` to 2.2.0
+
 ## v1.10.0 [2021-04-01]
 
 ### Others

nifi-influx-database-processors/src/test/java/org/influxdata/nifi/processors/ITGetInfluxDatabaseRecord_2.java

@@ -24,6 +24,8 @@
 import java.util.List;
 
 import com.google.common.collect.Lists;
+import com.google.gson.JsonObject;
+import com.google.gson.JsonParser;
 import com.influxdb.client.domain.WritePrecision;
 import org.apache.avro.file.DataFileStream;
 import org.apache.avro.generic.GenericData;
@@ -43,8 +45,6 @@
 import org.influxdata.nifi.processors.internal.AbstractInfluxDatabaseProcessor;
 import org.influxdata.nifi.services.InfluxDatabaseService_2;
 import org.influxdata.nifi.services.StandardInfluxDatabaseService_2;
-import org.json.JSONArray;
-import org.json.JSONObject;
 import org.junit.Assert;
 import org.junit.Before;
 import org.junit.Test;
@@ -197,18 +197,18 @@ public void writeToJson() throws InitializationException {
         MockFlowFile flowFile = runner.getFlowFilesForRelationship(GetInfluxDatabaseRecord_2.REL_SUCCESS).get(0);
 
         String json = new String(runner.getContentAsByteArray(flowFile));
-		JSONObject parsedJson = (new JSONArray(json)).getJSONObject(0);
+		JsonObject parsedJson = (new JsonParser().parse(json).getAsJsonArray()).get(0).getAsJsonObject();
 
         Assert.assertNotNull(parsedJson);
-        Assert.assertEquals("_result", parsedJson.get("result"));
-        Assert.assertEquals(0, parsedJson.get("table"));
-        Assert.assertEquals(0, parsedJson.get("_start"));
-        Assert.assertEquals(0, parsedJson.get("_time"));
-        Assert.assertTrue((long) parsedJson.get("_stop") > from.getTime());
-        Assert.assertEquals("humidity", parsedJson.get("_field"));
-        Assert.assertEquals("newark", parsedJson.get("city"));
-        Assert.assertEquals("US", parsedJson.get("country"));
-        Assert.assertEquals(0.6D, parsedJson.get("_value"));
+        Assert.assertEquals("_result", parsedJson.get("result").getAsString());
+        Assert.assertEquals(0, parsedJson.get("table").getAsInt());
+        Assert.assertEquals(0, parsedJson.get("_start").getAsInt());
+        Assert.assertEquals(0, parsedJson.get("_time").getAsInt());
+        Assert.assertTrue(parsedJson.get("_stop").getAsLong() > from.getTime());
+        Assert.assertEquals("humidity", parsedJson.get("_field").getAsString());
+        Assert.assertEquals("newark", parsedJson.get("city").getAsString());
+        Assert.assertEquals("US", parsedJson.get("country").getAsString());
+        Assert.assertEquals((Object) 0.6D, parsedJson.get("_value").getAsDouble());
     }
 
     @Test

pom.xml

@@ -212,7 +212,7 @@
             <dependency>
                 <groupId>com.influxdb</groupId>
                 <artifactId>influxdb-client-java</artifactId>
-                <version>1.11.0</version>
+                <version>2.2.0</version>
             </dependency>
 
             <dependency>