Standardized database connectivity support for an event processing server in an embedded context

• US 8,321,450 B2
• Filed: 07/21/2009
• Issued: 11/27/2012
• Est. Priority Date: 07/21/2009
• Status: Active Grant

• Current Assignee: Oracle International Corporation (Oracle Corporation)
• Original Assignee: Oracle International Corporation (Oracle Corporation)
• Inventors: Thatte, Mohit, Bishnoi, Sandeep, Jain, Namit, Srinivasan, Anand, Mishra, Shailendra
• Primary Examiner(s): GIRMA, ANTENEH B
• Application Number:
  US12/506,891
• Publication Number:
  US 20110022618A1
• Time in Patent Office: 1,225 Days
• Field of Search: 719/328
• US Class Current: 707/769
• CPC Class Codes: G06F 16/24568 Data stream processing; Continuous queries
• CPC Class Codes: G06F 9/541 via adapters, e.g. between incompatible applications
• CPC Class Codes: H04L 69/00 Network arrangements, protocols or services independent of the application payload and not provided for in the other groups of this subclass networks security protocols H04L9/40; wireless communication networks H04W

Abstract

Techniques for facilitating communication between one or more client applications and an event processing server. In one set of embodiments, a framework is provided that enables a client application to communicate with an event processing server via a standard database connectivity API, such as Java Database Connectivity (JDBC).

Claims

1. A method for facilitating communication between a client application and an event processing server configured to run as part of a single computer process, the method comprising:

running, as part of the single computer process, a database connectivity adapter implementing a database connectivity API, wherein the database connectivity adapter is configured to facilitate intra-process communication between the client application and the event processing server via the database connectivity API by;

receiving, in response to an invocation of the database connectivity API by the client application, a query language statement to be executed by the event processing server;

parsing the query language statement to determine a type of the statement;

processing the query language statement based on its type; and

invoking a procedure of the event processing server for executing the query language statement by (1) the database connectivity adapter obtaining a reference to a local object instantiated by the event processing server within the same single computer process as the database connectivity adapter and (2) the database connectivity adapter invoking a method of the local object, the invocation of the method of the local object causing execution of the query language statement.

2. The method of claim 1 wherein the database connectivity API is Java Database Connectivity (JDBC).

3. The method of claim 1 wherein the query language statement is an Continuous Query Language (CQL) statement.

4. The method of claim 3 wherein the query language statement is a CQL statement for creating an event stream, a CQL statement for selecting data from an event stream, or a CQL statement for inserting data into an event stream.

5. The method of claim 1 wherein parsing the query language statement to determine a type of the statement comprises determining whether the query language statement is a data modification language (DML) statement.

6. The method of claim 5 wherein if the query language statement is a DML statement, processing the query language statement based on its type comprises:

converting one or more data values included in the query language statement into a data representation native to the event processing server.

7. The method of claim 6 wherein converting one or more data values included in the query language statement into a data representation native to the event processing server comprises:

determining attribute datatypes for an event stream being modified by the query language statement;

comparing the attribute datatypes to datatypes of the one or more data values; and

if the attribute datatypes and the datatypes of the one or more data values are different but compatible, converting the datatypes of the one or more data values into the attribute datatypes.

8. The method of claim 6 wherein if the query language statement is a DML statement, invoking a procedure of the event processing server for executing the query language statement comprises:

invoking a procedure of the event processing server for executing DML statements, wherein the procedure takes as an input parameter the data representation of the one or more data values native to the event processing server.

9. The method of claim 1 wherein parsing the query language statement to determine a type of the statement comprises determining whether the query language statement is a data definition language (DDL) statement.

10. The method of claim 9 wherein if the query language statement is a DDL statement, invoking a procedure of the event processing server for executing the query language statement comprises:

invoking a procedure of the event processing server for executing DDL statements, wherein the procedure takes as an input parameter the query language statement.

11. The method of claim 10 wherein the procedure of the event processing server for executing DDL statements is configured to:

parse the query language statement to determine a DDL type of the query language statement;

based on the parsing, perform one or more validations with respect to the query language statement; and

invoke another procedure of the event processing server to execute the query language statement.

12. The method of claim 1 wherein the client application is a data source configured to generate an event stream.

13. The method of claim 1 wherein the client application is a data integrator configured to aggregate event streams from a plurality of different data sources.

14. A system comprising:

a storage component configured to store data for one or more event streams; and

a processing component communicatively coupled with the storage component, the processing component being configured to;

run a client application, a database connectivity adapter, and an event processing server as part of a single computer process, wherein the database connectivity adapter implements a database connectivity API, and wherein the database connectivity adapter is configured to facilitate intra-process communication between the client application and the event processing server via the database connectivity API by;

receiving, in response to an invocation of the database connectivity API by the client application, a query language statement to be executed by the event processing server;

parsing the query language statement to determine a type of the statement;

processing the query language statement based on its type; and

invoking a procedure of the event processing server for executing the query language statement by (1) the database connectivity adapter obtaining a reference to a local object instantiated by the event processing server within the same single computer process as the database connectivity adapter and (2) the database connectivity adapter invoking a method of the local object, the invocation of the method of the local object causing execution of the query language statement.

15. A non-transitory machine-readable medium having stored thereon program code which, when executed by a processing component of a computer system, causes the processing component to facilitate communication between a client application and an event processing server configured to run as part of a single computer process, the program code comprising:

code for a database connectivity adapter configured to run as part of the single computer process, wherein the code for the database connectivity adapter comprises one or more code modules implementing a database connectivity API, and wherein the database connectivity adapter is configured to facilitate intra-process communication between the client application and the event processing server via the database connectivity API by;

receiving, in response to an invocation of the standard database connectivity API by the client application, a query language statement to be executed by the event processing server;

parsing the query language statement to determine a type of the statement;

processing the query language statement based on its type; and

invoking a procedure of the event processing server for executing the query language statement by (1) the database connectivity adapter obtaining a reference to a local object instantiated by the event processing server within the same single computer process as the database connectivity adapter and (2) the database connectivity adapter invoking a method of the local object, the invocation of the method of the local object causing execution of the query language statement.