The following lines contain the word 'select', 'insert', 'update' or 'delete':
l_update_name varchar2(30);
l_update_name := 'Purge'||P_batch_id;
ad_parallel_updates_pkg.initialize_rowid_range(ad_parallel_updates_pkg.ROWID_RANGE,
l_table_owner,
l_table_name,
l_update_name,
P_worker_id,
P_num_workers,
P_commit_size,
0);
ad_parallel_updates_pkg.get_rowid_range( l_start_rowid,
l_end_rowid,
l_any_rows_to_process,
P_commit_size,
TRUE);
SELECT count(1) INTO l_row_count FROM OKS_HEADERS_INTERFACE
WHERE ROWID BETWEEN l_start_rowid AND l_end_rowid
AND BATCH_ID = P_batch_id
AND INTERFACE_STATUS = 'S'
AND rownum = 1;
DELETE FROM OKS_SALES_CREDITS_INTERFACE
WHERE HEADER_INTERFACE_ID IN (SELECT HEADER_INTERFACE_ID FROM OKS_HEADERS_INTERFACE
WHERE ROWID BETWEEN l_start_rowid AND l_end_rowid
AND BATCH_ID = P_batch_id
AND INTERFACE_STATUS = 'S');
DELETE FROM OKS_NOTES_INTERFACE
WHERE HEADER_INTERFACE_ID IN (SELECT HEADER_INTERFACE_ID FROM OKS_HEADERS_INTERFACE
WHERE ROWID BETWEEN l_start_rowid AND l_end_rowid
AND BATCH_ID = P_batch_id
AND INTERFACE_STATUS = 'S')
OR LINE_INTERFACE_ID IN (SELECT OLI.LINE_INTERFACE_ID
FROM OKS_LINES_INTERFACE OLI, OKS_HEADERS_INTERFACE OHI
WHERE OHI.ROWID BETWEEN l_start_rowid AND l_end_rowid
AND OHI.BATCH_ID = P_batch_id
AND OHI.INTERFACE_STATUS = 'S'
AND OLI.HEADER_INTERFACE_ID = OHI.HEADER_INTERFACE_ID);
DELETE FROM OKS_COVERED_LEVELS_INTERFACE
WHERE LINE_INTERFACE_ID IN (SELECT OLI.LINE_INTERFACE_ID
FROM OKS_LINES_INTERFACE OLI, OKS_HEADERS_INTERFACE OHI
WHERE OHI.ROWID BETWEEN l_start_rowid AND l_end_rowid
AND OHI.BATCH_ID = P_batch_id
AND OHI.INTERFACE_STATUS = 'S'
AND OLI.HEADER_INTERFACE_ID = OHI.HEADER_INTERFACE_ID);
DELETE FROM OKS_USAGE_COUNTERS_INTERFACE
WHERE LINE_INTERFACE_ID IN (SELECT OLI.LINE_INTERFACE_ID
FROM OKS_LINES_INTERFACE OLI, OKS_HEADERS_INTERFACE OHI
WHERE OHI.ROWID BETWEEN l_start_rowid AND l_end_rowid
AND OHI.BATCH_ID = P_batch_id
AND OHI.INTERFACE_STATUS = 'S'
AND OLI.HEADER_INTERFACE_ID = OHI.HEADER_INTERFACE_ID);
DELETE FROM OKS_LINES_INTERFACE
WHERE HEADER_INTERFACE_ID IN (SELECT HEADER_INTERFACE_ID FROM OKS_HEADERS_INTERFACE
WHERE ROWID BETWEEN l_start_rowid AND l_end_rowid
AND BATCH_ID = P_batch_id
AND INTERFACE_STATUS = 'S');
DELETE FROM OKS_HEADERS_INTERFACE
WHERE ROWID BETWEEN l_start_rowid AND l_end_rowid
AND BATCH_ID = P_batch_id
AND INTERFACE_STATUS = 'S';
ad_parallel_updates_pkg.processed_rowid_range(l_rows_processed,
l_end_rowid);
ad_parallel_updates_pkg.get_rowid_range(l_start_rowid,
l_end_rowid,
l_any_rows_to_process,
P_commit_size,
FALSE);