...
问:在案例(十)中提到的定期刷新如何读取IoTDB里面的数据呢?
答:可以通过下面的代码读取IoTDB的数据,然后里用this答:可以通过下面的代码读取IoTDB的数据,然后用this.res返回结果,注意:不要一口气读上百万条!
代码块 | ||
---|---|---|
| ||
var Driver = Java.type("org.apache.iotdb.jdbc.IoTDBDriver"); var DriverManager = Java.type('java.sql.DriverManager'); DriverManager.registerDriver(new Driver()); this.logger.info("创建连接类成功!"); // 连接数据库的URL,如果是本地配套的直接使用127.0.0.1:6667 var url = "jdbc:iotdb://127.0.0.1:6667/"; // 数据库连接的用户名密码 var username = "root"; var password = "root"; var connection = DriverManager.getConnection(url, username, password); this.logger.info("创建连接对象成功!"); var statement = connection.createStatement(); this.logger.info("创建语句成功!"); statement.execute("SHOW STORAGE GROUP"); var result = statement.getResultSet(); this.logger.info("执行语句成功!");while (result.next()) { this.logger.info(result.getString(0)); // TODO:在这里增加有关连接结果处理的逻辑 }statement.close(); connection.close(); //返回结果 this.res = 1; |
...