| 1 |
1
사용자 정의 공유 트리거를 이용한 데이터 스트림과 저장 데이터의 통합 연속 질의 처리 시스템에 있어서,외부로부터 입력되는 데이터 스트림을 관리하기 위한 데이터 스트림 관리 수단;외부 애플리케이션으로부터 입력되는 통합 연속 질의를 관리하기 위한 통합 연속 질의 관리 수단;상기 애플리케이션으로부터 입력되는 사용자 정의 공유 트리거를 관리하고 외부의 연동 데이터베이스에 등록하기 위한 트리거 관리 수단;상기 연동 데이터베이스에 등록된 사용자 정의 공유 트리거의 수행 결과로부터 트리거 결과 집합을 구성하여 관리하기 위한 트리거 결과 관리 수단; 및상기 데이터 스트림 관리 수단으로부터 전달받은 데이터 스트림과 상기 트리거 결과 관리 수단으로부터 전달받은 트리거 결과 집합을 참조하여 통합 연속 질의를 처리하기 위한 통합 연속 질의 실행 수단을 포함하는 사용자 정의 공유 트리거를 이용한 데이터 스트림과 저장 데이터의 통합 연속 질의 처리 시스템
|
| 2 |
2
제 1 항에 있어서,상기 통합 연속 질의 실행 수단은,상기 데이터 스트림 관리 수단으로부터 전달받은 데이터 스트림과 상기 연동 데이터베이스의 저장 데이터에 대한 통합 연속 질의를 처리하되, 상기 연동 데이터베이스의 저장 데이터에 대해서는 상기 트리거 결과 관리 수단으로부터 전달받은 기 처리 완료된 트리거 결과 집합을 참조하여 통합 연속 질의를 처리하는 것을 특징으로 하는 사용자 정의 공유 트리거를 이용한 데이터 스트림과 저장 데이터에 대한 통합 연속 질의 처리 시스템
|
| 3 |
3
제 1 항 또는 제 2 항에 있어서,상기 트리거 결과 관리 수단은,상기 연동 데이터베이스의 각 저장 데이터에 대한 변경이 발생할 때마다 자동으로 수행되는 상기 등록된 사용자 정의 공유 트리거의 수행 결과를 상기 연동 데이터베이스로부터 전달받아 트리거 결과 집합을 구성하여 관리하는 것을 특징으로 하는 사용자 정의 공유 트리거를 이용한 데이터 스트림과 저장 데이터에 대한 통합 연속 질의 처리 시스템
|
| 4 |
4
제 3 항에 있어서,상기 트리거 결과 관리 수단은,사용자 정의 공유 트리거의 트리거문 수행 결과 집합, 총 사용자 수, 및 트리거 결과 집합의 참조/변경 시에 필요한 잠금에 관련된 정보를 트리거 결과 집합으로 관리하는 것을 특징으로 하는 사용자 정의 공유 트리거를 이용한 데이터 스트림과 저장 데이터의 통합 연속 질의 처리 시스템
|
| 5 |
5
제 4 항에 있어서,상기 트리거 결과 관리 수단은,사용자 정의 공유 트리거의 결과 집합에 대한 연산 수행 시 잠금 기법을 사용하되, 잠금을 획득한 후에 연산을 수행하고 연산이 완료된 후에는 잠금을 해제하는 것을 특징으로 하는 사용자 정의 공유 트리거를 이용한 데이터 스트림과 저장 데이터의 통합 연속 질의 처리 시스템
|
| 6 |
6
제 3 항에 있어서,상기 트리거 관리 수단은,사용자 정의 공유 트리거의 등록 및 삭제 기능을 제공하되,사용자 정의 공유 트리거의 등록 시에 사용자 정의 공유 트리거문의 구문 분석 및 정당성 검사를 수행하고, 사용자 정의 공유 트리거의 생성(등록)에 따라 상기 통합 연속 질의 실행 수단을 위한 환경을 구축하며,사용자 정의 공유 트리거의 삭제 시에 사용자 정의 공유 트리거를 사용하는 통합 연속 질의의 존재 여부를 검사하여 그 결과에 따라 삭제 기능을 수행하는 것을 특징으로 하는 사용자 정의 공유 트리거를 이용한 데이터 스트림과 저장 데이터의 통합 연속 질의 처리 시스템
|
| 7 |
7
제 6 항에 있어서,상기 트리거 관리 수단은,사용자 정의 공유 트리거의 삭제 요청 시 삭제하고자 하는 사용자 정의 공유 트리거를 참조하는 통합 연속 질의의 수가 0보다 작거나 같은 경우에는 바로 해당 사용자 정의 공유 트리거를 삭제하고, 0보다 큰 경우에는 사용자의 의도를 판단하기 위해 캐스케이드(cascade) 옵션의 값을 판단하여, 캐스케이드(cascade) 옵션이 트루(true)이면 해당하는 사용자 정의 공유 트리거 및 해당 사용자 정의 공유 트리거를 참조하는 통합 연속 질의를 모두 삭제하고, 캐스케이드(cascade) 옵션이 폴스(false)이면 해당하는 사용자 정의 공유 트리거 및 해당 사용자 정의 공유 트리거를 참조하는 통합 연속 질의를 삭제하지 않고 종료하는 것을 특징으로 하는 사용자 정의 공유 트리거를 이용한 데이터 스트림과 저장 데이터의 통합 연속 질의 처리 시스템
|
| 8 |
8
제 3 항에 있어서,상기 통합 연속 질의 관리 수단은,통합 연속 질의의 등록 및 삭제 기능을 제공하되,통합 연속 질의의 등록 시에 통합 연속 질의에 대한 구문 분석 및 정당성 검사를 수행하고, 해당 통합 연속 질의가 사용자 정의 공유 트리거를 참조함에 따라 해당 사용자 정의 공유 트리거의 총 사용자 수를 1 증대시키며,통합 연속 질의의 삭제 시에 해당 통합 연속 질의에서 참조하는 사용자 정의 공유 트리거의 총 사용자 수를 1 감소시키는 것을 특징으로 하는 사용자 정의 공유 트리거를 이용한 데이터 스트림과 저장 데이터의 통합 연속 질의 처리 시스템
|
| 9 |
9
통합 연속 질의 처리 시스템에서의 사용자 정의 공유 트리거를 이용한 데이터 스트림과 저장 데이터의 통합 연속 질의 처리 방법에 있어서,사용자 정의 공유 트리거를 등록하는 트리거 등록 단계;상기 등록한 사용자 정의 공유 트리거를 참조하는 통합 연속 질의를 등록하는 통합 연속 질의 등록 단계;상기 등록한 사용자 정의 공유 트리거의 수행 결과로 트리거 결과 집합을 구성하여 관리하는 트리거 결과 집합 구성 단계;데이터 스트림을 입력받는 데이터 스트림 입력 단계; 및상기 입력받은 데이터 스트림과 상기 구성한 트리거 결과 집합을 참조하여 통합 연속 질의를 처리하는 통합 연속 질의 처리 단계를 포함하는 통합 연속 질의 처리 시스템에서의 사용자 정의 공유 트리거를 이용한 데이터 스트림과 저장 데이터의 통합 연속 질의 처리 방법
|
| 10 |
10
제 9 항에 있어서,상기 등록된 사용자 정의 공유 트리거의 삭제 요청에 따라 해당 사용자 정의 공유 트리거를 사용하는 통합 연속 질의의 존재 여부를 검사하여 그 결과에 따라 삭제 기능을 수행하는 트리거 삭제 단계를 더 포함하는 통합 연속 질의 처리 시스템에서의 사용자 정의 공유 트리거를 이용한 데이터 스트림과 저장 데이터의 통합 연속 질의 처리 방법
|
| 11 |
11
제 10 항에 있어서,상기 등록된 통합 연속 질의의 삭제 요청에 따라 해당 통합 연속 질의에서 참조하는 사용자 정의 공유 트리거의 존재 여부를 검사하여 그 결과에 따라 삭제 기능을 수행하는 통합 연속 질의 삭제 단계를 더 포함하는 통합 연속 질의 처리 시스템에서의 사용자 정의 공유 트리거를 이용한 데이터 스트림과 저장 데이터의 통합 연속 질의 처리 방법
|
| 12 |
12
제 9 항 내지 제 11 항 중 어느 한 항에 있어서,상기 통합 연속 질의 처리 단계는,상기 입력받은 데이터 스트림과 상기 저장 데이터에 대한 통합 연속 질의를 처리하되, 상기 저장 데이터에 대해서는 기 처리 완료된 상기 트리거 결과 집합 구성 단계의 트리거 결과 집합을 참조하여 통합 연속 질의를 처리하는 것을 특징으로 하는 통합 연속 질의 처리 시스템에서의 사용자 정의 공유 트리거를 이용한 데이터 스트림과 저장 데이터의 통합 연속 질의 처리 방법
|
| 13 |
13
제 12 항에 있어서,상기 트리거 결과 집합 구성 단계는,상기 각 저장 데이터에 대한 변경이 발생할 때마다 자동으로 수행되는 상기 등록한 사용자 정의 공유 트리거의 수행 결과로 트리거 결과 집합을 구성하여 관리하는 것을 특징으로 하는 통합 연속 질의 처리 시스템에서의 사용자 정의 공유 트리거를 이용한 데이터 스트림과 저장 데이터의 통합 연속 질의 처리 방법
|
| 14 |
14
제 13 항에 있어서,상기 트리거 등록 단계는,사용자 정의 공유 트리거문을 구문 분석하는 구문 분석 단계;상기 구문 분석한 사용자 정의 공유 트리거문에 대한 정당성을 확인하는 정당성 검사 단계;상기 정당성을 검사한 사용자 정의 공유 트리거를 연동 데이터베이스에 등록하는 등록 단계;상기 등록한 사용자 정의 공유 트리거로부터 추출되어 수행된 결과로 초기 트리거 결과 집합을 구성하는 초기 트리거 결과 집합 구성 단계; 및해당 사용자 정의 공유 트리거와 관련된 메타데이터를 저장하는 메타데이터 저장 단계를 포함하는 통합 연속 질의 처리 시스템에서의 사용자 정의 공유 트리거를 이용한 데이터 스트림과 저장 데이터의 통합 연속 질의 처리 방법
|
| 15 |
15
제 13 항에 있어서,상기 통합 연속 질의 등록 단계는,통합 연속 질의문을 구문 분석하는 구문 분석 단계;상기 구문 분석한 통합 연속 질의에 대한 정당성을 확인하는 정당성 검사 단계;상기 정당성을 확인한 통합 연속 질의가 사용자 정의 공유 트리거를 참조하는지 확인하는 트리거 참조 확인 단계;상기 확인한 통합 연속 질의가 참조하는 사용자 정의 공유 트리거의 총 사용자 수를 증가시키는 트리거 연관 단계; 및해당 통합 연속 질의와 관련된 메타데이터를 저장하는 메타데이터 저장 단계를 포함하는 통합 연속 질의 처리 시스템에서의 사용자 정의 공유 트리거를 이용한 데이터 스트림과 저장 데이터의 통합 연속 질의 처리 방법
|
