[incubator-iotdb] branch master updated: add infer type test in SessionIT

[qiaojialin]

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 7557e5d  add infer type test in SessionIT
7557e5d is described below

commit 7557e5d476f6361db5c0c52756a69adf331baa73
Author: qiaojialin <646274...@qq.com>
AuthorDate: Fri May 29 09:27:19 2020 +0800

    add infer type test in SessionIT
---
 .../org/apache/iotdb/session/IoTDBSessionIT.java   | 80 +++++++++++++++++++++-
 1 file changed, 77 insertions(+), 3 deletions(-)

diff --git a/session/src/test/java/org/apache/iotdb/session/IoTDBSessionIT.java 
b/session/src/test/java/org/apache/iotdb/session/IoTDBSessionIT.java
index a6c197e..82ab497 100644
--- a/session/src/test/java/org/apache/iotdb/session/IoTDBSessionIT.java
+++ b/session/src/test/java/org/apache/iotdb/session/IoTDBSessionIT.java
@@ -105,13 +105,87 @@ public class IoTDBSessionIT {
       values.add("3");
       session.insertRecord(deviceId, time, measurements, values);
     }
+  }
+
+  @Test
+  public void testInsertByStrAndInferType() throws IoTDBConnectionException, 
StatementExecutionException {
+    session = new Session("127.0.0.1", 6667, "root", "root");
+    session.open();
+
+    String deviceId = "root.sg1.d1";
+    List<String> measurements = new ArrayList<>();
+    measurements.add("s1");
+    measurements.add("s2");
+    measurements.add("s3");
+    measurements.add("s4");
+
+    List<String> values = new ArrayList<>();
+    values.add("1");
+    values.add("1.2");
+    values.add("true");
+    values.add("dad");
+    session.insertRecord(deviceId, 1L, measurements, values);
+
+    String[] expected = new String[]{
+        
IoTDBDescriptor.getInstance().getConfig().getIntegerStringInferType().name(),
+        
IoTDBDescriptor.getInstance().getConfig().getFloatingStringInferType().name(),
+        
IoTDBDescriptor.getInstance().getConfig().getBooleanStringInferType().name(),
+        TSDataType.TEXT.name()
+    };
 
     SessionDataSet dataSet = session.executeQueryStatement("show timeseries 
root");
-    assertTrue(dataSet.hasNext());
-    RowRecord record = dataSet.next();
+    int i = 0;
+    while (dataSet.hasNext()) {
+      assertEquals(expected[i], 
dataSet.next().getFields().get(3).getStringValue());
+      i++;
+    }
+
+    session.close();
   }
 
-    @Test
+  @Test
+  public void testInsertByObjAndNotInferType() throws 
IoTDBConnectionException, StatementExecutionException {
+    session = new Session("127.0.0.1", 6667, "root", "root");
+    session.open();
+
+    String deviceId = "root.sg1.d1";
+    List<String> measurements = new ArrayList<>();
+    measurements.add("s1");
+    measurements.add("s2");
+    measurements.add("s3");
+    measurements.add("s4");
+
+    List<TSDataType> dataTypes = new ArrayList<>();
+    dataTypes.add(TSDataType.INT64);
+    dataTypes.add(TSDataType.DOUBLE);
+    dataTypes.add(TSDataType.TEXT);
+    dataTypes.add(TSDataType.TEXT);
+
+    List<Object> values = new ArrayList<>();
+    values.add(1L);
+    values.add(1.2d);
+    values.add("true");
+    values.add("dad");
+    session.insertRecord(deviceId, 1L, measurements, dataTypes, values);
+
+    String[] expected = new String[]{
+        TSDataType.INT64.name(),
+        TSDataType.DOUBLE.name(),
+        TSDataType.TEXT.name(),
+        TSDataType.TEXT.name()
+    };
+
+    SessionDataSet dataSet = session.executeQueryStatement("show timeseries 
root");
+    int i = 0;
+    while (dataSet.hasNext()) {
+      assertEquals(expected[i], 
dataSet.next().getFields().get(3).getStringValue());
+      i++;
+    }
+
+    session.close();
+  }
+
+  @Test
   public void testInsertByObject() throws IoTDBConnectionException, 
StatementExecutionException {
     session = new Session("127.0.0.1", 6667, "root", "root");
     session.open();