云原生大数据计算服务 MaxCompute：Schema操作

show schemas;

create schema <schema_name>；

desc schema <schema_name>；

drop schema <schema_name>；

• 跨Project操作Table，则命令格式需要写完整（project.schema.table）。
• 同一个Project下跨Schema的命令格式可以写成schema.table，即命令中如果写成a.b格式，则a解析为Schema，b解析为Table，Project为当前Proejct。
• 同一个Project下可以使用use schema <schema_name>命令指定当前Schema，命令中可直接使用类似select * from a的命令，此时a是Table，自动解析到当前的Project和指定的Schema。
• 如果无上下文指定Schema，命令中使用类型select * from a的命令，此时a是Table，自动解析到当前Project和名称为default 的Schema。

• 同一个Project（projectA）下操作Schema内对象。
  • 操作default这个Schema内的对象。

    use projectA;
    set odps.namespace.schema=true;--租户级别如果已经设置，此处就不用再指定
    --操作table t_a
    create table t_a(c1 string,c2 bigint);
    insert into/overwrite table t_a values ('a',1),('b',2),('c',3);
    select * from t_a;
    show tables;
    desc t_a;
    
    tunnel upload <path> t_a[/<pt_spc>];
    tunnel download t_a[/pt_spc] <path>;
    
    --操作resource res_a.jar
    add jar <path>/res_a.jar ;
    desc resource res_a.jar;
    list resources;
    get resource res_a.jar D:\;
    drop resource res_a.jar;
    
    --操作function fun_a
     create function fun_a as 'xx' using 'res_a.jar';
     desc function fun_a;
     list functions;
     drop function fun_a;

    path：文件的存放路径以及文件名称。pt_spc：需要指定至最末级分区，格式为：pt_spcpartition_col1=col1_value1, partition_col2=col2_value1...pt_spc。
  • 操作自定义Schema（s_1和s_2）下的对象，包括跨Schema操作。

    use projectA;
    set odps.namespace.schema=true;--租户级别已经设置，此处就不用再指定
    
    --操作s_1下的table t_c
    use schema s_1;
    create table t_c(c1 string,c2 bigint);
    insert into/overwrite table t_c values ('a',1),('b',2),('c',3);
    select * from t_c;
    show tables;
    drop table t_c;
    
    
    tunnel upload <path> t_c[/<pt_spc>];
    tunnel download t_c[/pt_spc] <path>;
    
    --操作s_2下的table t_d
    creata table s_2.t_d(c1 string,c2 bigint);
    insert into/overwrite table s_2.t_d values ('a',1),('b',2),('c',3);
    select * from s_2.t_d;
    show tables in s_2;
    drop table s_2.t_d;
    
    tunnel upload <path> s_2.t_d[/<pt_spc>];
    tunnel download s_2.t_d[/pt_spc] <path>;
    
    
    --操作s_1下的resource res_b.jar
    use schema s_1;
    add jar <path>/res_b.jar  ;
    desc resource res_b.jar;
    list resources;
    get resource res_b.jar D:\;
    drop resource res_b.jar;
    
    --操作s_2下的resource res_c.jar
    add jar xxx ;--add resource只能在当前schema/project下操作不能跨schema/project，所以正常操作还是需要切换到schema s_2
    --跨项目或跨Schema时，resource的层级使用英文冒号（:）分隔
    desc resource s_2:res_c.jar;
    list resources in s_2;
    get resource s_2:res_c.jar D:\;
    drop resource s_2:res_c.jar;
    
    --操作s_1下的function fun_b
     use schema s_1;
     create function fun_b as 'xx' using 'res_b.jar'
     desc function fun_b;
     list functions;
     drop function fun_b;
    
     --操作s_2下的function fun_c
     create function s_2.fun_c as 'xx' using 's_2/resources/res_c.jar'
     drop function s_2.fun_c;
     desc function s_2.fun_c;
     list functions in s_2;
     drop function s_2.fun_c;

• 跨Project操作（在ProjectA下操作ProjectB的对象）。

  use projectA;
  set odps.namespace.schema=true;  --租户级别如果已经设置，此处不用再指定
  
  --操作projectB下的s_3的table t_f
  create table projectB.s_3.t_f(c1 string,c2 bigint);
  insert into/overwrite table projectB.s_3.t_f values ('a',1),('b',2),('c',3);
  select * from projectB.s_3.t_f;
  show tables in projectB.s_3;
  desc projectB.s_3.t_f;
  drop table projectB.s_3.t_f;
  
  tunnel upload <path> projectB.s_3.t_f[/<pt_spc>];
  tunnel download projectB.s_3.t_f[/pt_spc] <path>;
  
  --操作projectB下的s_3的resource res_f.jar
  add jar xxx ;--add resource只能在当前schema/project下操作不能跨schema/project，所以正常操作还是需要切换到projectB并使用schema s_3
  --跨项目跨Schema时，resource的层级使用英文冒号（:）分隔
  desc resource projectB:s_3:res_f.jar;
  list resources in projectB.s_3;
  get resource projectB:s_3:res_f.jar D:\;
  drop resource projectB:s_3:res_f.jar;
  
  --操作projectB下s_3的function fun_f
   create function projectB.s_3.fun_f as 'xx' using 'projectB/schemas/s_3/resources/res_f.jar'
   desc function projectB.s_3.fun_f;
   list functions in projectB.s_3;
   drop function projectB.s_3.fun_f;