Merge pull request #638 from maanasa/nullchecksinpojo

majst01 · web-flow · commit 5cdc9e34611f · 2019-11-22T09:07:06.000+01:00
Allow only non null values to flow to influxDB
diff --git a/src/main/java/org/influxdb/dto/Point.java b/src/main/java/org/influxdb/dto/Point.java
@@ -276,9 +276,13 @@ private void addFieldByAttribute(final Object pojo, final Field field, final Col
         }
 
         if (column.tag()) {
-          this.tags.put(fieldName, (String) fieldValue);
+          if (fieldValue != null) {
+            this.tags.put(fieldName, (String) fieldValue);
+          }
         } else {
-          this.fields.put(fieldName, fieldValue);
+          if (fieldValue != null) {
+            this.fields.put(fieldName, fieldValue);
+          }
         }
 
       } catch (IllegalArgumentException | IllegalAccessException e) {

Original file line number	Diff line number	Diff line change
`@@ -276,9 +276,13 @@ private void addFieldByAttribute(final Object pojo, final Field field, final Col`
`276`	`276`	`}`
`277`	`277`
`278`	`278`	`if (column.tag()) {`
`279`		`- this.tags.put(fieldName, (String) fieldValue);`
	`279`	`+ if (fieldValue != null) {`
	`280`	`+ this.tags.put(fieldName, (String) fieldValue);`
	`281`	`+ }`
`280`	`282`	`} else {`
`281`		`- this.fields.put(fieldName, fieldValue);`
	`283`	`+ if (fieldValue != null) {`
	`284`	`+ this.fields.put(fieldName, fieldValue);`
	`285`	`+ }`
`282`	`286`	`}`
`283`	`287`
`284`	`288`	`} catch (IllegalArgumentException \| IllegalAccessException e) {`