Java读取InfluxDB数据库的方法详解

2025-01-14 04:50

本文主要是介绍Java读取InfluxDB数据库的方法详解,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

《Java读取InfluxDB数据库的方法详解》本文介绍基于Java语言,读取InfluxDB数据库的方法,包括读取InfluxDB的所有数据库,以及指定数据库中的measurement、field、...

首先,创建一个Java项目,用于撰写代码。

接下来,配置所需要的依赖;这里我们就选择可用于与InfluxDB数据库进行交互的、官方支持的Java客户端库influxdb-java。因为我是基于Maven来配置依赖的,所以就在项目的pom.XML文件中China编程,添加如下的内容。

<dependencies>
    <dependency>
        <groupId>org.influxdb</groupId>
        <artifactId>influxdb-java</artifactId>
        <version>2.8</version>
    </dependency>
</dependencies>

添加上述代码后,如下图所示。

Java读取InfluxDB数据库的方法详解

刚刚增添完毕上述代码时,pom.xml文件中influxdb-java依赖会飘红,我们就刷新一下Maven,让他下载对应的依赖;如下图所示。

Java读取InfluxDB数据库的方法详解

随后,可以在Dependencies中看到已经配置好了所需的influxdb-java依赖,如下图所示。

Java读取InfluxDB数据库的方法详解

接下来,即可开始撰写代码。这里的这个代码仅仅是一个非常简单的示例,只是我当初学习用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 Quephpry("SHOW MEASUREMENTS 编程China编程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: innerLChina编程ist) {
                System.out.println(object);
            }
        }
        System.out.println();
    }

    // Show tag values
    private static void showTaphpgValues(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的资料请关注China编程(www.chinasem.cn)其它相关文章!

这篇关于Java读取InfluxDB数据库的方法详解的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1153053

相关文章

C#从XmlDocument提取完整字符串的方法

《C#从XmlDocument提取完整字符串的方法》文章介绍了两种生成格式化XML字符串的方法,方法一使用`XmlDocument`的`OuterXml`属性,但输出的XML字符串不带格式,可读性差,... 方法1:通过XMLDocument的OuterXml属性,见XmlDocument类该方法获得的xm

Oracle数据库如何切换登录用户(system和sys)

《Oracle数据库如何切换登录用户(system和sys)》文章介绍了如何使用SQL*Plus工具登录Oracle数据库的system用户,包括打开登录入口、输入用户名和口令、以及切换到sys用户的... 目录打开登录入口登录system用户总结打开登录入口win+R打开运行对话框,输php入:sqlp

C#多线程编程中导致死锁的常见陷阱和避免方法

《C#多线程编程中导致死锁的常见陷阱和避免方法》在C#多线程编程中,死锁(Deadlock)是一种常见的、令人头疼的错误,死锁通常发生在多个线程试图获取多个资源的锁时,导致相互等待对方释放资源,最终形... 目录引言1. 什么是死锁?死锁的典型条件:2. 导致死锁的常见原因2.1 锁的顺序问题错误示例:不同

深入解析Spring TransactionTemplate 高级用法(示例代码)

《深入解析SpringTransactionTemplate高级用法(示例代码)》TransactionTemplate是Spring框架中一个强大的工具,它允许开发者以编程方式控制事务,通过... 目录1. TransactionTemplate 的核心概念2. 核心接口和类3. TransactionT

数据库使用之union、union all、各种join的用法区别解析

《数据库使用之union、unionall、各种join的用法区别解析》:本文主要介绍SQL中的Union和UnionAll的区别,包括去重与否以及使用时的注意事项,还详细解释了Join关键字,... 目录一、Union 和Union All1、区别:2、注意点:3、具体举例二、Join关键字的区别&php

Java实现Elasticsearch查询当前索引全部数据的完整代码

《Java实现Elasticsearch查询当前索引全部数据的完整代码》:本文主要介绍如何在Java中实现查询Elasticsearch索引中指定条件下的全部数据,通过设置滚动查询参数(scrol... 目录需求背景通常情况Java 实现查询 Elasticsearch 全部数据写在最后需求背景通常情况下

Spring Boot 整合 ShedLock 处理定时任务重复执行的问题小结

《SpringBoot整合ShedLock处理定时任务重复执行的问题小结》ShedLock是解决分布式系统中定时任务重复执行问题的Java库,通过在数据库中加锁,确保只有一个节点在指定时间执行... 目录前言什么是 ShedLock?ShedLock 的工作原理:定时任务重复执行China编程的问题使用 Shed

一文详解Java Condition的await和signal等待通知机制

《一文详解JavaCondition的await和signal等待通知机制》这篇文章主要为大家详细介绍了JavaCondition的await和signal等待通知机制的相关知识,文中的示例代码讲... 目录1. Condition的核心方法2. 使用场景与优势3. 使用流程与规范基本模板生产者-消费者示例

开启mysql的binlog日志步骤详解

《开启mysql的binlog日志步骤详解》:本文主要介绍MySQL5.7版本中二进制日志(bin_log)的配置和使用,文中通过图文及代码介绍的非常详细,需要的朋友可以参考下... 目录1.查看是否开启bin_log2.数据库会把日志放进logs目录中3.查看log日志总结 mysql版本5.71.查看

查询Oracle数据库表是否被锁的实现方式

《查询Oracle数据库表是否被锁的实现方式》本文介绍了查询Oracle数据库表是否被锁的方法,包括查询锁表的会话、人员信息,根据object_id查询表名,以及根据会话ID查询和停止本地进程,同时,... 目录查询oracle数据库表是否被锁1、查询锁表的会话、人员等信息2、根据 object_id查询被