溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
本篇內容主要講解“Apache IoTDB客戶端接口怎么用”，感興趣的朋友不妨來看看。本文介紹的方法操作簡單快捷，實用性強。下面就讓小編來帶大家學習“Apache IoTDB客戶端接口怎么用”吧!
JDBC 接口
JDBC 是關系數據庫的標準接口，也是大家最熟悉的接口。所以一開始我們就提供了這種接口。
和標準 JDBC 的使用方式一樣，需要加載數據庫驅動類，建立連接，建立 Statement，通過 Statement 執(zhí)行語句，對于非查詢來說，可以批量執(zhí)行減少網絡傳輸次數。下面是一個簡單的例子，
public static void main(String[] args) throws ClassNotFoundException, SQLException { Class.forName("org.apache.iotdb.jdbc.IoTDBDriver"); try (Connection connection = DriverManager .getConnection("jdbc:iotdb://127.0.0.1:6667/", "root", "root"); Statement statement = connection.createStatement()) { // 創(chuàng)建存儲組 statement.execute("SET STORAGE GROUP TO root.sg1"); // 創(chuàng)建時間序列 statement.execute("CREATE TIMESERIES root.sg1.d1.s1 WITH DATATYPE=INT64, ENCODING=RLE, COMPRESSOR=SNAPPY"); statement.execute("CREATE TIMESERIES root.sg1.d1.s2 WITH DATATYPE=INT64, ENCODING=RLE, COMPRESSOR=SNAPPY"); statement.execute("CREATE TIMESERIES root.sg1.d1.s3 WITH DATATYPE=INT64, ENCODING=RLE, COMPRESSOR=SNAPPY"); // 在客戶端積累一批更新語句 for (int i = 0; i <= 100; i++) { statement.addBatch("insert into root.sg1.d1(timestamp, s1, s2, s3) values("+ i + "," + 1 + "," + 1 + "," + 1 + ")"); } // 執(zhí)行 statement.executeBatch(); statement.clearBatch(); // 查詢 ResultSet resultSet = statement.executeQuery("select * from root where time <= 10"); // 打印結果集 ResultSetMetaData metaData = resultSet.getMetaData(); int columnCount = metaData.getColumnCount(); while (resultSet.next()) { for (int i = 1; i < columnCount; i++) { System.out.print(resultSet.getString(i)); System.out.print(" "); } System.out.println(); } } }
Java 原生接口 Session
對于數據寫入，SQL 解析就占了 70% 耗時。于是我們提供了一個原生的 NoSQL 接口（Session），相比于 JDBC 更高效。
insertRecord(String deviceId, long time, List<String> measurements, List<TSDataType> types, List<Object> values)
這個接口就對應一個 insert 語句，一次可以寫入一個設備一個時間戳多個測點的值，其中值的類型需要和注冊的類型保持一致，如果沒注冊過則自動注冊此類型。
insertRecord(String deviceId, long time, List<String> measurements, List<String> values)
在一些場景下，客戶端拿不到具體的數據類型，這時候可以用這種 String 參數的接口。如果提前注冊了序列，服務器會根據注冊的類型來解析這些 String 的值，如果沒注冊，會根據值的格式推斷類型進行注冊。
insertTablet(Tablet tablet, boolean sorted)
一個Tablet 是一個設備多個時間戳多個測點的值。這里要注意，每個測點在每個時間戳都需要有值，不能有空的。sorted 表示是否時間戳是遞增的，如果能保證遞增，可以設置為 true，否則我們還會再排個序。
如果只計算執(zhí)行時間，這個接口是最高效的，因為里邊使用了原始類型的數組，避免了裝箱。但是，這個接口對數據的格式要求很高，如果數據采集不是對齊采的，強行轉化成這種接口，轉化的耗時需要統(tǒng)計一下。
此外還有 insertTablets 和 insertRecords 兩種，其實就是以上幾種接口的批量的形式。
Session 的查詢結果集是 SessionDataSet，這個結構提供的 hasNext 和 next 方法把每一行數據都轉化成了 RowRecord 這個結構，如果客戶端還需要做其他轉化，這個結構就多余了。這時候可以通過 SessionDataSet.iterator()得到一個迭代器，這個迭代器的訪問數據的方式和 JDBC 的 ResultSet 是一樣的，直接從字節(jié)數組里拿數據，比 RowRecord 更高效。
連接池 SessionPool
自從原生接口誕生以來，很多用戶就從 JDBC 遷移到原始接口了，我們也擴充了原生接口的能力，增加了 Session 的連接池（東哥傾情奉獻）。連接池的接口和 Session 基本一樣，但是連接池可以供多線程使用，而且可以屏蔽連接異常等問題。
使用連接池唯一一點需要注意的是，查詢得到的結果集使用完需要返還給連接池（調用連接池的 closeResultSet 方法），不然連接會被占用，無法得到新的連接就報超時了。
SessionDataSetWrapper wrapper = null;try { wrapper = pool.executeQueryStatement("select * from root.sg1.d1"); while (wrapper.hasNext()) { System.out.println(wrapper.next()); }} catch (IoTDBConnectionException | StatementExecutionException e) { e.printStackTrace();} finally { // remember to close data set finally! pool.closeResultSet(wrapper);}
到此，相信大家對“Apache IoTDB客戶端接口怎么用”有了更深的了解，不妨來實際操作一番吧！這里是億速云網站，更多相關內容可以進入相關頻道進行查詢，關注我們，繼續(xù)學習！
免責聲明：本站發(fā)布的內容（圖片、視頻和文字）以原創(chuàng)、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯(lián)系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
