METHOD AND SYSTEM FOR DATA SYNCHRONIZATION

• US 20090271653A1
• Filed: 10/10/2008
• Published: 10/29/2009
• Est. Priority Date: 04/10/2006
• Status: Active Grant

• Current Assignee: Huawei Technologies Co., Ltd. (Huawei Investment & Holding Co., Ltd.)
• Original Assignee: Huawei Technologies Co., Ltd. (Huawei Investment & Holding Co., Ltd.)
• Inventors: HE, Wei, ZHU, Zhongchu, WANG, Yongfeng, ZHOU, Fei, SHI, Mingzhu, WANG, Yunlong
• Granted Patent: US 7,899,935 B2
• Time in Patent Office: Days
• US Class Current: 713/600
• CPC Class Codes: G06F 16/275 Synchronous replication
• CPC Class Codes: H04L 41/00 Arrangements for maintenance, administration or management of data switching networks, e.g. of packet switching networks
• CPC Class Codes: H04L 67/1095 Replication or mirroring of data, e.g. scheduling or transport for data synchronisation between network nodes
• CPC Class Codes: H04L 69/08 Protocols for interworking; Protocol conversion

Abstract

A data synchronization system and method. The method includes that when a change happens in a source application, data is collected from a source application based on a target application subscribing the source application and collection data is transmitted to the target application or is directly inserted to target database. The system includes data collection unit and distribution unit. The present invention may realize synchronization on demand, simultaneously reduce greatly synchronous data quantity, decrease network load, and guarantee smoothness and stabilization of network. The present invention applies to data synchronization of enterprise internal/external data systems, telecommunication networks, etc.

Claims

1. A method for data synchronization, comprising:

collecting data from a source application according to source application information subscribed by a target application when a change occurs in the source application data; and

sending the data collected to the target application or directly inserting the data collected into a target database.

2. The method for data synchronization according to claim 1, wherein the process of collecting data from a source application according to the source application information subscribed by a target application comprises:

collecting the data to be collected into a buffer in the unit of transaction, wherein, the collecting in the unit of transaction comprises;

collecting the data into a buffer and adding a transaction ID and operation sequence number field to the operational procedure information of each line of collection record during the process of collecting the data to the buffer.

3. The method for data synchronization according to claim 2, before the process of sending the data collected to the target application or directly inserting the data collected into a target database, further comprising:

converting the source application data collected into data that can be identified by the target application according to a preset mapping and converting rule.

4. The method for data synchronization according to claim 3, wherein the process of converting the source application data collected into data that can be identified by the target application according to a preset mapping and converting rule comprises:

obtaining the subscriber information corresponding to the data in the buffer according to a pre-established collecting rule, wherein the collecting rule comprises target application information, source application information subscribed by the target application and information of data to be collected;

obtaining the corresponding mapping and converting rule according to the subscriber information; and

mapping the data in the buffer and converting the source application data into data that can be identified by the target application according to the mapping and converting rule.

5. The method for data synchronization according to claim 4, wherein the mapping and converting rule is created as follows:

obtaining the source application information in the collecting rule;

obtaining the write interface of the target application and the sequence and type of all the interface parameters inside the target application according to the target application information in the collecting rule, and the data format of the collection output;

creating a mapping and converting relationship between the interface parameter of the target application and the source application information; and

issuing the mapping and converting relationship.

6. The method for data synchronization according to claim 1, wherein the data collected is sent to a designated target application or directly inserted to a designated target application according to a routing rule.

7. The method for data synchronization according to claim 6, wherein the routing rule is created as follows:

obtaining the format of data output from the information of data to be collected in the collecting rule;

obtaining the field for routing computation from the content of data output;

allocating a unique routing ID to each target application;

creating a routing computation rule;

creating a routing rule, according to the routing computation rule; and

issuing the routing rule.

8. The method for data synchronization according to claim 1, wherein the collecting rule is created as follows:

obtaining the description data of a service object in the source application;

defining or modifying the source application information subscribed by the target application and the information of data to be collected according to the description data of the service object; and

issuing the collecting rule.

9. The method for data synchronization according to claim 8, wherein the process of defining or modifying the source application information subscribed by the target application and the information of data to be collected according to the description data of the service object comprises:

selecting the attribute of description data item of the service object as a subscription item; and

defining the description data item of the service object as the content collected.

10. The method for data synchronization according to claim 2, further comprising:

defining a collecting and filtering condition; and

disabling the triggering of the collection event when change occurs in source application data that meets the collecting and filtering condition.

11. A system for data synchronization, comprising:

a data collection unit, adapted to collect data from a source application according to the source application information subscribed by a target application when a change occurs in the source application data; and

a distribution unit, adapted to send the data collected by the data collection unit to the target application or directly insert the data collected into a target database.

12. The system for data synchronization according to claim 11, further comprising:

a collection controller, adapted to set a collecting rule and control the data collection unit.

13. The system for data synchronization according to claim 11, wherein:

the data collection unit is a trigger embedded into the source application, which collects data from the source application and stores the data collected into a buffer in the unit of transaction when change occurs in the source application data.

14. The system for data synchronization according to claim 11, further comprising:

a mapping and converting unit, adapted to convert the source application data collected by the data collection unit into data that can be identified by the target application, according to a preset mapping and converting rule.

15. The system for data synchronization according to claim 14, wherein the mapping and converting unit comprises:

a mapping and converting setter, adapted to set a mapping and converting rule; and

a mapping and converting center, adapted to convert the source application data collected by the data collection unit into data that can be identified by the target application, according to the mapping and converting rule and package the data converted in transaction operation sequence.

16. The system for data synchronization according to claim 15, wherein the mapping and converting unit further comprises a port adapted to listen to a notification message from the data collection unit.

17. The system for data synchronization according to claim 11, wherein the distribution unit comprises:

a data routing management center, adapted to create a routing rule; and

a distributor, adapted to send the data collected to a designated target application or directly insert the data collected into a designated target database according to the routing rule.