Fix exception handling for InfluxDB 1.x

Fixes openhab#16233 Signed-off-by: Jacob Laursen <jacob-github@vindvejr.dk>
jlaur · Jan 7, 2024 · 14ab2ec · 14ab2ec
1 parent c8d2d4b
commit 14ab2ec
Showing 1 changed file with 11 additions and 6 deletions.
diff --git a/.../main/java/org/openhab/persistence/influxdb/internal/influx1/InfluxDB1RepositoryImpl.java b/.../main/java/org/openhab/persistence/influxdb/internal/influx1/InfluxDB1RepositoryImpl.java
@@ -75,12 +75,17 @@ public boolean isConnected() {
 
     @Override
     public boolean connect() {
-        final InfluxDB createdClient = InfluxDBFactory.connect(configuration.getUrl(), configuration.getUser(),
-                configuration.getPassword());
-        createdClient.setDatabase(configuration.getDatabaseName());
-        createdClient.setRetentionPolicy(configuration.getRetentionPolicy());
-        createdClient.enableBatch(200, 100, TimeUnit.MILLISECONDS);
-        this.client = createdClient;
+        try {
+            final InfluxDB createdClient = InfluxDBFactory.connect(configuration.getUrl(), configuration.getUser(),
+                    configuration.getPassword());
+            createdClient.setDatabase(configuration.getDatabaseName());
+            createdClient.setRetentionPolicy(configuration.getRetentionPolicy());
+            createdClient.enableBatch(200, 100, TimeUnit.MILLISECONDS);
+            this.client = createdClient;
+        } catch (InfluxException | InfluxDBException e) {
+            logger.debug("Connection failed", e);
+            return false;
+        }
         return checkConnectionStatus();
     }