fix bug: mapping from msgpack response to int, Integer, long, Long types works fine

src/main/java/org/influxdb/impl/InfluxDBResultMapper.java

@@ -361,11 +361,11 @@ <T> boolean fieldValueForPrimitivesModified(final Class<?> fieldType, final Fiel
  return true;
  }
  if (long.class.isAssignableFrom(fieldType)) {
- field.setLong(object, ((Double) value).longValue());
+ field.setLong(object, ((Number) value).longValue());
  return true;
  }
  if (int.class.isAssignableFrom(fieldType)) {
- field.setInt(object, ((Double) value).intValue());
+ field.setInt(object, ((Number) value).intValue());
  return true;
  }
  if (boolean.class.isAssignableFrom(fieldType)) {
@@ -382,11 +382,11 @@ <T> boolean fieldValueForPrimitiveWrappersModified(final Class<?> fieldType, fin
  return true;
  }
  if (Long.class.isAssignableFrom(fieldType)) {
- field.set(object, Long.valueOf(((Double) value).longValue()));
+ field.set(object, ((Number) value).longValue());
  return true;
  }
  if (Integer.class.isAssignableFrom(fieldType)) {
- field.set(object, Integer.valueOf(((Double) value).intValue()));
+ field.set(object, ((Number) value).intValue());
  return true;
  }
  if (Boolean.class.isAssignableFrom(fieldType)) {

src/test/java/org/influxdb/impl/InfluxDBResultMapperTest.java

@@ -151,7 +151,7 @@ public void testParseSeriesAs_testNonNullAndValidValues() {
  Double now = Long.valueOf(System.currentTimeMillis()).doubleValue();
  String uuidAsString = UUID.randomUUID().toString();
 
- // InfluxDB client returns any number as Double.
+ // InfluxDB client returns any number as Double. (with JSON response format, but not with msgpack)
  // See https://github.com/influxdata/influxdb-java/issues/153#issuecomment-259681987
  // for more information.
  List<Object> seriesResult = Arrays.asList(now, uuidAsString,
@@ -201,6 +201,62 @@ Double asDouble(Object obj) {
  return (Double) obj;
  }
 
+ @Test
+ public void testParseSeriesAs_testNonNullAndValidValues_msgpack() {
+ // Given...
+ mapper.cacheMeasurementClass(MyCustomMeasurement.class);
+
+ List<String> columnList = Arrays.asList("time", "uuid",
+ "doubleObject", "longObject", "integerObject",
+ "doublePrimitive", "longPrimitive", "integerPrimitive",
+ "booleanObject", "booleanPrimitive");
+
+ // InfluxDB client returns the time representation as Double.
+ Double now = Long.valueOf(System.currentTimeMillis()).doubleValue();
+ String uuidAsString = UUID.randomUUID().toString();
+
+ // InfluxDB client returns any number as Double. (with JSON response format, but not with msgpack)
+ // See https://github.com/influxdata/influxdb-java/issues/153#issuecomment-259681987
+ // for more information.
+ List<Object> seriesResult = Arrays.asList(now, uuidAsString,
+ new Double("1.01"), Long.valueOf(2), Integer.valueOf(3),
+ new Double("1.01"), Long.valueOf(4), Integer.valueOf(5),
+ Boolean.FALSE, Boolean.TRUE);
+
+ QueryResult.Series series = new QueryResult.Series();
+ series.setColumns(columnList);
+ series.setValues(Arrays.asList(seriesResult));
+
+ //When...
+ List<MyCustomMeasurement> result = new LinkedList<>();
+ mapper.parseSeriesAs(series, MyCustomMeasurement.class, result);
+
+ //Then...
+ MyCustomMeasurement myObject = result.get(0);
+ Assertions.assertEquals(now.longValue(), myObject.time.toEpochMilli(), "field 'time' does not match");
+ Assertions.assertEquals(uuidAsString, myObject.uuid, "field 'uuid' does not match");
+
+ Assertions.assertEquals(asDouble(seriesResult.get(2)), myObject.doubleObject, "field 'doubleObject' does not match");
+ Assertions.assertEquals(Long.valueOf(2), myObject.longObject, "field 'longObject' does not match");
+ Assertions.assertEquals(Integer.valueOf(3), myObject.integerObject, "field 'integerObject' does not match");
+
+ Assertions.assertTrue(
+ Double.compare(asDouble(seriesResult.get(5)).doubleValue(), myObject.doublePrimitive) == 0,
+ "field 'doublePrimitive' does not match");
+
+ Assertions.assertEquals( myObject.longPrimitive, 4, "field 'longPrimitive' does not match");
+ Assertions.assertEquals( myObject.integerPrimitive, 5, "field 'integerPrimitive' does not match");
+
+ Assertions.assertEquals(
+ Boolean.valueOf(String.valueOf(seriesResult.get(8))), myObject.booleanObject,
+ "field 'booleanObject' does not match");
+
+ Assertions.assertEquals(
+ Boolean.valueOf(String.valueOf(seriesResult.get(9))).booleanValue(), myObject.booleanPrimitive,
+ "field 'booleanPrimitive' does not match");
+ }
+
+
  @Test
  public void testFieldValueModified_DateAsISO8601() {
  // Given...
@@ -638,4 +694,4 @@ public String toString() {
  + ", median=" + median + ", min=" + min + ", max=" + max + "]";
  }
  }
-}
+}