oracle 单表流复制 stream

1、oracle 单表流复制 stream今日运气够好，oracle单表流复制搞定，因为oracle seam 操作步骤多，之前碰到许多问题， 没有理清思路或者说自己对此的理解不够，所以失败。对于重要表，流复制类 dataguard应用日志，主服务器 捕捉，然后传递，从服务器接受，如此而以。容易记录一下主要步骤。 1 主服务器 os： windows s:an 数据库版本10.2.0.1 从服务器 os: windows sid format 数据库版本10.2.0.1 2 主、从数据库分离执行如下的语句： sqlplus / as sysdba alter system aq_tm_proces

2、ses=2 scope=both; alter system set global_names=true scope=both; alter system set job_queue_processes=10 scope=both; alter system set parallel_max_servers=20 scope=both; alter system set undo_retention=3600 scope=both; alter system set n_format='yyyy-mm-dd hh24:mi:ss' scope=sp; alter system

3、set streams_pool_size=25m scope=spfile;-这个我没执行，理由是oracle自动分配了 alter system set utl_file_dir='*' scope=spfile; alter system set open_links=4 scope=spfile; 3 主从机设置归档 mout状态下alter database archivelog 另开启alter system set log_archive_start=true; 查看归档是否胜利select recid, name, first_ from v$archiv_lo

4、g; 4 主从机表空间和用户 create tablespace stream_tbs datafile 'g:oracleoradatarmanstream01.dbf' size 200m autotend on extent management local uniform size 1m segment space management auto; 表空间已创建。 - 创建streams管理用户，并授予dba权限 jssweb create user test identified by test default tablespace stream_tbs; 用户已创建

5、。 -将logminer的数据字典从system表空间转移到新建的表空间，防止撑满system表空间 exee dbms_logmnr_d.set_tablespace('tbs_stream'); - 因为streams用户操作需要较多权限，此处仅用于演示，简便期间挺直授予dba权限 授权test管理用户 jssweb grant dba to test; begin dbms_streams_auth.grant_admin_privilege( gran = 'test', grant_privileges = true); end; 5 主从机表空间和用

6、户 create tablespace stream_tbs datafile 'd:oracleoradatarmanstream01.dbf' size 200m autoextend on extent management local uniform size 1m segment space management auto; 表空间已创建。 - 创建streams管理用户，并授予dba权限 jssweb create user strmadmin identified by strmadmin default tablespace stream_tbs; 用户已创建。

7、 -将logminer的数据字典从system表空间转移到新建的表空间，防止撑满system表空间 execute dbms_logmnr_d.set_tablespace('tbs_stream'); - 因为streams用户操作需要较多权限，此处仅用于演示，简便期间挺直授予dba权限 授权test管理用户 jssweb grant dba to strmadmin ; begin dbms_streams_auth.grant_admin_privilege( grantee = 'strmadmin', grant_privileges = true);

8、 end; 6 配置网络衔接 主数据库（tnsnames.ora）中添加从数据库的配置。 rman = (description = (address_list = (address = (protocol = tcp)(host = 192.168.1.103)(port = 1521) ) (connect_data = (sid = rman) (server = dedicated) ) ) 配置从环境tnsnames.ora 从数据库（tnsnames.ora）中添加主数据库的配置。 format = (description = (address_list = (address =

9、 (protocol = tcp)(host = 192.168.1.104)(port = 1521) ) (connect_data = (sid = format) (server = dedicated) ) ) 7 创建database link 主：create database link format connect to strmadmin identified by strmadmin using 'format' 从：create database link rman connect to strmadmin identified by strmadmin

10、using 'rman ' 然后互相tns 或 select sysdate from alformat/rman; 8 主库 exec dbms_streams_adm.set_up_queue(); 从库 exec dbms_streams_adm.set_up_queue(); 9 创建捕捉规章 begin dbms_streams_adm.a_table_rules( table_name = 'scott.emp', streams_type = 'capture', streams_name = 'capture_stream

11、', queue_name = 'test.streams_queue', ilude_dml = true, include_ddl = true, inclusion_rule = true); end; -创建传扬规章 begin dbms_streams_adm.add_table_propagation_rules( table_name = 'scott.emp', streams_name = 'sour_to_targ', source_queue_name = 'test.streams_queue',

12、destination_queue_name = , include_dml = true, include_ddl = true, source_database = 'rman', inclusion_rule = true, queue_to_queue = true); end; select capture_name,us from dba_capture; capture_name status - - capture_stream disabled 次库 把scott用户下的表emp drop一下。 target数据库 创建应用规章 begin dbms_stre

13、ams_adm.add_table_rules( table_name = 'scott.emp', streams_type = 'apply', streams_name = 'apply_stream', queue_name = 'strmadmin.streams_queue', include_dml = true, include_ddl = true, source_database = 'rman', inclusion_rule = true); end; 初始化数据，首先从源库导出，再执行导入

14、，复制的方式无数，规律导入导出、rman、dupliion之类的，基本上你想怎么操作都可以， 由于只操作一个表，所以挺直通过数据库链复制。 create table scott.emp ( empno number(4) not null primary key , ename varchar2(10), job varchar2(9), mgr number(4), hiredate date, sal number(7,2), comm number(7,2), deptno number(2) ); insert into scott.emp select *from scott.emprman; 设置起始应用的scn declare iscn number; begin iscn := dbms_flashback.get_system_change_number(); dbms_apply_adm.set_table_instantiation_scnformat( source_object_name = 'scott.emp', source_database_name = 'rma