JAVA操作InfluxDB

package com.example.influxdb;
 
import java.util.concurrent.TimeUnit;
 
import org.influxdb.InfluxDB;
import org.influxdb.InfluxDBFactory;
import org.influxdb.dto.Point;
import org.influxdb.dto.Query;
 
public class InfluxDBExample {
 
    private String influxDBUrl = "http://localhost:8086";
    private String database = "mydb";
    private String measurement = "mymeasurement";
 
    public void writeData() {
        InfluxDB influxDB = InfluxDBFactory.connect(influxDBUrl);
        influxDB.createDatabase(database);
        influxDB.write(database, "", Point.measurement(measurement)
                .tag("tag1", "value1")
                .addField("field1", "value1")
                .addField("field2", 1)
                .time(System.currentTimeMillis(), TimeUnit.MILLISECONDS)
                .build());
        influxDB.close();
    }
 
    public void queryData() {
        InfluxDB influxDB = InfluxDBFactory.connect(influxDBUrl);
        String query = String.format("SELECT * FROM %s", measurement);
        Query querySpec = new Query(query, database);
        influxDB.query(querySpec);
        influxDB.close();
    }
 
    public static void main(String[] args) {
        InfluxDBExample example = new InfluxDBExample();
        example.writeData();
        example.queryData();
    }
}

这段代码展示了如何使用InfluxDB的Java API来写入数据和查询数据。首先，它创建了一个连接到InfluxDB实例的InfluxDB对象，然后创建了一个名为mydb的数据库，并向名为mymeasurement的测量中写入了一个带有标签和字段的点。接着，它执行了一个简单的查询来检索刚刚写入的数据。这个例子是基于InfluxDB 1.x版本的API，但在2.x版本中，API有所不同，需要使用InfluxDBClient类。