DBA Data[Home] [Help]

APPS.HR_DM_DOWNLOAD dependencies on HR_DM_UTILITY

Line 106: hr_dm_utility.message_init;

102: --
103:
104: -- initialize messaging (only for concurrent processing)
105: if (p_concurrent_process = 'Y') then
106: hr_dm_utility.message_init;
107: end if;
108:
109: hr_dm_utility.message('ROUT','entry:hr_dm_download.main', 5);
110: hr_dm_utility.message('PARA','(p_migration_id - ' || p_migration_id ||

Line 109: hr_dm_utility.message('ROUT','entry:hr_dm_download.main', 5);

105: if (p_concurrent_process = 'Y') then
106: hr_dm_utility.message_init;
107: end if;
108:
109: hr_dm_utility.message('ROUT','entry:hr_dm_download.main', 5);
110: hr_dm_utility.message('PARA','(p_migration_id - ' || p_migration_id ||
111: ')(p_last_migration_date - ' || p_last_migration_date ||
112: ')', 10);
113: -- get the download phase_id

Line 110: hr_dm_utility.message('PARA','(p_migration_id - ' || p_migration_id ||

106: hr_dm_utility.message_init;
107: end if;
108:
109: hr_dm_utility.message('ROUT','entry:hr_dm_download.main', 5);
110: hr_dm_utility.message('PARA','(p_migration_id - ' || p_migration_id ||
111: ')(p_last_migration_date - ' || p_last_migration_date ||
112: ')', 10);
113: -- get the download phase_id
114: l_download_phase_id := hr_dm_utility.get_phase_id('DP', p_migration_id);

Line 114: l_download_phase_id := hr_dm_utility.get_phase_id('DP', p_migration_id);

110: hr_dm_utility.message('PARA','(p_migration_id - ' || p_migration_id ||
111: ')(p_last_migration_date - ' || p_last_migration_date ||
112: ')', 10);
113: -- get the download phase_id
114: l_download_phase_id := hr_dm_utility.get_phase_id('DP', p_migration_id);
115:
116: -- get the range phase_id
117: l_range_phase_id := hr_dm_utility.get_phase_id('R', p_migration_id);
118:

Line 117: l_range_phase_id := hr_dm_utility.get_phase_id('R', p_migration_id);

113: -- get the download phase_id
114: l_download_phase_id := hr_dm_utility.get_phase_id('DP', p_migration_id);
115:
116: -- get the range phase_id
117: l_range_phase_id := hr_dm_utility.get_phase_id('R', p_migration_id);
118:
119: -- get the business_group_id and migration_type
120: open csr_migration_info;
121: fetch csr_migration_info into l_business_group_id, l_migration_type;

Line 131: l_chunk_size := hr_dm_utility.chunk_size(p_business_group_id => l_business_group_id);

127: end if;
128: close csr_migration_info;
129:
130: -- find the chunk size
131: l_chunk_size := hr_dm_utility.chunk_size(p_business_group_id => l_business_group_id);
132:
133: if l_chunk_size is null then
134: l_fatal_error_message := 'hr_dm_download.main :- Chunk Size not ' ||
135: 'defined for business group ' || l_business_group_id;

Line 140: l_no_of_threads := hr_dm_utility.number_of_threads(l_business_group_id);

136: raise e_fatal_error;
137: end if;
138:
139: -- find the number of threads to use
140: l_no_of_threads := hr_dm_utility.number_of_threads(l_business_group_id);
141:
142:
143: -- loop until either range phase is in error or all range phase items have
144: -- been processed

Line 153: l_current_phase_status := nvl(hr_dm_utility.get_phase_status('DP',

149: -- get status of download phase. If phase has error status set by other slave
150: -- process then we need to stop the processing of this slave.
151: -- if null returned, then assume it is not started.
152: --
153: l_current_phase_status := nvl(hr_dm_utility.get_phase_status('DP',
154: p_migration_id),
155: 'NS');
156:
157: -- if status is error, then raise an exception

Line 173: hr_dm_utility.update_migration_ranges(p_new_status => 'S',

169: close csr_table_range;
170: l_range_id := l_table_range_rec.range_id;
171:
172: -- update status to started
173: hr_dm_utility.update_migration_ranges(p_new_status => 'S',
174: p_id => l_table_range_rec.range_id);
175:
176: -- call download table range code in TDS package
177: -- passing business_group_id, r_migration_data.last_migration_date,

Line 193: hr_dm_utility.message('INFO','Call to TDS ' || l_string , 6);

189: l_table_range_rec.batch_id || ', ' ||
190: l_chunk_size ||',' ||
191: ':l_no_of_rec_downloaded); end;';
192:
193: hr_dm_utility.message('INFO','Call to TDS ' || l_string , 6);
194: -- bind variables
195:
196: l_cursor := dbms_sql.open_cursor;
197: hr_dm_utility.message('INFO','Open dynamic cursor ' , 7);

Line 197: hr_dm_utility.message('INFO','Open dynamic cursor ' , 7);

193: hr_dm_utility.message('INFO','Call to TDS ' || l_string , 6);
194: -- bind variables
195:
196: l_cursor := dbms_sql.open_cursor;
197: hr_dm_utility.message('INFO','Open dynamic cursor ' , 7);
198:
199: dbms_sql.parse(l_cursor, l_string, dbms_sql.native);
200:
201: hr_dm_utility.message('INFO','Bind dynamic var ' , 8);

Line 201: hr_dm_utility.message('INFO','Bind dynamic var ' , 8);

197: hr_dm_utility.message('INFO','Open dynamic cursor ' , 7);
198:
199: dbms_sql.parse(l_cursor, l_string, dbms_sql.native);
200:
201: hr_dm_utility.message('INFO','Bind dynamic var ' , 8);
202: -- bind the out variable of the download procedure.
203: dbms_sql.bind_variable(l_cursor,':l_no_of_rec_downloaded',20);
204:
205: hr_dm_utility.message('INFO','Get return value ' , 9);

Line 205: hr_dm_utility.message('INFO','Get return value ' , 9);

201: hr_dm_utility.message('INFO','Bind dynamic var ' , 8);
202: -- bind the out variable of the download procedure.
203: dbms_sql.bind_variable(l_cursor,':l_no_of_rec_downloaded',20);
204:
205: hr_dm_utility.message('INFO','Get return value ' , 9);
206: l_return_value := dbms_sql.execute(l_cursor);
207:
208: hr_dm_utility.message('INFO','Get variable value ' , 10);
209: -- get the value of the download procedure.

Line 208: hr_dm_utility.message('INFO','Get variable value ' , 10);

204:
205: hr_dm_utility.message('INFO','Get return value ' , 9);
206: l_return_value := dbms_sql.execute(l_cursor);
207:
208: hr_dm_utility.message('INFO','Get variable value ' , 10);
209: -- get the value of the download procedure.
210: dbms_sql.variable_value(l_cursor,
211: ':l_no_of_rec_downloaded',
212: l_no_of_rec_downloaded);

Line 214: hr_dm_utility.message('INFO','Close dynamic variable ' , 10);

210: dbms_sql.variable_value(l_cursor,
211: ':l_no_of_rec_downloaded',
212: l_no_of_rec_downloaded);
213:
214: hr_dm_utility.message('INFO','Close dynamic variable ' , 10);
215: -- close the cursor.
216: dbms_sql.close_cursor(l_cursor);
217:
218: -- update the no of records downloaded for the range.

Line 224: hr_dm_utility.update_migration_ranges(p_new_status => 'C',

220: set row_count = l_no_of_rec_downloaded
221: where range_id = l_table_range_rec.range_id;
222:
223: -- update status to completed
224: hr_dm_utility.update_migration_ranges(p_new_status => 'C',
225: p_id => l_table_range_rec.range_id);
226: commit;
227: end loop;
228: if csr_table_range%isopen then

Line 237: hr_dm_utility.message('INFO','Download - main controller', 15);

233: retcode := 0;
234: errbuf := 'No errors - examine logfiles for detailed reports.';
235:
236:
237: hr_dm_utility.message('INFO','Download - main controller', 15);
238: hr_dm_utility.message('SUMM','Download - main controller', 20);
239: hr_dm_utility.message('ROUT','exit:hr_dm_download.main', 25);
240: hr_dm_utility.message('PARA','(retcode - ' || retcode ||
241: ')(errbuf - ' || errbuf || ')', 30);

Line 238: hr_dm_utility.message('SUMM','Download - main controller', 20);

234: errbuf := 'No errors - examine logfiles for detailed reports.';
235:
236:
237: hr_dm_utility.message('INFO','Download - main controller', 15);
238: hr_dm_utility.message('SUMM','Download - main controller', 20);
239: hr_dm_utility.message('ROUT','exit:hr_dm_download.main', 25);
240: hr_dm_utility.message('PARA','(retcode - ' || retcode ||
241: ')(errbuf - ' || errbuf || ')', 30);
242:

Line 239: hr_dm_utility.message('ROUT','exit:hr_dm_download.main', 25);

235:
236:
237: hr_dm_utility.message('INFO','Download - main controller', 15);
238: hr_dm_utility.message('SUMM','Download - main controller', 20);
239: hr_dm_utility.message('ROUT','exit:hr_dm_download.main', 25);
240: hr_dm_utility.message('PARA','(retcode - ' || retcode ||
241: ')(errbuf - ' || errbuf || ')', 30);
242:
243: -- error handling

Line 240: hr_dm_utility.message('PARA','(retcode - ' || retcode ||

236:
237: hr_dm_utility.message('INFO','Download - main controller', 15);
238: hr_dm_utility.message('SUMM','Download - main controller', 20);
239: hr_dm_utility.message('ROUT','exit:hr_dm_download.main', 25);
240: hr_dm_utility.message('PARA','(retcode - ' || retcode ||
241: ')(errbuf - ' || errbuf || ')', 30);
242:
243: -- error handling
244: exception

Line 251: hr_dm_utility.error(SQLCODE,'hr_dm_download.main',l_fatal_error_message,'R');

247: close csr_table_range;
248: end if;
249: retcode := 0;
250: errbuf := 'An error occurred during the migration - examine logfiles for detailed reports.';
251: hr_dm_utility.error(SQLCODE,'hr_dm_download.main',l_fatal_error_message,'R');
252: hr_dm_utility.error(SQLCODE,'hr_dm_download.main','(none)','R');
253: when others then
254: if csr_table_range%isopen then
255: close csr_table_range;

Line 252: hr_dm_utility.error(SQLCODE,'hr_dm_download.main','(none)','R');

248: end if;
249: retcode := 0;
250: errbuf := 'An error occurred during the migration - examine logfiles for detailed reports.';
251: hr_dm_utility.error(SQLCODE,'hr_dm_download.main',l_fatal_error_message,'R');
252: hr_dm_utility.error(SQLCODE,'hr_dm_download.main','(none)','R');
253: when others then
254: if csr_table_range%isopen then
255: close csr_table_range;
256: end if;

Line 260: hr_dm_utility.update_migration_ranges(p_new_status => 'E',

256: end if;
257: retcode := 2;
258: errbuf := 'An error occurred during the migration - examine logfiles for detailed reports.';
259: -- update status to error
260: hr_dm_utility.update_migration_ranges(p_new_status => 'E',
261: p_id => l_range_id);
262: hr_dm_utility.error(SQLCODE,'hr_dm_download.main','(none)','R');
263: --
264: end main;

Line 262: hr_dm_utility.error(SQLCODE,'hr_dm_download.main','(none)','R');

258: errbuf := 'An error occurred during the migration - examine logfiles for detailed reports.';
259: -- update status to error
260: hr_dm_utility.update_migration_ranges(p_new_status => 'E',
261: p_id => l_range_id);
262: hr_dm_utility.error(SQLCODE,'hr_dm_download.main','(none)','R');
263: --
264: end main;
265: --
266: end hr_dm_download;