专栏首页码农分享SQLServer CDC数据迁移和数据抽取功能介绍 2

SQLServer CDC数据迁移和数据抽取功能介绍 2

数据库环境: 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 

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

我来说两句

0 条评论
登录 后参与评论

相关文章

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

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

    小狐狸
  • SQLServer CDC数据迁移和数据抽取功能介绍

    为了满足数据迁移和数据抽取的业务需要,使得有机会在数据库层面上直接实现增量抽取功能,ORACLE综合性能和场景需要,在数据库引擎层面直接集成了CDC功能,由于提...

    小狐狸
  • 1、苏宁百万级商品爬取 思路讲解 类别爬取

    通过图可知,总共有N个类别,每个类别都是一个DIV区块,然后再继续分解DIV区块分析内容。我们要得到的是类别表,据图所示我们可以分析得出类别表的结构应当树形的。...

    小狐狸
  • SQL Server 多表数据增量获取和发布 2.2

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

    小狐狸
  • Linux平台oracle 11g单实例 + ASM存储 安装部署

    操作环境:Citrix虚拟化环境中申请一个Linux6.4主机(模板) 目标:创建单机11g + ASM存储 数据库

    Alfred Zhao
  • 前端面试知识点

    允许用户传递一个callback参数给服务端,然后服务端返回数据时会将这个callback参数作为函数名来包裹住JSON数据,这样客户端就可以随意定制自己的函数...

    Daotin
  • web前端面试都问什么-JS篇

    在js中变量的作用域属于函数作用域, 在函数执行完后,作用域就会被清理,内存也会随之被回收,但是由于闭包函数是建立在函数内部的子函数, 由于其可访问上级作用域,...

    coder_koala
  • Java7和8 中的 HashMap 和 ConcurrentHashMap 全解析

    转自https://www.javadoop.com/post/hashmap#toc7

    Java技术江湖
  • 深入解析HashMap那些不为人知的事

    光从名字上应该也能猜到,HashMap肯定是基于hash算法实现的,这种基于hash实现的map叫做散列表(hash table)。

    慕容千语
  • 分析 JDK 源码丨Java HashMap

    HashMap 是数组和链表组合组成的复杂结构,哈希值决定了键值在数组的位置,当哈希值相同时则以链表形式存储,当链表长度到达设定的阈值则会对其进行树化,这样做是...

    码脑

扫码关注云+社区

领取腾讯云代金券