[influxdb] Fixes InfluxDB 2.0 issues #9247 and #8960 (#9258)

Signed-off-by: Joan Pujol <joanpujol@gmail.com>

diff --git a/bundles/org.openhab.persistence.influxdb/src/main/java/org/openhab/persistence/influxdb/internal/influx2/Influx2FilterCriteriaQueryCreatorImpl.java b/bundles/org.openhab.persistence.influxdb/src/main/java/org/openhab/persistence/influxdb/internal/influx2/Influx2FilterCriteriaQueryCreatorImpl.java
index 03b81a5940deb61ad88b42f4722c40792537f935..103ed646089a38359a024567ee04e1236adcffad 100644 (file)
--- a/bundles/org.openhab.persistence.influxdb/src/main/java/org/openhab/persistence/influxdb/internal/influx2/Influx2FilterCriteriaQueryCreatorImpl.java
+++ b/bundles/org.openhab.persistence.influxdb/src/main/java/org/openhab/persistence/influxdb/internal/influx2/Influx2FilterCriteriaQueryCreatorImpl.java
@@ -38,18 +38,16 @@ public class Influx2FilterCriteriaQueryCreatorImpl implements FilterCriteriaQuer
     public String createQuery(FilterCriteria criteria, String retentionPolicy) {
         Flux flux = Flux.from(retentionPolicy);
 
-        if (criteria.getBeginDate() != null || criteria.getEndDate() != null) {
-            RangeFlux range = flux.range();
-            if (criteria.getBeginDate() != null) {
-                range = range.withStart(criteria.getBeginDate().toInstant());
-            }
-            if (criteria.getEndDate() != null) {
-                range = range.withStop(criteria.getEndDate().toInstant());
-            }
-            flux = range;
+        RangeFlux range = flux.range();
+        if (criteria.getBeginDate() != null) {
+            range = range.withStart(criteria.getBeginDate().toInstant());
         } else {
-            flux = flux.range(-100L, ChronoUnit.YEARS); // Flux needs a mandatory range
+            range = flux.range(-100L, ChronoUnit.YEARS); // Flux needs a mandatory start range
         }
+        if (criteria.getEndDate() != null) {
+            range = range.withStop(criteria.getEndDate().toInstant());
+        }
+        flux = range;
 
         if (criteria.getItemName() != null) {
             flux = flux.filter(measurement().equal(criteria.getItemName()));

diff --git a/bundles/org.openhab.persistence.influxdb/src/main/resources/OH-INF/config/config.xml b/bundles/org.openhab.persistence.influxdb/src/main/resources/OH-INF/config/config.xml
index 3ee4fd5dd8038078d37179f0404315da3b7fc763..5c44cbc882f892a50dd99d6264343333b5cc51a5 100644 (file)
--- a/bundles/org.openhab.persistence.influxdb/src/main/resources/OH-INF/config/config.xml
+++ b/bundles/org.openhab.persistence.influxdb/src/main/resources/OH-INF/config/config.xml
@@ -69,7 +69,7 @@
                        <label>Retention Policy / Bucket</label>
                        <description>The name of the retention policy (Influx DB 1.0) or bucket (InfluxDB 2.0) to write data
                        </description>
-                       <default>openhab</default>
+                       <default>autogen</default>
                </parameter>
 
                <parameter name="replaceUnderscore" type="boolean" required="true" groupName="misc">