diff --git a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/analyzer/LimitOffsetPushDownTest.java b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/analyzer/LimitOffsetPushDownTest.java index 09e3d763d563..7bcf6f399fb9 100644 --- a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/analyzer/LimitOffsetPushDownTest.java +++ b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/analyzer/LimitOffsetPushDownTest.java @@ -69,7 +69,7 @@ public class LimitOffsetPushDownTest { public void noOrderByTest() { sql = "SELECT time, tag3, cast(s2 AS double) FROM table1 where s1>1 offset 5 limit 10"; context = new MPPQueryContext(sql, queryId, sessionInfo, null, null); - actualAnalysis = analyzeSQL(sql, metadata); + actualAnalysis = analyzeSQL(sql, metadata, context); logicalQueryPlan = new LogicalPlanner(context, metadata, sessionInfo, WarningCollector.NOOP) .plan(actualAnalysis); @@ -109,7 +109,7 @@ public void orderByAllTagsTest() { sql = "SELECT time, tag3, cast(s2 AS double) FROM table1 where s1>1 order by tag2 desc, tag1 asc, attr1 desc, tag3 desc, time desc, s1+s3 asc offset 5 limit 10"; context = new MPPQueryContext(sql, queryId, sessionInfo, null, null); - actualAnalysis = analyzeSQL(sql, metadata); + actualAnalysis = analyzeSQL(sql, metadata, context); logicalQueryPlan = new LogicalPlanner(context, metadata, sessionInfo, WarningCollector.NOOP) .plan(actualAnalysis); @@ -149,7 +149,7 @@ public void orderBySomeTagsTest() { sql = "SELECT time, tag3, cast(s2 AS double) FROM table1 where s1>1 order by tag2 desc, attr1 desc, tag3 desc, time desc, s1+s3 asc offset 5 limit 10"; context = new MPPQueryContext(sql, queryId, sessionInfo, null, null); - actualAnalysis = analyzeSQL(sql, metadata); + actualAnalysis = analyzeSQL(sql, metadata, context); logicalQueryPlan = new LogicalPlanner(context, metadata, sessionInfo, WarningCollector.NOOP) .plan(actualAnalysis); @@ -190,7 +190,7 @@ public void orderByTimeTest() { sql = "SELECT time, tag3, cast(s2 AS double) FROM table1 where s1>1 order by time desc, tag2 asc, s1+s3 asc offset 5 limit 10"; context = new MPPQueryContext(sql, queryId, sessionInfo, null, null); - actualAnalysis = analyzeSQL(sql, metadata); + actualAnalysis = analyzeSQL(sql, metadata, context); logicalQueryPlan = new LogicalPlanner(context, metadata, sessionInfo, WarningCollector.NOOP) .plan(actualAnalysis); @@ -230,7 +230,7 @@ public void orderByOthersTest() { sql = "SELECT time, tag3, cast(s2 AS double) FROM table1 where s1>1 order by s1 desc, tag2 desc, attr1 desc, tag3 desc, time desc, s1+s3 asc offset 5 limit 10"; context = new MPPQueryContext(sql, queryId, sessionInfo, null, null); - actualAnalysis = analyzeSQL(sql, metadata); + actualAnalysis = analyzeSQL(sql, metadata, context); logicalQueryPlan = new LogicalPlanner(context, metadata, sessionInfo, WarningCollector.NOOP) .plan(actualAnalysis); diff --git a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/analyzer/SortTest.java b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/analyzer/SortTest.java index 7feb9dc1b1cf..238bacc81800 100644 --- a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/analyzer/SortTest.java +++ b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/analyzer/SortTest.java @@ -100,7 +100,7 @@ public void someIDColumnTimeOthersSortTest() { "SELECT time, tag3, tag1, cast(s2 as double), s2+s3, attr1 FROM table1 " + "where s1>1 and s1+s3>0 and cast(s1 as double)>1.0 order by tag2 desc, tag3 asc, time desc, s1+s2 desc offset 5 limit 10"; context = new MPPQueryContext(sql, queryId, sessionInfo, null, null); - actualAnalysis = analyzeSQL(sql, metadata); + actualAnalysis = analyzeSQL(sql, metadata, context); logicalQueryPlan = new LogicalPlanner(context, metadata, sessionInfo, warningCollector).plan(actualAnalysis); rootNode = logicalQueryPlan.getRootNode(); @@ -176,7 +176,7 @@ public void someIDColumnTimeOthersSortTest() { sql = "SELECT * FROM table1 order by tag2 desc, tag3 asc offset 5 limit 10"; context = new MPPQueryContext(sql, queryId, sessionInfo, null, null); - actualAnalysis = analyzeSQL(sql, metadata); + actualAnalysis = analyzeSQL(sql, metadata, context); logicalQueryPlan = new LogicalPlanner(context, metadata, sessionInfo, warningCollector).plan(actualAnalysis); rootNode = logicalQueryPlan.getRootNode(); @@ -202,7 +202,7 @@ public void allIDColumnTimeSortWithLimitTest() { "SELECT time, tag3, tag1, cast(s2 as double), s2+s3, attr1 FROM table1 " + "where s1>1 and s1+s3>0 and cast(s1 as double)>1.0 order by tag2 desc, tag1 desc, tag3 asc, time desc, s1+s2 desc offset 5 limit 10"; context = new MPPQueryContext(sql, queryId, sessionInfo, null, null); - actualAnalysis = analyzeSQL(sql, metadata); + actualAnalysis = analyzeSQL(sql, metadata, context); logicalQueryPlan = new LogicalPlanner(context, metadata, sessionInfo, warningCollector).plan(actualAnalysis); rootNode = logicalQueryPlan.getRootNode(); @@ -280,7 +280,7 @@ public void allIDColumnTimeSortNoLimitTest() { "SELECT time, tag3, tag1, cast(s2 as double), s2+s3, attr1 FROM table1 " + "where s1>1 and s1+s3>0 and cast(s1 as double)>1.0 order by tag2 desc, tag1 desc, tag3 asc, time desc, s1+s2 desc"; context = new MPPQueryContext(sql, queryId, sessionInfo, null, null); - actualAnalysis = analyzeSQL(sql, metadata); + actualAnalysis = analyzeSQL(sql, metadata, context); logicalQueryPlan = new LogicalPlanner(context, metadata, sessionInfo, warningCollector).plan(actualAnalysis); rootNode = logicalQueryPlan.getRootNode(); @@ -348,7 +348,7 @@ public void someIDColumnOthersTimeSortTest() { "SELECT time, tag3, tag1, cast(s2 as double), s2+s3, attr1 FROM table1 " + "where s1>1 and s1+s3>0 and cast(s1 as double)>1.0 order by tag2 desc, tag1 desc, s1+s2 desc, time desc offset 5 limit 10"; context = new MPPQueryContext(sql, queryId, sessionInfo, null, null); - actualAnalysis = analyzeSQL(sql, metadata); + actualAnalysis = analyzeSQL(sql, metadata, context); logicalQueryPlan = new LogicalPlanner(context, metadata, sessionInfo, warningCollector).plan(actualAnalysis); rootNode = logicalQueryPlan.getRootNode(); @@ -428,7 +428,7 @@ public void allIDColumnOthersTimeSortTest() { "SELECT time, tag3, tag1, cast(s2 as double), s2+s3, attr1 FROM table1 " + "where s1>1 and s1+s3>0 and cast(s1 as double)>1.0 order by tag2 desc, tag1 desc, tag3 asc, s1+s2 desc, time desc offset 5 limit 10"; context = new MPPQueryContext(sql, queryId, sessionInfo, null, null); - actualAnalysis = analyzeSQL(sql, metadata); + actualAnalysis = analyzeSQL(sql, metadata, context); logicalQueryPlan = new LogicalPlanner(context, metadata, sessionInfo, warningCollector).plan(actualAnalysis); rootNode = logicalQueryPlan.getRootNode(); @@ -506,7 +506,7 @@ public void orderByTimeTest() { sql = "SELECT time, tag3, tag1, cast(s2 as double), s2+s3, attr1 FROM table1 order by time desc, tag2 asc, tag3 desc, s1+s2 desc offset 5 limit 10"; context = new MPPQueryContext(sql, queryId, sessionInfo, null, null); - actualAnalysis = analyzeSQL(sql, metadata); + actualAnalysis = analyzeSQL(sql, metadata, context); logicalQueryPlan = new LogicalPlanner(context, metadata, sessionInfo, warningCollector).plan(actualAnalysis); rootNode = logicalQueryPlan.getRootNode(); @@ -518,7 +518,7 @@ public void orderByTimeTest() { "SELECT time, tag3, substring(tag1, 1), cast(s2 as double), s2+s3, attr1 FROM table1 " + "where s1>1 and s1+s3>0 and cast(s1 as double)>1.0 order by time desc, s1+s2 asc, tag2 asc, tag1 desc offset 5 limit 10"; context = new MPPQueryContext(sql, queryId, sessionInfo, null, null); - actualAnalysis = analyzeSQL(sql, metadata); + actualAnalysis = analyzeSQL(sql, metadata, context); logicalQueryPlan = new LogicalPlanner(context, metadata, sessionInfo, warningCollector).plan(actualAnalysis); rootNode = logicalQueryPlan.getRootNode(); @@ -529,7 +529,7 @@ public void orderByTimeTest() { "SELECT time, tag3, tag1, cast(s2 as double), s2+s3, attr1 FROM table1 " + "where s1>1 and s1+s3>0 and cast(s1 as double)>1.0 order by time desc, s1+s2 asc, tag2 asc, tag3 desc, tag1 desc offset 5 limit 10"; context = new MPPQueryContext(sql, queryId, sessionInfo, null, null); - actualAnalysis = analyzeSQL(sql, metadata); + actualAnalysis = analyzeSQL(sql, metadata, context); logicalQueryPlan = new LogicalPlanner(context, metadata, sessionInfo, warningCollector).plan(actualAnalysis); rootNode = logicalQueryPlan.getRootNode(); @@ -540,7 +540,7 @@ public void orderByTimeTest() { "SELECT time, tag3, tag1, cast(s2 as double), s2+s3, attr1 FROM table1 " + "where s1>1 and s1+s3>0 and cast(s1 as double)>1.0 order by time desc, tag2 asc, tag3 desc, tag1 asc, s1+s2 desc offset 5 limit 10"; context = new MPPQueryContext(sql, queryId, sessionInfo, null, null); - actualAnalysis = analyzeSQL(sql, metadata); + actualAnalysis = analyzeSQL(sql, metadata, context); logicalQueryPlan = new LogicalPlanner(context, metadata, sessionInfo, warningCollector).plan(actualAnalysis); rootNode = logicalQueryPlan.getRootNode(); @@ -555,7 +555,7 @@ public void orderByOthersTest() { "SELECT time, tag3, tag1, cast(s2 as double), s2+s3, attr1 FROM table1 " + "order by s1+s2 desc, tag2 desc, tag1 desc, time desc offset 5 limit 10"; context = new MPPQueryContext(sql, queryId, sessionInfo, null, null); - actualAnalysis = analyzeSQL(sql, metadata); + actualAnalysis = analyzeSQL(sql, metadata, context); logicalQueryPlan = new LogicalPlanner(context, metadata, sessionInfo, warningCollector).plan(actualAnalysis); rootNode = logicalQueryPlan.getRootNode(); @@ -566,7 +566,7 @@ public void orderByOthersTest() { "SELECT time, tag3, tag1, cast(s2 as double), s2+s3, attr1 FROM table1 " + "where s1>1 and s1+s3>0 and cast(s1 as double)>1.0 order by s1+s2 desc, tag2 desc, tag1 desc, tag3 desc, time asc offset 5 limit 10"; context = new MPPQueryContext(sql, queryId, sessionInfo, null, null); - actualAnalysis = analyzeSQL(sql, metadata); + actualAnalysis = analyzeSQL(sql, metadata, context); logicalQueryPlan = new LogicalPlanner(context, metadata, sessionInfo, warningCollector).plan(actualAnalysis); rootNode = logicalQueryPlan.getRootNode(); @@ -577,7 +577,7 @@ public void orderByOthersTest() { "SELECT time, tag3, tag1, cast(s2 as double), s2+s3, attr1 FROM table1 " + "where s1>1 and s1+s3>0 and cast(s1 as double)>1.0 order by s1+s2 desc, time desc, tag2 desc, tag1 desc offset 5 limit 10"; context = new MPPQueryContext(sql, queryId, sessionInfo, null, null); - actualAnalysis = analyzeSQL(sql, metadata); + actualAnalysis = analyzeSQL(sql, metadata, context); logicalQueryPlan = new LogicalPlanner(context, metadata, sessionInfo, warningCollector).plan(actualAnalysis); rootNode = logicalQueryPlan.getRootNode(); @@ -588,7 +588,7 @@ public void orderByOthersTest() { "SELECT time, tag3, tag1, cast(s2 as double), s2+s3, attr1 FROM table1 " + "where s1>1 and s1+s3>0 and cast(s1 as double)>1.0 order by s1+s2 desc, time desc, tag2 desc, tag1 desc, tag3 asc offset 5 limit 10"; context = new MPPQueryContext(sql, queryId, sessionInfo, null, null); - actualAnalysis = analyzeSQL(sql, metadata); + actualAnalysis = analyzeSQL(sql, metadata, context); logicalQueryPlan = new LogicalPlanner(context, metadata, sessionInfo, warningCollector).plan(actualAnalysis); rootNode = logicalQueryPlan.getRootNode();