System and method for processing integrated queries against input data stream and data stored in database using trigger

• US 20070136254A1
• Filed: 11/08/2006
• Published: 06/14/2007
• Est. Priority Date: 12/08/2005
• Status: Abandoned Application

• Current Assignee: Electronics and Telecommunications Research Institute
• Original Assignee: Electronics and Telecommunications Research Institute
• Inventors: Kim, Myung-Joon, Lee, Mi-Young, Lee, Myung-Cheol, Choi, Hyun-Hwa
• Application Number:
  US11/594,641
• Publication Number:
  US 20070136254A1
• Time in Patent Office: Days
• US Class Current: 1/1
• CPC Class Codes: G06F 16/24568 Data stream processing; Continuous queries
• CPC Class Codes: G06F 16/80 of semi-structured data, e.g. markup language structured data such as SGML, XML or HTML content-based retrieval of web data G06F16/95

Abstract

Provided are a system and a method for processing integrated queries against an input data stream and data stored in a database using trigger. The system for processing an integrated query against an input data stream and data stored in a database using a trigger, including: a data stream manager for managing a continuously inputted data stream; a trigger result manager for registering a trigger in a database which interworks with the trigger result manager and forming a set of results that are obtained by executing the registered trigger to thereby provide the set of results in real time; and an executer for processing an integrated query against the data stream from the data stream manager and data stored in the database, wherein the integrated query is processed by referring to the set of results from the trigger result manager for the data stored in the database.

Claims

1. A system for processing an integrated query against an input data stream and data stored in a database using a trigger, comprising:

a data stream managing means for managing a continuously inputted data stream;

a trigger result managing means for registering a trigger in a database which interworks with the trigger result managing means and forming a set of results that are obtained by executing the registered trigger to thereby provide the set of results in real time; and

an execution means for processing an integrated query against the data stream from the data stream managing means and data stored in the database, wherein the integrated query is processed by referring to the set of results from the trigger result managing means for the data stored in the database.

2. The system as recited in claim 1, wherein the data stream managing means manages a continuously inputted extensible Markup Language (XML) data stream, and

the trigger result managing means registers a search XQuery trigger in one or more XML databases and forms a set of results that are obtained by executing the registered search XQuery trigger to provide the set of results in real time.

3. The system as recited in claim 1, wherein the trigger result managing means forms a set of results of trigger automatically executed when a change happens in the database.

4. The system as recited in claim 3, wherein the trigger result managing means manages information associated with the result of executing the query of the trigger, the total number of users, and lock as the set of results.

5. The system as recited in claim 4, wherein the trigger result managing means, upon request for creation of a trigger, increases the total number of users of the trigger by 1 when the trigger to be created already exists, and returns a name of the trigger.

6. The system as recited in claim 4, wherein the trigger result managing means, upon request for deletion of a trigger, decreases the total number of users of the trigger to be deleted by 1 when the total number is greater than 1.

7. The system as recited in claim 4, wherein the trigger result managing means performs an operation of the set of results of trigger by using a lock technique which performs the operation after acquisition of lock and release the lock after completion of the operation.

8. The system as recited in claim 3, wherein the trigger result managing means manages a list of the set of results to be corresponded to each of the one or more databases in a one-to-one way.

9. The system as recited in claim 3, wherein the execution means processes an integrated query against the data stream from the data stream managing means and processes against data stored in the database to provide the result to outside by using an XQuery trigger.

10. A method for processing an integrated query against an input data stream and data stored in a database using a trigger, comprising the steps of:

a) registering an integrated query;

b) registering a trigger for data stored in a database;

c) forming a set of results of the trigger automatically executed when a change happens in the database in real time;

d) receiving a continuously inputted data stream; and

e) processing the integrated query against the data stream and the data stored in the database, wherein the integrated query is executed by referring to the formed set of results for the data stored in the database.

11. The method as recited in claim 10, wherein in the step e), an integrated query is processed against a continuously inputted XML data stream and is processed against data stored in an XML databases by using an XQuery trigger.

12. The method as recited in claim 10, wherein an integrated continuous query is registered in the step a) by using an XQuery trigger.

13. The method as recited in claim 12, wherein the step a) includes the steps of:

a1) parsing a continuous query;

a2) confirming a validity for the parsed continuous query;

a3) confirming whether the continuous query is an integrated continuous query or not;

a4) dividing the integrated continuous query to form a separate query against the data stored in the database;

a5) creating a trigger and registering the trigger in the database when the formed separate query is executable through a trigger;

a6) executing the trigger to form a set of results of the trigger; and

a7) storing information on the relationship between the trigger and trigger result set and the continuous query.

14. The method as recited in claim 13, wherein the separate query is formed based on an XQuery syntax in the step a4).

15. The method as recited in claim 13, wherein in the step a5), the formed separate query is judged to be a query executable through the trigger when the separate query does not contain a value changed in real time.

16. The method as recited in claim 12, wherein in the step a6), information associated with the result of executing the query of the trigger, the total number of users, and a lock as the set of results is formed.

17. The method as recited in claim 16, wherein in the step b), upon request for creation of a trigger, the total number of users of the trigger is increased by 1 when the trigger to be created already exists.

18. The method as recited in claim 16, wherein in the step b), upon request for deletion of a trigger, the total number of users of the trigger to be deleted is decreased by 1 when the total number is greater than 1.