Consistent query execution in hybrid DBMS

Patent metadata

Field	Value
Publication number	US-11138227-B2
Application number	US-201916438561-A
Country	US
Kind code	B2
Filing date	Jun 12, 2019
Priority date	Aug 9, 2016
Publication date	Oct 5, 2021
Grant date	Oct 5, 2021

Abstract

A computer-implemented method for computer query processing and/or data-table management in a computer system. The method includes generating a table that exists as a first instance in a first database and as a second instance in a second database. The method includes generating a current replication batch of pooled changes of the first instance that committed at or before a first time. The method includes propagating changes specified in the current replication batch to the second instance. The method includes assigning a batch-ID of the current replication batch to the query. The method includes executing the query on the second instance using the batch-ID as a filter to exclude any changes that have an assigned batch-ID of a replication batch having committed later than the current replication batch. The method includes returning results of the query execution on the second instance.

First claim

What is claimed is:

1. A computer-implemented method, the method comprising:
generating, by one or more processors, a table that exists as a first instance in a first database and as a second instance in a second database;
generating, by the one or more processors, a current replication batch of pooled changes of the first instance that committed at or before a first time;
propagating, by the one or more processors, changes specified in the current replication batch to the second instance;
assigning, by the one or more processors, a batch-ID of the current replication batch to the query;
determining, by one or more processors, the query for the first instance and the second instance using a replication module and a plurality of database engines;
executing, by the one or more processors, the query on the second instance using the batch-ID as a filter to exclude any changes that have an assigned batch-ID of a replication batch having committed later than the current replication batch; and
returning, by the one or more processors, results of the query execution on the second instance.

2. The computer-implemented method of claim 1 , the method comprising:
determining, by the one or more processors, the first time based on a commit time of at least one most recent write transaction that was committed before receipt of the query.

3. The computer-implemented method of claim 1 , the method comprising:
asynchronously replicating, by the one or more processors, the current replication batch to the second instance, thereby propagating the changes specified in the current replication batch to the second instance.

4. The computer-implemented method of claim 1 , the method comprising:
storing, by the one or more processors, each change that is specified in the current replication batch in the second instance.

5. The computer-implemented method of claim 1 , the method comprising:
initiating, by the one or more processors, execution of the query on the second instance in response to a determination that a replication of the current replication batch to the second instance was completed.

6. The computer-implemented method of claim 1 , the method comprising:
responsive to a determination to execute the query against the second instance, sending, by the one or more processors, the query and the assigned batch-ID to a database engine that maintains the second database.

7. The computer-implemented method of claim 1 , the method including:
executing, by the one or more processors, a plurality of write transactions, thereby respectively changing the first instance; and
asynchronously pooling, by the one or more processors, the changes of the first instance introduced by the write transactions.

8. The computer-implemented method of claim 1 , the method including:
in response to receiving the query against the table, determining whether to execute the query against the first instance or against the second instance, wherein the method is implemented by a data processing system that includes and a replication module, a first database engine maintaining the first database, and a second database engine maintaining the second database.

9. A computer program product, the computer program product comprising a computer readable storage medium having program instructions embodied therewith, wherein the computer readable storage medium is not a transitory signal per se, the program instructions executable by a device to cause the device to perform a method comprising:
generating, by one or more processors, a table that exists as a first instance in a first database and as a second instance in a second database;
generating, by the one or more processors, a current replication batch of pooled changes of the first instance that committed at or before a first time;
propagating, by the one or more processors, changes specified in the current replication batch to the second instance;
assigning, by the one or more processors, a batch-ID of the current replication batch to the query;
determining, by one or more processors, the query for the first instance and the second instance using a replication module and a plurality of database engines;
executing, by the one or more processors, the query on the second instance using the batch-ID as a filter to exclude any changes that have an assigned batch-ID of a replication batch having committed later than the current replication batch; and
returning, by the one or more processors, results of the query execution on the second instance.

10. The computer program product of claim 9 , the method comprising:
determining, by the one or more processors, the first time based on a commit time of at least one most recent write transaction that was committed before receipt of the query.

11. The computer program product of claim 9 , the method comprising:
asynchronously replicating, by the one or more processors, the current replication batch to the second instance, thereby propagating the changes specified in the current replication batch to the second instance.

12. The computer program product of claim 9 , the method comprising:
storing, by the one or more processors, each change that is specified in the current replication batch in the second instance.

13. The computer program product of claim 9 , the method comprising:
initiating, by the one or more processors, execution of the query on the second instance in response to a determination that a replication of the current replication batch to the second instance was completed.

14. The computer program product of claim 9 , the method comprising:
responsive to a determination to execute the query against the second instance, sending, by the one or more processors, the query and the assigned batch-ID to a database engine that maintains the second database.

15. The computer program product of claim 9 , the method including:
executing, by the one or more processors, a plurality of write transactions, thereby respectively changing the first instance; and
asynchronously pooling, by the one or more processors, the changes of the first instance introduced by the write transactions.

16. The computer program product of claim 9 , the method including:
in response to receiving the query against the table, determining whether to execute the query against the first instance or against the second instance, wherein the method is implemented by a data processing system that includes and a replication module, a first database engine maintaining the first database, and a second database engine maintaining the second database.

17. A computer system, the computer system comprising:
one or more computer processors;
at least one computer readable storage medium that is not a transitory signal per se; and
program instructions stored on the at least one computer readable storage medium, the program instructions being executable by at least one computer processor of the one or more computer processors to cause the at least one computer processor to perform a method comprising:
generating, by one or more processors, a table that exists as a first instance in a first database and as a second instance in a second database;
generating, by the one or more processors, a current replication batch of pooled changes of the first instance that committed at or before a first time;
propagating, by the one or more processors, changes specified in the current replication batch to the second instance;
assigning, by the one or more processors, a batch-ID of the current replication batch to the query;
determining, by one

Assignees

• IBM

Inventors

• Brodt Andreas
• Koeth Oliver
• Martin Daniel
• Stolze Knut

Classifications

• G06F16/2455

  Query execution · CPC title

• G06F16/2282

  Tablespace storage structures; Management thereof · CPC title

• G06F16/273 Primary

  Asynchronous replication or reconciliation · CPC title