shellはoracleストレージプロシージャを実行し、ストレージプロシージャの戻り値を取得します.
From: http://www.flatws.cn/article/program/oracle/2011-06-27/32316.html
同僚は1つの小さいetlスケジューリングをして、ストレージプロセスの実行状況を返してその後続の依存が実行するかどうかを制御する必要があります.本人はただストレージプロセスを実行するshellスクリプトを呼び出してストレージプロセスの出力パラメータを返して、具体的な制御プログラムを書いていません.この考え方で開発を続けると、それは小さなetlスケジューリングプログラムです.必要があれば私に連絡して、36026376、共同で研究して共同で進歩して、ははは
次に、各スクリプトについて説明します:(ex_produre.sh)
1.ストアド・プロシージャ・スクリプトの実行
a.ストレージプロセス(pdm_cust_act_behav_base)
同僚は1つの小さいetlスケジューリングをして、ストレージプロセスの実行状況を返してその後続の依存が実行するかどうかを制御する必要があります.本人はただストレージプロセスを実行するshellスクリプトを呼び出してストレージプロセスの出力パラメータを返して、具体的な制御プログラムを書いていません.この考え方で開発を続けると、それは小さなetlスケジューリングプログラムです.必要があれば私に連絡して、36026376、共同で研究して共同で進歩して、ははは
次に、各スクリプトについて説明します:(ex_produre.sh)
1.ストアド・プロシージャ・スクリプトの実行
#!/bin/bash
user_name=$1
user_pass=$2
produre_name=$3
statis_sign=$4
sql_str=`
sqlplus -S $user_name/$user_pass as sysdba <<EOF
set linesize 800;
set long 2048576;
set serveroutput on;
var oi_return number;
call $user_name.$produre_name($statis_sign,:oi_return);
select :oi_return from dual;
exit
EOF`
echo "$sql_str"|sed -e '4,/^$/!d;/^$/d'|
while read run_return
do
echo $run_return
done
#!/bin/bash
sh ex_produre.sh etl jiangtao pdm_cust_act_behav_base 201003 |grep -v OI_RETURN |grep -v -| while read vi_result
do
#this date
echo $vi_result
if [ $vi_result -eq 0 ]
then
echo "this produre is normal run "
else
echo "this produre is not normal run "
fi
donea.ストレージプロセス(pdm_cust_act_behav_base)
create or replace procedure pdm_cust_act_behav_base (is_month in varchar2, oi_return out number)
/** HEAD
* @name etl.pdm_cust_act_behav_base
* @caption ？？？？？？？？？？
* @type ？？？
* @parameter is_month in varchar2 ？？？？？？？YYYYMM
* @parameter oi_return out number ？？？？？？？？？0 ？？？-1 ？？
* @description ？？？？？？？？？？
* @target etl#tdm_cust_act_behav_base
* @source hwmk#tmm_ci_user_basic_m
* @middle
* @version 1.0
* @author
* @create-date
* @TODO ？
* @version
* @mender
* @modify_date
* @modify_desc
* @copyright
*/
-- ********************************************************************************
-- ？？？？: etl.pdm_cust_act_behav_base
-- ？？？？: ？？？？？？？？？？
-- ？？？？: is_month - ？？？？
-- ？？？？: oi_return - ？？？？？？？？？0 ？？？-1 ？？
-- ？？？？: hwmk.tmm_ci_user_basic_m
-- ？？？？: etl.tdm_cust_act_behav_base
-- ？？？？:
-- ？？？？:
-- ？？？？:
-- ？？？？: v1.0
-- ？？？？:
-- ？？？？:
-- ？？？？:
-- ？？？？:
-- ？？？？:
-- ********************************************************************************
is
vs_task_name varchar2(30); -- ？？？？
vs_table_name varchar2(30); -- ？？？
vs_message varchar2(200); -- ？？？？
vi_task_id integer; -- ？？id
vi_month integer; -- ？？？？
begin
vs_task_name := 'pdm_cust_act_behav_base';
vs_table_name := 'tdm_cust_act_behav_base';
-- ？？？？？？
etl.ps_log(vs_task_name, vs_table_name, is_month, 1, null, vi_task_id);
-- ？？: ？？？？？？？？？？
if (is_month is null) then
vs_message := '？？？？？？？？？？';
etl.ps_log(null, null, null, 3, vs_message, vi_task_id);
oi_return := -1;
return;
end if;
------------------------------------------------------------
-- ？？？？？？
vi_month := to_number(is_month);
------------------------------------------------------------
insert into etl.tdm_cust_act_behav_base
(
statis_month,
serv_id
)
select
vi_month,
15204669284
from dual
;
commit;
------------------------------------------------------------
-- ？？？？？？
etl.ps_log(null, null, null, 2, null, vi_task_id);
-- ？？？？
oi_return := 0;
return;
exception
when others then
-- ？？？？？？
vs_message := substr(sqlerrm, 1, 200);
-- ？？？？
rollback;
-- ？？？？？？
etl.ps_log(null, null, null, 3, vs_message, vi_task_id);
-- ？？？？
oi_return := -1;
return;
end;
/create or replace procedure ps_log
(
is_task_name in varchar2,
is_table_name in varchar2,
is_task_sign in varchar2,
ii_task_status in integer,
is_task_log in varchar2,
oi_task_id in out integer
)
-- ********************************************************************************
-- ？？？？: etl.ps_log
-- ？？？？: DW？？？？？？？？
-- ？？？？: is_task_name - ？？？？
-- is_table_name - ？？？？
-- is_task_sign - ？？？？, ？？？？？？？？？？？
-- ii_task_status - ？？？？, 1 ？？？？？, 2 ？？？？？？, 3 ？？？？？？
-- is_task_log - ？？？？, ？？？？[？？？？？]？[？？？？？？],
-- ？？？？[？？？？]
-- oi_task_id - ？？ID, ？？？2？3？？？？？？
-- ii_rowcount - ？？？
-- ？？？？: oi_task_id - ？？ID, ？？？1？？？？？？
-- ？？？？:
-- ？？？？: etl.ts_log
-- ？？？？:
-- ？？？？: ？？？
-- ？？？？: 2010-02-01
-- ？？？？: V1.0
-- ？？？？:
-- ？？？？:
-- ？？？？:
-- ？？？？:
-- ？？？？: ？？？？
-- ********************************************************************************
is
vs_err_msg varchar2(255); -- ？？？？？？
begin
if ii_task_status = 1 then
-- ？？？？？？？？？？？？
select etl.seq_dw_log.nextval
into oi_task_id
from dual;
insert into etl.ts_log
(
task_id, -- ？？ID
task_name, -- ？？？？
table_name, -- ？？？？
task_sign, -- ？？？？
start_time, -- ？？？？？？
end_time, -- ？？？？？？？？？？？？？
task_status, -- ？？？？
task_log -- ？？？？
)
values
(
oi_task_id,
is_task_name,
is_table_name,
is_task_sign,
sysdate,
null,
'1',
'？？？？？'
);
elsif ii_task_status = 2 then
-- ？？？？？？？？？？？？ID？？？？？？？？
update etl.ts_log
set end_time = sysdate,
task_status = '2',
task_log = '？？？？？？'
where task_id = oi_task_id;
else
-- ？？？？？？？？？？ID？？？？？？？？？？？？？
update etl.ts_log
set end_time = sysdate,
task_status = '3',
task_log = substr(is_task_log, 1, 200)
where task_id = oi_task_id;
end if;
commit;
-- ？？？？
return;
exception
-- ？？？？
when others then
-- ？？？？？？
vs_err_msg := substr(sqlerrm, 1, 200);
-- ？？？？
rollback;
-- ？？？？？？
dbms_output.put_line('etl.ps_log: ' || vs_err_msg);
-- ？？？？
return;
end;
/-- Create sequence
create sequence SEQ_DW_LOG
minvalue 1
maxvalue 999999999999999999999999999
start with 2731
increment by 1
cache 20;
create table TS_LOG
(
TASK_ID INTEGER,
TASK_NAME VARCHAR2(30),
TABLE_NAME VARCHAR2(30),
TASK_SIGN VARCHAR2(20),
START_TIME DATE,
END_TIME DATE,
TASK_STATUS VARCHAR2(1),
TASK_LOG VARCHAR2(200),
ROWCOUNT NUMBER
);
-- Create table
create table TDM_CUST_ACT_BEHAV_BASE
(
STATIS_MONTH NUMBER(10),
SERV_ID NUMBER(12)
);