Support for a parameterized query/view in complex event processing

• US 9,110,945 B2
• Filed: 11/12/2013
• Issued: 08/18/2015
• 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, Castro Alves, Alexandre de, Hsiao, Eric
• Primary Examiner(s): Fan, Shiow-Jy
• Application Number:
  US14/077,230
• Publication Number:
  US 20140136514A1
• Time in Patent Office: 644 Days
• Field of Search: 707/758, 707/769, 707/779, 707/E17.014
• US Class Current: 1/1
• 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 one or more 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;

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

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;

substituting the placeholder at runtime with parameter values corresponding to the sets of parameters;

generating multiple customized queries and views which differ by at least only one variable based on the substituting;

instantiating a new query for each of the sets of parameters which correspond to the same bind variable 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 one or more of the following:

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

8. 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 one or more 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;

determine that the sets of parameters correspond to the same bind variable;

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;

substitute the placeholder at runtime with parameter values corresponding to the sets of parameters;

generate multiple customized queries and views which differ by at least only one variable based on the substituting;

instantiate a new query for each of the sets of parameters which correspond to the same bind variable as a continuous query; and

execute the continuous query to process the event stream.

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

generate the query; and

process the event stream.

10. The system for providing parameterized queries in CEP as in claim 9, 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.

11. A non-transitory computer-readable medium having sets of instructions stored for providing parameterized queries in complex event processing (CEP), 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, wherein the one or more bind variables are typeless within the CEP environment;

parse the query template to determine positions of 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 one or more 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;

determine that the sets of parameters correspond to the same bind variable;

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;

substitute the placeholder at runtime with parameter values corresponding to the sets of parameters;

generate multiple customized queries and views which differ by at least only one variable based on the substituting;

instantiate a new query for each of the sets of parameters which correspond to the same bind variable as a continuous query; and

execute the continuous query to process the event stream.

12. The non-transitory computer-readable medium of claim 11, 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.

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:

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.

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 instantiate queries using the new sets of parameters for the runtime system.

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

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

17. The non-transitory computer-readable medium of claim 11, wherein the sets of instructions when further executed by the computer, cause the computer to 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.

18. The non-transitory computer-readable medium of claim 11, wherein the sets of instructions when further executed by the computer, cause the computer to 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.

19. The non-transitory computer-readable medium of claim 18, wherein the sets of instructions when further executed by the computer, cause the computer to, based on the new query, build a query execution plan;

adding the query execution plan to a runtime environment as a continuous query.