Smart data replication recoverer

Patent metadata

Field	Value
Publication number	US-2017255528-A1
Application number	US-201615058316-A
Country	US
Kind code	A1
Filing date	Mar 2, 2016
Priority date	Mar 2, 2016
Publication date	Sep 7, 2017
Grant date	—

Abstract

A processor-implemented method for selective data replication recovery in a heterogeneous environment is provided, including a source agent, a target agent, and data replication recoverer (DRR) agent. The method includes receiving, by a DRR agent, one or more committed transaction records from a source agent, which is configured to receive the one or more committed transaction records from a source database. The DRR agent creates data and metadata records from the received one or more committed transaction records, and saves the data and the metadata records in a data replication repository. In response to receiving a request to recover a target database, the DRR agent selectively recovers target database using either one or more individual transactions or a bookmark.

First claim

1 .- 7 . (canceled)

8 . A computer program product for data replication recovery in a heterogeneous environment comprising:
a data replication recoverer (DRR) agent embodied on a computer readable storage medium, the DRR agent including program instructions executable by a processor, the program instructions comprising: receiving, by a data replication recoverer (DRR) agent, one or more committed transaction records from a source agent, wherein the source agent is configured to receive the one or more committed transaction records from a source database; creating, by the DRR agent, data and metadata records from the received one or more committed transaction records, and saving the data and the metadata records in a data replication repository; and in response to receiving a request to recover a target database, selectively recovering, by the DRR agent, the target database wherein the target database is recovered using either one or more individual transactions or a bookmark.

9 . The computer program product of claim 8 , wherein the source database differs from at least one of the one or more target databases in architecture, wherein the architecture includes relational and non-relational.

10 . The computer program product of claim 8 , wherein the bookmark records a stable save point in the metadata, and wherein the bookmark comprises a first log position corresponding to a last committed transaction on the target database, a second log position corresponding to an earliest open transaction on the source database, and a third log position corresponding to a last applied transaction on the target database.

11 . The computer program product of claim 8 , wherein each of the one or more target databases is associated with one dedicated data repository.

12 . The computer program product of claim 8 , wherein the metadata comprises a transaction identifier, a timestamp associated with a transaction, transaction statistics wherein the transaction statistics include a number of operations performed on the source database, and a number of rows processed on the source database.

13 . The computer program product of claim 8 , wherein selectively recovering the target database further comprises:
locating the selected bookmark within the data replication repository associated with the target database; locating an earliest log position entry recorded in the bookmark and a last log position entry recorded in the bookmark in the metadata within the data replication repository associated with the target database; creating a plurality of database operations to reverse the transactions recorded within the earliest log position entry and the last log position entry in the selected bookmark; sending, by the DRR agent, the plurality of created database operations to a target agent on the target database, wherein the target agent executes the plurality of created database operations on the target database; based on the created database operations completing on the target database, notifying the DRR agent, by the target agent; and in response to receiving the notification, the DRR agent marking the data and metadata in the data replication repository as being recovered.

14 . A computer system for data replication recovery in a heterogeneous environment comprising:
one or more processors, one or more computer-readable storage devices, and a plurality of program instructions stored on at least one of the one or more storage devices for execution by at least one of the one or more processors, the plurality of program instructions comprising: program instructions to receive, by a data replication recoverer (DRR) agent, one or more committed transaction records from a source agent, wherein the source agent is configured to receive the one or more committed transaction records from a source database; program instructions to create, by the DRR agent, data and metadata records from the received one or more committed transaction records, and program instructions to save the data and the metadata records in a data replication repository; and in response to receiving a request to recover a target database, program instructions to selectively recover, by the DRR agent, the target database wherein the target database is recovered using either one or more individual transactions or a bookmark.

15 . The computer system of claim 14 , wherein the source database differs from at least one of the one or more target databases in architecture, wherein the architecture includes relational and non-relational.

16 . The computer system of claim 14 , wherein the bookmark records a stable save point in the metadata, and wherein the bookmark comprises a first log position corresponding to a last committed transaction on the target database, a second log position corresponding to an earliest open transaction on the source database, and a third log position corresponding to a last applied transaction on the target database.

17 . The computer system of claim 14 , wherein each of the one or more target databases is associated with one dedicated data repository.

18 . The computer system of claim 14 , wherein the metadata comprises a transaction identifier, a timestamp associated with a transaction, transaction statistics wherein the transaction statistics include a number of operations performed on the source database, and a number of rows processed on the source database.

19 . The computer system of claim 14 , wherein the program instructions to selectively recover the target database further comprises:
program instructions to locate the selected bookmark within the data replication repository associated with the target database; program instructions to locate an earliest log position entry recorded in the bookmark and a last log position entry recorded in the bookmark in the metadata within the data replication repository associated with the target database; program instructions to create a plurality of database operations to reverse the transactions recorded within the earliest log position entry and the last log position entry in the selected bookmark; program instructions to send, by the DRR agent, the plurality of created database operations to a target agent on the target database, wherein the target agent executes the plurality of created database operations on the target database; based on the created database operations completing on the target database, program instructions to notify the DRR agent, by the target agent; and in response to receiving the notification, program instructions for the DRR agent to mark the data and metadata in the data replication repository as being recovered.

20 . The computer system of claim 14 , wherein the data replication repository includes the metadata, the data records created from the received one or more transaction records, and the bookmark.

Assignees

• IBM

Inventors

• Kedia Pravin K
• Kumar Nirmal

Classifications

• G06F11/1474 Primary

  in transactions (updating of structured data in databases G06F16/23) · CPC title

• G06F11/2097

  maintaining the standby controller/processing unit updated (initialisation or re-synchronisation thereof G06F11/1658 and subgroups) · CPC title

• G06F11/2094

  Redundant storage or storage space (G06F11/2056 takes precedence) · CPC title

• G06F11/1464

  for networked environments · CPC title

• G06F16/2379

  Updates performed during online database operations; commit processing · CPC title