我要评论首先，创建一个java项目，用于撰写代码。
接下来，配置所需要的依赖；这里我们就选择可用于与influxdb数据库进行交互的、官方支持的java客户端库influxdb-java。因为我是基于maven来配置依赖的，所以就在项目的pom.xml文件中，添加如下的内容。
<dependencies>
<dependency>
<groupid>org.influxdb</groupid>
<artifactid>influxdb-java</artifactid>
<version>2.8</version>
</dependency>
</dependencies>
添加上述代码后，如下图所示。
刚刚增添完毕上述代码时，pom.xml文件中influxdb-java依赖会飘红，我们就刷新一下maven，让他下载对应的依赖；如下图所示。
随后，可以在dependencies中看到已经配置好了所需的influxdb-java依赖，如下图所示。
接下来，即可开始撰写代码。这里的这个代码仅仅是一个非常简单的示例，只是我当初学习用java语言读取influxdb数据库用的；大家可以在这个基础上，按照自己的需求进一步丰富代码逻辑。完整代码如下所示。
import org.influxdb.influxdb;
import org.influxdb.influxdbfactory;
import org.influxdb.dto.query;
import org.influxdb.dto.queryresult;
import org.jetbrains.annotations.notnull;
import java.util.list;
import java.util.scanner;
public class main {
private static final string url = "http://127.0.0.1:8086";
private static final string username = "root";
private static final string password = "";
public static void main(string[] args) {
influxdb influxdb = influxdbfactory.connect(url, username, password);
showdatabases(influxdb);
showmeasurements(influxdb);
showdata(influxdb);
}
// show database(s)
private static void showdatabases(influxdb influxdb) {
queryresult queryresult = influxdb.query(new query("show databases"));
queryresult.series series = queryresult.getresults().get(0).getseries().get(0);
list<list<object>> databaselist = series.getvalues();
system.out.println("database(s) is(are):");
for (list<object> innerlist: databaselist) {
for (object object: innerlist) {
system.out.println(object);
}
}
system.out.println();
}
// show measurement(s)
private static void showmeasurements(influxdb influxdb) {
scanner scanner = new scanner(system.in);
system.out.print("please enter the database name: ");
string databasename = scanner.nextline();
try {
list<list<object>> measurementslist = influxdb.query(new query("show measurements on " + databasename)).getresults().get(0).getseries().get(0).getvalues();
system.out.println("measurement(s) for " + databasename + " is(are):");
for (list<object> innerlist: measurementslist) {
for (object object: innerlist) {
system.out.println(object);
}
}
system.out.println();
showtagkeys(influxdb, databasename);
showtagvalues(influxdb, databasename);
showfieldkeys(influxdb, databasename);
} catch (exception e) {
system.out.println("measurement(s) for " + databasename + " is empty!");
return;
}
}
// show tag keys
private static void showtagkeys(influxdb influxdb, string databasename) {
list<list<object>> tagkeyslist = influxdb.query(new query("show tag keys on " + databasename)).getresults().get(0).getseries().get(0).getvalues();
system.out.println("tag key(s) for " + databasename + " is(are):");
for (list<object> innerlist: tagkeyslist) {
for (object object: innerlist) {
system.out.println(object);
}
}
system.out.println();
}
// show tag values
private static void showtagvalues(influxdb influxdb, string databasename) {
scanner scanner = new scanner(system.in);
system.out.print("please enter the tag key name: ");
string tagkey = scanner.nextline();
list<list<object>> tagvalueslist = influxdb.query(new query("show tag values on " + databasename + " with key = " + tagkey)).getresults().get(0).getseries().get(0).getvalues();
system.out.println("tag value(s) is(are):");
for (list<object> innerlist: tagvalueslist) {
system.out.println(innerlist.get(0) + ": " + innerlist.get(1));
}
system.out.println();
}
// show field keys
private static void showfieldkeys(influxdb influxdb, string databasename) {
list<list<object>> fieldkeyslist = influxdb.query(new query("show field keys on " + databasename)).getresults().get(0).getseries().get(0).getvalues();
system.out.println("field key(s) and type(s) are:");
for (list<object> innerlist: fieldkeyslist) {
system.out.println(innerlist.get(0) + ": " + innerlist.get(1));
}
system.out.println();
}
// show data
private static void showdata(@notnull influxdb influxdb) {
scanner scanner = new scanner(system.in);
system.out.print("please enter the database name: ");
string databasename = scanner.nextline();
system.out.print("please enter the measurements name: ");
string measurementname = scanner.nextline();
influxdb.setdatabase(databasename);
queryresult dataresult = influxdb.query(new query("select * from " + measurementname));
system.out.println(dataresult);
}
}
代码整体思路也很简单，这里再简单介绍一下代码的流程。
首先，需要连接到influxdb数据库。在这一部分，通过influxdbfactory.connect创建了一个本地运行的influxdb实例的连接，使用默认的url （也就是http://127.0.0.1:8086），并配置用户名和密码。
随后，showdatabases方法执行了show databases，用以查询并打印出influxdb实例所有数据库的名字。从这一部分的代码开始，后续所有代码在操作数据库方面的逻辑都是很类似的——通过模拟并执行influxdb的数据库语句，来实现各项操作。
接下来，showmeasurements方法可以让我们输入一个数据库名，然后执行show measurements查询来获取该数据库中所有measurement的名称，并打印出来。如果measurement为空，则会输出相应的提示信息。
其次，showtagkeys方法用于列出指定数据库的所有tag key，其后的showtagvalues方法则可以让我们输入一个tag key名，随后查询并打印出该tag key对应的所有tag value。
紧接着，showfieldkeys方法用于列出指定数据库中所有的field key。
最后，showdata方法让我们输入一个数据库和measurement的名称，随后查询、获取该measurement下的所有数据，并将结果直接打印出来。当然，我这里当初只是为了验证是否读取到了measurement，所以是直接打印的；在实际应用中，大家可以修改一下代码，更优雅地格式化输出。
至此，大功告成。
以上就是java读取influxdb数据库的方法详解的详细内容，更多关于java读取influxdb的资料请关注代码网其它相关文章！
发表评论