From 49bd72038d6bae30a34c096f2cba8c5b11dbad8c Mon Sep 17 00:00:00 2001
From: zhang <zc857179121@qq.com>
Date: 星期五, 06 二月 2026 08:16:05 +0800
Subject: [PATCH] 1
---
component/component-Influxdb/src/main/java/com/zy/component/influxdb/service/InfluxDBService.java | 24 ++++++++++++------------
1 files changed, 12 insertions(+), 12 deletions(-)
diff --git a/component/component-Influxdb/src/main/java/com/zy/component/influxdb/service/InfluxDBService.java b/component/component-Influxdb/src/main/java/com/zy/component/influxdb/service/InfluxDBService.java
index c3f5ad4..32e71c6 100644
--- a/component/component-Influxdb/src/main/java/com/zy/component/influxdb/service/InfluxDBService.java
+++ b/component/component-Influxdb/src/main/java/com/zy/component/influxdb/service/InfluxDBService.java
@@ -9,7 +9,6 @@
import org.springframework.stereotype.Service;
import java.time.Instant;
-import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;
@@ -55,18 +54,19 @@
public List<Map<String, Object>> queryData(String sql) {
try {
// 鎵ц鏌ヨ
- Stream<Object[]> query = influxDBClient.query(sql);
- logger.info("鏌ヨ鏁版嵁锛歿}", query);
+ Stream<Map<String, Object>> mapStream = influxDBClient.queryRows(sql);
+ logger.info("鏌ヨ鏁版嵁锛歿}", mapStream.collect(Collectors.toList()));
+ //query.forEach(row -> System.out.printf("| %-8s | %-8s | %-30s |%n", row[1], row[2], row[0]));
// 杞崲涓� Map 鍒楄〃锛堜究浜庡悗缁鐞嗭級
- List<Map<String, Object>> collect = query.map(record -> {
- Map<String, Object> map = new LinkedHashMap<>();
- for (int i = 0; i < record.length; i += 2) {
- map.put((String) record[i], record[i + 1]);
- }
- return map;
- })
- .collect(Collectors.toList());
- return collect;
+// List<Map<String, Object>> collect = query.map(record -> {
+// Map<String, Object> map = new LinkedHashMap<>();
+// for (int i = 0; i < record.length; i += 2) {
+// map.put((String) record[i], record[i + 1]);
+// }
+// return map;
+// })
+// .collect(Collectors.toList());
+ return null;
} catch (Exception e) {
logger.error("Failed to query data from the database.");
e.printStackTrace();
--
Gitblit v1.9.1