增量抽取-时间戳方式实现

----------时间戳方式抽取数据------------------------
介绍:它是一种基于快照比较的变化数据捕获方式,在源表上增加一个时间戳字段,系统中更新修改表数据的时候,同时修改时间戳字段的值。当进行数据抽取时,通过比较上次
         抽取时间与时间戳字段的值来决定抽取那些数据。有的数据库的时间戳支持自动更新,即表的其他字段的数据发生变化时,自动更新时间戳字段。有的数据库不支持时间戳的自动
         更新,这就要求业务系统在更新业务数据时,手工更新时间戳字段。
一:在数据源上增加一个时间戳字段
       时间戳:oracle提供了时间戳数据类型Timestamp,将定义为时间戳数据类型的字段做查询时,查询到的结果为:18-4月 -10 03.31.06.000000 下午
     这种格式不太符合我们的需要,用to_char函数把一个日期数据转换为任何一个我们想要的格式。
     to_char(sysdate,'yyyy-mm-dd hh24:mi:ss')-----将时间戳类型转换为字符串类型
     oracle还提供了一种日期类型Date,也可以用to_char()转换成自己想要的格式。
     两种类型都是对日期和时间的表示,只是两种类型的精度不同,date精确到秒,而Timestamp精确到小数秒,两者格式化显示都一样。
     to_char函数对两种类型都支持,但是turnc函数不支持时间戳类型。
                    当两个时间的差别极其重要时,使用时间戳类型要比日期类型更加精确。
     两个date类型相减的结果是以天为单位,而两个时间戳类型相减的结果是直观的显示“多少天+多少小时+多少分钟+多少秒+多少小数秒”;
     例如:
     select to_timestamp('2018-11-11 12:12:12.23','yyyy-mm-dd hh24:mi:ss.ff')-to_timestamp('2018-10-11 12:12:12.23','yyyy-mm-dd hh24:mi:ss.ff') from dual
     结果为:
     查询结果显示(多少天 多少小时 多少分钟 多少秒 多少小数秒 ):000000001 01:30:10.100000
     date类型转化为timestamp类型要使用cast函数:
     select cast(sysdate as Timestamp) from dual
二:新建time_test表
 CREATE TABLE `time_test` (
   `id` int(10) NOT NULL AUTO_INCREMENT,
   `name` varchar(50) DEFAULT NULL,
   `age` int(3) DEFAULT NULL,
   `time_smp` timestamp NULL DEFAULT NULL,
   PRIMARY KEY (`id`)
 ) ENGINE=InnoDB AUTO_INCREMENT=14 DEFAULT CHARSET=utf8;
三:新建触发器
 当插入数据时,默认给当前时间;
 当修改数据时,时间戳更新为当前时间;
 以上两个触发器都在源表基础上做修改。
 a:触发器名称tri_time_test_insert---插入
    触发器没成tri_time_test_update---更新
 b:触发时间----都在触发事件之后触发
 c:执行语句
  插入后-------------------改变思路,将时间戳定义为默认值
  --------------------------更新mysql表中的某一字段,为其设置一个默认值
    ALTER TABLE time_test ALTER COLUMN time_smp SET DEFAULT now();
  d:触发器没成tri_time_test_update---更新
 create  trigger tri_time_test_update AFTER update
 on `time_test` FOR EACH ROW
 begin
 set @point=(select name from `time_test` where id = OLD.id ); 
 set @point02=(select age from `time_test` where id = OLD.id );
 if @point != old.name then
 update `time_test` set time_smp=now() where idC=OLD.id;
 end if;
 if @point02 != old.age then
 update `time_test` set time_smp=now() where idC=OLD.id;
 end if;
 end
 
 
 
原文地址:https://www.cnblogs.com/zja001/p/10095448.html