博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
SQL Server 多表数据增量获取和发布 2.2
阅读量:6847 次
发布时间:2019-06-26

本文共 2126 字,大约阅读时间需要 7 分钟。

数据库环境:

1、SQLServer 2008R2
2、SQLServer 代理打开

一、新建一个数据库

创建数据库 Incremental_DB

img_384307952ad1df19ba38237b61252361.png
image.png

二、创建俩张测试表



--创建用户表CREATE TABLE [dbo].[Person](    [Id] [INT] IDENTITY(1,1) NOT NULL,    [Name] [NVARCHAR](120) NULL,    [Age] [INT] NULL, CONSTRAINT [PK_Demo] PRIMARY KEY CLUSTERED (    [Id] ASC)WITH (PAD_INDEX  = OFF, STATISTICS_NORECOMPUTE  = OFF, IGNORE_DUP_KEY = OFF, ALLOW_ROW_LOCKS  = ON, ALLOW_PAGE_LOCKS  = ON) ON [PRIMARY]) ON [PRIMARY]--创建部门表CREATE TABLE [dbo].[Department](    [Id] [INT] IDENTITY(1,1) NOT NULL,    [Name] [NVARCHAR](50) NULL, CONSTRAINT [PK_Department] PRIMARY KEY CLUSTERED (    [Id] ASC)WITH (PAD_INDEX  = OFF, STATISTICS_NORECOMPUTE  = OFF, IGNORE_DUP_KEY = OFF, ALLOW_ROW_LOCKS  = ON, ALLOW_PAGE_LOCKS  = ON) ON [PRIMARY]) ON [PRIMARY]

三、实现数据变更捕获

一、对目标库显式启用CDC

USE Incremental_DBGOEXECUTE sys.sp_cdc_enable_db;GO

查看是否启用CDC

SELECT  is_cdc_enabled,CASE WHE is_cdc_enabled=0 THEN 'CDC功能禁用'ELSE 'CDC功能启用'END [描述]FROM    sys.databasesWHERE   [name]='Incremental_DB'

创建成功后,会在测试库自动添加CDC用户和架构

img_f23b5126137fee2873ac6555c57cb5b6.png
image.png

二、对目标库数据表显式启用CDC

USE Incremental_DBEXECUTE sys.sp_cdc_enable_table    @source_schema = N'dbo'--架构名称  , @source_name = N'Department'--表名称  , @role_name = 'cdc_Admin'--会自动生成自定义 'cdc_Admin' 角色 如果不想控制访问角色,则@role_name必须显式设置为null  , @capture_instance=NULLEXECUTE sys.sp_cdc_enable_table    @source_schema = N'dbo'--架构名称  , @source_name = N'Person'--表名称  , @role_name = 'cdc_Admin'--会自动生成自定义 'cdc_Admin' 角色 如果不想控制访问角色,则@role_name必须显式设置为null  , @capture_instance=NULL

语句执行成功后在系统表中生成俩张变化表

img_263df0d927128f5f9fbd082ec9093290.png
新增表.png

数据库可编程性中增加俩个函数

img_e712ead50367bc79b8fdcfda3eaf60cb.png
新增函数.png

同时SQLServer 代理中新增俩个作业

  • capture(捕获作业)
  • clean(清理作业)

    img_0c6f6322e13940837179d8777b1a397b.png
    新增作业.png

如果出现如下错误,请参考上一篇文章CDC注意事项第三点

img_15395ef0b8f908ceeaf17cec6ea0d739.png
image.png

验证数据表是否启用CDC

USE Incremental_DB--查看是否已启用:SELECT  name ,        is_tracked_by_cdc ,        CASE WHEN is_tracked_by_cdc = 0 THEN 'CDC功能禁用'             ELSE 'CDC功能启用'        END 描述FROM    sys.tablesWHERE   OBJECT_ID IN(OBJECT_ID('Person'),OBJECT_ID('Department'))

四、禁用数据库或数据表CDC功能

禁用数据表CDC

--禁用人员表CDC功能EXECUTE sys.sp_cdc_disable_table     @source_schema = N'dbo',     @source_name = N'Person',    @capture_instance = 'dbo_Person'

禁用后系统表中原来的dbo_Person_CT表被删除,函数删除等

img_b61b2e515c465cbad05aade6507edb16.png
禁用后系统表截图.png

禁用数据库CDC

EXEC sys.sp_cdc_disable_db

转载地址:http://pnlul.baihongyu.com/

你可能感兴趣的文章
HDU1312 ZOJ2165 Red and Black
查看>>
测试人员面试不自信怎么办?
查看>>
第一次实验报告
查看>>
正则匹配replace替换重复字符串
查看>>
[Linux学习]chattr配置文件隐藏属性及lsattr查看隐藏属性
查看>>
mybatis大数据提交和更新,数据SQL语句批量提交数据库
查看>>
每天一个小算法(Shell Sort2)
查看>>
Java数据结构与算法(7) - ch05双向链表(Double List)
查看>>
fiddler 教程
查看>>
自适应布局
查看>>
ILSpy c#反编译工具,附下载地址
查看>>
课堂练习——查找水王续
查看>>
在后台设置yii的配置文件
查看>>
(4/24) webpack3.x快速搭建本地服务和实现热更新
查看>>
Failure is not fatal, but failure to change might be.
查看>>
L2-015. 互评成绩
查看>>
iOS9新特性
查看>>
poj3186 poj3267
查看>>
烂泥:学习centos之快速搭建LNMP环境
查看>>
Poj2723:Get Luffy Out
查看>>