关闭 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的功能使用及说明的全部内容,本文我们就介绍到这里了,希望本次的介绍能够对您有所收获!

    上一篇返回首页 下一篇

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

    别人在看

    Destoon 模板存放规则及语法参考

    Destoon系统常量与变量

    Destoon系统目录文件结构说明

    Destoon 系统安装指南

    Destoon会员公司主页模板风格添加方法

    Destoon 二次开发入门

    Microsoft 将于 2026 年 10 月终止对 Windows 11 SE 的支持

    Windows 11 存储感知如何设置?了解Windows 11 存储感知开启的好处

    Windows 11 24H2 更新灾难:系统升级了,SSD固态盘不见了...

    小米路由器买哪款?Miwifi热门路由器型号对比分析

    IT头条

    Synology 对 Office 套件进行重大 AI 更新,增强私有云的生产力和安全性

    01:43

    StorONE 的高效平台将 Storage Guardian 数据中心占用空间减少 80%

    11:03

    年赚千亿的印度能源巨头Nayara 云服务瘫痪,被微软卡了一下脖子

    12:54

    国产6nm GPU新突破!砺算科技官宣:自研TrueGPU架构7月26日发布

    01:57

    公安部:我国在售汽车搭载的“智驾”系统都不具备“自动驾驶”功能

    02:03

    技术热点

    最全面的前端开发指南

    Windows7任务栏桌面下角的一些正在运行的图标不见了

    sql server快速删除记录方法

    SQL Server 7移动数据的6种方法

    SQL Server 2008的新压缩特性

    每个Java程序员必须知道的5个JVM命令行标志

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

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