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

    上一篇返回首页 下一篇

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

    别人在看

    帝国CMS7.5编辑器上传图片取消宽高的三种方法

    帝国cms如何自动生成缩略图的实现方法

    Windows 12即将到来,将彻底改变人机交互

    帝国CMS 7.5忘记登陆账号密码怎么办?可以phpmyadmin中重置管理员密码

    帝国CMS 7.5 后台编辑器换行,修改回车键br换行为p标签

    Windows 11 版本与 Windows 10比较,新功能一览

    Windows 11激活产品密钥收集及专业版激活方法

    如何从 Windows 11 中完全删除/卸载 OneNote?无解!

    抖音安全与信任开放日:揭秘推荐算法,告别单一标签依赖

    ultraedit编辑器打开文件时,总是提示是否转换为DOS格式,如何关闭?

    IT头条

    华为Pura80系列新机预热,余承东力赞其复杂光线下的视频拍摄实力

    01:28

    阿里千问3开源首战告捷:全球下载破千万,国产AI模型崛起新高度!

    01:22

    DeepSeek R1小版本试升级:网友实测编程能力已达到国际一线水平

    23:15

    NVIDIA 与 Dell 合作,大规模交付 Blackwell AI 系统

    20:52

    Cerebras 以最快的 Llama 4 Maverick 性能引领 LLM 推理竞赛

    20:51

    技术热点

    PHP中的随机性——你觉得自己幸运吗?

    搞定Ubuntu Linux下WPA无线上网

    Java使用内存映射实现大文件的上传

    MySQL安全性指南

    MySQL两项性能的基本测试浅谈

    教您使用UniqueIdentifier选取SQL Server主键

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

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