Support for a parameterized query/view in complex event processing

• US 8,713,049 B2
• Filed: 07/28/2011
• Issued: 04/29/2014
• Est. Priority Date: 09/17/2010
• Status: Active Grant

• Current Assignee: Oracle International Corporation (Oracle Corporation)
• Original Assignee: Oracle International Corporation (Oracle Corporation)
• Inventors: Jain, Parul, Shukla, Vikram, Srinivasan, Anand, de Castro Alves, Alexandre, Hsiao, Eric
• Primary Examiner(s): Fan, Shiow-Jy
• Application Number:
  US13/193,377
• Publication Number:
  US 20120072455A1
• Time in Patent Office: 1,006 Days
• Field of Search: 707/758, 707/769, 707/779, 707/E17.014
• US Class Current: 707/779
• CPC Class Codes: G06F 16/2452 Query translation
• CPC Class Codes: G06F 16/24524 Access plan code generation and invalidation; Reuse of access plans
• CPC Class Codes: G06F 16/24534 Query rewriting; Transformation

Abstract

The present invention includes a method for providing parameterized queries in complex event processing (CEP). The method includes providing a query template which includes one or more bind variables, providing sets of parameters corresponding to the one or more bind variables, and parsing the query template to determine positions of the one or more bind variables. The method further includes scanning the provided sets of parameters to determine which of the sets of parameters are to be bound to the one or more bind variables, binding the one or more bind variables which are determined to be bound to the sets of parameters, and substituting the bound one or more bind variables with the corresponding sets of parameters. The method further includes injecting all incarnations of the parameterized queries into the system, and one template/parameterized query is configured to run them all.

Claims

1. A method of providing parameterized queries in complex event processing (CEP) environment, the method comprising:

providing a query template which includes one or more bind variables, wherein the one or more bind variables are typeless within the CEP environment;

providing sets of parameters corresponding to the one or more bind variables;

parsing the query template to determine positions of the one or more bind variables;

scanning the provided sets of parameters to determine which of the sets of parameters are to be bound to the one or more bind variables;

binding the one or more bind variables which are determined to be bound to the corresponding sets of parameters;

inserting arbitrary predicates into the query template, based on the one or more bind variables being typeless;

substituting the bound one or more bind variables with the corresponding sets of parameters;

based on the sets of parameters, generating a single parameterized query which is a template that provides possible values for the bound one of more bind variables;

determining a placeholder occurring in the single parameterized query for processing an event stream;

based on the single parameterized query, generating multiple customized queries and views which differ by at least one variable, wherein the multiple customized queries and views are maintained by substituting the placeholder at runtime with parameters from the sets of parameters;

instantiating a new query based on the query temple which includes the corresponding sets of parameters substituted for the one or more bind variables and injecting the new query into a CEP server;

based on the new query, building a query execution plan;

adding the query execution plan to a runtime environment as a continuous query; and

executing the continuous query to process the event stream.

2. The method of providing parameterized queries in CEP as in claim 1, further comprising building a map of the determined positions of the one or more bind variables.

3. The method of providing parameterized queries in CEP as in claim 2, wherein the substituting of the one or more bind variables with the corresponding sets of parameters further comprises using the map of determined positions of the one or more bind variables to place the bound sets of parameters within the query template.

4. The method of providing parameterized queries in CEP as in claim 1, wherein the providing of the sets of parameters corresponding to the one or more bind variables is performed either statically or dynamically.

5. The method of providing parameterized queries in CEP as in claim 4, wherein the providing of the sets of parameters corresponding to the one or more bind variables is performed statically by using a config file at deployment time of the query template.

6. The method of providing parameterized queries in CEP as in claim 4, wherein the providing of the sets of parameters corresponding to the one or more bind variables is performed dynamically by using a module management solution.

7. The method of providing parameterized queries in CEP as in claim 5, wherein the config file includes at least one or more of the following:

application association, processor association, query rules, the query template, the sets of parameters, or the bindings.

8. The method of providing parameterized queries in CEP as in claim 1, further comprising:

determining that multiple sets of parameters correspond to the same bind variable; and

instantiating a separate new query for each of the multiple sets of parameters which correspond to the same bind variable.

9. A system for providing parameterized queries in complex event processing (CEP), the system comprising:

a memory; and

a processor coupled with the memory, wherein the memory has sets of instructions stored thereon which, when executed by the processor, cause the processor to;

provide a query template which includes one or more bind variables, wherein the one or more bind variables are typeless within the CEP environment;

provide sets of parameters corresponding to the one or more bind variables;

parse the query template to determine positions of the one or more bind variables;

scan the provided sets of parameters to determine which of the sets of parameters are to be bound to the one or more bind variables;

bind the one or more bind variables which are determined to be bound to the corresponding sets of parameters;

insert arbitrary predicates into the query template, based on the one or more bind variables being typeless;

substitute the bound one or more bind variables with the corresponding sets of parameters;

based on the sets of parameters, generate a single parameterized query which is a template that provides possible values for the bound one of more bind variables;

determine a placeholder occurring in the single parameterized query for processing an event stream;

based on the single parameterized query, generate multiple customized queries and views which differ by at least only one variable, wherein the multiple customized queries and views are maintained by substituting the placeholder at runtime with parameters from the sets of parameters;

instantiate a new query based on the query temple which includes the corresponding sets of parameters substituted for the one or more bind variables and injecting the new query into a CEP server;

based on the new query, build a query execution plan;

adding the query execution plan to a runtime environment as a continuous query; and

execute the continuous query to process the event stream.

10. The system for providing parameterized queries in CEP as in claim 9, wherein the sets of instructions when further executed by the processor, cause the processor to:

generate the query; and

process the event stream.

11. The system for providing parameterized queries in CEP as in claim 10, further comprising:

a CEP server including a Continuous Query Language (“

CQL”

) engine, wherein the CQL engine instantiates a plurality of CEP applications; and

a visualizer in communication with the CEP server, wherein the visualizer is configured to display result information from the processed event stream.

12. A non-transitory computer-readable medium having sets of instructions stored thereon which, when executed by a computer, cause the computer to:

provide a query template which includes one or more bind variables, wherein the one or more bind variables are typeless within the CEP environment;

provide sets of parameters corresponding to the one or more bind variables;

parse the query template to determine positions of the one or more bind variables;

scan the provided sets of parameters to determine which of the sets of parameters are to be bound to the one or more bind variables;

bind the one or more bind variables which are determined to be bound to the corresponding sets of parameters;

insert arbitrary predicates into the query template, based on the one or more bind variables being typeless;

substitute the bound one or more bind variables with the corresponding sets of parameters;

based on the sets of parameters, generate a single parameterized query which is a template that provides possible values for the bound one of more bind variables;

determine a placeholder occurring in the single parameterized query for processing an event stream;

based on the single parameterized query, generate multiple customized queries and views which differ by at least only one variable, wherein the multiple customized queries and views are maintained by substituting the placeholder at runtime with parameters from the sets of parameters;

instantiate a new query based on the query temple which includes the corresponding sets of parameters substituted for the one or more bind variables and injecting the new query into a CEP server;

based on the new query, build a query execution plan;

adding the query execution plan to a runtime environment as a continuous query; and

execute the continuous query to process the event stream.

13. The non-transitory computer-readable medium of claim 12, wherein the sets of instructions when further executed by the computer, cause the computer to determine that new sets of parameters are specified for binding.

14. The non-transitory computer-readable medium of claim 13, wherein the sets of instructions when further executed by the computer, cause the computer to:

identify queries which have been instantiated using sets of parameters prior to being specified with new sets of parameters; and

delete the queries which have been instantiated using sets of parameters prior to being specified with new sets of parameters.

15. The non-transitory computer-readable medium of claim 14, wherein the sets of instructions when further executed by the computer, cause the computer to instantiate queries using the new sets of parameters for the runtime system.

16. The non-transitory computer-readable medium of claim 12, wherein the sets of instructions when further executed by the computer, cause the computer to:

convert the sets of parameters into strings;

check the strings of the sets of parameters to determine a form of the sets of parameters;

compare the determined form of the sets of parameters with a form of the corresponding bind variables; and

in response to the determined type of the sets of parameters matching the type of the corresponding bind variables, verify the sets of parameters.

17. The non-transitory computer-readable medium of claim 16, wherein the type of the corresponding bind variables and sets of parameters includes at least one or more of the following:

INT, FLOAT, LONG, BIGDECIMAL, DOUBLE, or STRING.