APPS.BSC_AW_UTILITY dependencies on DBMS_JOB

Line 869: useful for dbms jobs

865:
866: /*
867: this will init all procedures
868: this is useful if we dont need to worry about which all packs's init have been called.
869: useful for dbms jobs
870: */
871: procedure init_all_procedures is
872: Begin
873: if get_parameter_value(g_options,'DEBUG LOG')='Y'

Line 1239: handle dbms jobs for parallel loading and aggregations in 10g+

1235: raise;
1236: End;
1237:
1238: /*
1239: handle dbms jobs for parallel loading and aggregations in 10g+
1240: we will have a global table with info on all current jobs. procedure
1241: wait on jobs will wait on jobs. jobs will communicate with the main process
1242: using dbms_pipe
1243: create job will add entries to the global table. clean job procedure will clean

Line 1254: PRAGMA AUTONOMOUS_TRANSACTION; --we have a commit here to start dbms job

1250: p_run_id number,
1251: p_process varchar2,
1252: p_options varchar2
1253: ) is
1254: PRAGMA AUTONOMOUS_TRANSACTION; --we have a commit here to start dbms job
1255: --
1256: l_job_id integer;
1257: l_parallel_job parallel_job_r;
1258: Begin

Line 1270: log_n('dbms_job.submit('||p_process||')'||bsc_aw_utility.get_time);

1266: end if;
1267: --create a pipe for communication
1268: create_pipe(p_job_name);
1269: if g_debug then
1270: log_n('dbms_job.submit('||p_process||')'||bsc_aw_utility.get_time);
1271: end if;
1272: dbms_job.submit(l_job_id,p_process);
1273: --add to the global array list
1274: g_parallel_jobs(g_parallel_jobs.count+1).job_name:=p_job_name;

Line 1272: dbms_job.submit(l_job_id,p_process);

1268: create_pipe(p_job_name);
1269: if g_debug then
1270: log_n('dbms_job.submit('||p_process||')'||bsc_aw_utility.get_time);
1271: end if;
1272: dbms_job.submit(l_job_id,p_process);
1273: --add to the global array list
1274: g_parallel_jobs(g_parallel_jobs.count+1).job_name:=p_job_name;
1275: g_parallel_jobs(g_parallel_jobs.count).run_id:=p_run_id; --1,2, 3 etc
1276: g_parallel_jobs(g_parallel_jobs.count).job_id:=l_job_id;

Line 1518: return can_launch_dbms_job(p_number_jobs);

1514: and nvl(get_parameter_value('NO PARALLEL'),'N')='N' then
1515: if p_number_jobs<=1 then
1516: return 'N';
1517: end if;
1518: return can_launch_dbms_job(p_number_jobs);
1519: end if;
1520: return 'N'; --if 9i, no jobs possible
1521: Exception when others then
1522: log_n('Exception in can_launch_jobs '||sqlerrm);

Line 1526: function can_launch_dbms_job(p_number_jobs number) return varchar2 is

1522: log_n('Exception in can_launch_jobs '||sqlerrm);
1523: raise;
1524: End;
1525:
1526: function can_launch_dbms_job(p_number_jobs number) return varchar2 is
1527: l_job_queue_processes number;
1528: l_jobs_running number;
1529: l_status varchar2(20);
1530: Begin

Line 1552: log_n('Exception in can_launch_dbms_job '||sqlerrm);

1548: end if;
1549: end if;
1550: return l_status;
1551: Exception when others then
1552: log_n('Exception in can_launch_dbms_job '||sqlerrm);
1553: raise;
1554: End;
1555:
1556: function count_jobs_running return number is

Line 1586: --makes a string out of the options. for dbms jobs

1582: log_n('Exception in get_vparameter '||sqlerrm);
1583: raise;
1584: End;
1585:
1586: --makes a string out of the options. for dbms jobs
1587: function get_option_string return varchar2 is
1588: l_string varchar2(4000);
1589: Begin
1590: for i in 1..g_options.count loop