Oracle 流复制(Stream Replication)

快来打我* 2022-05-28 01:07 238阅读 0赞

Stream 是Oracle 的消息队列(也叫Oracle Advanced Queue)技术的一种扩展应用。 Oracle 的消息队列是通过发布/订阅的方式来解决事件管理。流复制(Stream replication)只是基于它的一个数据共享技术，也可以被用作一个可**灵活定制的高可用性方案**。 它可以实现两个数据库之间**数据库级，schema级，Table级的数据同步**，并且这种同步可以是**双向的**。 Oracle Stream也是通过数据冗余来提高可用性，这一点和Data Guard 类型。

Oracle 高级复制(Oracle advanced Replication) 和流复制(Stream Replication) 是从名称和功能上都相似的两种技术。 但前者是基于触发器的，后者是基于日志挖掘(Logminer)技术。

**1. ****Stream 的工作原理**

Stream 是**Oracle Advanced Queue**技术的一种扩展应用， 这种技术最基本的**原理就是收集事件**，把时间保存在队列中，然后把这些事件发布给不同的订阅者。 从DBA的角度来说，** 就是把捕获Oracle数据库产生的Redo日志，然后把这些日志通过网络传播到多个数据库**，**其他数据库通过应用这些日志，达到复制变化的作用**。

在Stream 环境下，** 复制的起点数据库叫作Source Database**， **复制的终点数据库叫作Target Database**。 在这两个数据库上都要创建一个队列，其中的Source Database上的是**发送队列**，而Target Database上的是**接收队列**。

数据库的所有操作都会被记录在日志中。 配好Stream环境后， 在Source Database上会有一个**捕获进程****(Capture Process)**, 该进程利用Logminer技术从日志中提取DDL,DML语句，这些语句用一种特殊的格式表达，叫作**逻辑变更记录**(Logical Change Record, LCR). 一个LCR对应一个原子的行变更，因此源数据库上的一个DML语句，可能对应若干个LCR记录。 这些LCR会保存到Sourece Database的本地发送队列中。然后**传播进程(Propagation Process)**把这些记录通过网络发送到Target Database的接收队列。 在Target Database上会有一个**应用进程(Apply Process)**， 这个进程从本地的接收队列中取出LCR记录，然后在本地应用，实现数据同步

**2.  Data Guard 和Stream 区别**

Date Guard有两种类型：physical standby 和 logical standby。 这两中standby 都有3个功能模块：** 日志传送；日志接收，日志恢复**。两种standby在前两个模块中是一样的，都是通过LGWR或者ARCn进程发送日志，通过RFS进程接受日志。** ****区别在第三个模块**：

Physical Standby 使用的是Media Recovery技术直接在**数据块级别进行恢复**， 因此Physical Standby 能够做到两个数据库的完全同步， 没有数据类型限制。

Logical Standby实际是通过Logminer技术，把日志中的记录还原成SQL语句，然后通过Apply Engine 执行这些语句实现数据同步， 因此Logical Standby不能保证数据的完全一致。 比如Logical Standby 不支持某些数据类型，这一点在选择Logical Standby时必须要考虑. Logical Standby 不支持的数据类型可以从DBA\_LOGSTDBY\_UNSUPPORTED是不里查看.

SQL>SELECT \* FROM DBA\_LOGSTDBY\_UNSUPPORTED;

**Stream 使用的是Logical Standby 第三个模块，也就是在Source Database一端，Capture 进程利用Logminer 技术把日志内容还原成LCR， 然后发送到Target Database， 而在Target database 一端， 也是通过Apply Engine 执行这些LCR。 因此Stream在使用上也有些限制条件。这些可以从视图ALL/DBA\_STREAMS\_NEWLY\_SUPPORTED,  ALL/DBA\_STREAMS\_UNSUPPORTED 查看stream复制不支持的数据类型。**

SQL>SELECT table\_name, reason FROM ALL\_STREAMS\_NEWLY\_SUPPORTED;

SQL>SELECT table\_name, reason FROM DBA\_STREAMS\_NEWLY\_SUPPORTED;

SQL>SELECT table\_name, reason FROM DBA\_STREAMS\_UNSUPPORTED;

SQL>SELECT table\_name, reason FROM ALL\_STREAMS\_UNSUPPORTED;

下面以图表的形式列举他们的区别：

<table style="padding:0pt 5.4pt;border-collapse:collapse;"> 
 <tbody> 
 <tr> 
 <td style="padding:0pt 5.4pt;border:.5pt dashed rgb(0,0,0);">Streams</td> 
 <td style="border-bottom-color:rgb(0,0,0);border-width:.5pt .5pt .5pt medium;border-style:dashed dashed dashed none;padding:0pt 5.4pt;border-top-color:rgb(0,0,0);border-right-color:rgb(0,0,0);">Data&nbsp;Guard</td> 
 </tr> 
 <tr> 
 <td style="border-bottom-color:rgb(0,0,0);border-width:medium .5pt .5pt;border-style:none dashed dashed;border-left-color:rgb(0,0,0);padding:0pt 5.4pt;border-right-color:rgb(0,0,0);">主要目的是数据共享</td> 
 <td style="border-bottom-color:rgb(0,0,0);border-width:medium .5pt .5pt medium;border-style:none dashed dashed none;padding:0pt 5.4pt;border-right-color:rgb(0,0,0);">主要目的是灾难恢复和高可用性</td> 
 </tr> 
 <tr> 
 <td style="border-bottom-color:rgb(0,0,0);border-width:medium .5pt .5pt;border-style:none dashed dashed;border-left-color:rgb(0,0,0);padding:0pt 5.4pt;border-right-color:rgb(0,0,0);">可以多方向同步</td> 
 <td style="border-bottom-color:rgb(0,0,0);border-width:medium .5pt .5pt medium;border-style:none dashed dashed none;padding:0pt 5.4pt;border-right-color:rgb(0,0,0);">只能是单向，从Primary--&gt;&nbsp;Standby</td> 
 </tr> 
 <tr> 
 <td style="border-bottom-color:rgb(0,0,0);border-width:medium .5pt .5pt;border-style:none dashed dashed;border-left-color:rgb(0,0,0);padding:0pt 5.4pt;border-right-color:rgb(0,0,0);">数据粒度可以是数据库，Schema，Table三个级别</td> 
 <td style="border-bottom-color:rgb(0,0,0);border-width:medium .5pt .5pt medium;border-style:none dashed dashed none;padding:0pt 5.4pt;border-right-color:rgb(0,0,0);">只有数据库级别</td> 
 </tr> 
 <tr> 
 <td style="border-bottom-color:rgb(0,0,0);border-width:medium .5pt .5pt;border-style:none dashed dashed;border-left-color:rgb(0,0,0);padding:0pt 5.4pt;border-right-color:rgb(0,0,0);">支持异种平台的同步(Heterogeneous&nbsp;Platforms)</td> 
 <td style="border-bottom-color:rgb(0,0,0);border-width:medium .5pt .5pt medium;border-style:none dashed dashed none;padding:0pt 5.4pt;border-right-color:rgb(0,0,0);">必须同种平台&nbsp;(Homogeneous&nbsp;Platforms)</td> 
 </tr> 
 <tr> 
 <td style="border-bottom-color:rgb(0,0,0);border-width:medium .5pt .5pt;border-style:none dashed dashed;border-left-color:rgb(0,0,0);padding:0pt 5.4pt;border-right-color:rgb(0,0,0);">参与复制的每个数据库可以读写</td> 
 <td style="border-bottom-color:rgb(0,0,0);border-width:medium .5pt .5pt medium;border-style:none dashed dashed none;padding:0pt 5.4pt;border-right-color:rgb(0,0,0);">只有Primary可以读写，Standby&nbsp;只读</td> 
 </tr> 
 <tr> 
 <td style="border-bottom-color:rgb(0,0,0);border-width:medium .5pt .5pt;border-style:none dashed dashed;border-left-color:rgb(0,0,0);padding:0pt 5.4pt;border-right-color:rgb(0,0,0);">支持Oracle&nbsp;和非Oracle&nbsp;数据库间的同步</td> 
 <td style="border-bottom-color:rgb(0,0,0);border-width:medium .5pt .5pt medium;border-style:none dashed dashed none;padding:0pt 5.4pt;border-right-color:rgb(0,0,0);">只能是Oracle数据库间</td> 
 </tr> 
 </tbody> 
</table>

**3. ****前期规划的几点：**

1). 确定复制集：如是数据库级还是表级

2). 决定复制站点

3). 决定LCR是本地捕获还是下游捕获

本地捕获： 在源数据库进行，从联机日志和归档日志获得LCR

下游捕获：在目标数据库进行，从归档日志获得LCR.

本地捕获可以保护更多的数据，但是会占用源数据库的资源。

4). 决定复制拓扑结构：这时要决定复制数据库的用途，是只用于预防灾难，还是平时保持空闲，或允许用户使用。

**4. ****Streams Replication 实例**

**4.1 准备工作：**

DBA是源数据库， DBA2是目标数据库

4.1.1 源数据库和目标数据库必须是归档的

SQL> startup mount;

SQL> alter database archivelog;

SQL> alter database open;

SQL> archive log list

归档与非归档的切换请参考：

[http://blog.csdn.net/tianlesoftware/archive/2009/10/18/4693470.aspx][http_blog.csdn.net_tianlesoftware_archive_2009_10_18_4693470.aspx]

或者

http://user.qzone.qq.com/251097186/blog/1236924069

4.1.2. 源数据库和目的数据库均需要设置的参数：

alter system set global\_names=true scope = both;

默认为false,  Database Link 使用的是数据库的global\_name。

alter system set aq\_tm\_processes=2 scope=both;

以下参数都是10G的默认值， 检查下就可以了. 无需设置

如：Show parameter job\_queue\_processes

alter system set job\_queue\_processes = 10 scope=both;

alter system set sga\_target = 300m scope=spfile;

alter system set open\_links=4 scope=spfile;

alter system set statistics\_level='TYPICAL' scope=both;

10g 默认为Typical， 性能统计模式

alter system set logmnr\_max\_persistent\_sessions=1 scope=spfile;

10g 默认为1，持久的日志挖掘会话数。

alter system set "\_job\_queue\_interval"=1 scope=spfile;  
alter system set aq\_tm\_processes=1;  
alter system set streams\_pool\_size=200m scope=both;  
注意streams\_pool\_size一定要够大，因为如果启用了SGA\_TARGET，ORACLE可能分配很少内存给stream导致大量信息被spill到磁盘导致查询DBA\_APPLY,DBA\_CAPTURE,DBA\_PROPGATION全部状态ENABLED但就是没有数据被同步。  
同时设置\_job\_queue\_interval也是为了提高队列检查时间，防止apply出问题。

注意：与复制有关的2个参数：

如果等了足够长的时间发现数据没有复制过来，仔细检查了capture/propagation/apply各进程的状态都是正常的， 并检查参数.

alter system set "\_job\_queue\_interval"=1 scope=spfile;

并且将aq\_tm\_processes参数改为1（我原来这是为10）

alter system set aq\_tm\_processes=1;

改完后重启，发现数据就可以去了。这个隐含参数只是控制对job队列的检查频率，默认5秒。

4.1.3 . 在源数据库上启用追加日志

可以基于Database级别或Table级别，启用追加日志（Supplemental Log）。在建立根据Schema粒度进行复制的Oracle Stream环境中，如果确认Schema下所有Table都有合理的主键(Primary Key)，则不再需要启用追加日志。

\#启用Database 追加日志

alter database add supplemental log data;

\#启用Table追加日志

alter table add supplement log group log\_group\_name(table\_column\_name) always;

4.1.4 . 源数据库和目的数据库创建相同表空间和用户并赋权

创建表空间：

CREATE TABLESPACE streams\_tbs DATAFILE 'D:/ORACLE/ORADATA/DBA/streams\_tbs.dbf' SIZE 100M REUSE AUTOEXTEND ON MAXSIZE UNLIMITED;

CREATE TABLESPACE streams\_tbs DATAFILE 'D:/ORACLE/ORADATA/DBA2/streams\_tbs.dbf' SIZE 100M REUSE AUTOEXTEND ON MAXSIZE UNLIMITED;

创建用户：

CREATE USER strmadmin IDENTIFIED BY strmadmin DEFAULT TABLESPACE streams\_tbs

QUOTA UNLIMITED ON streams\_tbs;

赋权：

GRANT DBA to strmadmin;   /\* 10g要求dba角色以简化配置 \*/

exec DBMS\_STREAMS\_AUTH.GRANT\_ADMIN\_PRIVILEGE('strmadmin'); /\* 赋予流管理特权 \*/

4.1.5 配置listener.ora和tnsnames.Ora

DBA2 =

(DESCRIPTION =

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

(CONNECT\_DATA =

(SERVER = DEDICATED)

(SERVICE\_NAME = DBA2.anqingren.org)

)

4.1.6 创建DBLink

先用strmadmin登陆，在创建dblink

4.1.6.1在源端建到目库的db link

SQL> conn strmadmin/strmadmin;

已连接。

SQL> create database link DBA2 connect to strmadmin identified by strmadmin using 'dba2';

数据库链接已创建。

测试：

SQL> select \* from global\_name@dba2;

GLOBAL\_NAME

\-------------------

DBA2.ANQINGREN.ORG

4.1.6.2 在目端建到源库的db link

SQL> conn strmadmin/strmadmin;

已连接。

SQL> create database link dba connect to strmadmin identified by strmadmin using 'dba';

数据库链接已创建。

**4.2  用户级的复制(****不支持sys和system用户)**

**4.2.1 最初的用户复制**

分别在源库和目标数据库上创建测试用户

SQL>create user dave identified by dave;

SQL>grant dba to dave;

4.2.1 在源数据库上创建Source 队列

connect  strmadmin/strmadmin@dba;

BEGIN

DBMS\_STREAMS\_ADM.SET\_UP\_QUEUE(

queue\_table => 'SOURCE\_QUEUE\_TABLE',             --队列表

queue\_name  => 'SOURCE\_QUEUE',                --队列

queue\_user  => 'strmadmin');                  --队列用户

END;

或者:

SQL> EXEC DBMS\_STREAMS\_ADM.SET\_UP\_QUEUE();

PL/SQL procedure successfully completed.

该命令会创建一个队列缺省名：streams\_queue，队列表缺省是：STREAMS\_QUEUE\_TABLE

队列存储的object类型是anaydata

移除队列：

exec dbms\_streams\_adm.remove\_queue(

queue\_name => 'streams\_queue',

cascade => true,

drop\_unused\_queue\_table => true);.

可以用查询dba\_queues,dba\_queue\_tables来检查：

SQL>  select owner,queue\_table,name from dba\_queues where owner='STRMADMIN';

OWNER               QUEUE\_TABLE              NAME

\----------------- ------------------------- ------------------

STRMADMIN          SOURCES\_QUEUE\_TABLE        SOURCES\_QUEUE

STRMADMIN          SOURCES\_QUEUE\_TABLE        AQ$\_SOURCES\_QUEUE\_TABLE\_E

SQL>select owner,queue\_table,object\_type from dba\_queue\_tables where owner='STRMADMIN';

OWNER            QUEUE\_TABLE           OBJECT\_TYPE

\-------------- --------------------- ------------------

STRMADMIN       SOURCES\_QUEUE\_TABLE     SYS.ANYDATA

4.2.2 在目标数据库DBA2上创建接收队列

connect  strmadmin/strmadmin@dba2;

BEGIN

DBMS\_STREAMS\_ADM.SET\_UP\_QUEUE(

queue\_table => 'TARGET\_QUEUE\_TABLE',             --队列表

queue\_name  => 'TARGET\_QUEUE',                --队列

queue\_user  => 'strmadmin');                  --队列用户

END;

可以用查询dba\_queues,dba\_queue\_tables来检查：

SQL>  select owner,queue\_table,name from dba\_queues where owner='STRMADMIN';

OWNER               QUEUE\_TABLE             NAME

\------------------ ---------------------  \----------------

STRMADMIN           TARGET\_QUEUE\_TABLE    TARGET\_QUEUE

STRMADMIN           TARGET\_QUEUE\_TABLE    AQ$\_TARGET\_QUEUE\_TABLE\_E

4.2.3 在源数据库上创建capture 进程

SQL>conn strmadmin/strmadmin@DBA;

SQL> BEGIN

DBMS\_STREAMS\_ADM.ADD\_SCHEMA\_RULES(

schema\_name     => 'dave',    -- 用户名,如dave， 非sys或者system

streams\_type      => 'capture',

streams\_name     => 'capture\_stream',

queue\_name       => 'strmadmin.SOURCE\_QUEUE',

include\_dml       => true,

include\_ddl        => true,

source\_database => 'DBA',

include\_tagged\_lcr => false,

inclusion\_rule     => true);

END;

PL/SQL procedure successfully completed.

可以通过dba\_capture查看：

SQL> select CAPTURE\_NAME,QUEUE\_NAME,START\_SCN,STATUS,CAPTURE\_TYPE from dba\_capture;

CAPTURE\_NAME     QUEUE\_NAME       START\_SCN  STATUS   CAPTURE\_TY

\-------------------------    ----------------------------  ----------      --------------  ----------------

CAPTURE\_STREAM1  SOURCES\_QUEUE    1294052     DISABLED  LOCAL

SQL> select \* from  ALL\_CAPTURE\_PREPARED\_SCHEMAS;

SCHEMA\_NAME  TIMESTAMP   SUPPLEME  SUPPLEME SUPPLEME SUPPLEME

\--------------------    --------------    -------- --------  --------       --------

SYSTEM         20-10月\-09     IMPLICIT  IMPLICIT    IMPLICIT   NO

4.2.4 在源数据库上创建传播进程

SQL>conn strmadmin/strmadmin@DBA;

SQL> BEGIN

DBMS\_STREAMS\_ADM.ADD\_SCHEMA\_PROPAGATION\_RULES(

schema\_name                => 'dave',

streams\_name               => 'source\_to\_target',

source\_queue\_name          => 'strmadmin.SOURCE\_QUEUE',

destination\_queue\_name    => 'strmadmin.TARGET\_QUEUE@DBA2', \--此队列待创建

include\_dml               => true,

include\_ddl               => true,

source\_database           => 'DBA',

inclusion\_rule            => true,

queue\_to\_queue            => true);

END;

PL/SQL procedure successfully completed.

重新启动propagation process  
 --dbms\_propagation\_adm.start\_propagation (propagation\_name)  
 --其中propagation\_name可以从表all\_propagation中取得  
 select \* from all\_propagation;   
 SQL>  exec dbms\_propagation\_adm.start\_propagation('source\_to\_target');

exec dbms\_propagation\_adm.stop\_propagation('source\_to\_target');  
    PL/SQL procedure successfully completed.

select \* from all\_propagation;

可以通过dba\_propagations查看结果：

SQL> select PROPAGATION\_NAME,SOURCE\_QUEUE\_NAME,DESTINATION\_QUEUE\_NAME,DESTINATION\_DBLINK,STATUS from dba\_propagation;

PROPAGATION\_NAME   SOURCE\_QUEUE\_NA DESTINATION\_QUE DESTINATION\_DBLINK STATUS

\------------------ --------------- --------------- ------------------ --------

STREAM1\_TO\_STREAM2 SOURCES\_QUEUE   TARGET\_QUEUE    DBA2.ANQINGREN.ORG ENABLED

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

begin

dbms\_aqadm.alter\_propagation\_schedule(

queue\_name => 'SOURCE\_QUEUE',

destination => 'DBA2',

latency => 0);

end;

4.2.5 在目标数据库DBA2上创建Apply进程

SQL> BEGIN

DBMS\_STREAMS\_ADM.ADD\_SCHEMA\_RULES(

schema\_name      => 'SYSTEM',

streams\_type    => 'apply',

streams\_name    => 'target\_apply\_stream',

queue\_name      => 'strmadmin.TARGET\_QUEUE',

include\_dml     => true,

include\_ddl     => true,

include\_tagged\_lcr => false,

source\_database => 'DBA',

inclusion\_rule => true);

END;

可以通过：

dba\_apply

v$streams\_apply\_reader

v$streams\_apply\_coordinator

v$streams\_apply\_server

查看状态

SQL> select apply\_name,queue\_name,status from dba\_apply;

APPLY\_NAME                     QUEUE\_NAME                     STATUS

\------------------------------ ------------------------------ --------

TARGET\_APPLY\_STREAM            TARGET\_QUEUE                   DISABLED

4.2.6  实例化复制数据库

4.2.6.1 用exp/imp 完成实例化

带数据完成源端exp和目端的import：

Exp USERID=SYSTEM/ADMIN@DBA OWNER=SYSTEM FILE=D:/STRM.dmp LOG=STRM.log OBJECT\_CONSISTENT=Y STATISTICS = NONE

imp USERID=SYSTEM/ADMIN@DBA2 FULL=Y CONSTRAINTS=Y FILE=D:/STRM.dmp IGNORE=Y COMMIT=Y LOG=D:/import.log STREAMS\_INSTANTIATION=Y

或仅作实例化(不带数据)：

exp USERID=SYSTEM/ADMIN@DBA OWNER=SYSTEM FILE=D:/STRM.dmp LOG=D:/export.log OBJECT\_CONSISTENT=Y STATISTICS = NONE ROWS=NO

imp USERID=SYSTEM/ADMIN@DBA2 FULL=Y CONSTRAINTS=Y FILE=D:/STRM.dmp COMMIT=Y LOG=D:/import.log STREAMS\_INSTANTIATION=Y IGNORE=Y

4.2.6.2 直接设置SCN的方式进行实例化：

\---获取源库互置用户的SCN

connect strmadmin/strmadmin@DBA

set serveroutput on

DECLARE

iscn NUMBER; -- Variable to hold instantiation SCN value

BEGIN

iscn := DBMS\_FLASHBACK.GET\_SYSTEM\_CHANGE\_NUMBER();

DBMS\_OUTPUT.PUT\_LINE ('Instantiation SCN is: ' || iscn);

END;

\---设置为目标库互置用户的SCN

connect strmadmin/strmadmin@DBA2

BEGIN

DBMS\_APPLY\_ADM.SET\_SCHEMA\_INSTANTIATION\_SCN(

source\_schema\_name => 'SYSTEM',

source\_database\_name => 'DBA',

instantiation\_scn => &iscn);

END;

4.2.7.  在目标数据库上启动Apply进程

connect strmadmin/strmadmin@DBA2

SQL> BEGIN

DBMS\_APPLY\_ADM.SET\_PARAMETER(apply\_name => 'target\_apply\_stream', parameter

=> 'disable\_on\_error', VALUE => 'n');

END;

SQL> BEGIN

DBMS\_APPLY\_ADM.START\_APPLY(

apply\_name => 'target\_apply\_stream');

END;

\#停止Apply进程

begin

dbms\_apply\_adm.stop\_apply(

apply\_name => 'target\_apply\_stream');

end;

查看状态

SQL> select apply\_name,queue\_name,status from dba\_apply;

APPLY\_NAME                     QUEUE\_NAME                     STATUS

\------------------------------ ------------------------------ --------

TARGET\_APPLY\_STREAM            TARGET\_QUEUE                   ENABLED

4.2.8 在源数据库上启动capture

connect strmadmin/strmadmin@DBA

SQL> BEGIN

DBMS\_CAPTURE\_ADM.START\_CAPTURE(

capture\_name => 'capture\_stream');

END;

\#停止Capture进程

begin

dbms\_capture\_adm.stop\_capture(

capture\_name => 'capture\_stream');

end;

查看状态：

SQL> select capture\_name,status from dba\_capture;

CAPTURE\_NAME    STATUS

\--------------- --------

CAPTURE\_STREAM ENABLED

**4.3  表级的复制**

maintain\_tts  表空间复制

maintain\_schemas 用户复制

maintain\_tables 表复制的

与dbms\_streams\_adm的maintain\_global、maintain\_tts、maintain\_schemas等过程相比，maintain\_tables过程使用则更灵活，可以为某些特殊的表拿出来单独配置，maintain\_tables也象其它的过程一样，提供了一蓝子解决方案，如果要添加新的表到复制中，只需要再次执行maintain\_tables过程即可。

**4.3.****1 在stream进行配置前，需要做些准备工作**  
A 源库与目标库初始化参数的设置  
alter system set aq\_tm\_processes=1 scope=spfile;  
alter system set job\_queue\_processes=2 scope=spfile;  
alter system set global\_names=true scope=spfile;  
alter system set streams\_pool\_size=20m scope=spfile;   
说明streams\_pool\_size在生产环境中最好>200m  
B 源库与目标库tnsnames.ora配置  
见4.1  
C 源库与目标库复制管理员的创建  
    见4.1  
D 在源库与目标库创建DBLINK

见4.1  
E 源库与目标库必须处于归档模式  
见4.1  
**F**** 源库与目标库必须创建directory**  
connect [strmadmin/strmadmin@D][strmadmin_strmadmin_D]BA;  
create directory DIR\_DBA as 'D:/Stream/DBA';  
connect [strmadmin/strmadmin@D][strmadmin_strmadmin_D 1]BA2;  
create directory DIR\_DBA2 as 'D:/Stream/DBA2';  
说明:在复制表空间时,创建directory需要指定该表空间所在的目录  
G 创建测试用的表空间及表

CREATE TABLESPACE DAVE DATAFILE 'D:/ORACLE/ORADATA/DBA/DAVE.dbf' SIZE 100M;

create user tianle identified by tianle default tablespace DAVE;

grant dba to tianle;

conn TIANLE/TIANLE

create table test(id int,name varchar2(20));

create table test2(id int,name varchar2(20));

insert into test values(1,'dave');

insert into test values(2,'bl');

不能使用默认的表空间.

**4.3.2 **** 在源库执行MAINTAIN\_TTS过程**  
SQL>connect [strmadmin/strmadminpw@D][strmadmin_strmadmin_D]BA;  
declare  
v\_tables dbms\_utility.uncl\_array;  
begin  
v\_tables(1) := 'tianle.test;  
v\_tables(2) := 'tianle.test2';  
dbms\_streams\_adm.maintain\_tables(  
table\_names => v\_tables,  
source\_directory\_object => null,  
destination\_directory\_object => null,  
source\_database => 'DBA',  
destination\_database => 'DBA2',  
perform\_actions => true,  
bi\_directional => false,  
include\_ddl => true,  
instantiation => dbms\_streams\_adm.instantiation\_table\_network);  
end;  
/  
说明:在源库执行maintain\_tables时,目标库几乎什么都不用做,stream环境已经配置好啦,  
如果想复制其它的表,只用再执行maintain\_tables过程即可

**4.3.3**** 如果在执行2的过程时失败,需要清除脚本**  
\--select script\_id from dba\_recoverable\_script;  
\--exec dbms\_streams\_adm.RECOVER\_OPERATION('&1','PURGE');  
declare  
v\_script\_id varchar2(32);  
begin  
select script\_id into v\_script\_id from dba\_recoverable\_script;  
dbms\_streams\_adm.RECOVER\_OPERATION(v\_script\_id,'PURGE');  
exception  
when no\_data\_found then  
DBMS\_OUTPUT.PUT\_LINe('no data found') ;  
when others then

**　　****4.5 ****全库****级****复制**

以上主要为大家介绍了pre\_instantiation\_setup/post\_instantiation\_setup过程在配置全库复制的方法，以下介绍dbms\_streams\_adm的maintain\_global过程如何配置stream全库复制方法，适用于10gR2及以后版本。

不支持sys/ system 用户的变更。

1.在stream进行配置前，需要做些准备工作

a 源库与目标库初始化参数的设置

<table style="border-collapse:collapse;padding:6pt;"> 
 <tbody> 
 <tr> 
 <td style="padding:0pt 6pt;background-color:rgb(243,243,243);">alter&nbsp;system&nbsp;set&nbsp;aq_tm_processes=4&nbsp;scope=spfile; alter&nbsp;system&nbsp;set&nbsp;job_queue_processes=5&nbsp;scope=spfile; alter&nbsp;system&nbsp;set&nbsp;global_names=true&nbsp;scope=spfile; alter&nbsp;system&nbsp;set&nbsp;streams_pool_size=51m&nbsp;scope=spfile;</td> 
 </tr> 
 </tbody> 
</table>

说明streams\_pool\_size在生产环境中最好>200m

b 源库与目标库tnsnames.ora配置

见4.1

c 源库与目标库复制管理员的创建

见4.1

d 源库与目标库创建互连的DBLINK

见4.1

e 源库与目标库必须处于归档模式

见4.1

f 源库与目标库必须创建directory

create directory dir\_DBA as 'D:/Stream/DBA';  
create directory dir\_DBA2 as 'D:/Stream/DBA2';

2.在源库执行MAINTAIN\_GLOBAL过程

begin

dbms\_streams\_adm.maintain\_global(

source\_directory\_object =>'dir\_DBA',

destination\_directory\_object =>'dir\_DBA2',

source\_database=>'DBA',

destination\_database =>'DBA2',

perform\_actions=>true,

include\_ddl=>true,

instantiation=>DBMS\_STREAMS\_ADM.INSTANTIATION\_FULL\_NETWORK

);

end;

说明:在执行maintain\_global时,源库与目标库必须创建directory,然后在源库执行, 目标库几乎什么都不用做,stream环境已经配置完毕。

[http_blog.csdn.net_tianlesoftware_archive_2009_10_18_4693470.aspx]: http://blog.csdn.net/tianlesoftware/archive/2009/10/18/4693470.aspx
[strmadmin_strmadmin_D]: mailto:strmadmin/strmadminpw@test96
[strmadmin_strmadmin_D 1]: mailto:strmadmin/strmadminpw@test99