Data synchronization in a cloud infrastructure

• US 9,734,224 B2
• Filed: 03/20/2015
• Issued: 08/15/2017
• Est. Priority Date: 09/07/2012
• Status: Active Grant

• Current Assignee: Oracle International Corporation (Oracle Corporation)
• Original Assignee: Oracle International Corporation (Oracle Corporation)
• Inventors: Vasudevan, Ramesh, Prathipati, Anjani Kalyan, Chatterjee, Ramkrishna, Arun, Gopalan
• Primary Examiner(s): Coby, Frantz
• Application Number:
  US14/664,528
• Publication Number:
  US 20160070772A1
• Time in Patent Office: 879 Days
• Field of Search: 707610-613, 707617, 707620, 707802, 707639
• CPC Class Codes: G06F 16/122 using management policies backup systems G06F11/1446; file migration policies for HSM systems G06F16/185
• CPC Class Codes: G06F 16/178 Techniques for file synchronisation in file systems
• CPC Class Codes: G06F 16/2282 Tablespace storage structures; Management thereof
• CPC Class Codes: G06F 16/2308 Concurrency control transaction processing G06F9/466
• CPC Class Codes: G06F 16/2365 Ensuring data consistency and integrity
• 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/283 Multi-dimensional databases or data warehouses, e.g. MOLAP or ROLAP
• CPC Class Codes: G06F 16/284 Relational databases
• CPC Class Codes: G06Q 10/06315 Needs-based resource requirements planning or analysis
• CPC Class Codes: G06Q 10/0633 Workflow analysis
• CPC Class Codes: G06Q 30/0633 Lists, e.g. purchase orders, compilation or processing
• CPC Class Codes: G06Q 30/0635 Processing of requisition or of purchase orders
• 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 41/0686 Additional information in the notification, e.g. enhancement of specific meta-data
• CPC Class Codes: H04L 41/50 Network service management, e.g. ensuring proper service fulfilment according to agreements
• CPC Class Codes: H04L 41/5041 characterised by the time relationship between creation and deployment of a service
• CPC Class Codes: H04L 41/5054 Automatic deployment of services triggered by the service manager, e.g. service implementation by automatic configuration of network components
• CPC Class Codes: H04L 41/5064 Customer relationship management
• CPC Class Codes: H04L 43/0876 Network utilisation, e.g. volume of load or congestion level
• CPC Class Codes: H04L 47/70 : Admission control; Resource allocation
• CPC Class Codes: H04L 63/10 : for controlling access to devices or network resources
• CPC Class Codes: H04L 63/20 : for managing network security; network security policies in general filtering policies H04L63/0227
• CPC Class Codes: H04L 67/10 : in which an application is distributed across nodes in the network software deployment G06F8/60; multiprogramming arrangements G06F9/46

Abstract

A synchronization infrastructure that synchronizes data stored between components in a cloud infrastructure system is described. A first component in the cloud infrastructure system may store subscription information related to a subscription order which may in turn be utilized by a second component in the cloud infrastructure system to orchestrate the provisioning of services and resources for the order placed by the customer. The synchronization architecture utilizes transactionally consistent checkpoints that describe the state of the data stored in the components to synchronize the data between these components.

Claims

1. A computer-implemented method comprising:

for a source table in a first computing device comprised in a computing infrastructure system, the source table comprising a plurality of rows, each row of the plurality of rows associated with a checkpoint number, determining, based upon a first checkpoint number associated with the source table and checkpoint numbers associated with the plurality of rows in the source table, a set of one or more rows of the source table that have changed since when the source table was last synchronized with a corresponding target table;

determining a first run number associated with the source table, the first run number indicative of a number of data synchronization runs performed for the source table;

determining a second run number for the source table based at least in part on determining that the set of one or more rows of the source table have changed;

associating, by the first device, the second run number with the source table instead of the first run number; and

transferring, by the first device, the set of one or more rows to a target table in a second computing device and associating each row of the set of one or more rows in the target table with the second run number.

2. The method of claim 1, wherein determining the set of one or more rows that have changed comprises identifying the checkpoint numbers associated with the plurality of rows in the source table that are greater than the first checkpoint number.

3. The method of claim 2, further comprising determining a second checkpoint number, wherein determining the second checkpoint number comprises identifying a row in the set of one or more rows with a highest checkpoint number.

4. The method of claim 3, further comprising associating the second checkpoint number with the source table instead of the first checkpoint number.

5. The method of claim 3, wherein determining the second run number for the source table is further based on identifying the row in the set of one or more rows with the highest checkpoint number.

6. The method of claim 1, wherein transferring the set of one or more rows to the target table further comprises transferring a new run time associated with each row of the set of one or more rows to the target table.

7. The method of claim 6, further causing by the first computing device to store the second run number and the new run time in a runs table associated with the target table.

8. A system comprising:

one or more computing devices configurable to provide one or more services;

a memory configurable to store a subscription order related to the one or more services provided by the system; and

wherein a first computing device from the one or more computing devices is configurable to;

identify a source table in the first computing device, the source table comprising a plurality of rows, each row of the plurality of rows associated with a checkpoint number;

determine based upon a first checkpoint number associated with the source table and checkpoint numbers associated with the plurality of rows in the source table, a set of one or more rows of the source table that have changed since when the source table was last synchronized with a corresponding target table;

determine a first run number associated with the source table, the first run number indicative of a number of data synchronization runs performed for the source table;

determine a second run number for the source table based at least in part on determining that the set of one or more rows of the source table have changed;

associate the second run number with the source table instead of the first run number; and

transfer the set of one or more rows to a target table in a second computing device and associate each row of the set of one or more rows in the target table with the second run number.

9. The system of claim 8, wherein the first computing device is further configured to determine the set of one or more rows that have changed by identifying the checkpoint numbers associated with the plurality of rows in the source table that are greater than the first checkpoint number.

10. The system of claim 9, wherein the first computing device is further configured to determine a second checkpoint number, wherein the second checkpoint number is determined based on identifying a row in the set of one or more rows with a highest checkpoint number.

11. The system of claim 10, wherein the first computing device is further configured to associate the second checkpoint number with the source table instead of the first checkpoint number.

12. The system of claim 10, wherein the first computing device is further configured to determine the second run number for the source table based on identifying the row in the set of one or more rows with the highest checkpoint number.

13. The system of claim 8, wherein the first computing device is further configured to transfer a new run time associated with each row of the set of one or more rows to the target table.

14. The system of claim 13, wherein the first computing device is further configured to store the second run number and the new run time in a runs table associated with the target table.

15. A non-transitory computer-readable memory storing a plurality of instructions executable by one or more processors, the plurality of instructions comprising:

instructions that cause at least one processor from the one or more processors to identify a source table in a first computing device, the source table comprising a plurality of rows, each row of the plurality of rows associated with a checkpoint number;

instructions that cause at least one processor from the one or more processors to determine based upon a first checkpoint number associated with the source table and checkpoint numbers associated with the plurality of rows in the source table, a set of one or more rows of the source table that have changed since when the source table was last synchronized with a corresponding target table;

instructions that cause at least one processor from the one or more processors to determine a first run number associated with the source table, the first run number indicative of a number of data synchronization runs performed for the source table;

instructions that cause at least one processor from the one or more processors to determine a second run number for the source table based at least in part on determining that the set of one or more rows of the source table have changed;

instructions that cause at least one processor from the one or more processors to associate the second run number with the source table instead of the first run number; and

instructions that cause at least one processor from the one or more processors to transfer the set of one or more rows to a target table in a second computing device and associate each row of the set of one or more rows in the target table with the second run number.

16. The non-transitory computer-readable memory of claim 15, further comprising instructions that cause at least one processor from the one or more processors to determine the set of one or more rows that have changed by identifying the checkpoint numbers associated with the plurality of rows in the source table that are greater than the first checkpoint number.

17. The non-transitory computer-readable memory of claim 16, further comprising instructions that cause at least one processor from the one or more processors to determine a second checkpoint number by identifying a row in the set of one or more rows with a highest checkpoint number.

18. The non-transitory computer-readable memory of claim 17, wherein the instructions cause at least one processor from the one or more processors to associate the second checkpoint number with the source table instead of the first checkpoint number.

19. The non-transitory computer-readable memory of claim 17, wherein the instructions further cause at least one processor from the one or more processors to determine the second run number for the source table based on identifying the row in the set of one or more rows with the highest checkpoint number.

20. The non-transitory computer-readable memory of claim 15, wherein the instructions further cause at least one processor from the one or more processors to transfer the set of one or more rows to the target table further comprise instructions to cause at least one processor from the one or more processors to transfer a new run time associated with each row of the set of one or more rows to the target table.