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

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

数据湖探索 DLI

写数据至一个Sink表

语法格式

    
           INSERT INTO your_sink
  SELECT ... FROM your_source WHERE ...

示例

本例定义了两个表my_source 和my_sink，并使用INSERT INTO语句source表选择数据并插入到sink表。

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

--使用jdbc connector创建目标表my_sink
CREATE TABLE my_sink (
  name VARCHAR,
  age BIGINT
) WITH (
  'connector' = 'jdbc',
  'url' = 'jdbc:mysql://xxx/your-database',
  'table-name' = 'your-table',
  'username' = 'your-username',
  'password' = 'your-password'
);

--使用INSERT INTO语句从my_source表选择数据，并插入到my_sink表
INSERT INTO my_sink
SELECT name, age
FROM my_source;

         

       

     
    