The following lines contain the word 'select', 'insert', 'update' or 'delete':
SELECT a.inst_interface_id
FROM csi_instance_interface a
WHERE a.process_status = 'X';
SELECT nvl(FND_PROFILE.VALUE('CSI_OPEN_INTERFACE_COMMIT_RECS'),1000)
INTO l_commit_recs
FROM dual;
SELECT ceil(count(1)/l_commit_recs)
INTO x_count
FROM csi_instance_interface
WHERE trunc(source_transaction_date) BETWEEN
nvl(l_txn_from_date,trunc(source_transaction_date)) AND
nvl(l_txn_to_date,trunc(source_transaction_date))
AND process_status = 'R'
AND parallel_worker_id is NULL
AND source_system_name = nvl(p_source_system_name,source_system_name);
UPDATE csi_instance_interface a
SET process_status = 'X'
WHERE trunc(source_transaction_date) BETWEEN
nvl(l_txn_from_date,trunc(source_transaction_date)) AND
nvl(l_txn_to_date,trunc(source_transaction_date))
AND process_status = 'R'
AND source_system_name = nvl(p_source_system_name,source_system_name)
AND parallel_worker_id is NULL
AND rownum <= l_commit_recs;
l_inst_id_tbl.delete;
SELECT inst_interface_id,process_status
FROM csi_instance_interface
WHERE process_status = 'X'
AND nvl(transaction_identifier,'-1') = '-1'
AND parallel_worker_id = pc_parallel_worker_id;
SELECT nvl(FND_PROFILE.VALUE('CSI_OPEN_INTERFACE_COMMIT_RECS'),1000)
INTO l_commit_recs
FROM dual;
SELECT ceil(count(1)/l_commit_recs)
INTO x_count
FROM csi_instance_interface
WHERE trunc(source_transaction_date) BETWEEN
nvl(l_txn_from_date,trunc(source_transaction_date)) AND
nvl(l_txn_to_date,trunc(source_transaction_date))
AND nvl(transaction_identifier,'-1') = '-1'
AND process_status = 'R'
AND source_system_name = nvl(p_source_system_name,source_system_name)
AND parallel_worker_id = p_worker_id;
UPDATE csi_instance_interface a
SET process_status = 'X'
WHERE trunc(source_transaction_date) BETWEEN
nvl(l_txn_from_date,trunc(source_transaction_date)) AND
nvl(l_txn_to_date,trunc(source_transaction_date))
AND nvl(transaction_identifier,'-1') = '-1'
AND process_status = 'R'
AND source_system_name = nvl(p_source_system_name,source_system_name)
AND parallel_worker_id = p_worker_id
AND rownum <= l_commit_recs;
l_inst_id_tbl.delete;
UPDATE csi_instance_interface
SET parallel_worker_id = -1
WHERE inst_interface_id = l_inst_id_tbl(j).inst_interface_id;
UPDATE csi_instance_interface
SET parallel_worker_id = -1
WHERE inst_interface_id = l_inst_id_tbl(j).inst_interface_id;
UPDATE csi_instance_interface
SET parallel_worker_id = -1
WHERE inst_interface_id = l_inst_id_tbl(j).inst_interface_id;
UPDATE csi_instance_interface
SET parallel_worker_id = -1
WHERE inst_interface_id = l_inst_id_tbl(j).inst_interface_id;