Dynamic optimization of data aggregation

Patent metadata

Field	Value
Publication number	US-9256641-B1
Application number	US-201314057074-A
Country	US
Kind code	B1
Filing date	Oct 18, 2013
Priority date	Oct 18, 2013
Publication date	Feb 9, 2016
Grant date	Feb 9, 2016

Abstract

A method includes receiving a first database query, in which the first database query requests particular data associated with a first object that is stored on a data source. The method also includes determining whether the first database query includes an aggregation function. The method also includes sending an instruction to generate current aggregate data based on the aggregation function to the data source in response to determining that the first database query includes the aggregation function, in which the current aggregate data corresponds to the particular data. The data source is configured to generate the current aggregate data in response to receiving the instruction. The method includes generating a second database query based on the first database query, in which the second database query requests the current aggregate data. The method also includes retrieving the current aggregate data using the second database query and providing the current aggregate data.

First claim

What is claimed is:

1. A method comprising:
receiving a first database query, the first database query requesting particular data associated with a first object, the first object stored on a data source;
determining whether the first database query comprises an aggregation;
sending an instruction to generate current aggregate data based on the aggregation to the data source in response to determining that the first database query comprises the aggregation, wherein:
the instruction to generate the current aggregate data is generated based on the aggregation,
the current aggregate data corresponds to the particular data,
the data source is configured to generate the current aggregate data in response to receiving the instruction to generate the current aggregate data;

generating a second database query based on the first database query in response to sending the instruction to generate the current aggregate data, the second database query requesting the current aggregate data;
retrieving the current aggregate data using the second database query in response to generating the second database query;
providing the current aggregate data in response to retrieving the current aggregate data; and
issuing the first query in response to determining that the first database query does not comprise the aggregation.

2. The method of claim 1 , wherein the current aggregate data is located in a second object, the second object stored on the data source,
wherein the data source is further configured to generate the second object.

3. The method of claim 1 , further comprising:
obtaining a description of the first object in response to determining that the first database query comprises the aggregation; and
determining whether the first object comprises a predetermined amount of data based on the description of the first object,
wherein sending the instruction to generate the current aggregate data comprises sending the instruction to generate the current aggregate data to the data source in response to determining that the first object comprises the predetermined amount of data,
wherein issuing the first query comprises issuing the first query in response to determining that the first object does not comprise the predetermined amount of data.

4. The method of claim 1 , further comprising:
periodically sending an instruction to generate periodic aggregate data based on the aggregation to the data source, the periodic aggregate data corresponding to the particular data and the data source configured to, in response to receiving each instruction to generate the periodic aggregate data:
destroy the periodic aggregate data that was previously generated; and
regenerate the periodic aggregate data; and

determining whether to provide the periodic aggregate data in response to determining that the first database query comprises the aggregation;
generating a third database query based on the first database query in response to determining to provide the periodic aggregate data, the third database query requesting the periodic aggregate data;
retrieving the periodic aggregate data using the third database query in response to generating the third database query; and
providing the periodic aggregate data in response to retrieving the periodic aggregate data,
wherein sending the instruction to generate current aggregate data comprises sending the instruction to generate current aggregate data in response to determining to not provide the periodic aggregate data.

5. The method of claim 1 , further comprising:
mapping the current aggregate data to a column identified in the first database query in response to retrieving the current aggregate data, the column corresponding to the particular data,
wherein providing the current aggregate data comprises providing the current aggregate data based on the mapping.

6. The method of claim 1 , wherein retrieving the current aggregate data using the second database query comprises:
converting the second database query into a format supported by the data source;
sending the second database query in the format to the data source; and
receiving the current aggregate data from the data source.

7. The method of claim 1 , wherein the aggregation corresponds to an aggregation function, the aggregation function comprising one of: a count function, a maximum function, a minimum function, a first value function, a last value function, and a sum function.

8. A system comprising:
a first receiving device configured to receive a first database query, the first database query requesting particular data associated with a first object, the first object stored on a data source;
a first determining device configured to determine whether the first database query comprises an aggregation;
a first sending device configured to send an instruction to generate current aggregate data based on the aggregation to the data source in response to determining that the first database query comprises the aggregation, wherein:
the instruction to generate the current aggregate data is generated based on the aggregation,
the current aggregate data corresponds to the particular data,
the data source is configured to generate the current aggregate data in response to receiving the instruction to generate the current aggregate data;

a first generating device configured to generate a second database query based on the first database query in response to sending the instruction to generate the current aggregate data, the second database query requesting the current aggregate data;
a first retrieving device configured to retrieve the current aggregate data using the second database query in response to generating the second database query;
a first providing device configured to provide the current aggregate data in response to retrieving the current aggregate data; and
a standard issuing device configured to issue the first query in response to determining that the first database query does not comprise the aggregation.

9. The system according to claim 8 , wherein the current aggregate data is located in a second object, the second object stored on the data source,
wherein the data source is further configured to generate the second object.

10. The system of claim 8 , further comprising:
an obtaining device configured to obtain a description of the first object in response to determining that the first database query comprises the aggregation; and
a second determining device configured to determine whether the first object comprises a predetermined amount of data based on the description of the first object,
wherein the first sending device is configured to send the instruction to generate the current aggregate data to the data source in response to determining that the first object comprises the predetermined amount of data,
wherein the standard issuing device is configured to issue the first query in response to determining that the first object does not comprise the predetermined amount of data.

11. The system of claim 8 , further comprising:
a second sending device configured to periodically send an instruction to generate periodic aggregate data based on the aggregation to the data source, the periodic aggregate data corresponding to the particular data and the data source configured to, in response to receiving each instruction to generate the periodic aggregate data:
destroy the periodic aggregate data that was previously generated; and
regenerate the periodic aggregate data; and

a third determining device configured to determine whether to provide the periodic aggregate data in response to determining that the first database query comprises the aggrega

Assignees

• Zlatnik Pavel
• Ca Inc

Inventors

• Zlatnik Pavel

Classifications

• G06F16/2453 Primary

  Query optimisation · CPC title

• G06F17/30442 Primary

  Physics · mapped topic