编程 - Session

依赖

  • JDK >= 1.8
  • Maven >= 3.1

仅在client模块中打包

在根目录下运行:

mvn clean package -pl client -am -Dmaven.test.skip=true

安装到本地 maven 库

在根目录下运行:

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

在 maven 中使用 session 接口

  1. <dependencies>
  2.     <dependency>
  3.       <groupId>org.apache.iotdb</groupId>
  4.       <artifactId>iotdb-session</artifactId>
  5.       <version>0.9.3</version>
  6.     </dependency>
  7. </dependencies>

Session 接口使用示例

下面将给出Session对应的接口的简要介绍和对应参数：

启动Session的相关命令：

  • 初始化Session ​ Session(String host, int port) ​ Session(String host, String port, String username, String password) ​ Session(String host, int port, String username, String password)

  • 开启Session ​ Session.open()

  • 关闭Session ​ Session.close()

Session的相关数据操作命令

  • 设置存储组

    1. TSStatus setStorageGroup(String storageGroupId)

  • 删除单个或多个存储组

    1.     TSStatus deleteStorageGroup(String storageGroup)
    2.     TSStatus deleteStorageGroups(List<String> storageGroups)

  • 创建单个时间序列

    1.     TSStatus createTimeseries(String path, TSDataType dataType, TSEncoding encoding, CompressionType compressor)

  • 删除一个或多个时间序列

    1.     TSStatus deleteTimeseries(String path)
    2.     TSStatus deleteTimeseries(List<String> paths)

  • 删除某一特定时间前的时间序列

    1.     TSStatus deleteData(String path, long time)
    2.     TSStatus deleteData(List<String> paths, long time)

  • 插入时序数据

    1. TSStatus insert(String deviceId, long time, List<String> measurements, List<String> values)

  • 批量插入时序数据

    1. TSExecuteBatchStatementResp insertBatch(RowBatch rowBatch)

示例代码

浏览上述接口的详细信息，请参阅代码session/src/main/java/org/apache/iotdb/session/Session.java

使用上述接口的示例代码在example/session/src/main/java/org/apache/iotdb/SessionExample.java，在此文件中包含了开启session和执行批量插入等操作

针对原生接口的连接池

我们提供了一个针对原生接口的连接池(SessionPool)，使用该接口时，你只需要指定连接池的大小，就可以在使用时从池中获取连接。 如果超过60s都没得到一个连接的话，那么会打印一条警告日志，但是程序仍将继续等待。

当一个连接被用完后，他会自动返回池中等待下次被使用； 当一个连接损坏后，他会从池中被删除，并重建一个连接重新执行用户的操作。

对于查询操作：

  1. 使用SessionPool进行查询时，得到的结果集是SessionDataSet的封装类SessionDataSetWrapper;
  2. 若对于一个查询的结果集，用户并没有遍历完且不再想继续遍历时，需要手动调用释放连接的操作closeResultSet;
  3. 若对一个查询的结果集遍历时出现异常，也需要手动调用释放连接的操作closeResultSet.

使用示例可以参见 session/src/test/java/org/apache/iotdb/session/pool/SessionPoolTest.java