Skip to content

Commit 5930394

Browse files
codeDing18codeDing18
committed
[fix](test) Fix the unstable test
1 parent 7665c07 commit 5930394

File tree

1 file changed

+39
-39
lines changed

1 file changed

+39
-39
lines changed

‎fe/fe-core/src/test/java/org/apache/doris/nereids/trees/plans/commands/TruncateTableCommandTest.java

Lines changed: 39 additions & 39 deletions
Original file line numberDiff line numberDiff line change
@@ -52,18 +52,18 @@ public class TruncateTableCommandTest extends TestWithFeService {
5252
@Override
5353
protected void runBeforeAll() throws Exception {
5454
Config.enable_debug_points = true;
55-
createDatabase("test");
56-
connectContext.setDatabase("test");
55+
createDatabase("testcommand");
56+
connectContext.setDatabase("testcommand");
5757

58-
String createTableStr = "create table test.tbl(d1 date, k1 int, k2 bigint)"
58+
String createTableStr = "create table testcommand.tblcommand(d1 date, k1 int, k2 bigint)"
5959
+ "duplicate key(d1, k1) "
6060
+ "PARTITION BY RANGE(d1)"
6161
+ "(PARTITION p20210901 VALUES [('2021-09-01'), ('2021-09-02')))"
6262
+ "distributed by hash(k1) buckets 2 "
6363
+ "properties('replication_num' = '1');";
6464
createTable(createTableStr);
6565

66-
String createTable2 = "CREATE TABLE test.case_sensitive_table (\n"
66+
String createTable2 = "CREATE TABLE testcommand.case_sensitive_table_command (\n"
6767
+ " `date_id` date NULL COMMENT \"\",\n"
6868
+ " `column2` tinyint(4) NULL COMMENT \"\"\n"
6969
+ ") ENGINE=OLAP\n"
@@ -93,7 +93,7 @@ public void testValidate(@Mocked Env env, @Mocked AccessControllerManager access
9393
}
9494
};
9595

96-
String truncateStr = "TRUNCATE TABLE internal.test.case_sensitive_table PARTITION P20211008; \n";
96+
String truncateStr = "TRUNCATE TABLE internal.testcommand.case_sensitive_table_command PARTITION P20211008; \n";
9797

9898
NereidsParser nereidsParser = new NereidsParser();
9999
LogicalPlan plan = nereidsParser.parseSingle(truncateStr);
@@ -108,12 +108,12 @@ public void testValidate(@Mocked Env env, @Mocked AccessControllerManager access
108108
connectContext.setDatabase("test"); //reset database
109109

110110
// test no table
111-
tableNameInfo = new TableNameInfo("internal", "test", "");
111+
tableNameInfo = new TableNameInfo("internal", "testcommand", "");
112112
TruncateTableCommand truncateTableCommand1 = new TruncateTableCommand(tableNameInfo, Optional.empty(), false);
113113
Assertions.assertThrows(AnalysisException.class, () -> truncateTableCommand1.validate(connectContext));
114114

115115
// test no partition
116-
tableNameInfo = new TableNameInfo("internal", "test", "test");
116+
tableNameInfo = new TableNameInfo("internal", "testcommand", "test");
117117
PartitionNamesInfo partitionNamesInfo = new PartitionNamesInfo(false);
118118
TruncateTableCommand truncateTableCommand2 = new TruncateTableCommand(tableNameInfo, Optional.of(partitionNamesInfo), false);
119119
Assertions.assertThrows(AnalysisException.class, () -> truncateTableCommand2.validate(connectContext));
@@ -122,8 +122,8 @@ public void testValidate(@Mocked Env env, @Mocked AccessControllerManager access
122122
@Test
123123
public void testTruncateWithCaseInsensitivePartitionName() throws Exception {
124124
//now in order to support auto create partition, need set partition name is case sensitive
125-
Database db = Env.getCurrentInternalCatalog().getDbNullable("test");
126-
OlapTable tbl = db.getOlapTableOrDdlException("case_sensitive_table");
125+
Database db = Env.getCurrentInternalCatalog().getDbNullable("testcommand");
126+
OlapTable tbl = db.getOlapTableOrDdlException("case_sensitive_table_command");
127127

128128
long p20211006Id = tbl.getPartition("p20211006").getId();
129129
long p20211007Id = tbl.getPartition("P20211007").getId();
@@ -133,7 +133,7 @@ public void testTruncateWithCaseInsensitivePartitionName() throws Exception {
133133
Partition p20211008 = tbl.getPartition("P20211008");
134134
p20211008.updateVisibleVersion(2L);
135135
p20211008.setNextVersion(p20211008.getVisibleVersion() + 1);
136-
String truncateStr = "TRUNCATE TABLE internal.test.case_sensitive_table PARTITION P20211008; \n";
136+
String truncateStr = "TRUNCATE TABLE internal.testcommand.case_sensitive_table_command PARTITION P20211008; \n";
137137

138138
NereidsParser nereidsParser = new NereidsParser();
139139
LogicalPlan plan = nereidsParser.parseSingle(truncateStr);
@@ -142,7 +142,7 @@ public void testTruncateWithCaseInsensitivePartitionName() throws Exception {
142142
Assertions.assertNotEquals(p20211008Id, tbl.getPartition("P20211008").getId());
143143

144144
// 2. truncate P20211007
145-
truncateStr = "TRUNCATE TABLE internal.test.case_sensitive_table PARTITION P20211007 force; \n";
145+
truncateStr = "TRUNCATE TABLE internal.testcommand.case_sensitive_table_command PARTITION P20211007 force; \n";
146146
plan = nereidsParser.parseSingle(truncateStr);
147147
Assertions.assertTrue(plan instanceof TruncateTableCommand);
148148
Env.getCurrentEnv().truncateTable((TruncateTableCommand) plan);
@@ -156,77 +156,77 @@ public void testTruncateWithCaseInsensitivePartitionName() throws Exception {
156156

157157
@Test
158158
public void testTruncateTable() throws Exception {
159-
String stmtStr = "ALTER TABLE internal.test.tbl ADD PARTITION p20210902 VALUES [('2021-09-02'), ('2021-09-03'))"
159+
String stmtStr = "ALTER TABLE internal.testcommand.tblcommand ADD PARTITION p20210902 VALUES [('2021-09-02'), ('2021-09-03'))"
160160
+ " DISTRIBUTED BY HASH(`k1`) BUCKETS 3;";
161161
alterTable(stmtStr);
162-
stmtStr = "ALTER TABLE internal.test.tbl ADD PARTITION p20210903 VALUES [('2021-09-03'), ('2021-09-04'))"
162+
stmtStr = "ALTER TABLE internal.testcommand.tblcommand ADD PARTITION p20210903 VALUES [('2021-09-03'), ('2021-09-04'))"
163163
+ " DISTRIBUTED BY HASH(`k1`) BUCKETS 4;";
164164
alterTable(stmtStr);
165-
stmtStr = "ALTER TABLE internal.test.tbl ADD PARTITION p20210904 VALUES [('2021-09-04'), ('2021-09-05'))"
165+
stmtStr = "ALTER TABLE internal.testcommand.tblcommand ADD PARTITION p20210904 VALUES [('2021-09-04'), ('2021-09-05'))"
166166
+ " DISTRIBUTED BY HASH(`k1`) BUCKETS 5;";
167167
alterTable(stmtStr);
168-
checkShowTabletResultNum("internal.test.tbl", "p20210901", 2);
169-
checkShowTabletResultNum("internal.test.tbl", "p20210902", 3);
170-
checkShowTabletResultNum("internal.test.tbl", "p20210903", 4);
171-
checkShowTabletResultNum("internal.test.tbl", "p20210904", 5);
168+
checkShowTabletResultNum("internal.testcommand.tblcommand", "p20210901", 2);
169+
checkShowTabletResultNum("internal.testcommand.tblcommand", "p20210902", 3);
170+
checkShowTabletResultNum("internal.testcommand.tblcommand", "p20210903", 4);
171+
checkShowTabletResultNum("internal.testcommand.tblcommand", "p20210904", 5);
172172

173-
String truncateStr = "truncate table internal.test.tbl;";
173+
String truncateStr = "truncate table internal.testcommand.tblcommand;";
174174
NereidsParser nereidsParser = new NereidsParser();
175175
LogicalPlan plan = nereidsParser.parseSingle(truncateStr);
176176
Assertions.assertTrue(plan instanceof TruncateTableCommand);
177177
Env.getCurrentEnv().truncateTable((TruncateTableCommand) plan);
178178

179-
checkShowTabletResultNum("internal.test.tbl", "p20210901", 2);
180-
checkShowTabletResultNum("internal.test.tbl", "p20210902", 3);
181-
checkShowTabletResultNum("internal.test.tbl", "p20210903", 4);
182-
checkShowTabletResultNum("internal.test.tbl", "p20210904", 5);
179+
checkShowTabletResultNum("internal.testcommand.tblcommand", "p20210901", 2);
180+
checkShowTabletResultNum("internal.testcommand.tblcommand", "p20210902", 3);
181+
checkShowTabletResultNum("internal.testcommand.tblcommand", "p20210903", 4);
182+
checkShowTabletResultNum("internal.testcommand.tblcommand", "p20210904", 5);
183183

184-
truncateStr = "truncate table internal.test.tbl partition(p20210901, p20210902, p20210903, p20210904);";
184+
truncateStr = "truncate table internal.testcommand.tblcommand partition(p20210901, p20210902, p20210903, p20210904);";
185185
plan = nereidsParser.parseSingle(truncateStr);
186186
Assertions.assertTrue(plan instanceof TruncateTableCommand);
187187
Env.getCurrentEnv().truncateTable((TruncateTableCommand) plan);
188188

189-
checkShowTabletResultNum("internal.test.tbl", "p20210901", 2);
190-
checkShowTabletResultNum("internal.test.tbl", "p20210902", 3);
191-
checkShowTabletResultNum("internal.test.tbl", "p20210903", 4);
192-
checkShowTabletResultNum("internal.test.tbl", "p20210904", 5);
189+
checkShowTabletResultNum("internal.testcommand.tblcommand", "p20210901", 2);
190+
checkShowTabletResultNum("internal.testcommand.tblcommand", "p20210902", 3);
191+
checkShowTabletResultNum("internal.testcommand.tblcommand", "p20210903", 4);
192+
checkShowTabletResultNum("internal.testcommand.tblcommand", "p20210904", 5);
193193

194-
truncateStr = "truncate table internal.test.tbl partition (p20210901);";
194+
truncateStr = "truncate table internal.testcommand.tblcommand partition (p20210901);";
195195
plan = nereidsParser.parseSingle(truncateStr);
196196
Assertions.assertTrue(plan instanceof TruncateTableCommand);
197197
Env.getCurrentEnv().truncateTable((TruncateTableCommand) plan);
198-
checkShowTabletResultNum("internal.test.tbl", "p20210901", 2);
198+
checkShowTabletResultNum("internal.testcommand.tblcommand", "p20210901", 2);
199199

200-
truncateStr = "truncate table internal.test.tbl partition (p20210902);";
200+
truncateStr = "truncate table internal.testcommand.tblcommand partition (p20210902);";
201201
plan = nereidsParser.parseSingle(truncateStr);
202202
Assertions.assertTrue(plan instanceof TruncateTableCommand);
203203
Env.getCurrentEnv().truncateTable((TruncateTableCommand) plan);
204-
checkShowTabletResultNum("internal.test.tbl", "p20210902", 3);
204+
checkShowTabletResultNum("internal.testcommand.tblcommand", "p20210902", 3);
205205

206-
truncateStr = "truncate table internal.test.tbl partition (p20210903);";
206+
truncateStr = "truncate table internal.testcommand.tblcommand partition (p20210903);";
207207
plan = nereidsParser.parseSingle(truncateStr);
208208
Assertions.assertTrue(plan instanceof TruncateTableCommand);
209209
Env.getCurrentEnv().truncateTable((TruncateTableCommand) plan);
210-
checkShowTabletResultNum("internal.test.tbl", "p20210903", 4);
210+
checkShowTabletResultNum("internal.testcommand.tblcommand", "p20210903", 4);
211211

212-
truncateStr = "truncate table internal.test.tbl partition (p20210904);";
212+
truncateStr = "truncate table internal.testcommand.tblcommand partition (p20210904);";
213213
plan = nereidsParser.parseSingle(truncateStr);
214214
Assertions.assertTrue(plan instanceof TruncateTableCommand);
215215
Env.getCurrentEnv().truncateTable((TruncateTableCommand) plan);
216-
checkShowTabletResultNum("internal.test.tbl", "p20210904", 5);
216+
checkShowTabletResultNum("internal.testcommand.tblcommand", "p20210904", 5);
217217
}
218218

219219
@Test
220220
public void testTruncateTableFailed() throws Exception {
221-
String createTableStr = "create table internal.test.tbl2(d1 date, k1 int, k2 bigint)"
221+
String createTableStr = "create table internal.testcommand.tbl2(d1 date, k1 int, k2 bigint)"
222222
+ "duplicate key(d1, k1) "
223223
+ "PARTITION BY RANGE(d1)"
224224
+ "(PARTITION p20210901 VALUES [('2021-09-01'), ('2021-09-02')))"
225225
+ "distributed by hash(k1) buckets 2 "
226226
+ "properties('replication_num' = '1');";
227227
createTable(createTableStr);
228228
String partitionName = "p20210901";
229-
Database db = Env.getCurrentInternalCatalog().getDbNullable("test");
229+
Database db = Env.getCurrentInternalCatalog().getDbNullable("testcommand");
230230
OlapTable tbl2 = db.getOlapTableOrDdlException("tbl2");
231231
Assertions.assertNotNull(tbl2);
232232

@@ -245,7 +245,7 @@ public void testTruncateTableFailed() throws Exception {
245245
}
246246

247247
DebugPointUtil.addDebugPoint("InternalCatalog.truncateTable.metaChanged", new DebugPointUtil.DebugPoint());
248-
String truncateStr = "truncate table internal.test.tbl2 partition (" + partitionName + ");";
248+
String truncateStr = "truncate table internal.testcommand.tbl2 partition (" + partitionName + ");";
249249

250250
NereidsParser nereidsParser = new NereidsParser();
251251
LogicalPlan plan = nereidsParser.parseSingle(truncateStr);

0 commit comments

Comments
 (0)