Oracle 数据库复制常用脚本-ORACLE教程
转载自：互联网 作者：cd3c.com
您正在看的ORACLE教程是:Oracle 数据库复制常用脚本。
Oracle 数据库复制常用脚本
（石骁騑 2001年07月30日 17:30）
Oracle的数据复制是一个Oracle数据库产品中比较成熟的一项技术，它是整个分布式计算解决方案的一个重要组成部分。对于具有复制环境的数据库系统，和Oracle DBA一样，同样要有一个人来专门负责维护Oracle的数据复制问题，称之为Oracle Replication Administrator（Oracle复制管理员）。本文就Oracle数据复制中复制管理员经常关心的一些关于复制系统的问题，编写了不同的存储过程。当然，通过Oracle提供的复制管理器也可以达到这些目的，但在实际应用中，Oracle复制管理器具有不灵活，速度慢，同时我们不能对其查询结果进行随意控制等等的缺点。
一、查看Oracle8x延迟事务队列调用及调用个数
推（push）一个大的延迟事务（Deferred Transactions）队列是非常慢的。一个常见的问题就是一个事务中含有非常多的调用（calls）。如果系统检测到一个错误，如ora－01403（数据未找到错误），也就是我们常说的检测到冲突，而且没有冲突消除方法，写到deferror错误表和回滚事务的时间就会更长，事务中如果调用calls很多，则消耗在任何一个调用的时间就会以指数形式增长。
对于数据复制中每个事务的调用数Oracel强烈建议不超过50个。下面的存储过程提供了一个快速查看延迟事务队列中的事务列表以及每个事务中调用数的脚本。输出是以传输顺序排列的，这个顺序就是事务将要传播到主节点的顺序。这对于确定传播中的延迟以及挂起等是非常有帮助的。
在搭建Oracle数据复制环境中，有一个经验是值得注意的，那就是一定要设置冲突解决方案，即可使用Oracle系统提供的几种方案，也可以自己编写脚本来完成冲突处理。为什么这样说，一定要设置冲突解决方案，也许我们可以说，我们的复制环境是一个单项复制，不可能出现冲突现象。在这里我讲一个自己的亲身经历的例子来说明这个问题，在实际工作中，我搭建了一个具有15个节点的高级复制环境，一个主定义节点，14个主节点，其中14个主节点向主定义节点单向传递数据。一般来讲这种情况下不会出现冲突。但是在实际应用中，问题就出现了，其中几个节点在传输了一些数据后，就挂（hang）了起来。所有可能查找的原因到查了，始终发现不了问题的根结。最后发现是由于数据传播到远程节点后，出现了错误，而在该节点又没有设置冲突解决方案，同时出现错误的该事务又具有超过1000条的调用。其中有一条调用出错了，事务需要回滚，而这个在本地和远程节点间的回滚时间就会以几何基数增长。就出现了前面谈到的系统挂起（hang）的表现。这也就是说即是在根本不可能出现冲突的系统中，由于偶然的不定的错误进程，批量数据的处理以及没有考虑复制情况下的数据导入都可造成在传播过程中严重的性能问题，最严重的情况就是系统挂起，不能完成正常的复制工作。最简单和有效的办法就是在多路复制环境下设置一个系统确省的冲突处理方法来避免这种情况的发生。
下面这个存储过程就是在Oracle 8 环境下列出延迟事务队列中的事务和事务中调用个数的脚本，该脚本对Oracle 7 不支持，这是因为Oracle 8 和Oracle 7 的复制机制发生了变化。
存储过程调用方法：
在SQL/PLUS下，首先运行下面的设置，使存储过程的输出到屏幕上，
SET SERVEROUTPUT ON SIZE 200000
EXEC P_LIST_TRANSACTIONS(ORA_SJJK);
其中，存储过程的参数as_destination为所要查看的事务传播到目的节点的延迟队列，为数据库联接（DBLINK）名。
如果我们看到一个事务具有很多的调用（超过50个），这个事务很可能就是造成延迟事务队列推过程延迟甚至是挂起的原因。
附：存储过程脚本：下载该脚本
CREATE OR REPLACE PROCEDURE REPADMIN.P_LIST_TRANSACTION(as_destination in VARCHAR2) IS
local_node VARCHAR2(128);
remote_node VARCHAR2(128);
last_scn NUMBER;
last_tid VARCHAR2(22);
last_tdb VARCHAR2(128);
cnt NUMBER;
CURSOR c(last_delivered NUMBER, last_tid VARCHAR2, last_tdb VARCHAR2) IS
select cscn, enq_tid,
dscn, DECODE(c.recipient_key, 0, 'D', 'R')
from system.def$_aqcall c where
(c.cscn >= last_delivered)
and ((c.cscn > last_delivered) or (c.enq_tid > last_tid))
and (
( c.recipient_key = 0
and exists ( select /*+ index(cd def$_calldest_primary) */ null
from system.def$_calldest cd
where cd.enq_tid = c.enq_tid
and cd.dblink = remote_node ) )
or ( c.recipient_key > 0
and ( ( exists (
select null from system.repcat$_repprop P
where P.dblink = remote_node
and P.how = 1
and P.recipient_key = c.recipient_key
and ((P.delivery_order is NULL)
or (P.delivery_order < c.cscn))))
or ( exists
( select /*+ ordered use_nl(rp) */ null
from system.def$_aqcall cc, system.repcat$_repprop rp
where cc.enq_tid = c.enq_tid
and cc.cscn is null
and rp.recipient_key = cc.recipient_key
and rp.how = 1
and rp.dblink = remote_node
and ((rp.delivery_order is NULL)
or (rp.delivery_order < c.cscn)))))))
order by c.cscn, c.enq_tid;
BEGIN
SELECT NLS_UPPER(global_name) INTO local_node FROM global_name;
SELECT dblink INTO remote_node from deftrandest
WHERE dblink LIKE UPPER (as_destination||'%') AND ROWNUM < 2;
IF (remote_node IS NULL) THEN
DBMS_OUTPUT.PUT_LINE ('不能确定目标节点，输入参数有误!');
RETURN;
ELSE
DBMS_OUTPUT.PUT_LINE ('延迟事务目标节点为: '||remote_node);
DBMS_OUTPUT.PUT_LINE ('-------------------------------------------');
END IF;
SELECT last_delivered, last_enq_tid, dblink
INTO last_scn, last_tid, last_tdb
FROM system.def$_destination
WHERE dblink = remote_node;
FOR R IN C(last_scn,last_tid,last_tdb) LOOP
SELECT count(*) INTO cnt FROM system.def$_aqcall WHERE enq_
[1] [2] [3] [4] [5] 下一篇
