METHOD FOR ENSURING REFERENTIAL INTEGRITY IN REPLICATION ENGINES BY RESOLVING LOCK CONFLICTS

• US 20100332448A1
• Filed: 09/13/2010
• Published: 12/30/2010
• Est. Priority Date: 06/30/2003
• Status: Active Grant

• Current Assignee: Intel Corporation
• Original Assignee: Gravic Incorporated
• Inventors: HOLENSTEIN, Bruce D., HOLENSTEIN, Paul J., HIGHLEYMAN, Wilbur H.
• Granted Patent: US 8,620,862 B2
• Time in Patent Office: Days
• US Class Current: 707/615
• CPC Class Codes: G06F 11/2048 where the redundant components share neither address space nor persistent storage
• CPC Class Codes: G06F 11/2064 while ensuring consistency
• CPC Class Codes: G06F 11/2066 Optimisation of the communication load
• CPC Class Codes: G06F 11/2071 using a plurality of controllers
• CPC Class Codes: G06F 11/2097 maintaining the standby controller/processing unit updated initialisation or re-synchronisation thereof G06F11/1658 and subgroups
• CPC Class Codes: G06F 16/2365 Ensuring data consistency and integrity
• CPC Class Codes: G06F 16/273 Asynchronous replication or reconciliation
• CPC Class Codes: G06Q 10/087 Inventory or stock management, e.g. order filling, procurement or balancing against orders

Abstract

A method is provided for processing base level data of a change queue that is not serialized at the logical level. The base level change queue data is transaction data previously posted to a source database. A logical replication engine is provided to replicate and post the change queue data to a target database in the order that the transaction data is stored in the change queue. Upon detection in the logical replication engine of change queue data that is not serialized at the logical level, the change queue data is reserialized at the logical level before the logical replication engine applies the change queue data to the target database. The change queue data that is not serialized at the logical level may be posted to the target database using asynchronous database access.

Claims

1. A method of processing base level data of a change queue that is not serialized at the logical level, the base level change queue data being transaction data previously posted to a source database, the method comprising:

(a) providing a logical replication engine to replicate and post the change queue data to a target database in the order that the transaction data is stored in the change queue; and

(b) upon detection in the logical replication engine of change queue data that is not serialized at the logical level, reserializing the change queue data at the logical level before the logical replication engine applies the change queue data to the target database.

2. The method of claim 1 wherein the reserializing in step (b) is performed by accumulating index inserts.

3. The method of claim 1 wherein the reserializing in step (b) is performed with a set-aside queue.

4. The method of claim 1 wherein the reserializing in step (b) is performed with a set-aside queue with transaction end-state processing.

5. The method of claim 1 wherein the change queue is a change log.

6. The method of claim 1 wherein the change queue is an audit trail.

7. The method of claim 1 wherein the change queue is a database of changes.

8. A method of processing base level data of a change queue that is not serialized at the logical level, the base level change queue data being transaction data previously posted to a source database, the method comprising:

(a) providing a logical replication engine to replicate the change queue data that is not serialized at the logical level to a target database; and

(b) posting the change queue data that is not serialized at the logical level to the target database using asynchronous database access.

9. The method of claim 8 wherein step (a) replicates the change queue data to the target database in the order that the transaction data is stored in the change queue.

10. The method of claim 8 wherein the asynchronous database access uses asynchronous calls to the target database.

11. The method of claim 8 wherein the change queue is a change log.

12. The method of claim 8 wherein the change queue is an audit trail.

13. The method of claim 8 wherein the change queue is a database of changes.

14. An article of manufacture for processing base level data of a change queue that is not serialized at the logical level, the base level change queue data being transaction data previously posted to a source database, the article of manufacture comprising a computer-readable medium encoded with computer-executable instructions for performing the steps of:

(a) providing a logical replication engine to replicate and post the change queue data to a target database in the order that the transaction data is stored in the change queue; and

(b) upon detection in the logical replication engine of change queue data that is not serialized at the logical level, reserializing the change queue data at the logical level before the logical replication engine applies the change queue data to the target database.

15. The article of manufacture of claim 14 wherein the reserializing in step (b) is performed by accumulating index inserts.

16. The article of manufacture of claim 14 wherein the reserializing in step (b) is performed with a set-aside queue.

17. The article of manufacture of claim 14 wherein the reserializing in step (b) is performed with a set-aside queue with transaction end-state processing.

18. The article of manufacture of claim 14 wherein the change queue is a change log.

19. The article of manufacture of claim 14 wherein the change queue is an audit trail.

20. The article of manufacture of claim 14 wherein the change queue is a database of changes.

21. An article of manufacture for processing base level data of a change queue that is not serialized at the logical level, the base level change queue data being transaction data previously posted to a source database, the article of manufacture comprising a computer-readable medium encoded with computer-executable instructions for performing the steps of:

(a) providing a logical replication engine to replicate the change queue data that is not serialized at the logical level to a target database; and

(b) posting the change queue data that is not serialized at the logical level to the target database using asynchronous database access.

22. The article of manufacture of claim 21 wherein step (a) replicates the change queue data to the target database in the order that the transaction data is stored in the change queue.

23. The article of manufacture of claim 21 wherein the asynchronous database access uses asynchronous calls to the target database.

24. The article of manufacture of claim 21 wherein the change queue is a change log.

25. The article of manufacture of claim 21 wherein the change queue is an audit trail.

26. The article of manufacture of claim 21 wherein the change queue is a database of changes.