# PDI-时间戳关系型数据库到StarRocks同步示例

本示例主要介绍 Primeton DI 处理引擎下，使用基于时间戳的关系型数据库到StarRocks增量同步进行数据同步的场景。

主要步骤如下：

准备数据
新建通用模板作业
配置数据源/库
配置表名映射
同步配置
通用配置
指标日志
保存草稿
运行
提交版本

# 准备数据

以 MySQL 数据库为来源数据库。创建数据库：dws_source_dev，在数据库 dws_source_dev 中创建一个表 orderinfo。

SET NAMES utf8mb4;
SET FOREIGN_KEY_CHECKS = 0;

-- ----------------------------
-- Table structure for t_xueji
-- ----------------------------
drop table if EXISTS orderinfo;
create table orderinfo
(
  ordercode    VARCHAR(32) not null comment '订单号',
  amount       int(11) comment '数量',
  price        VARCHAR(32) comment '价格',
  manufacturer VARCHAR(32) comment '厂商',
  createtime   DATE comment '创建时间',
  createuser   VARCHAR(32) comment '创建人',
  updatetime   timestamp comment '更新时间'
) ENGINE=INNODB DEFAULT CHARSET=utf8;

alter table orderinfo add constraint ORDER_PRIMARYKEY primary key (ORDERCODE);

-- ----------------------------
-- Records of t_xueji
-- ----------------------------
BEGIN;
insert into orderinfo (ordercode, amount, price, manufacturer, createtime, createuser, updatetime) 
values ('001', 1000, '5000', 'xingyun', '2018-12-13', 'zhangcong', '2018-12-13 00:00:00');
insert into orderinfo (ordercode, amount, price, manufacturer, createtime, createuser, updatetime)
values ('002', 500, '1000', '西安金属', '2018-12-13', '王强', '2018-12-15 00:00:00');
insert into orderinfo (ordercode, amount, price, manufacturer, createtime, createuser, updatetime)
values ('003', 1500, '7000', '枫禾林木', '2018-12-13', '魏雨', '2018-12-13 12:00:00');
insert into orderinfo (ordercode, amount, price, manufacturer, createtime, createuser, updatetime)
values ('004', 20000, '75000', '星峰', '2018-12-13', '王林', '2018-12-13 00:00:00');
insert into orderinfo (ordercode, amount, price, manufacturer, createtime, createuser, updatetime)
values ('005', 1300, '8000', '天威科技', '2018-12-13', '王林', '2019-12-01 00:00:00');

COMMIT;
SET FOREIGN_KEY_CHECKS = 1;

创建 StarRocks 目标数据库 dws_target，在目标数据库 dws_target 中创建一个表 orderinfo，如果表已经存在可以忽略该步骤。

drop table if exists `orderinfo`;
CREATE TABLE `orderinfo` (
  `ordercode` varchar(32) NOT NULL COMMENT "订单号",
  `amount` int(11) NULL COMMENT "数量",
  `price` varchar(32) NULL COMMENT "价格",
  `manufacturer2` varchar(100) NULL COMMENT "厂商",
  `createtime` date NULL COMMENT "创建时间",
  `createuser` varchar(32) NULL COMMENT "创建人",
  `updatetime` datetime NULL COMMENT "更新时间"
) ENGINE=OLAP 
PRIMARY KEY(`ordercode`)
DISTRIBUTED BY HASH(`ordercode`);