The following lines contain the word 'select', 'insert', 'update' or 'delete':
select INSTR(value,',',1,2),INSTR(value,',',1,3)
into v_st_position,v_end_position from v$parameter
where upper(name) = 'UTL_FILE_DIR';
select substr(value,v_st_position+1,v_w_position)
into v_log_name from v$parameter
where upper(name) = 'UTL_FILE_DIR';
SELECT *
FROM mtl_cycle_count_headers
WHERE
(cycle_count_header_id = cchid);
SELECT *
FROM mtl_cycle_count_entries
WHERE
(cycle_count_header_id = hid
OR cycle_count_entry_id = ccid)
AND NVL(export_flag, 2) = 2
AND entry_status_code IN(1, 3);
SELECT msi.tracking_quantity_ind
, msi.secondary_default_ind
, msi.secondary_uom_code
, msi.process_costing_enabled_flag
, mtp.process_enabled_flag
FROM mtl_system_items msi, mtl_parameters mtp
WHERE mtp.organization_id = cp_organization_id
AND msi.organization_id = mtp.organization_id
AND msi.inventory_item_id = cp_inventory_item_id;
SELECT
MTL_CC_ENTRIES_INTERFACE_S2.nextval
INTO
L_cc_entry_iface_group_id
FROM
dual;
select SERIAL_NUMBER_CONTROL_CODE into x_serial_number_control
from mtl_system_items
where organization_id = c_rec.organization_id
and inventory_item_id = c_rec.inventory_item_id;
select SERIAL_COUNT_OPTION into x_serial_count_option
from mtl_cycle_count_headers
where cycle_count_header_id = c_rec.Cycle_Count_Header_id;
P_DeleteProcRec IN NUMBER DEFAULT 2)
IS
l_debug number := NVL(FND_PROFILE.VALUE('INV_DEBUG_TRACE'),0);
IF P_DeleteProcRec NOT IN(1, 2) THEN
RETCODE := 'ERROR';
ERRBUF :=FND_MESSAGE.GET_STRING('INV', 'INV_CCEOI_WRONG_DELETEREC');
SELECT COUNT(*)
INTO L_MaxNumRows
FROM MTL_CC_ENTRIES_INTERFACE
WHERE NVL(STATUS_FLAG, 4) = 4
-- STATUS_FLAG = 4
AND NVL(LOCK_FLAG, 2) =2
AND NVL(DELETE_FLAG, 2) = 2
AND NVL(PROCESS_FLAG, 1) = 1
AND NVL(PROCESS_MODE, 3) = 3;
SELECT COUNT(*)
INTO L_MaxNumRows
FROM MTL_CC_ENTRIES_INTERFACE
WHERE CYCLE_COUNT_HEADER_ID = P_CYCLE_COUNT_HEADER_ID
AND NVL(STATUS_FLAG, 4) = 4
--AND STATUS_FLAG = 4
AND NVL(LOCK_FLAG, 2) =2
AND NVL(DELETE_FLAG, 2) = 2
AND NVL(PROCESS_FLAG, 1) = 1
AND NVL(PROCESS_MODE, 3) = 3;
SELECT ROUND(L_MaxNumRows/L_CountWorker)
INTO
L_CountRows
FROM
DUAL;
UPDATE mtl_cc_entries_interface
SET
cc_entry_interface_group_id = NULL,
LAST_UPDATE_DATE = SYSDATE,
LAST_UPDATED_BY = MTL_CCEOI_VAR_PVT.G_UserID,
LAST_UPDATE_LOGIN = MTL_CCEOI_VAR_PVT.G_LoginID,
PROGRAM_APPLICATION_ID = MTL_CCEOI_VAR_PVT.G_ProgramAppID,
PROGRAM_ID = MTL_CCEOI_VAR_PVT.G_ProgramID,
REQUEST_ID = MTL_CCEOI_VAR_PVT.G_RequestID,
PROGRAM_UPDATE_DATE = SYSDATE
WHERE
CYCLE_COUNT_HEADER_ID = NVL(P_Cycle_Count_Header_Id,CYCLE_COUNT_HEADER_ID)
AND NVL(PROCESS_FLAG, 1) = 1
AND NVL(LOCK_FLAG, 2) = 2
AND NVL(PROCESS_MODE, 3) = 3
AND NVL(STATUS_FLAG,4) = 4
AND NVL(DELETE_FLAG, 2) = 2;
SELECT MTL_CC_ENTRIES_INTERFACE_S1.NEXTVAL
INTO
L_NextGroupID
FROM
DUAL;
UPDATE mtl_cc_entries_interface
SET
cc_entry_interface_group_id = L_NextGroupID,
LAST_UPDATE_DATE = SYSDATE,
LAST_UPDATED_BY = MTL_CCEOI_VAR_PVT.G_UserID,
LAST_UPDATE_LOGIN = MTL_CCEOI_VAR_PVT.G_LoginID,
PROGRAM_APPLICATION_ID = MTL_CCEOI_VAR_PVT.G_ProgramAppID,
PROGRAM_ID = MTL_CCEOI_VAR_PVT.G_ProgramID,
REQUEST_ID = MTL_CCEOI_VAR_PVT.G_RequestID,
PROGRAM_UPDATE_DATE = SYSDATE
WHERE
NVL(PROCESS_FLAG, 1) = 1
AND NVL(LOCK_FLAG, 2) = 2
AND NVL(PROCESS_MODE, 3) = 3
AND NVL(STATUS_FLAG,4) = 4
AND NVL(DELETE_FLAG, 2) = 2
AND cc_entry_interface_group_id IS NULL
AND ROWNUM <= L_CountRows;
UPDATE mtl_cc_entries_interface
SET
cc_entry_interface_group_id = L_NextGroupID,
LAST_UPDATE_DATE = SYSDATE,
LAST_UPDATED_BY = MTL_CCEOI_VAR_PVT.G_UserID,
LAST_UPDATE_LOGIN = MTL_CCEOI_VAR_PVT.G_LoginID,
PROGRAM_APPLICATION_ID = MTL_CCEOI_VAR_PVT.G_ProgramAppID,
PROGRAM_ID = MTL_CCEOI_VAR_PVT.G_ProgramID,
REQUEST_ID = MTL_CCEOI_VAR_PVT.G_RequestID,
PROGRAM_UPDATE_DATE = SYSDATE
WHERE
CYCLE_COUNT_HEADER_ID = P_Cycle_Count_Header_Id
AND NVL(PROCESS_FLAG, 1) = 1
AND NVL(LOCK_FLAG, 2) = 2
AND NVL(PROCESS_MODE, 3) = 3
AND NVL(STATUS_FLAG,4) = 4
AND NVL(DELETE_FLAG, 2) = 2
AND cc_entry_interface_group_id IS NULL
AND ROWNUM <= L_CountRows;
argument4 => to_char(P_DeleteProcRec));
SELECT
*
FROM
MTL_CC_ENTRIES_INTERFACE
WHERE
(ERROR_FLAG = 2
AND STATUS_FLAG IN(0, 1))
OR DELETE_FLAG = 1;
select count(*)
into L_recs
FROM
MTL_CC_ENTRIES_INTERFACE
WHERE
(ERROR_FLAG = 2 AND STATUS_FLAG IN (0, 1))
OR DELETE_FLAG = 1;
MTL_CCEOI_PROCESS_PVT.Delete_CCEOIError(
p_cc_entry_interface_id => c_rec.cc_entry_interface_id);
MTL_CCEOI_PROCESS_PVT.Delete_CCIEntry(
p_cc_entry_interface_id => c_rec.cc_entry_interface_id);
'Deleted rows ='|| TO_CHAR(L_counter));
P_DeleteProcRec IN NUMBER DEFAULT 2)
IS
l_interface_id NUMBER;
SELECT * FROM MTL_CC_ENTRIES_INTERFACE
WHERE
CC_ENTRY_INTERFACE_GROUP_ID = id
-- AND LOCK_FLAG = 1 -- record will be locked by public API
AND NVL(PROCESS_FLAG, 1) = 1
AND NVL(PROCESS_MODE, 3) IN(2, 3)
AND NVL(STATUS_FLAG,4)=4
AND NVL(DELETE_FLAG,2)=2;
IF P_DeleteProcRec NOT IN(1, 2) THEN
ERRBUF := FND_MESSAGE.GET_STRING('INV', 'INV_CCEOI_WRONG_DELETEREC');
UPDATE mtl_cc_entries_interface
SET
LAST_UPDATE_DATE = SYSDATE,
LAST_UPDATED_BY = MTL_CCEOI_VAR_PVT.G_UserID,
LAST_UPDATE_LOGIN = MTL_CCEOI_VAR_PVT.G_LoginID,
PROGRAM_APPLICATION_ID = MTL_CCEOI_VAR_PVT.G_ProgramAppID,
PROGRAM_ID = MTL_CCEOI_VAR_PVT.G_ProgramID,
REQUEST_ID = MTL_CCEOI_VAR_PVT.G_RequestID,
PROGRAM_UPDATE_DATE = sysdate
-- LOCK_FLAG = 1
WHERE
cc_entry_interface_group_id = P_CC_Interface_Group_ID
AND NVL(lock_flag, 2) = 2
AND NVL(PROCESS_FLAG, 1) = 1
AND NVL(PROCESS_MODE, 3) IN(2, 3);
L_iface_rec.last_update_date := c_rec.last_update_date ;
L_iface_rec.last_updated_by := c_rec.last_updated_by ;
L_iface_rec.last_update_login := c_rec.last_update_login ;
L_iface_rec.program_update_date := c_rec.program_update_date ;
L_iface_rec.delete_flag := c_rec.delete_flag ;
UPDATE mtl_cc_entries_interface
SET
LAST_UPDATE_DATE = SYSDATE,
LAST_UPDATED_BY = MTL_CCEOI_VAR_PVT.G_UserID,
LAST_UPDATE_LOGIN = MTL_CCEOI_VAR_PVT.G_LoginID,
PROGRAM_APPLICATION_ID = MTL_CCEOI_VAR_PVT.G_ProgramAppID,
PROGRAM_ID = MTL_CCEOI_VAR_PVT.G_ProgramID,
REQUEST_ID = MTL_CCEOI_VAR_PVT.G_RequestID,
PROGRAM_UPDATE_DATE = SYSDATE
-- LOCK_FLAG = 2
WHERE
cc_entry_interface_group_id = P_CC_Interface_Group_Id;
UPDATE mtl_cc_entries_interface
SET
LAST_UPDATE_DATE = SYSDATE,
LAST_UPDATED_BY = MTL_CCEOI_VAR_PVT.G_UserID,
LAST_UPDATE_LOGIN = MTL_CCEOI_VAR_PVT.G_LoginID,
PROGRAM_APPLICATION_ID = MTL_CCEOI_VAR_PVT.G_ProgramAppID,
PROGRAM_ID = MTL_CCEOI_VAR_PVT.G_ProgramID,
REQUEST_ID = MTL_CCEOI_VAR_PVT.G_RequestID,
PROGRAM_UPDATE_DATE = SYSDATE
-- LOCK_FLAG = 2
WHERE
cc_entry_interface_group_id = P_CC_Interface_Group_ID;
UPDATE mtl_cc_entries_interface
SET
LAST_UPDATE_DATE = SYSDATE,
LAST_UPDATED_BY = MTL_CCEOI_VAR_PVT.G_UserID,
LAST_UPDATE_LOGIN = MTL_CCEOI_VAR_PVT.G_LoginID,
PROGRAM_APPLICATION_ID = MTL_CCEOI_VAR_PVT.G_ProgramAppID,
PROGRAM_ID = MTL_CCEOI_VAR_PVT.G_ProgramID,
REQUEST_ID = MTL_CCEOI_VAR_PVT.G_RequestID,
PROGRAM_UPDATE_DATE = SYSDATE
-- LOCK_FLAG = 2
WHERE
cc_entry_interface_group_id = P_CC_Interface_Group_ID;
Update mtl_cycle_count_entries
set export_flag = 2
where cycle_count_entry_id
in (select cycle_count_entry_id
from mtl_cc_entries_interface where
cc_entry_interface_group_id = P_CC_Interface_Group_ID
and status_flag = 0 );
FND_FILE.PUT_LINE(FND_FILE.LOG, 'Worker: Unexport Not updated ');
IF P_DeleteProcRec = 1 THEN
-- DELETE completed interface records
-- All records which are marked FOR deletion delete_flag =1
-- OR status_flag IN (0,1) AND error_flag = 2 will be deleted
Purge_CCEntriesIface(ERRBUF => ERRBUF, RETCODE => RETCODE);