将SQL Server作为源端

1sp_configure 'show advanced options', 1;
2reconfigure;
3sp_configure 'Agent XPs', 1;
4reconfigure;

1-- 启动数据库级别CDC命令
2EXEC sys.sp_cdc_enable_db;
3-- 检查是否启动成功
4SELECT name,is_cdc_enabled FROM sys.databases WHERE name = 'DB_name'

1Could not update the metadata that indicates database DB_name is enabled for Change Data Capture. The failure occurred when executing the command 'SetCDCTracked(Value = 1)'. The error returned was 15404: 'Could not obtain information about Windows NT group/user 'RDS-WIN-TEST\Administrator', error code 0x534.'. Use the action and error to determine the cause of the failure and resubmit the request.

1ALTER AUTHORIZATION ON DATABASE::[DB_name] TO [sa]
2或者
3EXEC sp_changedbowner 'sa'

1-- 启动表级别CDC命令
2EXEC sys.sp_cdc_enable_table
3@source_schema= N'schema_name',-- 源表所属的架构的名称，无默认值，且不能为NULL
4@source_name = N'table_name',-- 源表的名称，无默认值，且不能为NULL
5@role_name = NULL,-- 建议设置为NULL，用于访问更改数据的数据库角色的名称。必须指定。如果显式设置为NULL，则没有控制角色用于限制对更改数据的访问。可以为现有的固定服务器角色或数据库角色，如果指定的角色不存在则会自动创建该名称的数据库角色
6@capture_instance = DEFAULT,-- 用于命名特定于实例的变更数据捕获对象的捕获实例的名称。且不能为NULL，源表最多可以有两个捕获实例。
7@supports_net_changes = 0,-- 是否为此捕获实例启用用于查询净更改的支持，默认值为1， 如果supports_net_changes设置为1，则必须指定index_name ，否则源表必须具有定义的主键
8@index_name = NULL,-- 唯一标识源表中的行的唯一索引的名称，可以为NULL。未使用则CDC将使用主键，如果表也没有主键，则将忽略后来添加的主键
9@captured_column_list = NULL,-- 标识要包含在变更表中的源表列，NULL则所有列都将包括在变更表中，以逗号分隔的列名称列表，可以选择将列表中的单个列名称放在双引号("")或方括号([])中，不能包含以下保留列名：__$start_lsn、__$end_lsn、__$seqval、__$operation和__$update_mask。
10@filegroup_name = DEFAULT, -- 要用于为捕获实例创建的变更表的文件组，为 NULL则使用默认文件组，建议为变更数据捕获的变更表创建一个单独的文件组。
11@allow_partition_switch = 1 -- 是否可以对启用了变更数据捕获的表执行ALTER TABLE的SWITCH PARTITION命令,默认值为1，对于非分区表，此开关设置始终为 1，并忽略实际的设置。

1消息 22832，级别 16，状态 1，过程 sp_cdc_enable_table_internal，第 623 行
2无法更新元数据来指示已对表 [aqadmin].[AQ_TEST_1] 启用了变更数据捕获。执行命令 '[sys].[sp_cdc_add_job] @job_type = N'capture'' 时失败。返回的错误为 22836: '无法更新数据库 aq11 的元数据来指示已添加某变更数据捕获作业。执行命令 'sp_add_jobstep_internal' 时失败。返回的错误为 14234: '指定的 @server无效(有效值由 sp_helpserver 返回)。'。请使用此操作和错误来确定失败的原因并重新提交请求。'。请使用此操作和错误来确定失败的原因并重新提交请求。

1IF serverproperty('servername')<>@@servername
2  BEGIN
3  DECLARE  @server SYSNAME  
4  SET   @server=@@servername      
5  EXEC  sp_dropserver @server=@server    
6  SET   @server=cast(serverproperty('servername') AS SYSNAME)   
7  EXEC  sp_addserver @server=@server,@local='LOCAL'  
8  PRINT 'ok！'
9  END 
10ELSE  
11  PRINT 'undo！

1EXECUTE sys.sp_cdc_change_job
2@job_type = N'cleanup',
3@retention = 129600;
4
5-- 重新启动
6EXECUTE sys.sp_cdc_start_job
7@job_type = N'cleanup';

1EXECUTE sys.sp_cdc_change_job
2@job_type = N'capture',
3@pollinginterval = 1;
4
5-- 重新启动
6EXECUTE sys.sp_cdc_start_job
7@job_type = N'capture';