zoukankan      html  css  js  c++  java
  • 增量抽取-时间戳方式实现

    ----------时间戳方式抽取数据------------------------
    介绍:它是一种基于快照比较的变化数据捕获方式,在源表上增加一个时间戳字段,系统中更新修改表数据的时候,同时修改时间戳字段的值。当进行数据抽取时,通过比较上次
             抽取时间与时间戳字段的值来决定抽取那些数据。有的数据库的时间戳支持自动更新,即表的其他字段的数据发生变化时,自动更新时间戳字段。有的数据库不支持时间戳的自动
             更新,这就要求业务系统在更新业务数据时,手工更新时间戳字段。
    一:在数据源上增加一个时间戳字段
           时间戳: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
     
     
     
  • 相关阅读:
    01背包回溯法
    网络嗅探器
    侦听局域网内密码
    Winsock协议目录
    LSP(分层服务提供者)
    n后问题回溯法
    批处理作业调度回溯法
    图m着色问题
    SPI概述
    符号三角形问题回溯法
  • 原文地址:https://www.cnblogs.com/zja001/p/10095448.html
Copyright © 2011-2022 走看看