...
| 代码块 | ||
|---|---|---|
| ||
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; |
...