JPH03208143A - 分散データベース処理装置 - Google Patents
分散データベース処理装置Info
- Publication number
- JPH03208143A JPH03208143A JP2002450A JP245090A JPH03208143A JP H03208143 A JPH03208143 A JP H03208143A JP 2002450 A JP2002450 A JP 2002450A JP 245090 A JP245090 A JP 245090A JP H03208143 A JPH03208143 A JP H03208143A
- Authority
- JP
- Japan
- Prior art keywords
- query
- processing device
- partial
- database processing
- execution
- 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.)
- Pending
Links
- 238000012545 processing Methods 0.000 claims abstract description 76
- 238000004891 communication Methods 0.000 claims abstract description 13
- 238000005457 optimization Methods 0.000 description 10
- 238000010586 diagram Methods 0.000 description 9
- 238000000034 method Methods 0.000 description 5
- 238000012546 transfer Methods 0.000 description 3
- 230000000694 effects Effects 0.000 description 2
- 238000007796 conventional method Methods 0.000 description 1
- 238000012986 modification Methods 0.000 description 1
- 230000004048 modification Effects 0.000 description 1
Landscapes
- Information Retrieval, Db Structures And Fs Structures Therefor (AREA)
Abstract
(57)【要約】本公報は電子出願前の出願データであるた
め要約のデータは記録されません。
め要約のデータは記録されません。
Description
【発明の詳細な説明】
（産業上の利用分野）
本発明は、関係型分散データベース処理装置に関し、特
に複数の関係データベース処理装置間での最適化処理を
行なわずに問い合わせ処理の応答時間を最小にする分散
データベース処理装置に関する。
に複数の関係データベース処理装置間での最適化処理を
行なわずに問い合わせ処理の応答時間を最小にする分散
データベース処理装置に関する。
（従来の技術）
従来、関係型データベース処理装置（以下、ＲＤＢＭＳ
と略称する。）は、非手続的な問い合わせ要求を、手続
的な処理シーケンスに変換する必要があった。しかし、
一般に１つの問い合わせ要求を実行する手続的な処理シ
ーケンスは複数ある。
と略称する。）は、非手続的な問い合わせ要求を、手続
的な処理シーケンスに変換する必要があった。しかし、
一般に１つの問い合わせ要求を実行する手続的な処理シ
ーケンスは複数ある。
そこで、複数の代替案から実行に必要なコストを評価し
て、コスト最小の代替案を見付け出す処理、つまり問い
合わせの最適化処理が必要であった。
て、コスト最小の代替案を見付け出す処理、つまり問い
合わせの最適化処理が必要であった。
特に複数の計算機が通信装置によって接続されており、
各々の計算機がＲＤＢＭＳを有し、各ＲＤＢＭＳが各々
データベースを管理し、かつその複数のデータベース内
のりレーション（関係型分散データベース処理装置にお
けるファイルに相当するもの）間の関係演算を許す分散
データベース処理装置では、従来各ＲＤＢＭＳ間での問
い合わせの最適化処理が必要であった。このような各Ｒ
ＤＢＭＳ間での問い合わせの最適化処理を、特に分散問
い合わせの最適化処理という。
各々の計算機がＲＤＢＭＳを有し、各ＲＤＢＭＳが各々
データベースを管理し、かつその複数のデータベース内
のりレーション（関係型分散データベース処理装置にお
けるファイルに相当するもの）間の関係演算を許す分散
データベース処理装置では、従来各ＲＤＢＭＳ間での問
い合わせの最適化処理が必要であった。このような各Ｒ
ＤＢＭＳ間での問い合わせの最適化処理を、特に分散問
い合わせの最適化処理という。
従来の分散データベース処理装置における分散問い合わ
せ最適化処理を要約すると、以下のようになる。
せ最適化処理を要約すると、以下のようになる。
（１）問い合わせをＲＤＢＭＳがまとまって処理できる
部分問い合わせに分割する。
部分問い合わせに分割する。
（２）可能な部分問い合わせの実行順序を生戊する。
（３）各部分問い合わせ実行順序に対し、各ＲＤＢＭＳ
が部分問い合わせを実行した場合、実行に要する時間と
応答されるレコード数を予測し、次に全レコードの転送
にかかる時間を予測する。次に全てのＲＤＢＭＳについ
て、部分問い合わせの実行時間と転送時間とを合計し、
分散問い合わせの各部分問い合わせ実行順序の実行時間
を夫々予測する。
が部分問い合わせを実行した場合、実行に要する時間と
応答されるレコード数を予測し、次に全レコードの転送
にかかる時間を予測する。次に全てのＲＤＢＭＳについ
て、部分問い合わせの実行時間と転送時間とを合計し、
分散問い合わせの各部分問い合わせ実行順序の実行時間
を夫々予測する。
（４）各問い合わせ実行順序の実行時間を比較し、応答
時間が最小になる部分問い合わせ実行順序を選択する。
時間が最小になる部分問い合わせ実行順序を選択する。
（発明が解決しようとする課題）
しかしながら、上述した従来の分散データベース処理装
置においては、各ＲＤＢＭＳが部分問い合わせを実行す
る時間、及び次のＲＤＢＭＳにレコードを送るのに必要
な時間を予測するためには、その部分問い合わせの実行
によって出力されるレコード数を予測しなければならな
い。この予測は、通常、部分問い合わせに関係するりレ
ーションの、レコート数や検索条件に使用される、属性
のデータの分布等の情報が必要である。
置においては、各ＲＤＢＭＳが部分問い合わせを実行す
る時間、及び次のＲＤＢＭＳにレコードを送るのに必要
な時間を予測するためには、その部分問い合わせの実行
によって出力されるレコード数を予測しなければならな
い。この予測は、通常、部分問い合わせに関係するりレ
ーションの、レコート数や検索条件に使用される、属性
のデータの分布等の情報が必要である。
常に更新されているリレーションにおいて、分散問い合
わせ最適化処理に必要な情報を正確に得ることは非常に
困難である。従って、最適化した結果がいつも正しいと
は限らず、かえって実行が遅くなってしまうという問題
点があった。
わせ最適化処理に必要な情報を正確に得ることは非常に
困難である。従って、最適化した結果がいつも正しいと
は限らず、かえって実行が遅くなってしまうという問題
点があった。
そこで、本発明の目的は、上述した問題点を解決し、従
来の如き分散問い合わせの最適化処理を予めせずに、常
に最適な分散問い合わせ処理をすることができる分散デ
ータベース処理装置を提供することにある。
来の如き分散問い合わせの最適化処理を予めせずに、常
に最適な分散問い合わせ処理をすることができる分散デ
ータベース処理装置を提供することにある。
（課題を解決するための手段）
本発明は、複数のデータベース処理装置が回報通信装置
に接続されてなる分散データベース処理装置において、
各前記データベース処理装置は、入力される問い合わせ
等の要求を受け付ける問い合わせ受け付け手段と、この
問い合わせ受け付け手段にて分散問い合わせを受け付け
ると、前記データベース処理装置が格納している、リレ
ーションに関係する問い合わせから、前記分散問い合わ
せと等価な部分問い合わせ実行順序を１つ以上生成する
問い合わせ分割手段と、自分のあるいは他のデータベー
ス処理装置の問い合わせ分割手段からの出力に基づき該
当する部分問い合わせ実行順序中の自分のデータベース
処理装置にて処理すべき該当する部分問い合わせを実行
したり、他のデータベース処理装置からの出力に基づき
、前記他のデータベース処理装置の他のデータベースア
クセス手段の実行した部分問い合わせを含む１つ以上の
部分問い合わせ実行順序における前記実行した部分問い
合わせの次のステップとして自分のデータベース処理装
置にて処理すべき部分問い合わせを実行したりするデー
タベースアクセス手段と、自分のデータベース処理装置
の前記データベースアクセス手段による該当する部分問
い合わせ実行順序の自分のデータベース処理装置にて処
理すべき部分問い合わせの実行中に、他のデータベース
処理装置の他のデータベースアクセス手段による他の部
分問い合わせ実行順序の実行が早く終了したとき、前記
他の部分問い合わせ実行順序の実行が早く終了した前記
他のデータベース処理装置からの出力に基づき、自分の
データベースアクセス手段による前記該当する部分問い
合わせ実行順序の実行を抑止させるデータ検索キャンセ
ル手段とを備えてなるものである。
に接続されてなる分散データベース処理装置において、
各前記データベース処理装置は、入力される問い合わせ
等の要求を受け付ける問い合わせ受け付け手段と、この
問い合わせ受け付け手段にて分散問い合わせを受け付け
ると、前記データベース処理装置が格納している、リレ
ーションに関係する問い合わせから、前記分散問い合わ
せと等価な部分問い合わせ実行順序を１つ以上生成する
問い合わせ分割手段と、自分のあるいは他のデータベー
ス処理装置の問い合わせ分割手段からの出力に基づき該
当する部分問い合わせ実行順序中の自分のデータベース
処理装置にて処理すべき該当する部分問い合わせを実行
したり、他のデータベース処理装置からの出力に基づき
、前記他のデータベース処理装置の他のデータベースア
クセス手段の実行した部分問い合わせを含む１つ以上の
部分問い合わせ実行順序における前記実行した部分問い
合わせの次のステップとして自分のデータベース処理装
置にて処理すべき部分問い合わせを実行したりするデー
タベースアクセス手段と、自分のデータベース処理装置
の前記データベースアクセス手段による該当する部分問
い合わせ実行順序の自分のデータベース処理装置にて処
理すべき部分問い合わせの実行中に、他のデータベース
処理装置の他のデータベースアクセス手段による他の部
分問い合わせ実行順序の実行が早く終了したとき、前記
他の部分問い合わせ実行順序の実行が早く終了した前記
他のデータベース処理装置からの出力に基づき、自分の
データベースアクセス手段による前記該当する部分問い
合わせ実行順序の実行を抑止させるデータ検索キャンセ
ル手段とを備えてなるものである。
（作用）
データベース処理装置の問い合わせ受け付け手段により
分散問い合わせを受け付けると、そのデータベース処理
装置の問い合わせ分割手段は、分散問い合わせと等価な
部分問い合わせ実行順序を１つ以上生成する。データベ
ース処理装置のデータベースアクセス手段は、自分のあ
るいは他のデータベース処理装置の問い合わせ分割手段
からの出力に基づき該当する部分問い合わせ実行順序中
の自分のデータベース処理装置にて処理すべき該当する
部分問い合わせを実行する。
分散問い合わせを受け付けると、そのデータベース処理
装置の問い合わせ分割手段は、分散問い合わせと等価な
部分問い合わせ実行順序を１つ以上生成する。データベ
ース処理装置のデータベースアクセス手段は、自分のあ
るいは他のデータベース処理装置の問い合わせ分割手段
からの出力に基づき該当する部分問い合わせ実行順序中
の自分のデータベース処理装置にて処理すべき該当する
部分問い合わせを実行する。
次に、自分のデータベース処理装置のデータベースアク
セス手段による、該当する部分問い合わせ実行順序の自
分のデータベース処理装置にて処理すべき部分問い合わ
せの実行中に、他のデータベース処理装置の他のデータ
ベースアクセス手段による他の部分問い合わせ実行順序
の実行が早く終了したとき、前記他の部分問い合わせ実
行順序の実行が早く終了した他のデータベース処理装置
からの出力に基づき、自分のデータベース処理装置のデ
ータ検索キャンセル手段は、自分のデータベース処理装
置のデータベースアクセス手段による前記該当する部分
問い合わせ実行順序の実行を抑止させる。そして、自分
のデータベース処理装置のデータベースアクセス手段は
、他のデータペースアクセス手段による早く実行を終了
した部分問い合わせを含む１つ以上の部分問い合わせ実
行順序における、前記早く実行を終了した部分問い合わ
せの次のステップとして自分のデータベース処理装置に
て処理すべき部分問い合わせを実行する。
セス手段による、該当する部分問い合わせ実行順序の自
分のデータベース処理装置にて処理すべき部分問い合わ
せの実行中に、他のデータベース処理装置の他のデータ
ベースアクセス手段による他の部分問い合わせ実行順序
の実行が早く終了したとき、前記他の部分問い合わせ実
行順序の実行が早く終了した他のデータベース処理装置
からの出力に基づき、自分のデータベース処理装置のデ
ータ検索キャンセル手段は、自分のデータベース処理装
置のデータベースアクセス手段による前記該当する部分
問い合わせ実行順序の実行を抑止させる。そして、自分
のデータベース処理装置のデータベースアクセス手段は
、他のデータペースアクセス手段による早く実行を終了
した部分問い合わせを含む１つ以上の部分問い合わせ実
行順序における、前記早く実行を終了した部分問い合わ
せの次のステップとして自分のデータベース処理装置に
て処理すべき部分問い合わせを実行する。
このように、分散問い合わせについての複数の部分問い
合わせ実行順序を平行的に同時に実行し、早く終了した
部分問い合わせ実行順序の結果によって、他の部分問い
合わせの実行順序の実行を抑止させるようにしたので、
従来の如き予め行なっていた分散問い合わせの最適化処
理をせずに、常に最適な、レスポンスタイムの小さい分
散問い合わせ処理をすることができる。
合わせ実行順序を平行的に同時に実行し、早く終了した
部分問い合わせ実行順序の結果によって、他の部分問い
合わせの実行順序の実行を抑止させるようにしたので、
従来の如き予め行なっていた分散問い合わせの最適化処
理をせずに、常に最適な、レスポンスタイムの小さい分
散問い合わせ処理をすることができる。
（実施例）
次に本発明の実施例につき、図面を用いて説明する。
第ｌ図は、本発明による分散データベース処理装置の一
実施例を示すブロック図である。
実施例を示すブロック図である。
同図において、ＩＡ，ＩＢ，ＩＣは、夫々データベース
を管理する ＲＤＢＭＳである。これらのＲＤＢＭＳＩ
Ａ， ｌ Ｂ． Ｉ Ｃは回報通信手段７に接続
され、これにより分散データベース処理装置が構成され
ている。２Ａ，２Ｂ，２Ｃは、夫々データベースのユー
ザ又は自分のＲＤＢＭＳ以外の、他のＲＤＢＭＳからの
問い合わせ等の要求を受け付ける問い合わせ受け付け手
段である。また、問い合わせ受け付け手段２Ａ，２Ｂ，
２Ｃは、夫々問い合わせを唯一つ識別できる問い合わせ
識別番号を、受け付けた問い合わせに振り、更にその問
い合わせが分散問い合わせであるか否かを判定し、分散
問い合わせである場合には、その問い合わせを自分のＲ
ＤＢＭＳの問い合わせ分割手段に渡すようになっている
。問い合わせ分割手段３Ａ，３Ｂ，３Ｃは、夫々自分の
ＲＤＢＭＳの問い合わせ受け付け手段が受け付けた分散
問い合わせを、部分問い合わせに分割し、分散問い合わ
せと同じ結果を出力するｌつ以上の部分問い合わせ実行
順序を生成する問い合わせ分割手段である。ここに、分
散問い合わせとは、その中で検索するりレーションが複
数のＲＤＢＭＳに格納されているものである。また、部
分問い合わせとは、その中で検索するりレーションが１
つのＲＤＢＭＳに格納されているものである。また、部
分問い合わせの実行順序とは、複数の部分問い合わせの
実行順序が示されている部分問い合わせの集まりである
。
を管理する ＲＤＢＭＳである。これらのＲＤＢＭＳＩ
Ａ， ｌ Ｂ． Ｉ Ｃは回報通信手段７に接続
され、これにより分散データベース処理装置が構成され
ている。２Ａ，２Ｂ，２Ｃは、夫々データベースのユー
ザ又は自分のＲＤＢＭＳ以外の、他のＲＤＢＭＳからの
問い合わせ等の要求を受け付ける問い合わせ受け付け手
段である。また、問い合わせ受け付け手段２Ａ，２Ｂ，
２Ｃは、夫々問い合わせを唯一つ識別できる問い合わせ
識別番号を、受け付けた問い合わせに振り、更にその問
い合わせが分散問い合わせであるか否かを判定し、分散
問い合わせである場合には、その問い合わせを自分のＲ
ＤＢＭＳの問い合わせ分割手段に渡すようになっている
。問い合わせ分割手段３Ａ，３Ｂ，３Ｃは、夫々自分の
ＲＤＢＭＳの問い合わせ受け付け手段が受け付けた分散
問い合わせを、部分問い合わせに分割し、分散問い合わ
せと同じ結果を出力するｌつ以上の部分問い合わせ実行
順序を生成する問い合わせ分割手段である。ここに、分
散問い合わせとは、その中で検索するりレーションが複
数のＲＤＢＭＳに格納されているものである。また、部
分問い合わせとは、その中で検索するりレーションが１
つのＲＤＢＭＳに格納されているものである。また、部
分問い合わせの実行順序とは、複数の部分問い合わせの
実行順序が示されている部分問い合わせの集まりである
。
また、４Ａ，４Ｂ，４Ｃは、夫々後述するデータベース
アクセス手段が自分のデータベースを検索する動作をキ
ャンセルするデータ検索キャンセル手段である。また、
５Ａ，５Ｂ，５Ｃは、夫々そのＲＤＢＭＳが管理してい
るデータベースを検索又は更新するデータベースアクセ
ス手段である。また、６Ａ．６Ｂ及び６Ｃは、夫々ＲＤ
ＢＭＳ Ｉ Ａ ，ＩＢ及びＩＣが管理しているデータ
ベースである。
アクセス手段が自分のデータベースを検索する動作をキ
ャンセルするデータ検索キャンセル手段である。また、
５Ａ，５Ｂ，５Ｃは、夫々そのＲＤＢＭＳが管理してい
るデータベースを検索又は更新するデータベースアクセ
ス手段である。また、６Ａ．６Ｂ及び６Ｃは、夫々ＲＤ
ＢＭＳ Ｉ Ａ ，ＩＢ及びＩＣが管理しているデータ
ベースである。
なお、問い合わせ受け付け手段２Ａと問い合わせ分割手
段３Ａとデータ検索キャンセル手段４Ａとデータベース
アクセス手段５Ａは、 ＲＤＢＭＳＩ Ａを構成する。
段３Ａとデータ検索キャンセル手段４Ａとデータベース
アクセス手段５Ａは、 ＲＤＢＭＳＩ Ａを構成する。
問い合わせ受け付け手段２Ｂと問い合わせ分割手段３Ｂ
とデータ検索キャンセル手段４Ｂとデータベースアクセ
ス手段５Ｂは、 ＲＤＢＭ３１Ｂを構成する。問い合わ
せ受け付け手段２Ｃと問い合わせ分割手段３Ｃとデータ
検索キャンセル手段４Ｃとデータベースアクセス手段５
ＣはＲＤＢＭＳＩＣを構成する。
とデータ検索キャンセル手段４Ｂとデータベースアクセ
ス手段５Ｂは、 ＲＤＢＭ３１Ｂを構成する。問い合わ
せ受け付け手段２Ｃと問い合わせ分割手段３Ｃとデータ
検索キャンセル手段４Ｃとデータベースアクセス手段５
ＣはＲＤＢＭＳＩＣを構成する。
次に第１図において、分散問い合わせがどのように処理
されるかを、例によって説明する。なお、本実施例では
、第１図のＲＤＢＭＳＩ Ａ， Ｉ Ｂ及びＩＣには
、第２図に示す如く、夫々リレーションＲＡ，ＲＢ及び
ＲＣが格納されている。第３図は、分散問い合わせとそ
の部分問い合わせ実行順序の生戊を示す説明図であって
、同図（ａ）は分散問い合わせを示し、同図（ｂ）及び
（Ｃ）は夫々分散問い合わせと等価な部分問い合わせ実
行順序を示す。
されるかを、例によって説明する。なお、本実施例では
、第１図のＲＤＢＭＳＩ Ａ， Ｉ Ｂ及びＩＣには
、第２図に示す如く、夫々リレーションＲＡ，ＲＢ及び
ＲＣが格納されている。第３図は、分散問い合わせとそ
の部分問い合わせ実行順序の生戊を示す説明図であって
、同図（ａ）は分散問い合わせを示し、同図（ｂ）及び
（Ｃ）は夫々分散問い合わせと等価な部分問い合わせ実
行順序を示す。
ユーザから出された分散問い合わせは、ユーザが使用し
ている ＲＤＢＭＳの問い合わせ受け付け手段によって
受け付けられる。本例では、第３図（ａ）で示される分
散問い合わせがＲＤＢＭＳＩＡの問い合わせ受け付け手
段２Ａによって受け付けられる。ここで、第３図（ａ）
の分散問い合わせは、リレーションＲＡ，ＲＢ，ＲＣを
ジョイン（ＪＯＩＮ）する（結合演算する）ものである
。
ている ＲＤＢＭＳの問い合わせ受け付け手段によって
受け付けられる。本例では、第３図（ａ）で示される分
散問い合わせがＲＤＢＭＳＩＡの問い合わせ受け付け手
段２Ａによって受け付けられる。ここで、第３図（ａ）
の分散問い合わせは、リレーションＲＡ，ＲＢ，ＲＣを
ジョイン（ＪＯＩＮ）する（結合演算する）ものである
。
問い合わせ受け付け手段２Ａは、受け付けた問い合わせ
に、問い合わせを唯一つ識別できる問い合わせ識別番号
を振り、更に問い合わせが分散問い合わせであると判定
し、その分散問い合わせを、問い合わせ分割手段３Ａに
渡す。
に、問い合わせを唯一つ識別できる問い合わせ識別番号
を振り、更に問い合わせが分散問い合わせであると判定
し、その分散問い合わせを、問い合わせ分割手段３Ａに
渡す。
問い合わせ分割手段３Ａは、分割問い合わせを、部分問
い合わせに分割し、分散問い合わせと等価な部分問い合
わせ実行順序を１つ以上生或する。本例では、第３図（
ｂ）と第３図（Ｃ）の部分問い合わせ実行順序が生成さ
れる。ここで、第３図（ｂ）の部分問い合わせ実行順序
は、ＲＤＢＭＳＩ Ａ − ＲＤＢＭＳＩ Ｂ − Ｒ
ＤＢＭＳＩ Ｃの順である。第３図（ｂ）はＲＤＢＭＳ
ＩＡの部分問い合わせ（ＲＡ）の処理結果に、 ＲＤＢ
ＭＳＩ Ｂが部分問い合わせ（ＲＢ）を結合演算した後
、更にこの結合演算結果にＲＤＢＭＳＩＣにて部分問い
合わせ（ＲＣ）の結合演算するものである。また、第３
図（Ｃ）の部分問い合わせ実行順序は、ＲＤＢＭＳＩ
Ａ − ＲＤＢＭＳＩ Ｃ − ＲＤＢＭＳＩ Ｂの順
で、部分問い合わせを実行する場合である。第３図（Ｃ
）は、ＲＤＢＭＳ Ｉ Ａの部分問い合わせ（ＲＡ）の
処理結果に、ＲＤＢＭＳ１Ｃが部分問い合わせ（ＲＣ）
を結合演算（ジョイン）し、この結合演算結果に、 Ｒ
ＤＢＭＳＩ Ｂが部分問い合わせ（ＲＢ）を結合演算す
るものである。第３図（ｂ）と第３図（ｃ）の部分問い
合わせ実行順序では、共にＲＤＢＭＳＩＡが最初に部分
問い合わせ（ＲＡ）を実行しなければならないので、
ＲＤＢＭＳ Ｉ Ａのデータベースアクセス手段５Ａは
、問い合わせ（ＲＡ）を実行する。問い合わせ分割手段
３Ａは、１つ以上の部分問い合わせ実行順序、本例では
、第３図（ｂ）と第３図（Ｃ）の部分問い合わせ実行順
序に、それと等価な分散問い合わせに振られた問い合わ
せ識別番号を付加して、第４図（ａ）に例示するように
１つのメッセージによって、各部分問い合わせ実行手順
とＯ以上の検索結果（本例では、ＲＤＢＭＳ Ｉ Ａの
データベースアクセス手段５Ａによる部分問い合わせ（
ＲＡ）の実行結果）を、次に実行するＲＤＢＭＳＩＢ，
１．Ｃに回報通信手段７を介して送る。同報通信手段７
は、前記メッセージを、本例では、ＲＤＢＭＳＩ Ｂ
， Ｉ Ｃに送る， ＲＤＢＭＳＩ Ｂは、前記メ
ッセージにより、第３図（ｂ）の部分問い合わせの実行
順序と ＲＤＢＭＳ Ｉ Ａによる部分問い合わせ（Ｒ
Ａ）検索結果などを知る。ＲＤＢＭＳＩＣは、前記メッ
セージにより、第３図（Ｃ）の部分問い合わせの実行順
序とＲＤＢＭＳＩ Ａによる部分問い合わせ（ＲＡ）検
索結果などを知る。
い合わせに分割し、分散問い合わせと等価な部分問い合
わせ実行順序を１つ以上生或する。本例では、第３図（
ｂ）と第３図（Ｃ）の部分問い合わせ実行順序が生成さ
れる。ここで、第３図（ｂ）の部分問い合わせ実行順序
は、ＲＤＢＭＳＩ Ａ − ＲＤＢＭＳＩ Ｂ − Ｒ
ＤＢＭＳＩ Ｃの順である。第３図（ｂ）はＲＤＢＭＳ
ＩＡの部分問い合わせ（ＲＡ）の処理結果に、 ＲＤＢ
ＭＳＩ Ｂが部分問い合わせ（ＲＢ）を結合演算した後
、更にこの結合演算結果にＲＤＢＭＳＩＣにて部分問い
合わせ（ＲＣ）の結合演算するものである。また、第３
図（Ｃ）の部分問い合わせ実行順序は、ＲＤＢＭＳＩ
Ａ − ＲＤＢＭＳＩ Ｃ − ＲＤＢＭＳＩ Ｂの順
で、部分問い合わせを実行する場合である。第３図（Ｃ
）は、ＲＤＢＭＳ Ｉ Ａの部分問い合わせ（ＲＡ）の
処理結果に、ＲＤＢＭＳ１Ｃが部分問い合わせ（ＲＣ）
を結合演算（ジョイン）し、この結合演算結果に、 Ｒ
ＤＢＭＳＩ Ｂが部分問い合わせ（ＲＢ）を結合演算す
るものである。第３図（ｂ）と第３図（ｃ）の部分問い
合わせ実行順序では、共にＲＤＢＭＳＩＡが最初に部分
問い合わせ（ＲＡ）を実行しなければならないので、
ＲＤＢＭＳ Ｉ Ａのデータベースアクセス手段５Ａは
、問い合わせ（ＲＡ）を実行する。問い合わせ分割手段
３Ａは、１つ以上の部分問い合わせ実行順序、本例では
、第３図（ｂ）と第３図（Ｃ）の部分問い合わせ実行順
序に、それと等価な分散問い合わせに振られた問い合わ
せ識別番号を付加して、第４図（ａ）に例示するように
１つのメッセージによって、各部分問い合わせ実行手順
とＯ以上の検索結果（本例では、ＲＤＢＭＳ Ｉ Ａの
データベースアクセス手段５Ａによる部分問い合わせ（
ＲＡ）の実行結果）を、次に実行するＲＤＢＭＳＩＢ，
１．Ｃに回報通信手段７を介して送る。同報通信手段７
は、前記メッセージを、本例では、ＲＤＢＭＳＩ Ｂ
， Ｉ Ｃに送る， ＲＤＢＭＳＩ Ｂは、前記メ
ッセージにより、第３図（ｂ）の部分問い合わせの実行
順序と ＲＤＢＭＳ Ｉ Ａによる部分問い合わせ（Ｒ
Ａ）検索結果などを知る。ＲＤＢＭＳＩＣは、前記メッ
セージにより、第３図（Ｃ）の部分問い合わせの実行順
序とＲＤＢＭＳＩ Ａによる部分問い合わせ（ＲＡ）検
索結果などを知る。
次に、部分問い合わせ実行順序を回報通信手段７を介し
てＲＤＢＭＳ Ｉ Ａより受けたＲＤＢＭＳ、本例では
ＲＤＢＭ３１Ｂ ， Ｉ Ｃの問い合わせ受け付け手
段２Ｂ，２Ｃは、データベースアクセス手段３Ｂ，３Ｃ
によってそのＲＤＢＭＳＩ Ｂ ， Ｉ Ｃに関連す
る部分問い合わせを実行した結果と、第３図（ｂ）（Ｃ
）に示す部分問い合わせ実行順序を記入した第４図（ｂ
），（Ｃ）に示すようなメッセージを、次に実行する
ＲＤＢＭＳに、本例ではＲＤＢＭＳＩＣ，ＩＢに同報通
信手段７を介して転送する。
てＲＤＢＭＳ Ｉ Ａより受けたＲＤＢＭＳ、本例では
ＲＤＢＭ３１Ｂ ， Ｉ Ｃの問い合わせ受け付け手
段２Ｂ，２Ｃは、データベースアクセス手段３Ｂ，３Ｃ
によってそのＲＤＢＭＳＩ Ｂ ， Ｉ Ｃに関連す
る部分問い合わせを実行した結果と、第３図（ｂ）（Ｃ
）に示す部分問い合わせ実行順序を記入した第４図（ｂ
），（Ｃ）に示すようなメッセージを、次に実行する
ＲＤＢＭＳに、本例ではＲＤＢＭＳＩＣ，ＩＢに同報通
信手段７を介して転送する。
このメッセージにより、 ＲＤＢＭＳＩ Ｃは、 ＲＤ
ＢＭＳＩＢのデータベースアクセス手段５Ｂによる検索
結果（ ＲＤＢＭＳＩ Ａの部分問い合わせ（ＲＡ）の
処理結果に、 ＲＤＢＭＳＩＢが部分問い合わせ（ＲＢ
）を結合演算したもの）と第３図（ｂ）の部分問い合わ
せ実行順序などを知る。また、ＲＤＢＭＳＩ Ｂは、Ｒ
ＤＢＭＳＩＣのデータベースアクセス手段５Ｃによる検
索結果（ ＲＤＢＭＳＩ Ａの部分問い合わせ（ＲＡ）
の処理結果に、 ＲＤＢＭＳＩＣが部分問い合わせ（Ｒ
Ｃ）を結合演算したもの）と第３図（ｃ）の部分問い合
わせ実行順序などを知る。
ＢＭＳＩＢのデータベースアクセス手段５Ｂによる検索
結果（ ＲＤＢＭＳＩ Ａの部分問い合わせ（ＲＡ）の
処理結果に、 ＲＤＢＭＳＩＢが部分問い合わせ（ＲＢ
）を結合演算したもの）と第３図（ｂ）の部分問い合わ
せ実行順序などを知る。また、ＲＤＢＭＳＩ Ｂは、Ｒ
ＤＢＭＳＩＣのデータベースアクセス手段５Ｃによる検
索結果（ ＲＤＢＭＳＩ Ａの部分問い合わせ（ＲＡ）
の処理結果に、 ＲＤＢＭＳＩＣが部分問い合わせ（Ｒ
Ｃ）を結合演算したもの）と第３図（ｃ）の部分問い合
わせ実行順序などを知る。
次に、自分のＲＤＢＭＳのデータベースアクセス手段に
よる、該当する部分問い合わせ実行順序の自分のＲＤＢ
ＭＳにて処理すべき部分問い合わせの実行中に、他のＲ
ＤＢＭＳの他のデータベースアクセス手段による他の部
分問い合わせ実行順序の実行が早く終了したとき、他の
部分問い合わせ実行順序の実行が早く終了した他のＲＤ
ＢＭＳからのメッセージに基づき、自分のＲＤＢＭＳの
データ検索キャンセル手段は、自分のＲＤＢＭＳのデー
タベースアクセス手段による前記該当する部分問い合わ
せ実行順序の実行を抑止させる（中断させる）。そして
、自分のＲＤＢＭＳのデータベースアクセス手段は、他
のデータベースアクセス手段による早く実行を終了した
部分問い合わせを含む１つ以上の部分問い合わせ実行順
序における、前記早く実行を終了した部分問い合わせの
次のステップとして自分のＲＤＢＭＳにて処理すべき部
分問い合わせを実行する。これについて第５図を用いて
本例の場合を説明する。なお、第５図は、第１図の動作
説明図であり、第５図（ａ）は、従来例を示し、第５図
（ｂ）は本発明の適用例を示し、第５図（ａ）．（ｂ）
において実線は分散データベース処理装置による実際の
処理を示す。
よる、該当する部分問い合わせ実行順序の自分のＲＤＢ
ＭＳにて処理すべき部分問い合わせの実行中に、他のＲ
ＤＢＭＳの他のデータベースアクセス手段による他の部
分問い合わせ実行順序の実行が早く終了したとき、他の
部分問い合わせ実行順序の実行が早く終了した他のＲＤ
ＢＭＳからのメッセージに基づき、自分のＲＤＢＭＳの
データ検索キャンセル手段は、自分のＲＤＢＭＳのデー
タベースアクセス手段による前記該当する部分問い合わ
せ実行順序の実行を抑止させる（中断させる）。そして
、自分のＲＤＢＭＳのデータベースアクセス手段は、他
のデータベースアクセス手段による早く実行を終了した
部分問い合わせを含む１つ以上の部分問い合わせ実行順
序における、前記早く実行を終了した部分問い合わせの
次のステップとして自分のＲＤＢＭＳにて処理すべき部
分問い合わせを実行する。これについて第５図を用いて
本例の場合を説明する。なお、第５図は、第１図の動作
説明図であり、第５図（ａ）は、従来例を示し、第５図
（ｂ）は本発明の適用例を示し、第５図（ａ）．（ｂ）
において実線は分散データベース処理装置による実際の
処理を示す。
本例では、ＲＤＢＭＳＩ ＢがＲＤＢＭＳＩＣよりも先
に第３図（ｂ）の部分問い合わせ実行順序の実行が早く
終了したとする。すると、部分問い合わせ実行順序の実
行を早く終了したＲＤＢＭＳＩＢの問い合わせ受け付け
手段２Ｂから、同報通信手段７を介してＲＤＢＭＳＩＣ
にＲＤＢＭＳＩ Ｃによる第３図（Ｃ）の部分問い合わ
せ実行順序を中断し、第３図（ｂ）の部分問い合わせ実
行順序における、次のステップの部分問い合わせ（ＲＣ
）を実行せよとのメッセージが送られてくる。このメッ
セージは、ＲＤＢＭＳＩＣの問い合わせ受け付け手段２
Ｃによって受け付けられる。そして、問い合わせ受け付
け手段２Ｃからの指示に基づき、データ検索キャンセル
手段４Ｃは、データベースアクセス手段５Ｃに対して実
行中であった第３図（ｃ）の部分問い合わせ実行順序の
実行を中断させた上で、第３図（ｂ）の部分問い合わせ
実行順序における、次のステップの部分問い合わせ（Ｒ
Ｃ）を実行させる。第５図では、部分問い合わせ実行順
序のが第３図（ｂ）の部分問い合わせ実行順序に相当し
、部分問い合わせ実行順序■が第３図（ｃ）の部分問い
合わせ実行順序に相当する。図示のａのステップでは、
部分問い合わせ実行順序のと■の部分問い合わせの実行
は同じであるが、図示のｂ．ｂ’のステップでは、ｂの
ステップに係る部分問い合わせ実行順序のが部分問い合
わせ実行順序■よりも早く実行を終了するので、ＲＤＢ
ＭＳＩ Ｃによる部分問い合わせ実行順序■の実行を中
断させ、部分問い合わせ実行順序■の次のステップＣ（
第３図（ｂ）の問い合わせＲＣに相当する。）を実行さ
せている。
に第３図（ｂ）の部分問い合わせ実行順序の実行が早く
終了したとする。すると、部分問い合わせ実行順序の実
行を早く終了したＲＤＢＭＳＩＢの問い合わせ受け付け
手段２Ｂから、同報通信手段７を介してＲＤＢＭＳＩＣ
にＲＤＢＭＳＩ Ｃによる第３図（Ｃ）の部分問い合わ
せ実行順序を中断し、第３図（ｂ）の部分問い合わせ実
行順序における、次のステップの部分問い合わせ（ＲＣ
）を実行せよとのメッセージが送られてくる。このメッ
セージは、ＲＤＢＭＳＩＣの問い合わせ受け付け手段２
Ｃによって受け付けられる。そして、問い合わせ受け付
け手段２Ｃからの指示に基づき、データ検索キャンセル
手段４Ｃは、データベースアクセス手段５Ｃに対して実
行中であった第３図（ｃ）の部分問い合わせ実行順序の
実行を中断させた上で、第３図（ｂ）の部分問い合わせ
実行順序における、次のステップの部分問い合わせ（Ｒ
Ｃ）を実行させる。第５図では、部分問い合わせ実行順
序のが第３図（ｂ）の部分問い合わせ実行順序に相当し
、部分問い合わせ実行順序■が第３図（ｃ）の部分問い
合わせ実行順序に相当する。図示のａのステップでは、
部分問い合わせ実行順序のと■の部分問い合わせの実行
は同じであるが、図示のｂ．ｂ’のステップでは、ｂの
ステップに係る部分問い合わせ実行順序のが部分問い合
わせ実行順序■よりも早く実行を終了するので、ＲＤＢ
ＭＳＩ Ｃによる部分問い合わせ実行順序■の実行を中
断させ、部分問い合わせ実行順序■の次のステップＣ（
第３図（ｂ）の問い合わせＲＣに相当する。）を実行さ
せている。
このようにすることにより、従来の如き、分散問い合わ
せのための最適化処理（第５図（ａ）のｄで示す。）を
せずに、常に最適な、レスポンスタイムの小さい分散問
い合わせ処理をすることができる。
せのための最適化処理（第５図（ａ）のｄで示す。）を
せずに、常に最適な、レスポンスタイムの小さい分散問
い合わせ処理をすることができる。
また、本発明では、同報通信手段７により同報通信機能
を用い、複数のＲＤＢＭＳに対する各々の部分問い合わ
せ実行手順と、その実行に必要な検索結果を、１つのメ
ッセージに重畳し同報によって送るので、第５図（ｂ）
に示すタイムチャートの如く、従来方式（第５図（ａ）
）と殆ど同じ通信コストで分散問い合わせが処理される
。
を用い、複数のＲＤＢＭＳに対する各々の部分問い合わ
せ実行手順と、その実行に必要な検索結果を、１つのメ
ッセージに重畳し同報によって送るので、第５図（ｂ）
に示すタイムチャートの如く、従来方式（第５図（ａ）
）と殆ど同じ通信コストで分散問い合わせが処理される
。
本発明は本実施例に限定されることなく、本発明の要旨
を逸脱しない範囲で種々の応用及び変形が考えられる。
を逸脱しない範囲で種々の応用及び変形が考えられる。
（発明の効果）
上述したように、本発明を用いれば、従来の如き、予め
行なっていた分散問い合わせの最適化処理をせずに、常
に最適なレスポンスタイムの小さい分散問い合わせ処理
をすることができるなどの効果を奏する。
行なっていた分散問い合わせの最適化処理をせずに、常
に最適なレスポンスタイムの小さい分散問い合わせ処理
をすることができるなどの効果を奏する。
【図面の簡単な説明】
第１図は本発明による分散データベース処理装置の一実
施例を示すブロック図、第２図は第１図のＲＤＢＭＳの
りレーション格納状態を示す図、第３図は分散問い合わ
せとその部分問い合わせ実行順序の生成を示す説明図、
第４図はメッセージ内容を示す説明図、第５図は第１図
の動作説明図である。 ＬＡ，ＩＢ，ＩＣ・・・ＲＤＢＭＳ， ２Ａ， ３Ａ ４Ａ， ５Ａ ６Ａ， ２ Ｂ ３Ｂ， ４Ｂ， ５Ｂ， ６ Ｂ ２Ｃ・・・問い合わせ受け付け手段、 ３Ｃ・・・問い合わせ分割手段、 ４Ｃ・・・データ検索キャンセル手段、５Ｃ・・・デー
タベースアクセス手段、６Ｃ・・・データベース。
施例を示すブロック図、第２図は第１図のＲＤＢＭＳの
りレーション格納状態を示す図、第３図は分散問い合わ
せとその部分問い合わせ実行順序の生成を示す説明図、
第４図はメッセージ内容を示す説明図、第５図は第１図
の動作説明図である。 ＬＡ，ＩＢ，ＩＣ・・・ＲＤＢＭＳ， ２Ａ， ３Ａ ４Ａ， ５Ａ ６Ａ， ２ Ｂ ３Ｂ， ４Ｂ， ５Ｂ， ６ Ｂ ２Ｃ・・・問い合わせ受け付け手段、 ３Ｃ・・・問い合わせ分割手段、 ４Ｃ・・・データ検索キャンセル手段、５Ｃ・・・デー
タベースアクセス手段、６Ｃ・・・データベース。
Claims (1)
- 【特許請求の範囲】 複数のデータベース処理装置が同報通信装置に接続され
てなる分散データベース処理装置において、 各前記データベース処理装置は、 入力される問い合わせ等の要求を受け付ける問い合わせ
受け付け手段と、 この問い合わせ受け付け手段にて分散問い合わせを受け
付けると、前記データベース処理装置が格納している、
リレーションに関係する問い合わせから、前記分散問い
合わせと等価な部分問い合わせ実行順序を１つ以上生成
する問い合わせ分割手段と、 自分のあるいは他のデータベース処理装置の問い合わせ
分割手段からの出力に基づき該当する部分問い合わせ実
行順序中の自分のデータベース処理装置にて処理すべき
該当する部分問い合わせを実行したり、他のデータベー
ス処理装置からの出力に基づき、前記他のデータベース
処理装置の他のデータベースアクセス手段の実行した部
分問い合わせを含む１つ以上の部分問い合わせ実行順序
における前記実行した部分問い合わせの次のステップと
して自分のデータベース処理装置にて処理すべき部分問
い合わせを実行したりするデータベースアクセス手段と
、 自分のデータベース処理装置の前記データベースアクセ
ス手段による該当する部分問い合わせ実行順序の自分の
データベース処理装置にて処理すべき部分問い合わせの
実行中に、他のデータベース処理装置の他のデータベー
スアクセス手段による他の部分問い合わせ実行順序の実
行が早く終了したとき、前記他の部分問い合わせ実行順
序の実行が早く終了した前記他のデータベース処理装置
からの出力に基づき、自分のデータベースアクセス手段
による前記該当する部分問い合わせ実行順序の実行を抑
止させるデータ検索キャンセル手段とを備えたことを特
徴とする分散データベース処理装置。
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| JP2002450A JPH03208143A (ja) | 1990-01-11 | 1990-01-11 | 分散データベース処理装置 |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| JP2002450A JPH03208143A (ja) | 1990-01-11 | 1990-01-11 | 分散データベース処理装置 |
Publications (1)
| Publication Number | Publication Date |
|---|---|
| JPH03208143A true JPH03208143A (ja) | 1991-09-11 |
Family
ID=11529620
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| JP2002450A Pending JPH03208143A (ja) | 1990-01-11 | 1990-01-11 | 分散データベース処理装置 |
Country Status (1)
| Country | Link |
|---|---|
| JP (1) | JPH03208143A (ja) |
Cited By (2)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US8055647B2 (en) | 2003-10-06 | 2011-11-08 | International Business Machines Corporation | System, method and program for database searching |
| JP2016091356A (ja) * | 2014-11-06 | 2016-05-23 | Kddi株式会社 | 仮想データベースシステム管理装置、管理方法及び管理プログラム |
-
1990
- 1990-01-11 JP JP2002450A patent/JPH03208143A/ja active Pending
Cited By (2)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US8055647B2 (en) | 2003-10-06 | 2011-11-08 | International Business Machines Corporation | System, method and program for database searching |
| JP2016091356A (ja) * | 2014-11-06 | 2016-05-23 | Kddi株式会社 | 仮想データベースシステム管理装置、管理方法及び管理プログラム |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| US7814042B2 (en) | Selecting candidate queries | |
| US7092954B1 (en) | Optimizing an equi-join operation using a bitmap index structure | |
| US7788243B2 (en) | System and methods for optimizing data transfer among various resources in a distributed environment | |
| US5864842A (en) | Optimization of SQL queries using hash star join operations | |
| US10635671B2 (en) | Sort-merge band join optimization | |
| US6684203B1 (en) | Using global temporary tables to transform queries | |
| US8996503B2 (en) | Query plan optimization for prepared SQL statements | |
| US7814091B2 (en) | Multi-tiered query processing techniques for minus and intersect operators | |
| US6850927B1 (en) | Evaluating queries with outer joins by categorizing and processing combinations of relationships between table records | |
| US8108375B2 (en) | Processing database queries by returning results of a first query to subsequent queries | |
| US20090119247A1 (en) | Efficient hash based full-outer join | |
| CN111767314A (zh) | 数据缓存及查询方法、装置、懒缓存系统及存储介质 | |
| US7840552B2 (en) | Cost-based subquery correlation and decorrelation | |
| US6938036B2 (en) | Query modification analysis | |
| CN114860764A (zh) | 分布式数据库查询的优化方法、系统及电子设备 | |
| US6470331B1 (en) | Very large table reduction in parallel processing database systems | |
| JP2006172067A (ja) | データベース管理方法、システム及びプログラム | |
| US9342545B2 (en) | Using a partially built index in a computer database system | |
| US20080263017A1 (en) | System for unordered relational database retrieval returning distinct values | |
| US7617189B2 (en) | Parallel query processing techniques for minus and intersect operators | |
| JPH03208143A (ja) | 分散データベース処理装置 | |
| JP3565117B2 (ja) | 複数異種情報源アクセス方法及びクライアント装置及び複数異種情報源アクセスプログラムを格納した記憶媒体 | |
| JP3712791B2 (ja) | データベース管理方法及びその情報処理装置 | |
| JPH0644309A (ja) | データベース管理方式 | |
| US7437347B1 (en) | Row redistribution in a relational database management system |