6: B_STAGE_ID STAGE_ID_TYPE;
7: B_TRANSACTION_LEVEL TRANSACTION_LEVEL_TYPE;
8: --bug 3133379
9: --- Local PL/SQL table variables.
10: i_stage_record_type ec_utils.mapping_tbl;
11: i_record_info Record_Info;
12: i_level_info Level_Info;
13:
14: vPath varchar2(1000);
80:
81: i_stage_cursor number :=0;
82: l_common_key varchar2(2000);
83:
84: i_empty_tbl ec_utils.mapping_tbl;
85:
86: BEGIN
87: if ec_debug.G_debug_level >= 2 then
88: ec_debug.push('EC_OUTBOUND_STAGE.GET_DATA');
157: ec_debug.pl(0,'EC','ECE_SEED_DATA_MISSING','TRANSACTION_TYPE',i_transaction_type);
158: /**
159: Set the Retcode for the Concurrent Manager
160: **/
161: ec_utils.i_ret_code := 2;
162: raise ec_utils.program_exit;
163: end if;
164:
165: /**
158: /**
159: Set the Retcode for the Concurrent Manager
160: **/
161: ec_utils.i_ret_code := 2;
162: raise ec_utils.program_exit;
163: end if;
164:
165: /**
166: Build each record's SELECT statement
241: ec_debug.pop('EC_OUTBOUND_STAGE.GET_DATA');
242: end if;
243: EXCEPTION
244: WHEN UTL_FILE.write_error THEN
245: ec_utils.i_ret_code :=2;
246: ec_debug.pl(0,'EC','ECE_UTL_WRITE_ERROR',null);
247: ec_debug.pl(0,'EC','ECE_PROGRAM_ERROR','PROGRESS_LEVEL','EC_OUTBOUND_STAGE.GET_DATA');
248: ec_debug.pl(0,'EC','ECE_ERROR_MESSAGE','ERROR_MESSAGE',SQLERRM);
249: utl_file.fclose(u_file_handle);
246: ec_debug.pl(0,'EC','ECE_UTL_WRITE_ERROR',null);
247: ec_debug.pl(0,'EC','ECE_PROGRAM_ERROR','PROGRESS_LEVEL','EC_OUTBOUND_STAGE.GET_DATA');
248: ec_debug.pl(0,'EC','ECE_ERROR_MESSAGE','ERROR_MESSAGE',SQLERRM);
249: utl_file.fclose(u_file_handle);
250: raise EC_UTILS.PROGRAM_EXIT;
251: WHEN UTL_FILE.read_error THEN
252: ec_utils.i_ret_code :=2;
253: ec_debug.pl(0,'EC','ECE_UTL_READ_ERROR',null);
254: ec_debug.pl(0,'EC','ECE_PROGRAM_ERROR','PROGRESS_LEVEL','EC_OUTBOUND_STAGE.GET_DATA');
248: ec_debug.pl(0,'EC','ECE_ERROR_MESSAGE','ERROR_MESSAGE',SQLERRM);
249: utl_file.fclose(u_file_handle);
250: raise EC_UTILS.PROGRAM_EXIT;
251: WHEN UTL_FILE.read_error THEN
252: ec_utils.i_ret_code :=2;
253: ec_debug.pl(0,'EC','ECE_UTL_READ_ERROR',null);
254: ec_debug.pl(0,'EC','ECE_PROGRAM_ERROR','PROGRESS_LEVEL','EC_OUTBOUND_STAGE.GET_DATA');
255: ec_debug.pl(0,'EC','ECE_ERROR_MESSAGE','ERROR_MESSAGE',SQLERRM);
256: utl_file.fclose(u_file_handle);
253: ec_debug.pl(0,'EC','ECE_UTL_READ_ERROR',null);
254: ec_debug.pl(0,'EC','ECE_PROGRAM_ERROR','PROGRESS_LEVEL','EC_OUTBOUND_STAGE.GET_DATA');
255: ec_debug.pl(0,'EC','ECE_ERROR_MESSAGE','ERROR_MESSAGE',SQLERRM);
256: utl_file.fclose(u_file_handle);
257: raise EC_UTILS.PROGRAM_EXIT;
258: WHEN UTL_FILE.invalid_path THEN
259: ec_utils.i_ret_code :=2;
260: ec_debug.pl(0,'EC','ECE_UTL_INVALID_PATH',null);
261: ec_debug.pl(0,'EC','ECE_PROGRAM_ERROR','PROGRESS_LEVEL','EC_OUTBOUND_STAGE.GET_DATA');
255: ec_debug.pl(0,'EC','ECE_ERROR_MESSAGE','ERROR_MESSAGE',SQLERRM);
256: utl_file.fclose(u_file_handle);
257: raise EC_UTILS.PROGRAM_EXIT;
258: WHEN UTL_FILE.invalid_path THEN
259: ec_utils.i_ret_code :=2;
260: ec_debug.pl(0,'EC','ECE_UTL_INVALID_PATH',null);
261: ec_debug.pl(0,'EC','ECE_PROGRAM_ERROR','PROGRESS_LEVEL','EC_OUTBOUND_STAGE.GET_DATA');
262: ec_debug.pl(0,'EC','ECE_ERROR_MESSAGE','ERROR_MESSAGE',SQLERRM);
263: utl_file.fclose(u_file_handle);
260: ec_debug.pl(0,'EC','ECE_UTL_INVALID_PATH',null);
261: ec_debug.pl(0,'EC','ECE_PROGRAM_ERROR','PROGRESS_LEVEL','EC_OUTBOUND_STAGE.GET_DATA');
262: ec_debug.pl(0,'EC','ECE_ERROR_MESSAGE','ERROR_MESSAGE',SQLERRM);
263: utl_file.fclose(u_file_handle);
264: raise EC_UTILS.PROGRAM_EXIT;
265: WHEN UTL_FILE.invalid_mode THEN
266: ec_utils.i_ret_code :=2;
267: ec_debug.pl(0,'EC','ECE_UTL_INVALID_MODE',null);
268: ec_debug.pl(0,'EC','ECE_PROGRAM_ERROR','PROGRESS_LEVEL','EC_OUTBOUND_STAGE.GET_DATA');
262: ec_debug.pl(0,'EC','ECE_ERROR_MESSAGE','ERROR_MESSAGE',SQLERRM);
263: utl_file.fclose(u_file_handle);
264: raise EC_UTILS.PROGRAM_EXIT;
265: WHEN UTL_FILE.invalid_mode THEN
266: ec_utils.i_ret_code :=2;
267: ec_debug.pl(0,'EC','ECE_UTL_INVALID_MODE',null);
268: ec_debug.pl(0,'EC','ECE_PROGRAM_ERROR','PROGRESS_LEVEL','EC_OUTBOUND_STAGE.GET_DATA');
269: ec_debug.pl(0,'EC','ECE_ERROR_MESSAGE','ERROR_MESSAGE',SQLERRM);
270: utl_file.fclose(u_file_handle);
267: ec_debug.pl(0,'EC','ECE_UTL_INVALID_MODE',null);
268: ec_debug.pl(0,'EC','ECE_PROGRAM_ERROR','PROGRESS_LEVEL','EC_OUTBOUND_STAGE.GET_DATA');
269: ec_debug.pl(0,'EC','ECE_ERROR_MESSAGE','ERROR_MESSAGE',SQLERRM);
270: utl_file.fclose(u_file_handle);
271: raise EC_UTILS.PROGRAM_EXIT;
272: WHEN UTL_FILE.invalid_operation THEN
273: ec_utils.i_ret_code :=2;
274: ec_debug.pl(0,'EC','ECE_UTL_INVALID_OPERATION',null);
275: ec_debug.pl(0,'EC','ECE_PROGRAM_ERROR','PROGRESS_LEVEL','EC_OUTBOUND_STAGE.GET_DATA');
269: ec_debug.pl(0,'EC','ECE_ERROR_MESSAGE','ERROR_MESSAGE',SQLERRM);
270: utl_file.fclose(u_file_handle);
271: raise EC_UTILS.PROGRAM_EXIT;
272: WHEN UTL_FILE.invalid_operation THEN
273: ec_utils.i_ret_code :=2;
274: ec_debug.pl(0,'EC','ECE_UTL_INVALID_OPERATION',null);
275: ec_debug.pl(0,'EC','ECE_PROGRAM_ERROR','PROGRESS_LEVEL','EC_OUTBOUND_STAGE.GET_DATA');
276: ec_debug.pl(0,'EC','ECE_ERROR_MESSAGE','ERROR_MESSAGE',SQLERRM);
277: utl_file.fclose(u_file_handle);
274: ec_debug.pl(0,'EC','ECE_UTL_INVALID_OPERATION',null);
275: ec_debug.pl(0,'EC','ECE_PROGRAM_ERROR','PROGRESS_LEVEL','EC_OUTBOUND_STAGE.GET_DATA');
276: ec_debug.pl(0,'EC','ECE_ERROR_MESSAGE','ERROR_MESSAGE',SQLERRM);
277: utl_file.fclose(u_file_handle);
278: raise EC_UTILS.PROGRAM_EXIT;
279: WHEN UTL_FILE.invalid_filehandle THEN
280: ec_utils.i_ret_code :=2;
281: ec_debug.pl(0,'EC','ECE_UTL_INVALID_FILEHANDLE',null);
282: ec_debug.pl(0,'EC','ECE_PROGRAM_ERROR','PROGRESS_LEVEL','EC_OUTBOUND_STAGE.GET_DATA');
276: ec_debug.pl(0,'EC','ECE_ERROR_MESSAGE','ERROR_MESSAGE',SQLERRM);
277: utl_file.fclose(u_file_handle);
278: raise EC_UTILS.PROGRAM_EXIT;
279: WHEN UTL_FILE.invalid_filehandle THEN
280: ec_utils.i_ret_code :=2;
281: ec_debug.pl(0,'EC','ECE_UTL_INVALID_FILEHANDLE',null);
282: ec_debug.pl(0,'EC','ECE_PROGRAM_ERROR','PROGRESS_LEVEL','EC_OUTBOUND_STAGE.GET_DATA');
283: ec_debug.pl(0,'EC','ECE_ERROR_MESSAGE','ERROR_MESSAGE',SQLERRM);
284: utl_file.fclose(u_file_handle);
281: ec_debug.pl(0,'EC','ECE_UTL_INVALID_FILEHANDLE',null);
282: ec_debug.pl(0,'EC','ECE_PROGRAM_ERROR','PROGRESS_LEVEL','EC_OUTBOUND_STAGE.GET_DATA');
283: ec_debug.pl(0,'EC','ECE_ERROR_MESSAGE','ERROR_MESSAGE',SQLERRM);
284: utl_file.fclose(u_file_handle);
285: raise EC_UTILS.PROGRAM_EXIT;
286: WHEN UTL_FILE.internal_error THEN
287: ec_utils.i_ret_code :=2;
288: ec_debug.pl(0,'EC','ECE_UTL_INTERNAL_ERROR',null);
289: ec_debug.pl(0,'EC','ECE_PROGRAM_ERROR','PROGRESS_LEVEL','EC_OUTBOUND_STAGE.GET_DATA');
283: ec_debug.pl(0,'EC','ECE_ERROR_MESSAGE','ERROR_MESSAGE',SQLERRM);
284: utl_file.fclose(u_file_handle);
285: raise EC_UTILS.PROGRAM_EXIT;
286: WHEN UTL_FILE.internal_error THEN
287: ec_utils.i_ret_code :=2;
288: ec_debug.pl(0,'EC','ECE_UTL_INTERNAL_ERROR',null);
289: ec_debug.pl(0,'EC','ECE_PROGRAM_ERROR','PROGRESS_LEVEL','EC_OUTBOUND_STAGE.GET_DATA');
290: ec_debug.pl(0,'EC','ECE_ERROR_MESSAGE','ERROR_MESSAGE',SQLERRM);
291: utl_file.fclose(u_file_handle);
288: ec_debug.pl(0,'EC','ECE_UTL_INTERNAL_ERROR',null);
289: ec_debug.pl(0,'EC','ECE_PROGRAM_ERROR','PROGRESS_LEVEL','EC_OUTBOUND_STAGE.GET_DATA');
290: ec_debug.pl(0,'EC','ECE_ERROR_MESSAGE','ERROR_MESSAGE',SQLERRM);
291: utl_file.fclose(u_file_handle);
292: raise EC_UTILS.PROGRAM_EXIT;
293: WHEN EC_UTILS.PROGRAM_EXIT THEN
294: raise;
295: WHEN OTHERS THEN
296: ec_utils.i_ret_code :=2;
289: ec_debug.pl(0,'EC','ECE_PROGRAM_ERROR','PROGRESS_LEVEL','EC_OUTBOUND_STAGE.GET_DATA');
290: ec_debug.pl(0,'EC','ECE_ERROR_MESSAGE','ERROR_MESSAGE',SQLERRM);
291: utl_file.fclose(u_file_handle);
292: raise EC_UTILS.PROGRAM_EXIT;
293: WHEN EC_UTILS.PROGRAM_EXIT THEN
294: raise;
295: WHEN OTHERS THEN
296: ec_utils.i_ret_code :=2;
297: ec_debug.pl(0,'EC','ECE_PROGRAM_ERROR','PROGRESS_LEVEL','EC_OUTBOUND_STAGE.GET_DATA');
292: raise EC_UTILS.PROGRAM_EXIT;
293: WHEN EC_UTILS.PROGRAM_EXIT THEN
294: raise;
295: WHEN OTHERS THEN
296: ec_utils.i_ret_code :=2;
297: ec_debug.pl(0,'EC','ECE_PROGRAM_ERROR','PROGRESS_LEVEL','EC_OUTBOUND_STAGE.GET_DATA');
298: ec_debug.pl(0,'EC','ECE_ERROR_MESSAGE','ERROR_MESSAGE',SQLERRM);
299: utl_file.fclose(u_file_handle);
300: raise EC_UTILS.PROGRAM_EXIT;
296: ec_utils.i_ret_code :=2;
297: ec_debug.pl(0,'EC','ECE_PROGRAM_ERROR','PROGRESS_LEVEL','EC_OUTBOUND_STAGE.GET_DATA');
298: ec_debug.pl(0,'EC','ECE_ERROR_MESSAGE','ERROR_MESSAGE',SQLERRM);
299: utl_file.fclose(u_file_handle);
300: raise EC_UTILS.PROGRAM_EXIT;
301: END Get_Data;
302:
303: /**
304: This procedures fetches the staging data in the proper hierarchecal order by recursively
390: -- WHEN OTHERS THEN
391: -- error_position := dbms_sql.last_error_position;
392: -- ec_debug.pl(0,'EC','ECE_PROGRAM_ERROR','PROGRESS_LEVEL','EC_OUTBOUND_STAGE.FETCH_STAGE_DATA');
393: -- ece_error_handling_pvt.print_parse_error (error_position,cSelect_stmt);
394: -- EC_UTILS.i_ret_code :=2;
395: -- raise EC_UTILS.PROGRAM_EXIT;
396: -- END;
397:
398: /**
391: -- error_position := dbms_sql.last_error_position;
392: -- ec_debug.pl(0,'EC','ECE_PROGRAM_ERROR','PROGRESS_LEVEL','EC_OUTBOUND_STAGE.FETCH_STAGE_DATA');
393: -- ece_error_handling_pvt.print_parse_error (error_position,cSelect_stmt);
394: -- EC_UTILS.i_ret_code :=2;
395: -- raise EC_UTILS.PROGRAM_EXIT;
396: -- END;
397:
398: /**
399: Bind values
425: ec_debug.pl(0,'EC','ECE_PROGRAM_ERROR','PROGRESS_LEVEL', 'EC_OUTBOUND_STAGE.FETCH_STAGE_DATA');
426: ec_debug.pl(0,'EC','ECE_ERROR_MESSAGE','ERROR_MESSAGE',SQLERRM);
427: ec_debug.pl(0,'EC','ECE_ERROR_SQL',null);
428: ec_debug.pl(0,cSelect_stmt);
429: EC_UTILS.i_ret_code :=2;
430: raise EC_UTILS.PROGRAM_EXIT;
431: END; **/
432:
433: /** BEGIN
426: ec_debug.pl(0,'EC','ECE_ERROR_MESSAGE','ERROR_MESSAGE',SQLERRM);
427: ec_debug.pl(0,'EC','ECE_ERROR_SQL',null);
428: ec_debug.pl(0,cSelect_stmt);
429: EC_UTILS.i_ret_code :=2;
430: raise EC_UTILS.PROGRAM_EXIT;
431: END; **/
432:
433: /** BEGIN
434: WHILE dbms_sql.fetch_rows(i_stage_cursor) > 0
464: EXCEPTION
465: WHEN OTHERS THEN
466: ec_debug.pl(0,'EC','ECE_PROGRAM_ERROR','PROGRESS_LEVEL', 'EC_OUTBOUND_STAGE.FETCH_STAGE_DATA');
467: ec_debug.pl(0,'EC','ECE_ERROR_MESSAGE','ERROR_MESSAGE',SQLERRM);
468: EC_UTILS.i_ret_code :=2;
469: raise EC_UTILS.PROGRAM_EXIT;
470: END;
471: **/
472: /**
465: WHEN OTHERS THEN
466: ec_debug.pl(0,'EC','ECE_PROGRAM_ERROR','PROGRESS_LEVEL', 'EC_OUTBOUND_STAGE.FETCH_STAGE_DATA');
467: ec_debug.pl(0,'EC','ECE_ERROR_MESSAGE','ERROR_MESSAGE',SQLERRM);
468: EC_UTILS.i_ret_code :=2;
469: raise EC_UTILS.PROGRAM_EXIT;
470: END;
471: **/
472: /**
473: Close Cursor
477: ec_debug.pop('EC_OUTBOUND_STAGE.FETCH_STAGE_DATA');
478: end if;
479:
480: EXCEPTION
481: WHEN EC_UTILS.PROGRAM_EXIT THEN
482: raise;
483: WHEN OTHERS THEN
484: ec_debug.pl(0,'EC','ECE_PROGRAM_ERROR','PROGRESS_LEVEL','EC_OUTBOUND_STAGE.FETCH_STAGE_DATA');
485: ec_debug.pl(0,'EC','ECE_ERROR_MESSAGE','ERROR_MESSAGE',SQLERRM);
482: raise;
483: WHEN OTHERS THEN
484: ec_debug.pl(0,'EC','ECE_PROGRAM_ERROR','PROGRESS_LEVEL','EC_OUTBOUND_STAGE.FETCH_STAGE_DATA');
485: ec_debug.pl(0,'EC','ECE_ERROR_MESSAGE','ERROR_MESSAGE',SQLERRM);
486: EC_UTILS.i_ret_code:=2;
487: raise EC_UTILS.PROGRAM_EXIT;
488: END Fetch_Stage_Data;
489:
490: /**
483: WHEN OTHERS THEN
484: ec_debug.pl(0,'EC','ECE_PROGRAM_ERROR','PROGRESS_LEVEL','EC_OUTBOUND_STAGE.FETCH_STAGE_DATA');
485: ec_debug.pl(0,'EC','ECE_ERROR_MESSAGE','ERROR_MESSAGE',SQLERRM);
486: EC_UTILS.i_ret_code:=2;
487: raise EC_UTILS.PROGRAM_EXIT;
488: END Fetch_Stage_Data;
489:
490: /**
491: This procedures loads the mapping information between the Flat File
614: ec_debug.pl(0,'EC','ECE_SEED_NOT_LEVEL','TRANSACTION_TYPE',i_transaction_type,'LEVEL',i_level);
615: /**
616: Set the Retcode for the Concurrent Manager to Error.
617: **/
618: ec_utils.i_ret_code := 2;
619: raise EC_UTILS.PROGRAM_EXIT;
620: end if;
621: if ec_debug.G_debug_level >= 2 then
622: ec_debug.pop('EC_OUTBOUND_STAGE.POPULATE_FLATFILE_MAPPING');
615: /**
616: Set the Retcode for the Concurrent Manager to Error.
617: **/
618: ec_utils.i_ret_code := 2;
619: raise EC_UTILS.PROGRAM_EXIT;
620: end if;
621: if ec_debug.G_debug_level >= 2 then
622: ec_debug.pop('EC_OUTBOUND_STAGE.POPULATE_FLATFILE_MAPPING');
623: end if;
621: if ec_debug.G_debug_level >= 2 then
622: ec_debug.pop('EC_OUTBOUND_STAGE.POPULATE_FLATFILE_MAPPING');
623: end if;
624: EXCEPTION
625: WHEN EC_UTILS.PROGRAM_EXIT then
626: raise;
627: WHEN OTHERS then
628: ec_debug.pl(0,'EC','ECE_PROGRAM_ERROR','PROGRESS_LEVEL','EC_OUTBOUND_STAGE.POPULATE_FLATFILE_MAPPING');
629: ec_debug.pl(0,'EC','ECE_ERROR_MESSAGE','ERROR_MESSAGE',SQLERRM);
626: raise;
627: WHEN OTHERS then
628: ec_debug.pl(0,'EC','ECE_PROGRAM_ERROR','PROGRESS_LEVEL','EC_OUTBOUND_STAGE.POPULATE_FLATFILE_MAPPING');
629: ec_debug.pl(0,'EC','ECE_ERROR_MESSAGE','ERROR_MESSAGE',SQLERRM);
630: ec_utils.i_ret_code:=2;
631: raise ec_utils.program_exit;
632: END populate_flatfile_mapping;
633:
634: /**
627: WHEN OTHERS then
628: ec_debug.pl(0,'EC','ECE_PROGRAM_ERROR','PROGRESS_LEVEL','EC_OUTBOUND_STAGE.POPULATE_FLATFILE_MAPPING');
629: ec_debug.pl(0,'EC','ECE_ERROR_MESSAGE','ERROR_MESSAGE',SQLERRM);
630: ec_utils.i_ret_code:=2;
631: raise ec_utils.program_exit;
632: END populate_flatfile_mapping;
633:
634: /**
635: This procedure formats the main body of a SELECT statement for each record number of
718: EXCEPTION
719: WHEN OTHERS then
720: ec_debug.pl(0,'EC','ECE_PROGRAM_ERROR','PROGRESS_LEVEL','EC_OUTBOUND_STAGE.GET_SELECT_STMT');
721: ec_debug.pl(0,'EC','ECE_ERROR_MESSAGE','ERROR_MESSAGE',SQLERRM);
722: ec_utils.i_ret_code:=2;
723: raise EC_UTILS.PROGRAM_EXIT;
724: END get_select_stmt;
725:
726: /**
719: WHEN OTHERS then
720: ec_debug.pl(0,'EC','ECE_PROGRAM_ERROR','PROGRESS_LEVEL','EC_OUTBOUND_STAGE.GET_SELECT_STMT');
721: ec_debug.pl(0,'EC','ECE_ERROR_MESSAGE','ERROR_MESSAGE',SQLERRM);
722: ec_utils.i_ret_code:=2;
723: raise EC_UTILS.PROGRAM_EXIT;
724: END get_select_stmt;
725:
726: /**
727: The Data is extracted from the Staging table using loaded in the Local PL/SQL table.
809: WHEN OTHERS THEN
810: error_position := dbms_sql.last_error_position;
811: ec_debug.pl(0,'EC','ECE_PROGRAM_ERROR','PROGRESS_LEVEL','EC_OUTBOUND_STAGE.SELECT_FROM_STAGE_TABLE');
812: ece_error_handling_pvt.print_parse_error (error_position,cSelect_stmt);
813: EC_UTILS.i_ret_code :=2;
814: raise EC_UTILS.PROGRAM_EXIT;
815: END;
816: if ec_debug.G_debug_level = 3 then
817: ec_debug.pl(3,'EC','ECE_STAGE_SELECT_LEVEL','LEVEL',i_level,null);
810: error_position := dbms_sql.last_error_position;
811: ec_debug.pl(0,'EC','ECE_PROGRAM_ERROR','PROGRESS_LEVEL','EC_OUTBOUND_STAGE.SELECT_FROM_STAGE_TABLE');
812: ece_error_handling_pvt.print_parse_error (error_position,cSelect_stmt);
813: EC_UTILS.i_ret_code :=2;
814: raise EC_UTILS.PROGRAM_EXIT;
815: END;
816: if ec_debug.G_debug_level = 3 then
817: ec_debug.pl(3,'EC','ECE_STAGE_SELECT_LEVEL','LEVEL',i_level,null);
818: end if;
853: ec_debug.pl(0,'EC','ECE_PROGRAM_ERROR','PROGRESS_LEVEL', 'EC_OUTBOUND_STAGE.SELECT_FROM_STAGE_TABLE');
854: ec_debug.pl(0,'EC','ECE_ERROR_MESSAGE','ERROR_MESSAGE',SQLERRM);
855: ec_debug.pl(0,'EC','ECE_ERROR_SQL',null);
856: ec_debug.pl(0,cSelect_stmt);
857: EC_UTILS.i_ret_code :=2;
858: raise EC_UTILS.PROGRAM_EXIT;
859: END;
860:
861: BEGIN
854: ec_debug.pl(0,'EC','ECE_ERROR_MESSAGE','ERROR_MESSAGE',SQLERRM);
855: ec_debug.pl(0,'EC','ECE_ERROR_SQL',null);
856: ec_debug.pl(0,cSelect_stmt);
857: EC_UTILS.i_ret_code :=2;
858: raise EC_UTILS.PROGRAM_EXIT;
859: END;
860:
861: BEGIN
862: WHILE dbms_sql.fetch_rows(i_select_cursor) > 0
886: EXCEPTION
887: WHEN OTHERS THEN
888: ec_debug.pl(0,'EC','ECE_PROGRAM_ERROR','PROGRESS_LEVEL', 'EC_OUTBOUND_STAGE.SELECT_FROM_STAGE_TABLE');
889: ec_debug.pl(0,'EC','ECE_ERROR_MESSAGE','ERROR_MESSAGE',SQLERRM);
890: EC_UTILS.i_ret_code :=2;
891: raise EC_UTILS.PROGRAM_EXIT;
892: END;
893:
894: end if;
887: WHEN OTHERS THEN
888: ec_debug.pl(0,'EC','ECE_PROGRAM_ERROR','PROGRESS_LEVEL', 'EC_OUTBOUND_STAGE.SELECT_FROM_STAGE_TABLE');
889: ec_debug.pl(0,'EC','ECE_ERROR_MESSAGE','ERROR_MESSAGE',SQLERRM);
890: EC_UTILS.i_ret_code :=2;
891: raise EC_UTILS.PROGRAM_EXIT;
892: END;
893:
894: end if;
895: if ec_debug.G_debug_level >= 2 then
897:
898: ec_debug.pop('EC_OUTBOUND_STAGE.SELECT_FROM_STAGE_TABLE');
899: end if;
900: EXCEPTION
901: WHEN EC_UTILS.PROGRAM_EXIT THEN
902: raise;
903: WHEN OTHERS THEN
904: IF dbms_sql.IS_OPEN(i_select_cursor)
905: then
906: dbms_sql.close_cursor(i_select_cursor);
907: end if;
908: ec_debug.pl(0,'EC','ECE_PROGRAM_ERROR','PROGRESS_LEVEL','EC_OUTBOUND_STAGE.SELECT_FROM_STAGE_TABLE');
909: ec_debug.pl(0,'EC','ECE_ERROR_MESSAGE','ERROR_MESSAGE',SQLERRM);
910: EC_UTILS.i_ret_code:=2;
911: raise EC_UTILS.PROGRAM_EXIT;
912: END Select_From_Stage_Table;
913:
914: /**
907: end if;
908: ec_debug.pl(0,'EC','ECE_PROGRAM_ERROR','PROGRESS_LEVEL','EC_OUTBOUND_STAGE.SELECT_FROM_STAGE_TABLE');
909: ec_debug.pl(0,'EC','ECE_ERROR_MESSAGE','ERROR_MESSAGE',SQLERRM);
910: EC_UTILS.i_ret_code:=2;
911: raise EC_UTILS.PROGRAM_EXIT;
912: END Select_From_Stage_Table;
913:
914: /**
915: This procedure formats the common key for each level of a given transaction. It takes the previous common key
960: EXCEPTION
961: WHEN OTHERS then
962: ec_debug.pl(0,'EC','ECE_PROGRAM_ERROR','PROGRESS_LEVEL','EC_OUTBOUND_STAGE.SELECT_COMMON_KEY');
963: ec_debug.pl(0,'EC','ECE_ERROR_MESSAGE','ERROR_MESSAGE',SQLERRM);
964: ec_utils.i_ret_code:=2;
965: raise EC_UTILS.PROGRAM_EXIT;
966: END Select_Common_Key;
967:
968: END EC_OUTBOUND_STAGE;
961: WHEN OTHERS then
962: ec_debug.pl(0,'EC','ECE_PROGRAM_ERROR','PROGRESS_LEVEL','EC_OUTBOUND_STAGE.SELECT_COMMON_KEY');
963: ec_debug.pl(0,'EC','ECE_ERROR_MESSAGE','ERROR_MESSAGE',SQLERRM);
964: ec_utils.i_ret_code:=2;
965: raise EC_UTILS.PROGRAM_EXIT;
966: END Select_Common_Key;
967:
968: END EC_OUTBOUND_STAGE;