步骤五：启动实例并插入数据

步骤一：启动实时任务

1. 在Dataphin首页，单击顶部菜单栏的研发。

2. 按照下图操作指引，启动flink_dataphin实时任务。

   

3. 启动实时实例对话框，配置启动参数。

   参数	描述
   启动方式	选择无状态启动。
   指定来源表读取数据时点	选择当前日期及此刻时间。
   时间参数配置	选择当前日期。

4. 单击确定。

步骤二：插入数据

登录flink_dataphin数据源的MySQL实例，并使用以下命令写入数据以验证实时任务计算结果。

//创建生成产品类型的函数
CREATE FUNCTION getSkuId() RETURNS VARCHAR(20)
BEGIN
    DECLARE sku_id VARCHAR(20);
    SET sku_id = CASE FLOOR(RAND() * 3)
        WHEN 0 THEN '绿茶'
        WHEN 1 THEN '红茶'
        WHEN 2 THEN '花茶'
        ELSE '数据生成错误'
    END;
    RETURN sku_id;
END;

//每3秒执行一次生成数据的写入
DELIMITER $$
CREATE PROCEDURE executeStatement3000Times()
BEGIN
  DECLARE i INT DEFAULT 0;
  WHILE i < 1000 DO
    INSERT INTO oms_orders(id, buyer_id,sku_type,sku_quantity, gmt_create) VALUES (default,FLOOR(RAND() * 10),getSkuId(),FLOOR(RAND() * 10),current_timestamp());
    SET i = i + 1;
    SELECT SLEEP(3);
  END WHILE;
END $$
DELIMITER ;

//执行PROCEDURE生成数据并写入
CALL executeStatement3000Times();