--创建测试库create database test;--创建配置表create table test..time_config(tb varchar(20) PRIMARY KEY,enddate binary(10));--创建业务表create table test..TB_s (ID INT PRIMARY KEY,NAME VARCHAR(20)); --原表create table test..TB_t (ID INT PRIMARY KEY,NAME VARCHAR(20),ISDELETED INT); --目标表--给配置表初始时间insert into test..time_configselect 'TB_t' as tb,max(start_lsn) as enddate from test.[cdc].[lsn_time_mapping]--开启cdcuse TESTGOEXEC sys.sp_cdc_enable_db --开启库级别cdcEXEC sys.sp_cdc_enable_table @source_schema = 'dbo', @source_name = 'TB_s', @role_name = null; --开启表cdcGO--增量实现存储过程create proc cdc_tb asdeclare @time_begin binary(10),@time_end binary(10)select @time_begin=max(enddate) from test.dbo.time_config    --上次结束时间，即本次开始时间select @time_end=max(start_lsn) from test.[cdc].[lsn_time_mapping]    --获取最大时间，即本次结束时间--抽取增量数据select ID,NAME,CASE WHEN __$operation=1 then 1 else 0 end as isdeleted into #tb_import from(select row_number()over(partition by id order by [__$start_lsn] desc,__$seqval,__$operation desc ) as rn,* from test.[cdc].[dbo_TB_s_CT] where [__$start_lsn]>@time_begin and [__$start_lsn]<=@time_end) t1 where rn=1;delete from test..TB_t where exists (select * from #tb_import);insert into test..TB_t select * from #tb_import;update test.dbo.time_config set enddate= @time_end where tb='TB_t';--将本次结束时间存入配置表;declare @count intselect @count=count(1) from #tb_import print('更新'+cast(@count as varchar(10))+'条记录')--测试添加：insert into TB_sselect 1,'aaa'--修改update TB_s set name='bbb' where id=1--删除delete from TB_s where id=1select * from TB_sexec cdc_tb --创建job 定时作业select * from TB_t