You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by qi...@apache.org on 2020/04/11 04:42:25 UTC
[incubator-iotdb] branch master updated: Robust SessionExample
(#1026)
This is an automated email from the ASF dual-hosted git repository.
qiaojialin pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git
The following commit(s) were added to refs/heads/master by this push:
new b11ed18 Robust SessionExample (#1026)
b11ed18 is described below
commit b11ed188bbe19fbdb6cf08e319e2fb639874bfb1
Author: Jialin Qiao <qj...@mails.tsinghua.edu.cn>
AuthorDate: Sat Apr 11 12:42:16 2020 +0800
Robust SessionExample (#1026)
* fix session example
---
.../src/main/java/org/apache/iotdb/SessionExample.java | 16 ++++++++++++----
1 file changed, 12 insertions(+), 4 deletions(-)
diff --git a/example/session/src/main/java/org/apache/iotdb/SessionExample.java b/example/session/src/main/java/org/apache/iotdb/SessionExample.java
index 08596b2..7f28c43 100644
--- a/example/session/src/main/java/org/apache/iotdb/SessionExample.java
+++ b/example/session/src/main/java/org/apache/iotdb/SessionExample.java
@@ -44,16 +44,24 @@ public class SessionExample {
session = new Session("127.0.0.1", 6667, "root", "root");
session.open(false);
- session.setStorageGroup("root.sg1");
- if (session.checkTimeseriesExists("root.sg1.d1.s1")) {
+ try {
+ session.setStorageGroup("root.sg1");
+ } catch (StatementExecutionException e) {
+ if (!e.getMessage().contains("StorageGroupAlreadySetException")) {
+ throw e;
+ }
+// ignore duplicated set
+ }
+
+ if (!session.checkTimeseriesExists("root.sg1.d1.s1")) {
session.createTimeseries("root.sg1.d1.s1", TSDataType.INT64, TSEncoding.RLE,
CompressionType.SNAPPY);
}
- if (session.checkTimeseriesExists("root.sg1.d1.s2")) {
+ if (!session.checkTimeseriesExists("root.sg1.d1.s2")) {
session.createTimeseries("root.sg1.d1.s2", TSDataType.INT64, TSEncoding.RLE,
CompressionType.SNAPPY);
}
- if (session.checkTimeseriesExists("root.sg1.d1.s3")) {
+ if (!session.checkTimeseriesExists("root.sg1.d1.s3")) {
session.createTimeseries("root.sg1.d1.s3", TSDataType.INT64, TSEncoding.RLE,
CompressionType.SNAPPY);
}