标签:ring 自己 初始化 使用 orm 输出 pen 数据库 equals
一,获取maven依赖
<!-- https://mvnrepository.com/artifact/cn.edu.tsinghua/iotdb-jdbc --> <dependency> <groupId>cn.edu.tsinghua</groupId> <artifactId>iotdb-jdbc</artifactId> <version>0.6.0</version> </dependency>
可以自己去网上找依赖: https://mvnrepository.com/artifact/cn.edu.tsinghua/iotdb-jdbc/0.6.0
二,针对 上一篇文章上创建的组和时序 进行添加数据和查询数据简单写个测试工具类:
package com.czxk.cjc.utils; import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.ResultSetMetaData; import java.sql.SQLException; import java.sql.Statement; /** * * @author sunzhenyang * */ public class IoTdbUtil { private final String IOTDB_DRIVER = "cn.edu.tsinghua.iotdb.jdbc.TsfileDriver"; public static Connection connection = null; String url = "jdbc:tsfile://192.168.1.120:6667/"; //:JDBC 要连接的地址 String username = "root"; //:用户名,默认为 root String password ="root";//:密码,默认为 root /** * 初始化参数 * @param url * @param username * @param password * @throws ClassNotFoundException * @throws SQLException */ public IoTdbUtil(String url,String username,String password) throws ClassNotFoundException, SQLException { if(!"".equals(StringTools.emptyRetStr(url))) this.url = url; if(!"".equals(StringTools.emptyRetStr(username))) this.username = username; if(!"".equals(StringTools.emptyRetStr(password))) this.password = password; this.createConnection(); } /** * 创建连接 * @throws ClassNotFoundException * @throws SQLException */ private void createConnection() throws ClassNotFoundException, SQLException { try { //注册 IoTDB 的 JDBC 驱动 Class.forName(IOTDB_DRIVER); //使用 DriverManager 连接 IoTDB connection = DriverManager.getConnection(url, username, password); } catch (SQLException ex) { // handle any errors System.out.println("SQLException: " + ex.getMessage()); System.out.println("SQLState: " + ex.getSQLState()); System.out.println("VendorError: " + ex.getErrorCode()); } } /** * 执行查询 SQL * @param groupName 组名 * @param timeName 时间序列名 * @throws SQLException */ public void executeSelect(String groupName,String timeName) throws SQLException { // 查询测控 sgcc 集团 wf03 子站 wt01 设备温度 Statement statement = null; ResultSet resultSet = null; try { statement = connection.createStatement(); //statement.execute("select status from root.ln.wf01"); statement.execute("select "+timeName+" from " + groupName); resultSet = statement.getResultSet(); while(resultSet.next()){ //结果集下标从 1 开始 System.out.println(String.format("status %s, value %s", resultSet.getString(1), resultSet.getString(2))); } } catch (SQLException ex){ // handle any errors System.out.println("SQLException: " + ex.getMessage()); System.out.println("SQLState: " + ex.getSQLState()); System.out.println("VendorError: " + ex.getErrorCode()); } finally { if(statement != null) { statement.close(); } } } /** * 执行查询 SQL * @param sql 传入SQL * @throws SQLException */ public void executeSelect(String sql) throws SQLException { PreparedStatement preparedStatement = connection.prepareStatement(sql); try { //ResultSet resultSet = preparedStatement.executeQuery("select * from root "); ResultSet resultSet = preparedStatement.executeQuery(sql); ResultSetMetaData resultSetMetaData = resultSet.getMetaData(); while(resultSet.next()){ StringBuilder builder = new StringBuilder(); for (int i = 1; i <= resultSetMetaData.getColumnCount();i++) { builder.append(resultSet.getString(i)).append(","); } System.out.println(builder); } } catch (Exception ex) { }finally { preparedStatement.close(); } } /** * 关闭连接 * @throws SQLException */ public void closes() throws SQLException { if(connection != null) { connection.close(); } } /** * 测试 * @param args * @throws SQLException * @throws ClassNotFoundException */ public static void main(String[] args) throws ClassNotFoundException, SQLException { IoTdbUtil it = new IoTdbUtil(null, null, null); try { //测试添加数据 String sql = "insert into root.cjc(timestamp,cjcdata1,cjcdata2) values(?,?,?)"; PreparedStatement preparedStatement = connection.prepareStatement(sql); preparedStatement.setLong(1, 123456L); preparedStatement.setString(2, "haha哈哈"); preparedStatement.setString(3, "haha哈哈"); preparedStatement.execute(); //清除上一次的数据新加数据 继续添加 preparedStatement.clearParameters(); preparedStatement.setLong(1, 654321L); preparedStatement.setString(2, "haha哈哈"); preparedStatement.setString(3, "haha哈哈"); preparedStatement.execute(); preparedStatement.close(); //获取刚添加的数据 it.executeSelect("select * from root.cjc"); } catch (Exception e) { e.printStackTrace(); }finally { it.closes(); } } }
执行main方法后 输出:
123456,haha哈哈,haha哈哈,
654321,haha哈哈,haha哈哈,
初识 IoTdb 时间序列数据库集成到Java中, JavaAPI(二)
标签:ring 自己 初始化 使用 orm 输出 pen 数据库 equals
原文地址:https://www.cnblogs.com/sunhaoyu/p/12890606.html