DBA Data[Home] [Help]

APPS.JTF_IH_BULK dependencies on JTF_IH_BULK_RECOVERY

Line 243: INSERT INTO jtf_ih_bulk_recovery

239:
240: -- Perf fix for literal usuage
241: l_msg_id_perf := '0';
242:
243: INSERT INTO jtf_ih_bulk_recovery
244: ( recovery_id, request_id, msg_id, bulk_interaction_request,
245: num_int_processed, created_by, creation_date, last_updated_by,
246: last_update_date, last_update_login, program_id, program_application_id,
247: program_update_date)

Line 249: (jtf_ih_bulk_recovery_s1.nextval, G_CONC_REQUEST_ID, l_msg_id_perf,

245: num_int_processed, created_by, creation_date, last_updated_by,
246: last_update_date, last_update_login, program_id, program_application_id,
247: program_update_date)
248: VALUES
249: (jtf_ih_bulk_recovery_s1.nextval, G_CONC_REQUEST_ID, l_msg_id_perf,
250: EMPTY_CLOB(), null, G_USER_ID, sysdate, G_USER_ID, sysdate, G_LOGIN_ID,
251: G_CONC_REQUEST_ID, G_PROG_APPL_ID, sysdate);
252:
253: g_hrt_beat := -50;

Line 300: UPDATE jtf_ih_bulk_recovery

296: FROM jtf_ih_bulk_qtbl
297: WHERE msgid = l_msg_id;
298:
299: g_hrt_beat := -51.50;
300: UPDATE jtf_ih_bulk_recovery
301: SET
302: bulk_writer_code = saved_bulk_obj.bulkWriterCode,
303: bulk_batch_type = saved_bulk_obj.bulkBatchType,
304: bulk_batch_id = saved_bulk_obj.bulkBatchId,

Line 454: DELETE FROM jtf_ih_bulk_recovery

450: END LOOP;
451:
452: -- We are done processing bulk records, now get rid of the record in the
453: -- recovery table
454: DELETE FROM jtf_ih_bulk_recovery
455: WHERE request_id = G_CONC_REQUEST_ID;
456:
457: -- crazy, but if more than one record is ever deleted here something bad is
458: -- going on - so log the error (and don't commit ?)

Line 1014: UPDATE jtf_ih_bulk_recovery

1010:
1011: l_commit_int_num := i;
1012:
1013: -- update the crash recovery table too
1014: UPDATE jtf_ih_bulk_recovery
1015: SET num_int_processed = l_commit_int_num,
1016: last_update_date = sysdate,
1017: program_update_date = sysdate
1018: WHERE request_id = G_CONC_REQUEST_ID;

Line 1125: UPDATE jtf_ih_bulk_recovery

1121:
1122: -- commit any outstanding work.
1123: -- update the crash recovery table too - here the num int processed is diff
1124: -- from above
1125: UPDATE jtf_ih_bulk_recovery
1126: SET num_int_processed = l_num_int_done,
1127: last_update_date = sysdate,
1128: program_update_date = sysdate
1129: WHERE request_id = G_CONC_REQUEST_ID;

Line 2163: l_rec_recd IN OUT NOCOPY JTF_IH_BULK_RECOVERY%ROWTYPE

2159: END LOG_BULK_ERROR;
2160:
2161: FUNCTION FIND_ONE_CRASH_RECD
2162: (
2163: l_rec_recd IN OUT NOCOPY JTF_IH_BULK_RECOVERY%ROWTYPE
2164: ) RETURN BOOLEAN IS
2165:
2166: TYPE BulkRecoveryCurTyp IS REF CURSOR RETURN JTF_IH_BULK_RECOVERY%ROWTYPE;
2167: l_rec_cv BulkRecoveryCurTyp;

Line 2166: TYPE BulkRecoveryCurTyp IS REF CURSOR RETURN JTF_IH_BULK_RECOVERY%ROWTYPE;

2162: (
2163: l_rec_recd IN OUT NOCOPY JTF_IH_BULK_RECOVERY%ROWTYPE
2164: ) RETURN BOOLEAN IS
2165:
2166: TYPE BulkRecoveryCurTyp IS REF CURSOR RETURN JTF_IH_BULK_RECOVERY%ROWTYPE;
2167: l_rec_cv BulkRecoveryCurTyp;
2168: l_call_status BOOLEAN;
2169: l_found_recd BOOLEAN;
2170: l_phase VARCHAR2(80);

Line 2179: 'l_rec_recd TYPE JTF_IH_BULK_RECOVERY%ROWTYPE';

2175:
2176: BEGIN
2177: IF( FND_LOG.LEVEL_PROCEDURE >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) THEN
2178: l_fnd_log_msg := 'FUNCTION FIND_ONE_CRASH_RECD In parameters :'||
2179: 'l_rec_recd TYPE JTF_IH_BULK_RECOVERY%ROWTYPE';
2180: --dbms_output.put_line(l_fnd_log_msg);
2181: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE,
2182: 'jtf.plsql.JTF_IH_BULK.FIND_ONE_CRASH_RECD.begin', l_fnd_log_msg);
2183: END IF;

Line 2188: OPEN l_rec_cv FOR SELECT * FROM JTF_IH_BULK_RECOVERY;

2184:
2185: g_hrt_beat := -70;
2186: --FND_FILE.PUT_LINE(FND_FILE.OUTPUT, 'Entered find_one_crash_Recd');
2187:
2188: OPEN l_rec_cv FOR SELECT * FROM JTF_IH_BULK_RECOVERY;
2189:
2190: -- look for a crash victim in the RECORD_ID for each row in this table
2191:
2192: l_found_recd := FALSE;

Line 2256: UPDATE JTF_IH_BULK_RECOVERY

2252:
2253: IF (l_found_recd = TRUE) THEN
2254:
2255: -- 'grab' the record by changing the request_id to our own
2256: UPDATE JTF_IH_BULK_RECOVERY
2257: SET request_id = G_CONC_REQUEST_ID,
2258: program_id = G_CONC_REQUEST_ID,
2259: program_application_id = G_PROG_APPL_ID,
2260: last_update_date = sysdate,

Line 2298: PROCEDURE CLEAR_ONE_CRASH_RECD( l_rec_recd IN JTF_IH_BULK_RECOVERY%ROWTYPE) IS

2294:
2295: END FIND_ONE_CRASH_RECD;
2296:
2297:
2298: PROCEDURE CLEAR_ONE_CRASH_RECD( l_rec_recd IN JTF_IH_BULK_RECOVERY%ROWTYPE) IS
2299:
2300: l_ret_status VARCHAR2(5);
2301: BEGIN
2302:

Line 2342: DELETE FROM jtf_ih_bulk_recovery

2338: --FND_FILE.PUT_LINE(FND_FILE.LOG, FND_MESSAGE.GET);
2339: END IF;
2340:
2341: -- now that the crash victim has been taken care of, get rid of it
2342: DELETE FROM jtf_ih_bulk_recovery
2343: WHERE request_id = G_CONC_REQUEST_ID;
2344:
2345: COMMIT;
2346:

Line 2366: l_rec_recd JTF_IH_BULK_RECOVERY%ROWTYPE;

2362: -- Parameters - none
2363: --
2364: PROCEDURE PERFORM_CRASH_RECOVERY is
2365:
2366: l_rec_recd JTF_IH_BULK_RECOVERY%ROWTYPE;
2367:
2368: BEGIN
2369:
2370: IF( FND_LOG.LEVEL_PROCEDURE >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) THEN