前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >SQL Server 多表数据增量获取和发布 2.2

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

作者头像
happlyfox
发布2018-10-31 15:10:41
5320
发布2018-10-31 15:10:41
举报
文章被收录于专栏:技术开源分享技术开源分享

数据库环境: 1、SQLServer 2008R2 2、SQLServer 代理打开

一、新建一个数据库

创建数据库 Incremental_DB

image.png

二、创建俩张测试表


数据库脚本链接


代码语言:javascript
复制
--创建用户表
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
代码语言:javascript
复制
USE Incremental_DB
GO
EXECUTE sys.sp_cdc_enable_db;
GO

查看是否启用CDC

代码语言:javascript
复制
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
代码语言:javascript
复制
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

代码语言:javascript
复制
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

代码语言:javascript
复制
--禁用人员表CDC功能
EXECUTE sys.sp_cdc_disable_table 
    @source_schema = N'dbo', 
    @source_name = N'Person',
    @capture_instance = 'dbo_Person'

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

禁用后系统表截图.png

禁用数据库CDC

代码语言:javascript
复制
EXEC sys.sp_cdc_disable_db 
本文参与 腾讯云自媒体分享计划,分享自作者个人站点/博客。
原始发表:2018.08.28 ,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体分享计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • 一、新建一个数据库
  • 二、创建俩张测试表
  • 三、实现数据变更捕获
    • 一、对目标库显式启用CDC
      • 二、对目标库数据表显式启用CDC
        • 四、禁用数据库或数据表CDC功能
        相关产品与服务
        云数据库 SQL Server
        腾讯云数据库 SQL Server (TencentDB for SQL Server)是业界最常用的商用数据库之一,对基于 Windows 架构的应用程序具有完美的支持。TencentDB for SQL Server 拥有微软正版授权,可持续为用户提供最新的功能,避免未授权使用软件的风险。具有即开即用、稳定可靠、安全运行、弹性扩缩等特点。
        领券
        问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档