920: -- 2. Identify Changed AP Scheduled Payments record
921: -- --------------------------------------------------------
922: edw_log.put_line(' ');
923: edw_log.put_line('Identifying changed AP Scheduled Payments record');
924: fii_util.start_timer;
925: IDENTIFY_CHANGE(l_row_count);
926: fii_util.stop_timer;
927: fii_util.print_timer('Identified '||l_row_count||' changed records');
928:
922: edw_log.put_line(' ');
923: edw_log.put_line('Identifying changed AP Scheduled Payments record');
924: fii_util.start_timer;
925: IDENTIFY_CHANGE(l_row_count);
926: fii_util.stop_timer;
927: fii_util.print_timer('Identified '||l_row_count||' changed records');
928:
929: -- --------------------------------------------------------
930: -- 3. Pushing data to local staging table
923: edw_log.put_line('Identifying changed AP Scheduled Payments record');
924: fii_util.start_timer;
925: IDENTIFY_CHANGE(l_row_count);
926: fii_util.stop_timer;
927: fii_util.print_timer('Identified '||l_row_count||' changed records');
928:
929: -- --------------------------------------------------------
930: -- 3. Pushing data to local staging table
931: -- --------------------------------------------------------
931: -- --------------------------------------------------------
932:
933: edw_log.put_line(' ');
934: edw_log.put_line('Pushing data');
935: fii_util.start_timer;
936: g_row_count :=PUSH_TO_LOCAL;
937: fii_util.stop_timer;
938: fii_util.print_timer('Process Time');
939:
933: edw_log.put_line(' ');
934: edw_log.put_line('Pushing data');
935: fii_util.start_timer;
936: g_row_count :=PUSH_TO_LOCAL;
937: fii_util.stop_timer;
938: fii_util.print_timer('Process Time');
939:
940: IF (g_row_count = -1) THEN
941: RAISE L_push_local_failure;
934: edw_log.put_line('Pushing data');
935: fii_util.start_timer;
936: g_row_count :=PUSH_TO_LOCAL;
937: fii_util.stop_timer;
938: fii_util.print_timer('Process Time');
939:
940: IF (g_row_count = -1) THEN
941: RAISE L_push_local_failure;
942: END IF;
1054: -- and clean up local staging
1055: -- -----------------------------------------------
1056: edw_log.put_line(' ');
1057: edw_log.put_line('Moving data from local staging table to remote staging table');
1058: fii_util.start_timer;
1059: g_row_count := PUSH_REMOTE;
1060: fii_util.stop_timer;
1061: fii_util.print_timer('Duration');
1062:
1056: edw_log.put_line(' ');
1057: edw_log.put_line('Moving data from local staging table to remote staging table');
1058: fii_util.start_timer;
1059: g_row_count := PUSH_REMOTE;
1060: fii_util.stop_timer;
1061: fii_util.print_timer('Duration');
1062:
1063: IF (g_row_count = -1) THEN RAISE l_push_remote_failure; END IF;
1064:
1057: edw_log.put_line('Moving data from local staging table to remote staging table');
1058: fii_util.start_timer;
1059: g_row_count := PUSH_REMOTE;
1060: fii_util.stop_timer;
1061: fii_util.print_timer('Duration');
1062:
1063: IF (g_row_count = -1) THEN RAISE l_push_remote_failure; END IF;
1064:
1065: edw_log.put_line(' ');
1065: edw_log.put_line(' ');
1066: edw_log.put_line(to_char(g_row_count));
1067: edw_log.put_line('Cleaning local staging table');
1068:
1069: fii_util.start_timer;
1070: TRUNCATE_TABLE('FII_AP_SCH_PAYMTS_FSTG');
1071: fii_util.stop_timer;
1072: fii_util.print_timer('Duration');
1073:
1067: edw_log.put_line('Cleaning local staging table');
1068:
1069: fii_util.start_timer;
1070: TRUNCATE_TABLE('FII_AP_SCH_PAYMTS_FSTG');
1071: fii_util.stop_timer;
1072: fii_util.print_timer('Duration');
1073:
1074: ELSE
1075: -- -----------------------------------------------
1068:
1069: fii_util.start_timer;
1070: TRUNCATE_TABLE('FII_AP_SCH_PAYMTS_FSTG');
1071: fii_util.stop_timer;
1072: fii_util.print_timer('Duration');
1073:
1074: ELSE
1075: -- -----------------------------------------------
1076: -- The target warehouse is the same database
1081: edw_log.put_line(' ');
1082: edw_log.put_line(to_char(g_row_count));
1083: edw_log.put_line('Marking records in staging table with READY status');
1084:
1085: fii_util.start_timer;
1086: g_row_count := SET_STATUS_READY;
1087: fii_util.stop_timer;
1088: fii_util.print_timer('Duration');
1089: commit;
1083: edw_log.put_line('Marking records in staging table with READY status');
1084:
1085: fii_util.start_timer;
1086: g_row_count := SET_STATUS_READY;
1087: fii_util.stop_timer;
1088: fii_util.print_timer('Duration');
1089: commit;
1090: DELETE_STG;
1091: IF (g_row_count = -1) THEN RAISE l_set_status_failure; END IF;
1084:
1085: fii_util.start_timer;
1086: g_row_count := SET_STATUS_READY;
1087: fii_util.stop_timer;
1088: fii_util.print_timer('Duration');
1089: commit;
1090: DELETE_STG;
1091: IF (g_row_count = -1) THEN RAISE l_set_status_failure; END IF;
1092: END IF;