通过任务编排实现跨库数据同步

在MySQL数据库中创建订单表、商品表和统计表。

1. 登录数据管理DMS 5.0。

2. 单击控制台左上角的图标，选择全部功能 > SQL窗口 > SQL窗口。

   说明

   若您使用的是非极简模式的控制台，在顶部菜单栏中，选择SQL窗口 > SQL窗口。

3. 在请先选择数据库弹框中，搜索并选择MySQL数据库，单击确认。

4. 在MySQL数据库中新建订单表t_order、商品表t_product和用于同步数据分析结果的统计表t_order_report_daily。

   1. 创建表名为t_order的订单表。将下列建表SQL语句粘贴到SQL书写区域，单击执行。

      创建订单表t_order的SQL语句：

      CREATE TABLE `t_order` (
        `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT '主键',
        `product_id` bigint(20) NOT NULL COMMENT '产品id',
        `gmt_create` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
        `gmt_modified` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '修改时间',
        `customer_id` bigint(20) NOT NULL COMMENT '客户id',
        `price` decimal(14,2) NOT NULL COMMENT '价格',
        `status` varchar(64) NOT NULL COMMENT '订单状态',
        `province` varchar(256) DEFAULT NULL COMMENT '交易省份',
        PRIMARY KEY (`id`),
        KEY `idx_product_id` (`product_id`),
        KEY `idx_customer_id` (`customer_id`),
        KEY `idx_status` (`status`)
      ) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8mb4 ROW_FORMAT=COMPACT COMMENT='订单表'
      ;

      订单表t_order的表结构如下：

      该表共有 8 个字段（id、product_id、gmt_create、gmt_modified、customer_id、price、status、province），其中 id 为自增主键，province 允许为空，gmt_create 和 gmt_modified 的默认值为 CURRENT_TIMESTAMP。

   2. 创建表名为t_product的商品表。将下列建表SQL语句粘贴到SQL书写区域，单击执行。

      创建商品表t_product的SQL语句：

      CREATE TABLE `t_product` (
        `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT '主键',
        `name` varchar(128) NOT NULL COMMENT '产品名',
        `type` varchar(64) NOT NULL COMMENT '产品类别',
        `gmt_create` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
        `gmt_modified` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '修改时间',
        PRIMARY KEY (`id`)
      ) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8mb4 COMMENT='产品表'
      ;

      商品表t_product的表结构如下：

      该表共有 5 个字段（id、name、type、gmt_create、gmt_modified），其中 id 为自增主键，gmt_create 和 gmt_modified 的默认值为 CURRENT_TIMESTAMP。

   3. 创建表名为t_order_report_daily的统计表。将下列建表SQL语句粘贴到SQL书写区域，单击执行。

      创建统计表t_order_report_daily的SQL语句：

      CREATE TABLE `t_order_report_daily` (
        `dt` varchar(64) NOT NULL COMMENT '统计日期',
        `product_type` varchar(64) NOT NULL COMMENT '产品类型',
        `order_cnt` bigint(64) NOT NULL COMMENT '笔数',
        `order_amt` decimal(38,2) NOT NULL  COMMENT '金额',
        PRIMARY KEY (`dt`)
      ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='统计表'
      ;

      统计表t_order_report_daily的表结构如下：

      该表共有 4 个字段（dt、product_type、order_cnt、order_amt），其中 dt 为主键。

在AnalyticDB for MySQL数据仓库中创建接收数据的订单表、商品表和存放分析结果的统计表。

1. 进入SQL窗口页面，在请先选择数据库弹框中，搜索并选择AnalyticDB for MySQL数据仓库，单击确认。

2. 在AnalyticDB for MySQL数据仓库中新建用于同步数据的订单表t_order、商品表t_product和用于存放数据分析结果的统计表t_order_report_daily。

   说明

   订单表t_order、商品表t_product和统计表t_order_report_daily的建表SQL语句，请参见步骤4。

3. 订单表t_order和商品表t_product中写入测试数据。使用测试数据构建功能生成数据，具体请参见测试数据构建。

   • 构建订单表t_order的数据，数据量为2000万行。

     说明

     自由操作模式的实例，每个工单最大生成行数为100万行。

   • 构建商品表t_product的数据，数据量为1万行。