数据仓库服务 GAUSSDB(DWS)-通过DLI Flink作业将MySQL数据实时同步到GaussDB(DWS):步骤一：准备MySQL数据

时间：2024-09-14 17:38:48

步骤一：准备MySQL数据

购买RDS实例，参见表1配置关键参数，其他参数可保持默认，如需了解详情请参见RDS文档。

表1 RDS参数
参数项	取值
计费模式	按需计费
区域	华北-北京四
实例名称	rds-demo
数据库引擎	MySQL
数据库版本	5.7及以上
数据库端口	3306

连接RDS实例，执行以下命令，创建名为mys_data数据库。
1

CREATE DATABASE mys_data;

切换到新的数据库mys_data，并执行以下命令，创建表mys_orders。

    
         CREATE TABLE mys_data.mys_order
     ( order_id      VARCHAR(12),
       order_channel VARCHAR(32),
       order_time    DATETIME,
       cust_code     VARCHAR(6),
       pay_amount    DOUBLE,
       real_pay      DOUBLE,
       PRIMARY KEY (order_id) );

执行以下命令向表中插入数据。

    
         INSERT INTO mys_data.mys_order VALUES ('202306270001', 'webShop', TIMESTAMP('2023-06-27 10:00:00'), 'CUST1', 1000, 1000);
INSERT INTO mys_data.mys_order VALUES ('202306270002', 'webShop', TIMESTAMP('2023-06-27 11:00:00'), 'CUST2', 5000, 5000);