diff --git a/regression-test/suites/nereids_p0/insert_into_table/aggregate.groovy b/regression-test/suites/nereids_p0/insert_into_table/aggregate.groovy index d151cf43c2..9665e5520d 100644 --- a/regression-test/suites/nereids_p0/insert_into_table/aggregate.groovy +++ b/regression-test/suites/nereids_p0/insert_into_table/aggregate.groovy @@ -26,19 +26,23 @@ suite("nereids_insert_aggregate") { sql '''insert into nereids_insert_into_table_test.agg_t select * except(kaint) from src''' + sql 'sync' qt_11 'select * from agg_t order by id, kint' sql '''insert into nereids_insert_into_table_test.agg_t with label label_agg_cte with cte as (select * except(kaint) from src) select * from cte''' + sql 'sync' qt_12 'select * from agg_t order by id, kint' sql '''insert into nereids_insert_into_table_test.agg_t partition (p1, p2) with label label_agg select * except(kaint) from src where id < 4''' + sql 'sync' qt_13 'select * from agg_t order by id, kint' sql '''insert into nereids_insert_into_table_test.agg_light_sc_t select * except(kaint) from src''' + sql 'sync' qt_21 'select * from agg_light_sc_t order by id, kint' sql '''insert into nereids_insert_into_table_test.agg_light_sc_t with label label_agg_light_sc_cte @@ -48,32 +52,39 @@ suite("nereids_insert_aggregate") { sql '''insert into nereids_insert_into_table_test.agg_light_sc_t partition (p1, p2) with label label_agg_light_sc select * except(kaint) from src where id < 4''' + sql 'sync' qt_23 'select * from agg_light_sc_t order by id, kint' sql '''insert into nereids_insert_into_table_test.agg_not_null_t select * except(kaint) from src where id is not null''' + sql 'sync' qt_31 'select * from agg_not_null_t order by id, kint' sql '''insert into nereids_insert_into_table_test.agg_not_null_t with label label_agg_not_null_cte with cte as (select * except(kaint) from src) select * from cte where id is not null''' + sql 'sync' qt_32 'select * from agg_not_null_t order by id, kint' sql '''insert into nereids_insert_into_table_test.agg_not_null_t partition (p1, p2) with label label_agg_not_null select * except(kaint) from src where id < 4 and id is not null''' + sql 'sync' qt_33 'select * from agg_not_null_t order by id, kint' sql '''insert into nereids_insert_into_table_test.agg_light_sc_not_null_t select * except(kaint) from src where id is not null''' + sql 'sync' qt_41 'select * from agg_light_sc_not_null_t order by id, kint' sql '''insert into nereids_insert_into_table_test.agg_light_sc_not_null_t with label label_agg_light_sc_not_null_cte with cte as (select * except(kaint) from src) select * from cte where id is not null''' + sql 'sync' qt_42 'select * from agg_light_sc_not_null_t order by id, kint' sql '''insert into nereids_insert_into_table_test.agg_light_sc_not_null_t partition (p1, p2) with label label_agg_light_sc_not_null select * except(kaint) from src where id < 4 and id is not null''' + sql 'sync' qt_43 'select * from agg_light_sc_not_null_t order by id, kint' // test light_schema_change @@ -82,9 +93,11 @@ suite("nereids_insert_aggregate") { sql '''insert into nereids_insert_into_table_test.agg_light_sc_t select * except(kaint) from src''' + sql 'sync' qt_lsc1 'select * from agg_light_sc_t order by id, kint' sql '''insert into nereids_insert_into_table_test.agg_light_sc_not_null_t select * except(kaint) from src where id is not null''' + sql 'sync' qt_lsc2 'select * from agg_light_sc_not_null_t order by id, kint' } \ No newline at end of file diff --git a/regression-test/suites/nereids_p0/insert_into_table/complex_insert.groovy b/regression-test/suites/nereids_p0/insert_into_table/complex_insert.groovy index 7533fabf90..3bcf030861 100644 --- a/regression-test/suites/nereids_p0/insert_into_table/complex_insert.groovy +++ b/regression-test/suites/nereids_p0/insert_into_table/complex_insert.groovy @@ -64,12 +64,15 @@ suite('complex_insert') { ''' sql 'insert into dup_comp_t (id, kint, ksint) select id, kint, ksint from src' + sql 'sync' qt_sql_dup 'select * from dup_comp_t order by id, ksint' sql 'insert into agg_comp_t (id, kint, ksint) select id, kint, ksint from src' + sql 'sync' qt_sql_agg 'select * from agg_comp_t order by id, ksint' sql 'insert into uni_comp_t (id, kint, ksint) select id, kint, ksint from src' + sql 'sync' qt_sql_uni 'select * from uni_comp_t order by id, ksint' sql 'truncate table dup_comp_t' @@ -80,6 +83,7 @@ suite('complex_insert') { (select id, min(kbint) minv from src group by id, kbool) t2 where t1.id = t2.id ''' + sql 'sync' qt_sql_dup 'select * from dup_comp_t order by id, ksint, kint' sql 'truncate table agg_comp_t' @@ -90,6 +94,7 @@ suite('complex_insert') { (select id, min(kbint) minv from src group by id, kbool) t2 where t1.id = t2.id ''' + sql 'sync' qt_sql_agg 'select * from agg_comp_t order by id, ksint, kint' sql 'truncate table uni_comp_t' @@ -100,6 +105,7 @@ suite('complex_insert') { (select id, min(kbint) minv from src group by id, kbool) t2 where t1.id = t2.id ''' + sql 'sync' qt_sql_uni 'select * from uni_comp_t order by id, ksint, kint' sql 'drop table if exists t1' @@ -169,15 +175,15 @@ suite('complex_insert') { ''' sql 'insert into t1(id, c1, c2, c3) select id, c1 * 2, c2, c3 from t1' - + sql 'sync' qt_sql_1 'select * from t1, t2, t3 order by t1.id, t1.id1, t2.id, t3.id' sql 'insert into t2(id, c1, c2, c3) select id, c1, c2 * 2, c3 from t2' - + sql 'sync' qt_sql_2 'select * from t1, t2, t3 order by t1.id, t1.id1, t2.id, t3.id' sql 'insert into t2(c1, c3) select c1 + 1, c3 + 1 from (select id, c1, c3 from t1 order by id, c1 limit 10) t1, t3' - + sql 'sync' qt_sql_3 'select * from t1, t2, t3 order by t1.id, t1.id1, t2.id, t3.id' sql 'drop table if exists agg_have_dup_base' @@ -200,7 +206,7 @@ suite('complex_insert') { ''' sql 'insert into agg_have_dup_base select -4, -4, -4, \'d\'' - + sql 'sync' qt_mv 'select * from agg_have_dup_base' } \ No newline at end of file diff --git a/regression-test/suites/nereids_p0/insert_into_table/duplicate.groovy b/regression-test/suites/nereids_p0/insert_into_table/duplicate.groovy index 0a8fabae08..167952190c 100644 --- a/regression-test/suites/nereids_p0/insert_into_table/duplicate.groovy +++ b/regression-test/suites/nereids_p0/insert_into_table/duplicate.groovy @@ -26,54 +26,66 @@ suite("nereids_insert_duplicate") { sql '''insert into dup_t select * except(kaint) from src''' + sql 'sync' qt_11 'select * from dup_t order by id, kint' sql '''insert into dup_t with label label_dup_cte with cte as (select * except(kaint) from src) select * from cte''' + sql 'sync' qt_12 'select * from dup_t order by id, kint' sql '''insert into dup_t partition (p1, p2) with label label_dup select * except(kaint) from src where id < 4''' + sql 'sync' qt_13 'select * from dup_t order by id, kint' sql '''insert into dup_light_sc_t select * except(kaint) from src''' + sql 'sync' qt_21 'select * from dup_light_sc_t order by id, kint' sql '''insert into dup_light_sc_t with label label_dup_light_sc_cte with cte as (select * except(kaint) from src) select * from cte''' + sql 'sync' qt_22 'select * from dup_light_sc_t order by id, kint' sql '''insert into dup_light_sc_t partition (p1, p2) with label label_dup_light_sc select * except(kaint) from src where id < 4''' + sql 'sync' qt_23 'select * from dup_light_sc_t order by id, kint' sql '''insert into dup_not_null_t select * except(kaint) from src where id is not null''' + sql 'sync' qt_31 'select * from dup_not_null_t order by id, kint' sql '''insert into dup_not_null_t with label label_dup_not_null_cte with cte as (select * except(kaint) from src) select * from cte where id is not null''' + sql 'sync' qt_32 'select * from dup_not_null_t order by id, kint' sql '''insert into dup_not_null_t partition (p1, p2) with label label_dup_not_null select * except(kaint) from src where id < 4 and id is not null''' + sql 'sync' qt_33 'select * from dup_not_null_t order by id, kint' sql '''insert into dup_light_sc_not_null_t select * except(kaint) from src where id is not null''' + sql 'sync' qt_41 'select * from dup_light_sc_not_null_t order by id, kint' sql '''insert into dup_light_sc_not_null_t with label label_dup_light_sc_not_null_cte with cte as (select * except(kaint) from src) select * from cte where id is not null''' + sql 'sync' qt_42 'select * from dup_light_sc_not_null_t order by id, kint' sql '''insert into dup_light_sc_not_null_t partition (p1, p2) with label label_dup_light_sc_not_null select * except(kaint) from src where id < 4 and id is not null''' + sql 'sync' qt_43 'select * from dup_light_sc_not_null_t order by id, kint' // test light_schema_change @@ -82,9 +94,11 @@ suite("nereids_insert_duplicate") { sql '''insert into dup_light_sc_t select * except(kaint) from src''' + sql 'sync' qt_lsc1 'select * from dup_light_sc_t order by id, kint' sql '''insert into dup_light_sc_not_null_t select * except(kaint) from src where id is not null''' + sql 'sync' qt_lsc2 'select * from dup_light_sc_not_null_t order by id, kint' } \ No newline at end of file diff --git a/regression-test/suites/nereids_p0/insert_into_table/no_partition.groovy b/regression-test/suites/nereids_p0/insert_into_table/no_partition.groovy index ba9c028cce..e7d5873d36 100644 --- a/regression-test/suites/nereids_p0/insert_into_table/no_partition.groovy +++ b/regression-test/suites/nereids_p0/insert_into_table/no_partition.groovy @@ -26,83 +26,101 @@ suite('nereids_insert_no_partition') { sql '''insert into agg_nop_t select * except(kaint) from src''' + sql 'sync' qt_11 'select * from agg_nop_t order by id, kint' sql '''insert into agg_nop_t with label label_agg_cte_nop with cte as (select * except(kaint) from src) select * from cte''' + sql 'sync' qt_12 'select * from agg_nop_t order by id, kint' sql '''insert into agg_light_sc_nop_t select * except(kaint) from src''' + sql 'sync' qt_21 'select * from agg_light_sc_nop_t order by id, kint' sql '''insert into agg_light_sc_nop_t with label label_agg_light_sc_cte_nop with cte as (select * except(kaint) from src) select * from cte''' + sql 'sync' qt_22 'select * from agg_light_sc_nop_t order by id, kint' sql '''insert into agg_not_null_nop_t select * except(kaint) from src where id is not null''' + sql 'sync' qt_31 'select * from agg_not_null_nop_t order by id, kint' sql '''insert into agg_not_null_nop_t with label label_agg_not_null_cte_nop with cte as (select * except(kaint) from src) select * from cte where id is not null''' + sql 'sync' qt_32 'select * from agg_not_null_nop_t order by id, kint' sql '''insert into agg_light_sc_not_null_nop_t select * except(kaint) from src where id is not null''' + sql 'sync' qt_41 'select * from agg_light_sc_not_null_nop_t order by id, kint' sql '''insert into agg_light_sc_not_null_nop_t with label label_agg_light_sc_not_null_cte_nop with cte as (select * except(kaint) from src) select * from cte where id is not null''' + sql 'sync' qt_42 'select * from agg_light_sc_not_null_nop_t order by id, kint' sql '''insert into dup_nop_t select * except(kaint) from src''' + sql 'sync' qt_11 'select * from dup_nop_t order by id, kint' sql '''insert into dup_nop_t with label label_dup_cte_nop with cte as (select * except(kaint) from src) select * from cte''' + sql 'sync' qt_12 'select * from dup_nop_t order by id, kint' sql '''insert into dup_light_sc_nop_t select * except(kaint) from src''' + sql 'sync' qt_21 'select * from dup_light_sc_nop_t order by id, kint' sql '''insert into dup_light_sc_nop_t with label label_dup_light_sc_cte_nop with cte as (select * except(kaint) from src) select * from cte''' + sql 'sync' qt_22 'select * from dup_light_sc_nop_t order by id, kint' sql '''insert into dup_not_null_nop_t select * except(kaint) from src where id is not null''' + sql 'sync' qt_31 'select * from dup_not_null_nop_t order by id, kint' sql '''insert into dup_not_null_nop_t with label label_dup_not_null_cte_nop with cte as (select * except(kaint) from src) select * from cte where id is not null''' + sql 'sync' qt_32 'select * from dup_not_null_nop_t order by id, kint' sql '''insert into dup_light_sc_not_null_nop_t select * except(kaint) from src where id is not null''' + sql 'sync' qt_41 'select * from dup_light_sc_not_null_nop_t order by id, kint' sql '''insert into dup_light_sc_not_null_nop_t with label label_dup_light_sc_not_null_cte_nop with cte as (select * except(kaint) from src) select * from cte where id is not null''' + sql 'sync' qt_42 'select * from dup_light_sc_not_null_nop_t order by id, kint' sql '''insert into uni_nop_t select * except(kaint) from src''' + sql 'sync' qt_11 'select * from uni_nop_t order by id, kint' sql '''insert into uni_nop_t with label label_uni_cte_nop with cte as (select * except(kaint) from src) select * from cte''' + sql 'sync' qt_12 'select * from uni_nop_t order by id, kint' sql '''insert into uni_light_sc_nop_t @@ -112,60 +130,73 @@ suite('nereids_insert_no_partition') { sql '''insert into uni_light_sc_nop_t with label label_uni_light_sc_cte_nop with cte as (select * except(kaint) from src) select * from cte''' + sql 'sync' qt_22 'select * from uni_light_sc_nop_t order by id, kint' sql '''insert into uni_mow_nop_t select * except(kaint) from src''' + sql 'sync' qt_31 'select * from uni_mow_nop_t order by id, kint' sql '''insert into uni_mow_nop_t with label label_uni_mow_cte_nop with cte as (select * except(kaint) from src) select * from cte''' + sql 'sync' qt_32 'select * from uni_mow_nop_t order by id, kint' sql '''insert into uni_light_sc_mow_nop_t select * except(kaint) from src''' + sql 'sync' qt_41 'select * from uni_light_sc_mow_nop_t order by id, kint' sql '''insert into uni_light_sc_mow_nop_t with label label_uni_light_sc_mow_cte_nop with cte as (select * except(kaint) from src) select * from cte''' + sql 'sync' qt_42 'select * from uni_light_sc_mow_nop_t order by id, kint' sql '''insert into uni_mow_not_null_nop_t select * except(kaint) from src where id is not null''' + sql 'sync' qt_51 'select * from uni_mow_not_null_nop_t order by id, kint' sql '''insert into uni_mow_not_null_nop_t with label label_uni_not_null_cte_nop with cte as (select * except(kaint) from src) select * from cte where id is not null''' + sql 'sync' qt_52 'select * from uni_mow_not_null_nop_t order by id, kint' sql '''insert into uni_light_sc_mow_not_null_nop_t select * except(kaint) from src where id is not null''' + sql 'sync' qt_61 'select * from uni_light_sc_mow_not_null_nop_t order by id, kint' sql '''insert into uni_light_sc_mow_not_null_nop_t with label label_uni_light_sc_not_null_cte_nop with cte as (select * except(kaint) from src) select * from cte where id is not null''' + sql 'sync' qt_62 'select * from uni_light_sc_mow_not_null_nop_t order by id, kint' sql '''insert into uni_mow_not_null_nop_t select * except(kaint) from src where id is not null''' + sql 'sync' qt_71 'select * from uni_mow_not_null_nop_t order by id, kint' sql '''insert into uni_mow_not_null_nop_t with label label_uni_mow_not_null_cte_nop with cte as (select * except(kaint) from src) select * from cte where id is not null''' + sql 'sync' qt_72 'select * from uni_mow_not_null_nop_t order by id, kint' sql '''insert into uni_light_sc_mow_not_null_nop_t select * except(kaint) from src where id is not null''' + sql 'sync' qt_81 'select * from uni_light_sc_mow_not_null_nop_t order by id, kint' sql '''insert into uni_light_sc_mow_not_null_nop_t with label label_uni_light_sc_mow_not_null_cte_nop with cte as (select * except(kaint) from src) select * from cte where id is not null''' + sql 'sync' qt_82 'select * from uni_light_sc_mow_not_null_nop_t order by id, kint' // test light_schema_change @@ -174,10 +205,12 @@ suite('nereids_insert_no_partition') { sql '''insert into agg_light_sc_nop_t select * except(kaint) from src''' + sql 'sync' qt_lsc1 'select * from agg_light_sc_nop_t order by id, kint' sql '''insert into agg_light_sc_not_null_nop_t select * except(kaint) from src where id is not null''' + sql 'sync' qt_lsc2 'select * from agg_light_sc_not_null_nop_t order by id, kint' // test light_schema_change @@ -186,10 +219,12 @@ suite('nereids_insert_no_partition') { sql '''insert into dup_light_sc_nop_t select * except(kaint) from src''' + sql 'sync' qt_lsc1 'select * from dup_light_sc_nop_t order by id, kint' sql '''insert into dup_light_sc_not_null_nop_t select * except(kaint) from src where id is not null''' + sql 'sync' qt_lsc2 'select * from dup_light_sc_not_null_nop_t order by id, kint' // test light_schema_change @@ -200,17 +235,21 @@ suite('nereids_insert_no_partition') { sql '''insert into uni_light_sc_nop_t select * except(kaint) from src''' + sql 'sync' qt_lsc1 'select * from uni_light_sc_nop_t order by id, kint' sql '''insert into uni_light_sc_not_null_nop_t select * except(kaint) from src where id is not null''' + sql 'sync' qt_lsc2 'select * from uni_light_sc_not_null_nop_t order by id, kint' sql '''insert into uni_light_sc_mow_nop_t select * except(kaint) from src''' + sql 'sync' qt_lsc3 'select * from uni_light_sc_mow_nop_t order by id, kint' sql '''insert into uni_light_sc_mow_not_null_nop_t select * except(kaint) from src where id is not null''' + sql 'sync' qt_lsc4 'select * from uni_light_sc_mow_not_null_nop_t order by id, kint' } \ No newline at end of file diff --git a/regression-test/suites/nereids_p0/insert_into_table/type_cast_aggregate.groovy b/regression-test/suites/nereids_p0/insert_into_table/type_cast_aggregate.groovy index c3fbf3df64..b5ac0ba12f 100644 --- a/regression-test/suites/nereids_p0/insert_into_table/type_cast_aggregate.groovy +++ b/regression-test/suites/nereids_p0/insert_into_table/type_cast_aggregate.groovy @@ -26,53 +26,65 @@ suite("nereids_insert_aggregate_type_cast") { sql '''insert into agg_t_type_cast select id, ktint, ksint, kint, kbint, kdtv2, kdtm, kdbl from src''' + sql 'sync' qt_11 'select * from agg_t_type_cast order by id, kint' sql '''insert into agg_t_type_cast with label label_agg_type_cast_cte with cte as (select id, ktint, ksint, kint, kbint, kdtv2, kdtm, kdbl from src) select * from cte''' + sql 'sync' qt_12 'select * from agg_t_type_cast order by id, kint' sql '''insert into agg_t_type_cast partition (p1, p2) with label label_agg_type_cast select id, ktint, ksint, kint, kbint, kdtv2, kdtm, kdbl from src where id < 4''' + sql 'sync' qt_13 'select * from agg_t_type_cast order by id, kint' sql '''insert into agg_light_sc_t_type_cast select id, ktint, ksint, kint, kbint, kdtv2, kdtm, kdbl from src''' + sql 'sync' qt_21 'select * from agg_light_sc_t_type_cast order by id, kint' sql '''insert into agg_light_sc_t_type_cast with label label_agg_light_sc_type_cast_cte with cte as (select id, ktint, ksint, kint, kbint, kdtv2, kdtm, kdbl from src) select * from cte''' + sql 'sync' qt_22 'select * from agg_light_sc_t_type_cast order by id, kint' sql '''insert into agg_light_sc_t_type_cast partition (p1, p2) with label label_agg_light_sc_type_cast select id, ktint, ksint, kint, kbint, kdtv2, kdtm, kdbl from src where id < 4''' + sql 'sync' qt_23 'select * from agg_light_sc_t_type_cast order by id, kint' sql '''insert into agg_not_null_t_type_cast select id, ktint, ksint, kint, kbint, kdtv2, kdtm, kdbl from src where id is not null''' + sql 'sync' qt_31 'select * from agg_not_null_t_type_cast order by id, kint' sql '''insert into agg_not_null_t_type_cast with label label_agg_not_null_type_cast_cte with cte as (select id, ktint, ksint, kint, kbint, kdtv2, kdtm, kdbl from src) select * from cte where id is not null''' + sql 'sync' qt_32 'select * from agg_not_null_t_type_cast order by id, kint' sql '''insert into agg_not_null_t_type_cast partition (p1, p2) with label label_agg_not_null_type_cast select id, ktint, ksint, kint, kbint, kdtv2, kdtm, kdbl from src where id < 4 and id is not null''' + sql 'sync' qt_33 'select * from agg_not_null_t_type_cast order by id, kint' sql '''insert into agg_light_sc_not_null_t_type_cast select id, ktint, ksint, kint, kbint, kdtv2, kdtm, kdbl from src where id is not null''' + sql 'sync' qt_41 'select * from agg_light_sc_not_null_t_type_cast order by id, kint' sql '''insert into agg_light_sc_not_null_t_type_cast with label label_agg_light_sc_not_null_type_cast_cte with cte as (select id, ktint, ksint, kint, kbint, kdtv2, kdtm, kdbl from src) select * from cte where id is not null''' + sql 'sync' qt_42 'select * from agg_light_sc_not_null_t_type_cast order by id, kint' sql '''insert into agg_light_sc_not_null_t_type_cast partition (p1, p2) with label label_agg_light_sc_not_null_type_cast select id, ktint, ksint, kint, kbint, kdtv2, kdtm, kdbl from src where id < 4 and id is not null''' + sql 'sync' qt_43 'select * from agg_light_sc_not_null_t_type_cast order by id, kint' } \ No newline at end of file diff --git a/regression-test/suites/nereids_p0/insert_into_table/type_cast_duplicate.groovy b/regression-test/suites/nereids_p0/insert_into_table/type_cast_duplicate.groovy index 9f87e4aa51..3124c7570b 100644 --- a/regression-test/suites/nereids_p0/insert_into_table/type_cast_duplicate.groovy +++ b/regression-test/suites/nereids_p0/insert_into_table/type_cast_duplicate.groovy @@ -26,53 +26,65 @@ suite("nereids_insert_duplicate") { sql '''insert into dup_t_type_cast select id, ktint, ksint, kint, kbint, kdtv2, kdtm, kdbl from src''' + sql 'sync' qt_11 'select * from dup_t_type_cast order by id, kint' sql '''insert into dup_t_type_cast with label label_dup_type_cast_cte with cte as (select id, ktint, ksint, kint, kbint, kdtv2, kdtm, kdbl from src) select * from cte''' + sql 'sync' qt_12 'select * from dup_t_type_cast order by id, kint' sql '''insert into dup_t_type_cast partition (p1, p2) with label label_dup_type_cast select id, ktint, ksint, kint, kbint, kdtv2, kdtm, kdbl from src where id < 4''' + sql 'sync' qt_13 'select * from dup_t_type_cast order by id, kint' sql '''insert into dup_light_sc_t_type_cast select id, ktint, ksint, kint, kbint, kdtv2, kdtm, kdbl from src''' + sql 'sync' qt_21 'select * from dup_light_sc_t_type_cast order by id, kint' sql '''insert into dup_light_sc_t_type_cast with label label_dup_light_sc_type_cast_cte with cte as (select id, ktint, ksint, kint, kbint, kdtv2, kdtm, kdbl from src) select * from cte''' + sql 'sync' qt_22 'select * from dup_light_sc_t_type_cast order by id, kint' sql '''insert into dup_light_sc_t_type_cast partition (p1, p2) with label label_dup_light_sc_type_cast select id, ktint, ksint, kint, kbint, kdtv2, kdtm, kdbl from src where id < 4''' + sql 'sync' qt_23 'select * from dup_light_sc_t_type_cast order by id, kint' sql '''insert into dup_not_null_t_type_cast select id, ktint, ksint, kint, kbint, kdtv2, kdtm, kdbl from src where id is not null''' + sql 'sync' qt_31 'select * from dup_not_null_t_type_cast order by id, kint' sql '''insert into dup_not_null_t_type_cast with label label_dup_not_null_type_cast_cte with cte as (select id, ktint, ksint, kint, kbint, kdtv2, kdtm, kdbl from src) select * from cte where id is not null''' + sql 'sync' qt_32 'select * from dup_not_null_t_type_cast order by id, kint' sql '''insert into dup_not_null_t_type_cast partition (p1, p2) with label label_dup_not_null_type_cast select id, ktint, ksint, kint, kbint, kdtv2, kdtm, kdbl from src where id < 4 and id is not null''' + sql 'sync' qt_33 'select * from dup_not_null_t_type_cast order by id, kint' sql '''insert into dup_light_sc_not_null_t_type_cast select id, ktint, ksint, kint, kbint, kdtv2, kdtm, kdbl from src where id is not null''' + sql 'sync' qt_41 'select * from dup_light_sc_not_null_t_type_cast order by id, kint' sql '''insert into dup_light_sc_not_null_t_type_cast with label label_dup_light_sc_not_null_type_cast_cte with cte as (select id, ktint, ksint, kint, kbint, kdtv2, kdtm, kdbl from src) select * from cte where id is not null''' + sql 'sync' qt_42 'select * from dup_light_sc_not_null_t_type_cast order by id, kint' sql '''insert into dup_light_sc_not_null_t_type_cast partition (p1, p2) with label label_dup_light_sc_not_null_type_cast select id, ktint, ksint, kint, kbint, kdtv2, kdtm, kdbl from src where id < 4 and id is not null''' + sql 'sync' qt_43 'select * from dup_light_sc_not_null_t_type_cast order by id, kint' } \ No newline at end of file diff --git a/regression-test/suites/nereids_p0/insert_into_table/type_cast_unique.groovy b/regression-test/suites/nereids_p0/insert_into_table/type_cast_unique.groovy index e65c1acb7e..a0edf47b46 100644 --- a/regression-test/suites/nereids_p0/insert_into_table/type_cast_unique.groovy +++ b/regression-test/suites/nereids_p0/insert_into_table/type_cast_unique.groovy @@ -26,105 +26,129 @@ suite("nereids_insert_unique_type_cast") { sql '''insert into uni_t_type_cast select id, ktint, ksint, kint, kbint, kdtv2, kdtm, kdbl from src''' + sql 'sync' qt_11 'select * from uni_t_type_cast order by id, kint' sql '''insert into uni_t_type_cast with label label_uni_type_cast_cte with cte as (select id, ktint, ksint, kint, kbint, kdtv2, kdtm, kdbl from src) select * from cte''' + sql 'sync' qt_12 'select * from uni_t_type_cast order by id, kint' sql '''insert into uni_t_type_cast partition (p1, p2) with label label_uni_type_cast select id, ktint, ksint, kint, kbint, kdtv2, kdtm, kdbl from src where id < 4''' + sql 'sync' qt_13 'select * from uni_t_type_cast order by id, kint' sql '''insert into uni_light_sc_t_type_cast select id, ktint, ksint, kint, kbint, kdtv2, kdtm, kdbl from src''' + sql 'sync' qt_21 'select * from uni_light_sc_t_type_cast order by id, kint' sql '''insert into uni_light_sc_t_type_cast with label label_uni_light_sc_type_cast_cte with cte as (select id, ktint, ksint, kint, kbint, kdtv2, kdtm, kdbl from src) select * from cte''' + sql 'sync' qt_22 'select * from uni_light_sc_t_type_cast order by id, kint' sql '''insert into uni_light_sc_t_type_cast partition (p1, p2) with label label_uni_light_sc_type_cast select id, ktint, ksint, kint, kbint, kdtv2, kdtm, kdbl from src where id < 4''' + sql 'sync' qt_23 'select * from uni_light_sc_t_type_cast order by id, kint' sql '''insert into uni_mow_t_type_cast select id, ktint, ksint, kint, kbint, kdtv2, kdtm, kdbl from src''' + sql 'sync' qt_31 'select * from uni_mow_t_type_cast order by id, kint' sql '''insert into uni_mow_t_type_cast with label label_uni_mow_type_cast_cte with cte as (select id, ktint, ksint, kint, kbint, kdtv2, kdtm, kdbl from src) select * from cte''' + sql 'sync' qt_32 'select * from uni_mow_t_type_cast order by id, kint' sql '''insert into uni_mow_t_type_cast partition (p1, p2) with label label_uni_mow_type_cast select id, ktint, ksint, kint, kbint, kdtv2, kdtm, kdbl from src where id < 4''' + sql 'sync' qt_33 'select * from uni_mow_t_type_cast order by id, kint' sql '''insert into uni_light_sc_mow_t_type_cast select id, ktint, ksint, kint, kbint, kdtv2, kdtm, kdbl from src''' + sql 'sync' qt_41 'select * from uni_light_sc_mow_t_type_cast order by id, kint' sql '''insert into uni_light_sc_mow_t_type_cast with label label_uni_light_sc_mow_type_cast_cte with cte as (select id, ktint, ksint, kint, kbint, kdtv2, kdtm, kdbl from src) select * from cte''' + sql 'sync' qt_42 'select * from uni_light_sc_mow_t_type_cast order by id, kint' sql '''insert into uni_light_sc_mow_t_type_cast partition (p1, p2) with label label_uni_light_sc_mow_type_cast select id, ktint, ksint, kint, kbint, kdtv2, kdtm, kdbl from src where id < 4''' + sql 'sync' qt_43 'select * from uni_light_sc_mow_t_type_cast order by id, kint' sql '''insert into uni_mow_not_null_t_type_cast select id, ktint, ksint, kint, kbint, kdtv2, kdtm, kdbl from src where id is not null''' + sql 'sync' qt_51 'select * from uni_mow_not_null_t_type_cast order by id, kint' sql '''insert into uni_mow_not_null_t_type_cast with label label_uni_not_null_type_cast_cte with cte as (select id, ktint, ksint, kint, kbint, kdtv2, kdtm, kdbl from src) select * from cte where id is not null''' + sql 'sync' qt_52 'select * from uni_mow_not_null_t_type_cast order by id, kint' sql '''insert into uni_mow_not_null_t_type_cast partition (p1, p2) with label label_uni_not_null_type_cast select id, ktint, ksint, kint, kbint, kdtv2, kdtm, kdbl from src where id < 4 and id is not null''' + sql 'sync' qt_53 'select * from uni_mow_not_null_t_type_cast order by id, kint' sql '''insert into uni_light_sc_mow_not_null_t_type_cast select id, ktint, ksint, kint, kbint, kdtv2, kdtm, kdbl from src where id is not null''' + sql 'sync' qt_61 'select * from uni_light_sc_mow_not_null_t_type_cast order by id, kint' sql '''insert into uni_light_sc_mow_not_null_t_type_cast with label label_uni_light_sc_not_null_type_cast_cte with cte as (select id, ktint, ksint, kint, kbint, kdtv2, kdtm, kdbl from src) select * from cte where id is not null''' + sql 'sync' qt_62 'select * from uni_light_sc_mow_not_null_t_type_cast order by id, kint' sql '''insert into uni_light_sc_mow_not_null_t_type_cast partition (p1, p2) with label label_uni_light_sc_not_null_type_cast select id, ktint, ksint, kint, kbint, kdtv2, kdtm, kdbl from src where id < 4 and id is not null''' + sql 'sync' qt_63 'select * from uni_light_sc_mow_not_null_t_type_cast order by id, kint' sql '''insert into uni_mow_not_null_t_type_cast select id, ktint, ksint, kint, kbint, kdtv2, kdtm, kdbl from src where id is not null''' + sql 'sync' qt_71 'select * from uni_mow_not_null_t_type_cast order by id, kint' sql '''insert into uni_mow_not_null_t_type_cast with label label_uni_mow_not_null_type_cast_cte with cte as (select id, ktint, ksint, kint, kbint, kdtv2, kdtm, kdbl from src) select * from cte where id is not null''' + sql 'sync' qt_72 'select * from uni_mow_not_null_t_type_cast order by id, kint' sql '''insert into uni_mow_not_null_t_type_cast partition (p1, p2) with label label_uni_mow_not_null_type_cast select id, ktint, ksint, kint, kbint, kdtv2, kdtm, kdbl from src where id < 4 and id is not null''' + sql 'sync' qt_73 'select * from uni_mow_not_null_t_type_cast order by id, kint' sql '''insert into uni_light_sc_mow_not_null_t_type_cast select id, ktint, ksint, kint, kbint, kdtv2, kdtm, kdbl from src where id is not null''' + sql 'sync' qt_81 'select * from uni_light_sc_mow_not_null_t_type_cast order by id, kint' sql '''insert into uni_light_sc_mow_not_null_t_type_cast with label label_uni_light_sc_mow_not_null_type_cast_cte with cte as (select id, ktint, ksint, kint, kbint, kdtv2, kdtm, kdbl from src) select * from cte where id is not null''' + sql 'sync' qt_82 'select * from uni_light_sc_mow_not_null_t_type_cast order by id, kint' sql '''insert into uni_light_sc_mow_not_null_t_type_cast partition (p1, p2) with label label_uni_light_sc_mow_not_null_type_cast select id, ktint, ksint, kint, kbint, kdtv2, kdtm, kdbl from src where id < 4 and id is not null''' + sql 'sync' qt_83 'select * from uni_light_sc_mow_not_null_t_type_cast order by id, kint' } \ No newline at end of file diff --git a/regression-test/suites/nereids_p0/insert_into_table/unique.groovy b/regression-test/suites/nereids_p0/insert_into_table/unique.groovy index 0080a35aa1..f79332709a 100644 --- a/regression-test/suites/nereids_p0/insert_into_table/unique.groovy +++ b/regression-test/suites/nereids_p0/insert_into_table/unique.groovy @@ -26,106 +26,130 @@ suite("nereids_insert_unique") { sql '''insert into uni_t select * except(kaint) from src''' + sql 'sync' qt_11 'select * from uni_t order by id, kint' sql '''insert into uni_t with label label_uni_cte with cte as (select * except(kaint) from src) select * from cte''' + sql 'sync' qt_12 'select * from uni_t order by id, kint' sql '''insert into uni_t partition (p1, p2) with label label_uni select * except(kaint) from src where id < 4''' + sql 'sync' qt_13 'select * from uni_t order by id, kint' sql '''insert into uni_light_sc_t select * except(kaint) from src''' + sql 'sync' qt_21 'select * from uni_light_sc_t order by id, kint' sql '''insert into uni_light_sc_t with label label_uni_light_sc_cte with cte as (select * except(kaint) from src) select * from cte''' + sql 'sync' qt_22 'select * from uni_light_sc_t order by id, kint' sql '''insert into uni_light_sc_t partition (p1, p2) with label label_uni_light_sc select * except(kaint) from src where id < 4''' + sql 'sync' qt_23 'select * from uni_light_sc_t order by id, kint' sql '''insert into uni_mow_t select * except(kaint) from src''' + sql 'sync' qt_31 'select * from uni_mow_t order by id, kint' sql '''insert into uni_mow_t with label label_uni_mow_cte with cte as (select * except(kaint) from src) select * from cte''' + sql 'sync' qt_32 'select * from uni_mow_t order by id, kint' sql '''insert into uni_mow_t partition (p1, p2) with label label_uni_mow select * except(kaint) from src where id < 4''' + sql 'sync' qt_33 'select * from uni_mow_t order by id, kint' sql '''insert into uni_light_sc_mow_t select * except(kaint) from src''' + sql 'sync' qt_41 'select * from uni_light_sc_mow_t order by id, kint' sql '''insert into uni_light_sc_mow_t with label label_uni_light_sc_mow_cte with cte as (select * except(kaint) from src) select * from cte''' + sql 'sync' qt_42 'select * from uni_light_sc_mow_t order by id, kint' sql '''insert into uni_light_sc_mow_t partition (p1, p2) with label label_uni_light_sc_mow select * except(kaint) from src where id < 4''' + sql 'sync' qt_43 'select * from uni_light_sc_mow_t order by id, kint' sql '''insert into uni_mow_not_null_t select * except(kaint) from src where id is not null''' + sql 'sync' qt_51 'select * from uni_mow_not_null_t order by id, kint' sql '''insert into uni_mow_not_null_t with label label_uni_not_null_cte with cte as (select * except(kaint) from src) select * from cte where id is not null''' + sql 'sync' qt_52 'select * from uni_mow_not_null_t order by id, kint' sql '''insert into uni_mow_not_null_t partition (p1, p2) with label label_uni_not_null select * except(kaint) from src where id < 4 and id is not null''' + sql 'sync' qt_53 'select * from uni_mow_not_null_t order by id, kint' sql '''insert into uni_light_sc_mow_not_null_t select * except(kaint) from src where id is not null''' + sql 'sync' qt_61 'select * from uni_light_sc_mow_not_null_t order by id, kint' sql '''insert into uni_light_sc_mow_not_null_t with label label_uni_light_sc_not_null_cte with cte as (select * except(kaint) from src) select * from cte where id is not null''' + sql 'sync' qt_62 'select * from uni_light_sc_mow_not_null_t order by id, kint' sql '''insert into uni_light_sc_mow_not_null_t partition (p1, p2) with label label_uni_light_sc_not_null select * except(kaint) from src where id < 4 and id is not null''' + sql 'sync' qt_63 'select * from uni_light_sc_mow_not_null_t order by id, kint' sql '''insert into uni_mow_not_null_t select * except(kaint) from src where id is not null''' + sql 'sync' qt_71 'select * from uni_mow_not_null_t order by id, kint' sql '''insert into uni_mow_not_null_t with label label_uni_mow_not_null_cte with cte as (select * except(kaint) from src) select * from cte where id is not null''' + sql 'sync' qt_72 'select * from uni_mow_not_null_t order by id, kint' sql '''insert into uni_mow_not_null_t partition (p1, p2) with label label_uni_mow_not_null select * except(kaint) from src where id < 4 and id is not null''' + sql 'sync' qt_73 'select * from uni_mow_not_null_t order by id, kint' sql '''insert into uni_light_sc_mow_not_null_t select * except(kaint) from src where id is not null''' + sql 'sync' qt_81 'select * from uni_light_sc_mow_not_null_t order by id, kint' sql '''insert into uni_light_sc_mow_not_null_t with label label_uni_light_sc_mow_not_null_cte with cte as (select * except(kaint) from src) select * from cte where id is not null''' + sql 'sync' qt_82 'select * from uni_light_sc_mow_not_null_t order by id, kint' sql '''insert into uni_light_sc_mow_not_null_t partition (p1, p2) with label label_uni_light_sc_mow_not_null select * except(kaint) from src where id < 4 and id is not null''' + sql 'sync' qt_83 'select * from uni_light_sc_mow_not_null_t order by id, kint' // test light_schema_change @@ -136,17 +160,21 @@ suite("nereids_insert_unique") { sql '''insert into uni_light_sc_t select * except(kaint) from src''' + sql 'sync' qt_lsc1 'select * from uni_light_sc_t order by id, kint' sql '''insert into uni_light_sc_not_null_t select * except(kaint) from src where id is not null''' + sql 'sync' qt_lsc2 'select * from uni_light_sc_not_null_t order by id, kint' sql '''insert into uni_light_sc_mow_t select * except(kaint) from src''' + sql 'sync' qt_lsc3 'select * from uni_light_sc_mow_t order by id, kint' sql '''insert into uni_light_sc_mow_not_null_t select * except(kaint) from src where id is not null''' + sql 'sync' qt_lsc4 'select * from uni_light_sc_mow_not_null_t order by id, kint' } \ No newline at end of file diff --git a/regression-test/suites/nereids_p0/insert_into_table/unsupport_type.groovy b/regression-test/suites/nereids_p0/insert_into_table/unsupport_type.groovy index 515a7dbdf2..75bc38f594 100644 --- a/regression-test/suites/nereids_p0/insert_into_table/unsupport_type.groovy +++ b/regression-test/suites/nereids_p0/insert_into_table/unsupport_type.groovy @@ -31,5 +31,6 @@ suite("nereids_insert_array_type") { sql 'set enable_fallback_to_original_planner=true' sql 'insert into arr_t select id, kaint from src' + sql 'sync' sql 'select * from arr_t' } \ No newline at end of file