GENERATION OF ARCHIVER QUERIES FOR CONTINUOUS QUERIES OVER ARCHIVED RELATIONS

• US 20140095445A1
• Filed: 09/25/2013
• Published: 04/03/2014
• Est. Priority Date: 09/28/2012
• Status: Active Grant

• Current Assignee: Oracle International Corporation (Oracle Corporation)
• Original Assignee: Oracle International Corporation (Oracle Corporation)
• Inventors: Deshmukh, Unmesh Anil, Srinivasan, Anand, Shukla, Vikram
• Granted Patent: US 9,953,059 B2
• Time in Patent Office: Days
• US Class Current: 707/661
• CPC Class Codes: G06F 16/2308 Concurrency control transaction processing G06F9/466
• CPC Class Codes: G06F 16/24542 Plan optimisation
• CPC Class Codes: G06F 16/24544 Join order optimisation
• CPC Class Codes: G06F 16/24568 Data stream processing; Continuous queries
• CPC Class Codes: G06F 16/951 Indexing; Web crawling techniques

Abstract

A method may include receiving a continuous query identified by an archived relation associated with an application. The method may also include generating a physical query plan. Additionally, the method may include constructing a structured query language (SQL) equivalent expression corresponding to an attribute utilized by the operator and/or constructing an output SQL expression for the identified operator based at least in part on the SQL equivalent expression. Additionally, the method may include constructing the archiver query for the identified operator based at least in part on the output SQL expression. Further, the method may include executing the archiver query to obtain a result set of data records related to the application and/or generating a snapshot output of one or more data values related to the application based at least in part on the result set of data records.

Claims

1. A computer-implemented method, comprising:

receiving, by a computer system configured to execute computer-executable instructions, a continuous query, the continuous query being identified based at least in part on an archived relation associated with an application;

generating a physical query plan for the continuous query;

determining that an operator identified in the physical query plan is capable of constructing an archiver query;

constructing a structured query language (SQL) equivalent expression corresponding to an attribute utilized by the operator;

constructing an output SQL expression for the identified operator based at least in part on the SQL equivalent expression;

constructing the archiver query for the identified operator based at least in part on the output SQL expression;

identifying that the operator is a query operator;

executing the archiver query to obtain a result set of data records related to the application; and

generating a snapshot output of one or more data values related to the application based at least in part on the result set of data records.

2. The computer-implemented method of claim 1, further comprising constructing an archiver query clause for the identified operator based at least in part on the SQL equivalent expression.

3. Computer-implemented method of claim 2, further comprising constructing the output SQL expression for the identified operator based at least in part on the archiver query clause.

4. The computer-implemented method of claim 1, further comprising initializing a state of the query operator based at least in part on the result set of data records.

5. The computer-implemented method of claim 4, further comprising generating the snapshot output of the data values related to the application based at least in part on the state of the identified query operator.

6. The computer-implemented method of claim 5, further comprising constructing a list of tuples for the identified query operator from the result set of data records, wherein at least one tuple in the list of tuples is constructed based at least in part on a subset of attributes of the result set of data records.

7. The computer-implemented method of claim 6, further comprising:

initializing the state of the identified query operator based at least in part on the list of tuples; and

generating the snapshot output of the one or more data values related to the application based at least in part on the list of tuples.

8. A computer-readable storage medium storing computer-executable instructions that, when executed by one or more computer systems, configure the one or more computer systems to perform at least:

instructions that cause the one or more computer systems to receive a continuous query, the continuous query being identified based at least in part on an archived relation associated with an application;

instructions that cause the one or more computer systems to generate a physical query plan for the continuous query;

instructions that cause the one or more computer systems to determine that an operator identified in the physical query plan is capable of constructing an archiver query;

instructions that cause the one or more computer systems to construct the archiver query for the identified operator based at least in part on the determination;

instructions that cause the one or more computer systems to identify that the operator is a query operator;

instructions that cause the one or more computer systems to execute the archiver query to obtain a result set of data records related to the application; and

instructions that cause the one or more computer systems to generate a snapshot output of one or more data values related to the application based at least in part on the result set of data records.

9. The computer-readable storage medium of claim 8, further comprising:

instructions that cause the one or more computer systems to construct a structured query language (SQL) equivalent expression corresponding to an attribute utilized by the operator;

instructions that cause the one or more computer systems to construct an output SQL expression for the identified operator based at least in part on the SQL equivalent expression; and

instructions that cause the one or more computer systems to construct the archiver query for the identified operator based at least in part on the output SQL expression.

10. The computer-readable storage medium of claim 9, further comprising instructions that cause the one or more computer systems to construct an archiver query clause for the identified operator based at least in part on the SQL equivalent expression.

11. The computer-readable storage medium of claim 10, further comprising instructions that cause the one or more computer systems to construct the output SQL expression for the identified operator based at least in part on the archiver query clause.

12. The computer-readable storage medium of claim 8, further comprising instructions that cause the one or more computer systems to initialize a state of the query operator based at least in part on the result set of data records.

13. The computer-readable storage medium of claim 12, further comprising instructions that cause the one or more computer systems to generate the snapshot output of the data values related to the application based at least in part on the state of the identified query operator.

14. The computer-readable storage medium of claim 8, further comprising instructions that cause the one or more computer systems to display the snapshot output of the one or more data values related to the application to a user of the application via a display device.

15. The computer-readable storage medium of claim 8, further comprising instructions that cause the one or more computer systems to process incoming real-time events related to the application based at least in part on the snapshot output of the one or more data values.

16. A system, comprising:

a memory storing a plurality of instructions; and

a processor configured to access the memory, wherein the processor is further configured to execute the plurality of instructions to at least;

receive a continuous query, the continuous query being identified based at least in part on an archived relation associated with an application;

generate a physical query plan for the continuous query;

determine that an operator identified in the physical query plan is capable of constructing an archiver query;

construct a structured query language (SQL equivalent expression corresponding to an attribute utilized by the operator;

construct an output SQL expression for the identified operator based at least in part on the SQL equivalent expression;

construct the archiver query for the identified operator based at least in part on the output SQL expression;

identify that the operator is a query operator;

execute the archiver query to obtain a result set of data records related to the application; and

generate a snapshot output of one or more data values related to the application based at least in part on the data records.

17. The system of claim 16, wherein the processor is further configured to execute the plurality of instructions to at least construct an archiver query clause for the identified operator based at least in part on the SQL equivalent expression.

18. The system of claim 17, wherein the processor is further configured to execute the plurality of instructions to at least construct the output SQL expression for the identified operator based at least in part on the archiver query clause.

19. The system of claim 16, wherein the processor is further configured to execute the plurality of instructions to at least initialize a state of the query operator based at least in part on the result set of data records.

20. The system of claim 19, wherein the processor is further configured to execute the plurality of instructions to at least generate the snapshot output of the one or more data values related to the application based at least in part on the state of the identified query operator.