[iotdb] branch master updated: Add a testcase of dataApplier about batch insert. (#3645)

[tanxinyu]

This is an automated email from the ASF dual-hosted git repository.

tanxinyu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/master by this push:
     new 868821c  Add a testcase of dataApplier about batch insert. (#3645)
868821c is described below

commit 868821c84e789801642087960c038b8b7cb968a8
Author: MrQuansy <50790061+mrqua...@users.noreply.github.com>
AuthorDate: Thu Jul 29 16:34:01 2021 +0800

    Add a testcase of dataApplier about batch insert. (#3645)
    
    * add testcase of data applier about batch insert
---
 .../cluster/log/applier/DataLogApplierTest.java    | 36 ++++++++++++++++++++++
 1 file changed, 36 insertions(+)

diff --git 
a/cluster/src/test/java/org/apache/iotdb/cluster/log/applier/DataLogApplierTest.java
 
b/cluster/src/test/java/org/apache/iotdb/cluster/log/applier/DataLogApplierTest.java
index cd90c7b..b55bd9b 100644
--- 
a/cluster/src/test/java/org/apache/iotdb/cluster/log/applier/DataLogApplierTest.java
+++ 
b/cluster/src/test/java/org/apache/iotdb/cluster/log/applier/DataLogApplierTest.java
@@ -59,6 +59,7 @@ import org.apache.iotdb.db.metadata.PartialPath;
 import org.apache.iotdb.db.metadata.mnode.MeasurementMNode;
 import org.apache.iotdb.db.qp.physical.crud.DeletePlan;
 import org.apache.iotdb.db.qp.physical.crud.InsertRowPlan;
+import org.apache.iotdb.db.qp.physical.crud.InsertRowsPlan;
 import org.apache.iotdb.db.qp.physical.sys.ClearCachePlan;
 import org.apache.iotdb.db.qp.physical.sys.CreateMultiTimeSeriesPlan;
 import org.apache.iotdb.db.qp.physical.sys.FlushPlan;
@@ -305,6 +306,41 @@ public class DataLogApplierTest extends IoTDBTest {
   }
 
   @Test
+  public void testApplyBatchInsert()
+      throws MetadataException, QueryProcessException, StorageEngineException, 
IOException,
+          InterruptedException, QueryFilterOptimizationException {
+    InsertRowsPlan insertRowsPlan = new InsertRowsPlan();
+    PhysicalPlanLog log = new PhysicalPlanLog();
+    log.setPlan(insertRowsPlan);
+
+    for (int i = 1; i <= 4; i++) {
+      InsertRowPlan insertPlan = new InsertRowPlan();
+      insertPlan.setPrefixPath(new PartialPath(TestUtils.getTestSg(i)));
+      insertPlan.setTime(1);
+      insertPlan.setNeedInferType(true);
+      insertPlan.setMeasurements(new String[] 
{TestUtils.getTestMeasurement(0)});
+      insertPlan.setDataTypes(new 
TSDataType[insertPlan.getMeasurements().length]);
+      insertPlan.setValues(new Object[] {"1.0"});
+      insertPlan.setNeedInferType(true);
+      insertPlan.setMeasurementMNodes(
+          new MeasurementMNode[] {TestUtils.getTestMeasurementMNode(0)});
+      insertRowsPlan.addOneInsertRowPlan(insertPlan, i - 1);
+    }
+
+    applier.apply(log);
+
+    for (int i = 1; i <= 4; i++) {
+      QueryDataSet dataSet = 
query(Collections.singletonList(TestUtils.getTestSeries(i, 0)), null);
+      assertTrue(dataSet.hasNext());
+      RowRecord record = dataSet.next();
+      assertEquals(1, record.getTimestamp());
+      assertEquals(1, record.getFields().size());
+      assertEquals(1.0, record.getFields().get(0).getDoubleV(), 0.00001);
+      assertFalse(dataSet.hasNext());
+    }
+  }
+
+  @Test
   public void testApplyDeletion()
       throws QueryProcessException, MetadataException, 
QueryFilterOptimizationException,
           StorageEngineException, IOException, InterruptedException {