APPS.OKI_DBI_LOAD_CLEB_PVT dependencies on OKI_DBI_WORKER_STATUS

Line 1130: l_sql_string := 'TRUNCATE TABLE ' || l_oki_schema || '.OKI_DBI_WORKER_STATUS';

1126: rlog( 'Truncated Table ' || l_oki_schema || '.OKI_DBI_CHR_INC',1);
1127:
1128: /* Commented as per mail communications - for Disco */
1129: /*
1130: l_sql_string := 'TRUNCATE TABLE ' || l_oki_schema || '.OKI_DBI_WORKER_STATUS';
1131: EXECUTE IMMEDIATE l_sql_string;
1132: rlog( 'Truncated Table ' || l_oki_schema || '.OKI_DBI_WORKER_STATUS',1);
1133: */
1134:

Line 1132: rlog( 'Truncated Table ' || l_oki_schema || '.OKI_DBI_WORKER_STATUS',1);

1128: /* Commented as per mail communications - for Disco */
1129: /*
1130: l_sql_string := 'TRUNCATE TABLE ' || l_oki_schema || '.OKI_DBI_WORKER_STATUS';
1131: EXECUTE IMMEDIATE l_sql_string;
1132: rlog( 'Truncated Table ' || l_oki_schema || '.OKI_DBI_WORKER_STATUS',1);
1133: */
1134:
1135: DELETE FROM OKI_DBI_WORKER_STATUS WHERE OBJECT_NAME = 'OKI_DBI_CLE_B_OLD';
1136: COMMIT;

Line 1135: DELETE FROM OKI_DBI_WORKER_STATUS WHERE OBJECT_NAME = 'OKI_DBI_CLE_B_OLD';

1131: EXECUTE IMMEDIATE l_sql_string;
1132: rlog( 'Truncated Table ' || l_oki_schema || '.OKI_DBI_WORKER_STATUS',1);
1133: */
1134:
1135: DELETE FROM OKI_DBI_WORKER_STATUS WHERE OBJECT_NAME = 'OKI_DBI_CLE_B_OLD';
1136: COMMIT;
1137:
1138: l_sql_string := 'TRUNCATE TABLE ' || l_oki_schema || '.OKI_DBI_CLE_B_OLD';
1139: EXECUTE IMMEDIATE l_sql_string;

Line 3467: INSERT INTO OKI_DBI_WORKER_STATUS (

3463: WHERE worker_number = -1
3464: AND ROWNUM <= CEIL(g_contracts_count/l_no_of_workers);
3465:
3466: IF ( SQL%ROWCOUNT > 0 ) THEN
3467: INSERT INTO OKI_DBI_WORKER_STATUS (
3468: object_name
3469: , worker_number
3470: , status
3471: , phase) VALUES(

Line 3523: FROM OKI_DBI_WORKER_STATUS

3519: l_completed_cnt,
3520: l_wip_cnt,
3521: l_failed_cnt,
3522: l_tot_cnt
3523: FROM OKI_DBI_WORKER_STATUS
3524: WHERE object_name = 'OKI_DBI_CLE_B_OLD';
3525:
3526: IF ( l_failed_cnt > 0 ) THEN
3527: rlog('One of the sub-workers errored out..Exiting',1);

Line 3638: UPDATE OKI_DBI_WORKER_STATUS SET STATUS='UNASSIGNED', phase = l_phase + 1;

3634:
3635: END IF;
3636:
3637: IF ( l_phase < 7 ) THEN
3638: UPDATE OKI_DBI_WORKER_STATUS SET STATUS='UNASSIGNED', phase = l_phase + 1;
3639: END IF;
3640: COMMIT;
3641: END LOOP;
3642:

Line 5728: FROM OKI_DBI_WORKER_STATUS

5724: l_failed_cnt,
5725: l_wip_cnt,
5726: l_completed_cnt,
5727: l_total_cnt
5728: FROM OKI_DBI_WORKER_STATUS
5729: WHERE 1=1
5730: AND object_name = 'OKI_DBI_CLE_B_OLD';
5731:
5732: IF (l_failed_cnt > 0) THEN

Line 5740: UPDATE OKI_DBI_WORKER_STATUS

5736: ELSIF (l_completed_cnt = l_total_cnt) THEN
5737: rlog('All jobs completed, no more job. Terminating',2);
5738: ELSIF (l_unassigned_cnt > 0) THEN
5739:
5740: UPDATE OKI_DBI_WORKER_STATUS
5741: SET status = 'IN PROCESS'
5742: ,phase = p_phase
5743: WHERE object_name = 'OKI_DBI_CLE_B_OLD'
5744: AND worker_number = p_worker_no

Line 5773: UPDATE OKI_DBI_WORKER_STATUS

5769: -- rlog('Total No of Records updated in OKI_DBI_CLE_B_OLD using Worker '||
5770: -- p_worker_no || ' is '|| l_recs_processed,3);
5771: COMMIT;
5772:
5773: UPDATE OKI_DBI_WORKER_STATUS
5774: SET status = 'COMPLETED'
5775: WHERE object_name = 'OKI_DBI_CLE_B_OLD'
5776: AND status = 'IN PROCESS'
5777: AND worker_number = p_worker_no;

Line 5784: UPDATE OKI_DBI_WORKER_STATUS

5780: EXCEPTION
5781: WHEN OTHERS THEN
5782: retcode := -1;
5783:
5784: UPDATE OKI_DBI_WORKER_STATUS
5785: SET status = 'FAILED'
5786: WHERE object_name = 'OKI_DBI_CLE_B_OLD'
5787: AND status = 'IN PROCESS'
5788: AND worker_number = p_worker_no;