更新时间:2023-11-10 GMT+08:00
配置SQL Server CDC
概述
CDC(Change Data Capture),即数据变更抓取,通过为源端数据源开启CDC,ROMA Connect可实现数据源的实时数据同步以及数据表的物理删除同步。
本章节主要介绍如何为SQL Server数据库开启CDC功能。
前提条件
- 不支持采集二进制类型的字段,例如:BINARY,VARBINARY,IMAGE。
- 已下载SSMS客户端,下载地址参考SSMS客户端下载。
操作步骤
建议由数据库管理员进行CDC功能的配置操作,以下配置以windows环境为例进行说明。
- 开启CDC。
- 使用SSMS客户端连接到SQL Server数据库所在服务器,以sa用户登录数据库。
其中,密码为数据库用户sa的密码,可向数据库管理员获取。
- 单击“新建查询”,选择你需要开启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替换为实际的数据库名称。
- 执行以下命令查询CDC是否开启成功,结果为“1”表示成功。
select is_cdc_enabled from sys.databases where name='fdiromatest'
其中,fdiromatest替换为实际的数据库名称。
- 开启表级别配置。
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配置的表名。
- 执行以下命令查询执行结果,结果为“1”表示成功。
SELECT is_tracked_by_cdc FROM sys.tables WHERE name='baris'
其中,baris替换为实际需要开启CDC配置的表名。
CDC创建好之后,系统会创建以下一系列的系统表、视图、存储过程和作业来实现CDC功能。
- 使用SSMS客户端连接到SQL Server数据库所在服务器,以sa用户登录数据库。
- CDC配置完成后,需要新建一个用户并配置权限给FDI任务使用。
后续操作
如果系统表结构发生了变化或者有表级别调整,则需要重新开启CDC配置,配置步骤如下:
- 先关闭CDC配置,请根据实际情况填写schema和name。
EXEC sys.sp_cdc_disable_table @source_schema = N'dbo', @source_name = 'baris', @capture_instance ='all'
- 重新开启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
父主题: 创建数据集成任务(组合任务)