Predicting validity of data replication prior to actual replication in a transaction processing system

• US 9,727,601 B2
• Filed: 08/25/2016
• Issued: 08/08/2017
• Est. Priority Date: 01/28/2014
• Status: Expired due to Fees

• Current Assignee: International Business Machines Corporation
• Original Assignee: International Business Machines Corporation
• Inventors: Willoughby, Austin J., Rinke, Ralph A., Walker, Clark W.
• Primary Examiner(s): Obisesan, Augustine K
• Assistant Examiner(s): Ennaji, Lahcen
• Application Number:
  US15/246,972
• Publication Number:
  US 20160364436A1
• Time in Patent Office: 348 Days
• CPC Class Codes: G06F 16/2365 Ensuring data consistency and integrity
• CPC Class Codes: G06F 16/2379 Updates performed during online database operations; commit processing
• 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: G06N 5/04 Inference or reasoning models

Abstract

Validating a write of a replica record to a replica data store in a transaction processing system. The source record is written to a location in the source data store, and the location is recorded in a transaction log file. The transaction processing system obtains from the transaction log file the location, and the location in the replica data store to which the replica record will be written is predicted, based on the location and length of the previous replica record. If the obtained location of the source record corresponds to the predicted location of the replica record location, the replica record is written to a location in the replica data store.

Claims

1. A method for validating a write of a replica record to a replica data store in a transaction processing system, the replica record duplicating a source record in a source data store, the method comprising:

writing, by the transaction processing system, the source record to a location in the source data store;

recording, by the transaction processing system into a transaction log file, the location to which the source record is written in the source data store;

obtaining, by the transaction processing system from the transaction log file, the location to which the source record is written in the source data store;

predicting, by the transaction processing system, the location in the replica data store to which the replica record will be written, based on the location and length of the previous replica record;

responsive to determining that the obtained location of the source record does not correspond to the predicted location of the replica record;

not writing the replica record;

signaling, to the transaction processing system, a replica record location prediction failure; and

ending replication;

responsive to determining that the obtained location of the source record corresponds to the predicted location of the replica record location, writing, by the transaction processing system, the replica record to a location in the replica data store; and

responsive to determining that the obtained location of the source record does not correspond to the location in the replica data store to which the replica record was written, identifying the replica data store as corrupted.

2. The method according to claim 1, wherein each of the obtained location of the source record location, the predicted location of the replica record location, and the actual location to which the replica record will be written is a relative byte address (RBA).

3. The method according to claim 1, wherein the transaction processing system is a Customer Information Control System (CICS).

4. The method according to claim 1, wherein the source data store and the replica data store are Virtual Storage Access Method (VSAM) Entry Sequenced Data Sets (ESDS).

5. The method according to claim 4, wherein responsive to determining that the obtained location of the source record does not correspond to the predicted location of the replica record comprises:

predicting, by the transaction processing system, a second location in a next control interval in the replica data store; and

responsive to determining that the obtained location of the source record location does not correspond to the second predicted location;

not writing the replica record;

signaling, to the transaction processing system, a replica record location prediction failure; and

ending replication.

6. A computer program product for validating a write of a replica record to a replica data store in a transaction processing system, the replica record duplicating a source record in a source data store, the computer program product comprising one or more computer-readable tangible non-transitory storage devices and program instructions stored on at least one of the one or more computer-readable tangible non-transitory storage devices, the program instructions comprising:

program instructions to write, by the transaction processing system, the source record to a location in the source data store;

program instructions to record, by the transaction processing system into a transaction log file, the location to which the source record is written in the source data store;

program instructions to obtain, by the transaction processing system from the transaction log file, the location to which the source record is written in the source data store;

program instruction to predict, by the transaction processing system, the location in the replica data store to which the replica record will be written, based on the location and length of the previous replica record; and

responsive to determining that the obtained location of the source record does not correspond to the predicted location of the replica record, program instructions to;

not write the replica record;

signal, to the transaction processing system, a replica record location prediction failure; and

end replication;

responsive to determining that the obtained location of the source record corresponds to the predicted location of the replica record location, program instructions to write, by the transaction processing system, the replica record to a location in the replica data store; and

responsive to determining that the obtained location of the source record does not correspond to the location in the replica data store to which the replica record was written, program instructions to identify the replica data store as corrupted.

7. The computer program product according to claim 6, wherein each of the obtained location of the source record location, the predicted location of the replica record location, and the actual location to which the replica record will be written is a relative byte address (RBA).

8. The computer program product according to claim 6, wherein the transaction processing system is a Customer Information Control System (CICS).

9. The computer program product according to claim 6, wherein the source data store and the replica data store are Virtual Storage Access Method (VSAM) Entry Sequenced Data Sets (ESDS).

10. The computer program product according to claim 9, wherein responsive to determining that the obtained location of the source record does not correspond to the predicted location of the replica record comprises program instructions to:

predict, by the transaction processing system, a second location in a next control interval in the replica data store; and

responsive to determining that the obtained location of the source record location does not correspond to the second predicted location;

not write the replica record;

signal, to the transaction processing system, a replica record location prediction failure; and

end replication.

11. A computer system for validating a write of a replica record to a replica data store in a transaction processing system, the replica record duplicating a source record in a source data store, 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 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 write, by the transaction processing system, the source record to a location in the source data store;

program instructions to record, by the transaction processing system into a transaction log file, the location to which the source record is written in the source data store;

program instructions to obtain, by the transaction processing system from the transaction log file, the location to which the source record is written in the source data store;

program instruction to predict, by the transaction processing system, the location in the replica data store to which the replica record will be written, based on the location and length of the previous replica record; and

responsive to determining that the obtained location of the source record does not correspond to the predicted location of the replica record, program instructions to;

not write the replica record;

signal, to the transaction processing system, a replica record location prediction failure; and

end replication;

responsive to determining that the obtained location of the source record corresponds to the predicted location of the replica record location, program instructions to write, by the transaction processing system, the replica record to a location in the replica data store; and

responsive to determining that the obtained location of the source record does not correspond to the location in the replica data store to which the replica record was written, program instructions to identify the replica data store as corrupted.

12. The computer system according to claim 11, wherein each of the obtained location of the source record location, the predicted location of the replica record location, and the actual location to which the replica record will be written is a relative byte address (RBA).

13. The computer system according to claim 11, wherein the transaction processing system is a Customer Information Control System (CICS).

14. The computer system according to claim 11, wherein the source data store and the replica data store are Virtual Storage Access Method (VSAM) Entry Sequenced Data Sets (ESDS).

15. The computer system according to claim 14, wherein responsive to determining that the obtained location of the source record does not correspond to the predicted location of the replica record comprises program instructions to:

predict, by the transaction processing system, a second location in a next control interval in the replica data store; and

responsive to determining that the obtained location of the source record location does not correspond to the second predicted location;

not write the replica record;

signal, to the transaction processing system, a replica record location prediction failure; and

end replication.