Oracle10gR2 Streams(七)用户级复制

STRMADM@ning>create directory dir_source as 'f:\oracle\source';

Directory created.

STRMADM@dest>create directory dir_dest as 'f:\oracle\dest';

Directory created.

STRMADM@ning>create table ning.test(i int);

Table created.

alter system set log_archive_dest_2='service=dest arch noregister';

STRMADM@dest>BEGIN
  2    DBMS_STREAMS_ADM.MAINTAIN_SCHEMAS(
  3      schema_names                 => 'ning',
  4      source_directory_object      => 'DIR_SOURCE',
  5      destination_directory_object => 'DIR_DEST',
  6      source_database              => 'ning.test',
  7      destination_database         => 'dest.test',
  8      perform_actions              => true,
  9      dump_file_name               => 'export_ning.dmp',
 10      capture_queue_table          => 'rep_capture_queue_table',
 11      capture_queue_name           => 'rep_capture_queue',
 12      capture_queue_user           => NULL,
 13      apply_queue_table            => 'rep_dest_queue_table',
 14      apply_queue_name             => 'rep_dest_queue',
 15      apply_queue_user             => NULL,
 16      capture_name                 => 'capture_ning',
 17      propagation_name             => 'prop_ning',
 18      apply_name                   => 'apply_ning',
 19      log_file                     => 'export_ning.clg',
 20      bi_directional               => false,
 21      include_ddl                  => true,
 22      instantiation                => DBMS_STREAMS_ADM.INSTANTIATION_SCHEMA);
 23  END;
 24  /

PL/SQL procedure successfully completed.

STRMADM@ning> insert into ning.test values(1);

1 row created.

STRMADM@ning>commit;

Commit complete.

STRMADM@ning>alter system archive log current;

System altered.

STRMADM@dest>select * from ning.test;

         I
----------
         1

alter system set "_job_queue_interval"=1 scope=spfile;

alter system set aq_tm_processes=1;