数据库环境：
1、SQLServer 2008R2
2、SQLServer 代理打开
一、新建一个数据库
创建数据库 Incremental_DB
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_DB
GO
EXECUTE sys.sp_cdc_enable_db;
GO
查看是否启用CDC
SELECT is_cdc_enabled,CASE WHE is_cdc_enabled=0 THEN 'CDC功能禁用'ELSE 'CDC功能启用'END [描述]
FROM sys.databases
WHERE [name]='Incremental_DB'
创建成功后，会在测试库自动添加CDC用户和架构
image.png
二、对目标库数据表显式启用CDC
USE Incremental_DB
EXECUTE sys.sp_cdc_enable_table
@source_schema = N'dbo'--架构名称
, @source_name = N'Department'--表名称
, @role_name = 'cdc_Admin'--会自动生成自定义 'cdc_Admin' 角色 如果不想控制访问角色，则@role_name必须显式设置为null
, @capture_instance=NULL
EXECUTE 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
语句执行成功后在系统表中生成俩张变化表
新增表.png
数据库可编程性中增加俩个函数
新增函数.png
同时SQLServer 代理中新增俩个作业
- capture(捕获作业)
-
clean(清理作业)
新增作业.png
如果出现如下错误，请参考上一篇文章CDC注意事项第三点
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.tables
WHERE 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表被删除，函数删除等
禁用后系统表截图.png
禁用数据库CDC
EXEC sys.sp_cdc_disable_db
