diff --git a/regression-test/suites/ssb_unique_load_zstd_p0/ddl/customer_create.sql b/regression-test/suites/ssb_unique_load_zstd_p0/ddl/customer_create.sql deleted file mode 100644 index d172400d82ec08..00000000000000 --- a/regression-test/suites/ssb_unique_load_zstd_p0/ddl/customer_create.sql +++ /dev/null @@ -1,16 +0,0 @@ -CREATE TABLE IF NOT EXISTS `customer` ( - `c_custkey` int(11) NOT NULL COMMENT "", - `c_name` varchar(26) NOT NULL COMMENT "", - `c_address` varchar(41) NOT NULL COMMENT "", - `c_city` varchar(11) NOT NULL COMMENT "", - `c_nation` varchar(16) NOT NULL COMMENT "", - `c_region` varchar(13) NOT NULL COMMENT "", - `c_phone` varchar(16) NOT NULL COMMENT "", - `c_mktsegment` varchar(11) NOT NULL COMMENT "" -) -UNIQUE KEY (`c_custkey`) -DISTRIBUTED BY HASH(`c_custkey`) BUCKETS 10 -PROPERTIES ( -"compression"="zstd", -"replication_num" = "1" -); diff --git a/regression-test/suites/ssb_unique_load_zstd_p0/ddl/customer_delete.sql b/regression-test/suites/ssb_unique_load_zstd_p0/ddl/customer_delete.sql deleted file mode 100644 index fe22a226fedf85..00000000000000 --- a/regression-test/suites/ssb_unique_load_zstd_p0/ddl/customer_delete.sql +++ /dev/null @@ -1 +0,0 @@ -truncate table customer; \ No newline at end of file diff --git a/regression-test/suites/ssb_unique_load_zstd_p0/ddl/customer_part_delete.sql b/regression-test/suites/ssb_unique_load_zstd_p0/ddl/customer_part_delete.sql deleted file mode 100644 index a9d1b34d68cc0f..00000000000000 --- a/regression-test/suites/ssb_unique_load_zstd_p0/ddl/customer_part_delete.sql +++ /dev/null @@ -1 +0,0 @@ -delete from customer where c_custkey > 1500 ; diff --git a/regression-test/suites/ssb_unique_load_zstd_p0/ddl/customer_sequence_create.sql b/regression-test/suites/ssb_unique_load_zstd_p0/ddl/customer_sequence_create.sql deleted file mode 100644 index 282479442da0a3..00000000000000 --- a/regression-test/suites/ssb_unique_load_zstd_p0/ddl/customer_sequence_create.sql +++ /dev/null @@ -1,17 +0,0 @@ -CREATE TABLE IF NOT EXISTS `customer` ( - `c_custkey` int(11) NOT NULL COMMENT "", - `c_name` varchar(26) NOT NULL COMMENT "", - `c_address` varchar(41) NOT NULL COMMENT "", - `c_city` varchar(11) NOT NULL COMMENT "", - `c_nation` varchar(16) NOT NULL COMMENT "", - `c_region` varchar(13) NOT NULL COMMENT "", - `c_phone` varchar(16) NOT NULL COMMENT "", - `c_mktsegment` varchar(11) NOT NULL COMMENT "" -) -UNIQUE KEY (`c_custkey`) -DISTRIBUTED BY HASH(`c_custkey`) BUCKETS 10 -PROPERTIES ( -"function_column.sequence_type" = 'int', -"compression"="zstd", -"replication_num" = "1" -); diff --git a/regression-test/suites/ssb_unique_load_zstd_p0/ddl/date_create.sql b/regression-test/suites/ssb_unique_load_zstd_p0/ddl/date_create.sql deleted file mode 100644 index 830ce3ce599c84..00000000000000 --- a/regression-test/suites/ssb_unique_load_zstd_p0/ddl/date_create.sql +++ /dev/null @@ -1,25 +0,0 @@ -CREATE TABLE IF NOT EXISTS `date` ( - `d_datekey` int(11) NOT NULL COMMENT "", - `d_date` varchar(20) NOT NULL COMMENT "", - `d_dayofweek` varchar(10) NOT NULL COMMENT "", - `d_month` varchar(11) NOT NULL COMMENT "", - `d_year` int(11) NOT NULL COMMENT "", - `d_yearmonthnum` int(11) NOT NULL COMMENT "", - `d_yearmonth` varchar(9) NOT NULL COMMENT "", - `d_daynuminweek` int(11) NOT NULL COMMENT "", - `d_daynuminmonth` int(11) NOT NULL COMMENT "", - `d_daynuminyear` int(11) NOT NULL COMMENT "", - `d_monthnuminyear` int(11) NOT NULL COMMENT "", - `d_weeknuminyear` int(11) NOT NULL COMMENT "", - `d_sellingseason` varchar(14) NOT NULL COMMENT "", - `d_lastdayinweekfl` int(11) NOT NULL COMMENT "", - `d_lastdayinmonthfl` int(11) NOT NULL COMMENT "", - `d_holidayfl` int(11) NOT NULL COMMENT "", - `d_weekdayfl` int(11) NOT NULL COMMENT "" -) -UNIQUE KEY (`d_datekey`) -DISTRIBUTED BY HASH(`d_datekey`) BUCKETS 1 -PROPERTIES ( -"compression"="zstd", -"replication_num" = "1" -); diff --git a/regression-test/suites/ssb_unique_load_zstd_p0/ddl/date_delete.sql b/regression-test/suites/ssb_unique_load_zstd_p0/ddl/date_delete.sql deleted file mode 100644 index 12933cbbad92da..00000000000000 --- a/regression-test/suites/ssb_unique_load_zstd_p0/ddl/date_delete.sql +++ /dev/null @@ -1 +0,0 @@ -truncate table `date`; \ No newline at end of file diff --git a/regression-test/suites/ssb_unique_load_zstd_p0/ddl/date_part_delete.sql b/regression-test/suites/ssb_unique_load_zstd_p0/ddl/date_part_delete.sql deleted file mode 100644 index 0c21b27cc48c53..00000000000000 --- a/regression-test/suites/ssb_unique_load_zstd_p0/ddl/date_part_delete.sql +++ /dev/null @@ -1 +0,0 @@ -delete from `date` where d_datekey >= '19920701' and d_datekey <= '19920731'; diff --git a/regression-test/suites/ssb_unique_load_zstd_p0/ddl/date_sequence_create.sql b/regression-test/suites/ssb_unique_load_zstd_p0/ddl/date_sequence_create.sql deleted file mode 100644 index 662ac4fbd2114e..00000000000000 --- a/regression-test/suites/ssb_unique_load_zstd_p0/ddl/date_sequence_create.sql +++ /dev/null @@ -1,26 +0,0 @@ -CREATE TABLE IF NOT EXISTS `date` ( - `d_datekey` int(11) NOT NULL COMMENT "", - `d_date` varchar(20) NOT NULL COMMENT "", - `d_dayofweek` varchar(10) NOT NULL COMMENT "", - `d_month` varchar(11) NOT NULL COMMENT "", - `d_year` int(11) NOT NULL COMMENT "", - `d_yearmonthnum` int(11) NOT NULL COMMENT "", - `d_yearmonth` varchar(9) NOT NULL COMMENT "", - `d_daynuminweek` int(11) NOT NULL COMMENT "", - `d_daynuminmonth` int(11) NOT NULL COMMENT "", - `d_daynuminyear` int(11) NOT NULL COMMENT "", - `d_monthnuminyear` int(11) NOT NULL COMMENT "", - `d_weeknuminyear` int(11) NOT NULL COMMENT "", - `d_sellingseason` varchar(14) NOT NULL COMMENT "", - `d_lastdayinweekfl` int(11) NOT NULL COMMENT "", - `d_lastdayinmonthfl` int(11) NOT NULL COMMENT "", - `d_holidayfl` int(11) NOT NULL COMMENT "", - `d_weekdayfl` int(11) NOT NULL COMMENT "" -) -UNIQUE KEY (`d_datekey`) -DISTRIBUTED BY HASH(`d_datekey`) BUCKETS 1 -PROPERTIES ( -"function_column.sequence_type" = 'int', -"compression"="zstd", -"replication_num" = "1" -); diff --git a/regression-test/suites/ssb_unique_load_zstd_p0/ddl/lineorder_create.sql b/regression-test/suites/ssb_unique_load_zstd_p0/ddl/lineorder_create.sql deleted file mode 100644 index d75a3f1ae39dc3..00000000000000 --- a/regression-test/suites/ssb_unique_load_zstd_p0/ddl/lineorder_create.sql +++ /dev/null @@ -1,33 +0,0 @@ -CREATE TABLE IF NOT EXISTS `lineorder` ( - `lo_orderdate` int(11) NOT NULL COMMENT "", - `lo_orderkey` bigint(20) NOT NULL COMMENT "", - `lo_linenumber` bigint(20) NOT NULL COMMENT "", - `lo_custkey` int(11) NOT NULL COMMENT "", - `lo_partkey` int(11) NOT NULL COMMENT "", - `lo_suppkey` int(11) NOT NULL COMMENT "", - `lo_orderpriority` varchar(16) NOT NULL COMMENT "", - `lo_shippriority` int(11) NOT NULL COMMENT "", - `lo_quantity` bigint(20) NOT NULL COMMENT "", - `lo_extendedprice` bigint(20) NOT NULL COMMENT "", - `lo_ordtotalprice` bigint(20) NOT NULL COMMENT "", - `lo_discount` bigint(20) NOT NULL COMMENT "", - `lo_revenue` bigint(20) NOT NULL COMMENT "", - `lo_supplycost` bigint(20) NOT NULL COMMENT "", - `lo_tax` bigint(20) NOT NULL COMMENT "", - `lo_commitdate` bigint(20) NOT NULL COMMENT "", - `lo_shipmode` varchar(11) NOT NULL COMMENT "" -) -UNIQUE KEY (`lo_orderdate`,`lo_orderkey`,`lo_linenumber`) -PARTITION BY RANGE(`lo_orderdate`) -(PARTITION p1992 VALUES [("-2147483648"), ("19930101")), -PARTITION p1993 VALUES [("19930101"), ("19940101")), -PARTITION p1994 VALUES [("19940101"), ("19950101")), -PARTITION p1995 VALUES [("19950101"), ("19960101")), -PARTITION p1996 VALUES [("19960101"), ("19970101")), -PARTITION p1997 VALUES [("19970101"), ("19980101")), -PARTITION p1998 VALUES [("19980101"), ("19990101"))) -DISTRIBUTED BY HASH(`lo_orderkey`) BUCKETS 48 -PROPERTIES ( -"compression"="zstd", -"replication_num" = "1" -); diff --git a/regression-test/suites/ssb_unique_load_zstd_p0/ddl/lineorder_delete.sql b/regression-test/suites/ssb_unique_load_zstd_p0/ddl/lineorder_delete.sql deleted file mode 100644 index 329e040060edc6..00000000000000 --- a/regression-test/suites/ssb_unique_load_zstd_p0/ddl/lineorder_delete.sql +++ /dev/null @@ -1 +0,0 @@ -truncate table lineorder; \ No newline at end of file diff --git a/regression-test/suites/ssb_unique_load_zstd_p0/ddl/lineorder_part_delete.sql b/regression-test/suites/ssb_unique_load_zstd_p0/ddl/lineorder_part_delete.sql deleted file mode 100644 index abb7ded4331f2a..00000000000000 --- a/regression-test/suites/ssb_unique_load_zstd_p0/ddl/lineorder_part_delete.sql +++ /dev/null @@ -1 +0,0 @@ -delete from lineorder where lo_orderkey >= 240001 and lo_orderkey <= 360000; diff --git a/regression-test/suites/ssb_unique_load_zstd_p0/ddl/lineorder_sequence_create.sql b/regression-test/suites/ssb_unique_load_zstd_p0/ddl/lineorder_sequence_create.sql deleted file mode 100644 index 988cad5e2e2597..00000000000000 --- a/regression-test/suites/ssb_unique_load_zstd_p0/ddl/lineorder_sequence_create.sql +++ /dev/null @@ -1,34 +0,0 @@ -CREATE TABLE IF NOT EXISTS `lineorder` ( - `lo_orderdate` int(11) NOT NULL COMMENT "", - `lo_orderkey` bigint(20) NOT NULL COMMENT "", - `lo_linenumber` bigint(20) NOT NULL COMMENT "", - `lo_custkey` int(11) NOT NULL COMMENT "", - `lo_partkey` int(11) NOT NULL COMMENT "", - `lo_suppkey` int(11) NOT NULL COMMENT "", - `lo_orderpriority` varchar(16) NOT NULL COMMENT "", - `lo_shippriority` int(11) NOT NULL COMMENT "", - `lo_quantity` bigint(20) NOT NULL COMMENT "", - `lo_extendedprice` bigint(20) NOT NULL COMMENT "", - `lo_ordtotalprice` bigint(20) NOT NULL COMMENT "", - `lo_discount` bigint(20) NOT NULL COMMENT "", - `lo_revenue` bigint(20) NOT NULL COMMENT "", - `lo_supplycost` bigint(20) NOT NULL COMMENT "", - `lo_tax` bigint(20) NOT NULL COMMENT "", - `lo_commitdate` bigint(20) NOT NULL COMMENT "", - `lo_shipmode` varchar(11) NOT NULL COMMENT "" -) -UNIQUE KEY (`lo_orderdate`,`lo_orderkey`,`lo_linenumber`) -PARTITION BY RANGE(`lo_orderdate`) -(PARTITION p1992 VALUES [("-2147483648"), ("19930101")), -PARTITION p1993 VALUES [("19930101"), ("19940101")), -PARTITION p1994 VALUES [("19940101"), ("19950101")), -PARTITION p1995 VALUES [("19950101"), ("19960101")), -PARTITION p1996 VALUES [("19960101"), ("19970101")), -PARTITION p1997 VALUES [("19970101"), ("19980101")), -PARTITION p1998 VALUES [("19980101"), ("19990101"))) -DISTRIBUTED BY HASH(`lo_orderkey`) BUCKETS 48 -PROPERTIES ( -"function_column.sequence_type" = 'int', -"compression"="zstd", -"replication_num" = "1" -); diff --git a/regression-test/suites/ssb_unique_load_zstd_p0/ddl/part_create.sql b/regression-test/suites/ssb_unique_load_zstd_p0/ddl/part_create.sql deleted file mode 100644 index becc59157c388b..00000000000000 --- a/regression-test/suites/ssb_unique_load_zstd_p0/ddl/part_create.sql +++ /dev/null @@ -1,17 +0,0 @@ -CREATE TABLE IF NOT EXISTS `part` ( - `p_partkey` int(11) NOT NULL COMMENT "", - `p_name` varchar(23) NOT NULL COMMENT "", - `p_mfgr` varchar(7) NOT NULL COMMENT "", - `p_category` varchar(8) NOT NULL COMMENT "", - `p_brand` varchar(10) NOT NULL COMMENT "", - `p_color` varchar(12) NOT NULL COMMENT "", - `p_type` varchar(26) NOT NULL COMMENT "", - `p_size` int(11) NOT NULL COMMENT "", - `p_container` varchar(11) NOT NULL COMMENT "" -) -UNIQUE KEY (`p_partkey`) -DISTRIBUTED BY HASH(`p_partkey`) BUCKETS 10 -PROPERTIES ( -"compression"="zstd", -"replication_num" = "1" -); diff --git a/regression-test/suites/ssb_unique_load_zstd_p0/ddl/part_delete.sql b/regression-test/suites/ssb_unique_load_zstd_p0/ddl/part_delete.sql deleted file mode 100644 index 02c6abd2539add..00000000000000 --- a/regression-test/suites/ssb_unique_load_zstd_p0/ddl/part_delete.sql +++ /dev/null @@ -1 +0,0 @@ -truncate table `part`; \ No newline at end of file diff --git a/regression-test/suites/ssb_unique_load_zstd_p0/ddl/part_part_delete.sql b/regression-test/suites/ssb_unique_load_zstd_p0/ddl/part_part_delete.sql deleted file mode 100644 index 32ec2aa18b2397..00000000000000 --- a/regression-test/suites/ssb_unique_load_zstd_p0/ddl/part_part_delete.sql +++ /dev/null @@ -1 +0,0 @@ -delete from `part` where p_partkey > 10000; diff --git a/regression-test/suites/ssb_unique_load_zstd_p0/ddl/part_sequence_create.sql b/regression-test/suites/ssb_unique_load_zstd_p0/ddl/part_sequence_create.sql deleted file mode 100644 index 89cdb202274b3a..00000000000000 --- a/regression-test/suites/ssb_unique_load_zstd_p0/ddl/part_sequence_create.sql +++ /dev/null @@ -1,18 +0,0 @@ -CREATE TABLE IF NOT EXISTS `part` ( - `p_partkey` int(11) NOT NULL COMMENT "", - `p_name` varchar(23) NOT NULL COMMENT "", - `p_mfgr` varchar(7) NOT NULL COMMENT "", - `p_category` varchar(8) NOT NULL COMMENT "", - `p_brand` varchar(10) NOT NULL COMMENT "", - `p_color` varchar(12) NOT NULL COMMENT "", - `p_type` varchar(26) NOT NULL COMMENT "", - `p_size` int(11) NOT NULL COMMENT "", - `p_container` varchar(11) NOT NULL COMMENT "" -) -UNIQUE KEY (`p_partkey`) -DISTRIBUTED BY HASH(`p_partkey`) BUCKETS 10 -PROPERTIES ( -"function_column.sequence_type" = 'int', -"compression"="zstd", -"replication_num" = "1" -); diff --git a/regression-test/suites/ssb_unique_load_zstd_p0/ddl/supplier_create.sql b/regression-test/suites/ssb_unique_load_zstd_p0/ddl/supplier_create.sql deleted file mode 100644 index 783946219627f0..00000000000000 --- a/regression-test/suites/ssb_unique_load_zstd_p0/ddl/supplier_create.sql +++ /dev/null @@ -1,15 +0,0 @@ -CREATE TABLE IF NOT EXISTS `supplier` ( - `s_suppkey` int(11) NOT NULL COMMENT "", - `s_name` varchar(26) NOT NULL COMMENT "", - `s_address` varchar(26) NOT NULL COMMENT "", - `s_city` varchar(11) NOT NULL COMMENT "", - `s_nation` varchar(16) NOT NULL COMMENT "", - `s_region` varchar(13) NOT NULL COMMENT "", - `s_phone` varchar(16) NOT NULL COMMENT "" -) -UNIQUE KEY (`s_suppkey`) -DISTRIBUTED BY HASH(`s_suppkey`) BUCKETS 10 -PROPERTIES ( -"compression"="zstd", -"replication_num" = "1" -); diff --git a/regression-test/suites/ssb_unique_load_zstd_p0/ddl/supplier_delete.sql b/regression-test/suites/ssb_unique_load_zstd_p0/ddl/supplier_delete.sql deleted file mode 100644 index 39e663134cabd0..00000000000000 --- a/regression-test/suites/ssb_unique_load_zstd_p0/ddl/supplier_delete.sql +++ /dev/null @@ -1 +0,0 @@ -truncate table `supplier`; \ No newline at end of file diff --git a/regression-test/suites/ssb_unique_load_zstd_p0/ddl/supplier_part_delete.sql b/regression-test/suites/ssb_unique_load_zstd_p0/ddl/supplier_part_delete.sql deleted file mode 100644 index ac6a7030fd07b3..00000000000000 --- a/regression-test/suites/ssb_unique_load_zstd_p0/ddl/supplier_part_delete.sql +++ /dev/null @@ -1 +0,0 @@ -delete from `supplier` where s_suppkey > 100; diff --git a/regression-test/suites/ssb_unique_load_zstd_p0/ddl/supplier_sequence_create.sql b/regression-test/suites/ssb_unique_load_zstd_p0/ddl/supplier_sequence_create.sql deleted file mode 100644 index e3dcbf33b7ffa0..00000000000000 --- a/regression-test/suites/ssb_unique_load_zstd_p0/ddl/supplier_sequence_create.sql +++ /dev/null @@ -1,16 +0,0 @@ -CREATE TABLE IF NOT EXISTS `supplier` ( - `s_suppkey` int(11) NOT NULL COMMENT "", - `s_name` varchar(26) NOT NULL COMMENT "", - `s_address` varchar(26) NOT NULL COMMENT "", - `s_city` varchar(11) NOT NULL COMMENT "", - `s_nation` varchar(16) NOT NULL COMMENT "", - `s_region` varchar(13) NOT NULL COMMENT "", - `s_phone` varchar(16) NOT NULL COMMENT "" -) -UNIQUE KEY (`s_suppkey`) -DISTRIBUTED BY HASH(`s_suppkey`) BUCKETS 10 -PROPERTIES ( -"function_column.sequence_type" = 'int', -"compression"="zstd", -"replication_num" = "1" -); diff --git a/regression-test/suites/ssb_unique_load_zstd_p0/load_four_step/load.groovy b/regression-test/suites/ssb_unique_load_zstd_p0/load_four_step/load.groovy deleted file mode 100644 index 3c6ea2b4ef8cf1..00000000000000 --- a/regression-test/suites/ssb_unique_load_zstd_p0/load_four_step/load.groovy +++ /dev/null @@ -1,110 +0,0 @@ -// Licensed to the Apache Software Foundation (ASF) under one -// or more contributor license agreements. See the NOTICE file -// distributed with this work for additional information -// regarding copyright ownership. The ASF licenses this file -// to you under the Apache License, Version 2.0 (the -// "License"); you may not use this file except in compliance -// with the License. You may obtain a copy of the License at -// -// http://www.apache.org/licenses/LICENSE-2.0 -// -// Unless required by applicable law or agreed to in writing, -// software distributed under the License is distributed on an -// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY -// KIND, either express or implied. See the License for the -// specific language governing permissions and limitations -// under the License. - -// Most of the cases are copied from https://github.com/trinodb/trino/tree/master -// /testing/trino-product-tests/src/main/resources/sql-tests/testcases -// and modified by Doris. - -suite("load_four_step") { - def tables = ["customer": ["""c_custkey,c_name,c_address,c_city,c_nation,c_region,c_phone,c_mktsegment,no_use""", 3000, "c_custkey", 1500], "lineorder": ["""lo_orderkey,lo_linenumber,lo_custkey,lo_partkey,lo_suppkey,lo_orderdate,lo_orderpriority, - lo_shippriority,lo_quantity,lo_extendedprice,lo_ordtotalprice,lo_discount, - lo_revenue,lo_supplycost,lo_tax,lo_commitdate,lo_shipmode,lo_dummy""", 600572, "lo_orderkey", 481137], "part": ["""p_partkey,p_name,p_mfgr,p_category,p_brand,p_color,p_type,p_size,p_container,p_dummy""", 20000, "p_partkey", 10000], "date": ["""d_datekey,d_date,d_dayofweek,d_month,d_year,d_yearmonthnum,d_yearmonth, - d_daynuminweek,d_daynuminmonth,d_daynuminyear,d_monthnuminyear,d_weeknuminyear, - d_sellingseason,d_lastdayinweekfl,d_lastdayinmonthfl,d_holidayfl,d_weekdayfl,d_dummy""", 255, "d_datekey", 224], "supplier": ["""s_suppkey,s_name,s_address,s_city,s_nation,s_region,s_phone,s_dummy""", 200, "s_suppkey", 100]] - - tables.each { tableName, rows -> - sql """ DROP TABLE IF EXISTS $tableName """ - sql new File("""${context.file.parentFile.parent}/ddl/${tableName}_sequence_create.sql""").text - for (j in 0..<2) { - streamLoad { - table tableName - set 'column_separator', '|' - set 'compress_type', 'GZ' - set 'columns', rows[0] - set 'function_column.sequence_col', rows[2] - - // relate to ${DORIS_HOME}/regression-test/data/demo/streamload_input.csv. - // also, you can stream load a http stream, e.g. http://xxx/some.csv - file """${getS3Url()}/regression/ssb/sf0.1/${tableName}.tbl.gz""" - - time 10000 // limit inflight 10s - - // stream load action will check result, include Success status, and NumberTotalRows == NumberLoadedRows - - // if declared a check callback, the default check condition will ignore. - // So you must check all condition - check { result, exception, startTime, endTime -> - if (exception != null) { - throw exception - } - log.info("Stream load result: ${result}".toString()) - def json = parseJson(result) - assertEquals("success", json.Status.toLowerCase()) - assertEquals(json.NumberTotalRows, json.NumberLoadedRows) - assertTrue(json.NumberLoadedRows > 0 && json.LoadBytes > 0) - } - } - sql 'sync' - for (int i = 1; i <= 5; i++) { - def loadRowCount = sql "select count(1) from ${tableName}" - logger.info("select ${tableName} numbers: ${loadRowCount[0][0]}".toString()) - assertTrue(loadRowCount[0][0] == rows[1]) - } - } - sql """ set delete_without_partition = true; """ - sql new File("""${context.file.parentFile.parent}/ddl/${tableName}_part_delete.sql""").text - for (int i = 1; i <= 5; i++) { - def loadRowCount = sql "select count(1) from ${tableName}" - logger.info("select ${tableName} numbers: ${loadRowCount[0][0]}".toString()) - assertTrue(loadRowCount[0][0] == rows[3]) - } - streamLoad { - table tableName - set 'column_separator', '|' - set 'compress_type', 'GZ' - set 'columns', rows[0] - set 'function_column.sequence_col', rows[2] - - // relate to ${DORIS_HOME}/regression-test/data/demo/streamload_input.csv. - // also, you can stream load a http stream, e.g. http://xxx/some.csv - file """${getS3Url()}/regression/ssb/sf0.1/${tableName}.tbl.gz""" - - time 10000 // limit inflight 10s - - // stream load action will check result, include Success status, and NumberTotalRows == NumberLoadedRows - - // if declared a check callback, the default check condition will ignore. - // So you must check all condition - check { result, exception, startTime, endTime -> - if (exception != null) { - throw exception - } - log.info("Stream load result: ${result}".toString()) - def json = parseJson(result) - assertEquals("success", json.Status.toLowerCase()) - assertEquals(json.NumberTotalRows, json.NumberLoadedRows) - assertTrue(json.NumberLoadedRows > 0 && json.LoadBytes > 0) - } - } - sql 'sync' - for (int i = 1; i <= 5; i++) { - def loadRowCount = sql "select count(1) from ${tableName}" - logger.info("select ${tableName} numbers: ${loadRowCount[0][0]}".toString()) - assertTrue(loadRowCount[0][0] == rows[1]) - } - } -} diff --git a/regression-test/suites/ssb_unique_load_zstd_p0/load_one_step/load.groovy b/regression-test/suites/ssb_unique_load_zstd_p0/load_one_step/load.groovy deleted file mode 100644 index 1182f2016f7021..00000000000000 --- a/regression-test/suites/ssb_unique_load_zstd_p0/load_one_step/load.groovy +++ /dev/null @@ -1,65 +0,0 @@ -// Licensed to the Apache Software Foundation (ASF) under one -// or more contributor license agreements. See the NOTICE file -// distributed with this work for additional information -// regarding copyright ownership. The ASF licenses this file -// to you under the Apache License, Version 2.0 (the -// "License"); you may not use this file except in compliance -// with the License. You may obtain a copy of the License at -// -// http://www.apache.org/licenses/LICENSE-2.0 -// -// Unless required by applicable law or agreed to in writing, -// software distributed under the License is distributed on an -// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY -// KIND, either express or implied. See the License for the -// specific language governing permissions and limitations -// under the License. - - -suite("load_one_step") { - def tables = ["customer": ["""c_custkey,c_name,c_address,c_city,c_nation,c_region,c_phone,c_mktsegment,no_use""", 3000], "lineorder": ["""lo_orderkey,lo_linenumber,lo_custkey,lo_partkey,lo_suppkey,lo_orderdate,lo_orderpriority, - lo_shippriority,lo_quantity,lo_extendedprice,lo_ordtotalprice,lo_discount, - lo_revenue,lo_supplycost,lo_tax,lo_commitdate,lo_shipmode,lo_dummy""", 600572], "part": ["""p_partkey,p_name,p_mfgr,p_category,p_brand,p_color,p_type,p_size,p_container,p_dummy""", 20000], "date": ["""d_datekey,d_date,d_dayofweek,d_month,d_year,d_yearmonthnum,d_yearmonth, - d_daynuminweek,d_daynuminmonth,d_daynuminyear,d_monthnuminyear,d_weeknuminyear, - d_sellingseason,d_lastdayinweekfl,d_lastdayinmonthfl,d_holidayfl,d_weekdayfl,d_dummy""", 255], "supplier": ["""s_suppkey,s_name,s_address,s_city,s_nation,s_region,s_phone,s_dummy""", 200]] - - tables.each { tableName, rows -> - sql """ DROP TABLE IF EXISTS $tableName """ - sql new File("""${context.file.parentFile.parent}/ddl/${tableName}_create.sql""").text - streamLoad { - table tableName - def label = "load_one_step_${tableName}_" + UUID.randomUUID().toString() - set 'label', label - set 'column_separator', '|' - set 'compress_type', 'GZ' - set 'columns', rows[0] - - // relate to ${DORIS_HOME}/regression-test/data/demo/streamload_input.csv. - // also, you can stream load a http stream, e.g. http://xxx/some.csv - file """${getS3Url()}/regression/ssb/sf0.1/${tableName}.tbl.gz""" - - time 10000 // limit inflight 10s - - // stream load action will check result, include Success status, and NumberTotalRows == NumberLoadedRows - - // if declared a check callback, the default check condition will ignore. - // So you must check all condition - check { result, exception, startTime, endTime -> - if (exception != null) { - throw exception - } - log.info("Stream load result: ${result}".toString()) - def json = parseJson(result) - assertEquals("success", json.Status.toLowerCase()) - assertEquals(json.NumberTotalRows, json.NumberLoadedRows) - assertTrue(json.NumberLoadedRows > 0 && json.LoadBytes > 0) - } - } - sql 'sync' - for (int i = 1; i <= 5; i++) { - def loadRowCount = sql "select count(1) from ${tableName}" - logger.info("select ${tableName} numbers: ${loadRowCount[0][0]}".toString()) - assertTrue(loadRowCount[0][0] == rows[1]) - } - } -} diff --git a/regression-test/suites/ssb_unique_load_zstd_p0/load_three_step/load.groovy b/regression-test/suites/ssb_unique_load_zstd_p0/load_three_step/load.groovy deleted file mode 100644 index 28cc474d4041c5..00000000000000 --- a/regression-test/suites/ssb_unique_load_zstd_p0/load_three_step/load.groovy +++ /dev/null @@ -1,72 +0,0 @@ -// Licensed to the Apache Software Foundation (ASF) under one -// or more contributor license agreements. See the NOTICE file -// distributed with this work for additional information -// regarding copyright ownership. The ASF licenses this file -// to you under the Apache License, Version 2.0 (the -// "License"); you may not use this file except in compliance -// with the License. You may obtain a copy of the License at -// -// http://www.apache.org/licenses/LICENSE-2.0 -// -// Unless required by applicable law or agreed to in writing, -// software distributed under the License is distributed on an -// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY -// KIND, either express or implied. See the License for the -// specific language governing permissions and limitations -// under the License. - - -suite("load_three_step") { - def tables = ["customer": ["""c_custkey,c_name,c_address,c_city,c_nation,c_region,c_phone,c_mktsegment,no_use""", 3000, "c_custkey"], "lineorder": ["""lo_orderkey,lo_linenumber,lo_custkey,lo_partkey,lo_suppkey,lo_orderdate,lo_orderpriority, - lo_shippriority,lo_quantity,lo_extendedprice,lo_ordtotalprice,lo_discount, - lo_revenue,lo_supplycost,lo_tax,lo_commitdate,lo_shipmode,lo_dummy""", 600572, "lo_orderkey"], "part": ["""p_partkey,p_name,p_mfgr,p_category,p_brand,p_color,p_type,p_size,p_container,p_dummy""", 20000, "p_partkey"], "date": ["""d_datekey,d_date,d_dayofweek,d_month,d_year,d_yearmonthnum,d_yearmonth, - d_daynuminweek,d_daynuminmonth,d_daynuminyear,d_monthnuminyear,d_weeknuminyear, - d_sellingseason,d_lastdayinweekfl,d_lastdayinmonthfl,d_holidayfl,d_weekdayfl,d_dummy""", 255, "d_datekey"], "supplier": ["""s_suppkey,s_name,s_address,s_city,s_nation,s_region,s_phone,s_dummy""", 200, "s_suppkey"]] - - tables.each { tableName, rows -> - sql """ DROP TABLE IF EXISTS $tableName """ - sql new File("""${context.file.parentFile.parent}/ddl/${tableName}_sequence_create.sql""").text - for (j in 0..<2) { - streamLoad { - table tableName - set 'column_separator', '|' - set 'compress_type', 'GZ' - set 'columns', rows[0] - set 'function_column.sequence_col', rows[2] - - // relate to ${DORIS_HOME}/regression-test/data/demo/streamload_input.csv. - // also, you can stream load a http stream, e.g. http://xxx/some.csv - file """${getS3Url()}/regression/ssb/sf0.1/${tableName}.tbl.gz""" - - time 10000 // limit inflight 10s - - // stream load action will check result, include Success status, and NumberTotalRows == NumberLoadedRows - - // if declared a check callback, the default check condition will ignore. - // So you must check all condition - check { result, exception, startTime, endTime -> - if (exception != null) { - throw exception - } - log.info("Stream load result: ${result}".toString()) - def json = parseJson(result) - assertEquals("success", json.Status.toLowerCase()) - assertEquals(json.NumberTotalRows, json.NumberLoadedRows) - assertTrue(json.NumberLoadedRows > 0 && json.LoadBytes > 0) - } - } - sql 'sync' - for (int i = 1; i <= 5; i++) { - def loadRowCount = sql "select count(1) from ${tableName}" - logger.info("select ${tableName} numbers: ${loadRowCount[0][0]}".toString()) - assertTrue(loadRowCount[0][0] == rows[1]) - } - } - sql new File("""${context.file.parentFile.parent}/ddl/${tableName}_delete.sql""").text - for (int i = 1; i <= 5; i++) { - def loadRowCount = sql "select count(1) from ${tableName}" - logger.info("select ${tableName} numbers: ${loadRowCount[0][0]}".toString()) - assertTrue(loadRowCount[0][0] == 0) - } - } -} diff --git a/regression-test/suites/ssb_unique_load_zstd_p0/load_two_step/load.groovy b/regression-test/suites/ssb_unique_load_zstd_p0/load_two_step/load.groovy deleted file mode 100644 index fa1f9edbcbc5c1..00000000000000 --- a/regression-test/suites/ssb_unique_load_zstd_p0/load_two_step/load.groovy +++ /dev/null @@ -1,70 +0,0 @@ -// Licensed to the Apache Software Foundation (ASF) under one -// or more contributor license agreements. See the NOTICE file -// distributed with this work for additional information -// regarding copyright ownership. The ASF licenses this file -// to you under the Apache License, Version 2.0 (the -// "License"); you may not use this file except in compliance -// with the License. You may obtain a copy of the License at -// -// http://www.apache.org/licenses/LICENSE-2.0 -// -// Unless required by applicable law or agreed to in writing, -// software distributed under the License is distributed on an -// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY -// KIND, either express or implied. See the License for the -// specific language governing permissions and limitations -// under the License. - - -suite("load_two_step") { - def tables = ["customer": ["""c_custkey,c_name,c_address,c_city,c_nation,c_region,c_phone,c_mktsegment,no_use""", 3000, "c_custkey"], "lineorder": ["""lo_orderkey,lo_linenumber,lo_custkey,lo_partkey,lo_suppkey,lo_orderdate,lo_orderpriority, - lo_shippriority,lo_quantity,lo_extendedprice,lo_ordtotalprice,lo_discount, - lo_revenue,lo_supplycost,lo_tax,lo_commitdate,lo_shipmode,lo_dummy""", 600572, "lo_orderkey"], "part": ["""p_partkey,p_name,p_mfgr,p_category,p_brand,p_color,p_type,p_size,p_container,p_dummy""", 20000, "p_partkey"], "date": ["""d_datekey,d_date,d_dayofweek,d_month,d_year,d_yearmonthnum,d_yearmonth, - d_daynuminweek,d_daynuminmonth,d_daynuminyear,d_monthnuminyear,d_weeknuminyear, - d_sellingseason,d_lastdayinweekfl,d_lastdayinmonthfl,d_holidayfl,d_weekdayfl,d_dummy""", 255, "d_datekey"], "supplier": ["""s_suppkey,s_name,s_address,s_city,s_nation,s_region,s_phone,s_dummy""", 200, "s_suppkey"]] - - tables.each { tableName, rows -> - sql """ DROP TABLE IF EXISTS $tableName """ - sql new File("""${context.file.parentFile.parent}/ddl/${tableName}_sequence_create.sql""").text - streamLoad { - table tableName - set 'column_separator', '|' - set 'compress_type', 'GZ' - set 'columns', rows[0] - set 'function_column.sequence_col', rows[2] - - // relate to ${DORIS_HOME}/regression-test/data/demo/streamload_input.csv. - // also, you can stream load a http stream, e.g. http://xxx/some.csv - file """${getS3Url()}/regression/ssb/sf0.1/${tableName}.tbl.gz""" - - time 10000 // limit inflight 10s - - // stream load action will check result, include Success status, and NumberTotalRows == NumberLoadedRows - - // if declared a check callback, the default check condition will ignore. - // So you must check all condition - check { result, exception, startTime, endTime -> - if (exception != null) { - throw exception - } - log.info("Stream load result: ${result}".toString()) - def json = parseJson(result) - assertEquals("success", json.Status.toLowerCase()) - assertEquals(json.NumberTotalRows, json.NumberLoadedRows) - assertTrue(json.NumberLoadedRows > 0 && json.LoadBytes > 0) - } - } - sql 'sync' - for (int i = 1; i <= 5; i++) { - def loadRowCount = sql "select count(1) from ${tableName}" - logger.info("select ${tableName} numbers: ${loadRowCount[0][0]}".toString()) - assertTrue(loadRowCount[0][0] == rows[1]) - } - sql new File("""${context.file.parentFile.parent}/ddl/${tableName}_delete.sql""").text - for (int i = 1; i <= 5; i++) { - def loadRowCount = sql "select count(1) from ${tableName}" - logger.info("select ${tableName} numbers: ${loadRowCount[0][0]}".toString()) - assertTrue(loadRowCount[0][0] == 0) - } - } -} diff --git a/regression-test/suites/ssb_unique_sql_zstd_p0/ddl/customer_create.sql b/regression-test/suites/ssb_unique_sql_zstd_p0/ddl/customer_create.sql deleted file mode 100644 index d172400d82ec08..00000000000000 --- a/regression-test/suites/ssb_unique_sql_zstd_p0/ddl/customer_create.sql +++ /dev/null @@ -1,16 +0,0 @@ -CREATE TABLE IF NOT EXISTS `customer` ( - `c_custkey` int(11) NOT NULL COMMENT "", - `c_name` varchar(26) NOT NULL COMMENT "", - `c_address` varchar(41) NOT NULL COMMENT "", - `c_city` varchar(11) NOT NULL COMMENT "", - `c_nation` varchar(16) NOT NULL COMMENT "", - `c_region` varchar(13) NOT NULL COMMENT "", - `c_phone` varchar(16) NOT NULL COMMENT "", - `c_mktsegment` varchar(11) NOT NULL COMMENT "" -) -UNIQUE KEY (`c_custkey`) -DISTRIBUTED BY HASH(`c_custkey`) BUCKETS 10 -PROPERTIES ( -"compression"="zstd", -"replication_num" = "1" -); diff --git a/regression-test/suites/ssb_unique_sql_zstd_p0/ddl/customer_delete.sql b/regression-test/suites/ssb_unique_sql_zstd_p0/ddl/customer_delete.sql deleted file mode 100644 index fe22a226fedf85..00000000000000 --- a/regression-test/suites/ssb_unique_sql_zstd_p0/ddl/customer_delete.sql +++ /dev/null @@ -1 +0,0 @@ -truncate table customer; \ No newline at end of file diff --git a/regression-test/suites/ssb_unique_sql_zstd_p0/ddl/date_create.sql b/regression-test/suites/ssb_unique_sql_zstd_p0/ddl/date_create.sql deleted file mode 100644 index 830ce3ce599c84..00000000000000 --- a/regression-test/suites/ssb_unique_sql_zstd_p0/ddl/date_create.sql +++ /dev/null @@ -1,25 +0,0 @@ -CREATE TABLE IF NOT EXISTS `date` ( - `d_datekey` int(11) NOT NULL COMMENT "", - `d_date` varchar(20) NOT NULL COMMENT "", - `d_dayofweek` varchar(10) NOT NULL COMMENT "", - `d_month` varchar(11) NOT NULL COMMENT "", - `d_year` int(11) NOT NULL COMMENT "", - `d_yearmonthnum` int(11) NOT NULL COMMENT "", - `d_yearmonth` varchar(9) NOT NULL COMMENT "", - `d_daynuminweek` int(11) NOT NULL COMMENT "", - `d_daynuminmonth` int(11) NOT NULL COMMENT "", - `d_daynuminyear` int(11) NOT NULL COMMENT "", - `d_monthnuminyear` int(11) NOT NULL COMMENT "", - `d_weeknuminyear` int(11) NOT NULL COMMENT "", - `d_sellingseason` varchar(14) NOT NULL COMMENT "", - `d_lastdayinweekfl` int(11) NOT NULL COMMENT "", - `d_lastdayinmonthfl` int(11) NOT NULL COMMENT "", - `d_holidayfl` int(11) NOT NULL COMMENT "", - `d_weekdayfl` int(11) NOT NULL COMMENT "" -) -UNIQUE KEY (`d_datekey`) -DISTRIBUTED BY HASH(`d_datekey`) BUCKETS 1 -PROPERTIES ( -"compression"="zstd", -"replication_num" = "1" -); diff --git a/regression-test/suites/ssb_unique_sql_zstd_p0/ddl/date_delete.sql b/regression-test/suites/ssb_unique_sql_zstd_p0/ddl/date_delete.sql deleted file mode 100644 index 12933cbbad92da..00000000000000 --- a/regression-test/suites/ssb_unique_sql_zstd_p0/ddl/date_delete.sql +++ /dev/null @@ -1 +0,0 @@ -truncate table `date`; \ No newline at end of file diff --git a/regression-test/suites/ssb_unique_sql_zstd_p0/ddl/lineorder_create.sql b/regression-test/suites/ssb_unique_sql_zstd_p0/ddl/lineorder_create.sql deleted file mode 100644 index d75a3f1ae39dc3..00000000000000 --- a/regression-test/suites/ssb_unique_sql_zstd_p0/ddl/lineorder_create.sql +++ /dev/null @@ -1,33 +0,0 @@ -CREATE TABLE IF NOT EXISTS `lineorder` ( - `lo_orderdate` int(11) NOT NULL COMMENT "", - `lo_orderkey` bigint(20) NOT NULL COMMENT "", - `lo_linenumber` bigint(20) NOT NULL COMMENT "", - `lo_custkey` int(11) NOT NULL COMMENT "", - `lo_partkey` int(11) NOT NULL COMMENT "", - `lo_suppkey` int(11) NOT NULL COMMENT "", - `lo_orderpriority` varchar(16) NOT NULL COMMENT "", - `lo_shippriority` int(11) NOT NULL COMMENT "", - `lo_quantity` bigint(20) NOT NULL COMMENT "", - `lo_extendedprice` bigint(20) NOT NULL COMMENT "", - `lo_ordtotalprice` bigint(20) NOT NULL COMMENT "", - `lo_discount` bigint(20) NOT NULL COMMENT "", - `lo_revenue` bigint(20) NOT NULL COMMENT "", - `lo_supplycost` bigint(20) NOT NULL COMMENT "", - `lo_tax` bigint(20) NOT NULL COMMENT "", - `lo_commitdate` bigint(20) NOT NULL COMMENT "", - `lo_shipmode` varchar(11) NOT NULL COMMENT "" -) -UNIQUE KEY (`lo_orderdate`,`lo_orderkey`,`lo_linenumber`) -PARTITION BY RANGE(`lo_orderdate`) -(PARTITION p1992 VALUES [("-2147483648"), ("19930101")), -PARTITION p1993 VALUES [("19930101"), ("19940101")), -PARTITION p1994 VALUES [("19940101"), ("19950101")), -PARTITION p1995 VALUES [("19950101"), ("19960101")), -PARTITION p1996 VALUES [("19960101"), ("19970101")), -PARTITION p1997 VALUES [("19970101"), ("19980101")), -PARTITION p1998 VALUES [("19980101"), ("19990101"))) -DISTRIBUTED BY HASH(`lo_orderkey`) BUCKETS 48 -PROPERTIES ( -"compression"="zstd", -"replication_num" = "1" -); diff --git a/regression-test/suites/ssb_unique_sql_zstd_p0/ddl/lineorder_delete.sql b/regression-test/suites/ssb_unique_sql_zstd_p0/ddl/lineorder_delete.sql deleted file mode 100644 index 329e040060edc6..00000000000000 --- a/regression-test/suites/ssb_unique_sql_zstd_p0/ddl/lineorder_delete.sql +++ /dev/null @@ -1 +0,0 @@ -truncate table lineorder; \ No newline at end of file diff --git a/regression-test/suites/ssb_unique_sql_zstd_p0/ddl/part_create.sql b/regression-test/suites/ssb_unique_sql_zstd_p0/ddl/part_create.sql deleted file mode 100644 index becc59157c388b..00000000000000 --- a/regression-test/suites/ssb_unique_sql_zstd_p0/ddl/part_create.sql +++ /dev/null @@ -1,17 +0,0 @@ -CREATE TABLE IF NOT EXISTS `part` ( - `p_partkey` int(11) NOT NULL COMMENT "", - `p_name` varchar(23) NOT NULL COMMENT "", - `p_mfgr` varchar(7) NOT NULL COMMENT "", - `p_category` varchar(8) NOT NULL COMMENT "", - `p_brand` varchar(10) NOT NULL COMMENT "", - `p_color` varchar(12) NOT NULL COMMENT "", - `p_type` varchar(26) NOT NULL COMMENT "", - `p_size` int(11) NOT NULL COMMENT "", - `p_container` varchar(11) NOT NULL COMMENT "" -) -UNIQUE KEY (`p_partkey`) -DISTRIBUTED BY HASH(`p_partkey`) BUCKETS 10 -PROPERTIES ( -"compression"="zstd", -"replication_num" = "1" -); diff --git a/regression-test/suites/ssb_unique_sql_zstd_p0/ddl/part_delete.sql b/regression-test/suites/ssb_unique_sql_zstd_p0/ddl/part_delete.sql deleted file mode 100644 index 02c6abd2539add..00000000000000 --- a/regression-test/suites/ssb_unique_sql_zstd_p0/ddl/part_delete.sql +++ /dev/null @@ -1 +0,0 @@ -truncate table `part`; \ No newline at end of file diff --git a/regression-test/suites/ssb_unique_sql_zstd_p0/ddl/supplier_create.sql b/regression-test/suites/ssb_unique_sql_zstd_p0/ddl/supplier_create.sql deleted file mode 100644 index 783946219627f0..00000000000000 --- a/regression-test/suites/ssb_unique_sql_zstd_p0/ddl/supplier_create.sql +++ /dev/null @@ -1,15 +0,0 @@ -CREATE TABLE IF NOT EXISTS `supplier` ( - `s_suppkey` int(11) NOT NULL COMMENT "", - `s_name` varchar(26) NOT NULL COMMENT "", - `s_address` varchar(26) NOT NULL COMMENT "", - `s_city` varchar(11) NOT NULL COMMENT "", - `s_nation` varchar(16) NOT NULL COMMENT "", - `s_region` varchar(13) NOT NULL COMMENT "", - `s_phone` varchar(16) NOT NULL COMMENT "" -) -UNIQUE KEY (`s_suppkey`) -DISTRIBUTED BY HASH(`s_suppkey`) BUCKETS 10 -PROPERTIES ( -"compression"="zstd", -"replication_num" = "1" -); diff --git a/regression-test/suites/ssb_unique_sql_zstd_p0/ddl/supplier_delete.sql b/regression-test/suites/ssb_unique_sql_zstd_p0/ddl/supplier_delete.sql deleted file mode 100644 index 39e663134cabd0..00000000000000 --- a/regression-test/suites/ssb_unique_sql_zstd_p0/ddl/supplier_delete.sql +++ /dev/null @@ -1 +0,0 @@ -truncate table `supplier`; \ No newline at end of file diff --git a/regression-test/suites/ssb_unique_sql_zstd_p0/load.groovy b/regression-test/suites/ssb_unique_sql_zstd_p0/load.groovy deleted file mode 100644 index 5e0a460569cb34..00000000000000 --- a/regression-test/suites/ssb_unique_sql_zstd_p0/load.groovy +++ /dev/null @@ -1,82 +0,0 @@ -// Licensed to the Apache Software Foundation (ASF) under one -// or more contributor license agreements. See the NOTICE file -// distributed with this work for additional information -// regarding copyright ownership. The ASF licenses this file -// to you under the Apache License, Version 2.0 (the -// "License"); you may not use this file except in compliance -// with the License. You may obtain a copy of the License at -// -// http://www.apache.org/licenses/LICENSE-2.0 -// -// Unless required by applicable law or agreed to in writing, -// software distributed under the License is distributed on an -// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY -// KIND, either express or implied. See the License for the -// specific language governing permissions and limitations -// under the License. - -// Most of the cases are copied from https://github.com/trinodb/trino/tree/master -// /testing/trino-product-tests/src/main/resources/sql-tests/testcases -// and modified by Doris. - -// Note: To filter out tables from sql files, use the following one-liner comamnd -// sed -nr 's/.*tables: (.*)$/\1/gp' /path/to/*.sql | sed -nr 's/,/\n/gp' | sort | uniq -suite("load") { - def tables = ["customer", "lineorder", "part", "date", "supplier"] - def columns = ["""c_custkey,c_name,c_address,c_city,c_nation,c_region,c_phone,c_mktsegment,no_use""", - """lo_orderkey,lo_linenumber,lo_custkey,lo_partkey,lo_suppkey,lo_orderdate,lo_orderpriority, - lo_shippriority,lo_quantity,lo_extendedprice,lo_ordtotalprice,lo_discount, - lo_revenue,lo_supplycost,lo_tax,lo_commitdate,lo_shipmode,lo_dummy""", - """p_partkey,p_name,p_mfgr,p_category,p_brand,p_color,p_type,p_size,p_container,p_dummy""", - """d_datekey,d_date,d_dayofweek,d_month,d_year,d_yearmonthnum,d_yearmonth, - d_daynuminweek,d_daynuminmonth,d_daynuminyear,d_monthnuminyear,d_weeknuminyear, - d_sellingseason,d_lastdayinweekfl,d_lastdayinmonthfl,d_holidayfl,d_weekdayfl,d_dummy""", - """s_suppkey,s_name,s_address,s_city,s_nation,s_region,s_phone,s_dummy"""] - - for (String table in tables) { - sql new File("""${context.file.parent}/ddl/${table}_create.sql""").text - sql new File("""${context.file.parent}/ddl/${table}_delete.sql""").text - } - def i = 0 - for (String tableName in tables) { - streamLoad { - // a default db 'regression_test' is specified in - // ${DORIS_HOME}/conf/regression-conf.groovy - table tableName - - // default label is UUID: - // set 'label' UUID.randomUUID().toString() - - // default column_separator is specify in doris fe config, usually is '\t'. - // this line change to ',' - set 'column_separator', '|' - set 'compress_type', 'GZ' - set 'columns', columns[i] - - - // relate to ${DORIS_HOME}/regression-test/data/demo/streamload_input.csv. - // also, you can stream load a http stream, e.g. http://xxx/some.csv - file """${getS3Url()}/regression/ssb/sf0.1/${tableName}.tbl.gz""" - - time 10000 // limit inflight 10s - - // stream load action will check result, include Success status, and NumberTotalRows == NumberLoadedRows - - // if declared a check callback, the default check condition will ignore. - // So you must check all condition - check { result, exception, startTime, endTime -> - if (exception != null) { - throw exception - } - log.info("Stream load result: ${result}".toString()) - def json = parseJson(result) - assertEquals("success", json.Status.toLowerCase()) - assertEquals(json.NumberTotalRows, json.NumberLoadedRows) - assertTrue(json.NumberLoadedRows > 0 && json.LoadBytes > 0) - } - } - i++ - } - - sql """ sync """ -} diff --git a/regression-test/suites/ssb_unique_sql_zstd_p0/partition_sort_node/test_partiiton_sort.groovy b/regression-test/suites/ssb_unique_sql_zstd_p0/partition_sort_node/test_partiiton_sort.groovy deleted file mode 100644 index d9f6776b3ace9b..00000000000000 --- a/regression-test/suites/ssb_unique_sql_zstd_p0/partition_sort_node/test_partiiton_sort.groovy +++ /dev/null @@ -1,34 +0,0 @@ -// Licensed to the Apache Software Foundation (ASF) under one -// or more contributor license agreements. See the NOTICE file -// distributed with this work for additional information -// regarding copyright ownership. The ASF licenses this file -// to you under the Apache License, Version 2.0 (the -// "License"); you may not use this file except in compliance -// with the License. You may obtain a copy of the License at -// -// http://www.apache.org/licenses/LICENSE-2.0 -// -// Unless required by applicable law or agreed to in writing, -// software distributed under the License is distributed on an -// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY -// KIND, either express or implied. See the License for the -// specific language governing permissions and limitations -// under the License. - -suite("test_partition_sort") { - sql "use regression_test_ssb_unique_sql_zstd_p0" - qt_select0 """ select count() from part; """ - qt_select1 """ select count(distinct p_name), count(distinct p_color),count(distinct rn),count(distinct rk),count(distinct dr) from ( - select p_name, p_color , row_number() over(partition by p_name order by p_color) as rn,rank() over(partition by p_name order by p_color) as rk, - dense_rank() over(partition by p_name order by p_color) as dr from part) as t; """ - - qt_select2 """ select * from ( - select p_name, p_color , row_number() over(partition by p_name order by p_color) as rn from part) as t where rn=14 order by 1,2,3; """ - - qt_select3 """ select * from ( select p_name, p_color , rank() over(partition by p_name order by p_color) as rn from part) as t where rn=11 order by 1,2,3; """ - - qt_select4 """ select * from ( select p_name, p_color , dense_rank() over(partition by p_name order by p_color) as rn from part) as t where rn=10 order by 1,2,3; """ - - - -} \ No newline at end of file diff --git a/regression-test/suites/ssb_unique_sql_zstd_p0/sql/q1.1.sql b/regression-test/suites/ssb_unique_sql_zstd_p0/sql/q1.1.sql deleted file mode 100644 index 4ef15e93ea2f5f..00000000000000 --- a/regression-test/suites/ssb_unique_sql_zstd_p0/sql/q1.1.sql +++ /dev/null @@ -1,24 +0,0 @@ --- Licensed to the Apache Software Foundation (ASF) under one --- or more contributor license agreements. See the NOTICE file --- distributed with this work for additional information --- regarding copyright ownership. The ASF licenses this file --- to you under the Apache License, Version 2.0 (the --- "License"); you may not use this file except in compliance --- with the License. You may obtain a copy of the License at --- --- http://www.apache.org/licenses/LICENSE-2.0 --- --- Unless required by applicable law or agreed to in writing, --- software distributed under the License is distributed on an --- "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY --- KIND, either express or implied. See the License for the --- specific language governing permissions and limitations --- under the License. - -SELECT SUM(lo_extendedprice*lo_discount) AS -REVENUE -FROM lineorder, date -WHERE lo_orderdate = d_datekey -AND d_year = 1993 -AND lo_discount BETWEEN 1 AND 3 -AND lo_quantity < 25; diff --git a/regression-test/suites/ssb_unique_sql_zstd_p0/sql/q1.2.sql b/regression-test/suites/ssb_unique_sql_zstd_p0/sql/q1.2.sql deleted file mode 100644 index 1b8442bd939454..00000000000000 --- a/regression-test/suites/ssb_unique_sql_zstd_p0/sql/q1.2.sql +++ /dev/null @@ -1,24 +0,0 @@ --- Licensed to the Apache Software Foundation (ASF) under one --- or more contributor license agreements. See the NOTICE file --- distributed with this work for additional information --- regarding copyright ownership. The ASF licenses this file --- to you under the Apache License, Version 2.0 (the --- "License"); you may not use this file except in compliance --- with the License. You may obtain a copy of the License at --- --- http://www.apache.org/licenses/LICENSE-2.0 --- --- Unless required by applicable law or agreed to in writing, --- software distributed under the License is distributed on an --- "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY --- KIND, either express or implied. See the License for the --- specific language governing permissions and limitations --- under the License. - -SELECT SUM(lo_extendedprice*lo_discount) AS -REVENUE -FROM lineorder, date -WHERE lo_orderdate = d_datekey -AND d_yearmonth = 'Jan1994' -AND lo_discount BETWEEN 4 AND 6 -AND lo_quantity BETWEEN 26 AND 35; diff --git a/regression-test/suites/ssb_unique_sql_zstd_p0/sql/q1.3.sql b/regression-test/suites/ssb_unique_sql_zstd_p0/sql/q1.3.sql deleted file mode 100644 index ed6e51b1cfd264..00000000000000 --- a/regression-test/suites/ssb_unique_sql_zstd_p0/sql/q1.3.sql +++ /dev/null @@ -1,25 +0,0 @@ --- Licensed to the Apache Software Foundation (ASF) under one --- or more contributor license agreements. See the NOTICE file --- distributed with this work for additional information --- regarding copyright ownership. The ASF licenses this file --- to you under the Apache License, Version 2.0 (the --- "License"); you may not use this file except in compliance --- with the License. You may obtain a copy of the License at --- --- http://www.apache.org/licenses/LICENSE-2.0 --- --- Unless required by applicable law or agreed to in writing, --- software distributed under the License is distributed on an --- "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY --- KIND, either express or implied. See the License for the --- specific language governing permissions and limitations --- under the License. - -SELECT SUM(lo_extendedprice*lo_discount) AS -REVENUE -FROM lineorder, date -WHERE lo_orderdate = d_datekey -AND d_weeknuminyear= 6 -AND d_year = 1994 -AND lo_discount BETWEEN 5 AND 7 -AND lo_quantity BETWEEN 26 AND 35; diff --git a/regression-test/suites/ssb_unique_sql_zstd_p0/sql/q2.1.sql b/regression-test/suites/ssb_unique_sql_zstd_p0/sql/q2.1.sql deleted file mode 100644 index e1a1f52d189e4e..00000000000000 --- a/regression-test/suites/ssb_unique_sql_zstd_p0/sql/q2.1.sql +++ /dev/null @@ -1,26 +0,0 @@ --- Licensed to the Apache Software Foundation (ASF) under one --- or more contributor license agreements. See the NOTICE file --- distributed with this work for additional information --- regarding copyright ownership. The ASF licenses this file --- to you under the Apache License, Version 2.0 (the --- "License"); you may not use this file except in compliance --- with the License. You may obtain a copy of the License at --- --- http://www.apache.org/licenses/LICENSE-2.0 --- --- Unless required by applicable law or agreed to in writing, --- software distributed under the License is distributed on an --- "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY --- KIND, either express or implied. See the License for the --- specific language governing permissions and limitations --- under the License. - -SELECT SUM(lo_revenue), d_year, p_brand -FROM lineorder, date, part, supplier -WHERE lo_orderdate = d_datekey -AND lo_partkey = p_partkey -AND lo_suppkey = s_suppkey -AND p_category = 'MFGR#12' -AND s_region = 'AMERICA' -GROUP BY d_year, p_brand -ORDER BY d_year, p_brand; diff --git a/regression-test/suites/ssb_unique_sql_zstd_p0/sql/q2.2.sql b/regression-test/suites/ssb_unique_sql_zstd_p0/sql/q2.2.sql deleted file mode 100644 index 3db617011947ef..00000000000000 --- a/regression-test/suites/ssb_unique_sql_zstd_p0/sql/q2.2.sql +++ /dev/null @@ -1,27 +0,0 @@ --- Licensed to the Apache Software Foundation (ASF) under one --- or more contributor license agreements. See the NOTICE file --- distributed with this work for additional information --- regarding copyright ownership. The ASF licenses this file --- to you under the Apache License, Version 2.0 (the --- "License"); you may not use this file except in compliance --- with the License. You may obtain a copy of the License at --- --- http://www.apache.org/licenses/LICENSE-2.0 --- --- Unless required by applicable law or agreed to in writing, --- software distributed under the License is distributed on an --- "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY --- KIND, either express or implied. See the License for the --- specific language governing permissions and limitations --- under the License. - -SELECT SUM(lo_revenue), d_year, p_brand -FROM lineorder, date, part, supplier -WHERE lo_orderdate = d_datekey -AND lo_partkey = p_partkey -AND lo_suppkey = s_suppkey -AND p_brand BETWEEN 'MFGR#2221' -AND 'MFGR#2228' -AND s_region = 'ASIA' -GROUP BY d_year, p_brand -ORDER BY d_year, p_brand; diff --git a/regression-test/suites/ssb_unique_sql_zstd_p0/sql/q2.3.sql b/regression-test/suites/ssb_unique_sql_zstd_p0/sql/q2.3.sql deleted file mode 100644 index b70ca90666b8fe..00000000000000 --- a/regression-test/suites/ssb_unique_sql_zstd_p0/sql/q2.3.sql +++ /dev/null @@ -1,26 +0,0 @@ --- Licensed to the Apache Software Foundation (ASF) under one --- or more contributor license agreements. See the NOTICE file --- distributed with this work for additional information --- regarding copyright ownership. The ASF licenses this file --- to you under the Apache License, Version 2.0 (the --- "License"); you may not use this file except in compliance --- with the License. You may obtain a copy of the License at --- --- http://www.apache.org/licenses/LICENSE-2.0 --- --- Unless required by applicable law or agreed to in writing, --- software distributed under the License is distributed on an --- "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY --- KIND, either express or implied. See the License for the --- specific language governing permissions and limitations --- under the License. - -SELECT SUM(lo_revenue), d_year, p_brand -FROM lineorder, date, part, supplier -WHERE lo_orderdate = d_datekey -AND lo_partkey = p_partkey -AND lo_suppkey = s_suppkey -AND p_brand = 'MFGR#2239' -AND s_region = 'EUROPE' -GROUP BY d_year, p_brand -ORDER BY d_year, p_brand; diff --git a/regression-test/suites/ssb_unique_sql_zstd_p0/sql/q2.3_broadcast_join_sink_eof.sql b/regression-test/suites/ssb_unique_sql_zstd_p0/sql/q2.3_broadcast_join_sink_eof.sql deleted file mode 100644 index 763df454a97e34..00000000000000 --- a/regression-test/suites/ssb_unique_sql_zstd_p0/sql/q2.3_broadcast_join_sink_eof.sql +++ /dev/null @@ -1,36 +0,0 @@ --- Licensed to the Apache Software Foundation (ASF) under one --- or more contributor license agreements. See the NOTICE file --- distributed with this work for additional information --- regarding copyright ownership. The ASF licenses this file --- to you under the Apache License, Version 2.0 (the --- "License"); you may not use this file except in compliance --- with the License. You may obtain a copy of the License at --- --- http://www.apache.org/licenses/LICENSE-2.0 --- --- Unless required by applicable law or agreed to in writing, --- software distributed under the License is distributed on an --- "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY --- KIND, either express or implied. See the License for the --- specific language governing permissions and limitations --- under the License. - -SELECT - /*+SET_VAR(experimental_enable_pipeline_engine=false,parallel_fragment_exec_instance_num=2)*/ - SUM(lo_revenue), - d_year, - p_brand -FROM - lineorder - join [broadcast] date on lo_orderdate = d_datekey - join [broadcast] part on lo_partkey = p_partkey - join [broadcast] supplier on lo_suppkey = s_suppkey -WHERE - p_brand = 'MFGR#2239' - AND s_region = 'EUROPE' -GROUP BY - d_year, - p_brand -ORDER BY - d_year, - p_brand; diff --git a/regression-test/suites/ssb_unique_sql_zstd_p0/sql/q3.1.sql b/regression-test/suites/ssb_unique_sql_zstd_p0/sql/q3.1.sql deleted file mode 100644 index 70f17d789b45a2..00000000000000 --- a/regression-test/suites/ssb_unique_sql_zstd_p0/sql/q3.1.sql +++ /dev/null @@ -1,28 +0,0 @@ --- Licensed to the Apache Software Foundation (ASF) under one --- or more contributor license agreements. See the NOTICE file --- distributed with this work for additional information --- regarding copyright ownership. The ASF licenses this file --- to you under the Apache License, Version 2.0 (the --- "License"); you may not use this file except in compliance --- with the License. You may obtain a copy of the License at --- --- http://www.apache.org/licenses/LICENSE-2.0 --- --- Unless required by applicable law or agreed to in writing, --- software distributed under the License is distributed on an --- "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY --- KIND, either express or implied. See the License for the --- specific language governing permissions and limitations --- under the License. - -SELECT c_nation, s_nation, d_year, -SUM(lo_revenue) AS REVENUE -FROM customer, lineorder, supplier, date -WHERE lo_custkey = c_custkey -AND lo_suppkey = s_suppkey -AND lo_orderdate = d_datekey -AND c_region = 'ASIA' -AND s_region = 'ASIA' -AND d_year >= 1992 AND d_year <= 1997 -GROUP BY c_nation, s_nation, d_year -ORDER BY d_year ASC, REVENUE DESC; diff --git a/regression-test/suites/ssb_unique_sql_zstd_p0/sql/q3.2.sql b/regression-test/suites/ssb_unique_sql_zstd_p0/sql/q3.2.sql deleted file mode 100644 index a416fbea8b1768..00000000000000 --- a/regression-test/suites/ssb_unique_sql_zstd_p0/sql/q3.2.sql +++ /dev/null @@ -1,28 +0,0 @@ --- Licensed to the Apache Software Foundation (ASF) under one --- or more contributor license agreements. See the NOTICE file --- distributed with this work for additional information --- regarding copyright ownership. The ASF licenses this file --- to you under the Apache License, Version 2.0 (the --- "License"); you may not use this file except in compliance --- with the License. You may obtain a copy of the License at --- --- http://www.apache.org/licenses/LICENSE-2.0 --- --- Unless required by applicable law or agreed to in writing, --- software distributed under the License is distributed on an --- "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY --- KIND, either express or implied. See the License for the --- specific language governing permissions and limitations --- under the License. - -SELECT c_city, s_city, d_year, sum(lo_revenue) -AS REVENUE -FROM customer, lineorder, supplier, date -WHERE lo_custkey = c_custkey -AND lo_suppkey = s_suppkey -AND lo_orderdate = d_datekey -AND c_nation = 'UNITED STATES' -AND s_nation = 'UNITED STATES' -AND d_year >= 1992 AND d_year <= 1997 -GROUP BY c_city, s_city, d_year -ORDER BY d_year ASC, REVENUE DESC; diff --git a/regression-test/suites/ssb_unique_sql_zstd_p0/sql/q3.3.sql b/regression-test/suites/ssb_unique_sql_zstd_p0/sql/q3.3.sql deleted file mode 100644 index 98e29b72e70bf0..00000000000000 --- a/regression-test/suites/ssb_unique_sql_zstd_p0/sql/q3.3.sql +++ /dev/null @@ -1,30 +0,0 @@ --- Licensed to the Apache Software Foundation (ASF) under one --- or more contributor license agreements. See the NOTICE file --- distributed with this work for additional information --- regarding copyright ownership. The ASF licenses this file --- to you under the Apache License, Version 2.0 (the --- "License"); you may not use this file except in compliance --- with the License. You may obtain a copy of the License at --- --- http://www.apache.org/licenses/LICENSE-2.0 --- --- Unless required by applicable law or agreed to in writing, --- software distributed under the License is distributed on an --- "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY --- KIND, either express or implied. See the License for the --- specific language governing permissions and limitations --- under the License. - -SELECT c_city, s_city, d_year, SUM(lo_revenue) -AS REVENUE -FROM customer, lineorder, supplier, date -WHERE lo_custkey = c_custkey -AND lo_suppkey = s_suppkey -AND lo_orderdate = d_datekey -AND (c_city='UNITED KI1' -OR c_city='UNITED KI5') -AND (s_city='UNITED KI1' -OR s_city='UNITED KI5') -AND d_year >= 1992 AND d_year <= 1997 -GROUP BY c_city, s_city, d_year -ORDER BY d_year ASC, REVENUE DESC; diff --git a/regression-test/suites/ssb_unique_sql_zstd_p0/sql/q3.4.sql b/regression-test/suites/ssb_unique_sql_zstd_p0/sql/q3.4.sql deleted file mode 100644 index 65fe992ca4f12b..00000000000000 --- a/regression-test/suites/ssb_unique_sql_zstd_p0/sql/q3.4.sql +++ /dev/null @@ -1,30 +0,0 @@ --- Licensed to the Apache Software Foundation (ASF) under one --- or more contributor license agreements. See the NOTICE file --- distributed with this work for additional information --- regarding copyright ownership. The ASF licenses this file --- to you under the Apache License, Version 2.0 (the --- "License"); you may not use this file except in compliance --- with the License. You may obtain a copy of the License at --- --- http://www.apache.org/licenses/LICENSE-2.0 --- --- Unless required by applicable law or agreed to in writing, --- software distributed under the License is distributed on an --- "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY --- KIND, either express or implied. See the License for the --- specific language governing permissions and limitations --- under the License. - -SELECT c_city, s_city, d_year, SUM(lo_revenue) -AS REVENUE -FROM customer, lineorder, supplier, date -WHERE lo_custkey = c_custkey -AND lo_suppkey = s_suppkey -AND lo_orderdate = d_datekey -AND (c_city='UNITED KI1' -OR c_city='UNITED KI5') -AND (s_city='UNITED KI1' -OR s_city='UNITED KI5') -AND d_yearmonth = 'Dec1997' -GROUP BY c_city, s_city, d_year -ORDER BY d_year ASC, REVENUE DESC; diff --git a/regression-test/suites/ssb_unique_sql_zstd_p0/sql/q4.1.sql b/regression-test/suites/ssb_unique_sql_zstd_p0/sql/q4.1.sql deleted file mode 100644 index bdcd730bf922fe..00000000000000 --- a/regression-test/suites/ssb_unique_sql_zstd_p0/sql/q4.1.sql +++ /dev/null @@ -1,30 +0,0 @@ --- Licensed to the Apache Software Foundation (ASF) under one --- or more contributor license agreements. See the NOTICE file --- distributed with this work for additional information --- regarding copyright ownership. The ASF licenses this file --- to you under the Apache License, Version 2.0 (the --- "License"); you may not use this file except in compliance --- with the License. You may obtain a copy of the License at --- --- http://www.apache.org/licenses/LICENSE-2.0 --- --- Unless required by applicable law or agreed to in writing, --- software distributed under the License is distributed on an --- "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY --- KIND, either express or implied. See the License for the --- specific language governing permissions and limitations --- under the License. - -SELECT d_year, c_nation, -SUM(lo_revenue - lo_supplycost) AS PROFIT -FROM date, customer, supplier, part, lineorder -WHERE lo_custkey = c_custkey -AND lo_suppkey = s_suppkey -AND lo_partkey = p_partkey -AND lo_orderdate = d_datekey -AND c_region = 'AMERICA' -AND s_region = 'AMERICA' -AND (p_mfgr = 'MFGR#1' -OR p_mfgr = 'MFGR#2') -GROUP BY d_year, c_nation -ORDER BY d_year, c_nation; diff --git a/regression-test/suites/ssb_unique_sql_zstd_p0/sql/q4.2.sql b/regression-test/suites/ssb_unique_sql_zstd_p0/sql/q4.2.sql deleted file mode 100644 index 24c82cf682d155..00000000000000 --- a/regression-test/suites/ssb_unique_sql_zstd_p0/sql/q4.2.sql +++ /dev/null @@ -1,31 +0,0 @@ --- Licensed to the Apache Software Foundation (ASF) under one --- or more contributor license agreements. See the NOTICE file --- distributed with this work for additional information --- regarding copyright ownership. The ASF licenses this file --- to you under the Apache License, Version 2.0 (the --- "License"); you may not use this file except in compliance --- with the License. You may obtain a copy of the License at --- --- http://www.apache.org/licenses/LICENSE-2.0 --- --- Unless required by applicable law or agreed to in writing, --- software distributed under the License is distributed on an --- "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY --- KIND, either express or implied. See the License for the --- specific language governing permissions and limitations --- under the License. - -SELECT d_year, s_nation, p_category, -SUM(lo_revenue - lo_supplycost) AS PROFIT -FROM date, customer, supplier, part, lineorder -WHERE lo_custkey = c_custkey -AND lo_suppkey = s_suppkey -AND lo_partkey = p_partkey -AND lo_orderdate = d_datekey -AND c_region = 'AMERICA' -AND s_region = 'AMERICA' -AND (d_year = 1997 OR d_year = 1998) -AND (p_mfgr = 'MFGR#1' -OR p_mfgr = 'MFGR#2') -GROUP BY d_year, s_nation, p_category -ORDER BY d_year, s_nation, p_category; diff --git a/regression-test/suites/ssb_unique_sql_zstd_p0/sql/q4.3.sql b/regression-test/suites/ssb_unique_sql_zstd_p0/sql/q4.3.sql deleted file mode 100644 index 0dcc08bd26c8ad..00000000000000 --- a/regression-test/suites/ssb_unique_sql_zstd_p0/sql/q4.3.sql +++ /dev/null @@ -1,29 +0,0 @@ --- Licensed to the Apache Software Foundation (ASF) under one --- or more contributor license agreements. See the NOTICE file --- distributed with this work for additional information --- regarding copyright ownership. The ASF licenses this file --- to you under the Apache License, Version 2.0 (the --- "License"); you may not use this file except in compliance --- with the License. You may obtain a copy of the License at --- --- http://www.apache.org/licenses/LICENSE-2.0 --- --- Unless required by applicable law or agreed to in writing, --- software distributed under the License is distributed on an --- "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY --- KIND, either express or implied. See the License for the --- specific language governing permissions and limitations --- under the License. - -SELECT d_year, s_city, p_brand, -SUM(lo_revenue - lo_supplycost) AS PROFIT -FROM date, customer, supplier, part, lineorder -WHERE lo_custkey = c_custkey -AND lo_suppkey = s_suppkey -AND lo_partkey = p_partkey -AND lo_orderdate = d_datekey -AND s_nation = 'UNITED STATES' -AND (d_year = 1997 OR d_year = 1998) -AND p_category = 'MFGR#14' -GROUP BY d_year, s_city, p_brand -ORDER BY d_year, s_city, p_brand; diff --git a/regression-test/suites/tpch_unique_sql_zstd_p0/ddl/customer.sql b/regression-test/suites/tpch_unique_sql_zstd_p0/ddl/customer.sql deleted file mode 100644 index 6a8a8565ef703b..00000000000000 --- a/regression-test/suites/tpch_unique_sql_zstd_p0/ddl/customer.sql +++ /dev/null @@ -1,17 +0,0 @@ -CREATE TABLE IF NOT EXISTS customer ( - C_CUSTKEY INTEGER NOT NULL, - C_NAME VARCHAR(25) NOT NULL, - C_ADDRESS VARCHAR(40) NOT NULL, - C_NATIONKEY INTEGER NOT NULL, - C_PHONE CHAR(15) NOT NULL, - C_ACCTBAL DECIMAL(15,2) NOT NULL, - C_MKTSEGMENT CHAR(10) NOT NULL, - C_COMMENT VARCHAR(117) NOT NULL -) -UNIQUE KEY(C_CUSTKEY, C_NAME) -DISTRIBUTED BY HASH(C_CUSTKEY) BUCKETS 3 -PROPERTIES ( - "compression"="zstd", - "replication_num" = "1" -) - diff --git a/regression-test/suites/tpch_unique_sql_zstd_p0/ddl/customer_delete.sql b/regression-test/suites/tpch_unique_sql_zstd_p0/ddl/customer_delete.sql deleted file mode 100644 index a214fe920c914c..00000000000000 --- a/regression-test/suites/tpch_unique_sql_zstd_p0/ddl/customer_delete.sql +++ /dev/null @@ -1 +0,0 @@ -DELETE FROM customer where C_CUSTKEY >= 0; diff --git a/regression-test/suites/tpch_unique_sql_zstd_p0/ddl/lineitem.sql b/regression-test/suites/tpch_unique_sql_zstd_p0/ddl/lineitem.sql deleted file mode 100644 index cc4f2b343de255..00000000000000 --- a/regression-test/suites/tpch_unique_sql_zstd_p0/ddl/lineitem.sql +++ /dev/null @@ -1,25 +0,0 @@ -CREATE TABLE IF NOT EXISTS lineitem ( - L_ORDERKEY INTEGER NOT NULL, - L_PARTKEY INTEGER NOT NULL, - L_SUPPKEY INTEGER NOT NULL, - L_LINENUMBER INTEGER NOT NULL, - L_QUANTITY DECIMAL(15,2) NOT NULL, - L_EXTENDEDPRICE DECIMAL(15,2) NOT NULL, - L_DISCOUNT DECIMAL(15,2) NOT NULL, - L_TAX DECIMAL(15,2) NOT NULL, - L_RETURNFLAG CHAR(1) NOT NULL, - L_LINESTATUS CHAR(1) NOT NULL, - L_SHIPDATE DATE NOT NULL, - L_COMMITDATE DATE NOT NULL, - L_RECEIPTDATE DATE NOT NULL, - L_SHIPINSTRUCT CHAR(25) NOT NULL, - L_SHIPMODE CHAR(10) NOT NULL, - L_COMMENT VARCHAR(44) NOT NULL -) -UNIQUE KEY(L_ORDERKEY, L_PARTKEY, L_SUPPKEY, L_LINENUMBER) -DISTRIBUTED BY HASH(L_ORDERKEY) BUCKETS 3 -PROPERTIES ( - "compression"="zstd", - "replication_num" = "1" -) - diff --git a/regression-test/suites/tpch_unique_sql_zstd_p0/ddl/lineitem_delete.sql b/regression-test/suites/tpch_unique_sql_zstd_p0/ddl/lineitem_delete.sql deleted file mode 100644 index 6dbbe49ed0b52d..00000000000000 --- a/regression-test/suites/tpch_unique_sql_zstd_p0/ddl/lineitem_delete.sql +++ /dev/null @@ -1 +0,0 @@ -DELETE from lineitem where L_ORDERKEY >= 0; diff --git a/regression-test/suites/tpch_unique_sql_zstd_p0/ddl/nation.sql b/regression-test/suites/tpch_unique_sql_zstd_p0/ddl/nation.sql deleted file mode 100644 index 8329c839e34a3c..00000000000000 --- a/regression-test/suites/tpch_unique_sql_zstd_p0/ddl/nation.sql +++ /dev/null @@ -1,13 +0,0 @@ -CREATE TABLE IF NOT EXISTS nation ( - N_NATIONKEY INTEGER NOT NULL, - N_NAME CHAR(25) NOT NULL, - N_REGIONKEY INTEGER NOT NULL, - N_COMMENT VARCHAR(152) -) -UNIQUE KEY(N_NATIONKEY, N_NAME) -DISTRIBUTED BY HASH(N_NATIONKEY) BUCKETS 3 -PROPERTIES ( - "compression"="zstd", - "replication_num" = "1" -) - diff --git a/regression-test/suites/tpch_unique_sql_zstd_p0/ddl/nation_delete.sql b/regression-test/suites/tpch_unique_sql_zstd_p0/ddl/nation_delete.sql deleted file mode 100644 index 9fb7c085a6fea3..00000000000000 --- a/regression-test/suites/tpch_unique_sql_zstd_p0/ddl/nation_delete.sql +++ /dev/null @@ -1 +0,0 @@ -DELETE from nation where N_NATIONKEY >= 0; diff --git a/regression-test/suites/tpch_unique_sql_zstd_p0/ddl/orders.sql b/regression-test/suites/tpch_unique_sql_zstd_p0/ddl/orders.sql deleted file mode 100644 index 9cfc187c5f3dc1..00000000000000 --- a/regression-test/suites/tpch_unique_sql_zstd_p0/ddl/orders.sql +++ /dev/null @@ -1,18 +0,0 @@ -CREATE TABLE IF NOT EXISTS orders ( - O_ORDERKEY INTEGER NOT NULL, - O_CUSTKEY INTEGER NOT NULL, - O_ORDERSTATUS CHAR(1) NOT NULL, - O_TOTALPRICE DECIMAL(15,2) NOT NULL, - O_ORDERDATE DATE NOT NULL, - O_ORDERPRIORITY CHAR(15) NOT NULL, - O_CLERK CHAR(15) NOT NULL, - O_SHIPPRIORITY INTEGER NOT NULL, - O_COMMENT VARCHAR(79) NOT NULL -) -UNIQUE KEY(O_ORDERKEY, O_CUSTKEY) -DISTRIBUTED BY HASH(O_ORDERKEY) BUCKETS 3 -PROPERTIES ( - "compression"="zstd", - "replication_num" = "1" -) - diff --git a/regression-test/suites/tpch_unique_sql_zstd_p0/ddl/orders_delete.sql b/regression-test/suites/tpch_unique_sql_zstd_p0/ddl/orders_delete.sql deleted file mode 100644 index 5199d8f296dc90..00000000000000 --- a/regression-test/suites/tpch_unique_sql_zstd_p0/ddl/orders_delete.sql +++ /dev/null @@ -1 +0,0 @@ -delete from orders where O_ORDERKEY >= 0; diff --git a/regression-test/suites/tpch_unique_sql_zstd_p0/ddl/part.sql b/regression-test/suites/tpch_unique_sql_zstd_p0/ddl/part.sql deleted file mode 100644 index 3f66b80a9bdc11..00000000000000 --- a/regression-test/suites/tpch_unique_sql_zstd_p0/ddl/part.sql +++ /dev/null @@ -1,18 +0,0 @@ -CREATE TABLE IF NOT EXISTS part ( - P_PARTKEY INTEGER NOT NULL, - P_NAME VARCHAR(55) NOT NULL, - P_MFGR CHAR(25) NOT NULL, - P_BRAND CHAR(10) NOT NULL, - P_TYPE VARCHAR(25) NOT NULL, - P_SIZE INTEGER NOT NULL, - P_CONTAINER CHAR(10) NOT NULL, - P_RETAILPRICE DECIMAL(15,2) NOT NULL, - P_COMMENT VARCHAR(23) NOT NULL -) -UNIQUE KEY(P_PARTKEY, P_NAME) -DISTRIBUTED BY HASH(P_PARTKEY) BUCKETS 3 -PROPERTIES ( - "compression"="zstd", - "replication_num" = "1" -) - diff --git a/regression-test/suites/tpch_unique_sql_zstd_p0/ddl/part_delete.sql b/regression-test/suites/tpch_unique_sql_zstd_p0/ddl/part_delete.sql deleted file mode 100644 index ee1a2e5104503a..00000000000000 --- a/regression-test/suites/tpch_unique_sql_zstd_p0/ddl/part_delete.sql +++ /dev/null @@ -1 +0,0 @@ -delete from part where P_PARTKEY>=0; diff --git a/regression-test/suites/tpch_unique_sql_zstd_p0/ddl/partsupp.sql b/regression-test/suites/tpch_unique_sql_zstd_p0/ddl/partsupp.sql deleted file mode 100644 index 06fc71f4f197d0..00000000000000 --- a/regression-test/suites/tpch_unique_sql_zstd_p0/ddl/partsupp.sql +++ /dev/null @@ -1,14 +0,0 @@ -CREATE TABLE IF NOT EXISTS partsupp ( - PS_PARTKEY INTEGER NOT NULL, - PS_SUPPKEY INTEGER NOT NULL, - PS_AVAILQTY INTEGER NOT NULL, - PS_SUPPLYCOST DECIMAL(15,2) NOT NULL, - PS_COMMENT VARCHAR(199) NOT NULL -) -UNIQUE KEY(PS_PARTKEY, PS_SUPPKEY) -DISTRIBUTED BY HASH(PS_PARTKEY) BUCKETS 3 -PROPERTIES ( - "compression"="zstd", - "replication_num" = "1" -) - diff --git a/regression-test/suites/tpch_unique_sql_zstd_p0/ddl/partsupp_delete.sql b/regression-test/suites/tpch_unique_sql_zstd_p0/ddl/partsupp_delete.sql deleted file mode 100644 index 067cff3a6f0f77..00000000000000 --- a/regression-test/suites/tpch_unique_sql_zstd_p0/ddl/partsupp_delete.sql +++ /dev/null @@ -1 +0,0 @@ -delete from partsupp where PS_PARTKEY>=0; diff --git a/regression-test/suites/tpch_unique_sql_zstd_p0/ddl/region.sql b/regression-test/suites/tpch_unique_sql_zstd_p0/ddl/region.sql deleted file mode 100644 index c73f47cf12b823..00000000000000 --- a/regression-test/suites/tpch_unique_sql_zstd_p0/ddl/region.sql +++ /dev/null @@ -1,12 +0,0 @@ -CREATE TABLE IF NOT EXISTS region ( - R_REGIONKEY INTEGER NOT NULL, - R_NAME CHAR(25) NOT NULL, - R_COMMENT VARCHAR(152) -) -UNIQUE KEY(R_REGIONKEY, R_NAME) -DISTRIBUTED BY HASH(R_REGIONKEY) BUCKETS 3 -PROPERTIES ( - "compression"="zstd", - "replication_num" = "1" -) - diff --git a/regression-test/suites/tpch_unique_sql_zstd_p0/ddl/region_delete.sql b/regression-test/suites/tpch_unique_sql_zstd_p0/ddl/region_delete.sql deleted file mode 100644 index 4945d5105ab6cf..00000000000000 --- a/regression-test/suites/tpch_unique_sql_zstd_p0/ddl/region_delete.sql +++ /dev/null @@ -1 +0,0 @@ -delete from region where R_REGIONKEY>=0; diff --git a/regression-test/suites/tpch_unique_sql_zstd_p0/ddl/revenue1.sql b/regression-test/suites/tpch_unique_sql_zstd_p0/ddl/revenue1.sql deleted file mode 100644 index a12a60a2848a2d..00000000000000 --- a/regression-test/suites/tpch_unique_sql_zstd_p0/ddl/revenue1.sql +++ /dev/null @@ -1,11 +0,0 @@ -CREATE VIEW IF NOT EXISTS revenue1 AS - SELECT - l_suppkey AS supplier_no, - sum(l_extendedprice * (1 - l_discount)) AS total_revenue - FROM - lineitem - WHERE - l_shipdate >= DATE '1996-01-01' - AND l_shipdate < DATE '1996-01-01' + INTERVAL '3' MONTH -GROUP BY - l_suppkey; diff --git a/regression-test/suites/tpch_unique_sql_zstd_p0/ddl/revenue1_delete.sql b/regression-test/suites/tpch_unique_sql_zstd_p0/ddl/revenue1_delete.sql deleted file mode 100644 index 12b50f19605a16..00000000000000 --- a/regression-test/suites/tpch_unique_sql_zstd_p0/ddl/revenue1_delete.sql +++ /dev/null @@ -1 +0,0 @@ -drop view IF EXISTS revenue1; diff --git a/regression-test/suites/tpch_unique_sql_zstd_p0/ddl/supplier.sql b/regression-test/suites/tpch_unique_sql_zstd_p0/ddl/supplier.sql deleted file mode 100644 index d65df14f0f57a9..00000000000000 --- a/regression-test/suites/tpch_unique_sql_zstd_p0/ddl/supplier.sql +++ /dev/null @@ -1,15 +0,0 @@ -CREATE TABLE IF NOT EXISTS supplier ( - S_SUPPKEY INTEGER NOT NULL, - S_NAME CHAR(25) NOT NULL, - S_ADDRESS VARCHAR(40) NOT NULL, - S_NATIONKEY INTEGER NOT NULL, - S_PHONE CHAR(15) NOT NULL, - S_ACCTBAL DECIMAL(15,2) NOT NULL, - S_COMMENT VARCHAR(101) NOT NULL -) -UNIQUE KEY(S_SUPPKEY, S_NAME) -DISTRIBUTED BY HASH(S_SUPPKEY) BUCKETS 3 -PROPERTIES ( - "compression"="zstd", - "replication_num" = "1" -) diff --git a/regression-test/suites/tpch_unique_sql_zstd_p0/ddl/supplier_delete.sql b/regression-test/suites/tpch_unique_sql_zstd_p0/ddl/supplier_delete.sql deleted file mode 100644 index d8327a8f856334..00000000000000 --- a/regression-test/suites/tpch_unique_sql_zstd_p0/ddl/supplier_delete.sql +++ /dev/null @@ -1 +0,0 @@ -delete from supplier where S_SUPPKEY>=0; diff --git a/regression-test/suites/tpch_unique_sql_zstd_p0/load.groovy b/regression-test/suites/tpch_unique_sql_zstd_p0/load.groovy deleted file mode 100644 index b18f35c1215e5d..00000000000000 --- a/regression-test/suites/tpch_unique_sql_zstd_p0/load.groovy +++ /dev/null @@ -1,88 +0,0 @@ -// Licensed to the Apache Software Foundation (ASF) under one -// or more contributor license agreements. See the NOTICE file -// distributed with this work for additional information -// regarding copyright ownership. The ASF licenses this file -// to you under the Apache License, Version 2.0 (the -// "License"); you may not use this file except in compliance -// with the License. You may obtain a copy of the License at -// -// http://www.apache.org/licenses/LICENSE-2.0 -// -// Unless required by applicable law or agreed to in writing, -// software distributed under the License is distributed on an -// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY -// KIND, either express or implied. See the License for the -// specific language governing permissions and limitations -// under the License. - -// Most of the cases are copied from https://github.com/trinodb/trino/tree/master -// /testing/trino-product-tests/src/main/resources/sql-tests/testcases -// and modified by Doris. - -// syntax error: -// q06 q13 q15 -// Test 23 suites, failed 3 suites - -// Note: To filter out tables from sql files, use the following one-liner comamnd -// sed -nr 's/.*tables: (.*)$/\1/gp' /path/to/*.sql | sed -nr 's/,/\n/gp' | sort | uniq -suite("load") { - def tables = [customer: ["c_custkey, c_name, c_address, c_nationkey, c_phone, c_acctbal, c_mktsegment, c_comment,temp"], - lineitem: ["l_orderkey, l_partkey, l_suppkey, l_linenumber, l_quantity, l_extendedprice, l_discount, l_tax, l_returnflag,l_linestatus, l_shipdate,l_commitdate,l_receiptdate,l_shipinstruct,l_shipmode,l_comment,temp"], - nation : ["n_nationkey, n_name, n_regionkey, n_comment, temp"], - orders : ["o_orderkey, o_custkey, o_orderstatus, o_totalprice, o_orderdate, o_orderpriority, o_clerk, o_shippriority, o_comment, temp"], - part : ["p_partkey, p_name, p_mfgr, p_brand, p_type, p_size, p_container, p_retailprice, p_comment, temp"], - partsupp: ["ps_partkey,ps_suppkey,ps_availqty,ps_supplycost,ps_comment,temp"], - region : ["r_regionkey, r_name, r_comment,temp"], - supplier: ["s_suppkey, s_name, s_address, s_nationkey, s_phone, s_acctbal, s_comment,temp"]] - - tables.forEach { tableName, columns -> - sql new File("""${context.file.parent}/ddl/${tableName}.sql""").text - sql new File("""${context.file.parent}/ddl/${tableName}_delete.sql""").text - streamLoad { - // a default db 'regression_test' is specified in - // ${DORIS_HOME}/conf/regression-conf.groovy - table "${tableName}" - - // default label is UUID: - // set 'label' UUID.randomUUID().toString() - - // default column_separator is specify in doris fe config, usually is '\t'. - // this line change to ',' - set 'column_separator', '|' - set 'compress_type', 'GZ' - set 'columns', "${columns[0]}" - - // relate to ${DORIS_HOME}/regression-test/data/demo/streamload_input.csv. - // also, you can stream load a http stream, e.g. http://xxx/some.csv - file """${getS3Url()}/regression/tpch/sf0.1/${tableName}.tbl.gz""" - - time 10000 // limit inflight 10s - - // stream load action will check result, include Success status, and NumberTotalRows == NumberLoadedRows - - // if declared a check callback, the default check condition will ignore. - // So you must check all condition - check { result, exception, startTime, endTime -> - if (exception != null) { - throw exception - } - log.info("Stream load result: ${result}".toString()) - def json = parseJson(result) - assertEquals("success", json.Status.toLowerCase()) - assertEquals(json.NumberTotalRows, json.NumberLoadedRows) - assertTrue(json.NumberLoadedRows > 0 && json.LoadBytes > 0) - } - } - } - - Thread.sleep(70000) // wait for row count report of the tables just loaded - tables.forEach { tableName, columns -> - sql """ ANALYZE TABLE $tableName WITH SYNC """ - } - - def table = "revenue1" - sql new File("""${context.file.parent}/ddl/${table}_delete.sql""").text - sql new File("""${context.file.parent}/ddl/${table}.sql""").text - - sql """ sync """ -} diff --git a/regression-test/suites/tpch_unique_sql_zstd_p0/sql/q01.sql b/regression-test/suites/tpch_unique_sql_zstd_p0/sql/q01.sql deleted file mode 100644 index 7b20cc9febb2cb..00000000000000 --- a/regression-test/suites/tpch_unique_sql_zstd_p0/sql/q01.sql +++ /dev/null @@ -1,22 +0,0 @@ --- tables: lineitem -SELECT - l_returnflag, - l_linestatus, - sum(l_quantity) AS sum_qty, - sum(l_extendedprice) AS sum_base_price, - sum(l_extendedprice * (1 - l_discount)) AS sum_disc_price, - sum(l_extendedprice * (1 - l_discount) * (1 + l_tax)) AS sum_charge, - avg(l_quantity) AS avg_qty, - avg(l_extendedprice) AS avg_price, - avg(l_discount) AS avg_disc, - count(*) AS count_order -FROM - lineitem -WHERE - l_shipdate <= DATE '1998-12-01' - INTERVAL '90' DAY -GROUP BY -l_returnflag, -l_linestatus -ORDER BY -l_returnflag, -l_linestatus diff --git a/regression-test/suites/tpch_unique_sql_zstd_p0/sql/q02.sql b/regression-test/suites/tpch_unique_sql_zstd_p0/sql/q02.sql deleted file mode 100644 index 8c60ec1929364d..00000000000000 --- a/regression-test/suites/tpch_unique_sql_zstd_p0/sql/q02.sql +++ /dev/null @@ -1,42 +0,0 @@ --- tables: part,supplier,partsupp,nation,region -SELECT - s_acctbal, - s_name, - n_name, - p_partkey, - p_mfgr, - s_address, - s_phone, - s_comment -FROM - part, - supplier, - partsupp, - nation, - region -WHERE - p_partkey = ps_partkey - AND s_suppkey = ps_suppkey - AND p_size = 15 - AND p_type LIKE '%BRASS' - AND s_nationkey = n_nationkey - AND n_regionkey = r_regionkey - AND r_name = 'EUROPE' - AND ps_supplycost = ( - SELECT min(ps_supplycost) - FROM - partsupp, supplier, - nation, region - WHERE - p_partkey = ps_partkey - AND s_suppkey = ps_suppkey - AND s_nationkey = n_nationkey - AND n_regionkey = r_regionkey - AND r_name = 'EUROPE' - ) -ORDER BY - s_acctbal DESC, - n_name, - s_name, - p_partkey -LIMIT 100 diff --git a/regression-test/suites/tpch_unique_sql_zstd_p0/sql/q03.sql b/regression-test/suites/tpch_unique_sql_zstd_p0/sql/q03.sql deleted file mode 100644 index e689d3cbb0878b..00000000000000 --- a/regression-test/suites/tpch_unique_sql_zstd_p0/sql/q03.sql +++ /dev/null @@ -1,24 +0,0 @@ --- tables: customer,orders,lineitem -SELECT - l_orderkey, - sum(l_extendedprice * (1 - l_discount)) AS revenue, - o_orderdate, - o_shippriority -FROM - customer, - orders, - lineitem -WHERE - c_mktsegment = 'BUILDING' - AND c_custkey = o_custkey - AND l_orderkey = o_orderkey - AND o_orderdate < DATE '1995-03-15' - AND l_shipdate > DATE '1995-03-15' -GROUP BY - l_orderkey, - o_orderdate, - o_shippriority -ORDER BY - revenue DESC, - o_orderdate -LIMIT 10 diff --git a/regression-test/suites/tpch_unique_sql_zstd_p0/sql/q04.sql b/regression-test/suites/tpch_unique_sql_zstd_p0/sql/q04.sql deleted file mode 100644 index c4c7925eb70ff9..00000000000000 --- a/regression-test/suites/tpch_unique_sql_zstd_p0/sql/q04.sql +++ /dev/null @@ -1,19 +0,0 @@ --- tables: orders,lineitem -SELECT - o_orderpriority, - count(*) AS order_count -FROM orders -WHERE - o_orderdate >= DATE '1993-07-01' - AND o_orderdate < DATE '1993-07-01' + INTERVAL '3' MONTH -AND EXISTS ( -SELECT * -FROM lineitem -WHERE -l_orderkey = o_orderkey -AND l_commitdate < l_receiptdate -) -GROUP BY -o_orderpriority -ORDER BY -o_orderpriority diff --git a/regression-test/suites/tpch_unique_sql_zstd_p0/sql/q05.sql b/regression-test/suites/tpch_unique_sql_zstd_p0/sql/q05.sql deleted file mode 100644 index 059725c12ac8a0..00000000000000 --- a/regression-test/suites/tpch_unique_sql_zstd_p0/sql/q05.sql +++ /dev/null @@ -1,25 +0,0 @@ --- tables: customer,orders,lineitem,supplier,nation,region -SELECT - n_name, - sum(l_extendedprice * (1 - l_discount)) AS revenue -FROM - customer, - orders, - lineitem, - supplier, - nation, - region -WHERE - c_custkey = o_custkey - AND l_orderkey = o_orderkey - AND l_suppkey = s_suppkey - AND c_nationkey = s_nationkey - AND s_nationkey = n_nationkey - AND n_regionkey = r_regionkey - AND r_name = 'ASIA' - AND o_orderdate >= DATE '1994-01-01' - AND o_orderdate < DATE '1994-01-01' + INTERVAL '1' YEAR -GROUP BY -n_name -ORDER BY -revenue DESC diff --git a/regression-test/suites/tpch_unique_sql_zstd_p0/sql/q06.sql b/regression-test/suites/tpch_unique_sql_zstd_p0/sql/q06.sql deleted file mode 100644 index e81a352c2410e7..00000000000000 --- a/regression-test/suites/tpch_unique_sql_zstd_p0/sql/q06.sql +++ /dev/null @@ -1,11 +0,0 @@ --- tables: lineitem - -SELECT sum(l_extendedprice * l_discount) AS revenue -FROM - lineitem -WHERE - l_shipdate >= DATE '1994-01-01' - AND l_shipdate < DATE '1994-01-01' + INTERVAL '1' YEAR -AND l_discount BETWEEN 0.06 - 0.01 AND .06 + 0.01 -AND l_quantity < 24 - diff --git a/regression-test/suites/tpch_unique_sql_zstd_p0/sql/q07.sql b/regression-test/suites/tpch_unique_sql_zstd_p0/sql/q07.sql deleted file mode 100644 index edeaf35f7f0c33..00000000000000 --- a/regression-test/suites/tpch_unique_sql_zstd_p0/sql/q07.sql +++ /dev/null @@ -1,39 +0,0 @@ --- tables: supplier,lineitem,orders,customer,nation -SELECT - supp_nation, - cust_nation, - l_year, - sum(volume) AS revenue -FROM ( - SELECT - n1.n_name AS supp_nation, - n2.n_name AS cust_nation, - extract(YEAR FROM l_shipdate) AS l_year, - l_extendedprice * (1 - l_discount) AS volume - FROM - supplier, - lineitem, - orders, - customer, - nation n1, - nation n2 - WHERE - s_suppkey = l_suppkey - AND o_orderkey = l_orderkey - AND c_custkey = o_custkey - AND s_nationkey = n1.n_nationkey - AND c_nationkey = n2.n_nationkey - AND ( - (n1.n_name = 'FRANCE' AND n2.n_name = 'GERMANY') - OR (n1.n_name = 'GERMANY' AND n2.n_name = 'FRANCE') - ) - AND l_shipdate BETWEEN DATE '1995-01-01' AND DATE '1996-12-31' - ) AS shipping -GROUP BY - supp_nation, - cust_nation, - l_year -ORDER BY - supp_nation, - cust_nation, - l_year diff --git a/regression-test/suites/tpch_unique_sql_zstd_p0/sql/q08.sql b/regression-test/suites/tpch_unique_sql_zstd_p0/sql/q08.sql deleted file mode 100644 index 2657711d79fe1c..00000000000000 --- a/regression-test/suites/tpch_unique_sql_zstd_p0/sql/q08.sql +++ /dev/null @@ -1,38 +0,0 @@ --- tables: part,supplier,lineitem,orders,customer,nation,region -SELECT - o_year, - sum(CASE - WHEN nation = 'BRAZIL' - THEN volume - ELSE 0 - END) / sum(volume) AS mkt_share -FROM ( - SELECT - extract(YEAR FROM o_orderdate) AS o_year, - l_extendedprice * (1 - l_discount) AS volume, - n2.n_name AS nation - FROM - part, - supplier, - lineitem, - orders, - customer, - nation n1, - nation n2, - region - WHERE - p_partkey = l_partkey - AND s_suppkey = l_suppkey - AND l_orderkey = o_orderkey - AND o_custkey = c_custkey - AND c_nationkey = n1.n_nationkey - AND n1.n_regionkey = r_regionkey - AND r_name = 'AMERICA' - AND s_nationkey = n2.n_nationkey - AND o_orderdate BETWEEN DATE '1995-01-01' AND DATE '1996-12-31' - AND p_type = 'ECONOMY ANODIZED STEEL' - ) AS all_nations -GROUP BY - o_year -ORDER BY - o_year diff --git a/regression-test/suites/tpch_unique_sql_zstd_p0/sql/q09.sql b/regression-test/suites/tpch_unique_sql_zstd_p0/sql/q09.sql deleted file mode 100644 index 9236941881f39b..00000000000000 --- a/regression-test/suites/tpch_unique_sql_zstd_p0/sql/q09.sql +++ /dev/null @@ -1,32 +0,0 @@ --- tables: part,supplier,lineitem,partsupp,orders,nation -SELECT - nation, - o_year, - sum(amount) AS sum_profit -FROM ( - SELECT - n_name AS nation, - extract(YEAR FROM o_orderdate) AS o_year, - l_extendedprice * (1 - l_discount) - ps_supplycost * l_quantity AS amount - FROM - part, - supplier, - lineitem, - partsupp, - orders, - nation - WHERE - s_suppkey = l_suppkey - AND ps_suppkey = l_suppkey - AND ps_partkey = l_partkey - AND p_partkey = l_partkey - AND o_orderkey = l_orderkey - AND s_nationkey = n_nationkey - AND p_name LIKE '%green%' - ) AS profit -GROUP BY - nation, - o_year -ORDER BY - nation, - o_year DESC diff --git a/regression-test/suites/tpch_unique_sql_zstd_p0/sql/q10.sql b/regression-test/suites/tpch_unique_sql_zstd_p0/sql/q10.sql deleted file mode 100644 index 965bc17b3c0de7..00000000000000 --- a/regression-test/suites/tpch_unique_sql_zstd_p0/sql/q10.sql +++ /dev/null @@ -1,33 +0,0 @@ --- tables: customer,orders,lineitem,nation -SELECT - c_custkey, - c_name, - sum(l_extendedprice * (1 - l_discount)) AS revenue, - c_acctbal, - n_name, - c_address, - c_phone, - c_comment -FROM - customer, - orders, - lineitem, - nation -WHERE - c_custkey = o_custkey - AND l_orderkey = o_orderkey - AND o_orderdate >= DATE '1993-10-01' - AND o_orderdate < DATE '1993-10-01' + INTERVAL '3' MONTH - AND l_returnflag = 'R' - AND c_nationkey = n_nationkey -GROUP BY - c_custkey, - c_name, - c_acctbal, - c_phone, - n_name, - c_address, - c_comment -ORDER BY - revenue DESC -LIMIT 20 diff --git a/regression-test/suites/tpch_unique_sql_zstd_p0/sql/q11.sql b/regression-test/suites/tpch_unique_sql_zstd_p0/sql/q11.sql deleted file mode 100644 index 18856461ea2e2d..00000000000000 --- a/regression-test/suites/tpch_unique_sql_zstd_p0/sql/q11.sql +++ /dev/null @@ -1,28 +0,0 @@ --- tables: partsupp,supplier,nation -SELECT - ps_partkey, - sum(ps_supplycost * ps_availqty) AS value -FROM - partsupp, - supplier, - nation -WHERE - ps_suppkey = s_suppkey - AND s_nationkey = n_nationkey - AND n_name = 'GERMANY' -GROUP BY - ps_partkey -HAVING - sum(ps_supplycost * ps_availqty) > ( - SELECT sum(ps_supplycost * ps_availqty) * 0.0001 - FROM - partsupp, - supplier, - nation - WHERE - ps_suppkey = s_suppkey - AND s_nationkey = n_nationkey - AND n_name = 'GERMANY' - ) -ORDER BY - value DESC diff --git a/regression-test/suites/tpch_unique_sql_zstd_p0/sql/q12.sql b/regression-test/suites/tpch_unique_sql_zstd_p0/sql/q12.sql deleted file mode 100644 index 3312d53dc4ad1c..00000000000000 --- a/regression-test/suites/tpch_unique_sql_zstd_p0/sql/q12.sql +++ /dev/null @@ -1,29 +0,0 @@ --- tables: orders,lineitem -SELECT - l_shipmode, - sum(CASE - WHEN o_orderpriority = '1-URGENT' - OR o_orderpriority = '2-HIGH' - THEN 1 - ELSE 0 - END) AS high_line_count, - sum(CASE - WHEN o_orderpriority <> '1-URGENT' - AND o_orderpriority <> '2-HIGH' - THEN 1 - ELSE 0 - END) AS low_line_count -FROM - orders, - lineitem -WHERE - o_orderkey = l_orderkey - AND l_shipmode IN ('MAIL', 'SHIP') - AND l_commitdate < l_receiptdate - AND l_shipdate < l_commitdate - AND l_receiptdate >= DATE '1994-01-01' - AND l_receiptdate < DATE '1994-01-01' + INTERVAL '1' YEAR -GROUP BY - l_shipmode -ORDER BY - l_shipmode diff --git a/regression-test/suites/tpch_unique_sql_zstd_p0/sql/q13.sql b/regression-test/suites/tpch_unique_sql_zstd_p0/sql/q13.sql deleted file mode 100644 index f7d69a955f94d1..00000000000000 --- a/regression-test/suites/tpch_unique_sql_zstd_p0/sql/q13.sql +++ /dev/null @@ -1,21 +0,0 @@ --- tables: customer -SELECT - c_count, - count(*) AS custdist -FROM ( - SELECT - c_custkey, - count(o_orderkey) AS c_count - FROM - customer - LEFT OUTER JOIN orders ON - c_custkey = o_custkey - AND o_comment NOT LIKE '%special%requests%' - GROUP BY - c_custkey - ) AS c_orders -GROUP BY - c_count -ORDER BY - custdist DESC, - c_count DESC diff --git a/regression-test/suites/tpch_unique_sql_zstd_p0/sql/q14.sql b/regression-test/suites/tpch_unique_sql_zstd_p0/sql/q14.sql deleted file mode 100644 index 8fb3730bc23138..00000000000000 --- a/regression-test/suites/tpch_unique_sql_zstd_p0/sql/q14.sql +++ /dev/null @@ -1,13 +0,0 @@ --- tables: lineitem,part -SELECT 100.00 * sum(CASE - WHEN p_type LIKE 'PROMO%' - THEN l_extendedprice * (1 - l_discount) - ELSE 0 - END) / sum(l_extendedprice * (1 - l_discount)) AS promo_revenue -FROM - lineitem, - part -WHERE - l_partkey = p_partkey - AND l_shipdate >= DATE '1995-09-01' - AND l_shipdate < DATE '1995-09-01' + INTERVAL '1' MONTH diff --git a/regression-test/suites/tpch_unique_sql_zstd_p0/sql/q15.sql b/regression-test/suites/tpch_unique_sql_zstd_p0/sql/q15.sql deleted file mode 100644 index 80cd87be5d2e2e..00000000000000 --- a/regression-test/suites/tpch_unique_sql_zstd_p0/sql/q15.sql +++ /dev/null @@ -1,20 +0,0 @@ -SELECT - s_suppkey, - s_name, - s_address, - s_phone, - total_revenue -FROM - supplier, - revenue1 -WHERE - s_suppkey = supplier_no - AND total_revenue = ( - SELECT max(total_revenue) - FROM - revenue1 - ) -ORDER BY - s_suppkey; - - diff --git a/regression-test/suites/tpch_unique_sql_zstd_p0/sql/q16.sql b/regression-test/suites/tpch_unique_sql_zstd_p0/sql/q16.sql deleted file mode 100644 index 277777cb13acdc..00000000000000 --- a/regression-test/suites/tpch_unique_sql_zstd_p0/sql/q16.sql +++ /dev/null @@ -1,30 +0,0 @@ --- tables: partsupp,part,supplier -SELECT - p_brand, - p_type, - p_size, - count(DISTINCT ps_suppkey) AS supplier_cnt -FROM - partsupp, - part -WHERE - p_partkey = ps_partkey - AND p_brand <> 'Brand#45' - AND p_type NOT LIKE 'MEDIUM POLISHED%' - AND p_size IN (49, 14, 23, 45, 19, 3, 36, 9) - AND ps_suppkey NOT IN ( - SELECT s_suppkey - FROM - supplier - WHERE - s_comment LIKE '%Customer%Complaints%' - ) -GROUP BY - p_brand, - p_type, - p_size -ORDER BY - supplier_cnt DESC, - p_brand, - p_type, - p_size diff --git a/regression-test/suites/tpch_unique_sql_zstd_p0/sql/q17.sql b/regression-test/suites/tpch_unique_sql_zstd_p0/sql/q17.sql deleted file mode 100644 index c37f2ceedba52e..00000000000000 --- a/regression-test/suites/tpch_unique_sql_zstd_p0/sql/q17.sql +++ /dev/null @@ -1,16 +0,0 @@ --- tables: lineitem,part -SELECT sum(l_extendedprice) / 7.0 AS avg_yearly -FROM - lineitem, - part -WHERE - p_partkey = l_partkey - AND p_brand = 'Brand#23' - AND p_container = 'MED BOX' - AND l_quantity < ( - SELECT 0.2 * avg(l_quantity) - FROM - lineitem - WHERE - l_partkey = p_partkey - ) diff --git a/regression-test/suites/tpch_unique_sql_zstd_p0/sql/q18.sql b/regression-test/suites/tpch_unique_sql_zstd_p0/sql/q18.sql deleted file mode 100644 index 98db1d60466178..00000000000000 --- a/regression-test/suites/tpch_unique_sql_zstd_p0/sql/q18.sql +++ /dev/null @@ -1,34 +0,0 @@ --- tables: customer,orders,lineitem -SELECT - c_name, - c_custkey, - o_orderkey, - o_orderdate, - o_totalprice, - sum(l_quantity) -FROM - customer, - orders, - lineitem -WHERE - o_orderkey IN ( - SELECT l_orderkey - FROM - lineitem - GROUP BY - l_orderkey - HAVING - sum(l_quantity) > 300 - ) - AND c_custkey = o_custkey - AND o_orderkey = l_orderkey -GROUP BY - c_name, - c_custkey, - o_orderkey, - o_orderdate, - o_totalprice -ORDER BY - o_totalprice DESC, - o_orderdate -LIMIT 100 diff --git a/regression-test/suites/tpch_unique_sql_zstd_p0/sql/q19.sql b/regression-test/suites/tpch_unique_sql_zstd_p0/sql/q19.sql deleted file mode 100644 index c4e107cd68bc01..00000000000000 --- a/regression-test/suites/tpch_unique_sql_zstd_p0/sql/q19.sql +++ /dev/null @@ -1,35 +0,0 @@ --- tables: lineitem,part -SELECT sum(l_extendedprice * (1 - l_discount)) AS revenue -FROM - lineitem, - part -WHERE - ( - p_partkey = l_partkey - AND p_brand = 'Brand#12' - AND p_container IN ('SM CASE', 'SM BOX', 'SM PACK', 'SM PKG') - AND l_quantity >= 1 AND l_quantity <= 1 + 10 - AND p_size BETWEEN 1 AND 5 - AND l_shipmode IN ('AIR', 'AIR REG') - AND l_shipinstruct = 'DELIVER IN PERSON' - ) - OR - ( - p_partkey = l_partkey - AND p_brand = 'Brand#23' - AND p_container IN ('MED BAG', 'MED BOX', 'MED PKG', 'MED PACK') - AND l_quantity >= 10 AND l_quantity <= 10 + 10 - AND p_size BETWEEN 1 AND 10 - AND l_shipmode IN ('AIR', 'AIR REG') - AND l_shipinstruct = 'DELIVER IN PERSON' - ) - OR - ( - p_partkey = l_partkey - AND p_brand = 'Brand#34' - AND p_container IN ('LG CASE', 'LG BOX', 'LG PACK', 'LG PKG') - AND l_quantity >= 20 AND l_quantity <= 20 + 10 - AND p_size BETWEEN 1 AND 15 - AND l_shipmode IN ('AIR', 'AIR REG') - AND l_shipinstruct = 'DELIVER IN PERSON' - ) diff --git a/regression-test/suites/tpch_unique_sql_zstd_p0/sql/q20.sql b/regression-test/suites/tpch_unique_sql_zstd_p0/sql/q20.sql deleted file mode 100644 index 6d4ef5bcfc9155..00000000000000 --- a/regression-test/suites/tpch_unique_sql_zstd_p0/sql/q20.sql +++ /dev/null @@ -1,33 +0,0 @@ --- tables: supplier,nation,partsupp,lineitem,part -SELECT - s_name, - s_address -FROM - supplier, nation -WHERE - s_suppkey IN ( - SELECT ps_suppkey - FROM - partsupp - WHERE - ps_partkey IN ( - SELECT p_partkey - FROM - part - WHERE - p_name LIKE 'forest%' - ) - AND ps_availqty > ( - SELECT 0.5 * sum(l_quantity) - FROM - lineitem - WHERE - l_partkey = ps_partkey - AND l_suppkey = ps_suppkey - AND l_shipdate >= date('1994-01-01') - AND l_shipdate < date('1994-01-01') + interval '1' YEAR -) -) -AND s_nationkey = n_nationkey -AND n_name = 'CANADA' -ORDER BY s_name diff --git a/regression-test/suites/tpch_unique_sql_zstd_p0/sql/q21.sql b/regression-test/suites/tpch_unique_sql_zstd_p0/sql/q21.sql deleted file mode 100644 index 961f2749ddfe82..00000000000000 --- a/regression-test/suites/tpch_unique_sql_zstd_p0/sql/q21.sql +++ /dev/null @@ -1,39 +0,0 @@ --- tables: supplier,lineitem,orders,nation -SELECT - s_name, - count(*) AS numwait -FROM - supplier, - lineitem l1, - orders, - nation -WHERE - s_suppkey = l1.l_suppkey - AND o_orderkey = l1.l_orderkey - AND o_orderstatus = 'F' - AND l1.l_receiptdate > l1.l_commitdate - AND exists( - SELECT * - FROM - lineitem l2 - WHERE - l2.l_orderkey = l1.l_orderkey - AND l2.l_suppkey <> l1.l_suppkey - ) - AND NOT exists( - SELECT * - FROM - lineitem l3 - WHERE - l3.l_orderkey = l1.l_orderkey - AND l3.l_suppkey <> l1.l_suppkey - AND l3.l_receiptdate > l3.l_commitdate - ) - AND s_nationkey = n_nationkey - AND n_name = 'SAUDI ARABIA' -GROUP BY - s_name -ORDER BY - numwait DESC, - s_name -LIMIT 100 diff --git a/regression-test/suites/tpch_unique_sql_zstd_p0/sql/q22.sql b/regression-test/suites/tpch_unique_sql_zstd_p0/sql/q22.sql deleted file mode 100644 index 01da1804587b47..00000000000000 --- a/regression-test/suites/tpch_unique_sql_zstd_p0/sql/q22.sql +++ /dev/null @@ -1,35 +0,0 @@ --- tables: orders,customer -SELECT - cntrycode, - count(*) AS numcust, - sum(c_acctbal) AS totacctbal -FROM ( - SELECT - substr(c_phone, 1, 2) AS cntrycode, - c_acctbal - FROM - customer - WHERE - substr(c_phone, 1, 2) IN - ('13', '31', '23', '29', '30', '18', '17') - AND c_acctbal > ( - SELECT avg(c_acctbal) - FROM - customer - WHERE - c_acctbal > 0.00 - AND substr(c_phone, 1, 2) IN - ('13', '31', '23', '29', '30', '18', '17') - ) - AND NOT exists( - SELECT * - FROM - orders - WHERE - o_custkey = c_custkey - ) - ) AS custsale -GROUP BY - cntrycode -ORDER BY - cntrycode