The following lines contain the word 'select', 'insert', 'update' or 'delete':
CURSOR csr_select_pi IS
SELECT DISTINCT tbl.table_name
FROM ben_dm_tables tbl, ben_dm_table_order tbo,
all_objects obj
WHERE (tbo.table_id = tbl.table_id)
AND (obj.object_name = tbl.table_name)
AND (obj.object_type = 'TABLE')
AND obj.owner in
(l_apps_owner,
l_ff_owner,
l_ben_owner,
l_pay_owner,
l_per_owner);
OPEN csr_select_pi;
FETCH csr_select_pi INTO l_table_name;
EXIT WHEN csr_select_pi%NOTFOUND;
INSERT INTO ben_dm_phase_items (PHASE_ITEM_ID,
PHASE_ID,
GROUP_ORDER,
TABLE_NAME,
STATUS,
START_TIME,
END_TIME,
CREATED_BY,
CREATION_DATE,
LAST_UPDATED_BY,
LAST_UPDATE_DATE,
LAST_UPDATE_LOGIN)
SELECT ben_dm_phase_items_s.nextval,
l_phase_id,
NULL,
l_table_name,
'NS',
NULL,
NULL,
1,
SYSDATE,
1,
SYSDATE,
NULL
FROM dual
WHERE NOT EXISTS
(SELECT NULL FROM ben_dm_phase_items
WHERE ((phase_id = l_phase_id)
AND (table_name = l_table_name)));
CLOSE csr_select_pi;
CURSOR csr_select_pi IS
SELECT input_file_id, group_order
FROM ben_dm_input_file
ORDER BY group_order asc;
OPEN csr_select_pi;
FETCH csr_select_pi INTO l_input_file_id, l_group_order;
EXIT WHEN csr_select_pi%NOTFOUND;
INSERT INTO ben_dm_phase_items (PHASE_ITEM_ID,
PHASE_ID,
GROUP_ORDER,
TABLE_NAME,
INPUT_FILE_ID,
STATUS,
START_TIME,
END_TIME,
CREATED_BY,
CREATION_DATE,
LAST_UPDATED_BY,
LAST_UPDATE_DATE,
LAST_UPDATE_LOGIN)
SELECT ben_dm_phase_items_s.nextval,
l_phase_id,
l_group_order,
NULL,
l_input_file_id,
'NS',
NULL,
NULL,
1,
SYSDATE,
1,
SYSDATE,
NULL
FROM dual
WHERE NOT EXISTS
(SELECT NULL FROM ben_dm_phase_items
WHERE ((phase_id = l_phase_id)
AND (input_file_id = l_input_file_id)));
CLOSE csr_select_pi;
CURSOR csr_select_pi IS
SELECT distinct group_order
FROM ben_dm_input_file
-- WHERE migration_id = r_migration_data.migration_id
ORDER BY group_order asc;
OPEN csr_select_pi;
FETCH csr_select_pi INTO l_group_order;
EXIT WHEN csr_select_pi%NOTFOUND;
INSERT INTO ben_dm_phase_items (PHASE_ITEM_ID,
PHASE_ID,
GROUP_ORDER,
TABLE_NAME,
STATUS,
START_TIME,
END_TIME,
CREATED_BY,
CREATION_DATE,
LAST_UPDATED_BY,
LAST_UPDATE_DATE,
LAST_UPDATE_LOGIN)
SELECT ben_dm_phase_items_s.nextval,
l_phase_id,
l_group_order,
NULL,
'NS',
NULL,
NULL,
1,
SYSDATE,
1,
SYSDATE,
NULL
FROM dual
WHERE NOT EXISTS
(SELECT NULL FROM ben_dm_phase_items
WHERE ((phase_id = l_phase_id)
AND (group_order = l_group_order)));
CLOSE csr_select_pi;
SELECT phase_name, previous_phase, next_phase, database_location
FROM hr_dm_phase_rules
WHERE ((migration_type = 'SP')
AND (previous_phase = l_search_phase))
AND database_location = r_migration_data.database_location;
INSERT INTO ben_dm_phases (PHASE_ID,
MIGRATION_ID,
PHASE_NAME,
STATUS,
START_TIME,
END_TIME,
CREATED_BY,
CREATION_DATE,
LAST_UPDATED_BY,
LAST_UPDATE_DATE,
LAST_UPDATE_LOGIN)
SELECT ben_dm_phases_s.nextval,
r_migration_data.migration_id,
p_phase_name,
'NS',
NULL,
NULL,
1,
SYSDATE,
1,
SYSDATE,
NULL
FROM dual
WHERE NOT EXISTS
(SELECT NULL FROM ben_dm_phases
WHERE ((migration_id = r_migration_data.migration_id)
AND (phase_name = p_phase_name)));
SELECT phase_name, database_location
FROM hr_dm_phase_rules
WHERE ((migration_type = 'SP')
AND database_location = r_migration_data.database_location);
ben_dm_utility.update_phases(p_new_status => 'S',
p_id => ben_dm_utility.get_phase_id('I',
r_migration_data.migration_id));
DELETE ben_dm_entity_results;
ben_dm_utility.update_phases(p_new_status => 'C',
p_id => ben_dm_utility.get_phase_id('I',
r_migration_data.migration_id));