IoTDB 入门教程 实战篇③——Java示例（开源）

一、前文

   IoTDB入门教程——导读
    本文详细阐述了怎样通过一个Java项目乐成连接到IoTDB时序数据库，进而展示了怎样向该数据库高效地写入数据以及执行准确的数据查询操纵。
    此示例旨在为读者提供一个清晰、实用的引导，以便他们在自己的项目中实现与IoTDB的交互。
    此示例开源地点：小康师兄/IoTDB示例
  二、新建Java项目

• 文件—>新建—>项目
  
  
  
  
• 选择Maven
  
  
  
  
• 项目名称：Java-Example
  
  
  
  

三、运行Java项目

• 添加com.weijian.iotdb.Main.java
  
  
  
  
• 运行/调试设置，选择应用程序
  
  
  
  
• 构建并运行的主类Main
  
  
  
  
• 点击运行
  
  
  
  

四、Maven添加依靠

• 添加依靠dependencies—>org.apache.iotdb
  

1. <?xml version="1.0" encoding="UTF-8"?>
2. <project xmlns="http://maven.apache.org/POM/4.0.0"
3.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
5.     <modelVersion>4.0.0</modelVersion>
7.     <groupId>com.weijian.iotdb</groupId>
8.     <artifactId>Java-Example</artifactId>
9.     <version>1.0-SNAPSHOT</version>
11.     <properties>
12.         <maven.compiler.source>8</maven.compiler.source>
13.         <maven.compiler.target>8</maven.compiler.target>
14.     </properties>
16.     <dependencies>
17.         <dependency>
18.             <groupId>org.apache.iotdb</groupId>
19.             <artifactId>iotdb-session</artifactId>
20.             <version>1.3.2</version>
21.         </dependency>
22.         <dependency>
23.             <groupId>org.apache.iotdb</groupId>
24.             <artifactId>node-commons</artifactId>
25.             <version>1.3.2</version>
26.         </dependency>
27.     </dependencies>
28. </project>

复制代码

五、示例源码

   此示例开源地点：小康师兄/IoTDB示例
    https://gitee.com/weijian.kang/IoTDB-Example/tree/master/Java-Example
  示例相对简单，程序流程重要有3步骤

• 初始化与连接
  
• 写入数据
  
• 查询数据
  

1. package com.weijian.iotdb;
3. import org.apache.iotdb.isession.SessionDataSet;
4. import org.apache.iotdb.isession.util.Version;
5. import org.apache.iotdb.rpc.IoTDBConnectionException;
6. import org.apache.iotdb.rpc.StatementExecutionException;
7. import org.apache.iotdb.session.Session;
8. import org.apache.iotdb.tsfile.file.metadata.enums.TSDataType;
10. import java.util.ArrayList;
11. import java.util.List;
13. public class Main {
15.     public static void main(String[] args)
16.             throws IoTDBConnectionException, StatementExecutionException {
18.         System.out.println("Hello IoTDB Java Example");
20.         // 初始化与连接
21.         Session session = new Session.Builder()
22.                 .host("xx.xx.xx.xx")
23.                 .port(6667)
24.                 .username("root")
25.                 .password("root")
26.                 .version(Version.V_1_0)
27.                 .build();
28.         // 开启Session RPC不压缩
29.         session.open(false);
31.         // 写入数据
32.         List<Object> values = new ArrayList<>();
33.         values.add(88);
34.         insertRecord(session, values);
36.         // 查询数据
37.         queryRecord(session);
38.         
39.         // 关闭连接
40.         session.close();
41.     }
43.     private static void insertRecord(Session session, List<Object> values) throws IoTDBConnectionException, StatementExecutionException {
44.         List<String> measurements = new ArrayList<>();
45.         List<TSDataType> types = new ArrayList<>();
46.         measurements.add("status");
47.         types.add(TSDataType.INT32);
48.         session.insertRecord("root.test.test", System.currentTimeMillis(), measurements, types, values);
49.         System.out.println("————————————————写入数据成功————————————————");
50.     }
52.     private static void queryRecord(Session session) throws IoTDBConnectionException, StatementExecutionException {
53.         System.out.println("————————————————查询数据开始————————————————");
54.         try (SessionDataSet dataSet = session.executeQueryStatement("select status from root.test.test")) {
55.             System.out.println(dataSet.getColumnNames());
56.             dataSet.setFetchSize(1024); // default is 10000
57.             while (dataSet.hasNext()) {
58.                 System.out.println(dataSet.next());
59.             }
60.         }
61.         System.out.println("————————————————查询数据结束————————————————");
62.     }
63. }

复制代码

• 运行截图
  
  
  
  

七、查询数据

• 再次查询数据，看看是数据是否存入数据库
  
• 查询发现，value(88)的数据已经存入数据库
  

1. IoTDB> select status from root.test.test
2. +-----------------------------+---------------------+
3. |                         Time|root.test.test.status|
4. +-----------------------------+---------------------+
5. |1970-01-21T06:21:09.846+08:00|                 55.0|
6. |2024-07-21T08:34:04.378+08:00|                  1.0|
7. |2024-07-21T08:34:21.513+08:00|                  2.0|
8. |2024-07-21T08:34:23.284+08:00|                  3.0|
9. |2024-07-21T08:34:25.675+08:00|                 11.0|
10. |2024-07-21T08:34:28.155+08:00|                 22.0|
11. |2024-07-21T08:34:30.341+08:00|                 33.0|
12. |2024-07-27T16:44:06.000+08:00|                 66.0|
13. |2024-07-28T19:57:38.855+08:00|                 88.0|
14. |2024-07-28T20:11:41.161+08:00|                 88.0|
15. |2024-07-28T20:12:49.883+08:00|                 88.0|
16. +-----------------------------+---------------------+
17. Total line number = 11
18. It costs 0.073s

复制代码

八、参考

Java原生接口| IoTDB Website
觉得好，就一键三连呗（点赞+收藏+关注）

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。