JP6200377B2 - Virtual DB system and information processing method for virtual DB system - Google Patents
Virtual DB system and information processing method for virtual DB system Download PDFInfo
- Publication number
- JP6200377B2 JP6200377B2 JP2014110806A JP2014110806A JP6200377B2 JP 6200377 B2 JP6200377 B2 JP 6200377B2 JP 2014110806 A JP2014110806 A JP 2014110806A JP 2014110806 A JP2014110806 A JP 2014110806A JP 6200377 B2 JP6200377 B2 JP 6200377B2
- Authority
- JP
- Japan
- Prior art keywords
- virtual
- information
- data source
- event notification
- adapter
- Prior art date
- Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
- Active
Links
Images
Landscapes
- Information Retrieval, Db Structures And Fs Structures Therefor (AREA)
Description
異なる種類の複数のデータソースを単一のデータソースとしてクライアントAP(Application)に見せる仮想DB(DataBase)システム、および、仮想DBシステムの情報処理方法に関する。 The present invention relates to a virtual DB (DataBase) system that shows a plurality of different types of data sources as a single data source to a client AP (Application), and an information processing method of the virtual DB system.
昨今のネットワークの高度化やサービスライフスタイルの短命化に伴い、その運用を支援するOSS(Operation Support System)は、サービス毎にその提供時期に合わせて個別にかつ短期間で開発・導入されている。この個別に開発されたOSSが乱立することで、通信事業者のOSSの構成は複雑になり、OSSの開発・維持コストが増加する一因となっている。 With the recent advancement of networks and the shortening of service life styles, OSS (Operation Support System) that supports the operation of these services has been developed and introduced individually and in a short period of time according to the timing of each service. . This prosperous OSS developed individually complicates the configuration of the OSS of the telecommunications carrier, contributing to an increase in OSS development and maintenance costs.
図9(a)は、個別に開発されたOSSとそのOSSに接続されたNE(Network Element)5とを含むシステムを示す図である。OSS毎に、対応する各クライアントAP2(以下、単に「AP」と記載する場合がある。)やDB3が開発され、図9(a)に示すように、その各AP2とNE5とがそれぞれ接続される。
このようなシステム構成において、個別に開発されたOSSの開発・維持コストが増加するのは、以下に示す、(1)AP間連携の複雑化、(2)個別DB内のデータ重複、(3)NEアクセスのための機能重複、が主な原因となる。
FIG. 9A is a diagram showing a system including an individually developed OSS and an NE (Network Element) 5 connected to the OSS. For each OSS, corresponding client AP2 (hereinafter sometimes simply referred to as “AP”) and DB3 are developed, and each AP2 and NE5 are connected to each other as shown in FIG. 9A. The
In such a system configuration, the development / maintenance cost of individually developed OSS increases as follows: (1) complexity of cooperation between APs, (2) data duplication in individual DBs, (3 ) The main cause is duplication of functions for NE access.
(1)AP間連携の複雑化
OSSのAP2同士が個別に1対1で連携する場合、全体として連携がメッシュ構成となる。仮にn個のAP2がメッシュ構成で連携を行った場合、nの2乗オーダのIF(インタフェース)開発が必要になる。
(1) Complexity of cooperation between APs When the
(2)個別DB内のデータ重複
異なるOSSで同じデータが管理されている場合、情報の一貫性を維持するためのデータ同期等の機能を要する。
(2) Data duplication in individual DB When the same data is managed by different OSS, a function such as data synchronization for maintaining the consistency of information is required.
(3)NEアクセスのための機能重複
複数のOSS上のAP2が個別にNEアクセスのIFを開発した結果、同等または類似のデータを参照・更新する機能の重複が生じる場合がある。
(3) Overlapping of functions for NE access As a result of AP2 on multiple OSSs developing IFs for NE access individually, duplication of functions for referencing and updating equivalent or similar data may occur.
このような問題を解決するため、異なる種類の複数のデータソース(DBMS(Database Management System)やファイルシステム等)をクライアントAPに対して1つのデータソースとして統合して見せる技術として仮想DBシステム(以下、単に「仮想DB」とよぶ場合がある。)がある(例えば、非特許文献1参照)。図9(b)に示す従来の仮想DBでは、複数のDB3を仮想DBシステム1として統合し、各AP2は仮想DBシステム1に対してアクセスすることで、各DB3に関する情報処理を実行することができる。
In order to solve such a problem, a virtual DB system (hereinafter, referred to as a technique for integrating a plurality of different types of data sources (DBMS (Database Management System), file system, etc.) as a single data source to the client AP). , There are cases where it is simply called “virtual DB”) (for example, see Non-Patent Document 1). In the conventional virtual DB shown in FIG. 9B, a plurality of
この図9(b)に示すような仮想DBシステム1を構築し、各DB3を論理的に統合することで、「(2)個別DB内のデータ重複」の問題を解決し、同時に、データが共有されることにより、データ流通を目的としたAP間連携が必要なくなるため、「(1)AP連携の複雑化」の問題も解決することができる。
By constructing the
しかしながら、従来の仮想DBが想定しているデータソースは、DBやファイル等の静的なものであり、自身が記憶する情報に変更があった場合に自ら(つまり「動的に」)情報を発信するようなデータソース(例えば、NEや、他のAP等)からの情報を処理する機構を備えていなかった。NE等が動的に発信する情報としては、例えば、故障等の障害の発生を知らせるアラームや、NEの管理情報(CPU(Central Processing Unit)使用率やメモリ使用率等)のような時間経過により変化する情報についての発信情報等(以下、これらを総称して「イベント通知」と称する。)があげられる。従来の仮想DBは、このような動的に情報を発信するデータソースには対応していないため、「(3)NEアクセスのための機能重複」の問題を解決しNEも含めて仮想DBに統合する、つまり、NEに対する操作や、NEから発信される情報を処理する操作も含めてすべて仮想DB中のデータに対する処理として扱う、ことについては実現していなかった。 However, the data source assumed by the conventional virtual DB is a static source such as a DB or a file, and when the information stored by itself is changed, the data source (that is, “dynamically”) is stored. There is no mechanism for processing information from a data source (for example, NE or another AP) that transmits. Information that is dynamically transmitted by the NE or the like includes, for example, an alarm that informs the occurrence of a failure such as a failure, or time management such as NE management information (CPU (Central Processing Unit) usage rate, memory usage rate, etc.). Transmission information on information that changes (hereinafter, these are collectively referred to as “event notification”). Since the conventional virtual DB does not support such a data source that dynamically transmits information, the problem of “(3) duplication of functions for NE access” is solved, and the virtual DB including the NE is also included. It has not been realized to integrate, that is, to handle all of the data in the virtual DB, including operations for NE and operations for processing information transmitted from NE.
このような背景に鑑みて本発明がなされたのであり、本発明は、データソース側から発信される情報(イベント通知)も含めて仮想DB内で情報を一元的に処理することができる、仮想DBシステム、および、仮想DBシステムの情報処理方法を提供することを課題とする。
つまり、従来のDBやファイル等の静的なデータソースに加えて、イベント通知を送信するような動的なデータソース(NE等)を含めて仮想DBに統合し情報処理することができる、仮想DBシステム、および、仮想DBシステムの情報処理方法を提供することを課題とする。
In view of such a background, the present invention has been made, and the present invention is capable of processing information centrally in a virtual DB including information (event notification) transmitted from the data source side. It is an object of the present invention to provide an information processing method for a DB system and a virtual DB system.
In other words, in addition to conventional static data sources such as DBs and files, dynamic data sources (such as NE) that transmit event notifications can be integrated into a virtual DB for information processing. It is an object of the present invention to provide an information processing method for a DB system and a virtual DB system.
前記した課題を解決するため、請求項1に記載の発明は、複数のデータソースを統合して、複数の前記データソースそれぞれとクライアントAP(Application)との間の情報を処理する仮想DB(DataBase)サーバと、前記仮想DBサーバに接続され、複数の前記データソースそれぞれとの間で情報の送受信を行い、複数の前記データソースそれぞれに対応付けて設けられるアダプタと、を備える仮想DBシステムであって、複数の前記データソースには、前記データソース自身のイベント発生時に、イベント通知を発信する機能を備えた前記データソースが含まれており、前記仮想DBサーバが、前記クライアントAPから監視対象となる前記データソースの識別情報と監視条件とを含む監視対象情報が記載された参照クエリを受信し、前記参照クエリを実行することにより、前記監視対象情報で示される特定のデータソースに対応するアダプタに、前記監視対象情報を送信するクエリ実行部を備え、前記アダプタが、受信した前記監視対象情報で示される前記特定のデータソースを監視対象として登録し、前記特定のデータソースから前記イベント通知を受け取ると、前記仮想DBサーバに前記監視条件に合致する当該イベント通知の情報を送信するイベント通知処理部を備え、前記仮想DBサーバのクエリ実行部が、前記参照クエリを実行することにより、前記特定のデータソースに対応するアダプタから前記監視条件に合致する前記イベント通知の情報を取得しておき、前記参照クエリの実行を終了し、前記参照クエリのデータ読み出し処理であるフェッチ時に、前記クライアントAPへ前記取得したイベント通知の情報を送信すること、を特徴とする仮想DBシステムとした。
In order to solve the above-described problem, the invention according to
また、請求項4に記載の発明は、複数のデータソースを統合して、複数の前記データソースそれぞれとクライアントAPとの間の情報を処理する仮想DBサーバと、前記仮想DBサーバに接続され、複数の前記データソースそれぞれとの間で情報の送受信を行い、複数の前記データソースそれぞれに対応付けて設けられるアダプタと、を備える仮想DBシステムの情報処理方法であって、複数の前記データソースには、前記データソース自身のイベント発生時に、イベント通知を発信する機能を備えた前記データソースが含まれており、前記仮想DBサーバが、前記クライアントAPから監視対象となる前記データソースの識別情報と監視条件とを含む監視対象情報が記載された参照クエリを受信し、前記参照クエリを実行することにより、前記監視対象情報で示される特定のデータソースに対応するアダプタに、前記監視対象情報を送信し、前記アダプタが、受信した前記監視対象情報で示される前記特定のデータソースを監視対象として登録し、前記特定のデータソースから前記イベント通知を受け取ると、前記仮想DBサーバに前記監視条件に合致する当該イベント通知の情報を送信し、前記仮想DBサーバが、前記参照クエリを実行することにより、前記特定のデータソースに対応するアダプタから前記監視条件に合致する前記イベント通知の情報を取得しておき、前記参照クエリの実行を終了し、前記参照クエリのデータ読み出し処理であるフェッチ時に、前記クライアントAPへ前記取得したイベント通知の情報を送信することを特徴とする仮想DBシステムの情報処理方法とした。
The invention according to
このようにすることで、仮想DBシステムは、データソースから発信されたイベント通知をアダプタが受け取り、クライアントAPからの参照クエリに対する応答として、仮想DBサーバがそのイベント通知の情報をクライアントAPに送信することができる。
よって、従来のDBやファイル等の静的なデータソースに加えて、イベント通知を送信するような動的なデータソース(NE5等)を含めて仮想DBに統合し情報処理することができる。
By doing so, in the virtual DB system, the adapter receives the event notification transmitted from the data source, and the virtual DB server transmits the event notification information to the client AP as a response to the reference query from the client AP. be able to.
Therefore, in addition to conventional static data sources such as DBs and files, dynamic data sources (such as NE5) that transmit event notifications can be integrated into a virtual DB for information processing.
また、仮想DBシステムは、データソースから発信されたイベント通知を、クエリ実行時に仮想DBサーバが取得し、クライアントAPからの参照クエリに対する応答として、そのイベント通知の情報をクライアントAPに送信することができる。 In addition , the virtual DB system may acquire an event notification transmitted from the data source by the virtual DB server at the time of query execution, and send the event notification information to the client AP as a response to the reference query from the client AP. it can.
請求項2に記載の発明は、複数のデータソースを統合して、複数の前記データソースそれぞれとクライアントAPとの間の情報を処理する仮想DBサーバと、前記仮想DBサーバに接続され、複数の前記データソースそれぞれとの間で情報の送受信を行い、複数の前記データソースそれぞれに対応付けて設けられるアダプタと、を備える仮想DBシステムであって、複数の前記データソースには、前記データソース自身のイベント発生時に、イベント通知を発信する機能を備えた前記データソースが含まれており、前記仮想DBサーバが、前記クライアントAPから監視対象となる前記データソースの識別情報と監視条件とを含む監視対象情報が記載された参照クエリを受信し、前記参照クエリを実行することにより、前記監視対象情報で示される特定のデータソースに対応するアダプタに、前記監視対象情報を送信するクエリ実行部を備え、前記アダプタが、受信した前記監視対象情報で示される前記特定のデータソースを監視対象として登録し、前記特定のデータソースから前記イベント通知を受け取るイベント通知処理部を備え、前記アダプタの前記イベント通知処理部が、通知蓄積部を備えており、前記特定のデータソースから前記イベント通知を受け取ると、前記監視条件に合致する当該イベント通知を前記通知蓄積部に記憶しておき、前記仮想DBサーバのクエリ実行部が、前記参照クエリを実行することにより、前記特定のデータソースに対応するアダプタに、前記特定のデータソースを監視対象として登録すると、前記参照クエリの実行を終了し、前記参照クエリのデータ読み出し処理であるフェッチ時に、前記アダプタの通知蓄積部に問い合わせることにより、前記イベント通知の情報を取得し、前記クライアントAPへ前記取得したイベント通知の情報を送信することを特徴とする仮想DBシステムとした。
The invention according to
また、請求項5に記載の発明は、複数のデータソースを統合して、複数の前記データソースそれぞれとクライアントAPとの間の情報を処理する仮想DBサーバと、前記仮想DBサーバに接続され、複数の前記データソースそれぞれとの間で情報の送受信を行い、複数の前記データソースそれぞれに対応付けて設けられるアダプタと、を備える仮想DBシステムの情報処理方法であって、複数の前記データソースには、前記データソース自身のイベント発生時に、イベント通知を発信する機能を備えた前記データソースが含まれており、前記仮想DBサーバが、前記クライアントAPから監視対象となる前記データソースの識別情報と監視条件とを含む監視対象情報が記載された参照クエリを受信し、前記参照クエリを実行することにより、前記監視対象情報で示される特定のデータソースに対応するアダプタに、前記監視対象情報を送信し、前記アダプタが、通知蓄積部を備えており、受信した前記監視対象情報で示される前記特定のデータソースを監視対象として登録し、前記特定のデータソースから前記イベント通知を受け取ると、前記監視条件に合致する当該イベント通知を前記通知蓄積部に記憶しておき、前記仮想DBサーバが、前記参照クエリを実行することにより、前記特定のデータソースに対応するアダプタに、前記特定のデータソースを監視対象として登録すると、前記参照クエリの実行を終了し、前記参照クエリのデータ読み出し処理であるフェッチ時に、前記アダプタの通知蓄積部に問い合わせることにより、前記イベント通知の情報を取得し、前記クライアントAPへ前記取得したイベント通知の情報を送信することを特徴とする仮想DBシステムの情報処理方法とした。
The invention according to
このようにすることで、仮想DBシステムは、データソースから発信されたイベント通知をアダプタが受け取り、クライアントAPからの参照クエリに対する応答として、仮想DBサーバがそのイベント通知の情報をクライアントAPに送信することができる。
よって、従来のDBやファイル等の静的なデータソースに加えて、イベント通知を送信するような動的なデータソース(NE5等)を含めて仮想DBに統合し情報処理することができる。
また、仮想DBシステムは、データソースから発信されたイベント通知の情報を、参照クエリのフェッチ時に仮想DBサーバがアダプタの通知蓄積部から取得し、そのイベント通知の情報をクライアントAPに送信することができる。
By doing so, in the virtual DB system, the adapter receives the event notification transmitted from the data source, and the virtual DB server transmits the event notification information to the client AP as a response to the reference query from the client AP. be able to.
Therefore, in addition to conventional static data sources such as DBs and files, dynamic data sources (such as NE5) that transmit event notifications can be integrated into a virtual DB for information processing.
In the virtual DB system, the event notification information transmitted from the data source may be acquired from the notification storage unit of the adapter by the virtual DB server when the reference query is fetched, and the event notification information may be transmitted to the client AP. it can.
請求項3に記載の発明は、前記仮想DBサーバのクエリ実行部が、前記フェッチ時に、前記アダプタの通知蓄積部に問い合わせた結果、当該通知蓄積部が前記イベント通知を記憶していなかった場合に、前記特定のデータソースに対応するアダプタが前記イベント通知を受け取り、当該イベント通知が前記通知蓄積部に記憶されるまで待機することを特徴とする請求項2に記載の仮想DBシステムとした。
According to a third aspect of the invention, the query execution unit of the virtual DB server, when the fetch results of the inquiry to the notification storage unit of the adapter, when the notification storage unit has not stored the event notification The virtual DB system according to
また、請求項6に記載の発明は、前記仮想DBサーバが、前記フェッチ時に、前記アダプタの通知蓄積部に問い合わせた結果、当該通知蓄積部が前記イベント通知を記憶していなかった場合に、前記特定のデータソースに対応するアダプタが前記イベント通知を受け取り、当該イベント通知が前記通知蓄積部に記憶されるまで待機することを特徴とする請求項5に記載の仮想DBシステムの情報処理方法とした。
Further, in the invention according to
このようにすることで、仮想DBシステムは、アダプタの通知蓄積部にイベント通知が記憶されていない場合においても実行される、無駄となるフェッチの処理、それに伴う問い合わせや応答処理をなくすことができる。よって、仮想DBサーバおよびクライアントAPの処理負荷を低減することができる。 By doing so, the virtual DB system can eliminate the useless fetch process and the associated inquiry and response processes that are executed even when the event notification is not stored in the notification storage unit of the adapter. . Therefore, the processing load on the virtual DB server and the client AP can be reduced.
本発明によれば、イベント通知を発信する機能を備えたデータソースも含めて仮想DB内で情報を一元的に処理する、仮想DBシステム、および、仮想DBシステムの情報処理方法を提供することができる。 According to the present invention, it is possible to provide a virtual DB system and an information processing method for the virtual DB system that centrally process information in the virtual DB including a data source having a function of transmitting an event notification. it can.
次に、本発明を実施するための形態(以下、「本実施形態」という。)における仮想DBシステム1000等について説明する。
まず、比較例として従来の仮想DBシステム1を説明し、その後に、本実施形態に係る仮想DBシステム1000について説明する。
Next, a
First, a conventional
<比較例の仮想DBシステム>
図10は、比較例の仮想DBシステム1の構成例を示す機能ブロック図である。
比較例の仮想DBシステム1は、クライアントAP(以下、単に「AP」と称する。)2からクエリを受け取り、そのクエリを各データソース用のクエリに変換した上で、各データソース用のアダプタ30を介してそのクエリを出力し各データソースに実行させる。ここでの各データソースは、DBMS(図では「DB3」と記載する。)やファイルシステム(図では、「ファイル4」と記載する。)等であり、イベント通知等を送信する機能を備えたデータソース(例えば、NE)は含んでいない。
この比較例の仮想DBシステム1は、図10に示すように、仮想DBサーバ100と、データソースそれぞれに対応した複数のアダプタ30(30D1,30D2,30F)とを備えて構成される。そして、この仮想DBサーバ100は、クエリエンジン10およびスキーマ・ルール格納部20を備える。
<Virtual DB system of comparative example>
FIG. 10 is a functional block diagram illustrating a configuration example of the
The
As shown in FIG. 10, the
クエリエンジン10は、AP2から、例えばSQL(Structured Query Language)で記述されたクエリを受け取り、そのクエリを各データソース用のクエリに変換し、実行計画を立て実行する。このクエリエンジン10は、クエリ解析・書換部11、クエリ最適化部12およびクエリ実行部13を備える。
The query engine 10 receives a query described in, for example, SQL (Structured Query Language) from the
クエリ解析・書換部11は、AP2からのクエリを受け取り、そのクエリの字句解析を行う。そして、クエリ解析・書換部11は、解析したクエリに対して、スキーマ・ルール格納部20を参照し、クライアントAP用スキーマからデータソース(DS)用スキーマへのクエリの書き換えを行う。
なお、クライアントAP用スキーマとは、AP2側に見せるためのスキーマであり、AP2が参照可能な形式(例えば、テーブル形式)でデータ構造が格納されるものである。また、データソース(DS)用スキーマとは、データソースそれぞれに対応したデータ構造が格納されるものである。
The query analysis /
The client AP schema is a schema for showing to the AP2 side, and stores a data structure in a format (for example, a table format) that can be referred to by the AP2. The data source (DS) schema stores a data structure corresponding to each data source.
クエリ最適化部12は、クエリ解析・書換部11で書き換えられたクエリに対して、最適な実行計画を策定する。
クエリ実行部13は、策定された実行計画を、そのクエリが要求する処理対象のデータソース用のアダプタ30を介して実行する。
The
The
スキーマ・ルール格納部20には、不図示の記憶手段に記憶される情報であり、AP2に見せるクライアントAP用スキーマ(図示省略)、各データソースに対応したデータソース(DS)用スキーマ(図示省略)、このクライアントAP用スキーマとデータソース(DS)用スキーマとを対応付けるマッピングルール(図示省略)等が格納される。
The schema
アダプタ30は、各データソースに対応して設けられる。例えば、アダプタ30(30D1)は、DB「1」用のアダプタであり、アダプタ30(30D2)は、DB「2」用のアダプタであり、アダプタ30(30F)は、ファイル(ファイルシステム)用のアダプタである。そして、各アダプタ30は、クエリ実行部13が実行したクエリを各データソースにおけるクエリへ変換する。
The
比較例の仮想DBシステム1は、このように、データソースそれぞれに対応したアダプタ30を備え、仮想DBシステム1に対するクエリを各データソースに対するクエリに変換することにより、各データソース(DBMSやファイルシステム)の仮想的な統合を実現している。
As described above, the
しかしながら、前記したように、比較例の仮想DBシステム1では、データソース(DS)側で発生したイベント通知を検知して処理を実行する機能を備えていない。そのため、仮に比較例の仮想DBシステム1を用いて、データソース(DS)側からのイベント通知を処理しようとすると、図11に示すように、新たに外部のAP(外部AP)2(2a)を設けて、AP側でイベント通知を受け取り、その通知を解析し、仮想DBシステム1に投入するためのクエリに変換する必要がある。図11では、外部AP2(2a)に、通知受付機能と、通知-クエリ変換機能と、クエリ投入機能とを備えた例を示している。NE5(5N)からのイベント通知を、外部AP2の通知受付機能が受け付け、通知-クエリ変換機能が、イベント通知を解析し仮想DBシステム1に対応したクエリに変換した上で、クエリ投入機能が仮想DBシステム1に対して、クエリを送信する。
However, as described above, the
このように、外部AP2(2a)を設けることで、データソース(DS)側で発生したイベント通知を仮想DBシステム1において処理することは可能であるが、AP側でイベント通知をクエリに変換する必要が生じることや、仮想DBシステム1内のクエリエンジン10を経由することになりオーバヘッドが大きくなるという問題があった。
As described above, by providing the external AP 2 (2a), the event notification generated on the data source (DS) side can be processed in the
よって、従来のDB3やファイル4等のデータソースに加えて、NE5等のイベント通知を発信するような動的なデータソースを含めて仮想DBに統合し情報処理することは、実現していなかった。
Therefore, in addition to the conventional data sources such as DB3 and
(本実施形態)
次に、本実施形態に係る仮想DBシステム1000等について説明する。
(This embodiment)
Next, the
<概要>
上記において説明したように、従来の仮想DBが想定しているデータソースは、DB3やファイル4等の静的なものである。よって、従来の仮想DBは、自らイベント通知を発信するようなデータソースからの情報を処理する機能を備えていなかった。
<Overview>
As described above, the data source assumed by the conventional virtual DB is a static data source such as
これに対し、本実施形態に係る仮想DBシステム1000は、図1に示すように、データソースとして、DB3やファイル4に加え、自らイベント通知を発信する機能を備えた装置である、NE5等も含めて統合し情報を一元的に扱う。つまり、例えば、管理対象装置としてのNE5との間のアクセスや、他のAP2との連携等を含めて、仮想DBシステム1000を通して行う。
On the other hand, as shown in FIG. 1, the
そのため、仮想DBシステム1000は、各データソースに対応したアダプタ30を備える。特に、本実施形態では、図2に示すように、自らイベント通知を発信する機能を備えた装置である、NE5等に対応したアダプタ30(図2ではアダプタ30N)を備える。
そして、このNE用のアダプタ30(30N)が、比較例における仮想DBシステム1(図10)のアダプタ30にはない、データソース側からのイベント通知を処理するためのイベント通知処理部300を備えることを特徴とする。このイベント通知処理部300は、データソースから発信されたイベント通知を受け取り、AP2からの参照クエリに対する応答として、仮想DBサーバ100を介して、そのイベント通知の情報を送信する処理を実行する。
つまり、従来のアダプタ30の機能を拡張し、イベント通知処理部300を備えるようにすることにより、AP2からの参照クエリに対する応答の形で、データソースからのイベント通知の情報を、仮想DBシステム1000からAP2側に送信する。
Therefore, the
The NE adapter 30 (30N) includes an event
In other words, by expanding the function of the
このようにすることで、本実施形態に係る仮想DBシステム1000、および、仮想DBシステムの情報処理方法によれば、従来のDBやファイル等の静的なデータソースに加えて、イベント通知を送信するような動的なデータソース(NE5等)を含めて仮想DBに統合し情報処理することができる。
また、従来のAP2を極力変更することなく、データソースからのイベント通知を従来のDBアクセスと同様に扱うことができる。さらに、従来の仮想DBサーバ100の改編を行うことなく、データソースからのイベント通知を扱うことができる。なお、詳細は後記する。
By doing so, according to the
Further, the event notification from the data source can be handled in the same manner as the conventional DB access without changing the conventional AP2 as much as possible. Furthermore, it is possible to handle event notifications from data sources without modifying the conventional
本実施形態においては、上記のように、仮想DBシステム1000が、アダプタ30内にイベント通知処理部300を備えることにより、AP2からの参照クエリに対する応答の形で、データソースからのイベント通知の情報をAP2側に送信することを特徴とするものである。通常、DB3内のデータ処理を参照するためには、AP2からDB3に対して、次のような操作が行われる。
図3に示すように、まず、AP2は、DB3に対して、DB参照クエリを発行する(ステップS1)。図3では、AP2が、DB3に記憶されている「table 1」からデータを取得する例を示している(SELECT * FROM table 1;)。ステップS1により、DB3において条件に適合するレコードの一覧が作成される。
次に、AP2が、DB3からレコード(データ:図3では、col1とcol2のデータ)を順次読み出す処理であるフェッチ(各図において「fetch」と記載する。)を実行する。このフェッチにより、AP2は、DB3から各データを取得する(ステップS2)。
なお、図3の符号Pには、AP2がクエリを実行し、フェッチによりデータを取得するためのプログラム例を示している。
In the present embodiment, as described above, the
As shown in FIG. 3, first, AP2 issues a DB reference query to DB3 (step S1). FIG. 3 shows an example in which AP2 acquires data from “table 1” stored in DB3 (SELECT * FROM table 1;). By step S1, a list of records that meet the conditions in DB3 is created.
Next, AP2 executes fetch (denoted as “fetch” in each figure), which is a process of sequentially reading records (data: col1 and col2 data in FIG. 3) from DB3. With this fetch, AP2 acquires each data from DB3 (step S2).
In addition, the code | symbol P of FIG. 3 has shown the example of a program for AP2 performing a query and acquiring data by fetch.
本実施形態では、AP2から仮想DBシステム1000に対する参照クエリにより、(最初に)監視対象装置(例えば、監視対象となるNE5)と監視条件とをアダプタ30内のイベント通知処理部300に登録しておく。そして、アダプタ30が、登録した監視対象装置と監視条件に適合するイベント通知を受信した場合に、AP2からの参照クエリに対する応答として、そのイベント通知の情報をAP2へ送信する処理を行う。
In the present embodiment, a reference query from the
ここで、本実施形態に係る仮想DBシステム1000において、仮想DBサーバ100がアダプタ30から、イベント通知の情報(イベント情報)を取得するタイミングとしては、以下の2つのパターンがある。
(パターン1)クエリ実行時にイベント情報を取得する方式
(パターン2)フェッチ時にイベント情報を取得する方式
以下において、この(パターン1)のクエリ実行時に仮想DBサーバ100がイベント情報を取得する方式を、本発明の第1の実施形態として説明し、(パターン2)のフェッチ時に仮想DBサーバ100がイベント情報を取得する方式を、本発明の第2の実施形態として説明する。
Here, in the
(Pattern 1) Method of acquiring event information at the time of query execution (Pattern 2) Method of acquiring event information at the time of fetching In the following, a method in which the
<第1の実施形態>
まず、仮想DBシステム1000のアダプタ30が備えるイベント通知処理部300を介して、(パターン1)クエリ実行時に仮想DBサーバ100がイベント情報を取得する方式について具体的に説明する。
なお、ここで「クエリ実行時」とは、仮想DBサーバ100がAP2から参照クエリを受信してから、その参照クエリを解析して実行し、後記するクエリ実行終了メッセージをAP2に送信するまでの期間を意味し、その後のフェッチ処理の実行期間を含まない。
<First Embodiment>
First, a method in which the
Here, “during query execution” refers to a period from when the
図4は、本発明の第1の実施形態に係る仮想DBシステム1000の構成例を示す機能ブロック図である。
図4に示した仮想DBシステム1000は、図10に示した比較例の仮想DBシステム1と比べ、アダプタ30内に、イベント通知処理部300を備える点が異なる。なお、図10に示した仮想DBシステム1の仮想DBサーバ100と、本発明の第1の実施形態に係る仮想DBシステム1000の仮想DBサーバ100とは、同一の機能を備えるものであるため、同一の符号と名称を付し、詳細な説明は省略する。また、図4においては、仮想DBシステム1000にNE5が1台のみ接続された例を示しているが、図1に示したように、複数のDB3やファイルシステム4、他のNE5やAP2がデータソースとして接続されていてもよい。
FIG. 4 is a functional block diagram showing a configuration example of the
The
本発明の第1の実施形態に係るアダプタ30は、クエリエンジン10のクエリ実行部13が実行したクエリを対応するデータソース(ここでは、NE5)におけるクエリやそのデータソースに適合するプロトコルに基づく操作(コマンド)等に変換する処理を行う。そして、このアダプタ30は、さらに、図4に示すイベント通知処理部300の機能により、データソースから発信されたイベント通知を受け取り、AP2からの参照クエリに対する応答として、仮想DBサーバ100を介して、そのイベント通知を送信する。より詳細には、イベント通知処理部300は、クエリ実行時に、監視対象装置(ここでは、NE5)と監視条件とを登録しておき、監視対象装置から監視条件に合致するイベント通知を受け付けた場合に、そのイベント通知の情報(イベント情報)を仮想DBサーバ100に送信し記憶させておく。つまり、仮想DBシステム1000は、クエリ実行時にイベント通知の情報(イベント情報)をアダプタ30のイベント通知処理部300から仮想DBサーバ100が取得し、記憶しておくようにする。そして、AP2は、フェッチにより仮想DBサーバ100に記憶されたイベント情報を取得する。
このイベント通知処理部300は、図4に示すように、仮想DB側IF部310と、通知受付部320とを備える。
The
As shown in FIG. 4, the event
仮想DB側IF部310は、仮想DBサーバ100のクエリ実行部13から、クエリ形式で取得した監視対象装置(ここでは、NE5)および監視条件の情報(後記する「監視対象情報」)を解釈し、通知受付部320に登録することにより、監視を開始させる。
また、仮想DB側IF部310は、通知受付部320が、登録した監視対象装置から監視対象条件に合致するイベント通知(後記する図5においては、「trap」と記載する。)を受け付けた場合に、そのイベント通知(「trap」)を取得して、仮想DBサーバ100にイベント情報として送信する。
The virtual DB-side IF
Further, the virtual DB-side IF
通知受付部320は、仮想DB側IF部310からの要求により、監視対象装置および監視条件を登録する。そして、通知受付部320は、登録した監視対象装置からイベント通知を受け付けた場合に、登録した監視条件に合致するか否かを判定し、監視条件に合致する場合に、そのイベント通知を仮想DB側IF部310に出力する。
The
仮想DBサーバ100(クエリ実行部13)は、アダプタ30の仮想DB側IF部310からイベント情報を受信すると、そのイベント情報を自身の記憶部(不図示)に記憶する。そして、クエリ実行部13は、クエリの実行の終了を示すクエリ実行終了メッセージをAP2に送信する。
続いて、AP2がフェッチを実行し、その際に、仮想DBサーバ100は、自身に記憶したイベント情報をフェッチに対するデータとして送信する。つまり、AP2は、参照クエリの対する応答として、仮想DBサーバ100からイベント情報(データ)を取得することができる。
When the virtual DB server 100 (query execution unit 13) receives event information from the virtual DB side IF
Subsequently, the
≪処理の流れ≫
次に、本発明の第1の実施形態に係る仮想DBシステム1000の処理の流れについて、図5を参照して説明する(適宜図4参照)。
図5は、本発明の第1の実施形態に係る仮想DBシステム1000の処理の流れを示すフローチャートである。
なお、アダプタ30内の仮想DB側IF部310を、図4においては、IF部310と記載する。また、AP2には、仮想DBシステム1000に対するクエリの処理結果を表示するためのGUI(Graphical User Interface)6が接続されているものとする。
≪Process flow≫
Next, a processing flow of the
FIG. 5 is a flowchart showing a processing flow of the
Note that the virtual DB-side IF
まず、AP2は、仮想DBシステム1000の仮想DBサーバ100に対して、監視対象装置、監視条件を含む参照クエリを発行する(ステップS10)。
AP2は、例えば、参照クエリとして、「SELECT * FROM eventTable WHERE host=‘192.168.0.10’;」を発行する。ここで、「host=‘192.168.0.10’」は、監視対象装置を識別するためのIPアドレスを表す。そして、この参照クエリは、仮想DBサーバ100に記憶されたテーブルである「eventTable」から、その監視対象装置についての所定の監視条件に合致する情報の取得要求を意味する。監視条件としては、例えば、監視対象装置の状態情報であるCPU使用率やメモリ使用率であること(そのCPU使用率やメモリ使用率が所定の閾値を超えたことを示す情報であること)や、障害発生情報等であること等が設定される。
First, the
For example, AP2 issues “SELECT * FROM eventTable WHERE host = '192.168.0.10';” as a reference query. Here, “host = '192.168.0.10'” represents an IP address for identifying the monitoring target device. This reference query means an acquisition request for information that matches a predetermined monitoring condition for the monitoring target device from “eventTable” that is a table stored in the
次に、仮想DBサーバ100は、クエリエンジン10により、受信したクエリを解析し、参照先(FROM句で与えられるテーブル)に応じたアダプタ30を決定する。ここでは、仮想DBサーバ100は、FROM句で与えられる、例えば「eventTable」に対応するアダプタ30として、NE5用のアダプタ30Nが決定されたものとする。そして、仮想DBサーバ100は、WHERE句で与えられる監視対象装置と監視条件と含む監視対象情報を、決定したアダプタ30(30N)に送信する(ステップS11)。
Next, the
アダプタ30(30N)の仮想DB側IF部310は、監視対象情報を受信すると、その監視対象情報を、通知受付部320に出力する(ステップS12)。通知受付部320は、監視対象情報を取得すると、その監視対象情報に含まれる監視対象装置および監視対象条件を登録することにより、イベント通知の監視を開始する。なお、アダプタ30(30N)の仮想DB側IF部310は、通知受付部320に監視対象情報を登録後、通知受付部320がイベント通知(「trap」)を受け付けるまで待機する。
When receiving the monitoring target information, the virtual DB side IF
次に、NE5により、イベント通知(図5において、「trap」と記載する。)が送信され、アダプタ30(30N)の通知受付部320がそのイベント通知(「trap」)を受け付ける(ステップS13)。通知受付部320は、イベント通知(「trap」)を受け付けると、登録した監視対象情報(監視対象装置および監視条件)に合致するか否かを判定し、合致する場合に、そのイベント通知(「trap」)を仮想DB側IF部310に出力する(ステップS14)。
Next, an event notification (described as “trap” in FIG. 5) is transmitted by NE5, and the
続いて、アダプタ30(30N)の仮想DB側IF部310は、そのイベント通知の情報(イベント情報)を仮想DBサーバ100のクエリ実行部13に送信する(ステップS15)。そして、クエリ実行部13は、取得したイベント通知の情報(イベント情報)を、記憶部(不図示)に記憶しておく。なお、図5においては、このイベント通知の情報(イベント情報)を、参照クエリによりAP2が取得するデータを意味するものとして、「data」と記載している。そして、クエリ実行部13は、クエリ実行の終了を示すクエリ実行終了メッセージをAP2へ送信する(ステップS16)。
Subsequently, the virtual DB side IF
クエリ実行終了メッセージを受信したAP2は、フェッチによりイベント通知の情報(イベント情報)を、参照クエリに対する応答のデータとして取得する(ステップS17、S18)。そして、AP2は、取得したイベント通知の情報(イベント情報)をGUI6に出力する(ステップS19)。 Upon receiving the query execution end message, AP2 obtains event notification information (event information) by fetching as response data to the reference query (steps S17 and S18). And AP2 outputs the information (event information) of the acquired event notification to GUI6 (step S19).
なお、AP2からのフェッチ時に、仮想DBサーバ100において、イベント通知の情報(イベント情報)が記憶されていない場合には、仮想DBサーバ100のクエリ実行部13は、「null」をAP2に対し送信する(ステップS20、S21)。
また、AP2は、アダプタ30(30N)による監視を、例えば、exitメッセージを仮想DBシステム1000に送信することにより終了させることができる(ステップS22〜S24)。
When the event notification information (event information) is not stored in the
In addition, the
このように、本発明の第1の実施形態に係る仮想DBシステム1000、および、仮想DBシステムの情報処理方法によれば、データソースから発信されたイベント通知を、クエリ実行時に仮想DBサーバ100が取得し、AP2からの参照クエリに対する応答として、そのAP2に送信することができる。よって、従来のDBやファイル等の静的なデータソースに加えて、イベント通知を送信するような動的なデータソース(NE5等)を含めて仮想DBシステム1000に統合し情報処理することができる。
As described above, according to the
<第2の実施形態>
次に、仮想DBシステム1000のアダプタ30が備えるイベント通知処理部300を介して、(パターン2)フェッチ時にイベント情報を取得する方式について具体的に説明する。
<Second Embodiment>
Next, a method of acquiring event information at the time of fetching (pattern 2) via the event
図6は、本発明の第2の実施形態に係る仮想DBシステム1000Aの構成例を示す機能ブロック図である。
図6に示した仮想DBシステム1000Aは、図4に示した本発明の第1の実施形態に係る仮想DBシステム1000と比べ、仮想DBサーバ100内のクエリ実行部13が、クエリ実行部13Aとなっていること、アダプタ30内のイベント通知処理部300がイベント通知処理部300Aとなっていることが異なる。また、このイベント通知処理部300A内には、第1の実施形態の機能を一部変更した、仮想DB側IF部310A、通知受付部320Aと共に、新たな構成として通知蓄積部315が備えられる。その他の構成については、図4に示した仮想DBシステム1000の構成と同一の機能を備えるものであるため、同一の符号と名称を付し、詳細な説明は省略する。また、図6においては、仮想DBシステム1000AにNE5が1台のみ接続された例を示しているが、図1に示したように、複数のDB3やファイルシステム4、他のNE5やAP2がデータソースとして接続されていてもよい。
FIG. 6 is a functional block diagram showing a configuration example of the virtual DB system 1000A according to the second embodiment of the present invention.
The virtual DB system 1000A illustrated in FIG. 6 is different from the
本発明の第2の実施形態に係るアダプタ30は、クエリエンジン10のクエリ実行部13Aが実行したクエリを、対応するデータソース(ここでは、NE5)におけるクエリやそのデータソースに適合するプロトコルに基づく操作(コマンド)等に変換する処理を実行する。そして、このアダプタ30は、さらに、図6に示すイベント通知処理部300Aの機能により、データソースから発信されたイベント通知を受け取り、AP2からの参照クエリに対する応答として、仮想DBサーバ100を介して、そのイベント通知を送信する。より詳細には、仮想DBサーバ100のクエリ実行部13Aは、クエリ実行時に、アダプタ30のイベント通知処理部300Aに対して、監視対象装置(ここでは、NE5)と監視条件とを登録し、そのクエリの実行を終了する。イベント通知処理部300Aは、登録した監視対象装置から監視条件に合致するイベント通知を受け付けた場合に、そのイベント通知を蓄積しておく。そして、AP2からのフェッチ時に、仮想DBサーバ100がアダプタ30(イベント通知処理部300A)に対して問い合わせを行うことにより、イベント通知の情報(イベント情報)を取得し、AP2に対して送信する。つまり、フェッチ時にイベント通知の情報(イベント情報)を仮想DBサーバ100が取得するようにする。
このイベント通知処理部300Aは、図6に示すように、仮想DB側IF部310Aと、通知蓄積部315と、通知受付部320Aとを備える。
The
As shown in FIG. 6, the event notification processing unit 300A includes a virtual DB-side IF
仮想DB側IF部310Aは、仮想DBサーバ100のクエリ実行部13Aから、クエリ形式で取得した監視対象装置(ここでは、NE5)および監視条件の情報(「監視対象情報」)を解釈し、通知受付部320Aに登録することにより、監視を開始させる。
また、仮想DB側IF部310Aは、仮想DBサーバ100(クエリ実行部13A)からの要求に応じて、通知蓄積部315に問い合わせを行い、蓄積されたイベント通知を取得して、仮想DBサーバ100(クエリ実行部13A)にイベント通知の情報(イベント情報)として送信する。
The virtual DB-side IF
Also, the virtual DB side IF
通知蓄積部315は、通知受付部320Aからイベント通知を取得して蓄積(記憶)する。また、通知蓄積部315は、蓄積したイベント通知を仮想DB側IF部310Aからの問い合わせに応じて出力する。
The
通知受付部320Aは、仮想DB側IF部310Aからの要求により、監視対象装置および監視条件を登録する。そして、通知受付部320Aは、登録した監視対象装置からイベント通知を受け付けた場合に、監視条件に合致する否かを判定し、監視条件に合致する場合に、そのイベント通知を通知蓄積部315に出力する。
The
仮想DBサーバ100(クエリ実行部13A)は、アダプタ30の通知受付部320Aによる監視対象情報(監視対象装置および監視条件)の登録が完了した場合に、クエリ実行の終了を示すクエリ実行終了メッセージをAP2へ送信する。また、クエリ実行部13Aは、AP2からのフェッチによるデータ読み出し要求があったときに、アダプタ30(仮想DB側IF部310A)に対し、イベント通知の情報(イベント情報)の問い合わせを行い、通知蓄積部315に新規のイベント通知の情報(イベント情報)が蓄積されていれば取得し、そのフェッチの応答として、AP2へ送信する。
The virtual DB server 100 (
≪処理の流れ≫
次に、本発明の第2の実施形態に係る仮想DBシステム1000Aの処理の流れについて、図7を参照して説明する(適宜図6参照)。
図7は、本発明の第2の実施形態に係る仮想DBシステム1000Aの処理の流れを示すフローチャートである。
なお、アダプタ30内の仮想DB側IF部310Aを、図4においては、IF部310Aと記載している。また、AP2には、仮想DBシステム1000Aに対するクエリの処理結果を表示するためのGUI6が接続されているものとする。
≪Process flow≫
Next, a processing flow of the virtual DB system 1000A according to the second embodiment of the present invention will be described with reference to FIG. 7 (see FIG. 6 as appropriate).
FIG. 7 is a flowchart showing the flow of processing of the virtual DB system 1000A according to the second embodiment of the present invention.
Note that the virtual DB-side IF
まず、AP2は、仮想DBシステム1000Aの仮想DBサーバ100に対して、監視対象装置、監視条件を含む参照クエリを発行する(ステップS30)。
AP2は、例えば、参照クエリとして、「SELECT * FROM eventTable WHERE host=‘192.168.0.10’;」を発行する。ここで、「host=‘192.168.0.10’」は、監視対象装置を識別するためのIPアドレスを表す。そして、この参照クエリは、仮想DBサーバ100に記憶されたテーブルである「eventTable」から、その監視対象装置についての所定の監視条件に合致する情報の取得要求を意味する。監視条件としては、例えば、監視対象装置の状態情報であるCPU使用率やメモリ使用率であること(そのCPU使用率やメモリ使用率が所定の閾値を超えたことを示す情報であること)や、障害発生情報等であること等が設定される。
First, AP2 issues a reference query including a monitoring target device and monitoring conditions to the
For example, AP2 issues “SELECT * FROM eventTable WHERE host = '192.168.0.10';” as a reference query. Here, “host = '192.168.0.10'” represents an IP address for identifying the monitoring target device. This reference query means an acquisition request for information that matches a predetermined monitoring condition for the monitoring target device from “eventTable” that is a table stored in the
次に、仮想DBサーバ100は、クエリエンジン10により、受信したクエリを解析し、参照先(FROM句で与えられるテーブル)に応じたアダプタ30を決定する。ここでは、仮想DBサーバ100は、FROM句で与えられる「eventTable」に対応するアダプタ30として、NE5用のアダプタ30Nが決定されたものとする。そして、仮想DBサーバ100は、WHERE句で与えられる監視対象装置と監視条件と含む監視対象情報を、決定したアダプタ30(30N)に送信する(ステップS31)。
Next, the
アダプタ30(30N)の仮想DB側IF部310Aは、監視対象情報を受信すると、その監視対象情報を、通知受付部320Aに出力する(ステップS32)。通知受付部320Aは、監視対象情報を取得すると、その監視対象情報に含まれる監視対象装置および監視対象条件を登録することにより、イベント通知の監視を開始する。
When receiving the monitoring target information, the virtual DB side IF
続いて、通知受付部320Aは、監視対象情報の登録完了メッセージを、仮想DB側IF部310Aに送信し(ステップS33)、仮想DB側IF部310Aが、仮想DBサーバ100のクエリ実行部13Aに、その登録完了メッセージを転送する(ステップS34)。そして、アダプタ30から登録完了メッセージを受信したクエリ実行部13Aは、クエリ実行の終了を示すクエリ実行終了メッセージをAP2へ送信する(ステップS35)。
Subsequently, the
次に、NE5により、イベント通知(図7において、「trap」と記載する。)が送信され、アダプタ30(30N)の通知受付部320Aがそのイベント通知(「trap」)を受け付ける(ステップS36)。通知受付部320Aは、イベント通知(「trap」)を受け付けると、登録した監視対象情報(監視対象装置および監視条件)に合致するか否かを判定し、合致する場合に、そのイベント通知(「trap」)を通知蓄積部315に出力し(ステップS37)、通知蓄積部315においてそのイベント通知(「trap」)が蓄積(記憶)される。
Next, an event notification (described as “trap” in FIG. 7) is transmitted by NE5, and the
一方、クエリ実行終了メッセージを受信したAP2は、フェッチによるイベント通知の情報(イベント情報)の読み出し要求を送信する(ステップS38)。仮想DBサーバ100のクエリ実行部13Aは、フェッチによる読み出し要求を受信すると、アダプタ30の仮想DB側IF部310Aに問い合わせを行い(ステップS39)、仮想DB側IF部310Aは、その問い合わせを通知蓄積部315に転送する(ステップS40)。
On the other hand, the
通知蓄積部315は、その問い合わせを受信した際に、対応するイベント通知(「trap」)を記憶している場合には、そのイベント通知(「trap」)を仮想DB側IF部310Aに送信する(ステップS41)。そして、仮想DB側IF部310Aは、そのイベント通知の情報(イベント情報)を仮想DBサーバ100のクエリ実行部13Aに送信する(ステップS42)。クエリ実行部13Aは、取得したイベント通知の情報(イベント情報)をフェッチによる読み出し処理としてAP2へ送信する(ステップS43)。このイベント通知の情報(イベント情報)を受信したAP2は、取得したイベント情報をGUI6に出力する(ステップS44)。
When the
そして、AP2は、繰り返しフェッチを実行することにより、ステップS38〜S44と同様の処理を行う。具体的には、アダプタ30は、ステップS45およびS46の処理によりイベント通知の情報(イベント情報)を通知蓄積部315に蓄積(記憶)し、AP2のフェッチ時に、仮想DBサーバ100のクエリ実行部13Aが、アダプタ30(仮想DB側IF部310A、通知蓄積部315)に問い合わせることにより、イベント情報を取得し、GUI6に出力することができる(ステップS47〜S53)。
And AP2 performs the process similar to step S38-S44 by performing repeatedly fetching. Specifically, the
一方、符号(A−1)に示すように、ステップS54〜S56の処理により、アダプタ30の通知蓄積部315に対し、フェッチ時に伴う問い合わせを行った場合に、通知蓄積部315がイベント通知(「trap」)を記憶していなかったときには、通知蓄積部315は、仮想DB側IF部310Aに対し「null」を送信する(ステップS57)。「null」を受信した仮想DB側IF部310Aは、その「null」を仮想DBサーバ100のクエリ実行部13Aに送信し(ステップS58)、クエリ実行部13Aが、フェッチに対する応答として「null」をAP2へ送信する(ステップS59)。
On the other hand, as indicated by reference numeral (A-1), when an inquiry accompanying the fetch is made to the
また、AP2は、アダプタ30(30N)による監視を、例えば、exitメッセージを仮想DBシステム1000Aに送信することにより終了させることができる(ステップS60〜S62)。
Further, the
このように、本発明の第2の実施形態に係る仮想DBシステム1000A、および、仮想DBシステムの情報処理方法によれば、データソースから発信されたイベント通知を、フェッチ時に仮想DBサーバ100がアダプタ30から取得し、AP2からの参照クエリに対する応答として、そのAP2に送信することができる。よって、従来のDBやファイル等の静的なデータソースに加えて、イベント通知を送信するような動的なデータソース(NE5等)を含めて仮想DBシステム1000に統合し情報処理することができる。
As described above, according to the virtual DB system 1000A and the information processing method of the virtual DB system according to the second embodiment of the present invention, the
<第2の実施形態の変形例>
第2の実施形態に係る仮想DBシステム1000Aにおいては、図7の符号(A−1)に示すように、アダプタ30の通知蓄積部315が、イベント通知(「trap」)を記憶していなかった場合には、「null」を仮想DBサーバ100およびAP2側に送信していた。これに対し、第2の実施形態の変形例として、通知蓄積部315が、仮想DBサーバ100からの問い合わせを受信したときに、イベント通知(「trap」)を記憶していなかった場合、NE5からのイベント通知(「trap」)を通知受付部320Aが受け付け、通知蓄積部315に記憶されるまで待機するようにしてもよい。この場合、図8の符号(A−2)に示すように、ステップS70〜S72の処理により、問い合わせを受信したアダプタ30の通知蓄積部315は、「null」を送信するのではなく、次のイベント通知(「trap」)を通知受付部320Aが受け付けて、通知蓄積部315自身が記憶するまで待機する。そして、イベント通知(「trap」)を受信し記憶したことを契機として(ステップS73、S74)、通知蓄積部315が、そのイベント通知(「trap」)を仮想DB側IF部310Aに送信し、仮想DBサーバ100のクエリ実行部13Aを介して、AP2へ送信するようにしてもよい(ステップS75〜S77)。
<Modification of Second Embodiment>
In the virtual DB system 1000A according to the second embodiment, the
このようにすることにより、仮想DBシステム1000Aは、アダプタ30の通知蓄積部315にイベント通知(「trap」)が記憶されていない場合の無駄となる処理(図7のステップS54〜S59の処理)をなくすことができる。よって、仮想DBサーバ100およびAP2の処理負荷を低減することができる。
By doing so, the virtual DB system 1000A causes a wasteful process when the event notification (“trap”) is not stored in the
また、第2の実施形態のその他の変形例として、例えば、以下のようにすることもできる。第2の実施形態に係る仮想DBシステム1000Aにおいては、図7に示すように、AP2からのフェッチを仮想DBサーバ100が受信する度に、仮想DBサーバ100がアダプタ30の通知蓄積部315に対して問い合わせを行うようにしていた(例えば、ステップS38〜S40)。これに対し、他の変形例として、仮想DBサーバ100がフェッチの受信の度に問い合わせを行うのではなく、仮想DBサーバ100のクエリ実行部13Aが、所定の時間間隔で、通知蓄積部315に問い合わせを行い、その問い合わせの際に、イベント通知の情報(イベント情報)を取得し仮想DBサーバ100内に記憶しておくようにしてもよい。このようにすることにより、仮想DBサーバ100は、AP2からのフェッチの受信時に、アダプタ30に問い合わせることなく、自身に記憶されたイベント情報を、AP2に送信することができる。
Moreover, as another modification of 2nd Embodiment, it can also be performed as follows, for example. In the virtual DB system 1000A according to the second embodiment, as shown in FIG. 7, every time the
以上説明したように、本実施形態に係る仮想DBシステム1000(1000A)、および、仮想DBシステムの情報処理方法によれば、従来のDBやファイル等の静的なデータソースに加えて、イベント通知を送信するような動的なデータソース(NE5等)を含めて仮想DBに統合し情報処理することができる。
また、従来の仮想DBと同様に、AP2からの参照クエリに対する応答として、動的なデータソースからのイベント通知をAP2に送信できるようにしたことにより、AP2の変更を極力なくすことができ、データソースからのイベント通知を従来のDBアクセスと同様に扱うことができる。さらに、仮想DBサーバ100の構成を変更せず、アダプタ30にイベント通知処理部300を備える構成としたことにより、従来の仮想DBサーバ100の改編を行うことなく、データソースからのイベント通知を扱うことができる。
As described above, according to the virtual DB system 1000 (1000A) and the information processing method of the virtual DB system according to the present embodiment, in addition to the conventional static data source such as DB and file, event notification Including a dynamic data source (such as NE5) that transmits information, it can be integrated into a virtual DB for information processing.
In addition, as in the case of the conventional virtual DB, the event notification from the dynamic data source can be transmitted to AP2 as a response to the reference query from AP2, so that the change of AP2 can be eliminated as much as possible. Event notification from the source can be handled in the same way as conventional DB access. Further, the event
1,1000,1000A 仮想DBシステム
2 AP(クライアントAP)
3 DB
4 ファイル(ファイルシステム)
5 NE
6 GUI
10 クエリエンジン
11 クエリ解析・書換部
12 クエリ最適化部
13,13A クエリ実行部
20 スキーマ・ルール格納部
30 アダプタ
100 仮想DBサーバ
300,300A イベント通知処理部
310,310A 仮想DB側IF部
315 通知蓄積部
320,320A 通知受付部
1,1000,1000A
3 DB
4 files (file system)
5 NE
6 GUI
DESCRIPTION OF SYMBOLS 10
Claims (6)
複数の前記データソースには、前記データソース自身のイベント発生時に、イベント通知を発信する機能を備えた前記データソースが含まれており、
前記仮想DBサーバは、前記クライアントAPから監視対象となる前記データソースの識別情報と監視条件とを含む監視対象情報が記載された参照クエリを受信し、前記参照クエリを実行することにより、前記監視対象情報で示される特定のデータソースに対応するアダプタに、前記監視対象情報を送信するクエリ実行部を備え、
前記アダプタは、受信した前記監視対象情報で示される前記特定のデータソースを監視対象として登録し、前記特定のデータソースから前記イベント通知を受け取ると、前記仮想DBサーバに前記監視条件に合致する当該イベント通知の情報を送信するイベント通知処理部を備え、
前記仮想DBサーバのクエリ実行部は、
前記参照クエリを実行することにより、前記特定のデータソースに対応するアダプタから前記監視条件に合致する前記イベント通知の情報を取得しておき、前記参照クエリの実行を終了し、
前記参照クエリのデータ読み出し処理であるフェッチ時に、前記クライアントAPへ前記取得したイベント通知の情報を送信すること
を特徴とする仮想DBシステム。 A virtual DB (DataBase) server that integrates a plurality of data sources to process information between each of the plurality of data sources and a client AP (Application), and a plurality of the data sources connected to the virtual DB server A virtual DB system comprising: an adapter that transmits and receives information to and from each of the plurality of data sources and is provided in association with each of the data sources;
The plurality of data sources include the data source having a function of sending an event notification when an event of the data source itself occurs,
The virtual DB server receives a reference query in which monitoring target information including identification information and monitoring conditions of the data source to be monitored is described from the client AP, and executes the reference query to thereby execute the monitoring the adapter corresponding to a particular data source indicated by the target information includes a query execution unit you send the monitoring target information,
When the adapter registers the specific data source indicated by the received monitoring target information as a monitoring target and receives the event notification from the specific data source, the adapter matches the monitoring condition to the virtual DB server. Bei example the event notification processing unit that transmits the information of the event notification,
The query execution unit of the virtual DB server
By executing the reference query, the event notification information that matches the monitoring condition is obtained from the adapter corresponding to the specific data source, and the execution of the reference query is terminated.
A virtual DB system , wherein the acquired event notification information is transmitted to the client AP at the time of fetching which is data reading processing of the reference query .
複数の前記データソースには、前記データソース自身のイベント発生時に、イベント通知を発信する機能を備えた前記データソースが含まれており、
前記仮想DBサーバは、前記クライアントAPから監視対象となる前記データソースの識別情報と監視条件とを含む監視対象情報が記載された参照クエリを受信し、前記参照クエリを実行することにより、前記監視対象情報で示される特定のデータソースに対応するアダプタに、前記監視対象情報を送信するクエリ実行部を備え、
前記アダプタは、受信した前記監視対象情報で示される前記特定のデータソースを監視対象として登録し、前記特定のデータソースから前記イベント通知を受け取るイベント通知処理部を備え、
前記アダプタの前記イベント通知処理部は、通知蓄積部を備えており、
前記特定のデータソースから前記イベント通知を受け取ると、前記監視条件に合致する当該イベント通知を前記通知蓄積部に記憶しておき、
前記仮想DBサーバのクエリ実行部は、
前記参照クエリを実行することにより、前記特定のデータソースに対応するアダプタに、前記特定のデータソースを監視対象として登録すると、前記参照クエリの実行を終了し、
前記参照クエリのデータ読み出し処理であるフェッチ時に、前記アダプタの通知蓄積部に問い合わせることにより、前記イベント通知の情報を取得し、前記クライアントAPへ前記取得したイベント通知の情報を送信すること
を特徴とする仮想DBシステム。 A virtual DB server that integrates a plurality of data sources and processes information between each of the plurality of data sources and the client AP, and information between each of the plurality of data sources connected to the virtual DB server. And an adapter provided in association with each of the plurality of data sources, and a virtual DB system comprising:
The plurality of data sources include the data source having a function of sending an event notification when an event of the data source itself occurs,
The virtual DB server receives a reference query in which monitoring target information including identification information and monitoring conditions of the data source to be monitored is described from the client AP, and executes the reference query to thereby execute the monitoring the adapter corresponding to a particular data source indicated by the target information includes a query execution unit you send the monitoring target information,
Said adapter, said particular data source is registered as a monitoring target, Bei example Louis event notification processing unit receive the event notification from the particular data source indicated by the monitoring target information received,
The event notification processing unit of the adapter includes a notification storage unit,
When the event notification is received from the specific data source, the event notification that matches the monitoring condition is stored in the notification storage unit,
The query execution unit of the virtual DB server
When the specific data source is registered as a monitoring target in the adapter corresponding to the specific data source by executing the reference query, the execution of the reference query is terminated.
At the time of fetch, which is data reading processing of the reference query, the event notification information is acquired by inquiring of the notification storage unit of the adapter, and the acquired event notification information is transmitted to the client AP. Virtual DB system to do.
を特徴とする請求項2に記載の仮想DBシステム。 The query execution unit of the virtual DB server corresponds to the specific data source when the notification storage unit does not store the event notification as a result of inquiring of the notification storage unit of the adapter at the time of the fetch. The virtual DB system according to claim 2 , wherein the adapter receives the event notification and waits until the event notification is stored in the notification storage unit.
複数の前記データソースには、前記データソース自身のイベント発生時に、イベント通知を発信する機能を備えた前記データソースが含まれており、
前記仮想DBサーバは、前記クライアントAPから監視対象となる前記データソースの識別情報と監視条件とを含む監視対象情報が記載された参照クエリを受信し、前記参照クエリを実行することにより、前記監視対象情報で示される特定のデータソースに対応するアダプタに、前記監視対象情報を送信し、
前記アダプタは、受信した前記監視対象情報で示される前記特定のデータソースを監視対象として登録し、前記特定のデータソースから前記イベント通知を受け取ると、前記仮想DBサーバに前記監視条件に合致する当該イベント通知の情報を送信し、
前記仮想DBサーバは、
前記参照クエリを実行することにより、前記特定のデータソースに対応するアダプタから前記監視条件に合致する前記イベント通知の情報を取得しておき、前記参照クエリの実行を終了し、
前記参照クエリのデータ読み出し処理であるフェッチ時に、前記クライアントAPへ前記取得したイベント通知の情報を送信すること
を特徴とする仮想DBシステムの情報処理方法。 A virtual DB server that integrates a plurality of data sources and processes information between each of the plurality of data sources and the client AP, and information between each of the plurality of data sources connected to the virtual DB server. An information processing method of a virtual DB system comprising: an adapter provided in association with each of the plurality of data sources,
The plurality of data sources include the data source having a function of sending an event notification when an event of the data source itself occurs,
The virtual DB server receives a reference query in which monitoring target information including identification information and monitoring conditions of the data source to be monitored is described from the client AP, and executes the reference query to thereby execute the monitoring The monitoring target information is transmitted to the adapter corresponding to the specific data source indicated by the target information,
When the adapter registers the specific data source indicated by the received monitoring target information as a monitoring target and receives the event notification from the specific data source, the adapter matches the monitoring condition to the virtual DB server. Send event notification information,
The virtual DB server is
By executing the reference query, the event notification information that matches the monitoring condition is obtained from the adapter corresponding to the specific data source, and the execution of the reference query is terminated.
An information processing method of a virtual DB system , wherein the acquired event notification information is transmitted to the client AP at the time of fetching which is data reading processing of the reference query .
複数の前記データソースには、前記データソース自身のイベント発生時に、イベント通知を発信する機能を備えた前記データソースが含まれており、
前記仮想DBサーバは、前記クライアントAPから監視対象となる前記データソースの識別情報と監視条件とを含む監視対象情報が記載された参照クエリを受信し、前記参照クエリを実行することにより、前記監視対象情報で示される特定のデータソースに対応するアダプタに、前記監視対象情報を送信し、
前記アダプタは、通知蓄積部を備えており、
受信した前記監視対象情報で示される前記特定のデータソースを監視対象として登録し、前記特定のデータソースから前記イベント通知を受け取ると、前記監視条件に合致する当該イベント通知を前記通知蓄積部に記憶しておき、
前記仮想DBサーバは、
前記参照クエリを実行することにより、前記特定のデータソースに対応するアダプタに、前記特定のデータソースを監視対象として登録すると、前記参照クエリの実行を終了し、
前記参照クエリのデータ読み出し処理であるフェッチ時に、前記アダプタの通知蓄積部に問い合わせることにより、前記イベント通知の情報を取得し、前記クライアントAPへ前記取得したイベント通知の情報を送信すること
を特徴とする仮想DBシステムの情報処理方法。 A virtual DB server that integrates a plurality of data sources and processes information between each of the plurality of data sources and the client AP, and information between each of the plurality of data sources connected to the virtual DB server. An information processing method of a virtual DB system comprising: an adapter provided in association with each of the plurality of data sources,
The plurality of data sources include the data source having a function of sending an event notification when an event of the data source itself occurs,
The virtual DB server receives a reference query in which monitoring target information including identification information and monitoring conditions of the data source to be monitored is described from the client AP, and executes the reference query to thereby execute the monitoring The monitoring target information is transmitted to the adapter corresponding to the specific data source indicated by the target information,
The adapter includes a notification storage unit,
When the specific data source indicated by the received monitoring target information is registered as a monitoring target and the event notification is received from the specific data source, the event notification that matches the monitoring condition is stored in the notification storage unit. Aside,
The virtual DB server is
When the specific data source is registered as a monitoring target in the adapter corresponding to the specific data source by executing the reference query, the execution of the reference query is terminated.
At the time of fetch, which is data reading processing of the reference query, the event notification information is acquired by inquiring of the notification storage unit of the adapter, and the acquired event notification information is transmitted to the client AP. Information processing method for virtual DB system.
を特徴とする請求項5に記載の仮想DBシステムの情報処理方法。 When the virtual DB server makes an inquiry to the notification storage unit of the adapter at the time of the fetch, and the notification storage unit does not store the event notification, the adapter corresponding to the specific data source displays the event The virtual DB system information processing method according to claim 5 , wherein a notification is received and the system waits until the event notification is stored in the notification storage unit.
Priority Applications (1)
Application Number | Priority Date | Filing Date | Title |
---|---|---|---|
JP2014110806A JP6200377B2 (en) | 2014-05-29 | 2014-05-29 | Virtual DB system and information processing method for virtual DB system |
Applications Claiming Priority (1)
Application Number | Priority Date | Filing Date | Title |
---|---|---|---|
JP2014110806A JP6200377B2 (en) | 2014-05-29 | 2014-05-29 | Virtual DB system and information processing method for virtual DB system |
Publications (2)
Publication Number | Publication Date |
---|---|
JP2015225563A JP2015225563A (en) | 2015-12-14 |
JP6200377B2 true JP6200377B2 (en) | 2017-09-20 |
Family
ID=54842241
Family Applications (1)
Application Number | Title | Priority Date | Filing Date |
---|---|---|---|
JP2014110806A Active JP6200377B2 (en) | 2014-05-29 | 2014-05-29 | Virtual DB system and information processing method for virtual DB system |
Country Status (1)
Country | Link |
---|---|
JP (1) | JP6200377B2 (en) |
Family Cites Families (4)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
JP3874580B2 (en) * | 1999-09-29 | 2007-01-31 | 株式会社日立製作所 | Database integration system |
JP4656865B2 (en) * | 2004-06-15 | 2011-03-23 | 株式会社エヌ・ティ・ティ・ドコモ | Distributed processing system and file update method |
JP4808409B2 (en) * | 2005-01-14 | 2011-11-02 | 株式会社日立製作所 | Sensor network system, sensor data search method and program |
US8065365B2 (en) * | 2007-05-02 | 2011-11-22 | Oracle International Corporation | Grouping event notifications in a database system |
-
2014
- 2014-05-29 JP JP2014110806A patent/JP6200377B2/en active Active
Also Published As
Publication number | Publication date |
---|---|
JP2015225563A (en) | 2015-12-14 |
Similar Documents
Publication | Publication Date | Title |
---|---|---|
US11249728B2 (en) | System and method for generating an application structure for an application in a computerized organization | |
US20220107917A1 (en) | Generating target application packages for groups of computing devices | |
US11036754B2 (en) | Database table conversion | |
RU2531572C2 (en) | Database replication method and table updating apparatus | |
US11159390B2 (en) | Systems and methods for service-aware mapping of a system infrastructure | |
US11343355B1 (en) | Automated mapping of multi-tier applications in a distributed system | |
RU2607991C2 (en) | Method and system for service inspection and computer-readable storage medium thereof | |
WO2013063950A1 (en) | Inspection method and system of multimode communication device | |
WO2016074412A1 (en) | Compatibility administration method based on network configuration protocol, storage medium and device | |
JP6200377B2 (en) | Virtual DB system and information processing method for virtual DB system | |
JP6022409B2 (en) | Virtual DB system and information processing method for virtual DB system | |
JP5402066B2 (en) | Information search system, information search device, information search program, and information search method | |
US7155503B2 (en) | Data server | |
CN113486024B (en) | Data dictionary information transmission method and device, storage medium and electronic equipment | |
KR20120118866A (en) | An interface construction system and method to control low-erformance equipment using web technology | |
CN119311937A (en) | Remote collection method, system, computer device and storage medium for equipment information | |
JP5874915B2 (en) | Data stream processing system, management apparatus, data stream processing method, and computer program | |
WO2025017672A1 (en) | A system and method for processing a query | |
CN119383071A (en) | A management method, device and medium for cross-brand switch equipment | |
CN112181937A (en) | Data transmission method and device | |
JP2009169773A (en) | Image data management system |
Legal Events
Date | Code | Title | Description |
---|---|---|---|
A621 | Written request for application examination |
Free format text: JAPANESE INTERMEDIATE CODE: A621 Effective date: 20160722 |
|
A977 | Report on retrieval |
Free format text: JAPANESE INTERMEDIATE CODE: A971007 Effective date: 20170531 |
|
A131 | Notification of reasons for refusal |
Free format text: JAPANESE INTERMEDIATE CODE: A131 Effective date: 20170613 |
|
A521 | Written amendment |
Free format text: JAPANESE INTERMEDIATE CODE: A523 Effective date: 20170807 |
|
TRDD | Decision of grant or rejection written | ||
A01 | Written decision to grant a patent or to grant a registration (utility model) |
Free format text: JAPANESE INTERMEDIATE CODE: A01 Effective date: 20170822 |
|
A61 | First payment of annual fees (during grant procedure) |
Free format text: JAPANESE INTERMEDIATE CODE: A61 Effective date: 20170825 |
|
R150 | Certificate of patent or registration of utility model |
Ref document number: 6200377 Country of ref document: JP Free format text: JAPANESE INTERMEDIATE CODE: R150 |