The following lines contain the word 'select', 'insert', 'update' or 'delete':
DELETE FROM EGO_BULKLOAD_INTF
WHERE RESULTFMT_USAGE_ID = p_result_format_usage_id
AND PROCESS_STATUS <> G_DATA_ROWS_UPLOADED_NEW;
SELECT VALUE
FROM V$PARAMETER
WHERE NAME = 'utl_file_dir';
SELECT DISTINCT To_Number(SUBSTR(attribute_code, 1, INSTR(attribute_code, '$$') - 1)) attr_group_id,classification_code
FROM ego_results_fmt_usages
WHERE resultfmt_usage_id = c_resultfmt_usage_id
AND attribute_code LIKE '%$$%'
AND To_Number(SUBSTR(attribute_code, 1, INSTR(attribute_code, '$$') - 1)) IN
(
SELECT attr_group_id
FROM ego_attr_groups_v
WHERE attr_group_type = c_attr_group_type
AND application_id = G_APPLICATION_ID
);
SELECT attr_group_name, attr_name
FROM ego_attrs_v
WHERE attr_id = p_attr_id
AND attr_group_type = c_attr_group_type
AND application_id = G_APPLICATION_ID;
l_cursor_select INTEGER;
SELECT 'HZ_PARTY:'||TO_CHAR(PERSON_ID)
INTO G_HZ_PARTY_ID
FROM EGO_PEOPLE_V
WHERE USER_NAME = G_USER_NAME;
l_dyn_sql := ' SELECT To_Number(SUBSTR(attribute_code, INSTR(attribute_code, ''$$'')+2)) attr_id, intf_column_name, To_Number(SUBSTR(attribute_code, 1, INSTR(attribute_code, ''$$'') - 1)) attr_group_id '; --bug 6493113
l_cursor_select := DBMS_SQL.OPEN_CURSOR;
DBMS_SQL.PARSE(l_cursor_select, l_dyn_sql, DBMS_SQL.NATIVE);
DBMS_SQL.DEFINE_ARRAY(l_cursor_select, 1,l_attr_id_table,2500, l_temp);
DBMS_SQL.DEFINE_ARRAY(l_cursor_select, 2,l_intf_col_name_table,2500, l_temp);
DBMS_SQL.DEFINE_ARRAY(l_cursor_select, 3,l_attr_group_id_table,2500, l_temp);
DBMS_SQL.BIND_VARIABLE(l_cursor_select,':RESULTFMT_USAGE_ID', p_resultfmt_usage_id);
DBMS_SQL.BIND_VARIABLE(l_cursor_select,':ATTRIBUTE_CODE', c_attr_grp_rec.attr_group_id||'$$%');
l_cursor_execute := DBMS_SQL.EXECUTE(l_cursor_select);
l_count := DBMS_SQL.FETCH_ROWS(l_cursor_select);
DBMS_SQL.COLUMN_VALUE(l_cursor_select, 1, l_attr_id_table);
DBMS_SQL.COLUMN_VALUE(l_cursor_select, 2, l_intf_col_name_table);
DBMS_SQL.COLUMN_VALUE(l_cursor_select, 3, l_attr_group_id_table);
DBMS_SQL.CLOSE_CURSOR(l_cursor_select);
l_dyn_attr_id_val_sql := ' SELECT ';
l_usr_attr_data_tbl.DELETE(l_rows_per_attr_grp_indx);
l_attr_id_table.DELETE;
l_intf_col_name_table.DELETE;
Write_Conclog('Inserted Attribute value too large....');
INSERT INTO RRS_SITE_UA_INTF
(
DATA_SET_ID ,
TRANSACTION_ID ,
SITE_ID ,
ROW_IDENTIFIER ,
PROCESS_STATUS ,
SITE_USE_TYPE_CODE ,
ATTR_GROUP_INT_NAME ,
ATTR_INT_NAME ,
ATTR_DISP_VALUE ,
DATA_LEVEL_ID ,
DATA_LEVEL_NAME
)
VALUES
(
l_usr_attr_data_tbl(i).DATA_SET_ID,
l_usr_attr_data_tbl(i).TRANSACTION_ID,
l_usr_attr_data_tbl(i).PK_ID,
l_usr_attr_data_tbl(i).ROW_IDENTIFIER,
G_PS_TO_BE_PROCESSED,
l_usr_attr_data_tbl(i).CLASSIFICATION_CODE,
l_usr_attr_data_tbl(i).ATTR_GROUP_NAME,
l_usr_attr_data_tbl(i).ATTR_NAME,
l_varchar_data,
G_RRS_SITE_DATA_LEVEL_ID,
G_RRS_SITE_DATA_LEVEL
);
INSERT INTO RRS_LOCATION_UA_INTF
(
DATA_SET_ID ,
TRANSACTION_ID ,
LOCATION_ID ,
ROW_IDENTIFIER ,
PROCESS_STATUS ,
COUNTRY ,
ATTR_GROUP_INT_NAME ,
ATTR_INT_NAME ,
ATTR_DISP_VALUE ,
DATA_LEVEL_ID ,
DATA_LEVEL_NAME
)
VALUES
(
l_usr_attr_data_tbl(i).DATA_SET_ID,
l_usr_attr_data_tbl(i).TRANSACTION_ID,
l_usr_attr_data_tbl(i).PK_ID,
l_usr_attr_data_tbl(i).ROW_IDENTIFIER,
G_PS_TO_BE_PROCESSED,
l_usr_attr_data_tbl(i).CLASSIFICATION_CODE,
l_usr_attr_data_tbl(i).ATTR_GROUP_NAME,
l_usr_attr_data_tbl(i).ATTR_NAME,
l_varchar_data,
G_RRS_LOCATION_DATA_LEVEL_ID,
G_RRS_LOCATION_DATA_LEVEL
);
INSERT INTO RRS_TRADEAREA_UA_INTF
(
DATA_SET_ID ,
TRANSACTION_ID ,
TRADE_AREA_ID ,
ROW_IDENTIFIER ,
PROCESS_STATUS ,
GROUP_ID ,
ATTR_GROUP_INT_NAME ,
ATTR_INT_NAME ,
ATTR_DISP_VALUE ,
DATA_LEVEL_ID ,
DATA_LEVEL_NAME
)
VALUES
(
l_usr_attr_data_tbl(i).DATA_SET_ID,
l_usr_attr_data_tbl(i).TRANSACTION_ID,
l_usr_attr_data_tbl(i).PK_ID,
l_usr_attr_data_tbl(i).ROW_IDENTIFIER,
G_PS_TO_BE_PROCESSED,
l_usr_attr_data_tbl(i).CLASSIFICATION_CODE,
l_usr_attr_data_tbl(i).ATTR_GROUP_NAME,
l_usr_attr_data_tbl(i).ATTR_NAME,
l_varchar_data,
G_RRS_TRADE_AREA_DATA_LEVEL_ID,
G_RRS_TRADE_AREA_DATA_LEVEL
); --------End of bug 6493113
(SELECT 1
FROM RRS_SITES_INTERFACE rsi_e
WHERE rsi_e.TRANSACTION_TYPE = ''CREATE''
AND rsi_e.PROCESS_STATUS = ''1''
-- AND rsi_e.BATCH_ID = UAI2.BATCH_ID
AND rsi_e.SITE_ID = UAI2.SITE_ID
)';
select count(*) from RRS_SITE_UA_INTF
WHERE PROCESS_STATUS = G_PS_TO_BE_PROCESSED
AND DATA_SET_ID = p_data_set_id;
select count(*) from RRS_LOCATION_UA_INTF
WHERE PROCESS_STATUS = G_PS_TO_BE_PROCESSED
AND DATA_SET_ID = p_data_set_id;
SELECT COUNT(*) FROM RRS_TRADEAREA_UA_INTF
WHERE PROCESS_STATUS = G_PS_TO_BE_PROCESSED
AND DATA_SET_ID = p_data_set_id;
UPDATE RRS_SITE_UA_INTF
SET PROCESS_STATUS = G_PS_IN_PROCESS
,REQUEST_ID = G_REQUEST_ID
,PROGRAM_APPLICATION_ID = G_PROGAM_APPLICATION_ID
,PROGRAM_ID = G_PROGAM_ID
,PROGRAM_UPDATE_DATE = SYSDATE
,CREATED_BY = DECODE(CREATED_BY, NULL, G_USER_ID, CREATED_BY)
,CREATION_DATE = DECODE(CREATION_DATE, NULL, SYSDATE, CREATION_DATE)
,LAST_UPDATED_BY = G_USER_ID
,LAST_UPDATE_DATE = SYSDATE
,LAST_UPDATE_LOGIN = G_LOGIN_ID
,TRANSACTION_TYPE = UPPER(NVL(TRANSACTION_TYPE,EGO_USER_ATTRS_DATA_PVT.G_SYNC_MODE))
WHERE DATA_SET_ID = p_data_set_id
AND (PROCESS_STATUS IS NULL OR
PROCESS_STATUS = G_PS_TO_BE_PROCESSED);
l_rel_sql := 'SELECT CODE FROM RRS_SITES_OCV';
DELETE FROM RRS_SITE_UA_INTF
WHERE DATA_SET_ID = p_data_set_id
AND PROCESS_STATUS = G_PS_IN_PROCESS;
UPDATE RRS_SITE_UA_INTF
SET PROCESS_STATUS = G_PS_SUCCESS
WHERE DATA_SET_ID = p_data_set_id
AND PROCESS_STATUS = G_PS_IN_PROCESS;
UPDATE RRS_LOCATION_UA_INTF
SET PROCESS_STATUS = G_PS_IN_PROCESS
,REQUEST_ID = G_REQUEST_ID
,PROGRAM_APPLICATION_ID = G_PROGAM_APPLICATION_ID
,PROGRAM_ID = G_PROGAM_ID
,PROGRAM_UPDATE_DATE = SYSDATE
,CREATED_BY = DECODE(CREATED_BY, NULL, G_USER_ID, CREATED_BY)
,CREATION_DATE = DECODE(CREATION_DATE, NULL, SYSDATE, CREATION_DATE)
,LAST_UPDATED_BY = G_USER_ID
,LAST_UPDATE_DATE = SYSDATE
,LAST_UPDATE_LOGIN = G_LOGIN_ID
,TRANSACTION_TYPE = UPPER(NVL(TRANSACTION_TYPE,EGO_USER_ATTRS_DATA_PVT.G_SYNC_MODE))
WHERE DATA_SET_ID = p_data_set_id
AND (PROCESS_STATUS IS NULL OR
PROCESS_STATUS = G_PS_TO_BE_PROCESSED);
l_rel_sql := 'SELECT CODE FROM RRS_LOCATIONS_OCV' ;
DELETE FROM RRS_LOCATION_UA_INTF
WHERE DATA_SET_ID = p_data_set_id
AND PROCESS_STATUS = G_PS_IN_PROCESS;
UPDATE RRS_LOCATION_UA_INTF
SET PROCESS_STATUS = G_PS_SUCCESS
WHERE DATA_SET_ID = p_data_set_id
AND PROCESS_STATUS = G_PS_IN_PROCESS;
UPDATE RRS_TRADEAREA_UA_INTF
SET PROCESS_STATUS = G_PS_IN_PROCESS
,REQUEST_ID = G_REQUEST_ID
,PROGRAM_APPLICATION_ID = G_PROGAM_APPLICATION_ID
,PROGRAM_ID = G_PROGAM_ID
,PROGRAM_UPDATE_DATE = SYSDATE
,CREATED_BY = DECODE(CREATED_BY, NULL, G_USER_ID, CREATED_BY)
,CREATION_DATE = DECODE(CREATION_DATE, NULL, SYSDATE, CREATION_DATE)
,LAST_UPDATED_BY = G_USER_ID
,LAST_UPDATE_DATE = SYSDATE
,LAST_UPDATE_LOGIN = G_LOGIN_ID
,TRANSACTION_TYPE = UPPER(NVL(TRANSACTION_TYPE,EGO_USER_ATTRS_DATA_PVT.G_SYNC_MODE))
WHERE DATA_SET_ID = p_data_set_id
AND (PROCESS_STATUS IS NULL OR
PROCESS_STATUS = G_PS_TO_BE_PROCESSED);
l_rel_sql := 'SELECT CODE FROM RRS_TRADE_AREAS_OCV' ;
DELETE FROM RRS_TRADEAREA_UA_INTF
WHERE DATA_SET_ID = p_data_set_id
AND PROCESS_STATUS = G_PS_IN_PROCESS;
UPDATE RRS_TRADEAREA_UA_INTF
SET PROCESS_STATUS = G_PS_SUCCESS
WHERE DATA_SET_ID = p_data_set_id
AND PROCESS_STATUS = G_PS_IN_PROCESS;
UPDATE RRS_SITE_UA_INTF
SET PROCESS_STATUS = G_PS_GENERIC_ERROR
WHERE DATA_SET_ID = p_data_set_id
AND PROCESS_STATUS = G_PS_IN_PROCESS;
UPDATE RRS_LOCATION_UA_INTF
SET PROCESS_STATUS = G_PS_GENERIC_ERROR
WHERE DATA_SET_ID = p_data_set_id
AND PROCESS_STATUS = G_PS_IN_PROCESS;
UPDATE RRS_TRADEAREA_UA_INTF
SET PROCESS_STATUS = G_PS_GENERIC_ERROR
WHERE DATA_SET_ID = p_data_set_id
AND PROCESS_STATUS = G_PS_IN_PROCESS;
UPDATE EGO_BULKLOAD_INTF
SET
PROCESS_STATUS = G_PS_IN_PROCESS,
LAST_UPDATE_LOGIN = FND_GLOBAL.login_id,
REQUEST_ID = FND_GLOBAL.conc_request_id,
PROGRAM_APPLICATION_ID = FND_GLOBAL.prog_appl_id,
PROGRAM_ID = FND_GLOBAL.conc_program_id
WHERE RESULTFMT_USAGE_ID = result_format_usage_id
AND process_status = G_PS_TO_BE_PROCESSED;
SELECT rrs_site_intf_sets_s.NEXTVAL
INTO l_rrs_set_process_id
FROM dual;
UPDATE EGO_BULKLOAD_INTF
SET PROCESS_STATUS = G_PS_SUCCESS,
LAST_UPDATE_LOGIN = FND_GLOBAL.login_id,
REQUEST_ID = FND_GLOBAL.conc_request_id,
PROGRAM_APPLICATION_ID = FND_GLOBAL.prog_appl_id,
PROGRAM_ID = FND_GLOBAL.conc_program_id
WHERE RESULTFMT_USAGE_ID = result_format_usage_id
AND process_status = G_PS_IN_PROCESS;