关闭 x
IT技术网
    技 采 号
    ITJS.cn - 技术改变世界
    • 实用工具
    • 菜鸟教程
    IT采购网 中国存储网 科技号 CIO智库

    IT技术网

    IT采购网
    • 首页
    • 行业资讯
    • 系统运维
      • 操作系统
        • Windows
        • Linux
        • Mac OS
      • 数据库
        • MySQL
        • Oracle
        • SQL Server
      • 网站建设
    • 人工智能
    • 半导体芯片
    • 笔记本电脑
    • 智能手机
    • 智能汽车
    • 编程语言
    IT技术网 - ITJS.CN
    首页 » SQL Server »SQL Server 2008数据库中CDC的功能使用及说明

    SQL Server 2008数据库中CDC的功能使用及说明

    2015-09-18 00:00:00 出处:ITJS
    分享

    SQL Server 2008数据库中CDC的功能使用及说明的相关知识是本文我们主要要介绍的内容,那么什么是CDC呢?CDC(Change Data Capture:变更数据捕获)这个功能是SQL Server 2008企业版的功能,它提供了一种新的机制,对表格数据的更新进行跟踪,在数据仓库的建设过程中,通过这种技术,可以简化从业务数据库导入数据的复杂度。

    1. 准备一个数据库,里面准备一个表,Orders

    SQL Server 2008数据库中CDC的功能使用及说明

    2. 启用数据库级别的CDC选项

    --在数据库级别启用CDC功能

    EXEC sys.sp_cdc_enable_db

    这个命令执行完之后,会在系统表里面添加6个表格

    SQL Server 2008数据库中CDC的功能使用及说明

    3.在需要做数据捕获的表上面启用CDC选项

    EXEC sys.sp_cdc_enable_table @source_schema='dbo',@source_name='Orders',@capture_instance='Orders',@supports_net_changes=0,@role_name=null http://msdn.microsoft.com/en-us/library/bb522475.aspx 

    执行之后,会有如下的输出消息

    SQL Server 2008数据库中CDC的功能使用及说明

    这个提示的意思是说,要启动SQL Server Agent。因为CDC功能是要通过一个两个作业来自动化完成的

    SQL Server 2008数据库中CDC的功能使用及说明

    与此同时,执行上面的命令还将在系统表中添加一个表格

    SQL Server 2008数据库中CDC的功能使用及说明

    还会添加一个函数

    SQL Server 2008数据库中CDC的功能使用及说明

    4.插入或者更新数据测试CDC功能

    --插入或者更新数据测试CDC功能

    INSERT Orders(CustomerID) VALUES('Microsoft');  INSERT Orders(CustomerID) VALUES('Google');  UPDATE Orders SET CustomerID='Yahoo' WHERE OrderID=1 DELETE FROM Orders WHERE OrderID=2 

    这个范例插入两行数据,紧接着又对第一行更新,然后还删除了第二行,所以最终只有一行数据

    SQL Server 2008数据库中CDC的功能使用及说明

    那么,我们来看看CDC做了什么事情呢?

    SELECT * FROM cdc.Orders_CT

    SQL Server 2008数据库中CDC的功能使用及说明

    我们可以来解释一下上面结果的含义:

    __$operation=2的情况,表示新增

    __$operation=3或者4,表示更新,3表示旧值,4表示新值

    __$operation=1的情况,表示删除

    很好理解,不是吗?

    但是,我们一般都是需要按照时间范围进行检索,对吧,所以,需要使用下面的语法进行查询

    --按照时间范围查询CDC结果

    DECLARE @from_lsn BINARY(10),@end_lsn BINARY(10)  DECLARE @start_time DATETIME = '2011-8-10 00:00:00' DECLARE @end_time DATETIME ='2011-8-11 00:00:00' SELECT @from_lsn=sys.fn_cdc_map_time_to_lsn('smallest greater than or equal',@start_time)  SELECT @end_lsn=sys.fn_cdc_map_time_to_lsn(' largest less than or equal',@end_time)  SELECT * FROM cdc.fn_cdc_get_all_changes_Orders(@from_lsn,@end_lsn,'all') 

    关于sys.fn_cdc_map_time_to_lsn这个函数,请参考http://msdn.microsoft.com/en-us/library/bb500137.aspx

    查询的结果如下:

    SQL Server 2008数据库中CDC的功能使用及说明

    假如需要包含更新操作的旧值,则可以以下的语法

    DECLARE @from_lsn BINARY(10),@end_lsn BINARY(10)  DECLARE @start_time DATETIME = '2011-8-10 00:00:00' DECLARE @end_time DATETIME ='2011-8-11 00:00:00' SELECT @from_lsn=sys.fn_cdc_map_time_to_lsn('smallest greater than or equal',@start_time)  SELECT @end_lsn=sys.fn_cdc_map_time_to_lsn(' largest less than or equal',@end_time)  SELECT * FROM cdc.fn_cdc_get_all_changes_Orders(@from_lsn,@end_lsn,'all update old') 

    SQL Server 2008数据库中CDC的功能使用及说明

    通常,为了方便起见,我们会将这个查询定义为一个存储过程,如下

    --定义存储过程来进行查询

    CREATE PROC GetOrdersCDCResult(@start_time DATETIME,@end_time DATETIME)  AS  BEGIN  DECLARE @from_lsn BINARY(10),@end_lsn BINARY(10)  SELECT @from_lsn=sys.fn_cdc_map_time_to_lsn('smallest greater than or equal',@start_time)  SELECT @end_lsn=sys.fn_cdc_map_time_to_lsn(' largest less than or equal',@end_time)  SELECT * FROM cdc.fn_cdc_get_all_changes_Orders(@from_lsn,@end_lsn,'all')  END 

    然后,每次需要用的时候,就直接调用即可。

    --执行存储过程

    EXEC GetOrdersCDCResult '2011-8-10','2011-8-11'

    5.结合SSIS实现事实表的增量更新

    下面展示了一个SSIS 包的设计,这里面读取CDC的数据,先进行一些查找,然后按照__$operation的值拆分成为三个操作,分别进行插入,更新和删除,这样就可以实现对事实表的增量更新

    SQL Server 2008数据库中CDC的功能使用及说明

    本文所有的代码如下:

    USE SampleDatabase  GO  --在数据库级别启用CDC功能  EXEC sys.sp_cdc_enable_db   --在需要做数据捕获的表格上面启用CDC功能  EXEC sys.sp_cdc_enable_table @source_schema='dbo',@source_name='Orders',@capture_instance='Orders',@supports_net_changes=0,@role_name=null --插入或者更新数据测试CDC功能  INSERT Orders(CustomerID) VALUES('Microsoft');  INSERT Orders(CustomerID) VALUES('Google');  UPDATE Orders SET CustomerID='Yahoo' WHERE OrderID=1 DELETE FROM Orders WHERE OrderID=2 --查询CDC的结果  SELECT * FROM cdc.Orders_CT  --按照时间范围查询CDC结果  DECLARE @from_lsn BINARY(10),@end_lsn BINARY(10)  DECLARE @start_time DATETIME = '2011-8-10 00:00:00' DECLARE @end_time DATETIME ='2011-8-11 00:00:00' SELECT @from_lsn=sys.fn_cdc_map_time_to_lsn('smallest greater than or equal',@start_time)  SELECT @end_lsn=sys.fn_cdc_map_time_to_lsn(' largest less than or equal',@end_time)  SELECT * FROM cdc.fn_cdc_get_all_changes_Orders(@from_lsn,@end_lsn,'all')  --定义存储过程来进行查询  CREATE PROC GetOrdersCDCResult(@start_time DATETIME,@end_time DATETIME)  AS  BEGIN  DECLARE @from_lsn BINARY(10),@end_lsn BINARY(10)  SELECT @from_lsn=sys.fn_cdc_map_time_to_lsn('smallest greater than or equal',@start_time)  SELECT @end_lsn=sys.fn_cdc_map_time_to_lsn(' largest less than or equal',@end_time)  SELECT * FROM cdc.fn_cdc_get_all_changes_Orders(@from_lsn,@end_lsn,'all')  END  --执行存储过程  EXEC GetOrdersCDCResult '2011-8-10','2011-8-11' 

    以上就是SQL Server 2008数据库中CDC的功能使用及说明的全部内容,本文我们就介绍到这里了,希望本次的介绍能够对您有所收获!

    上一篇返回首页 下一篇

    声明: 此文观点不代表本站立场;转载务必保留本文链接;版权疑问请联系我们。

    别人在看

    Edge浏览器百度被劫持/篡改怎么办,地址后边跟着尾巴#tn=68018901_7_oem_dg

    Google Chrome 在 iPhone 上新增了 Safari 数据导入选项

    Windows 11专业版 KMS工具激活产品密钥的方法

    DEDECMS安全策略官方出品

    Microsoft Text Input Application 可以关闭吗?

    新版本QQ如何关闭自带的浏览器?

    C++编程语言中continue的用法和功能,附举例示范代码

    c++ map 的数据结构、基本操作以及其在实际应用中的使用。

    C语言如何避免内存泄漏、缓冲区溢出、空指针解引用等常见的安全问题

    C语言中的break语句详解

    IT头条

    马斯克2026最新采访总结:2040年,全球机器人数量将突破100亿台

    23:52

    专家解读|规范人工智能前沿业态健康发展的新探索:解读《人工智能拟人化互动服务管理暂行办法》

    00:54

    用至强 6高存力搞定MoE卸载!

    17:53

    美国将允许英伟达向中国“经批准的客户”出售H200 GPU

    02:08

    苹果与微信就15%手续费达成一致?腾讯未置可否

    22:00

    技术热点

    PHP 和 Node.js 的10项对比挑战

    Javascript闭包深入解析及实现方法

    windows 7、windows 8.1手动增加右键菜单功能技巧

    MYSQL出错代码大汇总

    windows 7假死机怎么办 windows 7系统假死机的原因以及解决方法

    Ubuntu(Linux)下配置IP地址的方法

      友情链接:
    • IT采购网
    • 科技号
    • 中国存储网
    • 存储网
    • 半导体联盟
    • 医疗软件网
    • 软件中国
    • ITbrand
    • 采购中国
    • CIO智库
    • 考研题库
    • 法务网
    • AI工具网
    • 电子芯片网
    • 安全库
    • 隐私保护
    • 版权申明
    • 联系我们
    IT技术网 版权所有 © 2020-2025,京ICP备14047533号-20,Power by OK设计网

    在上方输入关键词后,回车键 开始搜索。Esc键 取消该搜索窗口。