Method and a system for integrating data from a source to a destination

摘要

The embodiments herein provide a system and a method for integrating a data from a source to a destination. The method comprises generating a global-id, setting an event-id corresponding to an entity id in the global id, polling a data from a source, sorting changes of a source system based on a time of update and an entity id, creating and comparing an old as of state value and a new as of state value for each field for each update in the entity in the source and destination to detect a conflict on an entity, sending a time of update in the entity and a revision id of a change to the destination, comparing the global id with an event id for each entity at the destination to detect a presence of an entity in the destination and processing an entity at the destination based an event id.

主权项

1. A method for integrating data from a source system to a destination system, said method comprising the following steps:
generating a global-id by concatenating a source system name corresponding to an entity, and a corresponding entity project id and a corresponding entity id; setting an event-id corresponding to the entity id present in the global id; polling data from a plurality of entities of the source system; sorting a plurality of updates to the plurality of entities of the source system based on a time of update and a corresponding entity id; creating au old state value for each update on each of the plurality of entities in the source system; creating a new state value for each update on each of a plurality of entities in the destination system; sending an event to the destination system with the old state value and the new state value for each of a plurality of entities; comparing the old state value and the new state value for each of the updates to detect a conflicts on the plurality of entities in the destination system; sending a time of update of the plurality of entities and a revision id of a change to the destination system; comparing the global id with the event id for each entity, at the source system to detect a presence of the corresponding entity in the destination system; processing the plurality of entities at the destination system based on the event id; and synchronizing the entities at the destination system with the corresponding entities at the source system.