文档首页/ 应用与数据集成平台 ROMA Connect/ 用户指南/ 数据集成指导/ 创建数据集成任务（组合任务）/ 配置SQL Server CDC
更新时间：2025-01-20 GMT+08:00
查看PDF
分享

配置SQL Server CDC

概述

CDC（Change Data Capture），即数据变更抓取，通过为源端数据源开启CDC，ROMA Connect可实现数据源的实时数据同步以及数据表的物理删除同步。

本章节主要介绍如何为SQL Server数据库开启CDC功能。

约束与限制

  • 若SQL Server数据库为主从模式，不支持使用SQL Server从库。
  • 不支持采集二进制类型的字段，例如：BINARY，VARBINARY，IMAGE。
  • 已下载SSMS客户端，下载地址参考SSMS客户端下载。

操作步骤

建议由数据库管理员进行CDC功能的配置操作，以下配置以windows环境为例进行说明。

  1. 开启CDC。
    1. 使用SSMS客户端连接到SQL Server数据库所在服务器，以sa用户登录数据库。

      其中，密码为数据库用户sa的密码，可向数据库管理员获取。

    2. 单击“新建查询”，选择您需要开启CDC的数据库。执行以下命令，开启SQL Server数据库CDC。 
      if exists(select 1 from sys.databases where name='fdiromatest' and is_cdc_enabled=0)
begin
    exec sys.sp_cdc_enable_db
end

      其中，fdiromatest替换为实际的数据库名称。

    3. 执行以下命令查询CDC是否开启成功，结果为“1”表示成功。 
      select is_cdc_enabled from sys.databases where name='fdiromatest'

      其中，fdiromatest替换为实际的数据库名称。

    4. 开启表级别配置。 
      IF EXISTS(SELECT 1 FROM sys.tables WHERE name='baris' AND is_tracked_by_cdc = 0)
BEGIN
    EXEC sys.sp_cdc_enable_table
        @source_schema = 'dbo', -- source_schema
        @source_name = 'baris', -- table_name
        @capture_instance = NULL, -- capture_instance
        @supports_net_changes = 1, -- supports_net_changes
        @role_name = NULL -- role_name
END

      其中，baris替换为实际需要开启CDC配置的表名。

    5. 执行以下命令查询执行结果，结果为“1”表示成功。 
      SELECT is_tracked_by_cdc FROM sys.tables WHERE name='baris'

      其中，baris替换为实际需要开启CDC配置的表名。

      CDC创建好之后，系统会创建以下一系列的系统表、视图、存储过程和作业来实现CDC功能。

  2. CDC配置完成后，需要新建一个用户并配置权限给FDI任务使用。
    1. 右键单击“安全性”，选择“新建 > 登录名”。
    2. 在“常规”栏中填写创建的用户名及密码。

      身份验证选择SQL Server，然后填写密码。

    3. 在“服务器角色”栏勾选“dbcreator”和“public”角色。
    4. 在“用户映射”栏选择映射到此登录名的用户及数据库角色成员身份。
      1. 在“映射到此登录名的用户”中选择配置CDC的数据库，例如：fdiromatest。
      2. 在“数据库角色成员身份”中选择“db_datareader”、“db_owner”和“public”。
    5. 配置完成后单击“确定”即可。

后续操作

如果系统表结构发生了变化或者有表级别调整，则需要重新开启CDC配置，配置步骤如下：

  1. 先关闭CDC配置，请根据实际情况填写schema和name。 
    EXEC sys.sp_cdc_disable_table 
 @source_schema = N'dbo',
 @source_name = 'baris', 
 @capture_instance ='all'
  2. 重新开启CDC配置，请根据实际情况填写schema和name。

    开启表级别配置。

    IF EXISTS(SELECT 1 FROM sys.tables WHERE name='baris' AND is_tracked_by_cdc = 0) 
 BEGIN 
     EXEC sys.sp_cdc_enable_table 
         @source_schema = 'dbo', -- source_schema 
         @source_name = 'baris', -- table_name 
         @capture_instance = NULL, -- capture_instance 
         @supports_net_changes = 1, -- supports_net_changes 
         @role_name = NULL -- role_name 
 END

相关文档