Method and system for managing a distributed transaction process

• US 20090177709A1
• Filed: 01/06/2009
• Published: 07/09/2009
• Est. Priority Date: 10/01/2002
• Status: Active Grant

• Current Assignee: Conduent Business Services, LLC (Conduent, Inc.)
• Original Assignee: Josh A. Wiles, Kevin Zou, Pasquale Solitro, Zheng Zhu
• Inventors: Zhu, Zheng, Solitro, Pasquale, Wiles, Josh A., Zou, Kevin
• Granted Patent: US 8,554,728 B2
• Time in Patent Office: Days
• 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: Y10S 707/99955 Archiving or backup

Abstract

Systems and methods for managing a distributed transaction process include an active transaction manager that manages transactions with an active database, a latent transaction manager that manages transactions with a merge database, a transaction log that reflects the set of transactions in the active database that are not affiliated with the transactions in the merge database, and a merge manager that uses the transaction log to determine whether to transfer control of the merge database to the active transaction manager. Systems and methods may further instruct the active transaction manager to halt transactions with the active database while the merge database is updated to reflect a set of transactions affiliated with the set of transactions in the transaction log, and instruct the active transaction manager to subsequently manage transactions to the active database and the merge database.

Claims

1-72. -72. (canceled)

73. A method for synchronizing a first database with a second database, comprising:

logging discrepancy transactions, wherein the discrepancy transactions are a set of transactions reflected in the second database that are not reflected in the first database;

updating the first database to reflect the discrepancy transactions while continuing accepting transactions to the second database; and

when the first database is within a threshold of being completely updated with the discrepancy transactions;

halting accepting transactions to the second database,

completing the updating of the first database, and

resuming accepting transactions to the second database and the first database.

74. The method of claim 73, wherein the threshold is a maximum number of discrepancy transactions.

75. The method of claim 73, wherein the threshold is a maximum estimated time to complete the updating of the first database.

76. The method of claim 73, wherein halting accepting transactions to the second database comprises:

halting accepting additional discrepancy transactions to the second database while continuing accepting other transactions to the second database.

77. The method of claim 73, wherein the second database is part of a distributed transaction system.

78. The method of claim 77, wherein completing the updating of the first database further includes:

adding the first database to the distributed transaction system.

79. The method of claim 78, wherein resuming accepting transactions to the second database and the first database comprises:

atomically committing transactions to the second database and the first database.

80. The method of claim 77, wherein the transactions reflected in the second database include a first set of transactions that are in the distributed transaction system and a second set of transactions that are not in the distributed transaction system.

81. The method of claim 80, wherein the discrepancy transactions are in the first set of transactions.

82. The method of claim 81, wherein halting accepting transactions to the second database comprises:

halting accepting additional transactions corresponding to the first set of transactions while continuing accepting additional transactions corresponding to the second set of transactions; and

wherein resuming accepting transactions to the second database and the first database comprises;

resuming accepting additional transactions corresponding to the first set of transactions.

83. The method of claim 73, wherein halting accepting transactions to the second database further includes:

recording the transactions.

84. The method of claim 83, wherein resuming accepting transactions to the second database and the first database further includes:

updating the second database and the first database with the recorded transactions.

85. The method of claim 73 further including:

managing a persistence log.

86. A system for synchronizing a first database with a second database, comprising:

a first database;

a second database; and

a processor, wherein the processor is configured to access the first database and the second database, including the operations of;

logging discrepancy transactions, wherein the discrepancy transactions are a set of transactions reflected in the second database that are not reflected in the first database;

updating the first database to reflect the discrepancy transactions while continuing accepting transactions to the second database; and

when the first database is within a threshold of being completely updated with the discrepancy transactions;

halting accepting transactions to the second database,

completing the updating of the first database, and

resuming accepting transactions to the second database and the first database.

87. The system of claim 86, wherein the threshold is a maximum number of discrepancy transactions.

88. The system of claim 86, wherein the threshold is a maximum estimated time to complete the updating of the first database.

89. The system of claim 86, wherein halting accepting transactions to the second database comprises:

halting accepting additional discrepancy transactions to the second database while continuing accepting other transactions to the second database.

90. The system of claim 86, wherein the second database is part of a distributed transaction system.

91. The system of claim 90, wherein completing the updating of the first database further includes:

adding the first database to the distributed transaction system.

92. The system of claim 91, wherein resuming accepting transactions to the second database and the first database comprises:

atomically committing transactions to the second database and the first database.

93. The system of claim 90, wherein the transactions reflected in the second database include a first set of transactions that are in the distributed transaction system and a second set of transactions that are not in the distributed transaction system.

94. The system of claim 93, wherein the discrepancy transactions are in the first set of transactions.

95. The system of claim 94, wherein halting accepting transactions to the second database comprises:

halting accepting additional transactions corresponding to the first set of transactions while continuing accepting additional transactions corresponding to the second set of transactions; and

wherein resuming accepting transactions to the second database and the first database comprises;

resuming accepting additional transactions to first set of transactions.

96. The system of claim 86, wherein halting accepting transactions to the second database further includes:

recording the transactions.

97. The system of claim 96, wherein resuming accepting transactions to the second database and the first database further includes:

updating the second database and the first database with the recorded transactions.

98. The system of claim 86, the operations further including:

managing a persistence log.