HIGH PERFORMANCE REAL-TIME RELATIONAL DATABASE SYSTEM AND METHODS FOR USING SAME

• US 20160314166A1
• Filed: 07/05/2016
• Published: 10/27/2016
• Est. Priority Date: 08/13/2012
• Status: Active Grant

• Current Assignee: Teletech Holdings Incorporated
• Original Assignee: Aria Solutions Inc. (TTEC Holdings, Inc.)
• Inventors: Peloski, Paul
• Granted Patent: US 9,785,668 B2
• Time in Patent Office: Days
• US Class Current: 1/1
• CPC Class Codes: G06F 16/2246 Trees, e.g. B+trees
• CPC Class Codes: G06F 16/2393 Updating materialised views
• CPC Class Codes: G06F 16/245 Query processing
• CPC Class Codes: G06F 16/24561 Intermediate data storage techniques for performance improvement
• CPC Class Codes: G06F 30/20 Design optimisation, verification or simulation optimisation, verification or simulation of circuit designs G06F30/30

Abstract

A database system supporting persistent queries, using a persistent query service and various data sources. On receiving a request to create a persistent query from a client software application, the persistent query service: creates a query virtual table; parses the persistent query; creates a plurality of intermediate virtual tables; establishes listeners for the query virtual table; creates a plurality of data source virtual tables; causes the plurality of data source virtual tables to retrieve initial data from data sources; and propagates data via intermediate virtual tables to the persistent query virtual table. On detection of a data change in a data source, the associated data source virtual table causes the data change to propagate via intermediate virtual tables to the persistent query virtual table, and the client software application executes client code of at least one listener.

Claims

1. A database system supporting persistent queries, the system comprising:

a persistent query service stored and operating on a network-attached computer adapted to receive connections and requests from client software applications; and

a plurality of network-attached data sources;

wherein, on receiving a request to create a persistent query from a client software application, the persistent query service;

creates a query virtual table corresponding to the persistent query;

creates a tree structure representing a logical arrangement of a plurality of operators that yield results required by the persistent query;

creates a plurality of intermediate virtual tables corresponding to the plurality of operators, wherein the step of creating an intermediate virtual table further comprises establishing listeners associated with the intermediate virtual table to receive data change notifications;

establishes listeners for the query virtual table to receive data change notifications from a plurality of intermediate virtual tables;

causes the plurality of data source virtual tables to retrieve initial data from the plurality of data sources; and

propagates data via the plurality of intermediate virtual tables and their associated listeners to the persistent query virtual table; and

wherein, on detection of a data change in a data source, a plurality of corresponding methods of listeners of a plurality of virtual intermediate tables are invoked, and the data change is propagated via the plurality of intermediate virtual tables and their associated listeners to the persistent query virtual table.

2. The system of claim 1, wherein at least one intermediate virtual table is a projection table.

3. The system of claim 1, wherein at least one intermediate virtual table is a group-by table.

4. The system of claim 1, wherein at least one intermediate virtual table is an inner join table.

5. The system of claim 1, wherein at least one intermediate virtual table is a filter table.

6. The system of claim 1, wherein the plurality of corresponding methods is drawn from the set of RowAdded, RowDeleted, and RowChanged methods.

7. The system of claim 1, wherein the persistent query service is stored and operable on a cloud platform computer accessible from mobile client devices.

8. A method for creating and using persistent queries in a database system, the method comprising the steps of:

(a) creating at a persistent query service stored and operating on a network-attached computer, via a request delivered across the network from a software application executing on a computer, a persistent query, wherein the step of creating the persistent query further comprises establishing listeners with client code to receive notifications from the persistent query;

(b) parsing the persistent query to create a tree structure representing a logical arrangement of a plurality of operators that yield results required by the persistent query;

(c) creating a plurality of intermediate virtual tables corresponding to the plurality of operators;

wherein the step of creating an intermediate virtual table further comprises establishing listeners associated with the intermediate virtual table to receive data change notifications;

(d) establishing listeners for the query virtual table to receive data change notifications from a plurality of intermediate virtual tables;

(e) retrieving, by the plurality of data source virtual tables, initial data from the plurality of data sources;

(f) invoking row added methods of a plurality of intermediate virtual tables;

(g) propagating data via the plurality of intermediate virtual tables and their associated listeners to the persistent query virtual table;

(h) on detection of a data change in a data source, invoking corresponding methods of listeners of a plurality of virtual intermediate tables;

(i) propagating the data change via the plurality of intermediate virtual tables and their associated listeners to the persistent query virtual table; and

(j) executing the client code of each affected listener in the query virtual table.

9. The method of claim 8, wherein at least one intermediate virtual table is a projection table.

10. The method of claim 8, wherein at least one intermediate virtual table is a group-by table.

11. The method of claim 8, wherein at least one intermediate virtual table is an inner join table.

12. The method of claim 8, wherein at least one intermediate virtual table is a filter table.

13. The method of claim 8, wherein the plurality of corresponding methods is drawn from the set of RowAdded, RowDeleted, and RowChanged methods.

14. The method of claim 8, wherein the persistent query service is stored and operable on a cloud platform computer accessible from mobile client devices.