# PDI-MySQL到主数据增量同步示例

本示例主要介绍 Primeton DI 处理引擎下，使用 MySQL 到主数据增量同步进行单表数据同步场景。

主要步骤如下：

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

# 准备数据

1、创建 MySQL 数据库 example，在数据库 example 中创建一个表 fr_model01_origin。

CREATE TABLE `fr_model01_origin` (
  `FIELDNUM` decimal(32,0) DEFAULT NULL COMMENT 'fieldNum',
  `FIELDDATE` date DEFAULT NULL COMMENT 'fieldDate',
  `FIELDSTR` varchar(32) DEFAULT NULL COMMENT 'fieldStr',
  `FIELDTIME` datetime DEFAULT NULL COMMENT 'field04Time',
  `ANE` varchar(32) DEFAULT NULL COMMENT 'ane',
  `WDE` varchar(32) DEFAULT NULL COMMENT 'WDE'
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb3;

INSERT INTO example.fr_model01_origin
(FIELDNUM, FIELDDATE, FIELDSTR, FIELDTIME, ANE, WDE)
VALUES(1, '2024-10-15', 'bbb', '2024-10-15 15:21:06', NULL, NULL);
INSERT INTO example.fr_model01_origin
(FIELDNUM, FIELDDATE, FIELDSTR, FIELDTIME, ANE, WDE)
VALUES(0, '2024-10-17', 'aaa', '2024-10-15 15:01:54', NULL, NULL);
INSERT INTO example.fr_model01_origin
(FIELDNUM, FIELDDATE, FIELDSTR, FIELDTIME, ANE, WDE)
VALUES(0, '2024-10-07', '是的冯绍峰', '2024-10-16 00:00:00', NULL, NULL);
INSERT INTO example.fr_model01_origin
(FIELDNUM, FIELDDATE, FIELDSTR, FIELDTIME, ANE, WDE)
VALUES(2, '2025-01-12', 'ccc', '2025-01-13 00:15:10', 'ccc', 'ccc');
INSERT INTO example.fr_model01_origin
(FIELDNUM, FIELDDATE, FIELDSTR, FIELDTIME, ANE, WDE)
VALUES(3, '2025-01-12', 'ddd', '2025-01-13 00:15:46', 'ddd', 'ddd');
INSERT INTO example.fr_model01_origin
(FIELDNUM, FIELDDATE, FIELDSTR, FIELDTIME, ANE, WDE)
VALUES(5, '2025-01-12', '测试', '2025-02-11 00:15:46', 'aaa', 'aaa');

2、在【应用中心】>【业务组件】>【业务字段】菜单中，配置“DWS_MDM_SYNC”类型字典。

字典项编号	字段名称	字段描述
DWS_MDM_QUERY_MODEL	http://127.0.0.1:8090/api/mdm/data-cleaning/model-info/page-query	查询主数据模版地址（主数据提供）
DWS_MDM_RECEIVE_URL	http://127.0.0.1:8090/api/mdm/data-cleaning/batch/${modelId}	向主数据发送数据的HTTP地址
DWS_MDM_RECEIVE_HTTP_METHOD	POST	向主数据发送数据的HTTP方法
DWS_MDM_AFC_TOKEN	c0101b6109e8478784ceb8897159fe2b	主数据的登录token
DWS_MDM_TARGET_DATASOURCE_ID	MDM_PUB	主数据目标数据源编码（需配置主数据的目标数据源）