This is an automated email from the ASF dual-hosted git repository.
justinchen pushed a commit to branch fix-quote
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/fix-quote by this push:
new af1a64aaf70 hj
af1a64aaf70 is described below
commit af1a64aaf70557429fcedd156bf01c92c85d91e8
Author: Caideyipi <[email protected]>
AuthorDate: Mon Mar 2 16:26:17 2026 +0800
hj
---
.../view/recent/IoTDBComplexQueryTableViewIT.java | 18 ++++++++--------
.../iotdb/relational/it/schema/IoTDBTableIT.java | 20 ++++++++++--------
.../common/header/DatasetHeaderFactory.java | 2 +-
.../operator/schema/source/DeviceSchemaSource.java | 2 +-
.../plan/planner/OperatorTreeGenerator.java | 2 +-
.../node/metadata/read/DevicesSchemaScanNode.java | 24 +++++++++++-----------
.../metadata/fetcher/TableDeviceSchemaFetcher.java | 12 +++++------
.../sql/ast/AbstractQueryDeviceWithCache.java | 15 +++++++++-----
.../read/resp/info/impl/ShowDevicesResult.java | 4 ++--
.../logical/SchemaQueryLogicalPlannerTest.java | 6 +++---
.../schema/column/ColumnHeaderConstant.java | 2 +-
11 files changed, 58 insertions(+), 49 deletions(-)
diff --git
a/integration-test/src/test/java/org/apache/iotdb/relational/it/query/view/recent/IoTDBComplexQueryTableViewIT.java
b/integration-test/src/test/java/org/apache/iotdb/relational/it/query/view/recent/IoTDBComplexQueryTableViewIT.java
index 96f0a9de596..b6617ec50dd 100644
---
a/integration-test/src/test/java/org/apache/iotdb/relational/it/query/view/recent/IoTDBComplexQueryTableViewIT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/relational/it/query/view/recent/IoTDBComplexQueryTableViewIT.java
@@ -48,10 +48,10 @@ public class IoTDBComplexQueryTableViewIT {
"create aligned timeseries root.test.employees.D002(name TEXT,Gender
TEXT,Status BOOLEAN,employee_id INT32,salary DOUBLE,date_of_birth
DATE,Contac_info string)",
"create aligned timeseries root.test.employees.D002(name TEXT,Gender
TEXT,Status BOOLEAN,employee_id INT32,salary DOUBLE,date_of_birth
DATE,Contac_info string)",
"create aligned timeseries root.test.employees.D003(name TEXT,Gender
TEXT,Status BOOLEAN,employee_id INT32,salary DOUBLE,date_of_birth
DATE,Contac_info string)",
- "create aligned timeseries root.test.departments.D001(department_id
STRING,dep_name TEXT,dep_phone TEXT,dep_status BOOLEAN,dep_member
INT32,employee_id INT32)",
- "create aligned timeseries root.test.departments.D002(department_id
STRING,dep_name TEXT,dep_phone TEXT,dep_status BOOLEAN,dep_member
INT32,employee_id INT32)",
- "create aligned timeseries root.test.departments.D003(department_id
STRING,dep_name TEXT,dep_phone TEXT,dep_status BOOLEAN,dep_member
INT32,employee_id INT32)",
- "create aligned timeseries root.test.departments.D004(department_id
STRING,dep_name TEXT,dep_phone TEXT,dep_status BOOLEAN,dep_member
INT32,employee_id INT32)",
+ "create aligned timeseries root.test.departments.D001(`1department_id`
STRING,dep_name TEXT,dep_phone TEXT,dep_status BOOLEAN,dep_member
INT32,employee_id INT32)",
+ "create aligned timeseries root.test.departments.D002(`1department_id`
STRING,dep_name TEXT,dep_phone TEXT,dep_status BOOLEAN,dep_member
INT32,employee_id INT32)",
+ "create aligned timeseries root.test.departments.D003(`1department_id`
STRING,dep_name TEXT,dep_phone TEXT,dep_status BOOLEAN,dep_member
INT32,employee_id INT32)",
+ "create aligned timeseries root.test.departments.D004(`1department_id`
STRING,dep_name TEXT,dep_phone TEXT,dep_status BOOLEAN,dep_member
INT32,employee_id INT32)",
"insert into root.test.employees.D001(time, name, gender, status,
employee_id, salary, date_of_birth, contac_info) aligned values(1,
'Mary','Female', false, 1223, 5500.22, '1988-10-12', '133-1212-1234')",
"insert into root.test.employees.D001(time, name, gender, status,
employee_id, salary, date_of_birth, contac_info) aligned values(2, 'John',
'Male', true, 40012, 8822, '1985-06-15', '130-1002-1334')",
"insert into root.test.employees.D002(time, name, gender, status,
employee_id, salary, date_of_birth, contac_info) aligned values(3, 'Nancy',
'Female', true, 30112, 10002, '1983-08-15', '135-1302-1354')",
@@ -69,8 +69,8 @@ public class IoTDBComplexQueryTableViewIT {
new String[] {
"CREATE DATABASE " + DATABASE_NAME,
"USE " + DATABASE_NAME,
- "create view employees(department_id STRING TAG,name TEXT FIELD,Gender
TEXT FIELD,Status BOOLEAN FIELD,employee_id INT32 FIELD,salary DOUBLE
FIELD,date_of_birth DATE FIELD,Contac_info string FIELD) as
root.test.employees.**",
- "create view departments(department_id STRING TAG,dep_name TEXT
FIELD,dep_phone TEXT FIELD,dep_status BOOLEAN FIELD,dep_member INT32
FIELD,employee_id INT32 FIELD) as root.test.departments.**",
+ "create view employees(\"`1department_id`\" STRING TAG,name TEXT
FIELD,Gender TEXT FIELD,Status BOOLEAN FIELD,employee_id INT32 FIELD,salary
DOUBLE FIELD,date_of_birth DATE FIELD,Contac_info string FIELD) as
root.test.employees.**",
+ "create view departments(\"`1department_id`\" STRING TAG,dep_name TEXT
FIELD,dep_phone TEXT FIELD,dep_status BOOLEAN FIELD,dep_member INT32
FIELD,employee_id INT32 FIELD) as root.test.departments.**",
};
@BeforeClass
@@ -88,11 +88,11 @@ public class IoTDBComplexQueryTableViewIT {
@Test
public void queryTest1() {
// Look for the non-intersecting departments in the two tables
- String[] expectedHeader = new String[] {"department_id", "dep_name"};
+ String[] expectedHeader = new String[] {"`1department_id`", "dep_name"};
String[] retArray = new String[] {"D004,人事部,"};
tableResultSetEqualTest(
- "select department_id, dep_name from departments where not exists("
- + "select 1 from employees where employees.department_id =
departments.department_id)",
+ "select \"`1department_id`\", dep_name from departments where not
exists("
+ + "select 1 from employees where employees.\"`1department_id`\" =
departments.\"`1department_id`\")",
expectedHeader,
retArray,
DATABASE_NAME);
diff --git
a/integration-test/src/test/java/org/apache/iotdb/relational/it/schema/IoTDBTableIT.java
b/integration-test/src/test/java/org/apache/iotdb/relational/it/schema/IoTDBTableIT.java
index aac532a9800..b335278321c 100644
---
a/integration-test/src/test/java/org/apache/iotdb/relational/it/schema/IoTDBTableIT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/relational/it/schema/IoTDBTableIT.java
@@ -762,8 +762,8 @@ public class IoTDBTableIT {
final Statement statement = connection.createStatement()) {
statement.execute("create database root.another");
statement.execute("create database root.`重庆`.`1`.b");
- statement.execute("create timeSeries root.`重庆`.`1`.b.c.S1 int32");
- statement.execute("create timeSeries root.`重庆`.`1`.b.c.s2 string");
+ statement.execute("create timeSeries root.`重庆`.`1`.b.`2`.S1 int32");
+ statement.execute("create timeSeries root.`重庆`.`1`.b.`2`.s2 string");
statement.execute("create timeSeries root.`重庆`.`1`.b.S1 int32");
} catch (SQLException e) {
fail(e.getMessage());
@@ -789,7 +789,7 @@ public class IoTDBTableIT {
try (final Connection connection = EnvFactory.getEnv().getConnection();
final Statement statement = connection.createStatement()) {
- statement.execute("create timeSeries root.`重庆`.`1`.b.d.s1 int32");
+ statement.execute("create timeSeries root.`重庆`.`1`.b.`1`.s1 int32");
} catch (SQLException e) {
fail(e.getMessage());
}
@@ -814,13 +814,13 @@ public class IoTDBTableIT {
try (final Connection connection = EnvFactory.getEnv().getConnection();
final Statement statement = connection.createStatement()) {
- statement.execute("drop timeSeries root.`重庆`.`1`.b.d.s1");
+ statement.execute("drop timeSeries root.`重庆`.`1`.b.`1`.s1");
statement.execute("create device template t1 (S1 boolean, s9 int32)");
- statement.execute("set schema template t1 to root.`重庆`.`1`.b.d");
- statement.execute("create timeSeries root.`重庆`.`1`.b.c.f.g.h.S1 int32");
+ statement.execute("set schema template t1 to root.`重庆`.`1`.b.`1`");
+ statement.execute("create timeSeries root.`重庆`.`1`.b.`2`.f.g.h.S1
int32");
// Put schema cache
- statement.execute("select S1, s2 from root.`重庆`.`1`.b.c");
+ statement.execute("select S1, s2 from root.`重庆`.`1`.b.`2`");
} catch (SQLException e) {
fail(e.getMessage());
}
@@ -937,11 +937,15 @@ public class IoTDBTableIT {
TestUtils.assertResultSetEqual(
statement.executeQuery("show devices from view_table where tag1 =
'b'"),
"tag1,tag2,",
- new HashSet<>(Arrays.asList("b,c,", "b,null,", "b,e,")));
+ new HashSet<>(Arrays.asList("b,`2`,", "b,null,", "b,e,")));
TestUtils.assertResultSetEqual(
statement.executeQuery("show devices from view_table where tag1 =
'b' and tag2 is null"),
"tag1,tag2,",
Collections.singleton("b,null,"));
+ TestUtils.assertResultSetEqual(
+ statement.executeQuery("show devices from view_table where tag1 =
'b' and tag2 = '`2`'"),
+ "tag1,tag2,",
+ Collections.singleton("b,`2`,"));
TestUtils.assertResultSetEqual(
statement.executeQuery("count devices from view_table"),
"count(devices),",
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/common/header/DatasetHeaderFactory.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/common/header/DatasetHeaderFactory.java
index 4d19daca70d..79a48382434 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/common/header/DatasetHeaderFactory.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/common/header/DatasetHeaderFactory.java
@@ -56,7 +56,7 @@ public class DatasetHeaderFactory {
}
public static DatasetHeader getShowDevicesWithSgHeader() {
- return new
DatasetHeader(ColumnHeaderConstant.showDevicesWithSgColumnHeaders, true);
+ return new
DatasetHeader(ColumnHeaderConstant.showDevicesWithDbColumnHeaders, true);
}
public static DatasetHeader getShowDatabaseHeader(final boolean isDetailed) {
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/schema/source/DeviceSchemaSource.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/schema/source/DeviceSchemaSource.java
index a274c36402e..f2bce1b0f05 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/schema/source/DeviceSchemaSource.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/schema/source/DeviceSchemaSource.java
@@ -89,7 +89,7 @@ public class DeviceSchemaSource implements
ISchemaSource<IDeviceSchemaInfo> {
@Override
public List<ColumnHeader> getInfoQueryColumnHeaders() {
return hasSgCol
- ? ColumnHeaderConstant.showDevicesWithSgColumnHeaders
+ ? ColumnHeaderConstant.showDevicesWithDbColumnHeaders
: ColumnHeaderConstant.showDevicesColumnHeaders;
}
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/OperatorTreeGenerator.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/OperatorTreeGenerator.java
index 0219de6502d..f69c5aec0c6 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/OperatorTreeGenerator.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/OperatorTreeGenerator.java
@@ -935,7 +935,7 @@ public class OperatorTreeGenerator extends
PlanVisitor<Operator, LocalExecutionP
node.isPrefixPath(),
node.getLimit(),
node.getOffset(),
- node.isHasSgCol(),
+ node.isHasDbCol(),
node.getSchemaFilter(),
node.getScope()));
}
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/metadata/read/DevicesSchemaScanNode.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/metadata/read/DevicesSchemaScanNode.java
index e7c5067c4e3..d76e74d9d7a 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/metadata/read/DevicesSchemaScanNode.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/metadata/read/DevicesSchemaScanNode.java
@@ -40,7 +40,7 @@ import java.util.stream.Collectors;
public class DevicesSchemaScanNode extends SchemaQueryScanNode {
- private final boolean hasSgCol;
+ private final boolean hasDbCol;
private final SchemaFilter schemaFilter;
public DevicesSchemaScanNode(
@@ -49,16 +49,16 @@ public class DevicesSchemaScanNode extends
SchemaQueryScanNode {
long limit,
long offset,
boolean isPrefixPath,
- boolean hasSgCol,
+ boolean hasDbCol,
SchemaFilter schemaFilter,
PathPatternTree scope) {
super(id, path, limit, offset, isPrefixPath, scope);
- this.hasSgCol = hasSgCol;
+ this.hasDbCol = hasDbCol;
this.schemaFilter = schemaFilter;
}
- public boolean isHasSgCol() {
- return hasSgCol;
+ public boolean isHasDbCol() {
+ return hasDbCol;
}
public SchemaFilter getSchemaFilter() {
@@ -73,13 +73,13 @@ public class DevicesSchemaScanNode extends
SchemaQueryScanNode {
@Override
public PlanNode clone() {
return new DevicesSchemaScanNode(
- getPlanNodeId(), path, limit, offset, isPrefixPath, hasSgCol,
schemaFilter, scope);
+ getPlanNodeId(), path, limit, offset, isPrefixPath, hasDbCol,
schemaFilter, scope);
}
@Override
public List<String> getOutputColumnNames() {
- if (hasSgCol) {
- return ColumnHeaderConstant.showDevicesWithSgColumnHeaders.stream()
+ if (hasDbCol) {
+ return ColumnHeaderConstant.showDevicesWithDbColumnHeaders.stream()
.map(ColumnHeader::getColumnName)
.collect(Collectors.toList());
}
@@ -96,7 +96,7 @@ public class DevicesSchemaScanNode extends
SchemaQueryScanNode {
ReadWriteIOUtils.write(limit, byteBuffer);
ReadWriteIOUtils.write(offset, byteBuffer);
ReadWriteIOUtils.write(isPrefixPath, byteBuffer);
- ReadWriteIOUtils.write(hasSgCol, byteBuffer);
+ ReadWriteIOUtils.write(hasDbCol, byteBuffer);
SchemaFilter.serialize(schemaFilter, byteBuffer);
}
@@ -108,7 +108,7 @@ public class DevicesSchemaScanNode extends
SchemaQueryScanNode {
ReadWriteIOUtils.write(limit, stream);
ReadWriteIOUtils.write(offset, stream);
ReadWriteIOUtils.write(isPrefixPath, stream);
- ReadWriteIOUtils.write(hasSgCol, stream);
+ ReadWriteIOUtils.write(hasDbCol, stream);
SchemaFilter.serialize(schemaFilter, stream);
}
@@ -143,12 +143,12 @@ public class DevicesSchemaScanNode extends
SchemaQueryScanNode {
return false;
}
DevicesSchemaScanNode that = (DevicesSchemaScanNode) o;
- return hasSgCol == that.hasSgCol && Objects.equals(schemaFilter,
that.schemaFilter);
+ return hasDbCol == that.hasDbCol && Objects.equals(schemaFilter,
that.schemaFilter);
}
@Override
public int hashCode() {
- return Objects.hash(super.hashCode(), hasSgCol, schemaFilter);
+ return Objects.hash(super.hashCode(), hasDbCol, schemaFilter);
}
@Override
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/fetcher/TableDeviceSchemaFetcher.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/fetcher/TableDeviceSchemaFetcher.java
index c910c8ac668..e6c6048fa6b 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/fetcher/TableDeviceSchemaFetcher.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/fetcher/TableDeviceSchemaFetcher.java
@@ -365,17 +365,17 @@ public class TableDeviceSchemaFetcher {
final Map<String, List<DeviceEntry>> deviceEntryMap,
final String database,
final TsTable tableInstance,
- final Map<Integer, List<SchemaFilter>> idFilters,
+ final Map<Integer, List<SchemaFilter>> tagFilters,
final Predicate<AlignedDeviceEntry> check,
final List<String> attributeColumns,
final List<IDeviceID> fetchPaths,
final boolean isDirectDeviceQuery,
final MPPQueryContext queryContext) {
- final String[] idValues = new String[tableInstance.getTagNum()];
- for (final List<SchemaFilter> schemaFilters : idFilters.values()) {
+ final String[] tagValues = new String[tableInstance.getTagNum()];
+ for (final List<SchemaFilter> schemaFilters : tagFilters.values()) {
final TagFilter tagFilter = (TagFilter) schemaFilters.get(0);
final SchemaFilter childFilter = tagFilter.getChild();
- idValues[tagFilter.getIndex()] = ((PreciseFilter)
childFilter).getValue();
+ tagValues[tagFilter.getIndex()] = ((PreciseFilter)
childFilter).getValue();
}
return !TreeViewSchema.isTreeViewTable(tableInstance)
@@ -387,9 +387,9 @@ public class TableDeviceSchemaFetcher {
attributeColumns,
fetchPaths,
isDirectDeviceQuery,
- idValues,
+ tagValues,
queryContext)
- : tryGetTreeDeviceInCache(deviceEntryMap, tableInstance, check,
fetchPaths, idValues);
+ : tryGetTreeDeviceInCache(deviceEntryMap, tableInstance, check,
fetchPaths, tagValues);
}
private boolean tryGetTableDeviceInCache(
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/AbstractQueryDeviceWithCache.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/AbstractQueryDeviceWithCache.java
index edd95930a2f..6dd24a1bb3b 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/AbstractQueryDeviceWithCache.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/AbstractQueryDeviceWithCache.java
@@ -65,15 +65,20 @@ public abstract class AbstractQueryDeviceWithCache extends
AbstractTraverseDevic
if (Objects.isNull(where)) {
return true;
}
- final Map<String, List<DeviceEntry>> entries = new HashMap<>();
- entries.put(database, new ArrayList<>());
+ final Map<String, List<DeviceEntry>> hitCacheEntries = new HashMap<>();
+ hitCacheEntries.put(database, new ArrayList<>());
- final boolean needFetch = super.parseWhere(entries, tableInstance,
attributeColumns, context);
+ final boolean needFetch =
+ super.parseWhere(hitCacheEntries, tableInstance, attributeColumns,
context);
if (!needFetch) {
context.reserveMemoryForFrontEnd(
-
entries.get(database).stream().map(DeviceEntry::ramBytesUsed).reduce(0L,
Long::sum));
+ hitCacheEntries.values().stream()
+ .flatMap(List::stream)
+ .map(DeviceEntry::ramBytesUsed)
+ .reduce(0L, Long::sum));
results =
- entries.get(database).stream()
+ hitCacheEntries.values().stream()
+ .flatMap(List::stream)
.map(
deviceEntry ->
ShowDevicesResult.convertDeviceEntry2ShowDeviceResult(
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/read/resp/info/impl/ShowDevicesResult.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/read/resp/info/impl/ShowDevicesResult.java
index 1c65fb32675..e290e1a24eb 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/read/resp/info/impl/ShowDevicesResult.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/read/resp/info/impl/ShowDevicesResult.java
@@ -39,8 +39,8 @@ public class ShowDevicesResult extends ShowSchemaResult
implements IDeviceSchema
private static final long INSTANCE_SIZE =
RamUsageEstimator.shallowSizeOfInstance(ShowDevicesResult.class);
- private Boolean isAligned;
- private int templateId;
+ private final Boolean isAligned;
+ private final int templateId;
private Function<String, Binary> attributeProvider;
diff --git
a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/planner/logical/SchemaQueryLogicalPlannerTest.java
b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/planner/logical/SchemaQueryLogicalPlannerTest.java
index 83efa9162aa..31de153d287 100644
---
a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/planner/logical/SchemaQueryLogicalPlannerTest.java
+++
b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/planner/logical/SchemaQueryLogicalPlannerTest.java
@@ -580,7 +580,7 @@ public class SchemaQueryLogicalPlannerTest {
(DevicesSchemaScanNode) metaMergeNode.getChildren().get(0);
Assert.assertNotNull(showDevicesNode);
Assert.assertEquals(new PartialPath("root.ln.wf01.wt01"),
showDevicesNode.getPath());
- Assert.assertTrue(showDevicesNode.isHasSgCol());
+ Assert.assertTrue(showDevicesNode.isHasDbCol());
Assert.assertEquals(30, showDevicesNode.getLimit());
Assert.assertEquals(0, showDevicesNode.getOffset());
Assert.assertTrue(showDevicesNode.isHasLimit());
@@ -613,7 +613,7 @@ public class SchemaQueryLogicalPlannerTest {
(DevicesSchemaScanNode) metaMergeNode.getChildren().get(0);
Assert.assertNotNull(showDevicesNode);
Assert.assertEquals(new PartialPath("root.ln.wf01.wt01"),
showDevicesNode.getPath());
- Assert.assertFalse(showDevicesNode.isHasSgCol());
+ Assert.assertFalse(showDevicesNode.isHasDbCol());
Assert.assertEquals(
SchemaFilterType.PATH_CONTAINS,
showDevicesNode.getSchemaFilter().getSchemaFilterType());
Assert.assertEquals(
@@ -630,7 +630,7 @@ public class SchemaQueryLogicalPlannerTest {
(DevicesSchemaScanNode) PlanNodeType.deserialize(byteBuffer);
Assert.assertNotNull(showDevicesNode2);
Assert.assertEquals(new PartialPath("root.ln.wf01.wt01"),
showDevicesNode2.getPath());
- Assert.assertFalse(showDevicesNode2.isHasSgCol());
+ Assert.assertFalse(showDevicesNode2.isHasDbCol());
Assert.assertEquals(
SchemaFilterType.PATH_CONTAINS,
showDevicesNode2.getSchemaFilter().getSchemaFilterType());
Assert.assertEquals(
diff --git
a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/schema/column/ColumnHeaderConstant.java
b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/schema/column/ColumnHeaderConstant.java
index 55fecde7c3d..7f6fedfc224 100644
---
a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/schema/column/ColumnHeaderConstant.java
+++
b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/schema/column/ColumnHeaderConstant.java
@@ -369,7 +369,7 @@ public class ColumnHeaderConstant {
new ColumnHeader(DEADBAND_PARAMETERS, TSDataType.TEXT),
new ColumnHeader(VIEW_TYPE, TSDataType.TEXT));
- public static final List<ColumnHeader> showDevicesWithSgColumnHeaders =
+ public static final List<ColumnHeader> showDevicesWithDbColumnHeaders =
ImmutableList.of(
new ColumnHeader(DEVICE, TSDataType.TEXT),
new ColumnHeader(DATABASE, TSDataType.TEXT),
