MaxCompute支持对已有表的分区和列执行变更操作,如添加分区、添加列、删除列、更改列数据类型等,您可以根据实际业务场景执行相应操作。
MaxCompute SQL的分区和列操作命令如下。
类型 |
操作 |
功能 |
角色 |
操作入口 |
分区操作 |
为已存在的分区表新增分区。 |
具备修改表权限(Alter)的用户 |
本文中的命令您可以在如下工具平台执行: |
|
为已存在的分区表删除分区。 |
||||
修改分区表中分区的
|
||||
修改分区表的分区值。 |
||||
对分区表的分区进行合并,即同一个分区表下的多个分区合并成一个分区,同时删除被合并的分区维度的信息,把数据移动到指定分区。 |
||||
清空指定分区的数据。 |
||||
列操作 |
为已存在的非分区表或分区表添加列或注释。 |
|||
删除已存在的非分区表或分区表的列。 |
||||
更改已存在列的数据类型。 |
||||
调整表中指定列的顺序。 |
||||
为已存在的非分区表或分区表修改列名称。 |
||||
为已存在的非分区表或分区表修改列注释。 |
||||
为已存在的非分区表或分区表同时修改列名称和列注释。 |
||||
修改非分区列的非空属性。 |
目前Transaction Table2.0处于邀测阶段,默认不支持直接使用,如果本文示例中涉及到Transaction Table2.0功能,您可以点击 申请开通 ,在新功能试用申请页面申请开通使用Transaction Table2.0功能后,再运行相关命令。详情请参见 Transaction Table2.0概述 。
使用限制
-
目前支持TINYINT、 SMALLINT、INT、BIGINT、CHAR、VARCHAR和STRING数据类型的字段设为分区列。
-
单表分区层级最多6级。
-
单表分区数最多允许60000个分区。
-
一次最多查询分区数为10000个。
-
使用表结构变更(Schema Evolution)限制:
表结构变更包括对现有表新增复杂数据类型列、删除列、修改列顺序和修改列的数据类型。在下列场景中,如果执行了更改表的列顺序、添加新列并修改列顺序或删除列这三种操作,会使表的读写行为发生变化:
-
作业类型是MapReduce 1.0时,Graph任务无法读写修改的表。
-
CUPID作业只有Spark以下版本可以读表,但是不可以写表:
-
Spark-2.3.0-odps0.34.0
-
Spark-3.1.1-odps0.34.0
-
-
PAI作业可以读表,但不可以写表。
-
Hologres作业在1.3版本之前,Hologres引用修改的表作为外部表时,无法读写该表。
-
表做过表结构变更操作后,不支持CLONE TABLE。
-
Streaming Tunnel在写入表时,不可以修改表结构,否则会发生错误。
-
-
Transaction类型的分区表不支持merge partition操作。
-
Transaction Table2.0类型的非分区表不支持清空操作、不支持更改表的 write.bucket.num 属性。
添加分区
为已存在的分区表新增分区。
-
限制条件
-
MaxCompute单表支持的分区数量上限为6万个。
-
对于有多级分区的表,如果需要添加新的分区值,必须指明全部的分区。
-
仅支持新增分区值,不支持新增分区字段。
-
-
命令格式
alter table <table_name> add [if not exists] partition <pt_spec> [partition <pt_spec> partition <pt_spec>...];
-
参数说明
-
table_name :必填。待新增分区的分区表名称。
-
if not exists :可选。如果未指定 if not exists 而同名的分区已存在,会执行失败并返回报错。
-
pt_spec :必填。新增的分区,格式为
(partition_col1 = partition_col_value1, partition_col2 = partition_col_value2, ...)
。 partition_col 是分区字段, partition_col_value 是分区值。分区字段不区分大小写,分区值区分大小写。
-
-
使用示例
-
示例1:给表sale_detail添加一个分区,用来存储2013年12月杭州地区的销售记录。
alter table sale_detail add if not exists partition (sale_date='201312', region='hangzhou');
-
示例2:给表sale_detail同时添加两个分区,用来存储2013年12月北京和上海地区的销售记录。
alter table sale_detail add if not exists partition (sale_date='201312', region='beijing') partition (sale_date='201312', region='shanghai');
-
示例3:给表sale_detail添加分区,仅指定一个分区字段sale_date,返回报错,需要同时指定2个分区字段sale_date和region。
alter table sale_detail add if not exists partition (sale_date='20111011');
-
示例4:增加Transaction Table2.0表分区
--创建transation2.0表 create table mf_tt (pk bigint not null primary key, val bigint not null) partitioned by (dd string, hh string) tblproperties ("transactional"="true"); --添加分区 alter table mf_tt add partition (dd='01', hh='01');
-
示例5:修改Transaction Table2.0表属性
--更新bucket数据,目前只支持分区表,不支持非分区表 alter table mf_tt3 set tblproperties("write.bucket.num"="64"); --更新retain属性 alter table mf_tt3 set tblproperties("acid.data.retain.hours"="60");
-
删除分区
为已存在的分区表删除分区。
MaxCompute支持通过条件筛选方式删除分区。如果您希望一次性删除符合某个规则条件的多个分区,可以使用表达式指定筛选条件,通过筛选条件匹配分区并批量删除分区。
-
限制条件
-
每个分区过滤子句只能访问一个分区列。
-
表达式用到的函数必须是内建的Scalar函数。
-
-
注意事项
-
删除分区之后,MaxCompute项目的存储量会降低。
-
您可以结合MaxCompute提供的生命周期功能,实现自动回收旧分区的能力。更多生命周期信息,请参见 生命周期 。
-
-
命令格式
-
未指定筛选条件
--一次删除一个分区。 alter table <table_name> drop [if exists] partition <pt_spec>; --一次删除多个分区。 alter table <table_name> drop [if exists] partition <pt_spec>,partition <pt_spec>[,partition <pt_spec>....];
-
指定筛选条件
alter table <table_name> drop [if exists] partition <partition_filtercondition>;
-
-
参数说明
-
table_name :必填。待删除分区的分区表名称。
-
if exists :可选。如果未指定 if exists 且分区不存在,则返回报错。
-
pt_spec :必填。删除的分区。格式为
(partition_col1 = partition_col_value1, partition_col2 = partition_col_value2, ...)
。 partition_col 是分区字段, partition_col_value 是分区值。分区字段不区分大小写,分区值区分大小写。 -
partition_filtercondition :指定筛选条件时必填。分区筛选条件,不区分大小写。格式为:
partition_filtercondition : partition (<partition_col> <relational_operators> <partition_col_value>) | partition (scalar(<partition_col>) <relational_operators> <partition_col_value>) | partition (<partition_filtercondition1> AND|OR <partition_filtercondition2>) | partition (NOT <partition_filtercondition>) | partition (<partition_filtercondition1>)[,partition (<partition_filtercondition2>), ...]
-
partition_col :分区名称。
-
relational_operators :关系运算符,详情请参见 运算符 。
-
partition_col_value :分区列比较值或正则表达式,与分区列数据类型保持一致。
-
scalar() :Scalar函数。Scalar函数基于输入值生成对应的标量,对分区列的值( partition_col )进行处理后再按照指定的关系运算符 relational_operators 与 partition_col_value 做比较。
-
分区过滤条件支持逻辑运算符NOT、AND和OR。支持通过NOT过滤条件子句,取过滤规则的补集。支持多个过滤条件子句以AND或OR的关系组成整体分区匹配规则。
-
支持多个分区过滤子句,当多个分区过滤子句以英文逗号(,)分隔时,每个过滤子句的逻辑以OR的关系组成整体分区匹配规则。
-
-
-
使用示例
-
未指定筛选条件
--从表sale_detail中删除一个分区,2013年12月杭州分区的销售记录。 alter table sale_detail drop if exists partition(sale_date='201312',region='hangzhou'); --从表sale_detail中同时删除两个分区,2013年12月杭州和上海分区的销售记录。 alter table sale_detail drop if exists partition(sale_date='201312',region='hangzhou'),partition(sale_date='201312',region='shanghai');
-
指定筛选条件
--创建分区表。 create table if not exists sale_detail( shop_name STRING, customer_id STRING, total_price DOUBLE) partitioned by (sale_date STRING); --添加分区。 alter table sale_detail add if not exists partition (sale_date= '201910') partition (sale_date= '201911') partition (sale_date= '201912') partition (sale_date= '202001') partition (sale_date= '202002') partition (sale_date= '202003') partition (sale_date= '202004') partition (sale_date= '202005') partition (sale_date= '202006') partition (sale_date= '202007'); --批量删除分区。 alter table sale_detail drop if exists partition(sale_date < '201911'); alter table sale_detail drop if exists partition(sale_date >= '202007'); alter table sale_detail drop if exists partition(sale_date LIKE '20191%'); alter table sale_detail drop if exists partition(sale_date IN ('202002','202004','202006')); alter table sale_detail drop if exists partition(sale_date BETWEEN '202001' AND '202007'); alter table sale_detail drop if exists partition(substr(sale_date, 1, 4) = '2020'); alter table sale_detail drop if exists partition(sale_date < '201912' OR sale_date >= '202006'); alter table sale_detail drop if exists partition(sale_date > '201912' AND sale_date <= '202004'); alter table sale_detail drop if exists partition(NOT sale_date > '202004'); --支持多个分区过滤表达式,表达式之间是OR的关系。 alter table sale_detail drop if exists partition(sale_date < '201911'), partition(sale_date >= '202007'); --添加其他格式分区。 alter table sale_detail add IF NOT EXISTS partition (sale_date= '2019-10-05') partition (sale_date= '2019-10-06') partition (sale_date= '2019-10-07'); --批量删除分区,使用正则表达式匹配分区。 alter table sale_detail drop if exists partition(sale_date RLIKE '2019-\\d+-\\d+'); --创建多级分区表。 create table if not exists region_sale_detail( shop_name STRING, customer_id STRING, total_price DOUBLE) partitioned by (sale_date STRING , region STRING ); --添加分区。 alter table region_sale_detail add IF NOT EXISTS partition (sale_date= '201910',region = 'shanghai') partition (sale_date= '201911',region = 'shanghai') partition (sale_date= '201912',region = 'shanghai') partition (sale_date= '202001',region = 'shanghai') partition (sale_date= '202002',region = 'shanghai') partition (sale_date= '201910',region = 'beijing') partition (sale_date= '201911',region = 'beijing') partition (sale_date= '201912',region = 'beijing') partition (sale_date= '202001',region = 'beijing') partition (sale_date= '202002',region = 'beijing'); --执行如下语句批量删除多级分区,两个匹配条件是或的关系,会将sale_date小于201911或region等于beijing的分区都删除掉。 alter table region_sale_detail drop if exists partition(sale_date < '201911'),partition(region = 'beijing'); --如果删除sale_date小于201911且region等于beijing的分区,可以使用如下方法。 alter table region_sale_detail drop if exists partition(sale_date < '201911', region = 'beijing');
批量删除多级分区时,在一个
partition
过滤子句中,不能根据多个分区列编写组合条件匹配分区,如下语句会报错FAILED: ODPS-0130071:[1,82] Semantic analysis exception - invalid column reference region, partition expression must have one and only one column reference
。--分区过滤子句只能访问一个分区列,如下语句报错。 alter table region_sale_detail drop if exists partition(sale_date < '201911' AND region = 'beijing');
-
修改分区的更新时间
MaxCompute SQL提供
touch
操作,用于修改分区表中分区的
LastModifiedTime
。此操作会将
LastModifiedTime
修改为当前时间。此时,MaxCompute会认为数据有变动,重新计算生命周期。
-
使用限制
对于有多级分区的表,必须指明全部的分区。
-
命令格式
alter table <table_name> touch partition (<pt_spec>);
-
参数说明
-
table_name :必填。待修改分区更新时间的分区表名称。如果表不存在,则返回报错。
-
pt_spec :必填。需要修改更新时间的分区信息。格式为
(partition_col1 = partition_col_value1, partition_col2 = partition_col_value2, ...)
。 partition_col 是分区字段, partition_col_value 是分区值。如果指定的分区字段或分区值不存在,则返回报错。
-
-
使用示例
--修改表sale_detail的分区sale_date='201312', region='shanghai'的LastModifiedTime。 alter table sale_detail touch partition (sale_date='201312', region='shanghai');
修改分区值
MaxCompute SQL支持通过
rename
操作更改分区表的分区值。
-
使用限制
-
不支持修改分区列的列名,只能修改分区列对应的值。
-
对于有多级分区的表,必须指明全部的分区。
-
-
命令格式
alter table <table_name> partition (<pt_spec>) rename to partition (<new_pt_spec>);
-
参数说明
-
table_name :必填。待修改分区值的表名称。
-
pt_spec :必填。需要修改分区值的分区信息。格式为
(partition_col1 = partition_col_value1, partition_col2 = partition_col_value2, ...)
。 partition_col 是分区字段, partition_col_value 是分区值。如果指定的分区字段或分区值不存在,则返回报错。 -
new_pt_spec :必填。修改后的分区信息。格式为
(partition_col1 = new_partition_col_value1, partition_col2 = new_partition_col_value2, ...)
。 partition_col 是分区字段, new_partition_col_value 是新分区值。
-
-
使用示例
--修改表sale_detail的分区值。 alter table sale_detail partition (sale_date = '201312', region = 'hangzhou') rename to partition (sale_date = '201310', region = 'beijing');
合并分区
MaxCompute SQL提供
merge partition
对分区表的分区进行合并,即将同一个分区表下的多个分区合并成一个分区,同时删除被合并的分区维度的信息,把数据移动到指定分区。
-
使用限制
-
不支持外部表,聚簇表合并后的分区会消除聚簇属性。
-
一次性合并分区数量限制为4000个。
-
-
命令格式
alter table <table_name> merge [if exists] partition (<predicate>) [, partition(<predicate2>) ...] overwrite partition (<fullpartitionSpec>) [purge];
-
参数说明
-
table_name :必填。待合并分区的分区表名称。
-
if exists :可选。如果未指定 if exists ,且分区不存在,会执行失败并返回报错。如果指定 if exists 后不存在满足
merge
条件的分区,则不生成新分区。如果运行过程中出现源数据被并发修改(包括insert
、rename
或drop
)时,即使指定 if exists 也会报错。 -
predicate :必填。筛选待合并分区需要满足的条件。
-
fullpartitionSpec :必填。目标分区信息。
-
purge :可选关键字。选择该字段,则会清理session目录,默认清理3天内的日志。详情请参见 Purge 。
-
-
使用示例
-
示例1:合并满足指定条件的分区到目标分区。
--查看分区表的分区。 show partitions intpstringstringstring; ds=20181101/hh=00/mm=00 ds=20181101/hh=00/mm=10 ds=20181101/hh=10/mm=00 ds=20181101/hh=10/mm=10 --合并所有满足hh='00'的分区到hh='00',mm='00'中。 alter table intpstringstringstring merge partition(hh='00') overwrite partition(ds='20181101', hh='00', mm='00'); --查看合并后的分区。 show partitions intpstringstringstring; ds=20181101/hh=00/mm=00 ds=20181101/hh=10/mm=00 ds=20181101/hh=10/mm=10
-
示例2:合并指定的多个分区到目标分区。
--合并多个指定分区。 alter table intpstringstringstring merge if exists partition(ds='20181101', hh='00', mm='00'), partition(ds='20181101', hh='10', mm='00'), partition(ds='20181101', hh='10', mm='10') overwrite partition(ds='20181101', hh='00', mm='00') purge; --查看分区表的分区。 show partitions intpstringstringstring; ds=20181101/hh=00/mm=00
-
清空分区数据
清空分区表中指定分区的数据。
MaxCompute支持通过条件筛选方式清空分区数据。如果您希望一次性删除符合某个规则条件的一个或多个分区,可以使用表达式指定筛选条件,通过筛选条件匹配分区并批量清空分区数据。
-
命令格式
-
未指定筛选条件
truncate table <table_name> partition <pt_spec>[, partition <pt_spec>....];
-
指定筛选条件
truncate table <table_name> partition <partition_filtercondition>;
-
-
参数说明
-
table_name :必填。待清空分区数据的分区表名称。
-
pt_spec :必填。待清空数据的分区。格式为
(partition_col1 = partition_col_value1, partition_col2 = partition_col_value2, ...)
。 partition_col 是分区字段, partition_col_value 是分区值。分区字段不区分大小写,分区值区分大小写。 -
partition_filtercondition :指定筛选条件时必填。分区筛选条件,不区分大小写。格式为:
partition_filtercondition : partition (<partition_col> <relational_operators> <partition_col_value>) | partition (scalar(<partition_col>) <relational_operators> <partition_col_value>) | partition (<partition_filtercondition1> AND|OR <partition_filtercondition2>) | partition (NOT <partition_filtercondition>) | partition (<partition_filtercondition1>)[,partition (<partition_filtercondition2>), ...]
-
partition_col :分区名称。
-
relational_operators :关系运算符,详情请参见 运算符 。
-
partition_col_value :分区列比较值或正则表达式,与分区列数据类型保持一致。
-
scalar() :Scalar函数。Scalar函数基于输入值生成对应的标量,对分区列的值( partition_col )进行处理后再按照指定的关系运算符 relational_operators 与 partition_col_value 做比较。
-
分区过滤条件支持逻辑运算符NOT、AND和OR。支持通过NOT过滤条件子句,取过滤规则的补集。支持多个过滤条件子句以AND或OR的关系组成整体分区匹配规则。
-
支持多个分区过滤子句,当多个分区过滤子句以英文逗号(,)分隔时,每个过滤子句的逻辑以OR的关系组成整体分区匹配规则。
-
-
-
使用示例
-
未指定筛选条件
--从表sale_detail中清空一个分区,清空2013年12月杭州地域的销售记录。 truncate table sale_detail partition(sale_date='201312',region='hangzhou'); --从表sale_detail中同时清空两个分区,清空2013年12月杭州和上海地域的销售记录。 truncate table sale_detail partition(sale_date='201312',region='hangzhou'), partition(sale_date='201312',region='shanghai');
-
指定筛选条件
--从表sale_detail中清空多个分区,清空杭州地域下sale_date以2013开头的销售记录。 truncate table sale_detail partition(sale_date like '2013%' and region='hangzhou');
-
清空Transaction Table2.0非分区表
--清空非分区表,表类型必须为非分区表, 否则报错 truncate table mf_tt2;
-
添加列或注释
为已存在的非分区表或分区表添加列或注释。
-
MaxCompute已支持添加STRUCT类型的列,例如
struct<x: string, y: bigint>
、map<string, struct<x: double, y: double>>
。如果需要开通此功能,请设置以下参数,同时请注意 使用限制 ,修改该参数需要等待10分钟后才会生效:setproject odps.schema.evolution.enable=true;
设置项目空间的Project级属性,需操作账号为项目的Owner或者账号被赋予了项目级别的Super_Administrator或Admin角色,操作详情请参见 为用户赋予内置管理角色 。
-
Transaction Table2.0不支持Schema Evolution功能,包括:删除列、更改列顺序、增加复杂数据类型列、更改列数据类型。
-
命令格式
alter table <table_name> add columns (<col_name1> <type1> comment ['<col_comment>'][, <col_name2> <type2> comment '<col_comment>'...]);
-
参数说明
-
table_name :必填。待新增列的表名称。添加的新列不支持指定顺序,默认在最后一列。
-
col_name :必填。新增列的名称。
-
type :必填。新增列的数据类型。
-
col_comment :可选。新增列的注释。
-
-
使用示例
-
示例1:给表sale_detail添加两个列。
alter table sale_detail add columns (customer_name STRING, education BIGINT);
-
示例2:给表sale_detail添加两个列并同时添加列注释。
alter table sale_detail add columns (customer_name STRING comment '客户', education BIGINT comment '教育' );
-
示例3:给表sale_detail添加一个复杂数据类型列。
alter table sale_detail add columns (region struct<province:string, area:string>);
-
示例4:增加Transaction Table2.0的列
alter table mf_tt add columns (val2 bigint);
-
删除列
为已存在的非分区表或分区表删除指定的单个或多个列。
如果需要开通此功能,请设置以下参数,同时请注意 使用限制 ,修改该参数需要等待10分钟后才会生效:
setproject odps.schema.evolution.enable=true;
设置项目空间的Project级属性,需操作账号为项目的Owner或者账号被赋予了项目级别的Super_Administrator或Admin角色,操作详情请参见 为用户赋予内置管理角色 。
-
命令格式
alter table <table_name> drop columns <col_name1>[, <col_name2>...];
-
参数说明
-
table_name :必填。待删除列的表名称。
-
col_name :必填。待删除的列名称。
-
-
示例:删除表的列
--删除表sale_detail的列customer_id。输入yes确认后,即可删除列。 alter table sale_detail drop columns customer_id; --删除表sale_detail的列shop_name和customer_id。输入yes确认后,即可删除列。 alter table sale_detail drop columns shop_name, customer_id;
更改列数据类型
为已存在的列更改数据类型。
如果需要开通此功能,请设置以下参数,同时请注意 使用限制 ,修改该参数需要等待10分钟后才会生效:
setproject odps.schema.evolution.enable=true;
设置项目空间的Project级属性,需操作账号为项目的Owner或者账号被赋予了项目级别的Super_Administrator或Admin角色,操作详情请参见 为用户赋予内置管理角色 。
-
命令格式。
alter table <table_name> change [column] <old_column_name> <new_column_name> <new_data_type>;
-
参数说明。
-
table_name :必填。待修改列数据类型的表名称。
-
old_column_name :必填。待修改列数据类型的列名称。
-
new_column_name :必填。修改列数据类型后的列名称。 old_column_name 可以与 new_column_name 保持一致,表示不修改列名称。但是 new_column_name 不能与除 old_column_name 之外的列名称相同。
-
new_data_type :必填。待修改的列修改后的数据类型。
-
-
使用示例。
--将mf_evol_t3表的id字段由int转化为bigint alter table mf_evol_t3 change id id bigint; --将mf_evol_t3表的id字段类型由bigint转化为string alter table mf_evol_t3 change column id id string;
-
数据类型支持转换表。
说明Y 表示支持转换; N 表示不支持转换; - 表示不涉及; Y() 表示满足括号内的条件支持转换。
修改列的顺序
为已存在的非分区表或分区表修改列顺序。
如果需要开通此功能,请设置以下参数,同时请注意 使用限制 ,修改该参数需要等待10分钟后才会生效:
setproject odps.schema.evolution.enable=true;
设置项目空间的Project级属性,需操作账号为项目的Owner或者账号被赋予了项目级别的Super_Administrator或Admin角色,操作详情请参见 为用户赋予内置管理角色 。
-
命令格式
alter table <table_name> change <old_column_name> <new_column_name> <column_type> after <column_name>;
-
参数说明
-
table_name :必填。待修改列顺序的表名称。
-
old_column_name :必填。待修改顺序的列的原始名称。
-
new_col_name :必填。修改后的列名称。 new_col_name 可以与 old_column_name 保持一致,表示不修改列名称。但 new_col_name 不能与除 old_column_name 的之外的列名称相同。
-
column_type :必填。待修改的列的原始数据类型。不可修改。
-
column_name :必填。将待调整顺序的列调整至 column_name 之后。
-
-
使用示例
--修改表sale_detail的列customer_id为customer并位于total_price之后。 alter table sale_detail change customer_id customer string after total_price; --修改表sale_detail的列customer_id位于total_price之后,不修改列名称。 alter table sale_detail change customer_id customer_id string after total_price;
修改列名
为已存在的非分区表或分区表修改列名称。
-
命令格式
alter table <table_name> change column <old_col_name> rename to <new_col_name>;
-
参数说明
-
table_name :必填。待修改列名的表名称。
-
old_col_name :必填。待修改的列名称。 old_col_name 必须是已存在的列。
-
new_col_name :必填。修改后的列名称。表中不能有名为 new_col_name 的列。
-
-
使用示例
--修改表sale_detail的列名customer_name为customer。 alter table sale_detail change column customer_name rename to customer;
修改列注释
为已存在的非分区表或分区表修改列注释。
-
语法格式
alter table <table_name> change column <col_name> comment '<col_comment>';
-
参数说明
-
table_name :必填。待修改列注释的表名称。
-
col_name :必填。待修改注释的列名称。 col_name 必须是已存在的列。
-
col_comment :必填。修改后的注释信息。注释内容为长度不超过1024字节的有效字符串,否则报错。
-
-
使用示例
--修改表sale_detail的列customer的注释。 alter table sale_detail change column customer comment 'customer';
修改列名及注释
修改非分区表或分区表的列名或注释。
-
命令格式
alter table <table_name> change column <old_col_name> <new_col_name> <column_type> comment '<col_comment>';
-
参数说明
-
table_name :必填。需要修改列名以及注释的表名称。
-
old_col_name :必填。需要修改的列名称。
old_col_name
必须是已存在的列。 -
new_col_name :必填。新的列名称。表中不能有名为
new_col_name
的列。 -
column_type :必填。列的数据类型。
-
col_comment :可选。修改后的注释信息。内容最长为1024字节。
-
-
使用示例
--修改表sale_detail的列名customer_name为customer_newname,注释“客户”为“customer”。 alter table sale_detail change column customer_name customer_newname STRING comment 'customer';
修改表的列非空属性
修改表的非分区列的非空属性。即如果表的非分区列值禁止为NULL,您可以通过本命令修改分区列值允许为NULL。
您可以通过
desc extended table_name;
命令查看
Nullable
属性值,判断列的非空属性。如果
Nullable
为
true
,表示允许为NULL;如果
Nullable
为
false
,表示禁止为NULL。
-
使用限制
修改分区列值允许为NULL后,不可回退,不支持再修改分区列值禁止为NULL,请谨慎操作。
-
命令格式
alter table <table_name> change column <old_col_name> null;
-
参数说明
-
table_name :必填。待修改列非空属性的表名称。
-
old_col_name :必填。待修改的非分区列的名称。 old_col_name 必须是已存在的非分区列。
-
-
使用示例
--创建一张分区表,id列禁止为NULL。 create table null_test(id int not null, name string) partitioned by (ds string); --修改id列允许为NULL。 alter table null_test change column id null;
相关文档
更多关于表操作的命令请参见 表操作 。