数据湖探索 DLI-INSERT INTO:写数据至多个Sink表

时间：2024-11-16 13:21:45

数据湖探索 DLI

写数据至多个Sink表

EXECUTE STATEMENT SET BEGIN ... END; 是写数据至多个Sink表的必填语句，用于定义在同一个作业中执行多个插入数据的操作。

写数据至多个Sink表时，EXECUTE STATEMENT SET BEGIN ... END;是必填项。

语法格式

    
         EXECUTE STATEMENT SET BEGIN
  -- 第一个DML语句
  INSERT INTO your_sink1
  SELECT ... FROM your_source WHERE ...;

  -- 第二个DML语句
  INSERT INTO your_sink2
  SELECT ... FROM your_source WHERE ...

...
END;

示例

本例定义了源表datagen_source、Sink表print_sinkA和print_sinkB。然后使用EXECUTE STATEMENT执行两个INSERT INTO语句，分将转换后的数据写入两个不同的sink。

     
      
        
        
          --使用 datagen connector创建源表 datagen_source
CREATE TABLE datagen_source (
  name VARCHAR,
  age BIGINT
) WITH (
  'connector' = 'datagen'
);

--使用print connector创建结果表 print_sinkA 和 print_sinkB 

CREATE TABLE print_sinkA(
  name VARCHAR,
  age BIGINT
) WITH (
  'connector' = 'print' 
);

CREATE TABLE print_sinkB(
  name VARCHAR,
  age BIGINT
) WITH (
  'connector' = 'print' 
);

--使用 EXECUTE STATEMENT SET BEGIN来执行两个 INSERT INTO 语句。
--第一个INSERT INTO语句将datagen_source表中的数据按需转换后写入 print_sinkA。
--第二个 INSERT INTO 语句将数据按需转换后写入 print_sinkB。。
EXECUTE  STATEMENT SET BEGIN
INSERT INTO print_sinkA 
  SELECT UPPER(name), min(age) 
  FROM datagen_source 
  GROUP BY UPPER(name);
INSERT INTO print_sinkB 
  SELECT LOWER(name), max(age) 
  FROM datagen_source 
  GROUP BY LOWER(name);
END;

         

       

     
    