DBA Data[Home] [Help]

APPS.AD_ZD_PARALLEL_EXEC dependencies on AD_ZD

Line 1: PACKAGE BODY AD_ZD_PARALLEL_EXEC as

1: PACKAGE BODY AD_ZD_PARALLEL_EXEC as
2: /* $Header: ADZDPEXB.pls 120.33.12020000.7 2013/05/21 08:52:29 seetsing ship $ */
3:
4:
5: /******************************************************************

Line 14: ad_zd.log(x_module, x_level, x_message);

10:
11: -- log shortcut
12: procedure LOG(X_MODULE varchar2, X_LEVEL varchar2, X_MESSAGE varchar2) is
13: begin
14: ad_zd.log(x_module, x_level, x_message);
15: end;
16:
17: -- error shortcut
18: procedure ERROR(X_MODULE varchar2, X_MESSAGE varchar2) is

Line 20: ad_zd.error(x_module, x_message);

16:
17: -- error shortcut
18: procedure ERROR(X_MODULE varchar2, X_MESSAGE varchar2) is
19: begin
20: ad_zd.error(x_module, x_message);
21: end;
22:
23: -- exec shortcut
24: procedure EXEC(X_SQL in varchar2, X_LOG_MOD in varchar2, X_IGNORE in boolean default false) is

Line 26: ad_zd.exec(x_sql, x_log_mod, x_ignore);

22:
23: -- exec shortcut
24: procedure EXEC(X_SQL in varchar2, X_LOG_MOD in varchar2, X_IGNORE in boolean default false) is
25: begin
26: ad_zd.exec(x_sql, x_log_mod, x_ignore);
27: end;
28:
29:
30:

Line 81: from ad_zd_ddl_handler

77:
78: select 'Y' into l_exist from dual
79: where exists
80: ( select null
81: from ad_zd_ddl_handler
82: where phase = x_phase
83: and dbms_lob.compare(sql_lob, x_sql_lob) = 0
84: and nvl(executed, 'N') <> 'S' );
85: return 'Y';

Line 99: return ad_zd_ddl_handler_ddl_s.nextval;

95: -- Procedure to generate next batch id
96: --
97: FUNCTION GET_NEXT_DDL_ID RETURN NUMBER as
98: begin
99: return ad_zd_ddl_handler_ddl_s.nextval;
100: end GET_NEXT_DDL_ID;
101:
102:
103:

Line 123: from ad_zd_ddl_handler

119: begin
120:
121: -- 1. Check failed (FATAL, ERROR, RUNNING) count.
122: select count(1) into l_failed_count
123: from ad_zd_ddl_handler
124: where (x_phase is null or phase = x_phase)
125: and executed in (c_job_status_failed, c_job_status_running)
126: and nvl(status, 'ERROR') <> c_job_status_warning_desc;
127:

Line 139: from ad_zd_ddl_handler

135: is
136: L_STATUS varchar2(1) := 'S';
137: begin
138: select executed into l_status
139: from ad_zd_ddl_handler
140: where ddl_id = x_ddl_id;
141:
142: return l_status;
143: exception

Line 183: from ad_zd_ddl_handler

179: is
180: L_NOT_EXECUTED_COUNT pls_integer;
181: begin
182: select count(1) into l_not_executed_count
183: from ad_zd_ddl_handler
184: where (x_phase is null or phase = x_phase)
185: and executed in (c_job_status_not_executed, c_job_status_running);
186:
187: return l_not_executed_count;

Line 199: update ad_zd_ddl_handler

195: C_MODULE varchar2(127) := c_package||'update_status_r_to_n';
196: begin
197: log(c_module, 'EVENT', 'Reset jobs from R (running) to N (not executed) for phase '||x_phase);
198:
199: update ad_zd_ddl_handler
200: set executed = c_job_status_not_executed,
201: execution_time = null
202: where (x_phase is null or phase= x_phase)
203: and executed = c_job_status_running;

Line 218: where object_name like 'AD_ZD%'

214: begin
215: for obj in
216: ( select owner, object_name
217: from dba_invalid_objects
218: where object_name like 'AD_ZD%'
219: and object_type like 'PACKAGE%' )
220: loop
221: log(c_module, 'STATEMENT', 'Recompiling '||obj.owner||'.'||obj.object_name);
222: exec('ALTER PACKAGE '||obj.owner||'.'||obj.object_name||' COMPILE BODY', c_module, true);

Line 236: update ad_zd_ddl_handler

232: X_ERROR CLOB)
233: is
234: C_MODULE varchar2(127) := c_package||'updatejob_status';
235: begin
236: update ad_zd_ddl_handler
237: set executed = x_executed,
238: status = nvl(x_status, c_job_status_success_desc),
239: execution_time =current_timestamp,
240: error = x_error

Line 291: -- Loads a SQL into AD_ZD_DDL_HANDLER

287:
288: Processing APIs
289:
290: *******************************************************************/
291: -- Loads a SQL into AD_ZD_DDL_HANDLER
292: -- X_PHASE : Phase of SQL
293: -- X_SQL : SQL or PL/SQL block
294: -- X_UNIQUE: If SQL should be checked for uniqueness within the given phase
295: --

Line 324: insert into ad_zd_ddl_handler(

320:
321: -- If here, this SQL needs to be inserted.
322: l_ddl_id := get_next_ddl_id;
323:
324: insert into ad_zd_ddl_handler(
325: phase ,
326: ddl_id ,
327: sql_lob ,
328: executed ,

Line 348: -- Delete from AD_ZD_DDL_HANDLER

344: end LOAD;
345:
346:
347:
348: -- Delete from AD_ZD_DDL_HANDLER
349: PROCEDURE CLEANUP(X_PHASE varchar2)
350: is
351: C_MODULE varchar2(127) := c_package||'cleanup';
352: begin

Line 355: delete from ad_zd_ddl_handler

351: C_MODULE varchar2(127) := c_package||'cleanup';
352: begin
353: log(c_module, 'STATEMENT', 'Cleanup DDL handler, phase='||nvl(x_phase, 'ALL'));
354:
355: delete from ad_zd_ddl_handler
356: where ( x_phase is null or phase =x_phase );
357: commit;
358:
359: end CLEANUP;

Line 362: -- Parallel Execute Worker - execute DDLs from ad_zd_ddl_handler table

358:
359: end CLEANUP;
360:
361:
362: -- Parallel Execute Worker - execute DDLs from ad_zd_ddl_handler table
363: --
364: -- X_PHASE - phase of work to select and execute
365: -- X_MAX_WORKERS - total number of parallel workers
366: -- X_CURRENT_WORKER - worker number for this thread [1..X_MAX_WORKERS]

Line 394: from ad_zd_ddl_handler

390: select mod((rownum-1), x_max_workers)+1 worker_id,
391: row_id, ddl_id, sql_lob, edition_name, executed
392: from
393: ( select rowid row_id, ddl_id, sql_lob, edition_name, executed
394: from ad_zd_ddl_handler
395: where phase=p_phase
396: order by ddl_id );
397:
398: begin

Line 402: dbms_application_info.set_module('AD_ZD', x_phase);

398: begin
399:
400: log(c_module, 'PROCEDURE', l_worker_hdr||'begin');
401:
402: dbms_application_info.set_module('AD_ZD', x_phase);
403:
404: -- Open cursor
405: l_cur := dbms_sql.open_cursor;
406:

Line 417: update ad_zd_ddl_handler

413: l_job_hdr := l_worker_hdr||'ddl_id='||job.ddl_id||'] ';
414: l_job_hdr := '['||x_phase||' '||x_max_workers||':'||x_current_worker||' ddl_id='||job.ddl_id||'] ';
415:
416: -- If job still needs to be executed, mark it as running;
417: update ad_zd_ddl_handler
418: set executed = c_job_status_running
419: , status = c_job_status_running_desc
420: , execution_time = current_timestamp
421: , error = NULL

Line 449: update ad_zd_ddl_handler

445: l_ret := sys.dbms_sql.execute(l_cur);
446: end if;
447:
448: -- record success
449: update ad_zd_ddl_handler
450: set executed = c_job_status_succeeded
451: , status = c_job_status_success_desc
452: , execution_time = current_timestamp
453: , error = NULL

Line 470: -- If AD_ZD packages are invalid, exit worker

466: when (get_error_level(sqlcode)=c_job_status_fatal_desc) then
467: updatejob_status(job.ddl_id, c_job_status_failed, c_job_status_fatal_desc, l_error);
468: error(c_module, l_job_hdr||'Fatal Error, exiting. '||l_long_error);
469:
470: -- If AD_ZD packages are invalid, exit worker
471: when (sqlcode= -04061 and
472: (instr(l_error, 'AD_ZD_TABLE' ) > 0 OR
473: instr(l_error, 'AD_ZD_MVIEW' ) > 0 OR
474: instr(l_error, 'AD_ZD_PREP' ) > 0 OR

Line 472: (instr(l_error, 'AD_ZD_TABLE' ) > 0 OR

468: error(c_module, l_job_hdr||'Fatal Error, exiting. '||l_long_error);
469:
470: -- If AD_ZD packages are invalid, exit worker
471: when (sqlcode= -04061 and
472: (instr(l_error, 'AD_ZD_TABLE' ) > 0 OR
473: instr(l_error, 'AD_ZD_MVIEW' ) > 0 OR
474: instr(l_error, 'AD_ZD_PREP' ) > 0 OR
475: instr(l_error, 'AD_ZD_SEED' ) > 0 OR
476: instr(l_error, 'AD_ZD_LOG' ) > 0 )) then

Line 473: instr(l_error, 'AD_ZD_MVIEW' ) > 0 OR

469:
470: -- If AD_ZD packages are invalid, exit worker
471: when (sqlcode= -04061 and
472: (instr(l_error, 'AD_ZD_TABLE' ) > 0 OR
473: instr(l_error, 'AD_ZD_MVIEW' ) > 0 OR
474: instr(l_error, 'AD_ZD_PREP' ) > 0 OR
475: instr(l_error, 'AD_ZD_SEED' ) > 0 OR
476: instr(l_error, 'AD_ZD_LOG' ) > 0 )) then
477: updatejob_status(job.ddl_id, c_job_status_failed, c_job_status_fatal_desc, l_error);

Line 474: instr(l_error, 'AD_ZD_PREP' ) > 0 OR

470: -- If AD_ZD packages are invalid, exit worker
471: when (sqlcode= -04061 and
472: (instr(l_error, 'AD_ZD_TABLE' ) > 0 OR
473: instr(l_error, 'AD_ZD_MVIEW' ) > 0 OR
474: instr(l_error, 'AD_ZD_PREP' ) > 0 OR
475: instr(l_error, 'AD_ZD_SEED' ) > 0 OR
476: instr(l_error, 'AD_ZD_LOG' ) > 0 )) then
477: updatejob_status(job.ddl_id, c_job_status_failed, c_job_status_fatal_desc, l_error);
478: error(c_module, l_job_hdr||'AD_ZD Packages Invalid, exiting. '||l_long_error);

Line 475: instr(l_error, 'AD_ZD_SEED' ) > 0 OR

471: when (sqlcode= -04061 and
472: (instr(l_error, 'AD_ZD_TABLE' ) > 0 OR
473: instr(l_error, 'AD_ZD_MVIEW' ) > 0 OR
474: instr(l_error, 'AD_ZD_PREP' ) > 0 OR
475: instr(l_error, 'AD_ZD_SEED' ) > 0 OR
476: instr(l_error, 'AD_ZD_LOG' ) > 0 )) then
477: updatejob_status(job.ddl_id, c_job_status_failed, c_job_status_fatal_desc, l_error);
478: error(c_module, l_job_hdr||'AD_ZD Packages Invalid, exiting. '||l_long_error);
479:

Line 476: instr(l_error, 'AD_ZD_LOG' ) > 0 )) then

472: (instr(l_error, 'AD_ZD_TABLE' ) > 0 OR
473: instr(l_error, 'AD_ZD_MVIEW' ) > 0 OR
474: instr(l_error, 'AD_ZD_PREP' ) > 0 OR
475: instr(l_error, 'AD_ZD_SEED' ) > 0 OR
476: instr(l_error, 'AD_ZD_LOG' ) > 0 )) then
477: updatejob_status(job.ddl_id, c_job_status_failed, c_job_status_fatal_desc, l_error);
478: error(c_module, l_job_hdr||'AD_ZD Packages Invalid, exiting. '||l_long_error);
479:
480: -- mark Job as errored and continue

Line 478: error(c_module, l_job_hdr||'AD_ZD Packages Invalid, exiting. '||l_long_error);

474: instr(l_error, 'AD_ZD_PREP' ) > 0 OR
475: instr(l_error, 'AD_ZD_SEED' ) > 0 OR
476: instr(l_error, 'AD_ZD_LOG' ) > 0 )) then
477: updatejob_status(job.ddl_id, c_job_status_failed, c_job_status_fatal_desc, l_error);
478: error(c_module, l_job_hdr||'AD_ZD Packages Invalid, exiting. '||l_long_error);
479:
480: -- mark Job as errored and continue
481: else
482: l_error_level := get_error_level(sqlcode, l_error);

Line 513: end AD_ZD_PARALLEL_EXEC;

509: end if;
510: raise;
511: end EXECUTE;
512:
513: end AD_ZD_PARALLEL_EXEC;