DBA Data[Home] [Help]

APPS.OPI_EDW_OPMCOGS_F_C dependencies on EDW_LOG

Line 51: edw_log.put_line(' ');

47: AND COGS_PK like '%OPM%';
48:
49: BEGIN
50: /* Print Header */
51: edw_log.put_line(' ');
52: edw_log.put_line ('Identified Missing Rows Date:'||SYSDATE);
53:
54: edw_log.put_line (' ');
55: edw_log.put_line (' ');

Line 52: edw_log.put_line ('Identified Missing Rows Date:'||SYSDATE);

48:
49: BEGIN
50: /* Print Header */
51: edw_log.put_line(' ');
52: edw_log.put_line ('Identified Missing Rows Date:'||SYSDATE);
53:
54: edw_log.put_line (' ');
55: edw_log.put_line (' ');
56:

Line 54: edw_log.put_line (' ');

50: /* Print Header */
51: edw_log.put_line(' ');
52: edw_log.put_line ('Identified Missing Rows Date:'||SYSDATE);
53:
54: edw_log.put_line (' ');
55: edw_log.put_line (' ');
56:
57: edw_log.put_line ('Primary Key is IC_TRAN_PND/IC_TRAN_CMP-Transaction_id,Line_id');
58: edw_log.put_line ('-----------------------------------------');

Line 55: edw_log.put_line (' ');

51: edw_log.put_line(' ');
52: edw_log.put_line ('Identified Missing Rows Date:'||SYSDATE);
53:
54: edw_log.put_line (' ');
55: edw_log.put_line (' ');
56:
57: edw_log.put_line ('Primary Key is IC_TRAN_PND/IC_TRAN_CMP-Transaction_id,Line_id');
58: edw_log.put_line ('-----------------------------------------');
59: edw_log.put_line ('Primary Key / Currency / Transaction Date');

Line 57: edw_log.put_line ('Primary Key is IC_TRAN_PND/IC_TRAN_CMP-Transaction_id,Line_id');

53:
54: edw_log.put_line (' ');
55: edw_log.put_line (' ');
56:
57: edw_log.put_line ('Primary Key is IC_TRAN_PND/IC_TRAN_CMP-Transaction_id,Line_id');
58: edw_log.put_line ('-----------------------------------------');
59: edw_log.put_line ('Primary Key / Currency / Transaction Date');
60: edw_log.put_line ('-----------------------------------------');
61: /* Print Rows */

Line 58: edw_log.put_line ('-----------------------------------------');

54: edw_log.put_line (' ');
55: edw_log.put_line (' ');
56:
57: edw_log.put_line ('Primary Key is IC_TRAN_PND/IC_TRAN_CMP-Transaction_id,Line_id');
58: edw_log.put_line ('-----------------------------------------');
59: edw_log.put_line ('Primary Key / Currency / Transaction Date');
60: edw_log.put_line ('-----------------------------------------');
61: /* Print Rows */
62:

Line 59: edw_log.put_line ('Primary Key / Currency / Transaction Date');

55: edw_log.put_line (' ');
56:
57: edw_log.put_line ('Primary Key is IC_TRAN_PND/IC_TRAN_CMP-Transaction_id,Line_id');
58: edw_log.put_line ('-----------------------------------------');
59: edw_log.put_line ('Primary Key / Currency / Transaction Date');
60: edw_log.put_line ('-----------------------------------------');
61: /* Print Rows */
62:
63: For l_rows in missing_rate loop

Line 60: edw_log.put_line ('-----------------------------------------');

56:
57: edw_log.put_line ('Primary Key is IC_TRAN_PND/IC_TRAN_CMP-Transaction_id,Line_id');
58: edw_log.put_line ('-----------------------------------------');
59: edw_log.put_line ('Primary Key / Currency / Transaction Date');
60: edw_log.put_line ('-----------------------------------------');
61: /* Print Rows */
62:
63: For l_rows in missing_rate loop
64: edw_log.put_line (l_rows.COGS_PK||' / '||l_rows.BASE_CURRENCY_FK||' / '||l_rows.COGS_DATE);

Line 64: edw_log.put_line (l_rows.COGS_PK||' / '||l_rows.BASE_CURRENCY_FK||' / '||l_rows.COGS_DATE);

60: edw_log.put_line ('-----------------------------------------');
61: /* Print Rows */
62:
63: For l_rows in missing_rate loop
64: edw_log.put_line (l_rows.COGS_PK||' / '||l_rows.BASE_CURRENCY_FK||' / '||l_rows.COGS_DATE);
65: end loop;
66: edw_log.put_line(' ');
67: edw_log.put_line(' ');
68: EXCEPTION

Line 66: edw_log.put_line(' ');

62:
63: For l_rows in missing_rate loop
64: edw_log.put_line (l_rows.COGS_PK||' / '||l_rows.BASE_CURRENCY_FK||' / '||l_rows.COGS_DATE);
65: end loop;
66: edw_log.put_line(' ');
67: edw_log.put_line(' ');
68: EXCEPTION
69: WHEN OTHERS THEN
70: g_errbuf:=sqlerrm;

Line 67: edw_log.put_line(' ');

63: For l_rows in missing_rate loop
64: edw_log.put_line (l_rows.COGS_PK||' / '||l_rows.BASE_CURRENCY_FK||' / '||l_rows.COGS_DATE);
65: end loop;
66: edw_log.put_line(' ');
67: edw_log.put_line(' ');
68: EXCEPTION
69: WHEN OTHERS THEN
70: g_errbuf:=sqlerrm;
71: g_retcode:=sqlcode;

Line 72: edw_log.put_line('Raised Exception from PRINT_MISSING_RATE '||sqlerrm);

68: EXCEPTION
69: WHEN OTHERS THEN
70: g_errbuf:=sqlerrm;
71: g_retcode:=sqlcode;
72: edw_log.put_line('Raised Exception from PRINT_MISSING_RATE '||sqlerrm);
73: END;
74:
75: PROCEDURE PUSH_MISSING_ROWS
76: IS

Line 81: edw_log.put_line(' ');

77: l_count number;
78: BEGIN
79: /* Delete the incremental table before inserting new data */
80: DELETE OPI_EDW_OPMCOGS_INC WHERE SEQ_ID IS NOT NULL;
81: edw_log.put_line(' ');
82: SELECT count(*) into l_count from OPI_EDW_COGS_FSTG
83: WHERE COLLECTION_STATUS in ('RATE NOT AVAILABLE','INVALID CURRENCY')
84: AND COGS_PK like '%OPM%';
85: IF l_count > 0 THEN

Line 86: edw_log.put_line(' ');

82: SELECT count(*) into l_count from OPI_EDW_COGS_FSTG
83: WHERE COLLECTION_STATUS in ('RATE NOT AVAILABLE','INVALID CURRENCY')
84: AND COGS_PK like '%OPM%';
85: IF l_count > 0 THEN
86: edw_log.put_line(' ');
87: edw_log.Put_line('Identifying Missing Rate Rows ');
88: edw_log.put_line(' ');
89: /* insert into Incremental table all line_id where Currency is missing */
90: INSERT /*+ parallel(OPI_EDW_OPMCOGS_INC) */

Line 87: edw_log.Put_line('Identifying Missing Rate Rows ');

83: WHERE COLLECTION_STATUS in ('RATE NOT AVAILABLE','INVALID CURRENCY')
84: AND COGS_PK like '%OPM%';
85: IF l_count > 0 THEN
86: edw_log.put_line(' ');
87: edw_log.Put_line('Identifying Missing Rate Rows ');
88: edw_log.put_line(' ');
89: /* insert into Incremental table all line_id where Currency is missing */
90: INSERT /*+ parallel(OPI_EDW_OPMCOGS_INC) */
91: into OPI_EDW_OPMCOGS_INC (LINE_ID,view_id,seq_id)

Line 88: edw_log.put_line(' ');

84: AND COGS_PK like '%OPM%';
85: IF l_count > 0 THEN
86: edw_log.put_line(' ');
87: edw_log.Put_line('Identifying Missing Rate Rows ');
88: edw_log.put_line(' ');
89: /* insert into Incremental table all line_id where Currency is missing */
90: INSERT /*+ parallel(OPI_EDW_OPMCOGS_INC) */
91: into OPI_EDW_OPMCOGS_INC (LINE_ID,view_id,seq_id)
92: SELECT

Line 105: edw_log.Put_line(to_char(sql%rowcount) ||' rows missing Currency Rate Conversion for View Type 1');

101: FROM OPI_EDW_COGS_FSTG
102: WHERE COLLECTION_STATUS in ('RATE NOT AVAILABLE','INVALID CURRENCY')
103: AND COGS_PK like '%OPM%');
104:
105: edw_log.Put_line(to_char(sql%rowcount) ||' rows missing Currency Rate Conversion for View Type 1');
106:
107: INSERT /*+ parallel(OPI_EDW_OPMCOGS_INC) */
108: into OPI_EDW_OPMCOGS_INC (LINE_ID,view_id,seq_id)
109: SELECT

Line 121: edw_log.Put_line(to_char(sql%rowcount) ||' rows missing Currency Rate Conversion for View Type 2');

117: COGS_PK in ( SELECT COGS_PK
118: FROM OPI_EDW_COGS_FSTG
119: WHERE COLLECTION_STATUS in ('RATE NOT AVAILABLE','INVALID CURRENCY')
120: AND COGS_PK like '%OPM%');
121: edw_log.Put_line(to_char(sql%rowcount) ||' rows missing Currency Rate Conversion for View Type 2');
122: edw_log.put_line(' ');
123: Commit;
124: edw_log.put_line ('Printing Missing Rate Rows Output');
125: edw_log.put_line(' ');

Line 122: edw_log.put_line(' ');

118: FROM OPI_EDW_COGS_FSTG
119: WHERE COLLECTION_STATUS in ('RATE NOT AVAILABLE','INVALID CURRENCY')
120: AND COGS_PK like '%OPM%');
121: edw_log.Put_line(to_char(sql%rowcount) ||' rows missing Currency Rate Conversion for View Type 2');
122: edw_log.put_line(' ');
123: Commit;
124: edw_log.put_line ('Printing Missing Rate Rows Output');
125: edw_log.put_line(' ');
126: PRINT_MISSING_ROWS;

Line 124: edw_log.put_line ('Printing Missing Rate Rows Output');

120: AND COGS_PK like '%OPM%');
121: edw_log.Put_line(to_char(sql%rowcount) ||' rows missing Currency Rate Conversion for View Type 2');
122: edw_log.put_line(' ');
123: Commit;
124: edw_log.put_line ('Printing Missing Rate Rows Output');
125: edw_log.put_line(' ');
126: PRINT_MISSING_ROWS;
127: edw_log.put_line ('Output Printed. You can view the output using ''View output'' option from Request page');
128: edw_log.put_line(' ');

Line 125: edw_log.put_line(' ');

121: edw_log.Put_line(to_char(sql%rowcount) ||' rows missing Currency Rate Conversion for View Type 2');
122: edw_log.put_line(' ');
123: Commit;
124: edw_log.put_line ('Printing Missing Rate Rows Output');
125: edw_log.put_line(' ');
126: PRINT_MISSING_ROWS;
127: edw_log.put_line ('Output Printed. You can view the output using ''View output'' option from Request page');
128: edw_log.put_line(' ');
129:

Line 127: edw_log.put_line ('Output Printed. You can view the output using ''View output'' option from Request page');

123: Commit;
124: edw_log.put_line ('Printing Missing Rate Rows Output');
125: edw_log.put_line(' ');
126: PRINT_MISSING_ROWS;
127: edw_log.put_line ('Output Printed. You can view the output using ''View output'' option from Request page');
128: edw_log.put_line(' ');
129:
130: /*Delete all missing rows from FSTG table if source and target are on same instance*/
131: IF (LOCAL_SAME_AS_REMOTE) THEN

Line 128: edw_log.put_line(' ');

124: edw_log.put_line ('Printing Missing Rate Rows Output');
125: edw_log.put_line(' ');
126: PRINT_MISSING_ROWS;
127: edw_log.put_line ('Output Printed. You can view the output using ''View output'' option from Request page');
128: edw_log.put_line(' ');
129:
130: /*Delete all missing rows from FSTG table if source and target are on same instance*/
131: IF (LOCAL_SAME_AS_REMOTE) THEN
132: DELETE OPI_EDW_COGS_FSTG

Line 135: edw_log.Put_line(to_char(sql%rowcount) ||' missing Currency Rate Conversion rows deleted from Staging table');

131: IF (LOCAL_SAME_AS_REMOTE) THEN
132: DELETE OPI_EDW_COGS_FSTG
133: WHERE COLLECTION_STATUS in ('RATE NOT AVAILABLE','INVALID CURRENCY')
134: AND COGS_PK like '%OPM%';
135: edw_log.Put_line(to_char(sql%rowcount) ||' missing Currency Rate Conversion rows deleted from Staging table');
136: END IF;
137: /* Deletion completed */
138: ELSE
139: edw_log.Put_line('0 rows missing Currency Rate Conversion');

Line 139: edw_log.Put_line('0 rows missing Currency Rate Conversion');

135: edw_log.Put_line(to_char(sql%rowcount) ||' missing Currency Rate Conversion rows deleted from Staging table');
136: END IF;
137: /* Deletion completed */
138: ELSE
139: edw_log.Put_line('0 rows missing Currency Rate Conversion');
140: END IF;
141:
142: EXCEPTION
143: WHEN OTHERS THEN

Line 146: edw_log.put_line('Raised Exception '||sqlerrm);

142: EXCEPTION
143: WHEN OTHERS THEN
144: g_errbuf:=sqlerrm;
145: g_retcode:=sqlcode;
146: edw_log.put_line('Raised Exception '||sqlerrm);
147: END;
148:
149: -----------------------------------------------------------
150: --PROCEDURE PUSH_TO_LOCAL

Line 165: edw_log.Put_line('Inserting Rows into Staging Table');

161: -- progress until the push_to_local procedure for
162: -- all view types has completed successfully.
163: -- ------------------------------------------------
164:
165: edw_log.Put_line('Inserting Rows into Staging Table');
166: Insert Into OPI_EDW_COGS_FSTG
167: (COGS_PK
168: ,COGS_DATE
169: ,COGS_DATE_FK

Line 374: edw_log.Put_line('Insert completed in Staging tables');

370: from OPI_EDW_OPMCOGS_FCV
371: WHERE view_id = p_view_id
372: AND seq_id = p_seq_id;
373:
374: edw_log.Put_line('Insert completed in Staging tables');
375: l_no_rows := sql%rowcount;
376: /* Push Currency Conversion Missing Rows */
377: PUSH_MISSING_ROWS;
378: RETURN l_no_rows;

Line 519: edw_log.put_line( 'The collection range is from '||

515: EDW_COLLECTION_UTIL.G_local_last_push_start_date -
516: EDW_COLLECTION_UTIL.g_offset);
517: g_push_to_date := nvl(l_to_date,
518: EDW_COLLECTION_UTIL.G_local_curr_push_start_date);
519: edw_log.put_line( 'The collection range is from '||
520: to_char(g_push_from_date,'MM/DD/YYYY HH24:MI:SS')||' to '||
521: to_char(g_push_to_date,'MM/DD/YYYY HH24:MI:SS'));
522: edw_log.put_line(' ');
523: -- --------------------------------------------

Line 522: edw_log.put_line(' ');

518: EDW_COLLECTION_UTIL.G_local_curr_push_start_date);
519: edw_log.put_line( 'The collection range is from '||
520: to_char(g_push_from_date,'MM/DD/YYYY HH24:MI:SS')||' to '||
521: to_char(g_push_to_date,'MM/DD/YYYY HH24:MI:SS'));
522: edw_log.put_line(' ');
523: -- --------------------------------------------
524: -- Identify Change view 1 OP Data
525: -- --------------------------------------------
526: edw_log.put_line(' ');

Line 526: edw_log.put_line(' ');

522: edw_log.put_line(' ');
523: -- --------------------------------------------
524: -- Identify Change view 1 OP Data
525: -- --------------------------------------------
526: edw_log.put_line(' ');
527: edw_log.put_line('Identifying changes in view type 1');
528: l_seq_id1 := IDENTIFY_CHANGE(1,l_row_count);
529: if (l_seq_id1 = -1) THEN
530: RAISE l_iden_change_failure;

Line 527: edw_log.put_line('Identifying changes in view type 1');

523: -- --------------------------------------------
524: -- Identify Change view 1 OP Data
525: -- --------------------------------------------
526: edw_log.put_line(' ');
527: edw_log.put_line('Identifying changes in view type 1');
528: l_seq_id1 := IDENTIFY_CHANGE(1,l_row_count);
529: if (l_seq_id1 = -1) THEN
530: RAISE l_iden_change_failure;
531: end if;

Line 532: edw_log.put_line ('Identified '||l_row_count||' changed records in view type 1');

528: l_seq_id1 := IDENTIFY_CHANGE(1,l_row_count);
529: if (l_seq_id1 = -1) THEN
530: RAISE l_iden_change_failure;
531: end if;
532: edw_log.put_line ('Identified '||l_row_count||' changed records in view type 1');
533: -- --------------------------------------------
534: -- Identify Change view type 2 OM Data
535: -- --------------------------------------------
536: edw_log.put_line(' ');

Line 536: edw_log.put_line(' ');

532: edw_log.put_line ('Identified '||l_row_count||' changed records in view type 1');
533: -- --------------------------------------------
534: -- Identify Change view type 2 OM Data
535: -- --------------------------------------------
536: edw_log.put_line(' ');
537: edw_log.put_line('Identifying changes in view type 2');
538: l_seq_id2 := IDENTIFY_CHANGE(2,l_row_count);
539: if (l_seq_id2 = -1) THEN
540: RAISE l_iden_change_failure;

Line 537: edw_log.put_line('Identifying changes in view type 2');

533: -- --------------------------------------------
534: -- Identify Change view type 2 OM Data
535: -- --------------------------------------------
536: edw_log.put_line(' ');
537: edw_log.put_line('Identifying changes in view type 2');
538: l_seq_id2 := IDENTIFY_CHANGE(2,l_row_count);
539: if (l_seq_id2 = -1) THEN
540: RAISE l_iden_change_failure;
541: end if;

Line 542: edw_log.put_line ('Identified '||l_row_count||' changed records in view type 2');

538: l_seq_id2 := IDENTIFY_CHANGE(2,l_row_count);
539: if (l_seq_id2 = -1) THEN
540: RAISE l_iden_change_failure;
541: end if;
542: edw_log.put_line ('Identified '||l_row_count||' changed records in view type 2');
543: -- --------------------------------------------
544: -- Analyze the incremental table
545: -- --------------------------------------------
546: IF (FND_INSTALLATION.GET_APP_INFO('OPI', l_status, l_industry, l_pmi_schema)) THEN

Line 553: edw_log.put_line(' ');

549: END IF;
550: -- --------------------------------------------
551: -- Push to local staging table
552: -- --------------------------------------------
553: edw_log.put_line(' ');
554: edw_log.put_line('Inserting into local staging table ');
555: l_row_count1 := PUSH_TO_LOCAL(1, l_seq_id1);
556: IF (l_row_count1 = -1) THEN RAISE L_push_local_failure; END IF;
557: edw_log.put_line('Inserted '||nvl(l_row_count1,0)||

Line 554: edw_log.put_line('Inserting into local staging table ');

550: -- --------------------------------------------
551: -- Push to local staging table
552: -- --------------------------------------------
553: edw_log.put_line(' ');
554: edw_log.put_line('Inserting into local staging table ');
555: l_row_count1 := PUSH_TO_LOCAL(1, l_seq_id1);
556: IF (l_row_count1 = -1) THEN RAISE L_push_local_failure; END IF;
557: edw_log.put_line('Inserted '||nvl(l_row_count1,0)||
558: ' rows into the local staging table ');

Line 557: edw_log.put_line('Inserted '||nvl(l_row_count1,0)||

553: edw_log.put_line(' ');
554: edw_log.put_line('Inserting into local staging table ');
555: l_row_count1 := PUSH_TO_LOCAL(1, l_seq_id1);
556: IF (l_row_count1 = -1) THEN RAISE L_push_local_failure; END IF;
557: edw_log.put_line('Inserted '||nvl(l_row_count1,0)||
558: ' rows into the local staging table ');
559: edw_log.put_line(' ');
560: g_row_count:= l_row_count1;
561: edw_log.put_line(' ');

Line 559: edw_log.put_line(' ');

555: l_row_count1 := PUSH_TO_LOCAL(1, l_seq_id1);
556: IF (l_row_count1 = -1) THEN RAISE L_push_local_failure; END IF;
557: edw_log.put_line('Inserted '||nvl(l_row_count1,0)||
558: ' rows into the local staging table ');
559: edw_log.put_line(' ');
560: g_row_count:= l_row_count1;
561: edw_log.put_line(' ');
562: edw_log.put_line('Inserting into local staging table ');
563: l_row_count2 := PUSH_TO_LOCAL(2, l_seq_id2);

Line 561: edw_log.put_line(' ');

557: edw_log.put_line('Inserted '||nvl(l_row_count1,0)||
558: ' rows into the local staging table ');
559: edw_log.put_line(' ');
560: g_row_count:= l_row_count1;
561: edw_log.put_line(' ');
562: edw_log.put_line('Inserting into local staging table ');
563: l_row_count2 := PUSH_TO_LOCAL(2, l_seq_id2);
564: IF (l_row_count2 = -1) THEN RAISE L_push_local_failure; END IF;
565: edw_log.put_line('Inserted '||nvl(l_row_count2,0)||

Line 562: edw_log.put_line('Inserting into local staging table ');

558: ' rows into the local staging table ');
559: edw_log.put_line(' ');
560: g_row_count:= l_row_count1;
561: edw_log.put_line(' ');
562: edw_log.put_line('Inserting into local staging table ');
563: l_row_count2 := PUSH_TO_LOCAL(2, l_seq_id2);
564: IF (l_row_count2 = -1) THEN RAISE L_push_local_failure; END IF;
565: edw_log.put_line('Inserted '||nvl(l_row_count2,0)||
566: ' rows into the local staging table ');

Line 565: edw_log.put_line('Inserted '||nvl(l_row_count2,0)||

561: edw_log.put_line(' ');
562: edw_log.put_line('Inserting into local staging table ');
563: l_row_count2 := PUSH_TO_LOCAL(2, l_seq_id2);
564: IF (l_row_count2 = -1) THEN RAISE L_push_local_failure; END IF;
565: edw_log.put_line('Inserted '||nvl(l_row_count2,0)||
566: ' rows into the local staging table ');
567: edw_log.put_line(' ');
568: g_row_count:= l_row_count1 + l_row_count2;
569: edw_log.put_line(' ');

Line 567: edw_log.put_line(' ');

563: l_row_count2 := PUSH_TO_LOCAL(2, l_seq_id2);
564: IF (l_row_count2 = -1) THEN RAISE L_push_local_failure; END IF;
565: edw_log.put_line('Inserted '||nvl(l_row_count2,0)||
566: ' rows into the local staging table ');
567: edw_log.put_line(' ');
568: g_row_count:= l_row_count1 + l_row_count2;
569: edw_log.put_line(' ');
570: edw_log.put_line('For all views types, inserted '||nvl(g_row_count,0)||
571: ' rows into local staging table ');

Line 569: edw_log.put_line(' ');

565: edw_log.put_line('Inserted '||nvl(l_row_count2,0)||
566: ' rows into the local staging table ');
567: edw_log.put_line(' ');
568: g_row_count:= l_row_count1 + l_row_count2;
569: edw_log.put_line(' ');
570: edw_log.put_line('For all views types, inserted '||nvl(g_row_count,0)||
571: ' rows into local staging table ');
572:
573: -- -------------------------------------------

Line 570: edw_log.put_line('For all views types, inserted '||nvl(g_row_count,0)||

566: ' rows into the local staging table ');
567: edw_log.put_line(' ');
568: g_row_count:= l_row_count1 + l_row_count2;
569: edw_log.put_line(' ');
570: edw_log.put_line('For all views types, inserted '||nvl(g_row_count,0)||
571: ' rows into local staging table ');
572:
573: -- -------------------------------------------
574: -- Update Sales rep FK with seles rep_id

Line 597: edw_log.put_line(' ');

593: -- --------------------------------------------
594: -- No exception raised so far. Call wrapup to transport
595: -- data to target database, and insert messages into logs
596: -- -----------------------------------------------
597: edw_log.put_line(' ');
598: edw_log.put_line('Inserted '||nvl(g_row_count,0)||
599: ' rows into the staging table');
600: edw_log.put_line(' ');
601: EDW_COLLECTION_UTIL.wrapup(TRUE, g_row_count, l_exception_msg,

Line 598: edw_log.put_line('Inserted '||nvl(g_row_count,0)||

594: -- No exception raised so far. Call wrapup to transport
595: -- data to target database, and insert messages into logs
596: -- -----------------------------------------------
597: edw_log.put_line(' ');
598: edw_log.put_line('Inserted '||nvl(g_row_count,0)||
599: ' rows into the staging table');
600: edw_log.put_line(' ');
601: EDW_COLLECTION_UTIL.wrapup(TRUE, g_row_count, l_exception_msg,
602: g_push_from_date, g_push_to_date);

Line 600: edw_log.put_line(' ');

596: -- -----------------------------------------------
597: edw_log.put_line(' ');
598: edw_log.put_line('Inserted '||nvl(g_row_count,0)||
599: ' rows into the staging table');
600: edw_log.put_line(' ');
601: EDW_COLLECTION_UTIL.wrapup(TRUE, g_row_count, l_exception_msg,
602: g_push_from_date, g_push_to_date);
603: -- ---------------------------------------------------------------------------
604: -- END OF Collection , Developer Customizable Section

Line 612: edw_log.put_line('Inserting into local staging have failed');

608: Errbuf:=g_errbuf;
609: Retcode:=g_retcode;
610: l_exception_msg := Retcode || ':' || Errbuf;
611: rollback; -- Rollback insert into local staging
612: edw_log.put_line('Inserting into local staging have failed');
613: EDW_COLLECTION_UTIL.wrapup(FALSE, 0, l_exception_msg,
614: g_push_from_date, g_push_to_date);
615: l_exception_msg := Retcode || ':' || Errbuf;
616: delete OPI_EDW_OPMCOGS_INC;

Line 625: edw_log.put_line('Identifying changed records have Failed');

621: Retcode:=g_retcode;
622: l_exception_msg := Retcode || ':' || Errbuf;
623: delete OPI_EDW_OPMCOGS_INC;
624: commit;
625: edw_log.put_line('Identifying changed records have Failed');
626: EDW_COLLECTION_UTIL.wrapup(FALSE, 0, l_exception_msg,
627: g_push_from_date, g_push_to_date);
628: raise;
629: WHEN OTHERS THEN

Line 634: edw_log.put_line('Other errors');

630: Errbuf:=g_errbuf;
631: Retcode:=g_retcode;
632: l_exception_msg := Retcode || ':' || Errbuf;
633: rollback;
634: edw_log.put_line('Other errors');
635: EDW_COLLECTION_UTIL.wrapup(FALSE, 0, l_exception_msg,
636: g_push_from_date, g_push_to_date);
637: l_exception_msg := Retcode || ':' || Errbuf;
638: delete OPI_EDW_OPMCOGS_INC;