This is an automated email from the ASF dual-hosted git repository. caogaofei pushed a commit to branch geely_car_0205_confignode in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 74bf6f8c26036834a4bd3e209e93d29106d67336 Author: HTHou <[email protected]> AuthorDate: Tue Jan 31 16:11:28 2023 +0800 recover SessionExample --- .../main/java/org/apache/iotdb/SessionExample.java | 63 +++++++++++++++++++--- 1 file changed, 55 insertions(+), 8 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 3032c2c47e..5d9fa09b7b 100644 --- a/example/session/src/main/java/org/apache/iotdb/SessionExample.java +++ b/example/session/src/main/java/org/apache/iotdb/SessionExample.java @@ -22,8 +22,10 @@ package org.apache.iotdb; import org.apache.iotdb.isession.SessionDataSet; import org.apache.iotdb.isession.SessionDataSet.DataIterator; import org.apache.iotdb.isession.template.Template; +import org.apache.iotdb.isession.util.Version; import org.apache.iotdb.rpc.IoTDBConnectionException; import org.apache.iotdb.rpc.StatementExecutionException; +import org.apache.iotdb.rpc.TSStatusCode; import org.apache.iotdb.session.Session; import org.apache.iotdb.session.template.MeasurementNode; import org.apache.iotdb.tsfile.file.metadata.enums.CompressionType; @@ -34,9 +36,6 @@ import org.apache.iotdb.tsfile.utils.BitMap; import org.apache.iotdb.tsfile.write.record.Tablet; import org.apache.iotdb.tsfile.write.schema.MeasurementSchema; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - import java.io.IOException; import java.util.ArrayList; import java.util.Arrays; @@ -58,14 +57,62 @@ public class SessionExample { private static final String ROOT_SG1_D1_S5 = "root.sg1.d1.s5"; private static final String ROOT_SG1_D1 = "root.sg1.d1"; private static final String LOCAL_HOST = "127.0.0.1"; - private static final Logger LOGGER = LoggerFactory.getLogger(SessionExample.class); public static void main(String[] args) throws IoTDBConnectionException, StatementExecutionException { - Map<String, Map<String, String>> map = new HashMap<>(); - Map<String, String> map2 = new HashMap<>(); - map.put("s1", new HashMap<>()); - LOGGER.info("map is {}", map); + session = + new Session.Builder() + .host(LOCAL_HOST) + .port(6667) + .username("root") + .password("root") + .version(Version.V_0_13) + .build(); + session.open(false); + + // set session fetchSize + session.setFetchSize(10000); + + try { + session.createDatabase("root.sg1"); + } catch (StatementExecutionException e) { + if (e.getStatusCode() != TSStatusCode.PATH_ALREADY_EXIST.getStatusCode()) { + throw e; + } + } + + // createTemplate(); + createTimeseries(); + createMultiTimeseries(); + insertRecord(); + insertTablet(); + // insertTabletWithNullValues(); + // insertTablets(); + // insertRecords(); + // insertText(); + // selectInto(); + // createAndDropContinuousQueries(); + // nonQuery(); + // query(); + // queryWithTimeout(); + // rawDataQuery(); + // lastDataQuery(); + // queryByIterator(); + // deleteData(); + // deleteTimeseries(); + // setTimeout(); + + sessionEnableRedirect = new Session(LOCAL_HOST, 6667, "root", "root"); + sessionEnableRedirect.setEnableQueryRedirection(true); + sessionEnableRedirect.open(false); + + // set session fetchSize + sessionEnableRedirect.setFetchSize(10000); + + insertRecord4Redirect(); + query4Redirect(); + sessionEnableRedirect.close(); + session.close(); } private static void createAndDropContinuousQueries()
