This is an automated email from the ASF dual-hosted git repository.
dataroaring 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 3820657e286 [fix](regression-test) Fix some schema change case not
pick to 2.1 sufficiently (#44921)
3820657e286 is described below
commit 3820657e286bcc1a4501a0661c4e36ab633e7894
Author: Siyang Tang <[email protected]>
AuthorDate: Wed Dec 4 14:26:41 2024 +0800
[fix](regression-test) Fix some schema change case not pick to 2.1
sufficiently (#44921)
pick: #37390 (partly)
---
.../test_dup_schema_value_modify1.out | 63 ++
.../test_dup_schema_key_change_modify.groovy | 114 +--
.../test_dup_schema_value_modify1.groovy | 1001 ++++++++++++++++++++
3 files changed, 1121 insertions(+), 57 deletions(-)
diff --git
a/regression-test/data/schema_change_p0/test_dup_schema_value_modify1.out
b/regression-test/data/schema_change_p0/test_dup_schema_value_modify1.out
new file mode 100644
index 00000000000..9b419d15f94
--- /dev/null
+++ b/regression-test/data/schema_change_p0/test_dup_schema_value_modify1.out
@@ -0,0 +1,63 @@
+-- This file is automatically generated. You should know what you did if you
want to edit this
+-- ! --
+123456789 Alice 1.8 Beijing 25 0 13812345678 No. 123
Street, Beijing 2022-01-01T10:00 {"a":100, "b":200} ["abc","def"]
+123456789 Alice 1.8 Beijing 25 0 13812345678 No. 123
Street, Beijing 2022-01-01T10:00 {"a":100, "b":200} ["abc","def"]
+123456789 Alice 1.8 Beijing 25 0 13812345678 No. 123
Street, Beijing 2022-01-01T10:00 {"a":100, "b":200} ["abc","def"]
+123456789 Alice 1.8 Beijing 25 0 13812345678 No. 123
Street, Beijing 2022-01-01T10:00 {"a":100, "b":200} ["abc","def"]
+123456789 Alice 1.8 Beijing 25 0 13812345678 No. 123
Street, Beijing 2022-01-01T10:00 {"a":100, "b":200} ["abc","def"]
+123456789 Alice 1.8 Beijing 25 0 13812345678 No. 123
Street, Beijing 2022-01-01T10:00 {"a":100, "b":200} ["abc","def"]
+123456789 Alice 1.8 Beijing 25 0 13812345678 No. 123
Street, Beijing 2022-01-01T10:00 {"a":100, "b":200} ["abc","def"]
+234567890 Bob 1.89 Shanghai 30 1 13998765432
No. 456 Street, Shanghai 2022-02-02T12:00 {"a":200, "b":200}
["abc","def"]
+234567890 Bob 1.89 Shanghai 30 1 13998765432
No. 456 Street, Shanghai 2022-02-02T12:00 {"a":200, "b":200}
["abc","def"]
+234567890 Bob 1.89 Shanghai 30 1 13998765432
No. 456 Street, Shanghai 2022-02-02T12:00 {"a":200, "b":200}
["abc","def"]
+234567890 Bob 1.89 Shanghai 30 1 13998765432
No. 456 Street, Shanghai 2022-02-02T12:00 {"a":200, "b":200}
["abc","def"]
+234567890 Bob 1.89 Shanghai 30 1 13998765432
No. 456 Street, Shanghai 2022-02-02T12:00 {"a":200, "b":200}
["abc","def"]
+234567890 Bob 1.89 Shanghai 30 1 13998765432
No. 456 Street, Shanghai 2022-02-02T12:00 {"a":200, "b":200}
["abc","def"]
+234567890 Bob 1.89 Shanghai 30 1 13998765432
No. 456 Street, Shanghai 2022-02-02T12:00 {"a":200, "b":200}
["abc","def"]
+345678901 Carol 2.6 Guangzhou 28 0 13724681357
No. 789 Street, Guangzhou 2022-03-03T14:00 {"a":300, "b":200}
["abc","def"]
+345678901 Carol 2.6 Guangzhou 28 0 13724681357
No. 789 Street, Guangzhou 2022-03-03T14:00 {"a":300, "b":200}
["abc","def"]
+345678901 Carol 2.6 Guangzhou 28 0 13724681357
No. 789 Street, Guangzhou 2022-03-03T14:00 {"a":300, "b":200}
["abc","def"]
+345678901 Carol 2.6 Guangzhou 28 0 13724681357
No. 789 Street, Guangzhou 2022-03-03T14:00 {"a":300, "b":200}
["abc","def"]
+345678901 Carol 2.6 Guangzhou 28 0 13724681357
No. 789 Street, Guangzhou 2022-03-03T14:00 {"a":300, "b":200}
["abc","def"]
+345678901 Carol 2.6 Guangzhou 28 0 13724681357
No. 789 Street, Guangzhou 2022-03-03T14:00 {"a":300, "b":200}
["abc","def"]
+345678901 Carol 2.6 Guangzhou 28 0 13724681357
No. 789 Street, Guangzhou 2022-03-03T14:00 {"a":300, "b":200}
["abc","def"]
+456789012 Dave 3.9 Shenzhen 35 1 13680864279
No. 987 Street, Shenzhen 2022-04-04T16:00 {"a":400, "b":200}
["abc","def"]
+456789012 Dave 3.9 Shenzhen 35 1 13680864279
No. 987 Street, Shenzhen 2022-04-04T16:00 {"a":400, "b":200}
["abc","def"]
+456789012 Dave 3.9 Shenzhen 35 1 13680864279
No. 987 Street, Shenzhen 2022-04-04T16:00 {"a":400, "b":200}
["abc","def"]
+456789012 Dave 3.9 Shenzhen 35 1 13680864279
No. 987 Street, Shenzhen 2022-04-04T16:00 {"a":400, "b":200}
["abc","def"]
+456789012 Dave 3.9 Shenzhen 35 1 13680864279
No. 987 Street, Shenzhen 2022-04-04T16:00 {"a":400, "b":200}
["abc","def"]
+456789012 Dave 3.9 Shenzhen 35 1 13680864279
No. 987 Street, Shenzhen 2022-04-04T16:00 {"a":400, "b":200}
["abc","def"]
+456789012 Dave 3.9 Shenzhen 35 1 13680864279
No. 987 Street, Shenzhen 2022-04-04T16:00 {"a":400, "b":200}
["abc","def"]
+567890123 Eve 4.2 Chengdu 27 0 13572468091 No. 654
Street, Chengdu 2022-05-05T18:00 {"a":500, "b":200} ["abc","def"]
+567890123 Eve 4.2 Chengdu 27 0 13572468091 No. 654
Street, Chengdu 2022-05-05T18:00 {"a":500, "b":200} ["abc","def"]
+567890123 Eve 4.2 Chengdu 27 0 13572468091 No. 654
Street, Chengdu 2022-05-05T18:00 {"a":500, "b":200} ["abc","def"]
+567890123 Eve 4.2 Chengdu 27 0 13572468091 No. 654
Street, Chengdu 2022-05-05T18:00 {"a":500, "b":200} ["abc","def"]
+567890123 Eve 4.2 Chengdu 27 0 13572468091 No. 654
Street, Chengdu 2022-05-05T18:00 {"a":500, "b":200} ["abc","def"]
+567890123 Eve 4.2 Chengdu 27 0 13572468091 No. 654
Street, Chengdu 2022-05-05T18:00 {"a":500, "b":200} ["abc","def"]
+567890123 Eve 4.2 Chengdu 27 0 13572468091 No. 654
Street, Chengdu 2022-05-05T18:00 {"a":500, "b":200} ["abc","def"]
+678901234 Frank 2.5 Hangzhou 32 1 13467985213
No. 321 Street, Hangzhou 2022-06-06T20:00 {"a":600, "b":200}
["abc","def"]
+678901234 Frank 2.5 Hangzhou 32 1 13467985213
No. 321 Street, Hangzhou 2022-06-06T20:00 {"a":600, "b":200}
["abc","def"]
+678901234 Frank 2.5 Hangzhou 32 1 13467985213
No. 321 Street, Hangzhou 2022-06-06T20:00 {"a":600, "b":200}
["abc","def"]
+678901234 Frank 2.5 Hangzhou 32 1 13467985213
No. 321 Street, Hangzhou 2022-06-06T20:00 {"a":600, "b":200}
["abc","def"]
+678901234 Frank 2.5 Hangzhou 32 1 13467985213
No. 321 Street, Hangzhou 2022-06-06T20:00 {"a":600, "b":200}
["abc","def"]
+678901234 Frank 2.5 Hangzhou 32 1 13467985213
No. 321 Street, Hangzhou 2022-06-06T20:00 {"a":600, "b":200}
["abc","def"]
+678901234 Frank 2.5 Hangzhou 32 1 13467985213
No. 321 Street, Hangzhou 2022-06-06T20:00 {"a":600, "b":200}
["abc","def"]
+789012345 Grace 2.1 Xian 29 0 13333333333 No. 222
Street, Xian 2022-07-07T22:00 {"a":700, "b":200} ["abc","def"]
+789012345 Grace 2.1 Xian 29 0 13333333333 No. 222
Street, Xian 2022-07-07T22:00 {"a":700, "b":200} ["abc","def"]
+789012345 Grace 2.1 Xian 29 0 13333333333 No. 222
Street, Xian 2022-07-07T22:00 {"a":700, "b":200} ["abc","def"]
+789012345 Grace 2.1 Xian 29 0 13333333333 No. 222
Street, Xian 2022-07-07T22:00 {"a":700, "b":200} ["abc","def"]
+789012345 Grace 2.1 Xian 29 0 13333333333 No. 222
Street, Xian 2022-07-07T22:00 {"a":700, "b":200} ["abc","def"]
+789012345 Grace 2.1 Xian 29 0 13333333333 No. 222
Street, Xian 2022-07-07T22:00 {"a":700, "b":200} ["abc","def"]
+789012345 Grace 2.1 Xian 29 0 13333333333 No. 222
Street, Xian 2022-07-07T22:00 {"a":700, "b":200} ["abc","def"]
+993456689 Alice asd Yaan 25 0 13812345678 No. 123
Street, Beijing 2022-01-01T10:00 {"a":100, "b":200} ["abc","def"]
+
+-- ! --
+123456789 Alice 2 Beijing 25 0 13812345678 No. 123
Street, Beijing 2022-01-01T10:00 {"a":100, "b":200} ["abc","def"]
+234567890 Bob 2 Shanghai 30 1 13998765432
No. 456 Street, Shanghai 2022-02-02T12:00 {"a":200, "b":200}
["abc","def"]
+345678901 Carol 3 Guangzhou 28 0 13724681357
No. 789 Street, Guangzhou 2022-03-03T14:00 {"a":300, "b":200}
["abc","def"]
+456789012 Dave 4 Shenzhen 35 1 13680864279
No. 987 Street, Shenzhen 2022-04-04T16:00 {"a":400, "b":200}
["abc","def"]
+567890123 Eve 4 Chengdu 27 0 13572468091 No. 654
Street, Chengdu 2022-05-05T18:00 {"a":500, "b":200} ["abc","def"]
+678901234 Frank 3 Hangzhou 32 1 13467985213
No. 321 Street, Hangzhou 2022-06-06T20:00 {"a":600, "b":200}
["abc","def"]
+789012345 Grace 2 Xian 29 0 13333333333 No. 222
Street, Xian 2022-07-07T22:00 {"a":700, "b":200} ["abc","def"]
+993456689 Alice 1 Yaan 25 0 13812345678 No. 123
Street, Beijing 2022-01-01T10:00 {"a":100, "b":200} ["abc","def"]
+
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 7ed37a9ca39..7a46111e6fc 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
@@ -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 600
+ time 60
}, 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 600
+ time 60
}, 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 600
+ time 60
}, 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 600
+ time 60
}, 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 600
+ time 60
}, 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 600
+ time 60
}, 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 600
+ time 60
}, 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 600
+ time 60
}, 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 600
+ time 60
}, 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 600
+ time 60
}, 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 600
+ time 60
}, 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 600
+ time 60
}, 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 600
+ time 60
}, 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 600
+ time 60
}, 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 600
+ time 60
}, 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 600
+ time 60
}, 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 600
+ time 60
}, 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 600
+ time 60
}, 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 600
+ time 60
}, 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 600
+ time 60
}, 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 600
+ time 60
}, 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 600
+ time 60
}, 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 600
+ time 60
}, 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 600
+ time 60
}, 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 600
+ time 60
}, 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 600
+ time 60
}, 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 600
+ time 60
}, 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 600
+ time 60
}, 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 600
+ time 60
}, 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 600
+ time 60
}, 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 600
+ time 60
}, 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 600
+ time 60
}, 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 600
+ time 60
}, 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 600
+ time 60
}, 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 600
+ time 60
}, 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 600
+ time 60
}, 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 600
+ time 60
}, 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 600
+ time 60
}, 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 600
+ time 60
}, 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 600
+ time 60
}, 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 600
+ time 60
}, 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 600
+ time 60
}, 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 600
+ time 60
}, 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 600
+ time 60
}, 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 600
+ time 60
}, 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 600
+ time 60
}, 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 600
+ time 60
}, 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 600
+ time 60
}, 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 600
+ time 60
}, 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 600
+ time 60
}, 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 600
+ time 60
}, 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 600
+ time 60
}, 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 600
+ time 60
}, 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 600
+ time 60
}, insertSql, true, "${tbName1}")
}, errorMessage)
@@ -1103,7 +1103,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 600
+ time 60
}, insertSql, true, "${tbName1}")
}, errorMessage)
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 90dc5c030d8..b60bbe489e1 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,6 +1058,1007 @@ 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
*/
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
