fix test

Author: yujun777

regression-test/suites/autobucket/test_autobucket.groovy

@@ -17,7 +17,7 @@
 
 suite("test_autobucket") {
     sql "drop table if exists autobucket_test"
-    result = sql """
+    def result = sql """
         CREATE TABLE `autobucket_test` (
           `user_id` largeint(40) NOT NULL
         ) ENGINE=OLAP
@@ -32,11 +32,11 @@ suite("test_autobucket") {
     result = sql "show create table autobucket_test"
     assertTrue(result.toString().containsIgnoreCase("BUCKETS AUTO"))
 
-    result = sql "show partitions from autobucket_test"
+    result = sql_return_maparray "show partitions from autobucket_test"
     logger.info("${result}")
     // XXX: buckets at pos(8), next maybe impl by sql meta
     // 10 is the default buckets without partition size
-    assertEquals(Integer.valueOf(result.get(0).get(8)), 10)
+    assertEquals(Integer.valueOf(result.get(0).Buckets), 10)
 
     sql "drop table if exists autobucket_test"
 
@@ -56,10 +56,10 @@ suite("test_autobucket") {
         """
 
     default_min_buckets = 1 // in Config.java
-    result = sql "show partitions from autobucket_test_min_buckets"
+    result = sql_return_maparray "show partitions from autobucket_test_min_buckets"
     logger.info("${result}")
     // XXX: buckets at pos(8), next maybe impl by sql meta
-    assertEquals(Integer.valueOf(result.get(0).get(8)), default_min_buckets)
+    assertEquals(Integer.valueOf(result.get(0).Buckets), default_min_buckets)
 
     sql "drop table if exists autobucket_test_min_buckets"
 }

regression-test/suites/autobucket/test_autobucket_dynamic_partition.groovy

@@ -17,7 +17,7 @@
 
 suite("test_autobucket_dynamic_partition") {
     sql "drop table if exists test_autobucket_dynamic_partition"
-    result = sql """
+    def result = sql """
         CREATE TABLE
         test_autobucket_dynamic_partition (k1 DATETIME)
         PARTITION BY
@@ -35,14 +35,14 @@ suite("test_autobucket_dynamic_partition") {
     result = sql "show create table test_autobucket_dynamic_partition"
     assertTrue(result.toString().containsIgnoreCase("BUCKETS AUTO"))
 
-    result = sql "show partitions from test_autobucket_dynamic_partition"
+    result = sql_return_maparray "show partitions from test_autobucket_dynamic_partition"
     logger.info("${result}")
     // XXX: buckets at pos(8), next maybe impl by sql meta
     // 10 is the default buckets without partition size
     assertEquals(result.size(), 3)
-    assertEquals(Integer.valueOf(result.get(0).get(8)), 10)
-    assertEquals(Integer.valueOf(result.get(1).get(8)), 10)
-    assertEquals(Integer.valueOf(result.get(2).get(8)), 10)
+    for (def partition : result) {
+        assertEquals(Integer.valueOf(partition.Buckets), 10)
+    }
 
     sql "drop table if exists test_autobucket_dynamic_partition"
 }

regression-test/suites/cold_heat_separation/empty_table_use_policy/modify_partition_add_policy.groovy

@@ -130,12 +130,12 @@ suite("add_table_policy_by_modify_partition") {
     """
 
     // Test that the partition's specified policy would be covered by the table's policy
-    def partitions = sql """
+    def partitions = sql_return_maparray """
     show partitions from create_table_partion_use_created_policy_test
     """
 
-    for (par in partitions) {
-        assertTrue(par[12] == "created_create_table_partition_alter_policy")
+    for (def par in partitions) {
+        assertTrue(par.RemoteStoragePolicy == "created_create_table_partition_alter_policy")
     }
 
     sql """

regression-test/suites/partition_p0/dynamic_partition/test_dynamic_partition.groovy

@@ -32,12 +32,12 @@ suite("test_dynamic_partition") {
             "dynamic_partition.create_history_partition"="true",
             "dynamic_partition.replication_allocation" = "tag.location.default: 1")
         """
-    List<List<Object>> result  = sql "show tables like 'dy_par'"
+    def result  = sql "show tables like 'dy_par'"
     logger.info("${result}")
     assertEquals(result.size(), 1)
-    result = sql "show partitions from dy_par"
+    result = sql_return_maparray "show partitions from dy_par"
     // XXX: buckets at pos(8), next maybe impl by sql meta
-    assertEquals(Integer.valueOf(result.get(0).get(8)), 10)
+    assertEquals(Integer.valueOf(result.get(0).Buckets, 10)
     sql "drop table dy_par"
 
     sql "drop table if exists dy_par"
@@ -59,9 +59,9 @@ suite("test_dynamic_partition") {
     result  = sql "show tables like 'dy_par'"
     logger.info("${result}")
     assertEquals(result.size(), 1)
-    result = sql "show partitions from dy_par"
+    result = sql_return_maparray "show partitions from dy_par"
     // XXX: buckets at pos(8), next maybe impl by sql meta
-    assertEquals(Integer.valueOf(result.get(0).get(8)), 10)
+    assertEquals(Integer.valueOf(result.get(0).Buckets), 10)
     sql "drop table dy_par"
 
     sql "drop table if exists dy_par_bucket_set_by_distribution"
@@ -83,9 +83,9 @@ suite("test_dynamic_partition") {
     result  = sql "show tables like 'dy_par_bucket_set_by_distribution'"
     logger.info("${result}")
     assertEquals(result.size(), 1)
-    result = sql "show partitions from dy_par_bucket_set_by_distribution"
+    result = sql_return_maparray "show partitions from dy_par_bucket_set_by_distribution"
     // XXX: buckets at pos(8), next maybe impl by sql meta
-    assertEquals(Integer.valueOf(result.get(0).get(8)), 3)
+    assertEquals(Integer.valueOf(result.get(0).Buckets), 3)
     sql "drop table dy_par_bucket_set_by_distribution"
     sql "drop table if exists dy_par_bad"
     test {

regression-test/suites/partition_p0/dynamic_partition/test_dynamic_partition_with_rename.groovy

@@ -34,26 +34,26 @@ suite("test_dynamic_partition_with_rename") {
             "dynamic_partition.create_history_partition"="true",
             "dynamic_partition.replication_allocation" = "tag.location.default: 1")
         """
-    def result = sql "show partitions from ${tbl}"
+    def result = sql_return_maparray "show partitions from ${tbl}"
     assertEquals(7, result.size())
 
     // rename distributed column, then try to add too more dynamic partition
     sql "alter table ${tbl} rename column k1 renamed_k1"
     sql """ ADMIN SET FRONTEND CONFIG ('dynamic_partition_check_interval_seconds' = '1') """
     sql """ alter table ${tbl} set('dynamic_partition.end'='5') """
-    result = sql "show partitions from ${tbl}"
+    result = sql_return_maparray "show partitions from ${tbl}"
     for (def retry = 0; retry < 120; retry++) { // at most wait 120s
         if (result.size() == 9) {
             break;
         }
         logger.info("wait dynamic partition scheduler, sleep 1s")
         sleep(1000); // sleep 1s
-        result = sql "show partitions from ${tbl}"
+        result = sql_return_maparray "show partitions from ${tbl}"
     }
     assertEquals(9, result.size())
     for (def line = 0; line < result.size(); line++) {
         // XXX: DistributionKey at pos(7), next maybe impl by sql meta
-        assertEquals("renamed_k1", result.get(line).get(7))
+        assertEquals("renamed_k1", result.get(line).DistributionKey)
     }
 
     sql "drop table ${tbl}"

regression-test/suites/partition_p0/multi_partition/test_multi_column_partition.groovy

@@ -55,7 +55,7 @@ suite("test_multi_partition_key", "p0") {
             sql "select * from ${tableName} order by k1, k2"
             resultFile "partition_table.out"
         }
-        def result = sql "SHOW PARTITIONS FROM ${tableName}"
+        def result = sql_return_maparray "SHOW PARTITIONS FROM ${tableName}"
         assertTrue(result.size() > 1)
         if (ifDropTbl) {
             try_sql """DROP TABLE ${tableName}"""
@@ -143,8 +143,8 @@ suite("test_multi_partition_key", "p0") {
             false
     )
     // expect partition_f range: [ [126, 126] ~ [500, -128] )
-    def ret = sql "SHOW PARTITIONS FROM test_default_minvalue WHERE PartitionName='partition_f'"
-    assertTrue(ret[0][6].contains("[500, -128]"))
+    def ret = sql_return_maparray "SHOW PARTITIONS FROM test_default_minvalue WHERE PartitionName='partition_f'"
+    assertTrue(ret[0].Range.contains("[500, -128]"))
 
     // partition columns error
     test {
@@ -225,8 +225,8 @@ suite("test_multi_partition_key", "p0") {
     }
 
     sql "ALTER TABLE test_multi_col_test_partition_add ADD PARTITION partition_add VALUES LESS THAN ('30', '1000') "
-    def ret_add_p = sql "SHOW PARTITIONS FROM test_multi_col_test_partition_add WHERE PartitionName='partition_add'"
-    assertTrue(ret[0][6].contains("[500, -128]"))
+    def ret_add_p = sql_return_maparray "SHOW PARTITIONS FROM test_multi_col_test_partition_add WHERE PartitionName='partition_add'"
+    assertTrue(ret[0].Range.contains("[500, -128]"))
     test {
         sql "ALTER TABLE test_multi_col_test_partition_add ADD PARTITION add_partition_wrong " +
                 "VALUES LESS THAN ('30', '800') DISTRIBUTED BY hash(k1) BUCKETS 5"
@@ -247,11 +247,11 @@ suite("test_multi_partition_key", "p0") {
             false
     )
     sql "ALTER TABLE test_multi_col_test_partition_drop DROP PARTITION partition_d"
-    def ret_drop_p = sql "SHOW PARTITIONS FROM test_multi_col_test_partition_drop WHERE PartitionName='partition_d'"
+    def ret_drop_p = sql_return_maparray "SHOW PARTITIONS FROM test_multi_col_test_partition_drop WHERE PartitionName='partition_d'"
     assertEquals(0, ret_drop_p.size())
     sql "ALTER TABLE test_multi_col_test_partition_drop ADD PARTITION partition_dd VALUES LESS THAN ('0','0') "
-    ret_drop_p = sql "SHOW PARTITIONS FROM test_multi_col_test_partition_drop WHERE PartitionName='partition_dd'"
-    assertTrue(ret_drop_p[0][6].contains("[0, 0]"))
+    ret_drop_p = sql_return_maparray "SHOW PARTITIONS FROM test_multi_col_test_partition_drop WHERE PartitionName='partition_dd'"
+    assertTrue(ret_drop_p[0].Range.contains("[0, 0]"))
     // null value in the lowest partition, if drop the partition null is deleted.
     sql """drop table if exists test_multi_col_test_partition_null_value"""
     sql """
@@ -367,8 +367,8 @@ suite("test_multi_partition_key", "p0") {
     qt_sql12 "select * from test_multi_col_test_rollup order by k1, k2"
     // test partition modify, check partition replication_num
     sql "ALTER TABLE test_multi_col_test_rollup MODIFY PARTITION partition_a SET( 'replication_num' = '1')"
-    ret = sql "SHOW PARTITIONS FROM test_multi_col_test_rollup WHERE PartitionName='partition_a'"
-    assertEquals('1', ret[0][9])
+    ret = sql_return_maparray "SHOW PARTITIONS FROM test_multi_col_test_rollup WHERE PartitionName='partition_a'"
+    assertEquals(1, ret[0].ReplicationNum as int)
     // create table with range partition
     testPartitionTbl(
             "test_multi_column_fixed_range_1",
@@ -394,7 +394,7 @@ suite("test_multi_partition_key", "p0") {
     )
     // add partition with range
     sql "ALTER TABLE test_multi_column_fixed_range_1 ADD PARTITION partition_add VALUES LESS THAN ('50','1000') "
-    ret = sql "SHOW PARTITIONS FROM test_multi_column_fixed_range_1 WHERE PartitionName='partition_add'"
+    ret = sql_return_maparray "SHOW PARTITIONS FROM test_multi_column_fixed_range_1 WHERE PartitionName='partition_add'"
     assertEquals(1, ret.size(), )
     test {
         sql "ALTER TABLE test_multi_column_fixed_range_1 ADD PARTITION add_partition_wrong VALUES LESS THAN ('50','800')"

regression-test/suites/partition_p1/auto_partition/sql/multi_thread_load.groovy

@@ -189,10 +189,10 @@ suite("multi_thread_load") {
     def row_count_range = sql """select count() from ${table_name};"""
     assertTrue(data_count*rows == row_count_range[0][0], "${data_count*rows}, ${row_count_range[0][0]}")
     // check there's no intersect in partitions
-    def partition_res_range = sql """show partitions from ${table_name} order by PartitionName;"""
+    def partition_res_range = sql_return_maparray """show partitions from ${table_name} order by PartitionName;"""
     for (int i = 0; i < partition_res_range.size(); i++) {
         for (int j = i+1; j < partition_res_range.size(); j++) {
-            if (partition_res_range[i][6] == partition_res_range[j][6]) {
+            if (partition_res_range[i].Range == partition_res_range[j].Range) {
                 assertTrue(false, "$i, $j")
             }
         }