7:
8: -- ------------------------- set_active ------------------------
9: -- Description: The next group to be deleted is selected by finding the
10: -- first unprocessed group on the locking ladder and updating the table
11: -- hr_dm_migrations with its group id.
12: --
13: --
14: -- Input Parameters
15: -- p_migration_id - current migration
78: OPEN csr_get_active;
79: FETCH csr_get_active INTO l_active_group;
80: CLOSE csr_get_active;
81:
82: -- update hr_dm_migrations with active group
83: UPDATE hr_dm_migrations
84: SET active_group = l_active_group
85: WHERE migration_id = p_migration_id;
86:
79: FETCH csr_get_active INTO l_active_group;
80: CLOSE csr_get_active;
81:
82: -- update hr_dm_migrations with active group
83: UPDATE hr_dm_migrations
84: SET active_group = l_active_group
85: WHERE migration_id = p_migration_id;
86:
87: COMMIT;
341:
342:
343: CURSOR csr_migration_info IS
344: SELECT business_group_id, migration_type
345: FROM hr_dm_migrations
346: WHERE migration_id = p_migration_id;
347:
348: CURSOR csr_active_group IS
349: SELECT active_group
346: WHERE migration_id = p_migration_id;
347:
348: CURSOR csr_active_group IS
349: SELECT active_group
350: FROM hr_dm_migrations
351: WHERE migration_id = p_migration_id;
352:
353: CURSOR csr_group_work IS
354: SELECT group_id
706: utl_file.put_line(l_filehandle, '-- migration info');
707: utl_file.put_line(l_filehandle, 'delete from hr_dm_migration_requests');
708: utl_file.put_line(l_filehandle, 'where migration_id in');
709: utl_file.put_line(l_filehandle, ' (select migration_id');
710: utl_file.put_line(l_filehandle, ' from hr_dm_migrations');
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:
720: utl_file.put_line(l_filehandle, ' (select phase_id');
721: utl_file.put_line(l_filehandle, ' from hr_dm_phases');
722: utl_file.put_line(l_filehandle, ' where migration_id in');
723: utl_file.put_line(l_filehandle, ' (select migration_id');
724: utl_file.put_line(l_filehandle, ' from hr_dm_migrations');
725: utl_file.put_line(l_filehandle, ' where business_group_id = ' ||
726: r_migration_data.business_group_id || ')));');
727: utl_file.put_line(l_filehandle, '');
728:
734: utl_file.put_line(l_filehandle, ' (select phase_id');
735: utl_file.put_line(l_filehandle, ' from hr_dm_phases');
736: utl_file.put_line(l_filehandle, ' where migration_id in');
737: utl_file.put_line(l_filehandle, ' (select migration_id');
738: utl_file.put_line(l_filehandle, ' from hr_dm_migrations');
739: utl_file.put_line(l_filehandle, ' where business_group_id = ' ||
740: r_migration_data.business_group_id || ')));');
741: utl_file.put_line(l_filehandle, '');
742:
745: utl_file.put_line(l_filehandle, ' (select phase_id');
746: utl_file.put_line(l_filehandle, ' from hr_dm_phases');
747: utl_file.put_line(l_filehandle, ' where migration_id in');
748: utl_file.put_line(l_filehandle, ' (select migration_id');
749: utl_file.put_line(l_filehandle, ' from hr_dm_migrations');
750: utl_file.put_line(l_filehandle, ' where business_group_id = ' ||
751: r_migration_data.business_group_id || '));');
752: utl_file.put_line(l_filehandle, '');
753:
750: utl_file.put_line(l_filehandle, ' where business_group_id = ' ||
751: r_migration_data.business_group_id || '));');
752: utl_file.put_line(l_filehandle, '');
753:
754: utl_file.put_line(l_filehandle, 'delete from hr_dm_migrations');
755: utl_file.put_line(l_filehandle, 'where migration_id in');
756: utl_file.put_line(l_filehandle, ' (select migration_id');
757: utl_file.put_line(l_filehandle, ' from hr_dm_migrations');
758: utl_file.put_line(l_filehandle, ' where business_group_id = ' ||
753:
754: utl_file.put_line(l_filehandle, 'delete from hr_dm_migrations');
755: utl_file.put_line(l_filehandle, 'where migration_id in');
756: utl_file.put_line(l_filehandle, ' (select migration_id');
757: utl_file.put_line(l_filehandle, ' from hr_dm_migrations');
758: utl_file.put_line(l_filehandle, ' where business_group_id = ' ||
759: r_migration_data.business_group_id || ');');
760: utl_file.put_line(l_filehandle, '');
761: