阅读920 返回首页    go 阿里云


创建删除表__快速开始_大数据计算服务-阿里云

当用户被添加到项目空间并被赋予建表等权限后,就可以操作MaxCompute了。由于在MaxCompute中的操作对象(输入、输出)都是表,所以在处理数据之前,我们首先要创建表、分区。

创建表

语法格式:

  1. CREATE TABLE [IF NOT EXISTS] table_name
  2. [(col_name data_type [COMMENT col_comment], ...)]
  3. [COMMENT table_comment]
  4. [PARTITIONED BY (col_name data_type [COMMENT col_comment], ...)]
  5. [LIFECYCLE days]
  6. [AS select_statement]
  7. CREATE TABLE [IF NOT EXISTS] table_name
  8. LIKE existing_table_name

说明:

  • 表名与列名均对大小写不敏感。
  • 在创建表时,如果不指定if not exists选项而存在同名表,则返回出错;若指定此选项,则无论是否存在同名表,即使原表结构与要创建的目标表结构不一致,均返回成功。已存在的同名表的元信息不会被改动。
  • 数据类型只能是:bigint,double,boolean,datetime及string。
  • 表名,列名中不能有特殊字符,只能用英文的a-z,A-Z及数字和下划线_,且以字母开头,名称的长度不超过128字节。
  • Partitioned by 指定表的分区字段,目前仅支持string类型,其他类型行为未定义。分区值不可以有双字节字符(如中文),必须是以英文字母a-z,A-Z开始后可跟字母数字,名称的长度不超过128字节。 允许的字符包括:空格 ‘ ‘,冒号’:’,下划线’_’,美元符’$’,井号’#’,点’.’,感叹号’!’和’@’,出现其他字符行为未定义。例如:”t”,”n”,”/”等。当利用分区字段对表进行分区时,新增分区、更新分区内数据和读取分区数据均不需要做全表扫描,可以提高处理效率。
  • 注释内容是长度不超过1024字节的有效字符串。
  • lifecycle指明此表的生命周期,单位:天。create table like语句不会复制源表的生命周期属性。
  • 目前,在表中建的分区层次不能超过6级。一个表允许的分区个数支持按照具体的project配置,默认60,000个。

注意:

创建表示例:

  1. create table test1 (key string); -- 创建非分区表,表名test1,字段名key,数据类型string。
  2. create table test2 (key bigint) partitioned by (pt string, ds string); --创建分区表
  3. create table test3 (key boolean) partitioned by (pt string, ds string) lifecycle 100; -- 创建带有生命周期的表
  4. create table test4 like test3; -- 除生命周期属性外,test3的其他属性(字段类型,分区类型等)均与test4完全一致
  5. create table test5 as select * from test2;
  6. -- 这个操作会创建test5,但分区,生命周期信息不会被拷贝到目标表中。
  7. -- 此操作仅会将test2的数据复制到test5中(如果test2有数据的话,此示例中test2为空表,后续章节会介绍数据导入)。

这里我们介绍一个创建表的场景:假设需要创建一张用户表user,包括如下信息:

  • user_id bigint类型,用户标识,唯一标识一个用户
  • gender bigint 类型,性别 (0,未知;1,男;2,女)
  • age bigint, 用户年龄

按照region(区域)和dt(日期)进行分区,生命周期为365天。建表语句如下:

  1. CREATE TABLE user (
  2. user_id BIGINT, gender BIGINT COMMENT '0 unknow,1 male, 2 Female', age BIGINT)
  3. PARTITIONED BY (region string, dt string) LIFECYCLE 365;

获取表信息

当创建表成功之后,我们可以通过如下命令获取表的信息:

  1. desc <table_name>;

例如,获取上述示例中表test3信息:

  1. desc test3;

结果显示如下:

  1. odps@ $odps_project>desc test3;
  2. +------------------------------------------------------------------------------------+
  3. | Owner: ALIYUN$maojing.mj@alibaba-inc.com | Project: $odps_project
  4. | TableComment: |
  5. +------------------------------------------------------------------------------------+
  6. | CreateTime: 2015-09-18 12:26:57 |
  7. | LastDDLTime: 2015-09-18 12:26:57 |
  8. | LastModifiedTime: 2015-09-18 12:26:57 |
  9. | Lifecycle: 100 |
  10. +------------------------------------------------------------------------------------+
  11. | InternalTable: YES | Size: 0 |
  12. +------------------------------------------------------------------------------------+
  13. | Native Columns: |
  14. +------------------------------------------------------------------------------------+
  15. | Field | Type | Label | Comment |
  16. +------------------------------------------------------------------------------------+
  17. | key | boolean | | |
  18. +------------------------------------------------------------------------------------+
  19. | Partition Columns: |
  20. +------------------------------------------------------------------------------------+
  21. | pt | string | |
  22. | ds | string | |
  23. +------------------------------------------------------------------------------------+

获取test4信息:

  1. desc test4;

显示结果如下:

  1. odps@ $odps_project>desc test4;
  2. +------------------------------------------------------------------------------------+
  3. | Owner: ALIYUN$maojing.mj@alibaba-inc.com | Project: $odps_project
  4. | TableComment: |
  5. +------------------------------------------------------------------------------------+
  6. | CreateTime: 2015-09-18 12:27:09 |
  7. | LastDDLTime: 2015-09-18 12:27:09 |
  8. | LastModifiedTime: 2015-09-18 12:27:09 |
  9. +------------------------------------------------------------------------------------+
  10. | InternalTable: YES | Size: 0 |
  11. +------------------------------------------------------------------------------------+
  12. | Native Columns: |
  13. +------------------------------------------------------------------------------------+
  14. | Field | Type | Label | Comment |
  15. +------------------------------------------------------------------------------------+
  16. | key | boolean | | |
  17. +------------------------------------------------------------------------------------+
  18. | Partition Columns: |
  19. +------------------------------------------------------------------------------------+
  20. | pt | string | |
  21. | ds | string | |
  22. +------------------------------------------------------------------------------------+

您会发现,除生命周期属性外,test3的其他属性(字段类型,分区类型等)均与test4完全一致。获取表信息的更多介绍请参考 Describe Table 。您如果查看test2的表信息,pt,ds两个字段仅会作为普通列存在,而不是表的分区。

删除表

  1. DROP TABLE [IF EXISTS] table_name;

示例,删除test2表:

  1. drop table test2;

更多介绍请参考 删除表(DROP TABLE)

创建分区

当创建一张分区表之后,为了往该表里面导入不同分区数据,我们需要创建分区。命令如下:

  1. alter table table_name add [if not exists] partition partition_spec
  2. partition_spec:
  3. : (partition_col1 = partition_col_value1, partition_col2 = partiton_col_value2, ...)

比如上面的例子,给用户表user添加区域为hangzhou,日期为20150923的分区,句子显示如下:

  1. Alter table user add if not exists partition(region='hangzhou',dt='20150923');

删除分区

命令如下:

  1. alter table table_name drop [if exists] partition_spec;
  2. partition_spec:
  3. : (partition_col1 = partition_col_value1, partition_col2 = partiton_col_value2, ...)

比如删除区域为hangzhou,日期为20150923的分区,语句如下:

  1. Alter table user drop if exists partition(region='hangzhou',dt='20150923');

最后更新:2016-05-11 11:01:36

  上一篇:go 角色创建及授权__快速开始_大数据计算服务-阿里云
  下一篇:go 导入导出数据__快速开始_大数据计算服务-阿里云