@@ -27,97 +27,92 @@ suite("docs/table-design/schema-change.md") {
27
27
28
28
multi_sql " create database if not exists example_db; use example_db; drop table if exists my_table;"
29
29
sql """
30
- CREATE TABLE IF NOT EXISTS example_db.my_table(
31
- col1 int,
32
- col2 int,
33
- col3 int,
34
- col4 int,
35
- col5 int
36
- ) DUPLICATE KEY(col1, col2, col3)
37
- DISTRIBUTED BY RANDOM BUCKETS 1
38
- ROLLUP (
39
- example_rollup_index (col1, col3, col4, col5)
40
- )
41
- PROPERTIES (
42
- "replication_num" = "1"
43
- )
30
+ CREATE TABLE IF NOT EXISTS example_db.my_table(
31
+ col1 int,
32
+ col2 int,
33
+ col3 int,
34
+ col4 int,
35
+ col5 int
36
+ ) DUPLICATE KEY(col1, col2, col3)
37
+ DISTRIBUTED BY RANDOM BUCKETS 10
44
38
"""
45
39
sql """
46
- ALTER TABLE example_db.my_table
47
- ADD COLUMN new_key_col INT KEY DEFAULT "0" AFTER col1
48
- TO example_rollup_index
40
+ ALTER TABLE example_db.my_table ADD COLUMN key_col INT KEY DEFAULT "0" AFTER col1;
49
41
"""
50
42
waitUntilSchemaChangeDone(" my_table" )
51
43
sql """
52
- ALTER TABLE example_db.my_table
53
- ADD COLUMN new_val_col INT DEFAULT "0" AFTER col4
54
- TO example_rollup_index
44
+ ALTER TABLE example_db.my_table ADD COLUMN value_col INT DEFAULT "0" AFTER col4;
55
45
"""
56
46
waitUntilSchemaChangeDone(" my_table" )
57
47
58
48
sql " drop table if exists example_db.my_table"
59
49
sql """
60
- CREATE TABLE IF NOT EXISTS example_db.my_table(
61
- col1 int,
62
- col2 int,
63
- col3 int,
64
- col4 int SUM,
65
- col5 int MAX
66
- ) AGGREGATE KEY(col1, col2, col3)
67
- DISTRIBUTED BY HASH(col1) BUCKETS 1
68
- ROLLUP (
69
- example_rollup_index (col1, col3, col4, col5)
70
- )
71
- PROPERTIES (
72
- "replication_num" = "1"
73
- )
50
+ CREATE TABLE IF NOT EXISTS example_db.my_table(
51
+ col1 int,
52
+ col2 int,
53
+ col3 int,
54
+ col4 int SUM,
55
+ col5 varchar(32) REPLACE DEFAULT "abc"
56
+ ) AGGREGATE KEY(col1, col2, col3)
57
+ DISTRIBUTED BY HASH(col1) BUCKETS 10
74
58
"""
75
59
sql """
76
- ALTER TABLE example_db.my_table
77
- ADD COLUMN new_key_col INT DEFAULT "0" AFTER col1
78
- TO example_rollup_index
60
+ ALTER TABLE example_db.my_table ADD COLUMN key_col INT DEFAULT "0" AFTER col1;
79
61
"""
80
62
waitUntilSchemaChangeDone(" my_table" )
81
63
sql """
82
- ALTER TABLE example_db.my_table
83
- ADD COLUMN new_val_col INT SUM DEFAULT "0" AFTER col4
84
- TO example_rollup_index
64
+ ALTER TABLE example_db.my_table ADD COLUMN value_col INT SUM DEFAULT "0" AFTER col4;
85
65
"""
86
66
waitUntilSchemaChangeDone(" my_table" )
87
67
68
+ sql " drop table if exists example_db.my_table"
88
69
sql """
89
- ALTER TABLE example_db.my_table
90
- ADD COLUMN (c1 INT DEFAULT "1", c2 FLOAT SUM DEFAULT "0")
91
- TO example_rollup_index
70
+ CREATE TABLE IF NOT EXISTS example_db.my_table(
71
+ col1 int,
72
+ col2 int,
73
+ col3 int,
74
+ col4 int SUM,
75
+ col5 varchar(32) REPLACE DEFAULT "abc"
76
+ ) AGGREGATE KEY(col1, col2, col3)
77
+ DISTRIBUTED BY HASH(col1) BUCKETS 10
78
+ """
79
+ sql """
80
+ ALTER TABLE example_db.my_table ADD COLUMN (c1 INT DEFAULT "1", c2 FLOAT SUM DEFAULT "0");
92
81
"""
93
82
waitUntilSchemaChangeDone(" my_table" )
94
83
84
+ sql " drop table if exists example_db.my_table"
95
85
sql """
96
- ALTER TABLE example_db.my_table
97
- DROP COLUMN col3
98
- FROM example_rollup_index
86
+ CREATE TABLE IF NOT EXISTS example_db.my_table(
87
+ col1 int,
88
+ col2 int,
89
+ col3 int,
90
+ col4 int SUM,
91
+ col5 varchar(32) REPLACE DEFAULT "abc"
92
+ ) AGGREGATE KEY(col1, col2, col3)
93
+ DISTRIBUTED BY HASH(col1) BUCKETS 10
99
94
"""
100
- waitUntilSchemaChangeDone(" my_table" )
101
95
96
+ sql """
97
+ ALTER TABLE example_db.my_table DROP COLUMN col4;
98
+ """
99
+ waitUntilSchemaChangeDone(" my_table" )
102
100
103
101
sql " drop table if exists example_db.my_table"
104
102
sql """
105
- CREATE TABLE IF NOT EXISTS example_db.my_table(
106
- col0 int,
107
- col1 int DEFAULT "1",
108
- col2 int,
109
- col3 varchar(32),
110
- col4 int SUM,
111
- col5 varchar(32) REPLACE DEFAULT "abc"
112
- ) AGGREGATE KEY(col0, col1, col2, col3)
113
- DISTRIBUTED BY HASH(col0) BUCKETS 1
114
- PROPERTIES (
115
- "replication_num" = "1"
116
- )
103
+ CREATE TABLE IF NOT EXISTS example_db.my_table(
104
+ col0 int,
105
+ col1 int DEFAULT "1",
106
+ col2 int,
107
+ col3 varchar(32),
108
+ col4 int SUM,
109
+ col5 varchar(32) REPLACE DEFAULT "abc"
110
+ ) AGGREGATE KEY(col0, col1, col2, col3)
111
+ DISTRIBUTED BY HASH(col0) BUCKETS 10
117
112
"""
118
113
sql """
119
- ALTER TABLE example_db.my_table
120
- MODIFY COLUMN col1 BIGINT KEY DEFAULT "1" AFTER col2
114
+ ALTER TABLE example_db.my_table
115
+ MODIFY COLUMN col1 BIGINT KEY DEFAULT "1" AFTER col2;
121
116
"""
122
117
waitUntilSchemaChangeDone(" my_table" )
123
118
sql """
@@ -141,18 +136,10 @@ suite("docs/table-design/schema-change.md") {
141
136
v1 int SUM,
142
137
v2 int MAX,
143
138
) AGGREGATE KEY(k1, k2, k3, k4)
144
- DISTRIBUTED BY HASH(k1) BUCKETS 1
145
- ROLLUP (
146
- example_rollup_index(k1, k2, k3, v1, v2)
147
- )
148
- PROPERTIES (
149
- "replication_num" = "1"
150
- )
139
+ DISTRIBUTED BY HASH(k1) BUCKETS 10;
151
140
"""
152
141
sql """
153
- ALTER TABLE example_db.my_table
154
- ORDER BY (k3,k1,k2,v2,v1)
155
- FROM example_rollup_index
142
+ ALTER TABLE example_db.my_table ORDER BY (k3,k1,k2,k4,v2,v1)
156
143
"""
157
144
waitUntilSchemaChangeDone(" my_table" )
158
145
0 commit comments