本文介绍基于Java语言，读取InfluxDB数据库的方法，包括读取InfluxDB的所有数据库，以及指定数据库中的measurement、field、tag等。

  首先，创建一个Java项目，用于撰写代码。如果大家是基于IDEA来创建项目，则可以参考文章IDEA新建项目并撰写Java代码的方法（https://blog.csdn.net/zhebushibiaoshifu/article/details/140302869）中提到的方法。

  接下来，配置所需要的依赖；这里我们就选择可用于与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 keysprivate 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 valuesprivate 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 keysprivate 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 dataprivate 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，所以是直接打印的；在实际应用中，大家可以修改一下代码，更优雅地格式化输出。

  至此，大功告成。

欢迎关注：疯狂学习GIS