Oracle CDC基本操作及用法

1、创建change_set

BEGIN
DBMS_CDC_PUBLISH.CREATE_CHANGE_SET( 
change_set_name => 'CHANGE_SET_USER1', 
description => 'Change set for USER1', 
change_source_name => 'SYNC_SOURCE'

); 

END;

2、创建change_table

BEGIN

DBMS_CDC_PUBLISH.CREATE_CHANGE_TABLE( 
owner => 'system', 
change_table_name => 'CT_f_u_info', 
change_set_name => 'CHANGE_SET_f_u_info', 
source_schema => 'system', 
source_table => 'f_u_info', 
column_type_list => 'NAME VARCHAR2(100),ID NUMBER,ADDRESS VARCHAR2(100),SEX VARCHAR2(100),DEGREE VARCHAR2(100),FLAG VARCHAR2(1)', 
capture_values => 'both', 
rs_id => 'y', 
row_id => 'n', 
user_id => 'n',
timestamp => 'y', 
object_id => 'n', 
source_colmap => 'y', 
target_colmap => 'y', 
options_string => '', 
DDL_MARKERS=>'n'
); 
END;

3、清除change_table

--begin
--  SYS.dbms_cdc_publish.drop_change_table('zltest','CT_ZLCQTEST','Y');
--end;

4、清除change_set

begin
  SYS.dbms_cdc_publish.drop_change_set('change_set_CCC_cdc');

end;

5、停止CDC

BEGIN
  DBMS_CDC_SUBSCRIBE.PURGE_WINDOW(
  subscription_name => 'CT_T1001');
  END;

6、激活CDC

Begin
  dbms_cdc_subscribe.activate_subscription(subscription_name => 'CT_T1001');
END;