Assign database

dlmcpaul · Dec 18, 2022 · 5283629 · 5283629
1 parent b1d1b74
commit 5283629
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/src/main/java/com/hz/configuration/InfluxDBConfig.java b/src/main/java/com/hz/configuration/InfluxDBConfig.java
@@ -73,12 +73,12 @@ public String get(String k) {
 	public InfluxDB destinationInfluxDB() {
 		log.info("Writing solar stats to influx database at {}", config.getInfluxdbResource().getUrl());
 
-		InfluxDB database = null;
+		InfluxDB database;
 
 		if (config.getInfluxdbResource().getUser() == null || config.getInfluxdbResource().getUser().isEmpty()) {
-			InfluxDBFactory.connect(config.getInfluxdbResource().getUrl());
+			database = InfluxDBFactory.connect(config.getInfluxdbResource().getUrl());
 		} else {
-			InfluxDBFactory.connect(config.getInfluxdbResource().getUrl(), config.getInfluxdbResource().getUser(), config.getInfluxdbResource().getPassword());
+			database = InfluxDBFactory.connect(config.getInfluxdbResource().getUrl(), config.getInfluxdbResource().getUser(), config.getInfluxdbResource().getPassword());
 		}
 		database.query(new Query("CREATE DATABASE \"" + DATABASE_NAME + "\" WITH DURATION 365d", DATABASE_NAME));