[Home] [Help]
1021: hz_utility_pub.creation_date,
1022: hz_utility_pub.last_update_login,
1023: hz_utility_pub.last_update_date,
1024: hz_utility_pub.user_id,
1025: HZ_DQM_SYNC_INTERFACE_S.nextval
1026: );
1027: END insert_error_rec;
1028:
1029: -- REPURI. Bug 4884742. Added this procedure to insert data into hz_dqm_sh_sync_interface table.
1123: -- REPURI. Bug 4968126.
1124: -- Using the Merge instead of Insert statement
1125: -- so that duplicate records dont get inserted.
1126:
1127: MERGE INTO hz_dqm_sync_interface S
1128: USING (
1129: SELECT
1130: p_entity AS entity
1131: ,p_party_id AS party_id
1168: hz_utility_pub.creation_date,
1169: hz_utility_pub.last_update_login,
1170: hz_utility_pub.last_update_date,
1171: hz_utility_pub.user_id,
1172: HZ_DQM_SYNC_INTERFACE_S.nextval
1173: );
1174:
1175: END insert_interface_rec;
1176:
1655: and rownum = 1;
1656:
1657: IF (l_dqm_run = 'Y') THEN
1658:
1659: update HZ_DQM_SYNC_INTERFACE set STAGED_FLAG = 'P'
1660: where STAGED_FLAG = 'N' and REALTIME_SYNC_FLAG = 'Y'
1661: returning party_id, record_id, entity, operation, rowid BULK COLLECT into
1662: l_party_id, l_record_id, l_entity, l_operation, l_rowid;
1663:
1690: END IF;
1691: IF l_operation(i) = 'C' THEN
1692: DELETE FROM hz_dqm_sync_interface WHERE rowid = l_rowid(i) ;
1693: ELSE
1694: UPDATE hz_dqm_sync_interface SET staged_flag = 'Y' WHERE rowid = l_rowid(i);
1695: END IF;
1696: EXCEPTION WHEN OTHERS THEN
1697: NULL;
1698: END;
1700: EXCEPTION
1701: WHEN OTHERS THEN
1702: -- update staged_flag to 'E' if program generates an error.
1703: l_sql_error_message := SQLERRM;
1704: UPDATE hz_dqm_sync_interface SET error_data = l_sql_error_message, staged_flag = 'E' WHERE ROWID = l_rowid(i);
1705: END;
1706:
1707: COMMIT;
1708: END LOOP ;