US 11,893,041 B2
Data synchronization between a source database system and target database system
Knut Stolze, Hummelshain (DE); Vassil Radkov Dimov, Stuttgart (DE); Christian Michel, Sindelfingen (DE); and Daniel Martin, Stuttgart (DE)
Assigned to International Business Machines Corporation, Armonk, NY (US)
Filed by INTERNATIONAL BUSINESS MACHINES CORPORATION, Armonk, NY (US)
Filed on Mar. 26, 2020, as Appl. No. 16/830,696.
Claims priority of application No. 19174608 (EP), filed on May 15, 2019.
Prior Publication US 2020/0364241 A1, Nov. 19, 2020
Int. Cl. G06F 16/27 (2019.01); G06F 16/178 (2019.01); G06F 16/23 (2019.01)
CPC G06F 16/275 (2019.01) [G06F 16/178 (2019.01); G06F 16/2365 (2019.01); G06F 16/27 (2019.01)] 15 Claims
OG exemplary drawing
 
12. A computer system for data synchronization between a source database system and a target database system, wherein execution of a database transaction of the source database system is considered to be complete if a processing step followed by an application step of the database transaction is performed, the computer system comprising:
one or more processors, one or more computer-readable memories, one or more computer-readable tangible storage devices, and program instructions stored on at least one of the one or more computer-readable tangible storage devices for execution by at least one of the one or more processors via at least one of the one or more memories, the program instructions comprising:
program instructions to identify in a time interval one or more database transactions of the source database system via a transaction log of the source database system which comprises log records resulting from the one or more database transactions;
program instructions to each of the one or more database transactions of the transaction log as a committed or an uncommitted database transaction;
program instructions to send the transaction log to the target database system for implementing changes of the one or more database transactions, wherein prior to the sending log records of the one or more database transactions are transformed according to a data record structure of the target database system, and wherein the transformations comprise changing a format of the log records;
for each transaction of the identified database transactions, program instructions to determine whether the transaction was completed based on a tag of the transaction, wherein determining whether the transaction was completed further comprises:
in response to determining that the transaction is not completed, program instructions to perform, by the target database system, the processing step of the transaction if a duration time of the transaction exceeds a duration threshold, wherein performing the processing step comprises invoking a respective additional thread of a transaction process of the target database system;
in response to determining that the transaction is completed and the processing step of the transaction was not previously executed, program instructions to perform, by the target database system, the processing step and the application step of the transaction, wherein performing the processing step and the application step comprises invoking a main thread of the transaction process; and
in response to determining that the transaction is completed and the processing step of the transaction was previously executed, program instructions to perform, by the target database, the application step of the transaction, wherein performing the application step comprises invoking another respective additional thread of the transaction process of the target database system; and
program instructions to iteratively perform the identifying, the tagging, and the determining, wherein in each iteration the time interval is a time interval subsequent to a time interval of a preceding iteration, and wherein a length of a subsequent time interval is different from a length of a preceding time interval.