• JDK >= 1.8
    • Maven >= 3.0

    mvn clean install -pl jdbc -am -Dmaven.test.skip=true

    Requires that you include the packages containing the JDBC classes needed for database programming.

    2. import org.apache.iotdb.jdbc.IoTDBSQLException;
    4.   /**
    5.    * Before executing a SQL statement with a Statement object, you need to create a Statement object using the createStatement() method of the Connection object.
    6.    * After creating a Statement object, you can use its execute() method to execute a SQL statement
    7.    * Finally, remember to close the 'statement' and 'connection' objects by using their close() method
    8.    * For statements with query results, we can use the getResultSet() method of the Statement object to get the result set.
    9.    */
    10.   public static void main(String[] args) throws SQLException {
    11.     Connection connection = getConnection();
    12.     if (connection == null) {
    13.       System.out.println("get connection defeat");
    14.       return;
    15.     }
    16.     Statement statement = connection.createStatement();
    17.     //Create storage group
    18.     try {
    19.       statement.execute("SET STORAGE GROUP TO root.demo");
    20.     }catch (IoTDBSQLException e){
    21.       System.out.println(e.getMessage());
    22.     }
    25.     //Show storage group
    26.     statement.execute("SHOW STORAGE GROUP");
    27.     outputResult(statement.getResultSet());
    29.     //Create time series
    30.     //Different data type has different encoding methods. Here use INT32 as an example
    31.     try {
    32.       statement.execute("CREATE TIMESERIES root.demo.s0 WITH DATATYPE=INT32,ENCODING=RLE;");
    33.     }catch (IoTDBSQLException e){
    34.       System.out.println(e.getMessage());
    35.     }
    36.     //Show time series
    37.     statement.execute("SHOW TIMESERIES root.demo");
    39.     //Execute insert statements in batch
    40.     statement.addBatch("insert into root.demo(timestamp,s0) values(1,1);");
    41.     statement.addBatch("insert into root.demo(timestamp,s0) values(1,1);");
    43.     statement.addBatch("insert into root.demo(timestamp,s0) values(2,17);");
    44.     statement.addBatch("insert into root.demo(timestamp,s0) values(4,12);");
    45.     statement.executeBatch();
    46.     statement.clearBatch();
    48.     //Full query statement
    49.     String sql = "select * from root.demo";
    50.     ResultSet resultSet = statement.executeQuery(sql);
    51.     System.out.println("sql: " + sql);
    52.     outputResult(resultSet);
    54.     //Exact query statement
    55.     sql = "select s0 from root.demo where time = 4;";
    56.     resultSet= statement.executeQuery(sql);
    57.     System.out.println("sql: " + sql);
    58.     outputResult(resultSet);
    60.     //Time range query
    61.     sql = "select s0 from root.demo where time >= 2 and time < 5;";
    62.     resultSet = statement.executeQuery(sql);
    63.     System.out.println("sql: " + sql);
    64.     outputResult(resultSet);
    66.     //Aggregate query
    67.     sql = "select count(s0) from root.demo;";
    68.     resultSet = statement.executeQuery(sql);
    69.     System.out.println("sql: " + sql);
    70.     outputResult(resultSet);
    72.     //Delete time series
    73.     statement.execute("delete timeseries root.demo.s0");
    75.     //close connection
    76.     statement.close();
    77.     connection.close();
    78.   }
    80.   public static Connection getConnection() {
    81.     // JDBC driver name and database URL
    82.     String url = "jdbc:iotdb://127.0.0.1:6667/";
    84.     // Database credentials
    85.     String username = "root";
    86.     String password = "root";
    88.     Connection connection = null;
    89.     try {
    90.       Class.forName(driver);
    91.       connection = DriverManager.getConnection(url, username, password);
    92.     } catch (ClassNotFoundException e) {
    93.       e.printStackTrace();
    94.     } catch (SQLException e) {
    95.       e.printStackTrace();
    96.     }
    97.     return connection;
    98.   }
    100.   /**
    101.    * This is an example of outputting the results in the ResultSet
    102.    */
    103.   private static void outputResult(ResultSet resultSet) throws SQLException {
    104.     if (resultSet != null) {
    105.       System.out.println("--------------------------");
    106.       final ResultSetMetaData metaData = resultSet.getMetaData();
    107.       final int columnCount = metaData.getColumnCount();
    108.       for (int i = 0; i < columnCount; i++) {
    109.         System.out.print(metaData.getColumnLabel(i + 1) + " ");
    110.       }
    111.       System.out.println();
    112.       while (resultSet.next()) {
    113.         for (int i = 1; ; i++) {
    114.           System.out.print(resultSet.getString(i));
    115.           if (i < columnCount) {
    116.             System.out.print(", ");
    117.           } else {
    118.             System.out.println();
    119.             break;
    120.           }
    121.         }
    122.       }
    123.       System.out.println("--------------------------\n");
    124.     }