Synchronizing endpoint data stores having disparate schemas

• US 9,092,499 B2
• Filed: 01/20/2012
• Issued: 07/28/2015
• Est. Priority Date: 01/20/2012
• Status: Active Grant

• Current Assignee: Malikie Innovations Limited (Key Patent Innovations Limited)
• Original Assignee: Blackberry Limited
• Inventors: Wyatt, Derek Quinn
• Primary Examiner(s): PENG, HUAWEN A
• Application Number:
  US13/354,493
• Publication Number:
  US 20130191332A1
• Time in Patent Office: 1,285 Days
• Field of Search: 707/610
• US Class Current: 1/1
• CPC Class Codes: G06F 16/27 Replication, distribution or synchronisation of data between databases or within a distributed database system; Distributed database system architectures therefor
• CPC Class Codes: G06F 16/273 Asynchronous replication or reconciliation
• CPC Class Codes: G06F 16/955 using information identifiers, e.g. uniform resource locators [URL]

Abstract

Synchronizing data between multiple endpoint data stores that have disparate schemas is accomplished in a manner that reduces complexity. Each endpoint data store has an associated local schema that orders data into one or more fields. A synchronization server is disposed between the endpoints and keeps the multiple endpoints synchronized without the endpoints having to understand the various local schemas. A virtual schema is generated based on a set-intersection of the local schemas. The virtual schema maps a field in one local schema to a field in another local schema. Data is synchronized between the endpoint data stores using the virtual schema.

Claims

1. A method for synchronizing data between endpoint data stores, comprising:

performing a set-intersection on a first local schema associated with a first endpoint data store and a second local schema associated with a second endpoint data store, wherein each of the first and second local schemas organizes data into one or more fields of the corresponding first and second endpoint data stores;

generating a virtual schema based on the set-intersection on the first local schema and the second local schema, wherein the virtual schema maps a field in the first local schema to a field in the second local schema;

synchronizing data between the first and second endpoint data stores using the virtual schema, the synchronizing comprising;

receiving, by a synchronization server including a processor, data according to the first local schema from the first endpoint data store, and

processing, by the synchronization server using the virtual schema, the received data to produce data according to the second local schema for sending over a network to the second endpoint data store;

computing a hash value of the data according to the first local schema based only on content of at least one field of the data according to the first local schema that is mapped by the virtual schema to at least one field of the second local schema; and

determining, based on the hash value, a consistency of the data according to the first local schema with the data according to the second local schema.

2. The method of claim 1, further comprising:

retrieving the first local schema and the second local schema.

3. The method of claim 1, wherein each of the first local schema and the second local schema includes a respective set of field names and data types, and each field name has an associated list of at least one synonym for the field name.

4. The method of claim 1, wherein the synchronizing includes:

updating the second endpoint data store based on the data according to the second local schema.

5. The method of claim 4, wherein the updating includes:

transporting the data according to the second local schema to the second endpoint data store.

6. The method of claim 4, wherein the synchronizing is performed responsive to a triggering event.

7. The method of claim 6, wherein the triggering event is a synchronization request sent by a first endpoint that includes the first endpoint data store, the synchronization request identifying a second endpoint that includes the second endpoint data store.

8. The method of claim 1, wherein the performing of the set-intersection includes resolving field names using synonyms.

9. The method of claim 1, wherein the virtual schema is a first virtual schema, the method further comprising:

performing a set-intersection on the first local schema and a third local schema associated with a third endpoint data store, wherein the third local schema organizes data into one or more fields of the third endpoint data store;

generating a second virtual schema different from the first virtual schema, based on the set-intersection on the first local schema and the third local schema, wherein the second virtual schema maps a field in the first local schema to a field in the third local schema; and

synchronizing data between the first and third endpoint data stores using the second virtual schema.

10. The method of claim 1, wherein the one or more fields include one or more sets of field names and data types.

11. A synchronization server for synchronizing data between endpoints, each endpoint having a local schema associated therewith, the synchronization server comprising:

at least one processor configured to;

retrieve the local schema from each respective endpoint, each local schema organizing data into one or more fields of the corresponding endpoint, wherein the one or more fields include one or more pairs of field names and data types,

perform a set-intersection on the local schemas retrieved from the respective endpoints,

generate a virtual schema calculated from the set-intersection, the virtual schema useable in synchronization to tailor the data for transport among the endpoints, the virtual schema mapping a field in a first of the local schemas to a field in a second of the local schemas,

synchronize data between the endpoints using the virtual schema, where the synchronizing comprises;

receiving data according to the first local schema from a first of the endpoints, and

processing, using the virtual schema, the received data to produce data according to the second local schema for sending over a network to a second of the endpoints,

compute a hash value of the data according to the first local schema based only on content of at least one field of the data according to the first local schema that is mapped by the virtual schema to at least one field of the second local schema, and

determine, based on the hash value, a consistency of the data according to the first local schema with the data according to the second local schema.

12. The synchronization server of claim 11, wherein each field name has an associated list of at least one synonym for the field name.

13. The synchronization server of claim 12, wherein the at least one processor is configured to resolve field names using the synonyms.

14. The synchronization server of claim 13, wherein the synchronization server is configured to store the virtual schema, and upon synchronization, retrieve data and process the retrieved data based on the virtual schema.

15. The synchronization server of claim 11, wherein the synchronization server is configured to communicate with a portable wireless device at each endpoint.

16. The synchronization server of claim 11, wherein:

some of the fields of the local schemas are related by having similar content.

17. The synchronization server of claim 11, comprising:

a discoverer configured to retrieve the local schemas from the endpoints.

18. The synchronization server of claim 17, further comprising:

a set-intersection performer configured to perform the set-intersection on the retrieved local schemas.

19. The synchronization server of claim 18, further comprising:

a virtual schema generator configured to generate the virtual schema based on the set-intersection.

20. The synchronization server of claim 19, further comprising:

a synchronization request detector configured to respond to a synchronization request.

21. The synchronization server of claim 11, wherein the synchronization server is communicatively coupled to a plurality of portable wireless devices at respective endpoints.

22. A non-transitory computer-accessible medium storing instructions which, when executed by a processing entity, effectuate synchronization of data between endpoint data stores, the non-transitory computer-accessible medium comprising:

a code portion for performing a set-intersection on a first local schema associated with a first endpoint data store and a second local schema associated with a second endpoint data store, wherein each of the first and second local schemas organizes data into one or more fields of the corresponding first and second endpoint data stores;

a code portion for generating a virtual schema based on the set-intersection on the first local schema and the second local schema, wherein the virtual schema maps a field in the first local schema to a field in the second local schema;

a code portion for synchronizing data between the first and second endpoint data stores using the virtual schema, the synchronizing comprising;

receiving, by a synchronization server, data according to the first local schema from the first endpoint data store, and

processing, by the synchronization server using the virtual schema, the received data to produce data according to the second local schema for sending over a network to the second endpoint data store;

a code portion for computing a hash value of the data according to the first local schema based only on content of at least one field of the data according to the first local schema that is mapped by the virtual schema to at least one field of the second local schema; and

a code portion for determining, based on the hash value, a consistency of the data according to the first local schema with the data according to the second local schema.

23. The non-transitory computer-accessible medium of claim 22, wherein the one or more fields include one or more sets of field names and data types.