Java中集成influxdb2版本的select查询

在Java中集成InfluxDB 2.x版本，首先需要安装InfluxDB客户端库，如官方推荐的`io.influxdb.client`。这里是一个基本示例，展示如何使用它进行SELECT查询：

import io.influxdb.InfluxDB;
import io.influxdb.client.InfluxDBClient;
import io.influxdb.client.InfluxDBClientException;
import io.influxdb.query ResultSet;

public class InfluxDBSelectExample {

    private static final String URL = "http://localhost:8086";
    private static final String PASSWORD = "your_password";
    private static final String DATABASE = "your_database";

    public static void main(String[] args) {
        try (InfluxDBClient influxDBClient = InfluxDB.create(URL, PASSWORD)) {
            // 创建一个查询实例
            Flux<ResultSet> results = influxDBClient.query(
                    Flux Point.from("cpu_load")
                            .tag("host", "server1")
                            .field("value", 0.75f)
                            .time(Instant.now().minus(Duration.ofSeconds(60)))
                            .build()
                    .into("my_measurement"));

            // 运行查询并打印结果
            results.subscribe(results -> {
                for (ResultSet resultSet : results) {
                    resultSet.forEach(row -> {
                        System.out.printf("%s %s=%f%n", row.getTimestamp(), row.getTags().get("host"), row.getMeasurement().getFloatField("value"));
                    });
                }
            });

        } catch (InfluxDBClientException e) {
            e.printStackTrace();
        }
    }
}

这个示例中，我们创建了一个InfluxDBClient实例，然后执行了一个查询，选择在过去60秒内的`cpu_load`测量值，标签为`host=server1`。