Standardized database connectivity support for an event processing server
First Claim
Patent Images
1. A method for facilitating communication between a client application configured to run on a first system and an event processing server configured to run on a second system, the method comprising:
- running, on the first system, a database connectivity adapter implementing a database connectivity Application Programming Interface (API), wherein the database connectivity adapter is configured to facilitate 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;
converting the query language statement into a data representation native to the event processing server; and
invoking a procedure native to the event processing server and exposed by the event processing server based on the data representation;
wherein, in converting the query language statement into the data representation native to the event processing server, the database connectivity adapter determines whether a timestamp is specified by the query language statement and performs an action selected from a set of actions based on whether a timestamp is specified in the query language statement;
wherein the set of actions consists of (a) generating a timestamp that is not specified by the query language statement and adding the timestamp to the data representation native to the event processing server and (b) adding, to the data representation native to the event processing server, a timestamp that is specified by the query language statement;
wherein invoking the procedure native to the event processing server causes the event processing server to insert, into an unbounded sequence of events that are ordered by time, a tuple specified within the data representation native to the event processing server.
1 Assignment
0 Petitions
Accused Products
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).
-
Citations
14 Claims
-
1. A method for facilitating communication between a client application configured to run on a first system and an event processing server configured to run on a second system, the method comprising:
running, on the first system, a database connectivity adapter implementing a database connectivity Application Programming Interface (API), wherein the database connectivity adapter is configured to facilitate 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; converting the query language statement into a data representation native to the event processing server; and invoking a procedure native to the event processing server and exposed by the event processing server based on the data representation; wherein, in converting the query language statement into the data representation native to the event processing server, the database connectivity adapter determines whether a timestamp is specified by the query language statement and performs an action selected from a set of actions based on whether a timestamp is specified in the query language statement; wherein the set of actions consists of (a) generating a timestamp that is not specified by the query language statement and adding the timestamp to the data representation native to the event processing server and (b) adding, to the data representation native to the event processing server, a timestamp that is specified by the query language statement; wherein invoking the procedure native to the event processing server causes the event processing server to insert, into an unbounded sequence of events that are ordered by time, a tuple specified within the data representation native to the event processing server. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12)
-
13. A system comprising:
-
a processing device configured to; run a client application adapted to interact with an event processing server configured to run on a remote system; and run a database connectivity adapter implementing a database connectivity API, wherein the database connectivity adapter is configured to facilitate 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; converting the query language statement into a data representation native to the event processing server; and invoking a procedure native to the event processing server and exposed by the event processing server based on the data representation; wherein, in converting the query language statement into the data representation native to the event processing server, the database connectivity adapter determines whether a timestamp is specified by the query language statement and performs an action selected from a set of actions based on whether a timestamp is specified in the query language statement; wherein the set of actions consists of (a) generating a timestamp that is not specified by the query language statement and adding the timestamp to the data representation native to the event processing server and (b) adding, to the data representation native to the event processing server, a timestamp that is specified by the query language statement; wherein invoking the procedure native to the event processing server causes the event processing server to insert, into an unbounded sequence of events that are ordered by time, a tuple specified within the data representation native to the event processing server.
-
-
14. A non-transitory machine-readable medium having stored thereon program code which, when executed by a processing device of a computer system, causes the processing device to facilitate communication between a client application configured to run on a first system and an event processing server configured to run on a second system, the program code comprising:
-
code for a database connectivity adapter configured to run on the first system, wherein the database connectivity adapter implements a database connectivity API, and wherein the database connectivity adapter is configured to facilitate 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; converting the query language statement into a data representation native to the event processing server; and invoking a procedure native to the event processing server and exposed by the event processing server-based on the data representation; wherein, in converting the query language statement into the data representation native to the event processing server, the database connectivity adapter determines whether a timestamp is specified by the query language statement and performs an action selected from a set of actions based on whether a timestamp is specified in the query language statement; wherein the set of actions consists of (a) generating a timestamp that is not specified by the query language statement and adding the timestamp to the data representation native to the event processing server and (b) adding, to the data representation native to the event processing server, a timestamp that is specified by the query language statement; wherein invoking the procedure native to the event processing server causes the event processing server to insert, into an unbounded sequence of events that are ordered by time, a tuple specified within the data representation native to the event processing server.
-
Specification