kettle执行mysql单表增量同步任务

kettle 实现单表增量同步

增量同步的实施过程主要包括以下三个阶段：（以MySQL数据库为例，其他类型数据库同样适用，经实际测试验证可行，如存在疏漏之处，欢迎提出宝贵意见）

一、获取上次同步时间

建立同步时间日志表，用于存储每次同步操作的具体时间及同步状态，建表SQL语句如下：

CREATE TABLE kg_log (
FD_OBJECTID varchar(50) NOT NULL COMMENT '唯一标识符',
tbsj datetime DEFAULT NULL COMMENT '记录同步发生的时刻',
bm char(50) DEFAULT NULL COMMENT '对应的数据表名称',
result char(50) DEFAULT NULL COMMENT '同步操作的执行结果，1表示成功',
PRIMARY KEY (FD_OBJECTID)
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='用于记录同步时间的日志表';

创建新的数据转换流程，命名为：1-获取上一次同步时间，将表输入组件与变量设置模块拖入设计界面，实现效果如图所示：

![](https://ad.itadn.com/c/weblog/blog-img/i