[Home] [Help]
39: AND (group_order IN (
40: SELECT MAX(apg.group_order)
41: FROM hr_dm_phase_items pi_dn,
42: hr_dm_tables tbl,
43: hr_dm_migration_ranges mr,
44: hr_dm_phase_items pi_rg,
45: hr_dm_table_groupings tgp,
46: hr_dm_application_groups apg
47: WHERE pi_rg.phase_id = l_range_phase_id
277:
278:
279: -- ------------------------- main ------------------------
280: -- Description: This is the delete phase slave. It reads an item from the
281: -- hr_dm_migration_ranges table that is applicable for the current group.
282: -- The data is then deleted using the appropriate TDS package.
283: --
284: -- When there are no more items left for the currently active group, the
285: -- process pauses until all the threads that are processing the group have
357: AND (group_order IN (
358: SELECT MAX(apg.group_order)
359: FROM hr_dm_phase_items pi_dn,
360: hr_dm_tables tbl,
361: hr_dm_migration_ranges mr,
362: hr_dm_phase_items pi_rg,
363: hr_dm_table_groupings tgp,
364: hr_dm_application_groups apg
365: WHERE pi_rg.phase_id = l_range_phase_id
381: mr.ending_process_sequence,
382: pi_del.phase_item_id
383: FROM hr_dm_phase_items pi_del,
384: hr_dm_tables tbl,
385: hr_dm_migration_ranges mr,
386: hr_dm_phase_items pi_rg,
387: hr_dm_table_groupings tgp
388: WHERE pi_rg.phase_id = l_range_phase_id
389: AND pi_rg.phase_item_id = mr.phase_item_id
711: utl_file.put_line(l_filehandle, ' where business_group_id = ' ||
712: r_migration_data.business_group_id || ');');
713: utl_file.put_line(l_filehandle, '');
714:
715: utl_file.put_line(l_filehandle, 'delete from hr_dm_migration_ranges');
716: utl_file.put_line(l_filehandle, 'where phase_item_id in');
717: utl_file.put_line(l_filehandle, ' (select phase_item_id');
718: utl_file.put_line(l_filehandle, ' from hr_dm_phase_items');
719: utl_file.put_line(l_filehandle, ' where phase_id in');