36: EDW_MTL_INVENTORY_LOC_M_C.g_push_date_range2 := EDW_COLLECTION_UTIL.G_local_curr_push_start_date;
37: ELSE
38: EDW_MTL_INVENTORY_LOC_M_C.g_push_date_range2 := to_date(p_to_date, 'YYYY/MM/DD HH24:MI:SS');
39: END IF;
40: edw_log.put_line( 'The collection range is from '||
41: to_char(EDW_MTL_INVENTORY_LOC_M_C.g_push_date_range1,'MM/DD/YYYY HH24:MI:SS')||' to '||
42: to_char(EDW_MTL_INVENTORY_LOC_M_C.g_push_date_range2,'MM/DD/YYYY HH24:MI:SS'));
43: edw_log.put_line(' ');
44: -- -----------------------------------------------------------------------------
39: END IF;
40: edw_log.put_line( 'The collection range is from '||
41: to_char(EDW_MTL_INVENTORY_LOC_M_C.g_push_date_range1,'MM/DD/YYYY HH24:MI:SS')||' to '||
42: to_char(EDW_MTL_INVENTORY_LOC_M_C.g_push_date_range2,'MM/DD/YYYY HH24:MI:SS'));
43: edw_log.put_line(' ');
44: -- -----------------------------------------------------------------------------
45: -- Start of Collection , Developer Customizable Section
46: -- -----------------------------------------------------------------------------
47: edw_log.put_line(' ');
43: edw_log.put_line(' ');
44: -- -----------------------------------------------------------------------------
45: -- Start of Collection , Developer Customizable Section
46: -- -----------------------------------------------------------------------------
47: edw_log.put_line(' ');
48: edw_log.put_line('Pushing data');
49: l_temp_date := sysdate;
50: Push_EDW_MTL_ILDM_LOCATOR_LSTG(EDW_MTL_INVENTORY_LOC_M_C.g_push_date_range1, EDW_MTL_INVENTORY_LOC_M_C.g_push_date_range2);
51: Push_EDW_MTL_ILDM_SUB_INV_LSTG(EDW_MTL_INVENTORY_LOC_M_C.g_push_date_range1, EDW_MTL_INVENTORY_LOC_M_C.g_push_date_range2);
44: -- -----------------------------------------------------------------------------
45: -- Start of Collection , Developer Customizable Section
46: -- -----------------------------------------------------------------------------
47: edw_log.put_line(' ');
48: edw_log.put_line('Pushing data');
49: l_temp_date := sysdate;
50: Push_EDW_MTL_ILDM_LOCATOR_LSTG(EDW_MTL_INVENTORY_LOC_M_C.g_push_date_range1, EDW_MTL_INVENTORY_LOC_M_C.g_push_date_range2);
51: Push_EDW_MTL_ILDM_SUB_INV_LSTG(EDW_MTL_INVENTORY_LOC_M_C.g_push_date_range1, EDW_MTL_INVENTORY_LOC_M_C.g_push_date_range2);
52: Push_EDW_MTL_ILDM_PLANT_LSTG(EDW_MTL_INVENTORY_LOC_M_C.g_push_date_range1, EDW_MTL_INVENTORY_LOC_M_C.g_push_date_range2);
53: Push_EDW_MTL_ILDM_OU_LSTG(EDW_MTL_INVENTORY_LOC_M_C.g_push_date_range1, EDW_MTL_INVENTORY_LOC_M_C.g_push_date_range2);
54: Push_EDW_MTL_ILDM_PORG_LSTG(EDW_MTL_INVENTORY_LOC_M_C.g_push_date_range1, EDW_MTL_INVENTORY_LOC_M_C.g_push_date_range2);
55: Push_EDW_MTL_ILDM_PCMP_LSTG(EDW_MTL_INVENTORY_LOC_M_C.g_push_date_range1, EDW_MTL_INVENTORY_LOC_M_C.g_push_date_range2);
56: l_duration := sysdate - l_temp_date;
57: edw_log.put_line('Total rows inserted : '||g_row_count);
58: edw_log.put_line('Process Time: '||edw_log.duration(l_duration));
59: edw_log.put_line(' ');
60: -- ---------------------------------------------------------------------------
61: -- END OF Collection , Developer Customizable Section
54: Push_EDW_MTL_ILDM_PORG_LSTG(EDW_MTL_INVENTORY_LOC_M_C.g_push_date_range1, EDW_MTL_INVENTORY_LOC_M_C.g_push_date_range2);
55: Push_EDW_MTL_ILDM_PCMP_LSTG(EDW_MTL_INVENTORY_LOC_M_C.g_push_date_range1, EDW_MTL_INVENTORY_LOC_M_C.g_push_date_range2);
56: l_duration := sysdate - l_temp_date;
57: edw_log.put_line('Total rows inserted : '||g_row_count);
58: edw_log.put_line('Process Time: '||edw_log.duration(l_duration));
59: edw_log.put_line(' ');
60: -- ---------------------------------------------------------------------------
61: -- END OF Collection , Developer Customizable Section
62: -- ---------------------------------------------------------------------------
55: Push_EDW_MTL_ILDM_PCMP_LSTG(EDW_MTL_INVENTORY_LOC_M_C.g_push_date_range1, EDW_MTL_INVENTORY_LOC_M_C.g_push_date_range2);
56: l_duration := sysdate - l_temp_date;
57: edw_log.put_line('Total rows inserted : '||g_row_count);
58: edw_log.put_line('Process Time: '||edw_log.duration(l_duration));
59: edw_log.put_line(' ');
60: -- ---------------------------------------------------------------------------
61: -- END OF Collection , Developer Customizable Section
62: -- ---------------------------------------------------------------------------
63: EDW_COLLECTION_UTIL.wrapup(TRUE, g_lowest_level_count,
80: l_date1 DATE;
81: l_date2 DATE;
82: l_rows_inserted NUMBER :=0;
83: BEGIN
84: edw_log.put_line('Starting Push_EDW_MTL_ILDM_LOCATOR_LSTG');
85: l_date1 := p_from_date;
86: l_date2 := p_to_date;
87: Insert Into
88: EDW_MTL_ILDM_LOCATOR_LSTG@EDW_APPS_TO_WH(
126:
127: EDW_MTL_INVENTORY_LOC_M_C.g_lowest_level_count := l_rows_inserted;
128:
129: EDW_MTL_INVENTORY_LOC_M_C.g_row_count := EDW_MTL_INVENTORY_LOC_M_C.g_row_count + l_rows_inserted ;
130: edw_log.put_line('Inserted '||to_char(nvl(sql%rowcount,0))||
131: ' rows into the staging table');
132: edw_log.put_line('Commiting records for EDW_MTL_ILDM_LOCATOR_LSTG');
133: commit;
134: edw_log.put_line('Completed Push_EDW_MTL_ILDM_LOCATOR_LSTG');
128:
129: EDW_MTL_INVENTORY_LOC_M_C.g_row_count := EDW_MTL_INVENTORY_LOC_M_C.g_row_count + l_rows_inserted ;
130: edw_log.put_line('Inserted '||to_char(nvl(sql%rowcount,0))||
131: ' rows into the staging table');
132: edw_log.put_line('Commiting records for EDW_MTL_ILDM_LOCATOR_LSTG');
133: commit;
134: edw_log.put_line('Completed Push_EDW_MTL_ILDM_LOCATOR_LSTG');
135: Exception When others then
136: raise;
130: edw_log.put_line('Inserted '||to_char(nvl(sql%rowcount,0))||
131: ' rows into the staging table');
132: edw_log.put_line('Commiting records for EDW_MTL_ILDM_LOCATOR_LSTG');
133: commit;
134: edw_log.put_line('Completed Push_EDW_MTL_ILDM_LOCATOR_LSTG');
135: Exception When others then
136: raise;
137: commit;
138: END;
140: l_date1 DATE;
141: l_date2 DATE;
142: l_rows_inserted NUMBER :=0;
143: BEGIN
144: edw_log.put_line('Starting Push_EDW_MTL_ILDM_SUB_INV_LSTG');
145: l_date1 := p_from_date;
146: l_date2 := p_to_date;
147: Insert Into
148: EDW_MTL_ILDM_SUB_INV_LSTG@EDW_APPS_TO_WH(
181: from EDW_MTL_ILDM_SUB_INV_LCV@APPS_TO_APPS
182: where last_update_date between l_date1 and l_date2;
183: l_rows_inserted := sql%rowcount;
184: EDW_MTL_INVENTORY_LOC_M_C.g_row_count := EDW_MTL_INVENTORY_LOC_M_C.g_row_count + l_rows_inserted ;
185: edw_log.put_line('Inserted '||to_char(nvl(sql%rowcount,0))||
186: ' rows into the staging table');
187: edw_log.put_line('Commiting records for EDW_MTL_ILDM_SUB_INV_LSTG');
188: commit;
189: edw_log.put_line('Completed Push_EDW_MTL_ILDM_SUB_INV_LSTG');
183: l_rows_inserted := sql%rowcount;
184: EDW_MTL_INVENTORY_LOC_M_C.g_row_count := EDW_MTL_INVENTORY_LOC_M_C.g_row_count + l_rows_inserted ;
185: edw_log.put_line('Inserted '||to_char(nvl(sql%rowcount,0))||
186: ' rows into the staging table');
187: edw_log.put_line('Commiting records for EDW_MTL_ILDM_SUB_INV_LSTG');
188: commit;
189: edw_log.put_line('Completed Push_EDW_MTL_ILDM_SUB_INV_LSTG');
190: Exception When others then
191: raise;
185: edw_log.put_line('Inserted '||to_char(nvl(sql%rowcount,0))||
186: ' rows into the staging table');
187: edw_log.put_line('Commiting records for EDW_MTL_ILDM_SUB_INV_LSTG');
188: commit;
189: edw_log.put_line('Completed Push_EDW_MTL_ILDM_SUB_INV_LSTG');
190: Exception When others then
191: raise;
192: commit;
193: END;
195: l_date1 DATE;
196: l_date2 DATE;
197: l_rows_inserted NUMBER :=0;
198: BEGIN
199: edw_log.put_line('Starting Push_EDW_MTL_ILDM_PLANT_LSTG');
200: l_date1 := p_from_date;
201: l_date2 := p_to_date;
202: Insert Into
203: EDW_MTL_ILDM_PLANT_LSTG@EDW_APPS_TO_WH(
240: from EDW_MTL_ILDM_PLANT_LCV@APPS_TO_APPS
241: where last_update_date between l_date1 and l_date2;
242: l_rows_inserted := sql%rowcount;
243: EDW_MTL_INVENTORY_LOC_M_C.g_row_count := EDW_MTL_INVENTORY_LOC_M_C.g_row_count + l_rows_inserted ;
244: edw_log.put_line('Inserted '||to_char(nvl(sql%rowcount,0))||
245: ' rows into the staging table');
246: edw_log.put_line('Commiting records for EDW_MTL_ILDM_PLANT_LSTG');
247: commit;
248: edw_log.put_line('Completed Push_EDW_MTL_ILDM_PLANT_LSTG');
242: l_rows_inserted := sql%rowcount;
243: EDW_MTL_INVENTORY_LOC_M_C.g_row_count := EDW_MTL_INVENTORY_LOC_M_C.g_row_count + l_rows_inserted ;
244: edw_log.put_line('Inserted '||to_char(nvl(sql%rowcount,0))||
245: ' rows into the staging table');
246: edw_log.put_line('Commiting records for EDW_MTL_ILDM_PLANT_LSTG');
247: commit;
248: edw_log.put_line('Completed Push_EDW_MTL_ILDM_PLANT_LSTG');
249: Exception When others then
250: raise;
244: edw_log.put_line('Inserted '||to_char(nvl(sql%rowcount,0))||
245: ' rows into the staging table');
246: edw_log.put_line('Commiting records for EDW_MTL_ILDM_PLANT_LSTG');
247: commit;
248: edw_log.put_line('Completed Push_EDW_MTL_ILDM_PLANT_LSTG');
249: Exception When others then
250: raise;
251: commit;
252: END;
254: l_date1 DATE;
255: l_date2 DATE;
256: l_rows_inserted NUMBER :=0;
257: BEGIN
258: edw_log.put_line('Starting Push_EDW_MTL_ILDM_OU_LSTG');
259: l_date1 := p_from_date;
260: l_date2 := p_to_date;
261: Insert Into
262: EDW_MTL_ILDM_OU_LSTG@EDW_APPS_TO_WH(
305: from EDW_MTL_ILDM_OU_LCV@APPS_TO_APPS
306: where last_update_date between l_date1 and l_date2;
307: l_rows_inserted := sql%rowcount;
308: EDW_MTL_INVENTORY_LOC_M_C.g_row_count := EDW_MTL_INVENTORY_LOC_M_C.g_row_count + l_rows_inserted ;
309: edw_log.put_line('Inserted '||to_char(nvl(sql%rowcount,0))||
310: ' rows into the staging table');
311: edw_log.put_line('Commiting records for EDW_MTL_ILDM_OU_LSTG');
312: commit;
313: edw_log.put_line('Completed Push_EDW_MTL_ILDM_OU_LSTG');
307: l_rows_inserted := sql%rowcount;
308: EDW_MTL_INVENTORY_LOC_M_C.g_row_count := EDW_MTL_INVENTORY_LOC_M_C.g_row_count + l_rows_inserted ;
309: edw_log.put_line('Inserted '||to_char(nvl(sql%rowcount,0))||
310: ' rows into the staging table');
311: edw_log.put_line('Commiting records for EDW_MTL_ILDM_OU_LSTG');
312: commit;
313: edw_log.put_line('Completed Push_EDW_MTL_ILDM_OU_LSTG');
314: Exception When others then
315: raise;
309: edw_log.put_line('Inserted '||to_char(nvl(sql%rowcount,0))||
310: ' rows into the staging table');
311: edw_log.put_line('Commiting records for EDW_MTL_ILDM_OU_LSTG');
312: commit;
313: edw_log.put_line('Completed Push_EDW_MTL_ILDM_OU_LSTG');
314: Exception When others then
315: raise;
316: commit;
317: END;
319: l_date1 DATE;
320: l_date2 DATE;
321: l_rows_inserted NUMBER :=0;
322: BEGIN
323: edw_log.put_line('Starting Push_EDW_MTL_ILDM_PORG_LSTG');
324: l_date1 := p_from_date;
325: l_date2 := p_to_date;
326: Insert Into
327: EDW_MTL_ILDM_PORG_LSTG@EDW_APPS_TO_WH(
362: from EDW_MTL_ILDM_PORG_LCV@APPS_TO_APPS
363: where last_update_date between l_date1 and l_date2;
364: l_rows_inserted := sql%rowcount;
365: EDW_MTL_INVENTORY_LOC_M_C.g_row_count := EDW_MTL_INVENTORY_LOC_M_C.g_row_count + l_rows_inserted ;
366: edw_log.put_line('Inserted '||to_char(nvl(sql%rowcount,0))||
367: ' rows into the staging table');
368: edw_log.put_line('Commiting records for EDW_MTL_ILDM_PORG_LSTG');
369: commit;
370: edw_log.put_line('Completed Push_EDW_MTL_ILDM_PORG_LSTG');
364: l_rows_inserted := sql%rowcount;
365: EDW_MTL_INVENTORY_LOC_M_C.g_row_count := EDW_MTL_INVENTORY_LOC_M_C.g_row_count + l_rows_inserted ;
366: edw_log.put_line('Inserted '||to_char(nvl(sql%rowcount,0))||
367: ' rows into the staging table');
368: edw_log.put_line('Commiting records for EDW_MTL_ILDM_PORG_LSTG');
369: commit;
370: edw_log.put_line('Completed Push_EDW_MTL_ILDM_PORG_LSTG');
371: Exception When others then
372: raise;
366: edw_log.put_line('Inserted '||to_char(nvl(sql%rowcount,0))||
367: ' rows into the staging table');
368: edw_log.put_line('Commiting records for EDW_MTL_ILDM_PORG_LSTG');
369: commit;
370: edw_log.put_line('Completed Push_EDW_MTL_ILDM_PORG_LSTG');
371: Exception When others then
372: raise;
373: commit;
374: END;
376: l_date1 DATE;
377: l_date2 DATE;
378: l_rows_inserted NUMBER :=0;
379: BEGIN
380: edw_log.put_line('Starting Push_EDW_MTL_ILDM_PCMP_LSTG');
381: l_date1 := p_from_date;
382: l_date2 := p_to_date;
383: Insert Into
384: EDW_MTL_ILDM_PCMP_LSTG@EDW_APPS_TO_WH(
419: from EDW_MTL_ILDM_PCMP_LCV@APPS_TO_APPS
420: where last_update_date between l_date1 and l_date2;
421: l_rows_inserted := sql%rowcount;
422: EDW_MTL_INVENTORY_LOC_M_C.g_row_count := EDW_MTL_INVENTORY_LOC_M_C.g_row_count + l_rows_inserted ;
423: edw_log.put_line('Inserted '||to_char(nvl(sql%rowcount,0))||
424: ' rows into the staging table');
425: edw_log.put_line('Commiting records for EDW_MTL_ILDM_PCMP_LSTG');
426: commit;
427: edw_log.put_line('Completed Push_EDW_MTL_ILDM_PCMP_LSTG');
421: l_rows_inserted := sql%rowcount;
422: EDW_MTL_INVENTORY_LOC_M_C.g_row_count := EDW_MTL_INVENTORY_LOC_M_C.g_row_count + l_rows_inserted ;
423: edw_log.put_line('Inserted '||to_char(nvl(sql%rowcount,0))||
424: ' rows into the staging table');
425: edw_log.put_line('Commiting records for EDW_MTL_ILDM_PCMP_LSTG');
426: commit;
427: edw_log.put_line('Completed Push_EDW_MTL_ILDM_PCMP_LSTG');
428: Exception When others then
429: raise;
423: edw_log.put_line('Inserted '||to_char(nvl(sql%rowcount,0))||
424: ' rows into the staging table');
425: edw_log.put_line('Commiting records for EDW_MTL_ILDM_PCMP_LSTG');
426: commit;
427: edw_log.put_line('Completed Push_EDW_MTL_ILDM_PCMP_LSTG');
428: Exception When others then
429: raise;
430: commit;
431: END;