SUPPORT FOR A PARAMETERIZED QUERY/VIEW IN COMPLEX EVENT PROCESSING

• US 20120072455A1
• Filed: 07/28/2011
• Published: 03/22/2012
• Est. Priority Date: 09/17/2010
• Status: Active Grant

• Current Assignee: Oracle International Corporation (Oracle Corporation)
• Original Assignee: Oracle International Corporation (Oracle Corporation)
• Inventors: Shukla, Vikram, Srinivasan, Anand, de Castro Alves, Alexandre, Hsiao, Eric, Jain, Parul
• Granted Patent: US 8,713,049 B2
• Time in Patent Office: Days
• 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), the method comprising:

providing a query template which includes one or more bind variables;

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 sets of parameters; and

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

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 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 instantiating a new query based on the query temple which includes the sets of parameters substituted for the one or more bind variables.

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

instantiating the new query; and

injecting the new query into a CEP server.

10. The method of providing parameterized queries in CEP as in claim 9, further comprising:

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.

11. 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.

12. 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;

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

determine a parameter for the placeholder; and

generate a query from the parameterized query by substituting the placeholder with the parameter.

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

generate the query; and

process the event stream.

14. The system for providing parameterized queries in CEP as in claim 13, further comprising:

a CEP server including a 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.

15. A 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;

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 sets of parameters; and

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

16. The computer-readable medium of claim 15, 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.

17. The computer-readable medium of claim 16, 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.

18. The computer-readable medium of claim 17, 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.

19. The computer-readable medium of claim 15, 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 type of the sets of parameters with the type 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.

20. The computer-readable medium of claim 19, wherein the type of the corresponding bind variables and sets of parameters includes one or more of the following:

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