This is an automated email from the ASF dual-hosted git repository. hellostephen pushed a commit to branch branch-2.1 in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.1 by this push: new dd916c0626c [regression-test](fix) fix regression case bugs (#46055) dd916c0626c is described below commit dd916c0626c12d7b86f6630834afbbdd44869d89 Author: shuke <sh...@selectdb.com> AuthorDate: Fri Dec 27 14:57:25 2024 +0800 [regression-test](fix) fix regression case bugs (#46055) ### What problem does this PR solve? Issue Number: close #xxx Related PR: #xxx Problem Summary: schema change case bugs when cherry pick --- .../test_dup_schema_value_modify.out | 41 + .../pipeline/p0/conf/regression-conf.groovy | 1 + .../test_dup_schema_key_change_modify.groovy | 120 +-- .../test_dup_schema_value_modify1.groovy | 1003 +------------------- .../test_partial_update_2pc_schema_change.groovy | 4 +- 5 files changed, 106 insertions(+), 1063 deletions(-) diff --git a/regression-test/data/schema_change_p0/test_dup_schema_value_modify.out b/regression-test/data/schema_change_p0/test_dup_schema_value_modify.out new file mode 100644 index 00000000000..b52ac16a99c --- /dev/null +++ b/regression-test/data/schema_change_p0/test_dup_schema_value_modify.out @@ -0,0 +1,41 @@ +-- This file is automatically generated. You should know what you did if you want to edit this +-- ! -- +123456789 Alice 1 Beijing 25 0 13812345678 No. 123 Street, Beijing 2022-01-01T10:00 +123456789 Alice 1 Beijing 25 0 13812345678 No. 123 Street, Beijing 2022-01-01T10:00 +234567890 Bob 1 Shanghai 30 1 13998765432 No. 456 Street, Shanghai 2022-02-02T12:00 +234567890 Bob 1 Shanghai 30 1 13998765432 No. 456 Street, Shanghai 2022-02-02T12:00 +345678901 Carol 1 Guangzhou 28 0 13724681357 No. 789 Street, Guangzhou 2022-03-03T14:00 +345678901 Carol 1 Guangzhou 28 0 13724681357 No. 789 Street, Guangzhou 2022-03-03T14:00 +456789012 Dave 1 Shenzhen 35 1 13680864279 No. 987 Street, Shenzhen 2022-04-04T16:00 +456789012 Dave 1 Shenzhen 35 1 13680864279 No. 987 Street, Shenzhen 2022-04-04T16:00 +567890123 Eve 0 Chengdu 27 0 13572468091 No. 654 Street, Chengdu 2022-05-05T18:00 +567890123 Eve 0 Chengdu 27 0 13572468091 No. 654 Street, Chengdu 2022-05-05T18:00 +678901234 Frank 0 Hangzhou 32 1 13467985213 No. 321 Street, Hangzhou 2022-06-06T20:00 +678901234 Frank 0 Hangzhou 32 1 13467985213 No. 321 Street, Hangzhou 2022-06-06T20:00 +789012345 Grace 1 Xian 29 0 13333333333 No. 222 Street, Xian 2022-07-07T22:00 +789012345 Grace 1 Xian 29 0 13333333333 No. 222 Street, Xian 2022-07-07T22:00 +993456689 Alice 1 Yaan 25 0 13812345678 No. 123 Street, Beijing 2022-01-01T10:00 + +-- ! -- +123456789 Alice 1 Beijing 25 0 13812345678 No. 123 Street, Beijing 2022-01-01T10:00 +123456789 Alice 1 Beijing 25 0 13812345678 No. 123 Street, Beijing 2022-01-01T10:00 +123456789 Alice 1 Beijing 25 0 13812345678 No. 123 Street, Beijing 2022-01-01T10:00 +234567890 Bob 1 Shanghai 30 1 13998765432 No. 456 Street, Shanghai 2022-02-02T12:00 +234567890 Bob 1 Shanghai 30 1 13998765432 No. 456 Street, Shanghai 2022-02-02T12:00 +234567890 Bob 1 Shanghai 30 1 13998765432 No. 456 Street, Shanghai 2022-02-02T12:00 +345678901 Carol 1 Guangzhou 28 0 13724681357 No. 789 Street, Guangzhou 2022-03-03T14:00 +345678901 Carol 1 Guangzhou 28 0 13724681357 No. 789 Street, Guangzhou 2022-03-03T14:00 +345678901 Carol 1 Guangzhou 28 0 13724681357 No. 789 Street, Guangzhou 2022-03-03T14:00 +456789012 Dave 1 Shenzhen 35 1 13680864279 No. 987 Street, Shenzhen 2022-04-04T16:00 +456789012 Dave 1 Shenzhen 35 1 13680864279 No. 987 Street, Shenzhen 2022-04-04T16:00 +456789012 Dave 1 Shenzhen 35 1 13680864279 No. 987 Street, Shenzhen 2022-04-04T16:00 +567890123 Eve 0 Chengdu 27 0 13572468091 No. 654 Street, Chengdu 2022-05-05T18:00 +567890123 Eve 0 Chengdu 27 0 13572468091 No. 654 Street, Chengdu 2022-05-05T18:00 +567890123 Eve 0 Chengdu 27 0 13572468091 No. 654 Street, Chengdu 2022-05-05T18:00 +678901234 Frank 0 Hangzhou 32 1 13467985213 No. 321 Street, Hangzhou 2022-06-06T20:00 +678901234 Frank 0 Hangzhou 32 1 13467985213 No. 321 Street, Hangzhou 2022-06-06T20:00 +678901234 Frank 0 Hangzhou 32 1 13467985213 No. 321 Street, Hangzhou 2022-06-06T20:00 +789012345 Grace 1 Xian 29 0 13333333333 No. 222 Street, Xian 2022-07-07T22:00 +789012345 Grace 1 Xian 29 0 13333333333 No. 222 Street, Xian 2022-07-07T22:00 +789012345 Grace 1 Xian 29 0 13333333333 No. 222 Street, Xian 2022-07-07T22:00 +993456689 Alice asd Yaan 25 0 13812345678 No. 123 Street, Beijing 2022-01-01T10:00 \ No newline at end of file diff --git a/regression-test/pipeline/p0/conf/regression-conf.groovy b/regression-test/pipeline/p0/conf/regression-conf.groovy index 080e8f8c7ae..9f30c730013 100644 --- a/regression-test/pipeline/p0/conf/regression-conf.groovy +++ b/regression-test/pipeline/p0/conf/regression-conf.groovy @@ -75,6 +75,7 @@ excludeSuites = "000_the_start_sentinel_do_not_touch," + // keep this line as th excludeDirectories = "000_the_start_sentinel_do_not_touch," + // keep this line as the first line "nereids_rules_p0/subquery," + "workload_manager_p1," + + "plsql_p0," + // plsql is not developped any more, add by sk "zzz_the_end_sentinel_do_not_touch" // keep this line as the last line customConf1 = "test_custom_conf_value" diff --git a/regression-test/suites/schema_change_p0/test_dup_schema_key_change_modify.groovy b/regression-test/suites/schema_change_p0/test_dup_schema_key_change_modify.groovy index 7a46111e6fc..2d628f8c1a9 100644 --- a/regression-test/suites/schema_change_p0/test_dup_schema_key_change_modify.groovy +++ b/regression-test/suites/schema_change_p0/test_dup_schema_key_change_modify.groovy @@ -16,8 +16,8 @@ // under the License. suite("test_dup_schema_key_change_modify","p0") { - def tbName1 = "test_dup_schema_key_change_modify1" - def tbName2 = "test_dup_schema_key_change_modify_1" + def tbName1 = "test_dup_schema_key_change_modify1_v2" + def tbName2 = "test_dup_schema_key_change_modify_1_v2" def initTable1 = "" def initTableData1 = "" @@ -63,7 +63,7 @@ suite("test_dup_schema_key_change_modify","p0") { insertSql = "insert into ${tbName1} values(923456689, 'Alice', 1, 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00'); " waitForSchemaChangeDone({ sql getTableStatusSql - time 60 + time 600 }, insertSql, true,"${tbName1}") },errorMessage) @@ -77,7 +77,7 @@ suite("test_dup_schema_key_change_modify","p0") { insertSql = "insert into ${tbName1} values(923456689, 'Alice', 1, 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00'); " waitForSchemaChangeDone({ sql getTableStatusSql - time 60 + time 600 }, insertSql, true,"${tbName1}") },errorMessage) @@ -91,7 +91,7 @@ suite("test_dup_schema_key_change_modify","p0") { insertSql = "insert into ${tbName1} values(923456689, 'Alice', 1, 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00'); " waitForSchemaChangeDone({ sql getTableStatusSql - time 60 + time 600 }, insertSql, true,"${tbName1}") },errorMessage) @@ -106,7 +106,7 @@ suite("test_dup_schema_key_change_modify","p0") { insertSql = "insert into ${tbName1} values(923456689, 'Alice', 1, 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00'); " waitForSchemaChangeDone({ sql getTableStatusSql - time 60 + time 600 }, insertSql, true,"${tbName1}") },errorMessage) @@ -121,7 +121,7 @@ suite("test_dup_schema_key_change_modify","p0") { insertSql = "insert into ${tbName1} values(923456689, 'Alice', 1.0, 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00'); " waitForSchemaChangeDone({ sql getTableStatusSql - time 60 + time 600 }, insertSql, true,"${tbName1}") },errorMessage) @@ -136,7 +136,7 @@ suite("test_dup_schema_key_change_modify","p0") { insertSql = "insert into ${tbName1} values(923456689, 'Alice', 1.0, 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00'); " waitForSchemaChangeDone({ sql getTableStatusSql - time 60 + time 600 }, insertSql, true,"${tbName1}") },errorMessage) @@ -150,7 +150,7 @@ suite("test_dup_schema_key_change_modify","p0") { insertSql = "insert into ${tbName1} values(923456689, 'Alice', '1', 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00'); " waitForSchemaChangeDone({ sql getTableStatusSql - time 60 + time 600 }, insertSql, true,"${tbName1}") },errorMessage) @@ -164,7 +164,7 @@ suite("test_dup_schema_key_change_modify","p0") { insertSql = "insert into ${tbName1} values(923456689, 'Alice', '1', 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00'); " waitForSchemaChangeDone({ sql getTableStatusSql - time 60 + time 600 }, insertSql, true,"${tbName1}") },errorMessage) @@ -178,7 +178,7 @@ suite("test_dup_schema_key_change_modify","p0") { insertSql = "insert into ${tbName1} values(923456689, 'Alice', '1', 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00'); " waitForSchemaChangeDone({ sql getTableStatusSql - time 60 + time 600 }, insertSql, true,"${tbName1}") },errorMessage) @@ -222,7 +222,7 @@ suite("test_dup_schema_key_change_modify","p0") { insertSql = "insert into ${tbName1} values(923456689, 'Alice', false, 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00'); " waitForSchemaChangeDone({ sql getTableStatusSql - time 60 + time 600 }, insertSql, true,"${tbName1}") },errorMessage) @@ -235,7 +235,7 @@ suite("test_dup_schema_key_change_modify","p0") { insertSql = "insert into ${tbName1} values(923456689, 'Alice', 2, 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00'); " waitForSchemaChangeDone({ sql getTableStatusSql - time 60 + time 600 }, insertSql, false,"${tbName1}") sql """ DROP TABLE IF EXISTS ${tbName1} """ @@ -248,7 +248,7 @@ suite("test_dup_schema_key_change_modify","p0") { insertSql = "insert into ${tbName1} values(923456689, 'Alice', 2, 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00'); " waitForSchemaChangeDone({ sql getTableStatusSql - time 60 + time 600 }, insertSql, false,"${tbName1}") sql """ DROP TABLE IF EXISTS ${tbName2} """ @@ -291,7 +291,7 @@ suite("test_dup_schema_key_change_modify","p0") { insertSql = "insert into ${tbName1} values(923456689, 'Alice', 3, 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00'); " waitForSchemaChangeDone({ sql getTableStatusSql - time 60 + time 600 }, insertSql, false,"${tbName1}") @@ -336,7 +336,7 @@ suite("test_dup_schema_key_change_modify","p0") { insertSql = "insert into ${tbName1} values(923456689, 'Alice', 1, 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00'); " waitForSchemaChangeDone({ sql getTableStatusSql - time 60 + time 600 }, insertSql, false,"${tbName1}") sql """ DROP TABLE IF EXISTS ${tbName2} """ @@ -382,7 +382,7 @@ suite("test_dup_schema_key_change_modify","p0") { insertSql = "insert into ${tbName1} values(923456689, 'Alice', 1.2, 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00'); " waitForSchemaChangeDone({ sql getTableStatusSql - time 60 + time 600 }, insertSql, true,"${tbName1}") },errorMessage) @@ -396,7 +396,7 @@ suite("test_dup_schema_key_change_modify","p0") { insertSql = "insert into ${tbName1} values(923456689, 'Alice', 1.23, 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00'); " waitForSchemaChangeDone({ sql getTableStatusSql - time 60 + time 600 }, insertSql, true,"${tbName1}") },errorMessage) @@ -411,7 +411,7 @@ suite("test_dup_schema_key_change_modify","p0") { insertSql = "insert into ${tbName1} values(923456689, 'Alice', 1.23, 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00'); " waitForSchemaChangeDone({ sql getTableStatusSql - time 60 + time 600 }, insertSql, true,"${tbName1}") },errorMessage) @@ -425,7 +425,7 @@ suite("test_dup_schema_key_change_modify","p0") { insertSql = "insert into ${tbName1} values(923456689, 'Alice', 'char', 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00'); " waitForSchemaChangeDone({ sql getTableStatusSql - time 60 + time 600 }, insertSql, true,"${tbName1}") },errorMessage) @@ -437,7 +437,7 @@ suite("test_dup_schema_key_change_modify","p0") { insertSql = "insert into ${tbName1} values(923456689, 'Alice', 'varchar', 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00'); " waitForSchemaChangeDone({ sql getTableStatusSql - time 60 + time 600 }, insertSql, false,"${tbName1}") sql """ DROP TABLE IF EXISTS ${tbName1} """ @@ -450,7 +450,7 @@ suite("test_dup_schema_key_change_modify","p0") { insertSql = "insert into ${tbName1} values(923456689, 'Alice', 'asd', 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00'); " waitForSchemaChangeDone({ sql getTableStatusSql - time 60 + time 600 }, insertSql, true,"${tbName1}") },errorMessage) @@ -495,7 +495,7 @@ suite("test_dup_schema_key_change_modify","p0") { insertSql = "insert into ${tbName1} values(923456689, 'Alice', false, 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00'); " waitForSchemaChangeDone({ sql getTableStatusSql - time 60 + time 600 }, insertSql, true,"${tbName1}") },errorMessage) @@ -511,7 +511,7 @@ suite("test_dup_schema_key_change_modify","p0") { insertSql = "insert into ${tbName1} values(923456689, 'Alice', 2, 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00'); " waitForSchemaChangeDone({ sql getTableStatusSql - time 60 + time 600 }, insertSql, true,"${tbName1}") },errorMessage) @@ -524,7 +524,7 @@ suite("test_dup_schema_key_change_modify","p0") { insertSql = "insert into ${tbName1} values(923456689, 'Alice', 3, 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00'); " waitForSchemaChangeDone({ sql getTableStatusSql - time 60 + time 600 }, insertSql, false,"${tbName1}") sql """ DROP TABLE IF EXISTS ${tbName1} """ @@ -535,7 +535,7 @@ suite("test_dup_schema_key_change_modify","p0") { insertSql = "insert into ${tbName1} values(923456689, 'Alice', 4, 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00'); " waitForSchemaChangeDone({ sql getTableStatusSql - time 60 + time 600 }, insertSql, false,"${tbName1}") @@ -579,7 +579,7 @@ suite("test_dup_schema_key_change_modify","p0") { insertSql = "insert into ${tbName1} values(923456689, 'Alice', 5, 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00'); " waitForSchemaChangeDone({ sql getTableStatusSql - time 60 + time 600 }, insertSql, false,"${tbName1}") sql """ DROP TABLE IF EXISTS ${tbName2} """ @@ -624,7 +624,7 @@ suite("test_dup_schema_key_change_modify","p0") { insertSql = "insert into ${tbName1} values(923456689, 'Alice', 1.2, 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00'); " waitForSchemaChangeDone({ sql getTableStatusSql - time 60 + time 600 }, insertSql, true,"${tbName1}") },errorMessage) @@ -638,7 +638,7 @@ suite("test_dup_schema_key_change_modify","p0") { insertSql = "insert into ${tbName1} values(923456689, 'Alice', 1.23, 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00'); " waitForSchemaChangeDone({ sql getTableStatusSql - time 60 + time 600 }, insertSql, true,"${tbName1}") },errorMessage) @@ -653,7 +653,7 @@ suite("test_dup_schema_key_change_modify","p0") { insertSql = "insert into ${tbName1} values(923456689, 'Alice', 1.23, 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00'); " waitForSchemaChangeDone({ sql getTableStatusSql - time 60 + time 600 }, insertSql, true,"${tbName1}") },errorMessage) @@ -667,7 +667,7 @@ suite("test_dup_schema_key_change_modify","p0") { insertSql = "insert into ${tbName1} values(923456689, 'Alice', 'casd', 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00'); " waitForSchemaChangeDone({ sql getTableStatusSql - time 60 + time 600 }, insertSql, true,"${tbName1}") },errorMessage) @@ -679,7 +679,7 @@ suite("test_dup_schema_key_change_modify","p0") { insertSql = "insert into ${tbName1} values(923456689, 'Alice', 'vasd', 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00'); " waitForSchemaChangeDone({ sql getTableStatusSql - time 60 + time 600 }, insertSql, false,"${tbName1}") sql """ DROP TABLE IF EXISTS ${tbName1} """ @@ -692,7 +692,7 @@ suite("test_dup_schema_key_change_modify","p0") { insertSql = "insert into ${tbName1} values(923456689, 'Alice', 'asd', 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00'); " waitForSchemaChangeDone({ sql getTableStatusSql - time 60 + time 600 }, insertSql, true,"${tbName1}") },errorMessage) @@ -736,7 +736,7 @@ suite("test_dup_schema_key_change_modify","p0") { insertSql = "insert into ${tbName1} values(923456689, 'Alice', false, 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00'); " waitForSchemaChangeDone({ sql getTableStatusSql - time 60 + time 600 }, insertSql, true, "${tbName1}") }, errorMessage) @@ -750,7 +750,7 @@ suite("test_dup_schema_key_change_modify","p0") { insertSql = "insert into ${tbName1} values(923456689, 'Alice', 2, 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00'); " waitForSchemaChangeDone({ sql getTableStatusSql - time 60 + time 600 }, insertSql, true, "${tbName1}") }, errorMessage) @@ -764,7 +764,7 @@ suite("test_dup_schema_key_change_modify","p0") { insertSql = "insert into ${tbName1} values(923456689, 'Alice', 3, 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00'); " waitForSchemaChangeDone({ sql getTableStatusSql - time 60 + time 600 }, insertSql, true, "${tbName1}") }, errorMessage) @@ -775,7 +775,7 @@ suite("test_dup_schema_key_change_modify","p0") { insertSql = "insert into ${tbName1} values(923456689, 'Alice', 4, 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00'); " waitForSchemaChangeDone({ sql getTableStatusSql - time 60 + time 600 }, insertSql, false, "${tbName1}") sql """ DROP TABLE IF EXISTS ${tbName1} """ @@ -786,7 +786,7 @@ suite("test_dup_schema_key_change_modify","p0") { insertSql = "insert into ${tbName1} values(923456689, 'Alice', 5, 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00'); " waitForSchemaChangeDone({ sql getTableStatusSql - time 60 + time 600 }, insertSql, false, "${tbName1}") sql """ DROP TABLE IF EXISTS ${tbName2} """ @@ -831,7 +831,7 @@ suite("test_dup_schema_key_change_modify","p0") { insertSql = "insert into ${tbName1} values(923456689, 'Alice', 1.2, 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00'); " waitForSchemaChangeDone({ sql getTableStatusSql - time 60 + time 600 }, insertSql, true, "${tbName1}") }, errorMessage) @@ -845,7 +845,7 @@ suite("test_dup_schema_key_change_modify","p0") { insertSql = "insert into ${tbName1} values(923456689, 'Alice', 1.23, 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00'); " waitForSchemaChangeDone({ sql getTableStatusSql - time 60 + time 600 }, insertSql, true, "${tbName1}") }, errorMessage) @@ -859,7 +859,7 @@ suite("test_dup_schema_key_change_modify","p0") { insertSql = "insert into ${tbName1} values(923456689, 'Alice', 1.23, 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00'); " waitForSchemaChangeDone({ sql getTableStatusSql - time 60 + time 600 }, insertSql, true, "${tbName1}") }, errorMessage) @@ -873,7 +873,7 @@ suite("test_dup_schema_key_change_modify","p0") { insertSql = "insert into ${tbName1} values(923456689, 'Alice', 'casd', 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00'); " waitForSchemaChangeDone({ sql getTableStatusSql - time 60 + time 600 }, insertSql, true, "${tbName1}") }, errorMessage) @@ -885,12 +885,12 @@ suite("test_dup_schema_key_change_modify","p0") { insertSql = "insert into ${tbName1} values(923456689, 'Alice', 'vasd', 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00'); " waitForSchemaChangeDone({ sql getTableStatusSql - time 60 + time 600 }, insertSql, false, "${tbName1}") sql """ DROP TABLE IF EXISTS ${tbName1} """ //Test the dup model by modify a key type from INT to VARCHAR - errorMessage = "errCode = 2, detailMessage = Can not change from wider type INT to narrower type VARCHAR(2)" + errorMessage = "errCode = 2, detailMessage = Can not change from wider type int to narrower type varchar(2)" expectException({ sql initTable sql initTableData @@ -898,7 +898,7 @@ suite("test_dup_schema_key_change_modify","p0") { insertSql = "insert into ${tbName1} values(923456689, 'Alice', 'v1asd', 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00'); " waitForSchemaChangeDone({ sql getTableStatusSql - time 60 + time 600 }, insertSql, true, "${tbName1}") }, errorMessage) @@ -911,7 +911,7 @@ suite("test_dup_schema_key_change_modify","p0") { insertSql = "insert into ${tbName1} values(923456689, 'Alice', 'asd', 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00'); " waitForSchemaChangeDone({ sql getTableStatusSql - time 60 + time 600 }, insertSql, true, "${tbName1}") }, errorMessage) @@ -956,7 +956,7 @@ suite("test_dup_schema_key_change_modify","p0") { insertSql = "insert into ${tbName1} values(923456689, 'Alice', false, 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00'); " waitForSchemaChangeDone({ sql getTableStatusSql - time 60 + time 600 }, insertSql, true, "${tbName1}") }, errorMessage) @@ -970,7 +970,7 @@ suite("test_dup_schema_key_change_modify","p0") { insertSql = "insert into ${tbName1} values(923456689, 'Alice', 2, 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00'); " waitForSchemaChangeDone({ sql getTableStatusSql - time 60 + time 600 }, insertSql, true, "${tbName1}") }, errorMessage) @@ -984,7 +984,7 @@ suite("test_dup_schema_key_change_modify","p0") { insertSql = "insert into ${tbName1} values(923456689, 'Alice', 3, 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00'); " waitForSchemaChangeDone({ sql getTableStatusSql - time 60 + time 600 }, insertSql, true, "${tbName1}") }, errorMessage) @@ -998,7 +998,7 @@ suite("test_dup_schema_key_change_modify","p0") { insertSql = "insert into ${tbName1} values(923456689, 'Alice', 4, 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00'); " waitForSchemaChangeDone({ sql getTableStatusSql - time 60 + time 600 }, insertSql, true, "${tbName1}") }, errorMessage) @@ -1010,7 +1010,7 @@ suite("test_dup_schema_key_change_modify","p0") { insertSql = "insert into ${tbName1} values(923456689, 'Alice', 5, 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00'); " waitForSchemaChangeDone({ sql getTableStatusSql - time 60 + time 600 }, insertSql, false, "${tbName1}") sql """ DROP TABLE IF EXISTS ${tbName1} """ @@ -1023,7 +1023,7 @@ suite("test_dup_schema_key_change_modify","p0") { insertSql = "insert into ${tbName1} values(923456689, 'Alice', 1.2, 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00'); " waitForSchemaChangeDone({ sql getTableStatusSql - time 60 + time 600 }, insertSql, true, "${tbName1}") }, errorMessage) @@ -1037,7 +1037,7 @@ suite("test_dup_schema_key_change_modify","p0") { insertSql = "insert into ${tbName1} values(923456689, 'Alice', 1.23, 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00'); " waitForSchemaChangeDone({ sql getTableStatusSql - time 60 + time 600 }, insertSql, true, "${tbName1}") }, errorMessage) @@ -1051,7 +1051,7 @@ suite("test_dup_schema_key_change_modify","p0") { insertSql = "insert into ${tbName1} values(923456689, 'Alice', 1.23, 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00'); " waitForSchemaChangeDone({ sql getTableStatusSql - time 60 + time 600 }, insertSql, true, "${tbName1}") }, errorMessage) @@ -1065,7 +1065,7 @@ suite("test_dup_schema_key_change_modify","p0") { insertSql = "insert into ${tbName1} values(923456689, 'Alice', 'casd', 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00'); " waitForSchemaChangeDone({ sql getTableStatusSql - time 60 + time 600 }, insertSql, true, "${tbName1}") }, errorMessage) @@ -1077,12 +1077,12 @@ suite("test_dup_schema_key_change_modify","p0") { insertSql = "insert into ${tbName1} values(923456689, 'Alice', 'vasd', 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00'); " waitForSchemaChangeDone({ sql getTableStatusSql - time 60 + time 600 }, insertSql, false, "${tbName1}") sql """ DROP TABLE IF EXISTS ${tbName1} """ //Test the dup model by modify a key type from BIGINT to VARCHAR - errorMessage = "errCode = 2, detailMessage = Can not change from wider type BIGINT to narrower type VARCHAR(2)" + errorMessage = "errCode = 2, detailMessage = Can not change from wider type bigint to narrower type varchar(2)" expectException({ sql initTable sql initTableData @@ -1090,7 +1090,7 @@ suite("test_dup_schema_key_change_modify","p0") { insertSql = "insert into ${tbName1} values(923456689, 'Alice', 'v1asd', 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00'); " waitForSchemaChangeDone({ sql getTableStatusSql - time 60 + time 600 }, insertSql, true, "${tbName1}") }, errorMessage) @@ -1103,10 +1103,10 @@ suite("test_dup_schema_key_change_modify","p0") { insertSql = "insert into ${tbName1} values(923456689, 'Alice', 'asd', 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00'); " waitForSchemaChangeDone({ sql getTableStatusSql - time 60 + time 600 }, insertSql, true, "${tbName1}") }, errorMessage) -} +} \ No newline at end of file diff --git a/regression-test/suites/schema_change_p0/test_dup_schema_value_modify1.groovy b/regression-test/suites/schema_change_p0/test_dup_schema_value_modify1.groovy index b60bbe489e1..58ff46de5d4 100644 --- a/regression-test/suites/schema_change_p0/test_dup_schema_value_modify1.groovy +++ b/regression-test/suites/schema_change_p0/test_dup_schema_value_modify1.groovy @@ -1058,1007 +1058,6 @@ suite("test_dup_schema_value_modify1", "p0") { - - /** - * Test the dup model by modify a value type from FLOAT to other type - */ - sql """ DROP TABLE IF EXISTS ${tbName1} """ - initTable = " CREATE TABLE IF NOT EXISTS ${tbName1}\n" + - " (\n" + - " `user_id` LARGEINT NOT NULL COMMENT \"用户id\",\n" + - " `username` VARCHAR(50) NOT NULL COMMENT \"用户昵称\",\n" + - " `score` FLOAT COMMENT \"分数\",\n" + - " `city` VARCHAR(20) COMMENT \"用户所在城市\",\n" + - " `age` SMALLINT COMMENT \"用户年龄\",\n" + - " `sex` TINYINT COMMENT \"用户性别\",\n" + - " `phone` LARGEINT COMMENT \"用户电话\",\n" + - " `address` VARCHAR(500) COMMENT \"用户地址\",\n" + - " `register_time` DATETIME COMMENT \"用户注册时间\",\n" + - " `m` Map<STRING, INT> NULL COMMENT \"\",\n" + - " `j` JSON NULL COMMENT \"\"\n" + - " )\n" + - " DUPLICATE KEY(`user_id`, `username`)\n" + - " DISTRIBUTED BY HASH(`user_id`) BUCKETS 1\n" + - " PROPERTIES (\n" + - " \"replication_allocation\" = \"tag.location.default: 1\"\n" + - " );" - - initTableData = "insert into ${tbName1} values(123456789, 'Alice', 1.8, 'Beijing', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00', {'a': 100, 'b': 200}, '[\"abc\", \"def\"]')," + - " (234567890, 'Bob', 1.89, 'Shanghai', 30, 1, 13998765432, 'No. 456 Street, Shanghai', '2022-02-02 12:00:00', {'a': 200, 'b': 200}, '[\"abc\", \"def\"]')," + - " (345678901, 'Carol', 2.6, 'Guangzhou', 28, 0, 13724681357, 'No. 789 Street, Guangzhou', '2022-03-03 14:00:00', {'a': 300, 'b': 200}, '[\"abc\", \"def\"]')," + - " (456789012, 'Dave', 3.9, 'Shenzhen', 35, 1, 13680864279, 'No. 987 Street, Shenzhen', '2022-04-04 16:00:00', {'a': 400, 'b': 200}, '[\"abc\", \"def\"]')," + - " (567890123, 'Eve', 4.2, 'Chengdu', 27, 0, 13572468091, 'No. 654 Street, Chengdu', '2022-05-05 18:00:00', {'a': 500, 'b': 200}, '[\"abc\", \"def\"]')," + - " (678901234, 'Frank', 2.5, 'Hangzhou', 32, 1, 13467985213, 'No. 321 Street, Hangzhou', '2022-06-06 20:00:00', {'a': 600, 'b': 200}, '[\"abc\", \"def\"]')," + - " (789012345, 'Grace', 2.1, 'Xian', 29, 0, 13333333333, 'No. 222 Street, Xian', '2022-07-07 22:00:00', {'a': 700, 'b': 200}, '[\"abc\", \"def\"]');" - - //TODO Test the dup model by modify a value type from FLOAT to BOOLEAN - errorMessage = "errCode = 2, detailMessage = Can not change FLOAT to BOOLEAN" - expectException({ - sql initTable - sql initTableData - sql """ alter table ${tbName1} MODIFY column score BOOLEAN """ - insertSql = "insert into ${tbName1} values(993456689, 'Alice', false, 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00', {'a': 100, 'b': 200}, '{\"k1\":\"v1\", \"k2\": 200}'); " - waitForSchemaChangeDone({ - sql getTableStatusSql - time 60 - }, insertSql, true, "${tbName1}") - }, errorMessage) - - - // TODO Test the dup model by modify a value type from FLOAT to TINYINT - errorMessage = "errCode = 2, detailMessage = Can not change FLOAT to TINYINT" - expectException({ - sql initTable - sql initTableData - sql """ alter table ${tbName1} MODIFY column score TINYINT """ - insertSql = "insert into ${tbName1} values(993456689, 'Alice', 2, 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00', {'a': 100, 'b': 200}, '{\"k1\":\"v1\", \"k2\": 200}'); " - waitForSchemaChangeDone({ - sql getTableStatusSql - time 60 - }, insertSql, true, "${tbName1}") - }, errorMessage) - - - //TODO Test the dup model by modify a value type from FLOAT to SMALLINT - errorMessage = "errCode = 2, detailMessage = Can not change FLOAT to SMALLINT" - expectException({ - sql initTable - sql initTableData - sql """ alter table ${tbName1} MODIFY column score SMALLINT """ - insertSql = "insert into ${tbName1} values(993456689, 'Alice', 3, 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00', {'a': 100, 'b': 200}, [\"abc\", \"def\"]); " - waitForSchemaChangeDone({ - sql getTableStatusSql - time 60 - }, insertSql, true, "${tbName1}") - }, errorMessage) - - //TODO Test the dup model by modify a value type from FLOAT to INT - errorMessage = "errCode = 2, detailMessage = Can not change FLOAT to INT" - expectException({ - sql initTable - sql initTableData - - sql """ alter table ${tbName1} MODIFY column score INT """ - insertSql = "insert into ${tbName1} values(993456689, 'Alice', 4, 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00', {'a': 100, 'b': 200}, [\"abc\", \"def\"]); " - waitForSchemaChangeDone({ - sql getTableStatusSql - time 60 - }, insertSql, true, "${tbName1}") - }, errorMessage) - - - //TODO Test the dup model by modify a value type from FLOAT to BIGINT - errorMessage = "errCode = 2, detailMessage = Can not change FLOAT to BIGINT" - expectException({ - sql initTable - sql initTableData - sql """ alter table ${tbName1} MODIFY column score BIGINT """ - insertSql = "insert into ${tbName1} values(993456689, 'Alice', 545645, 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00', {'a': 100, 'b': 200}, [\"abc\", \"def\"]); " - waitForSchemaChangeDone({ - sql getTableStatusSql - time 60 - }, insertSql, true, "${tbName1}") - }, errorMessage) - - //TODO Test the dup model by modify a value type from FLOAT to LARGEINT - errorMessage = "errCode = 2, detailMessage = Can not change FLOAT to LARGEINT" - expectException({ - sql initTable - sql initTableData - sql """ alter table ${tbName1} MODIFY column score LARGEINT """ - insertSql = "insert into ${tbName1} values(993456689, 'Alice', 156546, 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00', {'a': 100, 'b': 200}, [\"abc\", \"def\"]); " - waitForSchemaChangeDone({ - sql getTableStatusSql - time 60 - }, insertSql, true, "${tbName1}") - }, errorMessage) - - - //TODO Loss of accuracy Test the dup model by modify a value type from FLOAT to DOUBLE - - sql initTable - sql initTableData - sql """ alter table ${tbName1} MODIFY column score DOUBLE """ - insertSql = "insert into ${tbName1} values(993456689, 'Alice', 1.23, 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00', {'a': 100, 'b': 200}, '[\"abc\", \"def\"]'); " - waitForSchemaChangeDone({ - sql getTableStatusSql - time 60 - }, insertSql, false, "${tbName1}") - - sql """ DROP TABLE IF EXISTS ${tbName2} """ - initTable2 = " CREATE TABLE IF NOT EXISTS ${tbName2}\n" + - " (\n" + - " `user_id` LARGEINT NOT NULL COMMENT \"用户id\",\n" + - " `username` VARCHAR(50) NOT NULL COMMENT \"用户昵称\",\n" + - " `score` DOUBLE COMMENT \"分数\",\n" + - " `city` VARCHAR(20) COMMENT \"用户所在城市\",\n" + - " `age` SMALLINT COMMENT \"用户年龄\",\n" + - " `sex` TINYINT COMMENT \"用户性别\",\n" + - " `phone` LARGEINT COMMENT \"用户电话\",\n" + - " `address` VARCHAR(500) COMMENT \"用户地址\",\n" + - " `register_time` DATETIME COMMENT \"用户注册时间\",\n" + - " `m` Map<STRING, INT> NULL COMMENT \"\",\n" + - " `j` JSON NULL COMMENT \"\"\n" + - " )\n" + - " DUPLICATE KEY(`user_id`, `username`)\n" + - " DISTRIBUTED BY HASH(`user_id`) BUCKETS 1\n" + - " PROPERTIES (\n" + - " \"replication_allocation\" = \"tag.location.default: 1\"\n" + - " );" - - initTableData2 = "insert into ${tbName2} values(123456789, 'Alice', 1.8, 'Beijing', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00', {'a': 100, 'b': 200}, '[\"abc\", \"def\"]')," + - " (234567890, 'Bob', 1.89, 'Shanghai', 30, 1, 13998765432, 'No. 456 Street, Shanghai', '2022-02-02 12:00:00', {'a': 200, 'b': 200}, '[\"abc\", \"def\"]')," + - " (345678901, 'Carol', 2.6, 'Guangzhou', 28, 0, 13724681357, 'No. 789 Street, Guangzhou', '2022-03-03 14:00:00', {'a': 300, 'b': 200}, '[\"abc\", \"def\"]')," + - " (456789012, 'Dave', 3.9, 'Shenzhen', 35, 1, 13680864279, 'No. 987 Street, Shenzhen', '2022-04-04 16:00:00', {'a': 400, 'b': 200}, '[\"abc\", \"def\"]')," + - " (567890123, 'Eve', 4.2, 'Chengdu', 27, 0, 13572468091, 'No. 654 Street, Chengdu', '2022-05-05 18:00:00', {'a': 500, 'b': 200}, '[\"abc\", \"def\"]')," + - " (678901234, 'Frank', 2.5, 'Hangzhou', 32, 1, 13467985213, 'No. 321 Street, Hangzhou', '2022-06-06 20:00:00', {'a': 600, 'b': 200}, '[\"abc\", \"def\"]')," + - " (993456689, 'Alice', 1.23, 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00', {'a': 100, 'b': 200}, '[\\\"abc\\\", \\\"def\\\"]')," + - " (789012345, 'Grace', 2.1, 'Xian', 29, 0, 13333333333, 'No. 222 Street, Xian', '2022-07-07 22:00:00', {'a': 700, 'b': 200}, '[\"abc\", \"def\"]');" - - sql initTable2 - sql initTableData2 - sql """ DROP TABLE IF EXISTS ${tbName1} """ - - - //TODO Test the dup model by modify a value type from FLOAT to DECIMAL - errorMessage = "errCode = 2, detailMessage = Can not change FLOAT to DECIMAL128" - expectException({ - sql initTable - sql initTableData - sql """ alter table ${tbName1} MODIFY column score DECIMAL(38,0) """ - insertSql = "insert into ${tbName1} values(993456689, 'Alice', 1.23, 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00', {'a': 100, 'b': 200}, '[\"abc\", \"def\"]'); " - waitForSchemaChangeDone({ - sql getTableStatusSql - time 60 - }, insertSql, true, "${tbName1}") - - }, errorMessage) - - - //TODO Test the dup model by modify a value type from FLOAT to DATE - errorMessage = "errCode = 2, detailMessage = Can not change FLOAT to DATEV2" - expectException({ - sql initTable - sql initTableData - sql """ alter table ${tbName1} MODIFY column score DATE """ - insertSql = "insert into ${tbName1} values(993456689, 'Alice', '2003-12-31', 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00', {'a': 100, 'b': 200}, '[\"abc\", \"def\"]'); " - waitForSchemaChangeDone({ - sql getTableStatusSql - time 60 - }, insertSql, true, "${tbName1}") - - }, errorMessage) - - //TODO Test the dup model by modify a value type from FLOAT to DATE - errorMessage = "errCode = 2, detailMessage = Can not change FLOAT to DATEV2" - expectException({ - sql initTable - sql initTableData - sql """ alter table ${tbName1} MODIFY column score DATEV2 """ - insertSql = "insert into ${tbName1} values(993456689, 'Alice', '2003-12-31', 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00', {'a': 100, 'b': 200}, '[\"abc\", \"def\"]'); " - waitForSchemaChangeDone({ - sql getTableStatusSql - time 60 - }, insertSql, true, "${tbName1}") - - }, errorMessage) - - - //TODO Test the dup model by modify a value type from FLOAT to DATETIME - errorMessage = "errCode = 2, detailMessage = Can not change FLOAT to DATETIMEV2" - expectException({ - sql initTable - sql initTableData - sql """ alter table ${tbName1} MODIFY column score DATETIME """ - insertSql = "insert into ${tbName1} values(993456689, 'Alice', '2003-12-31 20:12:12', 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00', {'a': 100, 'b': 200}, '[\"abc\", \"def\"]'); " - waitForSchemaChangeDone({ - sql getTableStatusSql - time 60 - }, insertSql, true, "${tbName1}") - - }, errorMessage) - - //TODO Test the dup model by modify a value type from FLOAT to DATETIME - errorMessage = "errCode = 2, detailMessage = Can not change FLOAT to DATETIMEV2" - expectException({ - sql initTable - sql initTableData - sql """ alter table ${tbName1} MODIFY column score DATETIMEV2 """ - insertSql = "insert into ${tbName1} values(993456689, 'Alice', '2003-12-31 20:12:12', 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00', {'a': 100, 'b': 200}, '[\"abc\", \"def\"]'); " - waitForSchemaChangeDone({ - sql getTableStatusSql - time 60 - }, insertSql, true, "${tbName1}") - - }, errorMessage) - - //TODO Test the dup model by modify a value type from FLOAT to CHAR - errorMessage = "errCode = 2, detailMessage = Can not change FLOAT to CHAR" - expectException({ - sql initTable - sql initTableData - sql """ alter table ${tbName1} MODIFY column score CHAR(15) """ - insertSql = "insert into ${tbName1} values(993456689, 'Alice', 'asd', 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00', {'a': 100, 'b': 200}, '[\"abc\", \"def\"]'); " - waitForSchemaChangeDone({ - sql getTableStatusSql - time 60 - }, insertSql, true, "${tbName1}") - }, errorMessage) - - //TODO Data doublingTest the dup model by modify a value type from FLOAT to VARCHAR - //Test the dup model by modify a value type from FLOAT to VARCHAR - sql initTable - sql initTableData - sql """ alter table ${tbName1} MODIFY column score VARCHAR(100) """ - insertSql = "insert into ${tbName1} values(993456689, 'Alice', 'asd', 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00', {'a': 100, 'b': 200}, '[\"abc\", \"def\"]'); " - waitForSchemaChangeDone({ - sql getTableStatusSql - time 60 - }, insertSql, true, "${tbName1}") - - - //Test the dup model by modify a value type from FLOAT to STRING - sql initTable - sql initTableData - sql """ alter table ${tbName1} MODIFY column score STRING """ - insertSql = "insert into ${tbName1} values(993456689, 'Alice', 'asd', 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00', {'a': 100, 'b': 200}, '[\"abc\", \"def\"]'); " - waitForSchemaChangeDone({ - sql getTableStatusSql - time 60 - }, insertSql, false, "${tbName1}") - - sql """ DROP TABLE IF EXISTS ${tbName2} """ - initTable2 = " CREATE TABLE IF NOT EXISTS ${tbName2}\n" + - " (\n" + - " `user_id` LARGEINT NOT NULL COMMENT \"用户id\",\n" + - " `username` VARCHAR(50) NOT NULL COMMENT \"用户昵称\",\n" + - " `score` STRING COMMENT \"分数\",\n" + - " `city` VARCHAR(20) COMMENT \"用户所在城市\",\n" + - " `age` SMALLINT COMMENT \"用户年龄\",\n" + - " `sex` TINYINT COMMENT \"用户性别\",\n" + - " `phone` LARGEINT COMMENT \"用户电话\",\n" + - " `address` VARCHAR(500) COMMENT \"用户地址\",\n" + - " `register_time` DATETIME COMMENT \"用户注册时间\",\n" + - " `m` Map<STRING, INT> NULL COMMENT \"\",\n" + - " `j` JSON NULL COMMENT \"\"\n" + - " )\n" + - " DUPLICATE KEY(`user_id`, `username`)\n" + - " DISTRIBUTED BY HASH(`user_id`) BUCKETS 1\n" + - " PROPERTIES (\n" + - " \"replication_allocation\" = \"tag.location.default: 1\"\n" + - " );" - - initTableData2 = "insert into ${tbName2} values(123456789, 'Alice', 1.8, 'Beijing', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00', {'a': 100, 'b': 200}, '[\"abc\", \"def\"]')," + - " (234567890, 'Bob', 1.89, 'Shanghai', 30, 1, 13998765432, 'No. 456 Street, Shanghai', '2022-02-02 12:00:00', {'a': 200, 'b': 200}, '[\"abc\", \"def\"]')," + - " (345678901, 'Carol', 2.6, 'Guangzhou', 28, 0, 13724681357, 'No. 789 Street, Guangzhou', '2022-03-03 14:00:00', {'a': 300, 'b': 200}, '[\"abc\", \"def\"]')," + - " (456789012, 'Dave', 3.9, 'Shenzhen', 35, 1, 13680864279, 'No. 987 Street, Shenzhen', '2022-04-04 16:00:00', {'a': 400, 'b': 200}, '[\"abc\", \"def\"]')," + - " (567890123, 'Eve', 4.2, 'Chengdu', 27, 0, 13572468091, 'No. 654 Street, Chengdu', '2022-05-05 18:00:00', {'a': 500, 'b': 200}, '[\"abc\", \"def\"]')," + - " (678901234, 'Frank', 2.5, 'Hangzhou', 32, 1, 13467985213, 'No. 321 Street, Hangzhou', '2022-06-06 20:00:00', {'a': 600, 'b': 200}, '[\"abc\", \"def\"]')," + - " (993456689, 'Alice', 'asd', 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00', {'a': 100, 'b': 200}, '[\\\"abc\\\", \\\"def\\\"]')," + - " (789012345, 'Grace', 2.1, 'Xian', 29, 0, 13333333333, 'No. 222 Street, Xian', '2022-07-07 22:00:00', {'a': 700, 'b': 200}, '[\"abc\", \"def\"]');" - - sql initTable2 - sql initTableData2 - checkTableData("${tbName1}", "${tbName2}", "score") - sql """ DROP TABLE IF EXISTS ${tbName1} """ - - - //TODO Test the dup model by modify a value type from FLOAT to map - //Test the dup model by modify a value type from FLOAT to STRING - errorMessage = "errCode = 2, detailMessage = Can not change FLOAT to MAP" - expectException({ - sql initTable - sql initTableData - sql """ alter table ${tbName1} MODIFY column score Map<STRING, INT> """ - insertSql = "insert into ${tbName1} values(993456689, 'Alice', {'a': 100, 'b': 200}, 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00', {'a': 100, 'b': 200}, '[\"abc\", \"def\"]'); " - waitForSchemaChangeDone({ - sql getTableStatusSql - time 60 - }, insertSql, true, "${tbName1}") - }, errorMessage) - - - //TODO Test the dup model by modify a value type from FLOAT to JSON - errorMessage = "errCode = 2, detailMessage = Can not change FLOAT to JSON" - expectException({ - sql initTable - sql initTableData - sql """ alter table ${tbName1} MODIFY column score JSON """ - insertSql = "insert into ${tbName1} values(993456689, 'Alice', '{'a': 100, 'b': 200}', 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00', {'a': 100, 'b': 200}, '[\"abc\", \"def\"]'); " - waitForSchemaChangeDone({ - sql getTableStatusSql - time 60 - }, insertSql, true, "${tbName1}") - }, errorMessage) - - /** - * Test the unique model by modify a value type from DOUBLE to other type - */ - sql """ DROP TABLE IF EXISTS ${tbName1} """ - initTable = " CREATE TABLE IF NOT EXISTS ${tbName1}\n" + - " (\n" + - " `user_id` LARGEINT NOT NULL COMMENT \"用户id\",\n" + - " `username` VARCHAR(50) NOT NULL COMMENT \"用户昵称\",\n" + - " `score` DOUBLE COMMENT \"分数\",\n" + - " `city` VARCHAR(20) COMMENT \"用户所在城市\",\n" + - " `age` SMALLINT COMMENT \"用户年龄\",\n" + - " `sex` TINYINT COMMENT \"用户性别\",\n" + - " `phone` LARGEINT COMMENT \"用户电话\",\n" + - " `address` VARCHAR(500) COMMENT \"用户地址\",\n" + - " `register_time` DATETIME COMMENT \"用户注册时间\",\n" + - " `m` Map<STRING, INT> NULL COMMENT \"\",\n" + - " `j` JSON NULL COMMENT \"\"\n" + - " )\n" + - " UNIQUE KEY(`user_id`, `username`)\n" + - " DISTRIBUTED BY HASH(`user_id`) BUCKETS 1\n" + - " PROPERTIES (\n" + - " \"replication_allocation\" = \"tag.location.default: 1\"\n" + - " );" - - initTableData = "insert into ${tbName1} values(123456789, 'Alice', 1.8, 'Beijing', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00', {'a': 100, 'b': 200}, '[\"abc\", \"def\"]')," + - " (234567890, 'Bob', 1.89, 'Shanghai', 30, 1, 13998765432, 'No. 456 Street, Shanghai', '2022-02-02 12:00:00', {'a': 200, 'b': 200}, '[\"abc\", \"def\"]')," + - " (345678901, 'Carol', 2.6, 'Guangzhou', 28, 0, 13724681357, 'No. 789 Street, Guangzhou', '2022-03-03 14:00:00', {'a': 300, 'b': 200}, '[\"abc\", \"def\"]')," + - " (456789012, 'Dave', 3.9, 'Shenzhen', 35, 1, 13680864279, 'No. 987 Street, Shenzhen', '2022-04-04 16:00:00', {'a': 400, 'b': 200}, '[\"abc\", \"def\"]')," + - " (567890123, 'Eve', 4.2, 'Chengdu', 27, 0, 13572468091, 'No. 654 Street, Chengdu', '2022-05-05 18:00:00', {'a': 500, 'b': 200}, '[\"abc\", \"def\"]')," + - " (678901234, 'Frank', 2.5, 'Hangzhou', 32, 1, 13467985213, 'No. 321 Street, Hangzhou', '2022-06-06 20:00:00', {'a': 600, 'b': 200}, '[\"abc\", \"def\"]')," + - " (789012345, 'Grace', 2.1, 'Xian', 29, 0, 13333333333, 'No. 222 Street, Xian', '2022-07-07 22:00:00', {'a': 700, 'b': 200}, '[\"abc\", \"def\"]');" - - //TODO Test the unique model by modify a value type from DOUBLE to BOOLEAN - errorMessage = "errCode = 2, detailMessage = Can not change DOUBLE to BOOLEAN" - expectException({ - sql initTable - sql initTableData - sql """ alter table ${tbName1} MODIFY column score BOOLEAN """ - insertSql = "insert into ${tbName1} values(993456689, 'Alice', false, 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00', {'a': 100, 'b': 200}, '{\"k1\":\"v1\", \"k2\": 200}'); " - waitForSchemaChangeDone({ - sql getTableStatusSql - time 60 - }, insertSql, true, "${tbName1}") - }, errorMessage) - - - // TODO Test the unique model by modify a value type from DOUBLE to TINYINT - errorMessage = "errCode = 2, detailMessage = Can not change DOUBLE to TINYINT" - expectException({ - sql initTable - sql initTableData - sql """ alter table ${tbName1} MODIFY column score TINYINT """ - insertSql = "insert into ${tbName1} values(993456689, 'Alice', 2, 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00', {'a': 100, 'b': 200}, '{\"k1\":\"v1\", \"k2\": 200}'); " - waitForSchemaChangeDone({ - sql getTableStatusSql - time 60 - }, insertSql, true, "${tbName1}") - }, errorMessage) - - - //Test the unique model by modify a value type from DOUBLE to SMALLINT - errorMessage = "errCode = 2, detailMessage = Can not change DOUBLE to SMALLINT" - expectException({ - sql initTable - sql initTableData - sql """ alter table ${tbName1} MODIFY column score SMALLINT """ - insertSql = "insert into ${tbName1} values(993456689, 'Alice', 3, 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00', {'a': 100, 'b': 200}, [\"abc\", \"def\"]); " - waitForSchemaChangeDone({ - sql getTableStatusSql - time 60 - }, insertSql, true, "${tbName1}") - }, errorMessage) - - //Test the unique model by modify a value type from DOUBLE to INT - errorMessage = "errCode = 2, detailMessage = Can not change DOUBLE to INT" - expectException({ - sql initTable - sql initTableData - - sql """ alter table ${tbName1} MODIFY column score INT """ - insertSql = "insert into ${tbName1} values(993456689, 'Alice', 4, 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00', {'a': 100, 'b': 200}, [\"abc\", \"def\"]); " - waitForSchemaChangeDone({ - sql getTableStatusSql - time 60 - }, insertSql, true, "${tbName1}") - }, errorMessage) - - - //Test the unique model by modify a value type from DOUBLE to BIGINT - errorMessage = "errCode = 2, detailMessage = Can not change DOUBLE to BIGINT" - expectException({ - sql initTable - sql initTableData - sql """ alter table ${tbName1} MODIFY column score BIGINT """ - insertSql = "insert into ${tbName1} values(993456689, 'Alice', 545645, 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00', {'a': 100, 'b': 200}, [\"abc\", \"def\"]); " - waitForSchemaChangeDone({ - sql getTableStatusSql - time 60 - }, insertSql, true, "${tbName1}") - }, errorMessage) - - //Test the unique model by modify a value type from DOUBLE to LARGEINT - errorMessage = "errCode = 2, detailMessage = Can not change DOUBLE to LARGEINT" - expectException({ - sql initTable - sql initTableData - sql """ alter table ${tbName1} MODIFY column score LARGEINT """ - insertSql = "insert into ${tbName1} values(993456689, 'Alice', 156546, 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00', {'a': 100, 'b': 200}, [\"abc\", \"def\"]); " - waitForSchemaChangeDone({ - sql getTableStatusSql - time 60 - }, insertSql, true, "${tbName1}") - }, errorMessage) - - - //Test the unique model by modify a value type from DOUBLE to FLOAT - errorMessage = "errCode = 2, detailMessage = Can not change DOUBLE to FLOAT" - expectException({ - sql initTable - sql initTableData - sql """ alter table ${tbName1} MODIFY column score FLOAT """ - insertSql = "insert into ${tbName1} values(993456689, 'Alice', 1.23, 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00', {'a': 100, 'b': 200}, '[\"abc\", \"def\"]'); " - waitForSchemaChangeDone({ - sql getTableStatusSql - time 60 - }, insertSql, true, "${tbName1}") - }, errorMessage) - - - //TODO Test the unique model by modify a value type from DOUBLE to DECIMAL - errorMessage = "errCode = 2, detailMessage = Can not change DOUBLE to DECIMAL128" - expectException({ - sql initTable - sql initTableData - sql """ alter table ${tbName1} MODIFY column score DECIMAL(38,0) """ - insertSql = "insert into ${tbName1} values(993456689, 'Alice', 1.23, 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00', {'a': 100, 'b': 200}, '[\"abc\", \"def\"]'); " - waitForSchemaChangeDone({ - sql getTableStatusSql - time 60 - }, insertSql, true, "${tbName1}") - - }, errorMessage) - - - //TODO Test the unique model by modify a value type from DOUBLE to DATE - errorMessage = "errCode = 2, detailMessage = Can not change DOUBLE to DATEV2" - expectException({ - sql initTable - sql initTableData - sql """ alter table ${tbName1} MODIFY column score DATE """ - insertSql = "insert into ${tbName1} values(993456689, 'Alice', '2003-12-31', 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00', {'a': 100, 'b': 200}, '[\"abc\", \"def\"]'); " - waitForSchemaChangeDone({ - sql getTableStatusSql - time 60 - }, insertSql, true, "${tbName1}") - - }, errorMessage) - - //TODO Test the unique model by modify a value type from DOUBLE to DATE - errorMessage = "errCode = 2, detailMessage = Can not change DOUBLE to DATEV2" - expectException({ - sql initTable - sql initTableData - sql """ alter table ${tbName1} MODIFY column score DATEV2 """ - insertSql = "insert into ${tbName1} values(993456689, 'Alice', '2003-12-31', 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00', {'a': 100, 'b': 200}, '[\"abc\", \"def\"]'); " - waitForSchemaChangeDone({ - sql getTableStatusSql - time 60 - }, insertSql, true, "${tbName1}") - - }, errorMessage) - - - //TODO Test the unique model by modify a value type from DOUBLE to DATETIME - errorMessage = "errCode = 2, detailMessage = Can not change DOUBLE to DATETIMEV2" - expectException({ - sql initTable - sql initTableData - sql """ alter table ${tbName1} MODIFY column score DATETIME """ - insertSql = "insert into ${tbName1} values(993456689, 'Alice', '2003-12-31 20:12:12', 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00', {'a': 100, 'b': 200}, '[\"abc\", \"def\"]'); " - waitForSchemaChangeDone({ - sql getTableStatusSql - time 60 - }, insertSql, true, "${tbName1}") - - }, errorMessage) - - //TODO Test the unique model by modify a value type from DOUBLE to DATETIME - errorMessage = "errCode = 2, detailMessage = Can not change DOUBLE to DATETIMEV2" - expectException({ - sql initTable - sql initTableData - sql """ alter table ${tbName1} MODIFY column score DATETIMEV2 """ - insertSql = "insert into ${tbName1} values(993456689, 'Alice', '2003-12-31 20:12:12', 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00', {'a': 100, 'b': 200}, '[\"abc\", \"def\"]'); " - waitForSchemaChangeDone({ - sql getTableStatusSql - time 60 - }, insertSql, true, "${tbName1}") - - }, errorMessage) - - //TODO Test the unique model by modify a value type from DOUBLE to CHAR - errorMessage = "errCode = 2, detailMessage = Can not change DOUBLE to CHAR" - expectException({ - sql initTable - sql initTableData - sql """ alter table ${tbName1} MODIFY column score CHAR(15) """ - insertSql = "insert into ${tbName1} values(993456689, 'Alice', 'asd', 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00', {'a': 100, 'b': 200}, '[\"abc\", \"def\"]'); " - waitForSchemaChangeDone({ - sql getTableStatusSql - time 60 - }, insertSql, true, "${tbName1}") - }, errorMessage) - - //Test the unique model by modify a value type from DOUBLE to VARCHAR - sql initTable - sql initTableData - sql """ alter table ${tbName1} MODIFY column score VARCHAR(100) """ - insertSql = "insert into ${tbName1} values(993456689, 'Alice', 'asd', 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00', {'a': 100, 'b': 200}, '[\"abc\", \"def\"]'); " - waitForSchemaChangeDone({ - sql getTableStatusSql - time 60 - }, insertSql, false, "${tbName1}") - - sql """ DROP TABLE IF EXISTS ${tbName2} """ - initTable2 = " CREATE TABLE IF NOT EXISTS ${tbName2}\n" + - " (\n" + - " `user_id` LARGEINT NOT NULL COMMENT \"用户id\",\n" + - " `username` VARCHAR(50) NOT NULL COMMENT \"用户昵称\",\n" + - " `score` VARCHAR(100) COMMENT \"分数\",\n" + - " `city` VARCHAR(20) COMMENT \"用户所在城市\",\n" + - " `age` SMALLINT COMMENT \"用户年龄\",\n" + - " `sex` TINYINT COMMENT \"用户性别\",\n" + - " `phone` LARGEINT COMMENT \"用户电话\",\n" + - " `address` VARCHAR(500) COMMENT \"用户地址\",\n" + - " `register_time` DATETIME COMMENT \"用户注册时间\",\n" + - " `m` Map<STRING, INT> NULL COMMENT \"\",\n" + - " `j` JSON NULL COMMENT \"\"\n" + - " )\n" + - " DUPLICATE KEY(`user_id`, `username`)\n" + - " DISTRIBUTED BY HASH(`user_id`) BUCKETS 1\n" + - " PROPERTIES (\n" + - " \"replication_allocation\" = \"tag.location.default: 1\"\n" + - " );" - - initTableData2 = "insert into ${tbName2} values(123456789, 'Alice', 1.8, 'Beijing', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00', {'a': 100, 'b': 200}, '[\"abc\", \"def\"]')," + - " (234567890, 'Bob', 1.89, 'Shanghai', 30, 1, 13998765432, 'No. 456 Street, Shanghai', '2022-02-02 12:00:00', {'a': 200, 'b': 200}, '[\"abc\", \"def\"]')," + - " (345678901, 'Carol', 2.6, 'Guangzhou', 28, 0, 13724681357, 'No. 789 Street, Guangzhou', '2022-03-03 14:00:00', {'a': 300, 'b': 200}, '[\"abc\", \"def\"]')," + - " (456789012, 'Dave', 3.9, 'Shenzhen', 35, 1, 13680864279, 'No. 987 Street, Shenzhen', '2022-04-04 16:00:00', {'a': 400, 'b': 200}, '[\"abc\", \"def\"]')," + - " (567890123, 'Eve', 4.2, 'Chengdu', 27, 0, 13572468091, 'No. 654 Street, Chengdu', '2022-05-05 18:00:00', {'a': 500, 'b': 200}, '[\"abc\", \"def\"]')," + - " (678901234, 'Frank', 2.5, 'Hangzhou', 32, 1, 13467985213, 'No. 321 Street, Hangzhou', '2022-06-06 20:00:00', {'a': 600, 'b': 200}, '[\"abc\", \"def\"]')," + - " (993456689, 'Alice', 'asd', 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00', {'a': 100, 'b': 200}, '[\\\"abc\\\", \\\"def\\\"]')," + - " (789012345, 'Grace', 2.1, 'Xian', 29, 0, 13333333333, 'No. 222 Street, Xian', '2022-07-07 22:00:00', {'a': 700, 'b': 200}, '[\"abc\", \"def\"]');" - - sql initTable2 - sql initTableData2 - checkTableData("${tbName1}", "${tbName2}", "score") - sql """ DROP TABLE IF EXISTS ${tbName1} """ - - - //Test the unique model by modify a value type from DOUBLE to STRING - sql initTable - sql initTableData - sql """ alter table ${tbName1} MODIFY column score STRING """ - insertSql = "insert into ${tbName1} values(993456689, 'Alice', 'asd', 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00', {'a': 100, 'b': 200}, '[\"abc\", \"def\"]'); " - waitForSchemaChangeDone({ - sql getTableStatusSql - time 60 - }, insertSql, false, "${tbName1}") - - - sql """ DROP TABLE IF EXISTS ${tbName2} """ - initTable2 = " CREATE TABLE IF NOT EXISTS ${tbName2}\n" + - " (\n" + - " `user_id` LARGEINT NOT NULL COMMENT \"用户id\",\n" + - " `username` VARCHAR(50) NOT NULL COMMENT \"用户昵称\",\n" + - " `score` STRING COMMENT \"分数\",\n" + - " `city` VARCHAR(20) COMMENT \"用户所在城市\",\n" + - " `age` SMALLINT COMMENT \"用户年龄\",\n" + - " `sex` TINYINT COMMENT \"用户性别\",\n" + - " `phone` LARGEINT COMMENT \"用户电话\",\n" + - " `address` VARCHAR(500) COMMENT \"用户地址\",\n" + - " `register_time` DATETIME COMMENT \"用户注册时间\",\n" + - " `m` Map<STRING, INT> NULL COMMENT \"\",\n" + - " `j` JSON NULL COMMENT \"\"\n" + - " )\n" + - " DUPLICATE KEY(`user_id`, `username`)\n" + - " DISTRIBUTED BY HASH(`user_id`) BUCKETS 1\n" + - " PROPERTIES (\n" + - " \"replication_allocation\" = \"tag.location.default: 1\"\n" + - " );" - - initTableData2 = "insert into ${tbName2} values(123456789, 'Alice', 1.8, 'Beijing', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00', {'a': 100, 'b': 200}, '[\"abc\", \"def\"]')," + - " (234567890, 'Bob', 1.89, 'Shanghai', 30, 1, 13998765432, 'No. 456 Street, Shanghai', '2022-02-02 12:00:00', {'a': 200, 'b': 200}, '[\"abc\", \"def\"]')," + - " (345678901, 'Carol', 2.6, 'Guangzhou', 28, 0, 13724681357, 'No. 789 Street, Guangzhou', '2022-03-03 14:00:00', {'a': 300, 'b': 200}, '[\"abc\", \"def\"]')," + - " (456789012, 'Dave', 3.9, 'Shenzhen', 35, 1, 13680864279, 'No. 987 Street, Shenzhen', '2022-04-04 16:00:00', {'a': 400, 'b': 200}, '[\"abc\", \"def\"]')," + - " (567890123, 'Eve', 4.2, 'Chengdu', 27, 0, 13572468091, 'No. 654 Street, Chengdu', '2022-05-05 18:00:00', {'a': 500, 'b': 200}, '[\"abc\", \"def\"]')," + - " (678901234, 'Frank', 2.5, 'Hangzhou', 32, 1, 13467985213, 'No. 321 Street, Hangzhou', '2022-06-06 20:00:00', {'a': 600, 'b': 200}, '[\"abc\", \"def\"]')," + - " (993456689, 'Alice', 'asd', 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00', {'a': 100, 'b': 200}, '[\\\"abc\\\", \\\"def\\\"]')," + - " (789012345, 'Grace', 2.1, 'Xian', 29, 0, 13333333333, 'No. 222 Street, Xian', '2022-07-07 22:00:00', {'a': 700, 'b': 200}, '[\"abc\", \"def\"]');" - - sql initTable2 - sql initTableData2 - checkTableData("${tbName1}", "${tbName2}", "score") - sql """ DROP TABLE IF EXISTS ${tbName1} """ - - - //TODO Test the unique model by modify a value type from DOUBLE to map - //Test the unique model by modify a value type from DOUBLE to STRING - errorMessage = "errCode = 2, detailMessage = Can not change DOUBLE to MAP" - expectException({ - sql initTable - sql initTableData - sql """ alter table ${tbName1} MODIFY column score Map<STRING, INT> """ - insertSql = "insert into ${tbName1} values(993456689, 'Alice', {'a': 100, 'b': 200}, 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00', {'a': 100, 'b': 200}, '[\"abc\", \"def\"]'); " - waitForSchemaChangeDone({ - sql getTableStatusSql - time 60 - }, insertSql, true, "${tbName1}") - }, errorMessage) - - - //Test the unique model by modify a value type from DOUBLE to JSON - errorMessage = "errCode = 2, detailMessage = Can not change DOUBLE to JSON" - expectException({ - sql initTable - sql initTableData - sql """ alter table ${tbName1} MODIFY column score JSON """ - insertSql = "insert into ${tbName1} values(993456689, 'Alice', '{'a': 100, 'b': 200}', 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00', {'a': 100, 'b': 200}, '[\"abc\", \"def\"]'); " - waitForSchemaChangeDone({ - sql getTableStatusSql - time 60 - }, insertSql, true, "${tbName1}") - }, errorMessage) - - - /** - * Test the unique model by modify a value type from DECIMAL to other type - */ - sql """ DROP TABLE IF EXISTS ${tbName1} """ - initTable = " CREATE TABLE IF NOT EXISTS ${tbName1}\n" + - " (\n" + - " `user_id` LARGEINT NOT NULL COMMENT \"用户id\",\n" + - " `username` VARCHAR(50) NOT NULL COMMENT \"用户昵称\",\n" + - " `score` DECIMAL(38,10) COMMENT \"分数\",\n" + - " `city` VARCHAR(20) COMMENT \"用户所在城市\",\n" + - " `age` SMALLINT COMMENT \"用户年龄\",\n" + - " `sex` TINYINT COMMENT \"用户性别\",\n" + - " `phone` LARGEINT COMMENT \"用户电话\",\n" + - " `address` VARCHAR(500) COMMENT \"用户地址\",\n" + - " `register_time` DATETIME COMMENT \"用户注册时间\",\n" + - " `m` Map<STRING, INT> NULL COMMENT \"\",\n" + - " `j` JSON NULL COMMENT \"\"\n" + - " )\n" + - " UNIQUE KEY(`user_id`, `username`)\n" + - " DISTRIBUTED BY HASH(`user_id`) BUCKETS 1\n" + - " PROPERTIES (\n" + - " \"replication_allocation\" = \"tag.location.default: 1\"\n" + - " );" - - initTableData = "insert into ${tbName1} values(123456789, 'Alice', 1.83, 'Beijing', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00', {'a': 100, 'b': 200}, '[\"abc\", \"def\"]')," + - " (234567890, 'Bob', 1.89, 'Shanghai', 30, 1, 13998765432, 'No. 456 Street, Shanghai', '2022-02-02 12:00:00', {'a': 200, 'b': 200}, '[\"abc\", \"def\"]')," + - " (345678901, 'Carol', 2.6689, 'Guangzhou', 28, 0, 13724681357, 'No. 789 Street, Guangzhou', '2022-03-03 14:00:00', {'a': 300, 'b': 200}, '[\"abc\", \"def\"]')," + - " (456789012, 'Dave', 3.9456, 'Shenzhen', 35, 1, 13680864279, 'No. 987 Street, Shenzhen', '2022-04-04 16:00:00', {'a': 400, 'b': 200}, '[\"abc\", \"def\"]')," + - " (567890123, 'Eve', 4.223, 'Chengdu', 27, 0, 13572468091, 'No. 654 Street, Chengdu', '2022-05-05 18:00:00', {'a': 500, 'b': 200}, '[\"abc\", \"def\"]')," + - " (678901234, 'Frank', 2.5454, 'Hangzhou', 32, 1, 13467985213, 'No. 321 Street, Hangzhou', '2022-06-06 20:00:00', {'a': 600, 'b': 200}, '[\"abc\", \"def\"]')," + - " (789012345, 'Grace', 2.19656, 'Xian', 29, 0, 13333333333, 'No. 222 Street, Xian', '2022-07-07 22:00:00', {'a': 700, 'b': 200}, '[\"abc\", \"def\"]');" - - //TODO Test the unique model by modify a value type from DECIMAL128 to BOOLEAN - errorMessage = "errCode = 2, detailMessage = Can not change DECIMAL128 to BOOLEAN" - expectException({ - sql initTable - sql initTableData - sql """ alter table ${tbName1} MODIFY column score BOOLEAN """ - insertSql = "insert into ${tbName1} values(993456689, 'Alice', false, 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00', {'a': 100, 'b': 200}, '{\"k1\":\"v1\", \"k2\": 200}'); " - waitForSchemaChangeDone({ - sql getTableStatusSql - time 60 - }, insertSql, true, "${tbName1}") - }, errorMessage) - - - // TODO Test the unique model by modify a value type from DECIMAL128 to TINYINT - errorMessage = "errCode = 2, detailMessage = Can not change DECIMAL128 to TINYINT" - expectException({ - sql initTable - sql initTableData - sql """ alter table ${tbName1} MODIFY column score TINYINT """ - insertSql = "insert into ${tbName1} values(993456689, 'Alice', 2, 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00', {'a': 100, 'b': 200}, '{\"k1\":\"v1\", \"k2\": 200}'); " - waitForSchemaChangeDone({ - sql getTableStatusSql - time 60 - }, insertSql, true, "${tbName1}") - }, errorMessage) - - - //Test the unique model by modify a value type from DECIMAL128 to SMALLINT - errorMessage = "errCode = 2, detailMessage = Can not change DECIMAL128 to SMALLINT" - expectException({ - sql initTable - sql initTableData - sql """ alter table ${tbName1} MODIFY column score SMALLINT """ - insertSql = "insert into ${tbName1} values(993456689, 'Alice', 3, 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00', {'a': 100, 'b': 200}, [\"abc\", \"def\"]); " - waitForSchemaChangeDone({ - sql getTableStatusSql - time 60 - }, insertSql, true, "${tbName1}") - }, errorMessage) - - //Test the unique model by modify a value type from DECIMAL128 to INT - errorMessage = "errCode = 2, detailMessage = Can not change DECIMAL128 to INT" - expectException({ - sql initTable - sql initTableData - - sql """ alter table ${tbName1} MODIFY column score INT """ - insertSql = "insert into ${tbName1} values(993456689, 'Alice', 4, 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00', {'a': 100, 'b': 200}, [\"abc\", \"def\"]); " - waitForSchemaChangeDone({ - sql getTableStatusSql - time 60 - }, insertSql, true, "${tbName1}") - }, errorMessage) - - - //Test the unique model by modify a value type from DECIMAL128 to BIGINT - errorMessage = "errCode = 2, detailMessage = Can not change DECIMAL128 to BIGINT" - expectException({ - sql initTable - sql initTableData - sql """ alter table ${tbName1} MODIFY column score BIGINT """ - insertSql = "insert into ${tbName1} values(993456689, 'Alice', 545645, 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00', {'a': 100, 'b': 200}, [\"abc\", \"def\"]); " - waitForSchemaChangeDone({ - sql getTableStatusSql - time 60 - }, insertSql, true, "${tbName1}") - }, errorMessage) - - //Test the unique model by modify a value type from DECIMAL128 to LARGEINT - errorMessage = "errCode = 2, detailMessage = Can not change DECIMAL128 to LARGEINT" - expectException({ - sql initTable - sql initTableData - sql """ alter table ${tbName1} MODIFY column score LARGEINT """ - insertSql = "insert into ${tbName1} values(993456689, 'Alice', 156546, 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00', {'a': 100, 'b': 200}, [\"abc\", \"def\"]); " - waitForSchemaChangeDone({ - sql getTableStatusSql - time 60 - }, insertSql, true, "${tbName1}") - }, errorMessage) - - - //Test the unique model by modify a value type from DECIMAL128 to FLOAT - errorMessage = "errCode = 2, detailMessage = Can not change DECIMAL128 to FLOAT" - expectException({ - sql initTable - sql initTableData - sql """ alter table ${tbName1} MODIFY column score FLOAT """ - insertSql = "insert into ${tbName1} values(993456689, 'Alice', 1.23, 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00', {'a': 100, 'b': 200}, '[\"abc\", \"def\"]'); " - waitForSchemaChangeDone({ - sql getTableStatusSql - time 60 - }, insertSql, true, "${tbName1}") - }, errorMessage) - - - //TODO Data accuracy loss Test the unique model by modify a value type from DECIMAL128 to DECIMAL - sql initTable - sql initTableData - sql """ alter table ${tbName1} MODIFY column score DECIMAL(38,0) """ - insertSql = "insert into ${tbName1} values(993456689, 'Alice', 1.23, 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00', {'a': 100, 'b': 200}, '[\"abc\", \"def\"]'); " - waitForSchemaChangeDone({ - sql getTableStatusSql - time 60 - }, insertSql, true, "${tbName1}") - - - - //TODO Test the unique model by modify a value type from DECIMAL128 to DATE - errorMessage = "errCode = 2, detailMessage = Can not change DECIMAL128 to DATEV2" - expectException({ - sql initTable - sql initTableData - sql """ alter table ${tbName1} MODIFY column score DATE """ - insertSql = "insert into ${tbName1} values(993456689, 'Alice', '2003-12-31', 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00', {'a': 100, 'b': 200}, '[\"abc\", \"def\"]'); " - waitForSchemaChangeDone({ - sql getTableStatusSql - time 60 - }, insertSql, true, "${tbName1}") - - }, errorMessage) - - //TODO Test the unique model by modify a value type from DECIMAL128 to DATE - errorMessage = "errCode = 2, detailMessage = Can not change DECIMAL128 to DATEV2" - expectException({ - sql initTable - sql initTableData - sql """ alter table ${tbName1} MODIFY column score DATEV2 """ - insertSql = "insert into ${tbName1} values(993456689, 'Alice', '2003-12-31', 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00', {'a': 100, 'b': 200}, '[\"abc\", \"def\"]'); " - waitForSchemaChangeDone({ - sql getTableStatusSql - time 60 - }, insertSql, true, "${tbName1}") - - }, errorMessage) - - - //TODO Test the unique model by modify a value type from DECIMAL128 to DATETIME - errorMessage = "errCode = 2, detailMessage = Can not change DECIMAL128 to DATETIMEV2" - expectException({ - sql initTable - sql initTableData - sql """ alter table ${tbName1} MODIFY column score DATETIME """ - insertSql = "insert into ${tbName1} values(993456689, 'Alice', '2003-12-31 20:12:12', 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00', {'a': 100, 'b': 200}, '[\"abc\", \"def\"]'); " - waitForSchemaChangeDone({ - sql getTableStatusSql - time 60 - }, insertSql, true, "${tbName1}") - - }, errorMessage) - - //TODO Test the unique model by modify a value type from DECIMAL128 to DATETIME - errorMessage = "errCode = 2, detailMessage = Can not change DECIMAL128 to DATETIMEV2" - expectException({ - sql initTable - sql initTableData - sql """ alter table ${tbName1} MODIFY column score DATETIMEV2 """ - insertSql = "insert into ${tbName1} values(993456689, 'Alice', '2003-12-31 20:12:12', 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00', {'a': 100, 'b': 200}, '[\"abc\", \"def\"]'); " - waitForSchemaChangeDone({ - sql getTableStatusSql - time 60 - }, insertSql, true, "${tbName1}") - - }, errorMessage) - - //TODO Test the unique model by modify a value type from DECIMAL128 to CHAR - errorMessage = "errCode = 2, detailMessage = Can not change DECIMAL128 to CHAR" - expectException({ - sql initTable - sql initTableData - sql """ alter table ${tbName1} MODIFY column score CHAR(15) """ - insertSql = "insert into ${tbName1} values(993456689, 'Alice', 'asd', 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00', {'a': 100, 'b': 200}, '[\"abc\", \"def\"]'); " - waitForSchemaChangeDone({ - sql getTableStatusSql - time 60 - }, insertSql, true, "${tbName1}") - }, errorMessage) - - //Test Data accuracy loss the unique model by modify a value type from DECIMAL128 to VARCHAR - sql initTable - sql initTableData - sql """ alter table ${tbName1} MODIFY column score VARCHAR(100) """ - insertSql = "insert into ${tbName1} values(993456689, 'Alice', 'asd', 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00', {'a': 100, 'b': 200}, '[\"abc\", \"def\"]'); " - waitForSchemaChangeDone({ - sql getTableStatusSql - time 60 - }, insertSql, false, "${tbName1}") - - sql """ DROP TABLE IF EXISTS ${tbName2} """ - initTable2 = " CREATE TABLE IF NOT EXISTS ${tbName2}\n" + - " (\n" + - " `user_id` LARGEINT NOT NULL COMMENT \"用户id\",\n" + - " `username` VARCHAR(50) NOT NULL COMMENT \"用户昵称\",\n" + - " `score` VARCHAR(100) COMMENT \"分数\",\n" + - " `city` VARCHAR(20) COMMENT \"用户所在城市\",\n" + - " `age` SMALLINT COMMENT \"用户年龄\",\n" + - " `sex` TINYINT COMMENT \"用户性别\",\n" + - " `phone` LARGEINT COMMENT \"用户电话\",\n" + - " `address` VARCHAR(500) COMMENT \"用户地址\",\n" + - " `register_time` DATETIME COMMENT \"用户注册时间\",\n" + - " `m` Map<STRING, INT> NULL COMMENT \"\",\n" + - " `j` JSON NULL COMMENT \"\"\n" + - " )\n" + - " DUPLICATE KEY(`user_id`, `username`)\n" + - " DISTRIBUTED BY HASH(`user_id`) BUCKETS 1\n" + - " PROPERTIES (\n" + - " \"replication_allocation\" = \"tag.location.default: 1\"\n" + - " );" - - initTableData2 = "insert into ${tbName2} values(123456789, 'Alice', 1.83, 'Beijing', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00', {'a': 100, 'b': 200}, '[\"abc\", \"def\"]')," + - " (234567890, 'Bob', 1.89, 'Shanghai', 30, 1, 13998765432, 'No. 456 Street, Shanghai', '2022-02-02 12:00:00', {'a': 200, 'b': 200}, '[\"abc\", \"def\"]')," + - " (345678901, 'Carol', 2.6689, 'Guangzhou', 28, 0, 13724681357, 'No. 789 Street, Guangzhou', '2022-03-03 14:00:00', {'a': 300, 'b': 200}, '[\"abc\", \"def\"]')," + - " (456789012, 'Dave', 3.9456, 'Shenzhen', 35, 1, 13680864279, 'No. 987 Street, Shenzhen', '2022-04-04 16:00:00', {'a': 400, 'b': 200}, '[\"abc\", \"def\"]')," + - " (567890123, 'Eve', 4.223, 'Chengdu', 27, 0, 13572468091, 'No. 654 Street, Chengdu', '2022-05-05 18:00:00', {'a': 500, 'b': 200}, '[\"abc\", \"def\"]')," + - " (678901234, 'Frank', 2.5454, 'Hangzhou', 32, 1, 13467985213, 'No. 321 Street, Hangzhou', '2022-06-06 20:00:00', {'a': 600, 'b': 200}, '[\"abc\", \"def\"]')," + - " (993456689, 'Alice', 'asd', 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00', {'a': 100, 'b': 200}, '[\\\"abc\\\", \\\"def\\\"]')," + - " (789012345, 'Grace', 2.19656, 'Xian', 29, 0, 13333333333, 'No. 222 Street, Xian', '2022-07-07 22:00:00', {'a': 700, 'b': 200}, '[\"abc\", \"def\"]');" - - sql initTable2 - sql initTableData2 - sql """ DROP TABLE IF EXISTS ${tbName1} """ - - - //TODO Data accuracy loss Test the unique model by modify a value type from DECIMAL128 to STRING - sql initTable - sql initTableData - sql """ alter table ${tbName1} MODIFY column score STRING """ - insertSql = "insert into ${tbName1} values(993456689, 'Alice', 'asd', 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00', {'a': 100, 'b': 200}, '[\"abc\", \"def\"]'); " - waitForSchemaChangeDone({ - sql getTableStatusSql - time 60 - }, insertSql, false, "${tbName1}") - - - sql """ DROP TABLE IF EXISTS ${tbName2} """ - initTable2 = " CREATE TABLE IF NOT EXISTS ${tbName2}\n" + - " (\n" + - " `user_id` LARGEINT NOT NULL COMMENT \"用户id\",\n" + - " `username` VARCHAR(50) NOT NULL COMMENT \"用户昵称\",\n" + - " `score` STRING COMMENT \"分数\",\n" + - " `city` VARCHAR(20) COMMENT \"用户所在城市\",\n" + - " `age` SMALLINT COMMENT \"用户年龄\",\n" + - " `sex` TINYINT COMMENT \"用户性别\",\n" + - " `phone` LARGEINT COMMENT \"用户电话\",\n" + - " `address` VARCHAR(500) COMMENT \"用户地址\",\n" + - " `register_time` DATETIME COMMENT \"用户注册时间\",\n" + - " `m` Map<STRING, INT> NULL COMMENT \"\",\n" + - " `j` JSON NULL COMMENT \"\"\n" + - " )\n" + - " DUPLICATE KEY(`user_id`, `username`)\n" + - " DISTRIBUTED BY HASH(`user_id`) BUCKETS 1\n" + - " PROPERTIES (\n" + - " \"replication_allocation\" = \"tag.location.default: 1\"\n" + - " );" - - initTableData2 = "insert into ${tbName2} values(123456789, 'Alice', 1.83, 'Beijing', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00', {'a': 100, 'b': 200}, '[\"abc\", \"def\"]')," + - " (234567890, 'Bob', 1.89, 'Shanghai', 30, 1, 13998765432, 'No. 456 Street, Shanghai', '2022-02-02 12:00:00', {'a': 200, 'b': 200}, '[\"abc\", \"def\"]')," + - " (345678901, 'Carol', 2.6689, 'Guangzhou', 28, 0, 13724681357, 'No. 789 Street, Guangzhou', '2022-03-03 14:00:00', {'a': 300, 'b': 200}, '[\"abc\", \"def\"]')," + - " (456789012, 'Dave', 3.9456, 'Shenzhen', 35, 1, 13680864279, 'No. 987 Street, Shenzhen', '2022-04-04 16:00:00', {'a': 400, 'b': 200}, '[\"abc\", \"def\"]')," + - " (567890123, 'Eve', 4.223, 'Chengdu', 27, 0, 13572468091, 'No. 654 Street, Chengdu', '2022-05-05 18:00:00', {'a': 500, 'b': 200}, '[\"abc\", \"def\"]')," + - " (678901234, 'Frank', 2.5454, 'Hangzhou', 32, 1, 13467985213, 'No. 321 Street, Hangzhou', '2022-06-06 20:00:00', {'a': 600, 'b': 200}, '[\"abc\", \"def\"]')," + - " (993456689, 'Alice', 'asd', 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00', {'a': 100, 'b': 200}, '[\\\"abc\\\", \\\"def\\\"]')," + - " (789012345, 'Grace', 2.19656, 'Xian', 29, 0, 13333333333, 'No. 222 Street, Xian', '2022-07-07 22:00:00', {'a': 700, 'b': 200}, '[\"abc\", \"def\"]');" - - sql initTable2 - sql initTableData2 - sql """ DROP TABLE IF EXISTS ${tbName1} """ - - - //TODO Test the unique model by modify a value type from DECIMAL128 to map - //Test the unique model by modify a value type from DECIMAL128 to STRING - errorMessage = "errCode = 2, detailMessage = Can not change DECIMAL128 to MAP" - expectException({ - sql initTable - sql initTableData - sql """ alter table ${tbName1} MODIFY column score Map<STRING, INT> """ - insertSql = "insert into ${tbName1} values(993456689, 'Alice', {'a': 100, 'b': 200}, 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00', {'a': 100, 'b': 200}, '[\"abc\", \"def\"]'); " - waitForSchemaChangeDone({ - sql getTableStatusSql - time 60 - }, insertSql, true, "${tbName1}") - }, errorMessage) - - - //Test the unique model by modify a value type from DECIMAL128 to JSON - errorMessage = "errCode = 2, detailMessage = Can not change DECIMAL128 to JSON" - expectException({ - sql initTable - sql initTableData - sql """ alter table ${tbName1} MODIFY column score JSON """ - insertSql = "insert into ${tbName1} values(993456689, 'Alice', '{'a': 100, 'b': 200}', 'Yaan', 25, 0, 13812345678, 'No. 123 Street, Beijing', '2022-01-01 10:00:00', {'a': 100, 'b': 200}, '[\"abc\", \"def\"]'); " - waitForSchemaChangeDone({ - sql getTableStatusSql - time 60 - }, insertSql, true, "${tbName1}") - }, errorMessage) - - - /** * Test the unique model by modify a value type from DATE to other type */ @@ -3370,4 +2369,4 @@ suite("test_dup_schema_value_modify1", "p0") { -} +} \ No newline at end of file diff --git a/regression-test/suites/unique_with_mow_p0/partial_update/test_partial_update_2pc_schema_change.groovy b/regression-test/suites/unique_with_mow_p0/partial_update/test_partial_update_2pc_schema_change.groovy index 9b323dec19c..364fc26db42 100644 --- a/regression-test/suites/unique_with_mow_p0/partial_update/test_partial_update_2pc_schema_change.groovy +++ b/regression-test/suites/unique_with_mow_p0/partial_update/test_partial_update_2pc_schema_change.groovy @@ -42,7 +42,9 @@ suite("test_partial_update_2pc_schema_change", "p0") { for (def use_row_store : [false, true]) { logger.info("current params: use_row_store: ${use_row_store}") - connect( context.config.jdbcUser, context.config.jdbcPassword, context.config.jdbcUrl) { + def user=context.config.jdbcUser + def password = context.config.jdbcPassword + connect(user, password, context.config.jdbcUrl) { sql "use ${db};" def tableName = "test_partial_update_2pc_schema_change" --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org For additional commands, e-mail: commits-h...@doris.apache.org