作为一个Oracle数据库治理员,会碰到这样的数据库治理需求,停止或者打开当前用户(模式)下所有表的约束条件和触发器。这在数据库的合并以及对数据库系统的代码表中某些代码的修改时需要做的工作之一。
我们来看这样一种实际数据库工作业务需求,这在目前的许多应用中是非常实际的。某地区银行数据,目前采用市级数据集中,随着计算机网络技术的不断提高以及对服务水平的要求,提出了省级乃至国家级的数据集中。除了应用需要修改以外,对于数据库治理员来讲,最重要的工作就是对各地分散治理的数据库统一集中到一个或者几个集中数据库中。此时就需要整理以前各地各自为政的代码表为一个统一的代码表以及数据库的最后集中合并。
对Oracle数据库治理员来讲,这样的数据维护工作,在更新代码表中代码或者合并数据之前,首先要作的工作就是将系统中某用户下所有的外键或触发器停止,处理完数据后,再打开这些关闭的外键和触发器。针对这样的工作需求,本文给出了下面两个SQL脚本:(1) 系统中某模式或用户下外键或者触发器的治理脚本;(2) 外键错误自动查找脚本。下面就来具体介绍这两个脚本。
一、约束治理脚本
该脚本可用来治理当前登录用户下的所有外键和触发器的打开和关闭,此处没有处理主键和唯一约束条件,该脚本稍加修改就可以处理主键和唯一约束条件,但这里建议最好不要在随意停止主键或唯一约束条件后,进行数据维护。
脚本运行方法如下(SQL/PLUS):
SQL> SET SERVEROUTPUT ON; SQL> ALTER SESSION SET NLS_DATE_FORMAT='YYYY-MM-DD HH24:MI:SS'; SQL> EXEC P_ALTERCONS(as_alter); 其中,参数as_alter只能是“ENABLE”或者“DISABLE”,否则程序提示错误。当参数为“ENABLE”时,表示将当前模式下所有的外键和触发器打开,相反“DISABLE”就是将当前模式下所有的外键和触发器关闭。
附存储过程脚本:
CREATE OR REPLACE PROCEDURE P_ALTERCONS( AS_ALTER VARCHAR2) AS v_CursorID INTEGER; v_StrCon VARCHAR2(300); v_StrTri VARCHAR2(300); v_FkNum NUMBER :=0; v_TriNum NUMBER :=0; v_sqlcode NUMBER; v_sqlerrm VARCHAR2(600); CURSOR C_CON IS SELECT * FROM USER_CONSTRAINTS WHERE CONSTRAINT_TYPE='R'; R_CON C_CON%ROWTYPE; CURSOR c_trigger IS SELECT TRIGGER_NAME,STATUS FROM user_triggers; notfound BOOLEAN; BEGIN DBMS_OUTPUT.PUT_LINE('BEGIN TIME: 'to_char(sysdate)); 判定输入参数是否为DISABLE或者是ENABLE,假如是的话,就继续处理,否则退出过程,给出提示 IF (UPPER(AS_ALTER) = 'DISABLE' OR UPPER(AS_ALTER) = 'ENABLE') THEN OPEN C_CON;
当前用户下外键的处理 ENABLE或者 DISABLE
v_CursorID := DBMS_SQL.OPEN_CURSOR; LOOP FETCH C_CON into R_CON; notfound:=C_CON%NOTFOUND; EXIT WHEN notfound; begin IF (UPPER(AS_ALTER)='DISABLE' AND R_CON.STATUS='ENABLED' OR UPPER(AS_ALTER)='ENABLE' AND R_CON.STATUS='DISABLED') THEN v_StrCon := 'ALTER TABLE 'R_CON.owner'.'R_CON.table_name' ' UPPER(as_alter) ' CONSTRAINT 'R_CON.constraint_name; DBMS_SQL.PARSE( v_CursorID, v_StrCon, DBMS_SQL.V7); v_FkNum :=v_FkNum+1; END IF; EXCEPTION WHEN OTHERS THEN v_sqlcode := SQLCODE; v_sqlerrm := SUBSTR(SQLERRM,1,600); DBMS_OUTPUT.PUT_LINE('ERROR: '' 'V_SQLERRM); -- 找出错误原因 IF (v_sqlcode = -2298) THEN p_con_err(R_CON.CONSTRAINT_NAME); END IF; END; END LOOP; CLOSE C_CON; DBMS_OUTPUT.PUT_LINE('====== Foreign Keys were 'as_alter', total 'to_char(v_FkNum)' ====='); -- 当前用户下触发器的处理 ENABLE或者 DISABLE FOR T_TRIGGER IN C_TRIGGER LOOP BEGIN IF (UPPER(AS_ALTER)='DISABLE' AND T_TRIGGER.STATUS='ENABLED' OR UPPER(AS_ALTER)='ENABLE' AND T_TRIGGER.STATUS='DISABLED') THEN v_StrTri := 'ALTER TRIGGER 'T_TRIGGER.TRIGGER_name ' 'UPPER(as_alter); DBMS_SQL.PARSE( v_CursorID, v_StrTri, DBMS_SQL.V7); v_TriNum :=v_TriNum+1; END IF; EXCEPTION WHEN OTHERS THEN v_sqlcode := SQLCODE; v_sqlerrm := SUBSTR(SQLERRM,1,600); DBMS_OUTPUT.PUT_LINE('ERROR: 'V_SQLCODE' 'V_SQLERRM); END; END LOOP; DBMS_OUTPUT.PUT_LINE('====== Triggers were 'as_alter', total 'to_char(v_TriNum)' ====='); DBMS_SQL.CLOSE_CURSOR(v_CursorID); ELSE -- 输入参数不正确 DBMS_OUTPUT.PUT_LINE('ERROR:输入参数不正确,参数为ENABLE或者DISABLE!'); END IF; DBMS_OUTPUT.PUT_LINE('END TIME: 'to_char(sysdate)); END; / 二、约束错误自动查找脚本
一般,数据库治理员在对数据进行维护时,如新数据的导入前,首先要关闭所有的外键和触发器,数据成功导入后,再打开导入前关闭的外键和触发器。这时经常会碰到错误号为ORA-02298的“未找到父项要害字”的错误。该错误的原因就是数据库表中出现了不能满足外键约束条件的记录。这里,另外给出了一个脚本(P_CON_ERR)用来自动查找造成这类错误的原因,也就是找出不满足外键约束条件的字段值。
该存储过程可单独运行,同时在前面介绍的存储过程P_ALTERCONS中也进行了调用,在存储过程P_ALTERCONS中,可以看到在打开外键时,假如出现错误号为ORA-02298的错误,就调用该存储过程,自动查找造成外键不能启动的原因。
下面是单独运行该存储过程的例子,在SQL/PLUS环境下:
SQL> SET SERVEROUTPUT ON; SQL> EXEC P_CON_ERR('FK_SB_HJJL_RELATION__SB_PZXH'); 外键错误情况 ============ NSRNM,PZLXDM,PZXH ----------------- 190321058, 900, 13546 777777775, 108, 17526 777777775, 108, 17528 777777775, 108, 17531 777777775, 108, 17546
PL/SQL过程已成功完成。
其中,FK_SB_HJJL_RELATION__SB_PZXH为出现错误的外键名称。
附存储过程脚本:
CREATE OR REPLACE PROCEDURE P_CON_ERR(as_constraint_name varchar2) AS v_CursorID INTEGER; V_CONSNAME VARCHAR2(30); V_TABLE_NAME VARCHAR2(30); V_RTABLE_NAME VARCHAR2(30); V_COLUMN VARCHAR2(100); v_Str VARCHAR2(600); TYPE t_col_value IS TABLE OF VARCHAR2(30) INDEX BY BINARY_INTEGER; v_Col_Val t_col_value; v_RET NUMBER; v_NUM NUMBER; i BINARY_INTEGER; V_WHERE VARCHAR2(600); V_CAUSE VARCHAR2(200); CURSOR C_COL_NAME(V_CON_NAME VARCHAR2) IS SELECT * FROM USER_CONS_COLUMNS WHERE CONSTRAINT_NAME=V_CON_NAME; BEGIN V_CONSNAME := TRIM(UPPER(as_constraint_name)); -- 约束名称 v_num :=0; FOR T_COL_NAME IN C_COL_NAME(V_CONSNAME) LOOP IF (V_NUM = 0) THEN V_COLUMN :=T_COL_NAME.COLUMN_NAME; V_WHERE :='A.'T_COL_NAME.COLUMN_NAME'= B.'T_COL_NAME.COLUMN_NAME; ELSE V_COLUMN :=V_COLUMN','T_COL_NAME.COLUMN_NAME; V_WHERE :=V_WHERE' AND ''A.'T_COL_NAME.COLUMN_NAME'= B.'T_COL_NAME.COLUMN_NAME; END IF; V_NUM :=V_NUM+1; END LOOP; FOR I IN 1..V_NUM LOOP V_COL_VAL(I) :=''; END LOOP; SELECT DISTINCT TABLE_NAME INTO V_TABLE_NAME FROM USER_CONS_COLUMNS WHERE CONSTRAINT_NAME = V_CONSNAME; -- 找到被引用的表名称 SELECT TABLE_NAME INTO V_RTABLE_NAME FROM USER_CONSTRAINTS WHERE CONSTRAINT_NAME IN (SELECT R_CONSTRAINT_NAME FROM USER_CONSTRAINTS WHERE CONSTRAINT_NAME = V_CONSNAME); DBMS_OUTPUT.PUT_LINE('外键错误情况'); DBMS_OUTPUT.PUT_LINE('============'); DBMS_OUTPUT.PUT_LINE(v_column); DBMS_OUTPUT.PUT_LINE(RPAD('-',LENGTH(V_COLUMN),'-')); v_CursorID := DBMS_SQL.OPEN_CURSOR; V_STR := 'SELECT DISTINCT 'V_COLUMN' FROM 'V_TABLE_NAME' A WHERE NOT EXISTS ( SELECT NULL FROM ' V_RTABLE_NAME' B WHERE 'V_WHERE')'; DBMS_SQL.PARSE( v_CursorID, v_Str, DBMS_SQL.V7); FOR I IN 1..V_NUM LOOP DBMS_SQL.DEFINE_COLUMN(v_CursorID,I,v_COL_VAL(I),30); END LOOP; v_ret := DBMS_SQL.EXECUTE(v_CursorID); WHILE DBMS_SQL.FETCH_ROWS(v_CursorID) > 0 LOOP V_CAUSE :=''; FOR I IN 1..V_NUM LOOP DBMS_SQL.COLUMN_VALUE(v_CursorID,I,V_COL_VAL(I)); IF (I = 1) THEN V_CAUSE :=V_COL_VAL(I); ELSE V_CAUSE :=V_CAUSE', 'V_COL_VAL(I); END IF; END LOOP; DBMS_OUTPUT.PUT_LINE(V_CAUSE); END LOOP; DBMS_SQL.CLOSE_CURSOR(v_CursorID); END; /
|