SYSTEM AND METHOD FOR PROCESSING CONTINUOUS INTEGRATED QUERIES ON BOTH DATA STREAM AND STORED DATA USING USER-DEFINED SHARE TRIGGER

• US 20080046401A1
• Filed: 08/14/2007
• Published: 02/21/2008
• Est. Priority Date: 08/21/2006
• Status: Active Grant

• Current Assignee: Electronics and Telecommunications Research Institute
• Original Assignee: Electronics and Telecommunications Research Institute
• Inventors: LEE, Myung-Cheol, CHOI, Hyun-Hwa, LEE, Mi-Young, KIM, Myung-Joon
• Granted Patent: US 7,860,884 B2
• Time in Patent Office: Days
• US Class Current: 707/2
• CPC Class Codes: G06F 16/24568 Data stream processing; Continuous queries

Abstract

Provided are a system and method for processing continuous integrated queries on both data stream and stored data using user-defined shared trigger. The system includes a data stream manager for managing data stream inputted from outside; a continuous integrated queries manager for managing the continuous integrated queries inputted from an external application; a trigger manager for managing the user-defined shared trigger inputted from the external application and registering the user-defined shared trigger in an external database; a trigger result manager for forming and managing a trigger result set from a performance result of the user-defined shared trigger registered in the cooperation database; and a continuous integrated queries performer for processing the continuous integrated queries referring to the transmitted data stream and trigger result set.

Claims

1. A system for processing continuous integrated queries on both data stream and stored data using a user-defined shared trigger, comprising:

a data stream managing means for managing data stream inputted from outside;

a continuous integrated queries managing means for managing the continuous integrated queries inputted from an external application;

a trigger managing means for managing the user-defined shared trigger inputted from the external application and registering the user-defined shared trigger in an external database;

a trigger result managing means for forming and managing a trigger result set from a performance result of the user-defined shared trigger registered in the cooperation database; and

a continuous integrated queries performing means for processing the continuous integrated queries referring to the transmitted data stream and trigger result set.

2. The system as recited in claim 1, wherein when the continuous integrated queries performing means processes the transmitted data stream and the continuous integrated queries on storage data of the cooperation database, the continuous integrated queries performing means processes the continuous integrated queries referring to a pre-processed trigger result set with respect to the storage data of the cooperation database.

3. The system as recited in claim 1, wherein the trigger result managing means receives a performance result of the automatically performed registered user-defined shared trigger from the cooperation database whenever each of storage data of the database is changed, and forms and manages the trigger result set.

4. The system as recited in claim 3, wherein the trigger result managing means manages information related to a trigger sentence performance result set of the user-defined shared trigger, the total number of users, and a lock required for referring to/changing the trigger result set.

5. The system as recited in claim 4, wherein the trigger result managing means uses a lock technique when an operation on a result set of the user-defined shared trigger is performed, performs an operation when the lock is acquired, and releases the lock after the operation is completely performed.

6. The system as recited in claim 3, wherein when the trigger managing means provides functions of registering and deleting the user-defined shared trigger, the trigger managing means performs syntax analyzing and justification checking processes on a user-defined shared trigger sentence in registering of the user-defined shared trigger, builds an environment for the continuous integrated queries performing means according to creation of the user-defined shared trigger, checks whether the continuous integrated queries using the user-defined shared trigger exist when the user-defined shared trigger is deleted, and performs a deleting function according to the result.

7. The system as recited in claim 6, wherein when the user-defined shared trigger is requested to be deleted, the trigger managing means deletes the user-defined shared trigger in case that the number of the continuous integrated queries referring to the user-defined shared trigger to be deleted is smaller than or the same as 0, determines a value of a cascade option to determine intention of the user in case that the number of continuous integrated queries referring to the user-defined shared trigger to be deleted is larger than 0, deletes all continuous integrated queries referring to the corresponding user-defined shared trigger and user-defined shared trigger in case that the cascade option is true, and ends the continuous integrated queries referring to the corresponding user-defined shared trigger and user-defined shared trigger without deleting in case that the cascade option is false.

8. The system as recited in claim 3, wherein when the continuous integrated queries managing means provides functions of registering and deleting the continuous integrated queries, the continuous integrated queries managing means performs a syntax analyzing function and a justification checking function on the continuous integrated queries in registering of the continuous integrated queries, increases the total number of users of the user-defined shared trigger by 1 as the continuous integrated queries refer to the user-defined shared trigger, and decreases the total number of users of the user-defined shared trigger referred to in the continuous integrated queries in deleting of the continuous integrated queries.

9. A method for processing continuous integrated queries on both data stream and stored data using user-defined shared trigger in a continuous integrated queries process system, comprising the steps of:

registering a user-defined shared trigger;

registering continuous integrated queries referring to the registered user-defined shared trigger;

forming and managing a trigger result set as a performance result of the registered user-defined shared trigger;

receiving a data stream; and

processing the continuous integrated queries by referring to the received data stream and the formed trigger result set.

10. The method as recited in claim 9, further comprising the step of:

checking whether continuous integrated queries using the user-defined shared trigger exist upon a deletion request of the registered user-defined shared trigger and performing a deleting function according to a result.

11. The method as recited in claim 10, further comprising the step of:

checking whether user-defined shared triggers referred to the continuous integrated queries exist upon deletion request of the registered continuous integrated queries and performing a deleting function according to the result.

12. The method as recited in claim 9, wherein when the continuous integrated queries on storage data and the inputted data stream are processed in the step of processing the continuous integrated queries, the continuous integrated queries are processed with respect to the storage data referring to the trigger result set of the pre-processed step of forming and managing a trigger result set.

13. The method as recited in claim 12, wherein in the step of forming and managing a trigger result set, a trigger result set is formed and managed as a performance result of the registered user-defined shared trigger, which is automatically performed whenever each of storage data is changed.

14. The method as recited in claim 13, wherein the step of registering the user-defined shared trigger includes the steps of:

analyzing a syntax of the user-defined shared trigger sentence;

checking justification of the syntax analyzed user-defined shared trigger sentence;

registering the user-defined shared trigger whose justification is checked in a cooperation database;

forming an initial trigger result set as a result performed by being extracted from the registered user-defined shared trigger; and

storing metadata related to the user-defined shared trigger.

15. The method as recited in claim 13, wherein the step of registering continuous integrated queries includes the steps of:

analyzing a syntax of the continuous integrated queries sentence;

checking justification of the syntax analyzed continuous integrated queries;

checking whether continuous integrated queries whose justification is checked refer to the user-defined shared trigger;

increasing the total number of users of the user-defined shared trigger that is referred to by the checked continuous integrated queries; and

storing metadata related to the continuous integrated queries.