(iotdb) branch support_schema_evolution updated: supplement DataRegionTest

[jiangtian]

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

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


The following commit(s) were added to refs/heads/support_schema_evolution by 
this push:
     new 4ced268f8b1 supplement DataRegionTest
4ced268f8b1 is described below

commit 4ced268f8b1c54de8b36c25e3b245f0f7419e9e7
Author: Tian Jiang <jt2594...@163.com>
AuthorDate: Thu Nov 27 19:12:56 2025 +0800

    supplement DataRegionTest
---
 .../plan/statement/StatementTestUtils.java         | 12 ++++++++--
 .../storageengine/dataregion/DataRegionTest.java   | 28 ++++++++++++++++++++--
 2 files changed, 36 insertions(+), 4 deletions(-)

diff --git 
a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/statement/StatementTestUtils.java
 
b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/statement/StatementTestUtils.java
index a80095458a9..2b064a77721 100644
--- 
a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/statement/StatementTestUtils.java
+++ 
b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/statement/StatementTestUtils.java
@@ -55,7 +55,11 @@ public class StatementTestUtils {
   }
 
   public static String tableName() {
-    return "table1";
+    return tableName(1);
+  }
+
+  public static String tableName(int i) {
+    return "table" + i;
   }
 
   public static String[] genColumnNames() {
@@ -232,7 +236,11 @@ public class StatementTestUtils {
   }
 
   public static TsTable genTsTable() {
-    final TsTable tsTable = new TsTable(tableName());
+    return genTsTable(1);
+  }
+
+  public static TsTable genTsTable(int tableId) {
+    final TsTable tsTable = new TsTable(tableName(tableId));
     String[] measurements = genColumnNames();
     TSDataType[] dataTypes = genDataTypes();
     TsTableColumnCategory[] columnCategories = genColumnCategories();
diff --git 
a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/DataRegionTest.java
 
b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/DataRegionTest.java
index 5b692e70571..b525b4860e7 100644
--- 
a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/DataRegionTest.java
+++ 
b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/DataRegionTest.java
@@ -141,9 +141,13 @@ public class DataRegionTest {
     config.setInnerUnsequenceCompactionSelector(
         InnerUnsequenceCompactionSelector.SIZE_TIERED_SINGLE_TARGET);
     DataNodeTableCache.getInstance()
-        .preUpdateTable(dataRegion.getDatabaseName(), 
StatementTestUtils.genTsTable(), null);
+        .preUpdateTable(dataRegion.getDatabaseName(), 
StatementTestUtils.genTsTable(1), null);
     DataNodeTableCache.getInstance()
-        .commitUpdateTable(dataRegion.getDatabaseName(), 
StatementTestUtils.tableName(), null);
+        .commitUpdateTable(dataRegion.getDatabaseName(), 
StatementTestUtils.tableName(1), null);
+    DataNodeTableCache.getInstance()
+        .preUpdateTable(dataRegion.getDatabaseName(), 
StatementTestUtils.genTsTable(2), null);
+    DataNodeTableCache.getInstance()
+        .commitUpdateTable(dataRegion.getDatabaseName(), 
StatementTestUtils.tableName(2), null);
   }
 
   @After
@@ -1822,6 +1826,11 @@ public class DataRegionTest {
         Collections.singletonList(0L), Long.MAX_VALUE);
     assertEquals(1, dataSource.getSeqResources().size());
 
+    DataNodeTableCache.getInstance()
+        .preUpdateTable(dataRegion.getDatabaseName(), 
StatementTestUtils.genTsTable(1), null);
+    DataNodeTableCache.getInstance()
+        .commitUpdateTable(dataRegion.getDatabaseName(), 
StatementTestUtils.tableName(1), null);
+
     // write again with table1
     insertRowNode = new RelationalInsertRowNode(new PlanNodeId(""),
         new PartialPath(new String[] {"table1"}),
@@ -1835,5 +1844,20 @@ public class DataRegionTest {
         new TsTableColumnCategory[]{TsTableColumnCategory.TAG, 
TsTableColumnCategory.FIELD, TsTableColumnCategory.FIELD});
     dataRegion.insert(insertRowNode);
 
+    // can query with table1
+    fullPaths = Arrays.asList(
+        new AlignedFullPath(deviceID1, Arrays.asList(measurements), 
Arrays.asList(measurementSchemas))
+    );
+    dataSource = dataRegion.query(fullPaths, deviceID1, new QueryContext(), 
null,
+        Collections.singletonList(0L), Long.MAX_VALUE);
+    assertEquals(1, dataSource.getUnseqResources().size());
+
+    // can query with table2
+    fullPaths = Arrays.asList(
+        new AlignedFullPath(deviceID2, Arrays.asList(measurements), 
Arrays.asList(measurementSchemas))
+    );
+    dataSource = dataRegion.query(fullPaths, deviceID2, new QueryContext(), 
null,
+        Collections.singletonList(0L), Long.MAX_VALUE);
+    assertEquals(1, dataSource.getSeqResources().size());
   }
 }