Oracle ETL日志審計(jì)存儲(chǔ)過(guò)程示例

需求概述

在ETL中，為了方便跟蹤每個(gè)步驟的執(zhí)行情況，需要建立日志審計(jì)表來(lái)跟蹤以便后期的跟蹤與問(wèn)題問(wèn)題。本文就通過(guò)一個(gè)存儲(chǔ)過(guò)程來(lái)實(shí)現(xiàn)對(duì)存儲(chǔ)過(guò)程執(zhí)行異常的跟蹤(審計(jì))。

代碼實(shí)現(xiàn)?

-- 1 存儲(chǔ)過(guò)程ETL_TRACE跟蹤存儲(chǔ)過(guò)程執(zhí)行情況 /* 功能：用于記錄存儲(chǔ)過(guò)程運(yùn)行的日志 參數(shù)說(shuō)明:ownername 存儲(chǔ)過(guò)程的用戶名procname 存儲(chǔ)過(guò)程名stepname 步驟名errcode 錯(cuò)誤碼errtext 錯(cuò)誤內(nèi)容 */ CREATE OR REPLACE PROCEDURE ETL_TRACE (ownername in varchar2, procname in varchar2, stepname in varchar2, errcode in number, errtext in varchar2) AS begin--如果沒有異常發(fā)生，將ownername,procname,stepname參數(shù)寫入到日志表if (errcode = 0 or errtext is null)then-- 沒有錯(cuò)誤號(hào)， 直接設(shè)為 NULLinsert into ETL_LOGINFO( owner, procname, step,time, errorcode, errortext )values (ownername,procname,stepname, sysdate, '', '' );elseinsert into ETL_LOGINFO ( owner, procedure_name, step,time, errorcode, errortext )values (ownername,procname,stepname, sysdate, errcode, errtext );end if;commit; exceptionwhen others thenrollback; end;-- 2 存儲(chǔ)過(guò)程ETL_TRACE對(duì)應(yīng)的表結(jié)構(gòu)create table ETL_LOGINFO (owner VARCHAR2(50),procname VARCHAR2(100),step VARCHAR2(30),time DATE,errorcode VARCHAR2(100),errortext VARCHAR2(4000) ); comment on column ETL_LOGINFO.owneris '存儲(chǔ)過(guò)程調(diào)用用戶名'; comment on column ETL_LOGINFO.procnameis '存儲(chǔ)過(guò)程名'; comment on column ETL_LOGINFO.stepis '步驟標(biāo)記'; comment on column ETL_LOGINFO.timeis '調(diào)用時(shí)間'; comment on column ETL_LOGINFO.errorcodeis '錯(cuò)誤代碼'; comment on column ETL_LOGINFO.errortextis '錯(cuò)誤說(shuō)明';-- 3 其它存儲(chǔ)過(guò)程與日志審計(jì)過(guò)程ETL_TRACE結(jié)合使用偽代碼 CREATE OR REPLACE PROCEDURE P_PROCDEMO(INDATE IN VARCHAR2) ISERRCODE NUMBER DEFAULT 0;ERRTEXT VARCHAR2(300) DEFAULT NULL;OWNERNAME VARCHAR2(40) DEFAULT NULL; PROCNAME VARCHAR2(40) DEFAULT NULL; STEP VARCHAR2(6);EXCE EXCEPTION; BEGINSELECT T.USERNAME INTO OWNERNAME FROM USER_USERS T;PROCNAME := 'P_PROCDEMO';-- 日志記錄ETL_TRACE(OWNERNAME, PROCNAME, 'BEGIN', ERRCODE, ERRTEXT);-- 按日期清理數(shù)據(jù) DELETE FROM LOGICTAB WHERE sjrq = INDATE;COMMIT;--寫入數(shù)據(jù)到目標(biāo)表STEP := '00001';--業(yè)務(wù)邏輯(偽代碼)INSERT INTO LOGICTAB SELECT XX FROM TBL ... COMMIT;ETL_TRACE(OWNERNAME, PROCNAME, 'END', ERRCODE, ERRTEXT);STEP := '00002';-- 異常時(shí)記錄錯(cuò)誤到 EXCEPTIONWHEN OTHERS THENERRCODE := SQLCODE; --設(shè)置異常代碼ERRTEXT := SUBSTR('第'||STEP || '步錯(cuò)誤見:' || SQLERRM, 1, 250); --拼接出異常描述，方便根據(jù)存儲(chǔ)過(guò)程步驟診斷問(wèn)題。ROLLBACK; ETL_TRACE(OWNERNAME,PROCNAME,'ERROR',ERRCODE,ERRTEXT); END;

總結(jié)

以上是生活随笔為你收集整理的Oracle ETL日志审计存储过程示例的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。