欢迎来到天天文库
浏览记录
ID:38014716
大小:233.00 KB
页数:5页
时间:2019-05-21
《kettle时间戳》由会员上传分享,免费在线阅读,更多相关内容在行业资料-天天文库。
1、同步:在这里指的是MYSQL的数据有了变动要更新到DB2对应的表中共有两种方法:1.时间戳2.触发器。下面讲的是根据时间戳来判断,进行更新。第一步:准备工作1.给MYSQL的datasource表加一列,列名是indate,是timestamp类型,默认值是CURRENT_TIMESTAMP(好像是个函数,用来取当前时间)如下:CREATETABLE`zp`.`datasource`(`id`int(1)unsignedNOTNULLAUTO_INCREMENT,`name`varchar(10)DEFAULTNULL,`indat
2、e`timestampNOTNULLDEFAULTCURRENT_TIMESTAMP,PRIMARYKEY(`id`))ENGINE=InnoDBAUTO_INCREMENT=9DEFAULTCHARSET=utf8;这样当在datasource里面新加了一列后,会自动在后面生成一个indate。2.初始化两个数据库MYSQL的zp数据库里datasource表里有数据,把这个表里的数据弄到DB2的zp数据库里object表里。方法等同(1)KETTLE实现数据库间数据的传输。第二步:KETTLE操作1.此时两个表结构是一样的了,并
3、且里面的数据也是相同的了。OBJECT里面也有了indate这一列(注意:OBJECT里面的indate不要有默认值,值就是复制的datasource里面的值)2.3.表输入里面要取出object里面最新的时间,用到MAX()函数。(此处一定要注意是object的时间,而不是datasource的时间,否则永远也取不出来数据)4.然后把参数传给下个“表输入”这里的“?”代表上一步里取出来的参数(最大的indate)。要注意的是下面的要勾选上:“替换SQL语句里的变量”可以认到上一步的传过来的参数,“从步骤插入数据”表示参数是从哪里来
4、的,“执行每一行”是对每一行进行判断。(对这几句话的解释有待进一步验证)。5.把根据条件查询到的数据传给OBJECT6.执行第三步:进行计划任务,要求这个转换每隔多长时间运行一次。未完待续....
此文档下载收益归作者所有