QueryResult to Object mapper added

README.md

@@ -137,7 +137,7 @@ public void write(final int udpPort, final Point point);
 note: make sure write content's total size should not > UDP protocol's limit(64K), or you should use http instead of udp.
 
 
-#### chunking support (version 2.6+ required, unreleased):
+#### Chunking support (version 2.6+ required):
 
 influxdb-java client now supports influxdb chunking. The following example uses a chunkSize of 20 and invokes the specified Consumer (e.g. System.out.println) for each received QueryResult
 ```java
@@ -146,6 +146,74 @@ influxDB.query(query, 20, queryResult -> System.out.println(queryResult));
 ```
 
 
+#### QueryResult mapper to POJO (version 2.7+ required, unreleased):
+
+An alternative way to handle the QueryResult object is now available.
+Supposing that you have a measurement _CPU_:
+```
+> INSERT cpu,host=serverA,region=us_west idle=0.64,happydevop=false,uptimesecs=123456789i
+>
+> select * from cpu
+name: cpu
+time                           happydevop host    idle region  uptimesecs
+----                           ---------- ----    ---- ------  ----------
+2017-06-20T15:32:46.202829088Z false      serverA 0.64 us_west 123456789
+```
+And the following tag keys:
+```
+> show tag keys from cpu
+name: cpu
+tagKey
+------
+host
+region
+```
+
+1. Create a POJO to represent your measurement. For example:
+```Java
+public class Cpu {
+    private Instant time;
+    private String hostname;
+    private String region;
+    private Double idle;
+    private Boolean happydevop;
+    private Long uptimeSecs;
+    // getters (and setters if you need)
+}
+```
+2. Add @Measurement and @Column annotations:
+```Java
+@Measurement(name = "cpu")
+public class Cpu {
+    @Column(name = "time")
+    private Instant time;
+    @Column(name = "host", tag = true)
+    private String hostname;
+    @Column(name = "region", tag = true)
+    private String region;
+    @Column(name = "idle")
+    private Double idle;
+    @Column(name = "happydevop")
+    private Boolean happydevop;
+    @Column(name = "uptimesecs")
+    private Long uptimeSecs;
+    // getters (and setters if you need)
+}
+```
+3. Call _InfluxDBResultMapper.toPOJO(...)_ to map the QueryResult to your POJO:
+```
+InfluxDB influxDB = InfluxDBFactory.connect("http://localhost:8086", "root", "root");
+String dbName = "myTimeseries";
+QueryResult queryResult = influxDB.query(new Query("SELECT * FROM cpu", dbName));
+
+InfluxResultMapper resultMapper = new InfluxResultMapper(); // thread-safe - can be reused
+List<Cpu> cpuList = resultMapper.toPOJO(queryResult, Cpu.class);
+```
+**QueryResult mapper limitations**
+- If your InfluxDB query contains multiple SELECT clauses, you will have to call InfluxResultMapper#toPOJO() multiple times to map every measurement returned by QueryResult to the respective POJO;
+- If your InfluxDB query contains multiple SELECT clauses **for the same measurement**, InfluxResultMapper will process all results because there is no way to distinguish which one should be mapped to your POJO. It may result in an invalid collection being returned;
+
+
 ### Other Usages:
 For additional usage examples have a look at [InfluxDBTest.java](https://github.com/influxdb/influxdb-java/blob/master/src/test/java/org/influxdb/InfluxDBTest.java "InfluxDBTest.java")
 

src/main/java/org/influxdb/InfluxDBMapperException.java

@@ -0,0 +1,41 @@
+/*
+ * The MIT License (MIT)
+ *
+ * Copyright (c) 2017 azeti Networks AG (<info@azeti.net>)
+ *
+ * Permission is hereby granted, free of charge, to any person obtaining a copy of this software and
+ * associated documentation files (the "Software"), to deal in the Software without restriction,
+ * including without limitation the rights to use, copy, modify, merge, publish, distribute,
+ * sublicense, and/or sell copies of the Software, and to permit persons to whom the Software is
+ * furnished to do so, subject to the following conditions:
+ *
+ * The above copyright notice and this permission notice shall be included in all copies or
+ * substantial portions of the Software.
+ *
+ * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT
+ * NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
+ * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM,
+ * DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+ * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
+ */
+package org.influxdb;
+
+/**
+ * @author fmachado
+ */
+public class InfluxDBMapperException extends RuntimeException {
+
+  private static final long serialVersionUID = -7328402653918756407L;
+
+  public InfluxDBMapperException(final String message, final Throwable cause) {
+    super(message, cause);
+  }
+
+  public InfluxDBMapperException(final String message) {
+    super(message);
+  }
+
+  public InfluxDBMapperException(final Throwable cause) {
+    super(cause);
+  }
+}

src/main/java/org/influxdb/annotation/Column.java

@@ -0,0 +1,38 @@
+/*
+ * The MIT License (MIT)
+ *
+ * Copyright (c) 2017 azeti Networks AG (<info@azeti.net>)
+ *
+ * Permission is hereby granted, free of charge, to any person obtaining a copy of this software and
+ * associated documentation files (the "Software"), to deal in the Software without restriction,
+ * including without limitation the rights to use, copy, modify, merge, publish, distribute,
+ * sublicense, and/or sell copies of the Software, and to permit persons to whom the Software is
+ * furnished to do so, subject to the following conditions:
+ *
+ * The above copyright notice and this permission notice shall be included in all copies or
+ * substantial portions of the Software.
+ *
+ * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT
+ * NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
+ * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM,
+ * DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+ * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
+ */
+package org.influxdb.annotation;
+
+import java.lang.annotation.ElementType;
+import java.lang.annotation.Retention;
+import java.lang.annotation.RetentionPolicy;
+import java.lang.annotation.Target;
+
+/**
+ * @author fmachado
+ */
+@Retention(RetentionPolicy.RUNTIME)
+@Target(ElementType.FIELD)
+public @interface Column {
+
+  String name();
+
+  boolean tag() default false;
+}

src/main/java/org/influxdb/annotation/Measurement.java

@@ -0,0 +1,39 @@
+/*
+ * The MIT License (MIT)
+ *
+ * Copyright (c) 2017 azeti Networks AG (<info@azeti.net>)
+ *
+ * Permission is hereby granted, free of charge, to any person obtaining a copy of this software and
+ * associated documentation files (the "Software"), to deal in the Software without restriction,
+ * including without limitation the rights to use, copy, modify, merge, publish, distribute,
+ * sublicense, and/or sell copies of the Software, and to permit persons to whom the Software is
+ * furnished to do so, subject to the following conditions:
+ *
+ * The above copyright notice and this permission notice shall be included in all copies or
+ * substantial portions of the Software.
+ *
+ * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT
+ * NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
+ * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM,
+ * DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+ * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
+ */
+package org.influxdb.annotation;
+
+import java.lang.annotation.ElementType;
+import java.lang.annotation.Retention;
+import java.lang.annotation.RetentionPolicy;
+import java.lang.annotation.Target;
+import java.util.concurrent.TimeUnit;
+
+/**
+ * @author fmachado
+ */
+@Retention(RetentionPolicy.RUNTIME)
+@Target(ElementType.TYPE)
+public @interface Measurement {
+
+  String name();
+
+  TimeUnit timeUnit() default TimeUnit.MILLISECONDS;
+}