Oracle存储过程模板 oracle 存储过程的写法及简单实例
liebian365 2024-10-28 17:15 6 浏览 0 评论
开发存储过程模板
--存储过程，调用日志存储过程在第2个
CREATE OR REPLACE PROCEDURE SP_WA_BDXSRYGLB(V_ETLDATE IN VARCHAR2 --执行日期
,V_RETURN OUT NUMBER --0=成功，-1=失败
,V_MSG OUT VARCHAR2 --如果报错，返回报错原因及代码
)
--------------------------------------------------------------------
--功能名称 : 表关联表完整性数据跑批
--执行周期 : 平台实时调用
--创建日期 : 2020/12/30
--源表 : W_JGBDDZB;BDXSRYGLB
--目标表 : W_BDXSRYGLB
--功能描述 : 进行表的拆分处理
--版本历史 : 1.0
--作者 : PH
--------------------------------------------------------------------
IS
V_DATE_ID DATE := TO_DATE(V_ETLDATE, 'YYYYMMDD'); --执行日期
V_SCHEMA VARCHAR2(10) ; --目标表所属用户
V_PROC_START_FLAG VARCHAR2(10) ; --运行开始标记符 00：运行
V_PROC_STOP_FLAG VARCHAR2(10) ; --运行开始标记符 01：结束
V_LOG_RUN_PNAME VARCHAR2(40) ; --存储过程英文名称
V_LOG_RUN_STEP NUMBER ; --执行步数
V_LOG_RUN_TABNAME VARCHAR2(40) ; --目标表名
V_LOG_RUN_OPRTTYP VARCHAR2(10) ; --操作类型
V_LOG_RUN_MSG VARCHAR2(1024) ; --返回状态信息:执行步骤/步骤+报错信息
V_LOG_RUN_MSGFLAG VARCHAR2(10) ; --错误信息
V_LOG_RUN_COUNT NUMBER ; --总次数
V_LOG_RUN_BEGIN_TIME DATE ; --开始时间
V_LOG_RUN_RECDATE DATE ; --步骤执行时间戳
V_LOG_RUN_ETL_DATE DATE ; --ETL执行日期
BEGIN
V_SCHEMA := 'EAST' ;
V_PROC_START_FLAG := '00' ;
V_PROC_STOP_FLAG := '01' ;
V_LOG_RUN_PNAME := 'SP_WA_BDXSRYGLB' ;
V_LOG_RUN_TABNAME := 'W_BDXSRYGLB' ;
V_LOG_RUN_OPRTTYP := '' ;
V_LOG_RUN_ETL_DATE := TO_DATE(V_ETLDATE,'YYYYMMDD') ;
V_LOG_RUN_BEGIN_TIME := SYSDATE ;
--插入存储过程运行日志
ETL.SP_DMD_PROCEDURE_LOG(V_DATE_ID ,V_SCHEMA ,V_LOG_RUN_PNAME ,V_PROC_START_FLAG);
--启用oracle并行
EXECUTE IMMEDIATE 'ALTER SESSION ENABLE PARALLEL DML';
EXECUTE IMMEDIATE 'ALTER SESSION FORCE PARALLEL DML PARALLEL 16';
EXECUTE IMMEDIATE 'ALTER SESSION FORCE PARALLEL QUERY PARALLEL 16';
V_LOG_RUN_STEP := 1 ;
V_LOG_RUN_BEGIN_TIME := SYSDATE ;
V_LOG_RUN_OPRTTYP := 'DELETE';
-----------------------------------------/STEP-1:删除当前批次数据/------------------------------
DELETE FROM W_BDXSRYGLB T WHERE T.SJBSPCH = V_ETLDATE;
V_LOG_RUN_COUNT := SQL%ROWCOUNT ;
V_LOG_RUN_MSG := '执行STEP' || V_LOG_RUN_STEP || '成功';
V_LOG_RUN_RECDATE := SYSDATE ;
V_LOG_RUN_MSGFLAG := 'SUCCESS' ;
ETL.SP_DMD_PROCEDURE_STEP_LOG(V_LOG_RUN_PNAME --程序名称
,V_LOG_RUN_STEP --执行步数
,V_LOG_RUN_TABNAME --表名称
,V_LOG_RUN_OPRTTYP --数据操作类型 DELETE=删除 INSERT=新增 UPDATE=更新 SP=调用存储
,V_LOG_RUN_MSG --信息描述
,V_LOG_RUN_MSGFLAG --信息标志 FAILED=错误标识 SUCCESS=正常标志
,V_LOG_RUN_COUNT --记录条数
,V_LOG_RUN_BEGIN_TIME --开始时间
,V_LOG_RUN_RECDATE --运行日志时间
,V_LOG_RUN_ETL_DATE) --数据日期
;
COMMIT;
V_LOG_RUN_STEP := 2 ;
V_LOG_RUN_BEGIN_TIME := SYSDATE ;
V_LOG_RUN_OPRTTYP := 'INSERT';
-----------------------------------------/STEP-2:插入完整关联表数据/------------------------------------
INSERT INTO W_BDXSRYGLB(
LSH --流水号
,BXJGDM --保险机构代码
,BXJGMC --保险机构名称
,XSRYDM --销售人员代码
,XSRYXM --销售人员姓名
,YYXSRYDM --银邮销售人员代码
,YYXSRYXM --银邮销售人员姓名
)SELECT/*+parallel(8)*/
T.LSH --流水号
,T.BXJGDM --保险机构代码
,T.BXJGMC --保险机构名称
,T.XSRYDM --销售人员代码
,T.XSRYXM --销售人员姓名
,T.YYXSRYDM --银邮销售人员代码
FROM D0508_BDXSRYGLB T;
V_LOG_RUN_COUNT := SQL%ROWCOUNT ;
V_LOG_RUN_MSG := '执行STEP' || V_LOG_RUN_STEP || '成功';
V_LOG_RUN_RECDATE := SYSDATE ;
V_LOG_RUN_MSGFLAG := 'SUCCESS' ;
ETL.SP_DMD_PROCEDURE_STEP_LOG(V_LOG_RUN_PNAME --程序名称
,V_LOG_RUN_STEP --执行步数
,V_LOG_RUN_TABNAME --表名称
,V_LOG_RUN_OPRTTYP --数据操作类型
,V_LOG_RUN_MSG --信息描述
,V_LOG_RUN_MSGFLAG --信息标志 failed-错误标识 success-正常标志
,V_LOG_RUN_COUNT --记录条数
,V_LOG_RUN_BEGIN_TIME --开始时间
,V_LOG_RUN_RECDATE --运行日志时间
,V_LOG_RUN_ETL_DATE) --数据日期
;
COMMIT;
V_RETURN := 0 ;
YDETL.SP_DMD_PROCEDURE_LOG(V_DATE_ID, V_SCHEMA, V_LOG_RUN_PNAME, V_PROC_STOP_FLAG);
-----------------------------------------------/异常处理/-----------------------------------------
EXCEPTION
WHEN OTHERS THEN
ROLLBACK ;
V_LOG_RUN_MSG := 'STEP =' || V_LOG_RUN_STEP || ',ORAERROR = ' || SQLCODE || ',' || SQLERRM(SQLCODE);
V_LOG_RUN_RECDATE := SYSDATE ;
V_LOG_RUN_MSGFLAG := 'FAILED' ;
ETL.SP_DMD_PROCEDURE_STEP_LOG(V_LOG_RUN_PNAME --程序名称
,V_LOG_RUN_STEP --执行步数
,V_LOG_RUN_TABNAME --表名称
,V_LOG_RUN_OPRTTYP --数据操作类型
,V_LOG_RUN_MSG --信息描述
,V_LOG_RUN_MSGFLAG --信息标志 failed-错误标识 success-正常标志
,V_LOG_RUN_COUNT --记录条数
,V_LOG_RUN_BEGIN_TIME --开始时间
,V_LOG_RUN_RECDATE --运行日志时间
,V_LOG_RUN_ETL_DATE) --数据日期
;
V_RETURN := -1 ;
V_MSG := V_LOG_RUN_MSG;
ETL.SP_DMD_PROCEDURE_LOG(V_DATE_ID, V_SCHEMA, V_LOG_RUN_PNAME, V_PROC_STOP_FLAG);
END;
日志存储过程和建表语句
--建总日志表**************************************************************
create table ETL.DMD_PROCEDURE_LOG
(
run_etl_date DATE,
user_name VARCHAR2(30),
run_pname VARCHAR2(60),
run_status VARCHAR2(20),
run_begin_time DATE,
run_recdate DATE,
run_sql_code INTEGER,
run_sql_errm VARCHAR2(1000)
)
--建步骤日志表**************************************************************
create table ETL.DMD_PROCEDURE_STEP_LOG
(
run_pname VARCHAR2(200 CHAR),
run_step VARCHAR2(20 CHAR),
run_tabname VARCHAR2(200 CHAR),
run_oprttyp VARCHAR2(20 CHAR),
run_msg VARCHAR2(500 CHAR),
run_msgflag VARCHAR2(20 CHAR),
run_count INTEGER,
run_recdate DATE,
run_etl_date DATE,
run_begin_time DATE
)
--日志存储过程**************************************************************
CREATE OR REPLACE PROCEDURE ETL.SP_DMD_PROCEDURE_LOG(P_WORK_DATE DATE,
P_USER_NAME VARCHAR2,
P_PROCEDURE_NAME VARCHAR2,
P_PHASE_FLAG VARCHAR2 DEFAULT '00')
/*--------------------------------------------------------------------
--功能名称 : ETL运行日志记录
--执行周期 : 天
--创建日期 : 2019/1/30
--数据来源 :其他程序传参
--目标表 :DMD_PROCEDURE_LOG
--功能描述 :记录ETL存储过程运行日志
--处理逻辑： :
--版本历史 :
--------------------------------------------------------------------
--作者 ： GHC 日期 版本号 说明
--表中文名: ETL运行日志记录 2045/1/30 1.0 稳定版
--------------------------------------------------------------------
--定义存储过程信息*/
/*
参数列表：
P_WORK_DATE: 批次日期
P_PROCEDURE_NAME: 存储过程名称
P_PROC_FLAG: 运行阶段标记符【00：开始；01：结束】
*/
IS
V_NOW_TIME DATE;
V_ETL_DATE DATE;
V_USER_NAME VARCHAR2(30);
V_PROC_NAME VARCHAR2(2000);
V_SQL_CODE INTEGER;
V_SQL_ERRM VARCHAR2(1000);
BEGIN
V_SQL_CODE := SQLCODE;
V_SQL_ERRM := SUBSTR(SQLERRM, 1, 1000);
V_NOW_TIME := SYSDATE;
V_ETL_DATE := TRUNC(P_WORK_DATE, 'DD');
V_USER_NAME := UPPER(P_USER_NAME);
V_PROC_NAME := UPPER(P_PROCEDURE_NAME);
IF P_PHASE_FLAG = '00' THEN
DELETE FROM DMD_PROCEDURE_LOG A
WHERE A.RUN_ETL_DATE = V_ETL_DATE
AND A.USER_NAME = V_USER_NAME
AND A.RUN_PNAME = V_PROC_NAME
AND A.RUN_SQL_CODE = 0;
COMMIT;
INSERT INTO DMD_PROCEDURE_LOG
(RUN_ETL_DATE,
USER_NAME,
RUN_PNAME,
RUN_STATUS,
RUN_BEGIN_TIME,
RUN_RECDATE,
RUN_SQL_CODE,
RUN_SQL_ERRM)
VALUES
(V_ETL_DATE,
V_USER_NAME,
V_PROC_NAME,
'RUNNING',
V_NOW_TIME,
NULL,
NULL,
NULL);
COMMIT;
ELSIF P_PHASE_FLAG = '01' THEN
IF V_SQL_CODE = 0 THEN
UPDATE DMD_PROCEDURE_LOG A
SET A.RUN_STATUS = 'SUCCESS',
A.RUN_RECDATE = V_NOW_TIME,
A.RUN_SQL_CODE = V_SQL_CODE,
A.RUN_SQL_ERRM = V_SQL_ERRM
WHERE A.RUN_ETL_DATE = V_ETL_DATE
AND A.USER_NAME = V_USER_NAME
AND A.RUN_PNAME = V_PROC_NAME
AND A.RUN_STATUS = 'RUNNING';
COMMIT;
ELSE
UPDATE DMD_PROCEDURE_LOG A
SET A.RUN_STATUS = 'FAILED',
A.RUN_RECDATE = V_NOW_TIME,
A.RUN_SQL_CODE = V_SQL_CODE,
A.RUN_SQL_ERRM = V_SQL_ERRM
WHERE A.RUN_ETL_DATE = V_ETL_DATE
AND A.USER_NAME = V_USER_NAME
AND A.RUN_PNAME = V_PROC_NAME
AND A.RUN_STATUS = 'RUNNING';
COMMIT;
-- 如果不想继续抛出异常，则可以注释该行代码
--RAISE_APPLICATION_ERROR(-20000,V_SQL_ERRM);
END IF;
END IF;
--如果是EAST存储过程，还需要往EAST日志表中增加执行结果
IF V_USER_NAME = 'EAST' THEN
/* SELECT COUNT(1) INTO V_COUNT FROM ETL.DMD_PROCEDURE_LOG A
WHERE A.RUN_ETL_DATE = V_ETL_DATE
AND A.RUN_PNAME = V_PROC_NAME;
IF V_COUNT = 0 THEN
--RETURN;
V_RUN_STATUS := '未执行';
ELSE
SELECT DECODE(RUN_STATUS, 'SUCCESS', '通过', '不通过') INTO V_RUN_STATUS
FROM ETL.DMD_PROCEDURE_LOG A
WHERE A.RUN_ETL_DATE = V_ETL_DATE
AND A.RUN_PNAME = V_PROC_NAME;
END IF;
V_SQL := ' INSERT INTO EAST.L_FLOW_LOG (ID,TAR_TAB_NM,DATA_DATE,OBJECT_TYPE,USER_ID,BEGIN_TIME,END_TIME,RESULT)
SELECT SYS_GUID(),'
||V_TAB_NAME||',
RUN_ETL_DATE,
''20'',
''ETL'',
RUN_BEGIN_TIME,
RUN_RECDATE,'
||V_RUN_STATUS||'
FROM ETL.DMD_PROCEDURE_LOG T
WHERE T.RUN_ETL_DATE = ' ||V_ETL_DATE||
' AND T.RUN_PNAME = ' || V_PROC_NAME ;
DBMS_OUTPUT.PUT_LINE(V_SQL);
EXECUTE IMMEDIATE V_SQL;
--END IF;*/
/* INSERT INTO L_FLOW_LOG
(ID,
TAR_TAB_NM,
DATA_DATE,
OBJECT_TYPE,
USER_ID,
BEGIN_TIME,
END_TIME,
RESULT,
DESC_)
SELECT SYS_GUID() AS ID,
REPLACE(RUN_PNAME, 'SP_', '') AS TAR_TAB_NM,
RUN_ETL_DATE AS DATA_DATE,
'20' AS OBJECT_TYPE,
'ETL' AS USER_ID,
RUN_BEGIN_TIME AS BEGIN_TIME,
RUN_RECDATE AS END_TIME,
DECODE(RUN_STATUS, 'SUCCESS', '通过', '不通过') AS RESULT,
REPLACE(RUN_PNAME, 'SP_', '') || '-' ||
TO_CHAR(RUN_ETL_DATE, 'YYYYMMDD') || '-采集任务执行' ||
DECODE(RUN_STATUS, 'SUCCESS', '通过', '不通过') AS DESC_
FROM DMD_PROCEDURE_LOG T
WHERE T.RUN_ETL_DATE = V_ETL_DATE
AND T.RUN_PNAME = V_PROC_NAME;*/
COMMIT;
END IF;
END;
/
---------步骤存储过程********************************
CREATE OR REPLACE PROCEDURE ETL.SP_DMD_PROCEDURE_STEP_LOG
(
V_LOG_RUN_PNAME VARCHAR2 DEFAULT NULL,
V_LOG_RUN_STEP NUMBER DEFAULT 0,
V_LOG_RUN_TABNAME VARCHAR2 DEFAULT NULL,
V_LOG_RUN_OPRTTYP VARCHAR2 DEFAULT NULL,
V_LOG_RUN_MSG VARCHAR2 DEFAULT NULL,
V_LOG_RUN_MSGFLAG VARCHAR2 DEFAULT NULL,
V_LOG_RUN_COUNT NUMBER DEFAULT 0,
V_LOG_RUN_BEGIN_TIME DATE DEFAULT NULL,
V_LOG_RUN_RECDATE DATE DEFAULT NULL,
V_LOG_RUN_ETL_DATE DATE DEFAULT NULL
) IS
/*--------------------------------------------------------------------
--功能名称 : ETL分步骤运行日志记录
--执行周期 : 天
--创建日期 : 2045/1/30
--数据来源 :其他程序传参
--目标表 :DMD_PROCEDURE_STEP_LOG
--功能描述 :记录ETL存储过程运行分步骤日志
--处理逻辑： :
--版本历史 :
--------------------------------------------------------------------
--作者 ： GHC 日期 版本号 说明
--表中文名: ETL分步骤运行日志记录 2045/1/30 1.0 稳定版
--------------------------------------------------------------------
--定义存储过程信息*/
BEGIN
--获取日志参数信息
DELETE FROM DMD_PROCEDURE_STEP_LOG T
WHERE T.RUN_PNAME=V_LOG_RUN_PNAME
AND (T.RUN_ETL_DATE=V_LOG_RUN_ETL_DATE OR T.RUN_ETL_DATE IS NULL)
AND (T.RUN_STEP = V_LOG_RUN_STEP OR T.RUN_STEP IS NULL);
COMMIT;
--插入日志参数到系统运行日志信息表
INSERT INTO DMD_PROCEDURE_STEP_LOG( RUN_PNAME --程序名称
,RUN_STEP --执行步
,RUN_TABNAME --表名称
,RUN_OPRTTYP --数据操作类型
,RUN_MSG --信息描述
,RUN_MSGFLAG --信息标志 failed-错误标志 success-正常标志
,RUN_COUNT --记录条数
,RUN_BEGIN_TIME --开始时间
,RUN_RECDATE --运行日志时间
,RUN_ETL_DATE --数据日期
)
VALUES(
V_LOG_RUN_PNAME
,V_LOG_RUN_STEP
,V_LOG_RUN_TABNAME
,V_LOG_RUN_OPRTTYP
,V_LOG_RUN_MSG
,V_LOG_RUN_MSGFLAG
,V_LOG_RUN_COUNT
,V_LOG_RUN_BEGIN_TIME
,V_LOG_RUN_RECDATE
,V_LOG_RUN_ETL_DATE
);
--IF SQLCODE = 0 THEN
--成功 提交
COMMIT;
--ELSE
--失败 回滚
--RUN_MSG:='执行失败'||'ORAERROR = '||SQLCODE||','||SQLERRM(SQLCODE);
-- ROLLBACK;
--end if ;
end SP_DMD_PROCEDURE_STEP_LOG;
/
相关推荐
- 快递查询教程，批量查询物流，一键管理快递
-
作为商家，每天需要查询许许多多的快递单号，面对不同的快递公司，有没有简单一点的物流查询方法呢？小编的回答当然是有的，下面随小编一起来试试这个新技巧。需要哪些工具？安装一个快递批量查询高手快递单号怎么快...
- 一键自动查询所有快递的物流信息 支持圆通、韵达等多家快递
-
对于各位商家来说拥有一个好的快递软件，能够有效的提高自己的工作效率，在管理快递单号的时候都需要对单号进行表格整理，那怎么样能够快速的查询所有单号信息，并自动生成表格呢？1、其实方法很简单，我们不需要一...
- 快递查询单号查询，怎么查物流到哪了
-
输入单号怎么查快递到哪里去了呢？今天小编给大家分享一个新的技巧，它支持多家快递，一次能查询多个单号物流，还可对查询到的物流进行分析、筛选以及导出，下面一起来试试。需要哪些工具?安装一个快递批量查询高手...
- 3分钟查询物流，教你一键批量查询全部物流信息
-
很多朋友在问，如何在短时间内把单号的物流信息查询出来，查询完成后筛选已签收件、筛选未签收件，今天小编就分享一款物流查询神器，感兴趣的朋友接着往下看。第一步，运行【快递批量查询高手】在主界面中点击【添...
- 快递单号查询，一次性查询全部物流信息
-
现在各种快递的查询方式，各有各的好，各有各的劣，总的来说，还是有比较方便的。今天小编就给大家分享一个新的技巧，支持多家快递，一次能查询多个单号的物流，还能对查询到的物流进行分析、筛选以及导出，下面一起...
- 快递查询工具，批量查询多个快递快递单号的物流状态、签收时间
-
最近有朋友在问，怎么快速查询单号的物流信息呢？除了官网，还有没有更简单的方法呢？小编的回答当然是有的，下面一起来看看。需要哪些工具？安装一个快递批量查询高手多个京东的快递单号怎么快速查询？进入快递批量...
- 快递查询软件，自动识别查询快递单号查询方法
-
当你拥有多个快递单号的时候，该如何快速查询物流信息？比如单号没有快递公司时，又该如何自动识别再去查询呢？不知道如何操作的宝贝们，下面随小编一起来试试。需要哪些工具？安装一个快递批量查询高手快递单号若干...
- 教你怎样查询快递查询单号并保存物流信息
-
商家发货，快递揽收后，一般会直接手动复制到官网上一个个查询物流，那么久而久之，就会觉得查询变得特别繁琐，今天小编给大家分享一个新的技巧，下面一起来试试。教程之前，我们来预览一下用快递批量查询高手...
- 简单几步骤查询所有快递物流信息
-
在高峰期订单量大的时候，可能需要一双手当十双手去查询快递物流，但是由于逐一去查询，效率极低，追踪困难。那么今天小编给大家分享一个新的技巧，一次能查询多个快递单号的物流，下面一起来学习一下，希望能给大家...
- 物流单号查询，如何查询快递信息，按最后更新时间搜索需要的单号
-
最近有很多朋友在问，如何通过快递单号查询物流信息，并按最后更新时间搜索出需要的单号呢？下面随小编一起来试试吧。需要哪些工具？安装一个快递批量查询高手快递单号若干怎么快速查询？运行【快递批量查询高手】...
- 连续保存新单号功能解析，导入单号查询并自动识别批量查快递信息
-
快递查询已经成为我们日常生活中不可或缺的一部分。然而，面对海量的快递单号，如何高效、准确地查询每一个快递的物流信息，成为了许多人头疼的问题。幸运的是，随着科技的进步，一款名为“快递批量查询高手”的软件...
- 快递查询教程，快递单号查询，筛选更新量为1的单号
-
最近有很多朋友在问，怎么快速查询快递单号的物流，并筛选出更新量为1的单号呢？今天小编给大家分享一个新方法，一起来试试吧。需要哪些工具？安装一个快递批量查询高手多个快递单号怎么快速查询？运行【快递批量查...
- 掌握批量查询快递动态的技巧，一键查找无信息记录的两种方法解析
-
在快节奏的商业环境中，高效的物流查询是确保业务顺畅运行的关键。作为快递查询达人，我深知时间的宝贵，因此，今天我将向大家介绍一款强大的工具——快递批量查询高手软件。这款软件能够帮助你批量查询快递动态，一...
- 从复杂到简单的单号查询，一键清除单号中的符号并批量查快递信息
-
在繁忙的商务与日常生活中，快递查询已成为不可或缺的一环。然而，面对海量的单号，逐一查询不仅耗时费力，还容易出错。现在，有了快递批量查询高手软件，一切变得简单明了。只需一键，即可搞定单号查询，一键处理单...
- 物流单号查询，在哪里查询快递
-
如果在快递单号多的情况，你还在一个个复制粘贴到官网上手动查询，是一件非常麻烦的事情。于是乎今天小编给大家分享一个新的技巧，下面一起来试试。需要哪些工具？安装一个快递批量查询高手快递单号怎么快速查询？...
欢迎 你 发表评论:
- 一周热门
- 最近发表
- 标签列表
-
- wireshark怎么抓包 (75)
- qt sleep (64)
- cs1.6指令代码大全 (55)
- factory-method (60)
- sqlite3_bind_blob (52)
- hibernate update (63)
- c++ base64 (70)
- nc 命令 (52)
- wm_close (51)
- epollin (51)
- sqlca.sqlcode (57)
- lua ipairs (60)
- tv_usec (64)
- 命令行进入文件夹 (53)
- postgresql array (57)
- statfs函数 (57)
- .project文件 (54)
- lua require (56)
- for_each (67)
- c#工厂模式 (57)
- wxsqlite3 (66)
- dmesg -c (58)
- fopen参数 (53)
- tar -zxvf -c (55)
- 速递查询 (52)