oracle简单stream 一个用户单向复制配置

以下我做streamm同步两台机器间的某一个用户的操作步骤。很简单,看到stream
还
有很多要看的。

1.环境介绍

主数据库SID : obpm

操作系统 : win 2003

IP地址 : 192.168.0.1

Global_name :

oracle
version: 10.2.0.1

从数据库SID: orcl

操作系统 : win 2003

IP地址 : 192.168.0.2

Global_name :

oracle
version: 10.2.0.1

2.在主/从数据库设置初始化参数(在主从数据库都执行以下操作)

1) sqlplus / as sysdba ----以dba身份登录

2)alter system set aq_tm_processes=2 scope=both; ---启用对队列消息的时间监视

　　alter system set global_names=true scope=both; ---设置全局名称为true

　　---alter system set job_queue_processes=10 scope=both;
--设置定时作业进程最大为10个,默认是10

　　alter system set undo_retention=3600 scope=both;
--设置回滚段时间,默认是900

alter system set streams_pool_size=25M scope=spfile;
--sga设置为自动调整情况下不需设置该参数

3)重启动两个数据库

3.设置主数据库为归档mode

1)archive log list; --查是否归档,如是归档,请忽略第3点

2)shutdown immediate;

startup mount;

alter database archivelog;

alter system set LOG_ARCHIVE_DEST_1='LOCATION=D:/arc/';
---设置归档目录

alter system switch logfile; --相应目录检查是否生成arc文件

alter database open;

4.主/从数据新建stream
管理用户(在主从数据库都执行以下操作)

1)sqlplus / as sysdba;

2)create tablespace tbs_stream datafile 'E:/tbs_stream01.dbf' size
100m autoextend on maxsize unlimited segment space management auto;
---创建主环境的Stream
专用表空间

3)execute dbms_logmnr_d.set_tablespace('tbs_stream');
--将logminer的数据字典从system表空间转移到新建的表空间，防止撑满system表空间

4)create user strmadmin identified by strmadmin default tablespace
tbs_stream temporary tablespace temp; --创建用户

5)grant dba to strmadmin;---直接给dba权限.

5.主数据库网络环境设置

1)主数据库(tnsnames.ora)中添加从数据库的配置。(也可以通过oracle
图
形工具net manager配置)

orcl =

(DESCRIPTION =

(ADDRESS_LIST =

(ADDRESS = (PROTOCOL = TCP)(HOST = 192.168.0.2)(PORT = 1521))

)

(CONNECT_DATA =

(SERVER = DEDICATED)

(SERVICE_NAME = orcl)

)

)

2)测试是否连的通(cmd下面输入以下命令)

sqlplus strmadmin/strmadmin@orcl

3)新建orcl的dblink

sqlplus strmadmin/strmadmin

create database link orcl connect to strmadmin identified by
strmadmin using 'orcl';

----global_names为true的情况下,主数据库建立的数据库链的名字必须和从数据库的global_name相同

select sysdate from dual@orcl; --测试dblink是否有效

6.从数据库网络环境设置

1)从数据库(tnsnames.ora)中添加主数据库的配置。(也可以通过oracle
图
形工具net manager配置)

obpm =

(DESCRIPTION =

(ADDRESS_LIST =

(ADDRESS = (PROTOCOL = TCP)(HOST = 192.168.0.1)(PORT = 1521))

)

(CONNECT_DATA =

(SERVER = DEDICATED)

(SERVICE_NAME = obpm)

)

)

2)测试是否连的通(cmd下面输入以下命令)

sqlplus strmadmin/strmadmin@obpm

3)新建obpm的dblink

sqlplus strmadmin/strmadmin

create database link obpm connect to strmadmin identified by
strmadmin using 'obpm';

----global_names为true的情况下,主数据库建立的数据库链的名字必须和从数据库的global_name相同

select sysdate from dual@obpm; --测试dblink是否有效

7.主数据库流队列创建

　　connect strmadmin/strmadmin --以strmadmin身份，登录主数据库。

　begin

dbms_streams_adm.set_up_queue(queue_table =>
'obpm_queue_table',queue_name => 'obpm_queue');

end;

　　/

8.从数据库流队列创建

　connect strmadmin/strmadmin --以strmadmin身份，登录从数据库。

　begin

dbms_streams_adm.set_up_queue(queue_table =>
'orcl_queue_table',queue_name => 'orcl_queue');

end;

　　/

9.主数据库创建捕获进程

　connect strmadmin/strmadmin

begin

dbms_streams_adm.add_schema_rules(

schema_name => 'xapps_crm',

streams_type => 'capture',

streams_name => 'capture_obpm',

queue_name => 'strmadmin.obpm_queue',

include_dml => true,

include_ddl => true,

include_tagged_lcr => false,

source_database => null,

inclusion_rule => true);

end;

　　/

10.从数据库实例化crm用户

　exp xapps_crm/xapps_crm@obpm file='F:/crm.dmp'
object_consistent=y rows=y

在从数据库新建xapps_crm

　　imp xapps_crm/xapps_crm@orcl file='F:/crm.dmp' ignore=y commit=y
streams_instantiation=y full=y

11.主数据库创建传播进程

　　connect strmadmin/strmadmin --以strmadmin身份，登录主数据库。

begin

dbms_streams_adm.add_schema_propagation_rules(

schema_name => 'xapps_crm',

streams_name => 'obpm_to_orcl',

source_queue_name => 'strmadmin.obpm_queue',

destination_queue_name => 'strmadmin.orcl_queue@orcl',

include_dml => true,

include_ddl => true,

include_tagged_lcr => false,

source_database => 'obpm',

inclusion_rule => true);

end;

　　/

　　

　　begin --修改propagation休眠时间为0，表示实时传播LCR。

　　dbms_aqadm.alter_propagation_schedule(

queue_name => 'obpm_queue',

destination => 'orcl',

latency => 600); --latency以秒为单位

end;

　　/

12.从数据创建应用进程

　connect strmadmin/strmadmin

begin

dbms_streams_adm.add_schema_rules(

schema_name => 'xapps_crm',

streams_type => 'apply',

streams_name => 'apply_orcl',

queue_name => 'strmadmin.orcl_queue',

include_dml => true,

include_ddl => true,

include_tagged_lcr => false,

source_database => 'obpm',

inclusion_rule => true);

end;

　　/

13.启动Stream

1)从数据库启动应用进程

　　connect strmadmin/strmadmin

begin

dbms_apply_adm.start_apply(

apply_name => 'apply_orcl');

end;

　　/



2)主数据库启动捕获进程

　　connect strmadmin/strmadmin

　begin

dbms_capture_adm.start_capture(

capture_name => 'capture_obpm');

end;

/

14.在crm用户中作何一个表新增数据,删除数据,增加表,修改表结构,进行同步测试

15.停止stream

1)主数据库停止Capture进程

　　connect strmadmin/strmadmin

　　begin

dbms_capture_adm.stop_capture(

capture_name => 'capture_obpm');

end;

　　/

　2)从数据库停止Apply进程

　　connect strmadmin/strmadmin

　　begin

dbms_apply_adm.stop_apply(

apply_name => 'apply_orcl');

end;

　　/

16.清除所有配置信息

1)按上述方法停止capture,applya进程

2)分别在主从数据库执行以下语句

connect strmadmin/strmadmin

exec DBMS_STREAMS_ADM.remove_streams_configuration();

17.如何知道捕捉(Capture)进程是否运行正常?

以strmadmin身份，登录主数据库，执行如下语句：

　SQL> SELECT
CAPTURE_NAME,QUEUE_NAME,RULE_SET_NAME,NEGATIVE_RULE_SET_NAME,STATUS FROM
DBA_CAPTURE;

　　如果STATUS状态是ENABLED，表示Capture进程运行正常;

　　如果STATUS状态是DISABLED，表示Capture进程处于停止状态，只需重新启动即可;

　　如果STATUS状态是ABORTED，表示Capture进程非正常停止，查询相应的ERROR_NUMBER、
ERROR_MESSAGE列可以得到详细的信息;同时，Oracle
会在跟踪文件中记录该
信息。

18. 如何知道Captured LCR是否有传播?

以strmadmin身份，登录主数据库，执行如下语句：

SQL> SELECT CAPTURE_NAME, QUEUE_NAME, STATUS, CAPTURED_SCN,
APPLIED_SCN FROM DBA_CAPTURE;


如果APPLIED_SCN小于CAPTURED_SCN，则表示在主数据库一端，要么LCR没有被dequeue，要么Propagation进程尚未
传播到从数据库一端。

19.如何知道Appy进程是否运行正常?

以strmadmin身份，登录从数据库，执行如下语句：

SQL> SELECT apply_name, apply_captured, status FROM dba_apply;

如果STATUS状态是ENABLED，表示Apply进程运行正常;

如果STATUS状态是DISABLED，表示Apply进程处于停止状态，只需重新启动即可;

如果STATUS状态是ABORTED，表示Apply进程非正常停止，查询相应的ERROR_NUMBER、ERROR_MESSAGE列可以
得到详细的信息;

同时，可以查询DBA_APPLY_ERROR视图，了解详细的Apply错误信息。