spring boot使用IoTDB的两种方式

InfluxDB和IotDB介绍与性能对比

Linux MacBook Docker安装IoTDB及使用

方式一: session方式访问IotDB (推荐使用,自带连接池)

maven依赖iotdb-session

1. <dependency>
2. <groupId>org.apache.iotdb</groupId>
3. <artifactId>iotdb-session</artifactId>
4. <version>0.11.2</version>
5. </dependency>

springboot IotDB配置信息session方式

1. spring:
2. iotdb:
3. username: root
4. password: root
5. ip:192.168.0.5
6. port:6667
7. maxSize:100

调用session方式

1. @Autowired
2. privateIotDBSessionConfig iotDBSessionConfig;
4. ......
6. StringBuffer tableName =newStringBuffer();
7. tableName.append("root").append(".").append("test").append("deviceid");
9. long currentTime =System.currentTimeMillis();
11. List<String> iotMeasurements =newArrayList<>();
12. iotMeasurements.add("aaa");
13. iotMeasurements.add("bbb");
15. List<String> iotValues =newArrayList<>();
16. iotValues.add("123");
17. iotValues.add("abide");
19. iotDBSessionConfig.insertRecord(tableName.toString(), currentTime, iotMeasurements, iotValues);

方式二: jdbc方式访问IotDB (自己实现连接池)

maven依赖iotdb-jdbc

1. <dependency>
2. <groupId>org.apache.iotdb</groupId>
3. <artifactId>iotdb-jdbc</artifactId>
4. <version>0.11.2</version>
5. </dependency>
7. <!-- alibaba的druid数据库连接池 -->
8. <dependency>
9. <groupId>com.alibaba</groupId>
10. <artifactId>druid-spring-boot-starter</artifactId>
11. </dependency>

spring boot IotDB配置信息jdbc

1. spring:
2. iotdb:
3. username: root
4. password: root
5. driver-name: org.apache.iotdb.jdbc.IoTDBDriver
6. url: jdbc:iotdb://192.168.0.5:6667/
7. initial-size:5
8. min-idle:10
9. max-active:50
10. max-wait:60000
11. remove-abandoned:true
12. remove-abandoned-timeout:30
13. time-between-eviction-runs-millis:60000
14. min-evictable-idle-time-millis:300000
15. test-while-idle:false
16. test-on-borrow:false
17. test-on-return:false

调用jdbc方式

1. @Autowired
2. privateIotDBConfig iotDBConfig;
4. ......
5. StringBuffer tableName =newStringBuffer();
6. tableName.append("root").append(".").append("test").append("deviceid");
8. long currentTime =System.currentTimeMillis();
10. List<String> iotMeasurements =newArrayList<>();
11. iotMeasurements.add("aaa");
12. iotMeasurements.add("bbb");
14. List<String> iotValues =newArrayList<>();
15. iotValues.add("123");
16. iotValues.add("abde");
18. StringBuffer sql =newStringBuffer();
19. sql.append(" insert into ").append(tableName.toString());
20. sql.append("(timestamp,");
21. sql.append(String.join(",", iotMeasurements)).append(")");
22. sql.append(" values(").append(currentTime).append(",");
23. sql.append(String.join(",", iotValues)).append(")");
24. iotDBConfig.insert(sql.toString());
26. //查询
27. StringBuffer querySql =newStringBuffer();
28. querySql.append(" select ").append("aaa");
29. querySql.append(" from ").append(tableName.toString());
30. querySql.append(" where ").append("bbb").append(" = '");
31. querySql.append("abde").append("'");
32. querySql.append(" order by time desc limit 1 ");
33. log.info("sql----{}", querySql);
34. List<Map<String,Object>> resultList = iotDBConfig.query(querySql.toString());

<audio controls="controls" style="display: none;"></audio>