Stale data recognition

Patent metadata

Field	Value
Publication number	US-12554704-B2
Application number	US-202117476039-A
Country	US
Kind code	B2
Filing date	Sep 15, 2021
Priority date	Sep 15, 2021
Publication date	Feb 17, 2026
Grant date	Feb 17, 2026

Abstract

A method, computer program product, and system include a processor(s) obtaining a query request from an application via a source database management system to a target database management system, where the query request comprises a query and a query timestamp indicating a last update to table(s) in the source database management system referenced in the query request. The processor(s) determines a table update timestamp indicating a last time when the table(s) in the source database management system referenced in the query request was replicated to the target database management system. The processor(s) generates an indicator where the indicator represent a difference between the query timestamp and the table update timestamp. The processor(s) executes the query in the target database management system. The processor(s) transmit a query result and the indicator to the source database management system.

First claim

What is claimed is:

1 . A computer-implemented method, comprising:
executing, by one or more processors, a query from an application on target tables of a target database management system accessed by the query to obtain, at the application, data responsive to the query, wherein the application has a stale data tolerance, the executing comprising:
obtaining, by the one or more processors, a query request from the application via a source database management system to the target database management system, wherein the query request comprises the query and a query timestamp indicating a last update to one or more tables in the source database management system referenced in the query request, and wherein the source database management system and the target database management system comprise an asynchronous replication enabled hybrid database management systems;
obtaining, by the one or more processors, a table update timestamp indicating a last time when the one or more tables in the source database management system referenced in the query request was replicated to the target database management system, based on determining the last time when the one or more tables in the source database management system referenced in the query request were replicated to the target database management system;
generating, by the one or more processors, an indicator wherein the indicator represents a difference between the query timestamp and the table update timestamp, wherein the indicator reports a staleness of the data specifically in target tables of the target database management system accessed by the query comprising the data responsive to the query, wherein the indicator is a measurable value which indicates a measurable staleness of the data responsive to the query;
executing, by the one or more processors, the query in the target database management system;
based on executing the query, obtaining, by the one or more processors, a query result comprising the data responsive to the query; and
transmitting, by the one or more processors, to the application, a query response, wherein the query response comprises the query result and the indicator, to the source database management system, wherein the indicator reports to the application whether the query is returning stale or current data from the target tables of the target database management system accessed by the query comprising the data responsive to the query, and wherein the application determines, based on whether the measurable value of indicator comports with the stale data tolerance of the application, whether the application will utilize the data responsive to the query.

2 . The computer-implemented method of claim 1 , wherein the source database management system is an online transactional processing system.

3 . The computer-implemented method of claim 1 , wherein the target database management system is an online analytical processing system.

4 . The computer-implemented method of claim 1 , wherein determining the last time when the one or more tables in the source database management system referenced in the query request were replicated to the target database management system to obtain the table update timestamp comprises:
querying, by the one or more processors, a replication engine communicatively coupled to a capture engine of the source database management system and the target database management system to obtain the table update timestamp.

5 . The computer-implemented method of claim 1 , wherein executing the query comprises executing the query by an accelerator.

6 . The computer-implemented method of claim 5 , wherein the one or more tables in the source database management system referenced in the query request were loaded into a column store structure of the accelerator.

7 . The computer-implemented method of claim 1 , wherein the query comprises a reference to one or more tables in a second source database management system, the method further comprising:
querying, by the one or more processors, the second source database management system to obtain a second query timestamp indicating a latest update to the one or more tables in the second source database management system; determining, by the one or more processors, a table update timestamp indicating a latest time when the one or more tables in the second source database management system were replicated to the target database management system; generating, by the one or more processors, a second indicator wherein the second indicator represents a difference between the second query timestamp and the table update timestamp indicating the latest time when the one or more tables in the second source database management system was replicated to the target database management system; and transmitting, by the one or more processors, the second indicator in the query response to the source database management system.

8 . The computer-implemented method of claim 1 , further comprising:
displaying, by the one or more processors, the indicator in an interface communicatively coupled to the source database management system.

9 . The computer-implemented method of claim 1 , further comprising:
determining, by the one or more processors, that data queried when executing the query is current based on the difference indicating that the query timestamp is equivalent or older than the table update timestamp.

10 . The computer-implemented method of claim 1 , further comprising:
determining, by the one or more processors, that data queried when executing the query is stale based on the difference indicating that the query timestamp is and newer than the table update timestamp.

11 . A computer program product comprising:
a computer readable storage medium readable by one or more processors of a shared computing environment comprising a computing system and storing instructions for execution by the one or more processors for performing a method comprising:
executing, by the one or more processors, a query from an application on target tables of a target database management system accessed by the query to obtain, at the application, data responsive to the query, wherein the application has a stale data tolerance, the executing comprising:
obtaining, by the one or more processors, a query request from the application via a source database management system to the target database management system, wherein the query request comprises the query and a query timestamp indicating a last update to one or more tables in the source database management system referenced in the query request, and wherein the source database management system and the target database management system comprise an asynchronous replication enabled hybrid database management systems;
obtaining, by the one or more processors, a table update timestamp indicating a last time when the one or more tables in the source database management system referenced in the query request was replicated to the target database management system, based on determining the last time when the one or more tables in the source database management system referenced in the query request were replicated to the target database management system;
generating, by the one or more processors, an indicator wherein the indicator represents a difference between the query timestamp and the table update timestamp, wherein the indicator reports a staleness of the data specifically in target tables of the target database management system accessed by the query comprising the data responsive to the query, wherein the indicator is a measurable value which indicates a measurable staleness of the data responsive to the query;
executing, by t

Assignees

• IBM

Inventors

• Martin Daniel
• Zhong Jia Heng
• Kameswaran Sowmya
• Simanjuntak Manogari Nogi

Classifications

• G06F16/2455 Primary

  Query execution · CPC title

• G06F16/27

  Replication, distribution or synchronisation of data between databases or within a distributed database system; Distributed database system architectures therefor · CPC title

• G06F16/254

  Extract, transform and load [ETL] procedures, e.g. ETL data flows in data warehouses · CPC title

• G06F16/2282

  Tablespace storage structures; Management thereof · CPC title

• G06F16/2379 Primary

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