QUERY GOVERNOR RULES FOR DATA REPLICATION

• US 20180046691A1
• Filed: 08/10/2016
• Published: 02/15/2018
• Est. Priority Date: 08/10/2016
• Status: Abandoned Application

• Current Assignee: International Business Machines SA (International Business Machines Corporation)
• Original Assignee: International Business Machines Corporation
• Inventors: BARSNESS, Eric L., BEUCH, Daniel E., MURAS, Brian R., SANTOSUOSSO, John M.
• Application Number:
  US15/233,678
• Publication Number:
  US 20180046691A1
• Time in Patent Office: Days
• CPC Class Codes: G06F 11/1402 Saving, restoring, recovering or retrying
• CPC Class Codes: G06F 11/2094 Redundant storage or storage space G06F11/2056 takes precedence
• CPC Class Codes: G06F 11/2097 maintaining the standby controller/processing unit updated initialisation or re-synchronisation thereof G06F11/1658 and subgroups
• CPC Class Codes: G06F 16/275 Synchronous replication
• CPC Class Codes: G06F 2201/80 Database-specific techniques
• CPC Class Codes: G06F 2201/81 Threshold

Abstract

Embodiments of the present disclosure provide a method, system, and computer program product for managing the execution of a query. The method, system and computer program product include receiving a query to be executed. The query governor calculates an estimated replication time of the received query. The estimated replication time is an estimated duration of time required to replicate changes caused by the query. The query governor determines whether the estimated replication time exceeds the threshold replication time. Responsive to the query governor determining that the estimated replication time does not exceed the threshold replication time, the query governor executes the query against the database in accordance with the instructions.

Claims

1. A method, comprising:

receiving a query to be executed against a database;

calculating an estimated replication time of the received query, wherein the estimated replication time is an estimated duration of time required to replicate changes caused by the query;

determining whether the estimated replication time exceeds a threshold replication time; and

responsive to determining that the estimated replication time does not exceed the threshold replication time, executing the query against the database in accordance with the instructions.

2. The method of claim 1, further comprising:

receiving a second query to be executed against the database;

communicating with a replication agent the received query;

receiving from the replication agent instructions to execute the second query against the database based on a determination of an estimated replication time for the second query being less than a second threshold replication time, wherein the estimated replication time for the second query is an estimated duration of time required to replicate changes caused by the second query; and

executing the second query against the database in accordance with the instructions.

3. The method of claim 2, further comprising:

receiving a third query to be executed against a database;

communicating with a replication agent, the third query;

receiving from the replication agent, instructions to modify the third query against the database based on a determination of a third estimated replication time being greater than a threshold replication time;

modifying the third query in accordance with instructions from the replication agent; and

executing the query against the database in accordance with the instructions.

4. The method of claim 3, wherein modifying the third query in accordance with instructions from the replication agent, comprises:

receiving instructions to modify the third query to an equivalent query having an estimated replication time less than the third estimated replication time of the third query.

5. The method of claim 2, further comprising:

receiving a third query to be executed against a database;

communicating with a replication agent, the third query;

receiving from the replication agent, instructions to rearrange the third query in a queue based on a determination of a third estimated replication time being greater than a threshold replication time; and

rearranging the third query in the query queue in accordance with instructions from the replication agent.

6. The method of claim 2, further comprising:

receiving a third query to be executed against a database;

communicating with a replication agent, the third query;

receiving from the replication agent, instructions to slow execution of the third query based on a determination of a third estimated replication being greater than a threshold replication time; and

slowing execution of the third query in accordance with instructions from the replication agent.

7. The method of claim 2, further comprising:

calculating an updated replication time of the second query;

communicating with a replication agent, the updated replication time;

receiving from the replication agent, instructions to execute the second query against the database based on a determination of an updated estimated replication time being less than a third threshold replication time; and

executing the second query against the database in accordance with the instructions.

8. A system, comprising:

a computer processor; and

a memory containing a program that, when executed on the computer processor, performs an operation for managing the execution of a query, comprising;

receiving a query to be executed against a database;

calculating an estimated replication time of the received query, wherein the estimated replication time is an estimated duration of time required to replicate changes caused by the query;

determining whether the estimated replication time exceeds a threshold replication time; and

responsive to determining that the estimated replication time does not exceed the threshold replication time, executing the query against the database in accordance with the instructions.

9. The system of claim 8, further comprising:

receiving a second query to be executed against the database;

communicating with a replication agent the received query;

receiving from the replication agent instructions to execute the second query against the database based on a determination of an estimated replication time for the second query being less than a second threshold replication time, wherein the estimated replication time for the second query is an estimated duration of time required to replicate changes caused by the second query; and

executing the second query against the database in accordance with the instructions.

10. The system of claim 9, further comprising:

receiving a third query to be executed against a database;

communicating with a replication agent, the third query;

receiving from the replication agent, instructions to modify the third query against the data base based on a determination of a third estimated replication time being greater than a threshold replication time;

modifying the third query in accordance with instructions from the replication agent; and

executing the query against the database in accordance with the instructions.

11. The system of claim 10, wherein modifying the third query in accordance with instructions from the replication agent, comprises:

receiving instructions to modify the third query to an equivalent query having an estimated replication time less than the third estimated replication time of the third query.

12. The system of claim 9, further comprising:

receiving a third query to be executed against a database;

communicating with a replication agent, the third query;

receiving from the replication agent, instructions to rearrange the third query in a queue based on a determination of a third estimated replication time being greater than a threshold replication time; and

rearranging the third query in the query queue in accordance with instructions from the replication agent.

13. The system of claim 9, further comprising:

receiving a third query to be executed against a database;

communicating with a replication agent, the third query;

receiving from the replication agent, instructions to slow execution of the third query based on a determination of a third estimated replication being greater than a threshold replication time; and

slowing execution of the third query in accordance with instructions from the replication agent.

14. The system of claim 8, further comprising:

calculating an updated replication time of the second query;

communicating with a replication agent, the updated replication time;

receiving from the replication agent, instructions to execute the second query against the database based on a determination of the updated estimated replication time for the amount of data change being less than a third threshold replication time; and

executing the second query against the database in accordance with the instructions.

15. A computer program product for managing the execution of a query, comprising:

a computer-readable storage medium having computer readable program code embodied therewith, the computer readable program code comprising;

computer readable program code to receive a query to be executed against a database;

computer readable program code calculate an estimated replication time of the received query, wherein the estimated replication time is an estimated duration of time required to replicate changes caused by the query;

computer readable program code to determine whether the estimated replication time exceeds a threshold replication time; and

computer readable program code to, responsive to determining that the estimated replication time does not exceed the threshold replication time, execute the query against the database in accordance with the instructions.

16. The computer program product of claim 15, further comprising:

receiving a second query to be executed against the database;

communicating with a replication agent the received query;

receiving from the replication agent instructions to execute the second query against the database based on a determination of an estimated replication time for the second query being less than a second threshold replication time, wherein the estimated replication time for the second query is an estimated duration of time required to replicate changes caused by the second query; and

executing the second query against the database in accordance with the instructions.

17. The computer program product of claim 16, further comprising:

receiving a third query to be executed against a database;

communicating with a replication agent, the third query;

receiving from the replication agent, instructions to modify the third query against the data base based on a determination of a third estimated replication time being greater than a threshold replication time;

modifying the third query in accordance with instructions from the replication agent; and

executing the query against the database in accordance with the instructions.

18. The computer program product of claim 16, further comprising:

receiving a third query to be executed against a database;

communicating with a replication agent, the third query;

receiving from the replication agent, instructions to modify the third query against the data base based on a determination of a third estimated replication time being greater than a threshold replication time;

modifying the third query in accordance with instructions from the replication agent; and

executing the query against the database in accordance with the instructions.

19. The computer program product of claim 18, wherein modifying the third query in accordance with instructions from the replication agent, comprises:

receiving instructions to modify the third query to an equivalent query having an estimated replication time less than the third estimated replication time of the third query.

20. The computer program product of claim 16, further comprising:

receiving a third query to be executed against a database;

communicating with a replication agent, the third query;

receiving from the replication agent, instructions to rearrange the third query in a queue based on a determination of a third estimated replication time being greater than a threshold replication time; and

rearranging the third query in the query queue in accordance with instructions from the replication agent.