MaxCompute：Schema操作

• 跨Project操作Table時，命令格式需要寫完整（project.schema.table）。

• 同一個Project下跨Schema的命令格式可以寫成schema.table，即命令中如果寫成a.b格式，則a解析為Schema，b解析為Table，Project為當前Project。

• 同一個Project下可以使用use schema <schema_name>命令指定當前Schema，命令中可直接使用類似select * from a的命令，此時a是Table，自動解析到當前的Project和指定的Schema。

• 如果無上下文指定Schema，命令中使用類型select * from a的命令，此時a是Table，自動解析到當前Project和名稱為default 的Schema。

使用樣本

• 樣本1：在同一個Project（projectA）下操作Schema內對象。

  • 操作default這個Schema內的對象。

    use projectA;
    set odps.namespace.schema=true;--租戶層級如果已經設定，此處就不用再指定
    --操作table t_a
    create table t_a(c1 string,c2 bigint);
    INSERT 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 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
    create 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;

• 樣本2：跨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 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;