[Home] [Help]
8: /*-------------------------- PRIVATE ROUTINES ----------------------------*/
9:
10: -- ------------------------- controller_init ------------------------
11: -- Description: Various initialization processes are undertaken:
12: -- a) ensuring that data for the migration exists in ben_dm_migrations
13: -- b) entries in ben_dm_migration_requests are marked as inactive
14: -- c) r_migration_data is seeded with information about the migration
15: -- d) the migration count is incremented
16: -- e) the validity of the migration is checked
69: DATA_FILE_PATH,
70: MIGRATION_COUNT,
71: DATABASE_LOCATION,
72: STATUS
73: FROM ben_dm_migrations
74: WHERE (migration_id = p_migration_id);
75:
76: CURSOR csr_migration_request IS
77: SELECT MAX(creation_date)
103: EXIT WHEN csr_migration%NOTFOUND;
104: END LOOP;
105: CLOSE csr_migration;
106:
107: -- raise error if no matching row in ben_dm_migrations
108: IF (l_migration_id IS NULL) THEN
109: l_fatal_error_message := 'No row identified in ben_dm_migrations!';
110: RAISE e_fatal_error;
111: END IF;
105: CLOSE csr_migration;
106:
107: -- raise error if no matching row in ben_dm_migrations
108: IF (l_migration_id IS NULL) THEN
109: l_fatal_error_message := 'No row identified in ben_dm_migrations!';
110: RAISE e_fatal_error;
111: END IF;
112:
113:
139: r_migration_data.last_migration_date :=
140: ben_dm_business.last_migration_date(
141: r_migration_data);
142:
143: -- increment migration count in ben_dm_migrations (non-paused)
144: IF (p_request_data IS NULL) THEN
145: UPDATE ben_dm_migrations
146: SET migration_count = l_migration_count+1
147: WHERE migration_id = p_migration_id;
141: r_migration_data);
142:
143: -- increment migration count in ben_dm_migrations (non-paused)
144: IF (p_request_data IS NULL) THEN
145: UPDATE ben_dm_migrations
146: SET migration_count = l_migration_count+1
147: WHERE migration_id = p_migration_id;
148: COMMIT;
149: END IF;
1114: AND (phase_name = l_request_data));
1115:
1116: CURSOR csr_mig_status IS
1117: SELECT status
1118: FROM ben_dm_migrations
1119: WHERE migration_id = r_migration_data.migration_id;
1120:
1121: --
1122: BEGIN
1159: ben_dm_utility.message('SUMM','End Truncate of ben_dm_entity_results, ben_dm_resolve_mappings and ben_dm_input_file tables', 20);
1160:
1161: --
1162: -- We are ready to do the insert, so pull the next
1163: -- sequence number from ben_dm_migrations_s.
1164: --
1165: SELECT ben_dm_migrations_s.nextval
1166: INTO l_migration_id
1167: FROM dual;
1161: --
1162: -- We are ready to do the insert, so pull the next
1163: -- sequence number from ben_dm_migrations_s.
1164: --
1165: SELECT ben_dm_migrations_s.nextval
1166: INTO l_migration_id
1167: FROM dual;
1168:
1169: INSERT INTO ben_dm_migrations
1165: SELECT ben_dm_migrations_s.nextval
1166: INTO l_migration_id
1167: FROM dual;
1168:
1169: INSERT INTO ben_dm_migrations
1170: (migration_id
1171: ,migration_name
1172: ,source_migration_id
1173: ,input_parameter_file_path
1298: ben_dm_utility.message('SUMM','End Truncate of ben_dm_entity_results, ben_dm_resolve_mappings and ben_dm_input_file tables', 20);
1299:
1300: --
1301: -- We are ready to do the insert, so pull the next
1302: -- sequence number from ben_dm_migrations_s.
1303: --
1304: SELECT ben_dm_migrations_s.nextval
1305: INTO l_migration_id
1306: FROM dual;
1300: --
1301: -- We are ready to do the insert, so pull the next
1302: -- sequence number from ben_dm_migrations_s.
1303: --
1304: SELECT ben_dm_migrations_s.nextval
1305: INTO l_migration_id
1306: FROM dual;
1307:
1308: INSERT INTO ben_dm_migrations
1304: SELECT ben_dm_migrations_s.nextval
1305: INTO l_migration_id
1306: FROM dual;
1307:
1308: INSERT INTO ben_dm_migrations
1309: (migration_id
1310: ,migration_name
1311: ,source_migration_id
1312: ,input_parameter_file_path