You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by su...@apache.org on 2021/05/11 16:10:56 UTC
[iotdb] 01/01: Add test
This is an automated email from the ASF dual-hosted git repository.
sunzesong pushed a commit to branch vector_bug
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 76d102151c20e5d6447f5f920afeb88a052a4a7d
Author: samperson1997 <sz...@mails.tsinghua.edu.cn>
AuthorDate: Wed May 12 00:09:55 2021 +0800
Add test
---
.../iotdb/db/metadata/MManagerBasicTest.java | 48 ++++++++++++++++++++++
1 file changed, 48 insertions(+)
diff --git a/server/src/test/java/org/apache/iotdb/db/metadata/MManagerBasicTest.java b/server/src/test/java/org/apache/iotdb/db/metadata/MManagerBasicTest.java
index 1e86e89..65808e8 100644
--- a/server/src/test/java/org/apache/iotdb/db/metadata/MManagerBasicTest.java
+++ b/server/src/test/java/org/apache/iotdb/db/metadata/MManagerBasicTest.java
@@ -22,8 +22,10 @@ import org.apache.iotdb.db.conf.IoTDBDescriptor;
import org.apache.iotdb.db.exception.metadata.IllegalPathException;
import org.apache.iotdb.db.exception.metadata.MetadataException;
import org.apache.iotdb.db.metadata.mnode.MNode;
+import org.apache.iotdb.db.metadata.mnode.MeasurementMNode;
import org.apache.iotdb.db.metadata.template.Template;
import org.apache.iotdb.db.qp.physical.crud.CreateTemplatePlan;
+import org.apache.iotdb.db.qp.physical.crud.InsertRowPlan;
import org.apache.iotdb.db.qp.physical.crud.SetDeviceTemplatePlan;
import org.apache.iotdb.db.qp.physical.sys.CreateTimeSeriesPlan;
import org.apache.iotdb.db.qp.physical.sys.ShowTimeSeriesPlan;
@@ -1334,4 +1336,50 @@ public class MManagerBasicTest {
assertTrue(manager.isPathExist(new PartialPath("root.group-with-hyphen")));
}
+
+ @Test
+ public void testCreateAlignedTimeseriesAndInsertWithMismatchDataType() {
+ MManager manager = IoTDB.metaManager;
+ try {
+ manager.setStorageGroup(new PartialPath("root.laptop"));
+ manager.createAlignedTimeSeries(
+ new PartialPath("root.laptop.d1"),
+ Arrays.asList("s1", "s2", "s3"),
+ Arrays.asList(
+ TSDataType.valueOf("FLOAT"),
+ TSDataType.valueOf("INT64"),
+ TSDataType.valueOf("INT32")),
+ Arrays.asList(
+ TSEncoding.valueOf("RLE"), TSEncoding.valueOf("RLE"), TSEncoding.valueOf("RLE")),
+ compressionType);
+
+ // construct an insertRowPlan with mismatched data type
+ long time = 1L;
+ TSDataType[] dataTypes =
+ new TSDataType[] {TSDataType.FLOAT, TSDataType.DOUBLE, TSDataType.INT32};
+
+ String[] columns = new String[3];
+ columns[0] = 2.0 + "";
+ columns[1] = 10000 + "";
+ columns[2] = 100 + "";
+
+ InsertRowPlan insertRowPlan =
+ new InsertRowPlan(
+ new PartialPath("root.laptop.d1"),
+ time,
+ new String[] {"(s1,s2,s3)"},
+ dataTypes,
+ columns);
+ insertRowPlan.setMeasurementMNodes(
+ new MeasurementMNode[insertRowPlan.getMeasurements().length]);
+
+ // call getSeriesSchemasAndReadLockDevice
+ MNode mNode = manager.getSeriesSchemasAndReadLockDevice(insertRowPlan);
+ assertNotNull(insertRowPlan.getMeasurementMNodes()[0]);
+
+ } catch (Exception e) {
+ e.printStackTrace();
+ fail(e.getMessage());
+ }
+ }
}