再记录一下怎么向流里面加一个表。

在源上：
SQL> spool add_table.out
SQL> BEGIN
2 DBMS_STREAMS_ADM.ADD_TABLE_PROPAGATION_RULES(
3 table_name => 'rep.tao',
4 streams_name => 'str1_to_str2',
5 source_queue_name => 'orcl.streams_queue',
6 destination_queue_name => 'centledb.streams_queue@centledb.sun.net',
7 include_dml => true,
8 include_ddl => true,
9 source_database => 'orcl.sun.net',
10 inclusion_rule => true,
11 queue_to_queue => true);
12 END;
13 /

PL/SQL 过程已成功完成。

SQL> BEGIN
2 DBMS_STREAMS_ADM.ADD_TABLE_RULES(
3 table_name => 'rep.tao',
4 streams_type => 'capture',
5 streams_name => 'capture_simp',
6 queue_name => 'orcl.streams_queue',
7 include_dml => true,
8 include_ddl => true,
9 inclusion_rule => true);
10 END;
11 /
在备上：
SQL> DECLARE
2 iscn NUMBER; -- Variable to hold instantiation SCN value
3 BEGIN
4 iscn := DBMS_FLASHBACK.GET_SYSTEM_CHANGE_NUMBER();
5 DBMS_APPLY_ADM.SET_TABLE_INSTANTIATION_SCN@CENTLEDB.SUN.NET(
6 source_object_name => 'rep.tao',
7 source_database_name => 'orcl.sun.net',
8 instantiation_scn => iscn);
9 END;
10 /

PL/SQL procedure successfully completed.

SQL> BEGIN
2 DBMS_STREAMS_ADM.ADD_TABLE_RULES(
3 table_name => 'rep.tao',
4 streams_type => 'apply',
5 streams_name => 'apply_simp',
6 queue_name => 'centledb.streams_queue',
7 include_dml => true,
8 include_ddl => true,
9 source_database => 'orcl.sun.net',
10 inclusion_rule => true);
11 END;
12 /

PL/SQL procedure successfully completed.

注：这个对新建立的表起作用。原来有数据的还要想其它的办法。