[Home] [Help]
1032: hz_utility_pub.creation_date,
1033: hz_utility_pub.last_update_login,
1034: hz_utility_pub.last_update_date,
1035: hz_utility_pub.user_id,
1036: HZ_DQM_SYNC_INTERFACE_S.nextval
1037: );
1038: END insert_error_rec;
1039:
1040: -- REPURI. Bug 4884742. Added this procedure to insert data into hz_dqm_sh_sync_interface table.
1162: hz_utility_pub.creation_date,
1163: hz_utility_pub.last_update_login,
1164: hz_utility_pub.last_update_date,
1165: hz_utility_pub.user_id,
1166: HZ_DQM_SYNC_INTERFACE_S.nextval
1167: );
1168:
1169: ELSE
1170:
1170:
1171: -- REPURI. Bug 4968126.
1172: -- Using the Merge instead of Insert statement
1173: -- so that duplicate records dont get inserted.
1174: MERGE INTO hz_dqm_sync_interface S
1175: USING (
1176: SELECT
1177: p_entity AS entity
1178: ,p_party_id AS party_id
1216: hz_utility_pub.creation_date,
1217: hz_utility_pub.last_update_login,
1218: hz_utility_pub.last_update_date,
1219: hz_utility_pub.user_id,
1220: HZ_DQM_SYNC_INTERFACE_S.nextval
1221: );
1222:
1223: END IF;
1224:
1774: and rownum = 1;
1775:
1776: IF (l_dqm_run = 'Y') THEN
1777:
1778: update HZ_DQM_SYNC_INTERFACE set STAGED_FLAG = 'P'
1779: where STAGED_FLAG = 'N' and REALTIME_SYNC_FLAG = 'Y'
1780: returning party_id, record_id, entity, operation, rowid BULK COLLECT into
1781: l_party_id, l_record_id, l_entity, l_operation, l_rowid;
1782:
1809: END IF;
1810: IF l_operation(i) = 'C' THEN
1811: DELETE FROM hz_dqm_sync_interface WHERE rowid = l_rowid(i) ;
1812: ELSE
1813: UPDATE hz_dqm_sync_interface SET staged_flag = 'Y' WHERE rowid = l_rowid(i);
1814: END IF;
1815: EXCEPTION WHEN OTHERS THEN
1816: NULL;
1817: END;
1819: EXCEPTION
1820: WHEN OTHERS THEN
1821: -- update staged_flag to 'E' if program generates an error.
1822: l_sql_error_message := SQLERRM;
1823: UPDATE hz_dqm_sync_interface SET error_data = l_sql_error_message, staged_flag = 'E' WHERE ROWID = l_rowid(i);
1824: END;
1825:
1826: COMMIT;
1827: END LOOP ;