使用ALTER TABLE命令可以对表进行修改,包括partition 、rollup、schema change、rename和index五种。语法:
ALTER TABLE [database.]tablealter_clause1[, alter_clause2, ...];alter_clause 分为 partition 、rollup、schema change、rename 和 index 五种。rename
将名为 table1的表修改为table2:
ALTER TABLE table1 RENAME table2;将表example_table中名为rollup1的rollup index修改为rollup2:
ALTER TABLE example_table RENAME ROLLUP rollup1 rollup2;将表example_table中名为p1的partition修改为p2:
ALTER TABLE example_table RENAME PARTITION p1 p2;partition
增加分区, 使用默认分桶方式,如现有分区[MIN, 2013-01-01),增加分区[2013-01-01, 2014-01-01):
ALTER TABLE example_db.my_table ADD PARTITION p1 VALUES LESS THAN ("2014-01-01");增加分区,使用新的分桶数:
ALTER TABLE example_db.my_table ADD PARTITION p1 VALUES LESS THAN ("2015-01-01") DISTRIBUTED BY HASH(k1) BUCKETS 20;增加分区,使用新的副本数:
ALTER TABLE example_db.my_table ADD PARTITION p1 VALUES LESS THAN ("2015-01-01") ("replication_num"="1");修改分区副本数:
ALTER TABLE example_db.my_table MODIFY PARTITION p1 SET("replication_num"="1");批量修改指定分区:
ALTER TABLE example_db.my_table MODIFY PARTITION (p1, p2, p4) SET("in_memory"="true");批量修改所有分区:
ALTER TABLE example_db.my_table MODIFY PARTITION (*) SET("storage_medium"="HDD");删除分区:
ALTER TABLE example_db.my_table DROP PARTITION p1;增加一个指定上下界的分区:
ALTER TABLE example_db.my_table ADD PARTITION p1 VALUES [("2014-01-01"), ("2014-02-01"));rollup
创建index: example_rollup_index,基于base index(k1,k2,k3,v1,v2),列式存储:
ALTER TABLE example_db.my_tableADD ROLLUP example_rollup_index(k1, k3, v1, v2);创建index: example_rollup_index2,基于example_rollup_index(k1,k3,v1,v2):
ALTER TABLE example_db.my_table ADD ROLLUP example_rollup_index2 (k1, v1) FROM example_rollup_index;创建index: example_rollup_index3, 基于base index (k1,k2,k3,v1), 自定义rollup超时时间一小时:
ALTER TABLE example_db.my_table ADD ROLLUP example_rollup_index(k1, k3, v1) PROPERTIES("timeout" = "3600");删除index: example_rollup_index2:
ALTER TABLE example_db.my_table DROP ROLLUP example_rollup_index2;表结构变更
使用ALTER TABLE命令可以修改表的Schema,包括:增加列、删除列、修改列类型、改变列顺序。以增加列为例:
我们新增一列uv,类型为BIGINT,聚合类型为SUM,默认值为0:
ALTER TABLE table1 ADD COLUMN uv BIGINT SUM DEFAULT '0' after pv;提交成功后,可以通过以下命令查看作业进度:
SHOW ALTER TABLE COLUMN;当作业状态为FINISHED,则表示作业完成,新的Schema已生效。
查看新的Schema:
DESC table1;可以使用以下命令取消当前正在执行的作业:
CANCEL ALTER TABLE ROLLUP FROM table1;更多可以参阅:HELP ALTER TABLE。
删除数据
Doris目前可以通过两种方式删除数据:DELETE FROM语句和ALTER TABLE DROP PARTITION 语句。
条件删除(drop from)
delete from语句类似标准delete语法,具体使用可以查看help delete;帮助。
语法:
DELETE FROM table_name [PARTITION partition_name]WHEREcolumn_name1 op { value | value_list } [ AND column_name2 op { value| value_list } ...];如:
delete from student_kafka where id=1;注意事项: