SQL Server 多表数据增量获取和发布 2.2

happlyfox

关注

发布于: 2021 年 03 月 02 日

数据库环境：

1、SQLServer 2008R2

2、SQLServer 代理打开

##一、新建一个数据库

创建数据库 Incremental_DB

##二、创建俩张测试表

-----

[数据库脚本链接]()

-----

--创建用户表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 用户和架构

二、对目标库数据表显式启用 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

复制代码

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

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

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

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

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

验证数据表是否启用 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'

复制代码

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

>禁用数据库 CDC

EXEC sys.sp_cdc_disable_db

复制代码

发布于: 2021 年 03 月 02 日阅读数: 18

原文链接:【http://xie.infoq.cn/article/148ec15e2c695c095fdf3c7ec】。文章转载请联系作者。

happlyfox

关注

公众号程序员工具集 2021.02.18 加入

博客 [www.zhouhuibo.club] 分享优秀的开源项目、学习资源和常用工具。谈论新闻热点、职场经验、学习感悟。共同进步！

发布

暂无评论

创作场景

SQL Server 多表数据增量获取和发布 2.2

一、对目标库显式启用 CDC

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

happlyfox

评论