JPH0556541B2 - - Google Patents
Info
- Publication number
- JPH0556541B2 JPH0556541B2 JP60047452A JP4745285A JPH0556541B2 JP H0556541 B2 JPH0556541 B2 JP H0556541B2 JP 60047452 A JP60047452 A JP 60047452A JP 4745285 A JP4745285 A JP 4745285A JP H0556541 B2 JPH0556541 B2 JP H0556541B2
- Authority
- JP
- Japan
- Prior art keywords
- computer
- processing request
- processing
- join operation
- request
- 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.)
- Expired - Lifetime
Links
Classifications
-
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F16/00—Information retrieval; Database structures therefor; File system structures therefor
- G06F16/20—Information retrieval; Database structures therefor; File system structures therefor of structured data, e.g. relational data
- G06F16/24—Querying
- G06F16/245—Query processing
- G06F16/2458—Special types of queries, e.g. statistical queries, fuzzy queries or distributed queries
- G06F16/2471—Distributed queries
-
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F16/00—Information retrieval; Database structures therefor; File system structures therefor
- G06F16/20—Information retrieval; Database structures therefor; File system structures therefor of structured data, e.g. relational data
- G06F16/24—Querying
- G06F16/245—Query processing
- G06F16/2455—Query execution
- G06F16/24553—Query execution of query operations
- G06F16/24558—Binary matching operations
- G06F16/2456—Join operations
-
- Y—GENERAL TAGGING OF NEW TECHNOLOGICAL DEVELOPMENTS; GENERAL TAGGING OF CROSS-SECTIONAL TECHNOLOGIES SPANNING OVER SEVERAL SECTIONS OF THE IPC; TECHNICAL SUBJECTS COVERED BY FORMER USPC CROSS-REFERENCE ART COLLECTIONS [XRACs] AND DIGESTS
- Y10—TECHNICAL SUBJECTS COVERED BY FORMER USPC
- Y10S—TECHNICAL SUBJECTS COVERED BY FORMER USPC CROSS-REFERENCE ART COLLECTIONS [XRACs] AND DIGESTS
- Y10S707/00—Data processing: database and file management or data structures
- Y10S707/99931—Database or file accessing
- Y10S707/99932—Access augmentation or optimizing
-
- Y—GENERAL TAGGING OF NEW TECHNOLOGICAL DEVELOPMENTS; GENERAL TAGGING OF CROSS-SECTIONAL TECHNOLOGIES SPANNING OVER SEVERAL SECTIONS OF THE IPC; TECHNICAL SUBJECTS COVERED BY FORMER USPC CROSS-REFERENCE ART COLLECTIONS [XRACs] AND DIGESTS
- Y10—TECHNICAL SUBJECTS COVERED BY FORMER USPC
- Y10S—TECHNICAL SUBJECTS COVERED BY FORMER USPC CROSS-REFERENCE ART COLLECTIONS [XRACs] AND DIGESTS
- Y10S707/00—Data processing: database and file management or data structures
- Y10S707/99931—Database or file accessing
- Y10S707/99939—Privileged access
Landscapes
- Engineering & Computer Science (AREA)
- Theoretical Computer Science (AREA)
- Physics & Mathematics (AREA)
- General Physics & Mathematics (AREA)
- Databases & Information Systems (AREA)
- General Engineering & Computer Science (AREA)
- Data Mining & Analysis (AREA)
- Computational Linguistics (AREA)
- Fuzzy Systems (AREA)
- Mathematical Physics (AREA)
- Probability & Statistics with Applications (AREA)
- Software Systems (AREA)
- Information Retrieval, Db Structures And Fs Structures Therefor (AREA)
Description
【発明の詳細な説明】
（産業上の利用分野）
本発明は分散データベース管理システムにおい
て、関係データベースの結合演算を高速に行うこ
とができる結合演算処理方式に関するものであ
る。
て、関係データベースの結合演算を高速に行うこ
とができる結合演算処理方式に関するものであ
る。
（従来の技術）
一般的な分散データベース管理システムでは種
種の通信網により相互に結合された複数のサイト
と呼ばれるローカルなデータベース管理システム
からシステム全体が構成され、これらのサイトに
附加された記憶装置にデータベースが格納されて
いる。このような分散データベース処理システム
が管理する複数サイトに分散した関係データベー
スに対する結合演算処理は、ある一つのサイトへ
他のサイトから結合演算処理に関係するリレーシ
ヨンのタプルすべてを転送し、結合演算処理を実
行するという処理を行なうことにより実現出来る
が、結合演算処理の結果得られる最終結果のリレ
ーシヨンには含まれないタプルまで転送しなけれ
ばならず、サイト間のデータ転送が結合演算処理
全体のボトル・ネツクになるという問題があつ
た。この問題点を解決するために、結合演算に際
して、あるサイトから他のサイトにリレーシヨン
を転送する場合は結合演算に係わる属性値のみを
転送し、それに基づいて結合演算処理の結果得ら
れるリレーシヨンに最終的に含まれるタプルのみ
から構成されるリレーシヨンを生成するという結
合演算の前処理を行い、その結果得られたリレー
シヨンを転送することにより、サイト間のデータ
転送量を減少させるという方式が行われていた。
種の通信網により相互に結合された複数のサイト
と呼ばれるローカルなデータベース管理システム
からシステム全体が構成され、これらのサイトに
附加された記憶装置にデータベースが格納されて
いる。このような分散データベース処理システム
が管理する複数サイトに分散した関係データベー
スに対する結合演算処理は、ある一つのサイトへ
他のサイトから結合演算処理に関係するリレーシ
ヨンのタプルすべてを転送し、結合演算処理を実
行するという処理を行なうことにより実現出来る
が、結合演算処理の結果得られる最終結果のリレ
ーシヨンには含まれないタプルまで転送しなけれ
ばならず、サイト間のデータ転送が結合演算処理
全体のボトル・ネツクになるという問題があつ
た。この問題点を解決するために、結合演算に際
して、あるサイトから他のサイトにリレーシヨン
を転送する場合は結合演算に係わる属性値のみを
転送し、それに基づいて結合演算処理の結果得ら
れるリレーシヨンに最終的に含まれるタプルのみ
から構成されるリレーシヨンを生成するという結
合演算の前処理を行い、その結果得られたリレー
シヨンを転送することにより、サイト間のデータ
転送量を減少させるという方式が行われていた。
第２図は関係データベース管理システムが扱う
データ、すなわちリレーシヨンの例を示してい
る。第２図中、Ｒはリレーシヨン名、Ａ１，Ａ
２，Ａ３は属性名、（ａあイ）（ｂいロ）等はタプ
ルと呼ばれる。
データ、すなわちリレーシヨンの例を示してい
る。第２図中、Ｒはリレーシヨン名、Ａ１，Ａ
２，Ａ３は属性名、（ａあイ）（ｂいロ）等はタプ
ルと呼ばれる。
第３図は従来の結合演算処理方式の一例を示し
ている（例えばJournal of the Association for
Computing Machinery vol、28、No.１、P25−
40、January 1981）。第３図ではサイトＡ１０−
１に格納されているリレーシヨンＲ１１−１とサ
イトＢ１０−２に格納されているリレーシヨンＰ
１１−２を属性Ａ２とＢ１の値が等しいという条
件で結合演算を行い、その結果をサイトＡ１０−
１に接続された計算機１２に返すという結合演算
の処理例を示している。まずサイトＡ１０−１に
接続された計算機１２のアプリケーシヨン・プロ
グラム１３からの分散データベース管理システム
１４に対する、分散データベース２５のリレーシ
ヨンＲとＰとの結合演算処理要求がサイトＡ１０
−１にデータベース管理システム・アクセス管理
機構１５を介して送られ、次にこの処理要求は処
理要求解析機構１６によつて処理要求の解析等を
行われた後、処理手順決定機構１７により処理の
実行手順が決定され、データベース処理実行制御
機構１８はこの処理手順に従つて結合演算処理を
行なう。即ち、まず前処理として、リレーシヨン
Ｒに対して射影演算が行われ、中間結果である属
性Ａ２のみから成るリレーシヨンR′１９が生成
され、サイトＡ１０−１のデータベース２０−１
に格納され、次にこのリレーシヨンはサイトＢ１
０−２での処理要求と共にサイト間通信実行制御
機構２１−１，２１−２およびサイト間通信網２
２を介してサイトＢ１０−２に送られ、サイトＢ
１０−２ではサイトＡ１０−１からの処理要求に
従つてサイトＡ１０−１から送られてきたリレー
シヨンR′１９とサイトＢ１０−２のリレーシヨ
ンＲ１１−２に対して結合演算を施し、中間結果
であるリレーシヨンP′２３を得、これをサイトＢ
１０−２のデータベース２０−２に格納する。次
にリレーシヨンP′２３がサイトＡ１０−１に送ら
れ、サイトＡ１０−１ではこのリレーシヨンP′２
３とリレーシヨンＲ１１−１に対して結合演算を
施し、最終結果であるリレーシヨンRe２４が計
算機１２のアプリケーシヨン・プログラム１３に
返される。
ている（例えばJournal of the Association for
Computing Machinery vol、28、No.１、P25−
40、January 1981）。第３図ではサイトＡ１０−
１に格納されているリレーシヨンＲ１１−１とサ
イトＢ１０−２に格納されているリレーシヨンＰ
１１−２を属性Ａ２とＢ１の値が等しいという条
件で結合演算を行い、その結果をサイトＡ１０−
１に接続された計算機１２に返すという結合演算
の処理例を示している。まずサイトＡ１０−１に
接続された計算機１２のアプリケーシヨン・プロ
グラム１３からの分散データベース管理システム
１４に対する、分散データベース２５のリレーシ
ヨンＲとＰとの結合演算処理要求がサイトＡ１０
−１にデータベース管理システム・アクセス管理
機構１５を介して送られ、次にこの処理要求は処
理要求解析機構１６によつて処理要求の解析等を
行われた後、処理手順決定機構１７により処理の
実行手順が決定され、データベース処理実行制御
機構１８はこの処理手順に従つて結合演算処理を
行なう。即ち、まず前処理として、リレーシヨン
Ｒに対して射影演算が行われ、中間結果である属
性Ａ２のみから成るリレーシヨンR′１９が生成
され、サイトＡ１０−１のデータベース２０−１
に格納され、次にこのリレーシヨンはサイトＢ１
０−２での処理要求と共にサイト間通信実行制御
機構２１−１，２１−２およびサイト間通信網２
２を介してサイトＢ１０−２に送られ、サイトＢ
１０−２ではサイトＡ１０−１からの処理要求に
従つてサイトＡ１０−１から送られてきたリレー
シヨンR′１９とサイトＢ１０−２のリレーシヨ
ンＲ１１−２に対して結合演算を施し、中間結果
であるリレーシヨンP′２３を得、これをサイトＢ
１０−２のデータベース２０−２に格納する。次
にリレーシヨンP′２３がサイトＡ１０−１に送ら
れ、サイトＡ１０−１ではこのリレーシヨンP′２
３とリレーシヨンＲ１１−１に対して結合演算を
施し、最終結果であるリレーシヨンRe２４が計
算機１２のアプリケーシヨン・プログラム１３に
返される。
（発明が解決しようとする問題点）
しかし、上記結合演算処理方式は、分散データ
ベース管理システムの各サイトを結合する通信網
の転送能力が比較的低い場合を想定した、各サイ
ト間の通信量を減少させる方式であり、また前処
理において準結合の結果得られた中間結果の保持
といつた付加的処理を行なわなければならないた
め、各サイトの処理能力が低い時または特定のサ
イトに多数の利用者が集中した時、または処理対
象のリレーシヨンが大容量であり中間結果が大容
量になる時は、各サイトでの前処理が結合演算処
理全体に対するボルト・ネツクとなり結合演算処
理速度が低下する。また各サイト間の通信量より
も通信回数が各サイト間のデータ転送能力に大き
な影響を与えるために各サイト間の通信回数の多
い上記方式ではかえつて結合演算処理速度が遅く
なるという問題点があつた。
ベース管理システムの各サイトを結合する通信網
の転送能力が比較的低い場合を想定した、各サイ
ト間の通信量を減少させる方式であり、また前処
理において準結合の結果得られた中間結果の保持
といつた付加的処理を行なわなければならないた
め、各サイトの処理能力が低い時または特定のサ
イトに多数の利用者が集中した時、または処理対
象のリレーシヨンが大容量であり中間結果が大容
量になる時は、各サイトでの前処理が結合演算処
理全体に対するボルト・ネツクとなり結合演算処
理速度が低下する。また各サイト間の通信量より
も通信回数が各サイト間のデータ転送能力に大き
な影響を与えるために各サイト間の通信回数の多
い上記方式ではかえつて結合演算処理速度が遅く
なるという問題点があつた。
この発明は、以上述べた分散データベース管理
システムにおける結合演算処理方式での通信回数
に基づく処理負荷による処理速度の低下と、上記
結合演算処理の前処理による処理速度の低下を除
去することにより、またパイプライン処理的な結
合演算処理により、分散データベース管理システ
ムにおける結合演算の処理速度を向上させること
が出来る結合演算処理方式を提供することを目的
とする。
システムにおける結合演算処理方式での通信回数
に基づく処理負荷による処理速度の低下と、上記
結合演算処理の前処理による処理速度の低下を除
去することにより、またパイプライン処理的な結
合演算処理により、分散データベース管理システ
ムにおける結合演算の処理速度を向上させること
が出来る結合演算処理方式を提供することを目的
とする。
（問題を解決するための手段）
本発明は、複数の第１の計算機と、少くとも一
つの第２の計算機と、前記第１の計算機及び前記
第２の計算機の各々とが直接的もしくは間接的に
相互に通信可能な通信網と、前記複数の第１の計
算機に分散されて格納されている分散データベー
スとが存在し、前記第２の計算機の結合演算指示
に基づいて、前記複数の第１の計算機が前記分散
データベースに対して結合演算処理を実行する分
散データベース管理システムにおける結合演算処
理方式において、前記第１の計算機は、前記第２
の計算機及び前記第１の計算機から送信された処
理要求を受信する受信手段と、前記受信手段によ
り受信された前記処理要求を解析し判断する処理
要求解析手段と、前記処理要求解析手段が前記第
２の計算機から送信されたリレーシヨン定義要求
であると判断した場合、前記第１の計算機自身が
有する部分における前記分散データベースについ
てリレーシヨン定義情報を作成し記憶するリレー
シヨン定義情報作成手段と、前記処理要求解析手
段が前記第２の計算機から送信されたリレーシヨ
ン定義情報読出要求であると判断した場合、前記
リレーシヨン定義情報作成手段により作成され記
憶されている前記リレーシヨン定義情報を読み出
すリレーシヨン定義情報読出手段と、前記処理要
求解析手段が前記第２の計算機もしくは前記第１
の計算機から送信された結合演算処理要求である
と判断した場合、前記結合演算処理要求に基づい
て、前記第２の計算機または以降の前記第１の計
算機で行うべき指示情報を作成する指示情報作成
手段と、前記結合演算処理要求及び前記リレーシ
ヨン定義情報とに基づいて、前記第１の計算機自
身が有する部分における前記分散データベースに
ついての結合演算処理を実行する結合演算処理手
段と、前記指示情報作成手段により作成された前
記指示情報及び前記結合演算処理手段により実行
された前記結合演算処理の結果とに基づいて、新
たな結合演算処理要求を作成する結合演算処理要
求作成手段と、前記処理要求に基づいて、前記第
１の計算機及び前記第２の計算機の中から送信対
象とすべき計算機を決定する送信先決定手段と、
前記リレーシヨン定義情報読出手段により読み出
された前記リレーシヨン定義情報及び前記結合演
算処理要求作成手段により作成された結合演算処
理要求を、前記送信先決定手段により決定された
計算機に送信する送信手段とを有する分散データ
ベース管理システムにおける結合演算処理方式で
ある。
つの第２の計算機と、前記第１の計算機及び前記
第２の計算機の各々とが直接的もしくは間接的に
相互に通信可能な通信網と、前記複数の第１の計
算機に分散されて格納されている分散データベー
スとが存在し、前記第２の計算機の結合演算指示
に基づいて、前記複数の第１の計算機が前記分散
データベースに対して結合演算処理を実行する分
散データベース管理システムにおける結合演算処
理方式において、前記第１の計算機は、前記第２
の計算機及び前記第１の計算機から送信された処
理要求を受信する受信手段と、前記受信手段によ
り受信された前記処理要求を解析し判断する処理
要求解析手段と、前記処理要求解析手段が前記第
２の計算機から送信されたリレーシヨン定義要求
であると判断した場合、前記第１の計算機自身が
有する部分における前記分散データベースについ
てリレーシヨン定義情報を作成し記憶するリレー
シヨン定義情報作成手段と、前記処理要求解析手
段が前記第２の計算機から送信されたリレーシヨ
ン定義情報読出要求であると判断した場合、前記
リレーシヨン定義情報作成手段により作成され記
憶されている前記リレーシヨン定義情報を読み出
すリレーシヨン定義情報読出手段と、前記処理要
求解析手段が前記第２の計算機もしくは前記第１
の計算機から送信された結合演算処理要求である
と判断した場合、前記結合演算処理要求に基づい
て、前記第２の計算機または以降の前記第１の計
算機で行うべき指示情報を作成する指示情報作成
手段と、前記結合演算処理要求及び前記リレーシ
ヨン定義情報とに基づいて、前記第１の計算機自
身が有する部分における前記分散データベースに
ついての結合演算処理を実行する結合演算処理手
段と、前記指示情報作成手段により作成された前
記指示情報及び前記結合演算処理手段により実行
された前記結合演算処理の結果とに基づいて、新
たな結合演算処理要求を作成する結合演算処理要
求作成手段と、前記処理要求に基づいて、前記第
１の計算機及び前記第２の計算機の中から送信対
象とすべき計算機を決定する送信先決定手段と、
前記リレーシヨン定義情報読出手段により読み出
された前記リレーシヨン定義情報及び前記結合演
算処理要求作成手段により作成された結合演算処
理要求を、前記送信先決定手段により決定された
計算機に送信する送信手段とを有する分散データ
ベース管理システムにおける結合演算処理方式で
ある。
（作用）
上記第２の計算機は、複数の第１の計算機に分
散されて格納されている分散データベースに対す
る結合演算処理要求等の当該分散データベースに
関する処理要求を、所定の第１の計算機に対して
送信する。上記処理要求を受信した第１の計算機
は、その処理要求に基づいて当該第１の計算機自
身が有する部分における前述の分散データベース
について検索等の結合演算処理を行い、その結果
と次の第１の計算機以降で行うべき結合演算処理
要求を次の第１の計算機に送信する。次の第１の
計算機は前の第１の計算機から受信した結合演算
処理要求に基づいて受信した上記結合演算処理結
果と自身が有する部分における前述の分散データ
ベースについて結合演算処理を実行する。次の第
１の計算機における結合演算処理がないときは結
合演算処理結果を第２の計算機に送信し、次の第
１の計算機における処理が残つているときは結合
演算処理結果を次の第１の計算機以降の総合演算
処理要求と共に次の第１の計算機に送信する。即
ち、上記一連の結合演算処理は第１の計算機間を
通じて順次段階的に実行されていく。
散されて格納されている分散データベースに対す
る結合演算処理要求等の当該分散データベースに
関する処理要求を、所定の第１の計算機に対して
送信する。上記処理要求を受信した第１の計算機
は、その処理要求に基づいて当該第１の計算機自
身が有する部分における前述の分散データベース
について検索等の結合演算処理を行い、その結果
と次の第１の計算機以降で行うべき結合演算処理
要求を次の第１の計算機に送信する。次の第１の
計算機は前の第１の計算機から受信した結合演算
処理要求に基づいて受信した上記結合演算処理結
果と自身が有する部分における前述の分散データ
ベースについて結合演算処理を実行する。次の第
１の計算機における結合演算処理がないときは結
合演算処理結果を第２の計算機に送信し、次の第
１の計算機における処理が残つているときは結合
演算処理結果を次の第１の計算機以降の総合演算
処理要求と共に次の第１の計算機に送信する。即
ち、上記一連の結合演算処理は第１の計算機間を
通じて順次段階的に実行されていく。
（実施例）
第４図は本発明による結合演算処理方式の概要
説明図である。第４図では複数のデータベース管
理システム（サイトと呼ぶ）３０とそれらを相互
に接続する通信網３１から分散データベース管理
システム（DDBMSと呼ぶ）３２が構成されてお
り、各サイトのデータベース３７から構成される
分散データベース３３に対する処理を行つてい
る。また、同じ通信網でこのDDBMSにそれを利
用する計算機３４が接続されている。計算機のア
プリケーシヨン・プログラム３５からのDDBMS
に対する結合演算処理要求は計算機内の処理手順
決定管理機構３６によつて決定された処理手順に
従つてサイト(1)３０−１に処理要求が出される。
次にサイト(1)では処理要求に従つてリレーシヨン
Ｒ(1)３２−１に処理を行うと同時に、その結果と
次サイト以降での処理手順とをサイト(2)３０−２
に送る。サイト(2)ではサイト(1)からの処理要求に
従つてサイト(1)からの結果を受信すると同時に、
リレーシヨンＲ(2)３２−２とサイト(1)からの結果
に対してデータベース処理を行いその結果と次サ
イト以降での処理手順とを次のサイトに送る。以
下、順次処理が行われ、最終結果がサイト(n)３０
−ｎから計算機３４に送られる。これらサイト(1)
からサイト(n)までの処理およびサイト(n)から計算
機３４への最終結果の送信は順次段階的に行われ
る。
説明図である。第４図では複数のデータベース管
理システム（サイトと呼ぶ）３０とそれらを相互
に接続する通信網３１から分散データベース管理
システム（DDBMSと呼ぶ）３２が構成されてお
り、各サイトのデータベース３７から構成される
分散データベース３３に対する処理を行つてい
る。また、同じ通信網でこのDDBMSにそれを利
用する計算機３４が接続されている。計算機のア
プリケーシヨン・プログラム３５からのDDBMS
に対する結合演算処理要求は計算機内の処理手順
決定管理機構３６によつて決定された処理手順に
従つてサイト(1)３０−１に処理要求が出される。
次にサイト(1)では処理要求に従つてリレーシヨン
Ｒ(1)３２−１に処理を行うと同時に、その結果と
次サイト以降での処理手順とをサイト(2)３０−２
に送る。サイト(2)ではサイト(1)からの処理要求に
従つてサイト(1)からの結果を受信すると同時に、
リレーシヨンＲ(2)３２−２とサイト(1)からの結果
に対してデータベース処理を行いその結果と次サ
イト以降での処理手順とを次のサイトに送る。以
下、順次処理が行われ、最終結果がサイト(n)３０
−ｎから計算機３４に送られる。これらサイト(1)
からサイト(n)までの処理およびサイト(n)から計算
機３４への最終結果の送信は順次段階的に行われ
る。
本発明による結合演算処理方式を実施例により
以下詳細に説明する。
以下詳細に説明する。
第１図は本発明の一実施例を示すものである。
第１図ではサイトＡ４０−１、サイトＢ４０−２
なるデータベース管理システム（DBMSと呼ぶ）
が通信網４１によつて相互に接続されて分散デー
タベース管理システム（DDBMSと呼ぶ）４２が
構成されており、各サイトのデータベース４３か
ら分散データベース４４が構成されている。各サ
イトのデータベースでは、そこに格納されたリレ
ーシヨン各々に対してリレーシヨン定義情報が格
納されている。例えば、定義情報４９−１−１は
リレーシヨン４７−１−１の定義情報であり、定
義情報４９−２−１はリレーシヨン４７−２−１
の定義情報である。このようにして、定義情報４
９−ｉ−ｊはリレーシヨン４７−ｉ−ｊを定義し
ている。そして、同じ通信網４１でこのDDBMS
４２を利用する計算機４５が上記サイト４０と相
互に接続されている。計算機４５は第１の処理要
求解析実行機構５７、処理手順決定管理機構４
８、DBMSアクセス管理機構５５を有する。ま
た、DDBMS４２を構成するDBMS４０−１，
４０−２は各々通信実行制御機構５０、処理要求
解析実行機構５１、データベース処理実行制御機
構５２を有する。
第１図ではサイトＡ４０−１、サイトＢ４０−２
なるデータベース管理システム（DBMSと呼ぶ）
が通信網４１によつて相互に接続されて分散デー
タベース管理システム（DDBMSと呼ぶ）４２が
構成されており、各サイトのデータベース４３か
ら分散データベース４４が構成されている。各サ
イトのデータベースでは、そこに格納されたリレ
ーシヨン各々に対してリレーシヨン定義情報が格
納されている。例えば、定義情報４９−１−１は
リレーシヨン４７−１−１の定義情報であり、定
義情報４９−２−１はリレーシヨン４７−２−１
の定義情報である。このようにして、定義情報４
９−ｉ−ｊはリレーシヨン４７−ｉ−ｊを定義し
ている。そして、同じ通信網４１でこのDDBMS
４２を利用する計算機４５が上記サイト４０と相
互に接続されている。計算機４５は第１の処理要
求解析実行機構５７、処理手順決定管理機構４
８、DBMSアクセス管理機構５５を有する。ま
た、DDBMS４２を構成するDBMS４０−１，
４０−２は各々通信実行制御機構５０、処理要求
解析実行機構５１、データベース処理実行制御機
構５２を有する。
第５図は、第１図における計算機４５での、処
理要求解析実行機構５７、処理手順決定管理機構
４８、DBMSアクセス管理機構５５における処
理の流れを説明したフロー図である。第６図は第
１図におけるデータベース管理システム
（DBMS）４０での処理の流れを説明したフロー
図である。
理要求解析実行機構５７、処理手順決定管理機構
４８、DBMSアクセス管理機構５５における処
理の流れを説明したフロー図である。第６図は第
１図におけるデータベース管理システム
（DBMS）４０での処理の流れを説明したフロー
図である。
以下に第１図、第５図、第６図を用いてリレー
シヨンの定義と、各サイト４０−１，４０−２に
おける結合演算の処理の流れを説明する。
シヨンの定義と、各サイト４０−１，４０−２に
おける結合演算の処理の流れを説明する。
(A) リレーシヨンの定義
(a) アプリケーシヨン・プログラム（AP）４
６からリレーシヨンの定義要求が、処理要求
待ち状態にある、第１の処理要求解析実行機
構５７に出される（ステツプ500）。
６からリレーシヨンの定義要求が、処理要求
待ち状態にある、第１の処理要求解析実行機
構５７に出される（ステツプ500）。
(b) 第１の処理要求解析実行機構５７により
AP４６からの処理要求の解析が行われる
（ステツプ501）。処理要求はリレーシヨンの
定義要求であつたと判断される。
AP４６からの処理要求の解析が行われる
（ステツプ501）。処理要求はリレーシヨンの
定義要求であつたと判断される。
(c) リレーシヨンの定義要求がDBMSへ送ら
れる（ステツプ502）。これは、第１の処理要
求解析実行機構５７→DBMSアクセス管理
機構５５→DBMSの順に送られる。
れる（ステツプ502）。これは、第１の処理要
求解析実行機構５７→DBMSアクセス管理
機構５５→DBMSの順に送られる。
この例では、要求はDBMS４０−１へ送
られると仮定する。
られると仮定する。
(d) 処理要求は、処理要求待ち状態であつた第
１の通信実行制御機構５０−１によつて受信
され、第２の処理要求解析実行機構５１−１
に送られる（ステツプ600）。
１の通信実行制御機構５０−１によつて受信
され、第２の処理要求解析実行機構５１−１
に送られる（ステツプ600）。
(e) 第２の処理要求解析実行機構５１−１によ
つて、処理要求の解析が行われる（ステツプ
601）。処理要求はリレーシヨンの定義要求で
あつたと判断される。
つて、処理要求の解析が行われる（ステツプ
601）。処理要求はリレーシヨンの定義要求で
あつたと判断される。
(f) リレーシヨン定義要求は、第２の処理要求
解析実行機構５１−１により第１のデータベ
ース処理実行制御機構５２−１に送られ、そ
こでリレーシヨンの定義が行われる（ステツ
プ602）。
解析実行機構５１−１により第１のデータベ
ース処理実行制御機構５２−１に送られ、そ
こでリレーシヨンの定義が行われる（ステツ
プ602）。
(g) 処理状態が計算機４５へ返却される（ステ
ツプ603）。
ツプ603）。
即ち、第１のデータベース処理実行制御機
構５２−１において、リレーシヨンの定義が
行われ、その定義情報がデータベース４３−
１に格納されたことを、第１のデータベース
処理実行制御機構５２−１→第２の処理要求
解析実行機構５１−１→第１の通信実行制御
機構５０−１→計算機４５の順により計算機
４５へ返却される。その後、DBMSは再び
待ち状態（ステツプ600）に戻る。
構５２−１において、リレーシヨンの定義が
行われ、その定義情報がデータベース４３−
１に格納されたことを、第１のデータベース
処理実行制御機構５２−１→第２の処理要求
解析実行機構５１−１→第１の通信実行制御
機構５０−１→計算機４５の順により計算機
４５へ返却される。その後、DBMSは再び
待ち状態（ステツプ600）に戻る。
(h) DBMS４０−１からの処理状態は、
DBMSからの返却情報待ち状態にある
DBMSアクセス管理機構５５によつて受信
される（ステツプ503）。
DBMSからの返却情報待ち状態にある
DBMSアクセス管理機構５５によつて受信
される（ステツプ503）。
(i) DBMSからの返却情報（処理状態）が
DBMSアクセス管理機構５５から、第１の
処理要求解析実行機構５７を介してAP４６
へ返される（ステツプ504）。
DBMSアクセス管理機構５５から、第１の
処理要求解析実行機構５７を介してAP４６
へ返される（ステツプ504）。
その後、処理要求解析実行機構５７は再び
処理要求待ち状態（ステツプ500）へ戻る。
処理要求待ち状態（ステツプ500）へ戻る。
(B) 計算機４５における結合演算に対する処理
(a) 第１の処理要求解析実行機構５７は処理要
求待ち状態にある。AP４６から結合演算の
処理要求が出されると、この処理要求解析実
行機構５７によつて受信される（ステツプ
500）。
求待ち状態にある。AP４６から結合演算の
処理要求が出されると、この処理要求解析実
行機構５７によつて受信される（ステツプ
500）。
この例では、要求された結合演算は、「リ
レーシヨンＲ４７−１−１とリレーシヨンＰ
４７−２−１を属性Ａ２と属性Ｂ１の値が等
しいという条件で結合し、その結果を計算機
４５に返す」という要求であつたと仮定す
る。
レーシヨンＲ４７−１−１とリレーシヨンＰ
４７−２−１を属性Ａ２と属性Ｂ１の値が等
しいという条件で結合し、その結果を計算機
４５に返す」という要求であつたと仮定す
る。
(b) 第１の処理要求解析実行機構５７により処
理要求の解析が行われる（ステツプ501）。処
理要求は結合演算処理であつたと判断され、
処理要求は処理手順決定管理機構４８へ送ら
れる。
理要求の解析が行われる（ステツプ501）。処
理要求は結合演算処理であつたと判断され、
処理要求は処理手順決定管理機構４８へ送ら
れる。
(e) 処理手順決定管理機構４８からリレーシヨ
ンの定義情報の読み出し要求が、DBMSア
クセス管理機構５５を介してDBMSへ送ら
れる（ステツプ505）。
ンの定義情報の読み出し要求が、DBMSア
クセス管理機構５５を介してDBMSへ送ら
れる（ステツプ505）。
この例では、第１回目にデータベース４３
−１に格納された、リレーシヨン４７−１−
１に対する定義情報４９−１−１に対する読
み出し要求が、DBMS４０−１へ送られ、
第２回目にデータベース４３−２に格納され
た、リレーシヨン４７−２−１に対する定義
情報４９−２−１に対する読み出し要求が、
DBMS４０−２へ送られたと仮定する。
−１に格納された、リレーシヨン４７−１−
１に対する定義情報４９−１−１に対する読
み出し要求が、DBMS４０−１へ送られ、
第２回目にデータベース４３−２に格納され
た、リレーシヨン４７−２−１に対する定義
情報４９−２−１に対する読み出し要求が、
DBMS４０−２へ送られたと仮定する。
(d) DBMS４０からの処理状態および定義情
報は、DBMSからの返却情報待ち状態にあ
るDBMSアクセス管理機構５５によつて受
信される（ステツプ506）。
報は、DBMSからの返却情報待ち状態にあ
るDBMSアクセス管理機構５５によつて受
信される（ステツプ506）。
この例では、Ｂの(c)の仮定により、第１回
目には定義情報４９−１−１、第２回目には
定義情報４９−２−１が受信される。
目には定義情報４９−１−１、第２回目には
定義情報４９−２−１が受信される。
(e) 上記DBMS４０からの返却情報は処理手
順決定管理機構４８に送られ、処理手順決定
管理機構４８では、処理手順の決定に必要な
定義情報がすべて読み出されたかどうかが判
断される（ステツプ507）。すべて読み出し済
みであれば（Ｂの(f)）ステツプ508へ進み、
まだ読み出すべき定義情報があれば（Ｂの
(c)）ステツプ505へ進む。
順決定管理機構４８に送られ、処理手順決定
管理機構４８では、処理手順の決定に必要な
定義情報がすべて読み出されたかどうかが判
断される（ステツプ507）。すべて読み出し済
みであれば（Ｂの(f)）ステツプ508へ進み、
まだ読み出すべき定義情報があれば（Ｂの
(c)）ステツプ505へ進む。
この例ではＢの(c)の仮定により、第１回目
にはステツプ505へ進み、第２回目にはステ
ツプ508へ進む。
にはステツプ505へ進み、第２回目にはステ
ツプ508へ進む。
(f) 処理手順決定管理機構４８により、結合演
算の処理手順が決定される（ステツプ508）。
算の処理手順が決定される（ステツプ508）。
この例では、処理手順は、「まずDBMS４
０−１に対して処理要求が出され、DBMS
４０−１ではリレーシヨン４７−１−１の検
索を行なうと同時に、検索結果をDBMS４
０−２に送る。この時DBMS４０−２での
処理要求も同時に送る。DBMS４０−２で
はDBMS４０−１からの処理要求に従つて、
DBMS４０−１から送られてきた検索結果
とリレーシヨン４７−２−１に対して結合演
算を行うと同時に、その結果を計算機４５に
送る。」の如く決定されたと仮定する。
０−１に対して処理要求が出され、DBMS
４０−１ではリレーシヨン４７−１−１の検
索を行なうと同時に、検索結果をDBMS４
０−２に送る。この時DBMS４０−２での
処理要求も同時に送る。DBMS４０−２で
はDBMS４０−１からの処理要求に従つて、
DBMS４０−１から送られてきた検索結果
とリレーシヨン４７−２−１に対して結合演
算を行うと同時に、その結果を計算機４５に
送る。」の如く決定されたと仮定する。
(g) 上記(f)で決定された処理手順に従つて、処
理要求がDBMS４０−１に送られる（ステ
ツプ509）。これは、処理手順決定管理機構４
８→DBMSアクセス管理機構５５→DBMS
４０−１の順に送られる。DBMSアクセス
管理機構５５はDBMS４０−２からの返却
情報待ち状態になる。
理要求がDBMS４０−１に送られる（ステ
ツプ509）。これは、処理手順決定管理機構４
８→DBMSアクセス管理機構５５→DBMS
４０−１の順に送られる。DBMSアクセス
管理機構５５はDBMS４０−２からの返却
情報待ち状態になる。
(h) DBMSからの返却情報待ち状態であつた
DBMSアクセス管理機構５５によつて、
DBMS４０−２からの処理状態および処理
結果を受信し、処理手順決定管理機構４８へ
送る（ステツプ510）。
DBMSアクセス管理機構５５によつて、
DBMS４０−２からの処理状態および処理
結果を受信し、処理手順決定管理機構４８へ
送る（ステツプ510）。
この例では、Ｅの(e)およびＥの(h)の仮定に
より、第１回目にはDBMS４０での処理が
継続中であること、および結合演算結果とし
てタプル（ａあイ）、（ｂあイ）が、第２回目
はDBMS４０での処理が継続中であること、
およびタプル（ｃいロ）、（ｄいロ）が、第３
回目にはDBMS４０での処理が終了したこ
と、および結合演算結果として空集合が受信
され、最終的に計算機４５のAP４６はリレ
ーシヨンRe５６を得る。
より、第１回目にはDBMS４０での処理が
継続中であること、および結合演算結果とし
てタプル（ａあイ）、（ｂあイ）が、第２回目
はDBMS４０での処理が継続中であること、
およびタプル（ｃいロ）、（ｄいロ）が、第３
回目にはDBMS４０での処理が終了したこ
と、および結合演算結果として空集合が受信
され、最終的に計算機４５のAP４６はリレ
ーシヨンRe５６を得る。
(i) 処理手順決定管理機構４８により上記処理
状態および結果がAP４６に返却される（ス
テツプ511）。これは、第１の処理要求解析実
行機構５７を介して行われる。
状態および結果がAP４６に返却される（ス
テツプ511）。これは、第１の処理要求解析実
行機構５７を介して行われる。
(j) DBMSでの処理が終了したかどうかの判
断が処理手順決定管理機構４８によつて行わ
れる（ステツプ512）。終了であれば再び待ち
状態ステツプ500に戻る。未終了であれば
（Ｂの(h)）ステツプ510に戻る。
断が処理手順決定管理機構４８によつて行わ
れる（ステツプ512）。終了であれば再び待ち
状態ステツプ500に戻る。未終了であれば
（Ｂの(h)）ステツプ510に戻る。
この例では、Ｅの(e)およびＥの(h)により、
第１回目および第２回目にはステツプ510へ
進み、第３回目にステツプ500へ進む。
第１回目および第２回目にはステツプ510へ
進み、第３回目にステツプ500へ進む。
(C) DBMS４０−１におけるリレーシヨン定義
情報の読み出し処理 (a) 第１の通信実行制御機構５０−１は処理要
求待ち状態にある。計算機４５から処理要求
が送信されると、通信実行制御機構５０−１
によつて受信され、処理要求は第２の処理要
求解析実行機構５１−１に送られる（ステツ
プ600）。
情報の読み出し処理 (a) 第１の通信実行制御機構５０−１は処理要
求待ち状態にある。計算機４５から処理要求
が送信されると、通信実行制御機構５０−１
によつて受信され、処理要求は第２の処理要
求解析実行機構５１−１に送られる（ステツ
プ600）。
(b) 第２の処理要求解析実行機構５１−１によ
つて、処理要求の解析が行われる（ステツプ
601）。処理要求はリレーシヨンＲ４７−１−
１に対する定義情報の読み出し要求であつた
と判断される。
つて、処理要求の解析が行われる（ステツプ
601）。処理要求はリレーシヨンＲ４７−１−
１に対する定義情報の読み出し要求であつた
と判断される。
(c) リレーシヨン定義情報読み出し要求は、第
２の処理要求解析実行機構５１−１により第
１のデータベース処理実行制御機構５２−１
に送られ、そこでリレーシヨンの定義情報４
９−１−１の読み出しが行われる（ステツプ
604）。
２の処理要求解析実行機構５１−１により第
１のデータベース処理実行制御機構５２−１
に送られ、そこでリレーシヨンの定義情報４
９−１−１の読み出しが行われる（ステツプ
604）。
(d) 処理状態、およびリレーシヨン定義情報４
９−１−１が計算機４５へ返却される（ステ
ツプ605）。
９−１−１が計算機４５へ返却される（ステ
ツプ605）。
即ち、第１のデータベース処理実行制御機
構５２−１において、リレーシヨンの定義情
報の読み出しが行われ、読み出した定義情報
および読み出しが実行されたこと（処理状
態）が、第１のデータベース処理実行制御機
構５２−１→第２の処理要求解析実行機構５
１−１→第１の通信実行制御機構５０−１→
計算機４５の順により計算機４５へ返却され
る。その後、DBMS４０−１は再び待ち状
態（ステツプ600）に戻る。
構５２−１において、リレーシヨンの定義情
報の読み出しが行われ、読み出した定義情報
および読み出しが実行されたこと（処理状
態）が、第１のデータベース処理実行制御機
構５２−１→第２の処理要求解析実行機構５
１−１→第１の通信実行制御機構５０−１→
計算機４５の順により計算機４５へ返却され
る。その後、DBMS４０−１は再び待ち状
態（ステツプ600）に戻る。
(D) DBMS４０−１における結合演算処理
(a) 第１の通信実行制御機構５０−１は処理要
求待ち状態にある。計算機４５から処理要求
が送信されると、第１の通信実行制御機構５
０−１によつて受信され、処理要求は第２の
処理要求解析実行機構５１−１に送られる
（ステツプ600）。
求待ち状態にある。計算機４５から処理要求
が送信されると、第１の通信実行制御機構５
０−１によつて受信され、処理要求は第２の
処理要求解析実行機構５１−１に送られる
（ステツプ600）。
(b) 第２の処理要求解析実行機構５１−１によ
つて、処理要求の解析が行われる（ステツプ
601）。処理要求は結合演算処理要求（リレー
シヨンＲ４７−１−１の検索と、その結果の
DBMS４０−２への送信）であつたと判断
される。
つて、処理要求の解析が行われる（ステツプ
601）。処理要求は結合演算処理要求（リレー
シヨンＲ４７−１−１の検索と、その結果の
DBMS４０−２への送信）であつたと判断
される。
(c) 与えられた処理要求に従つて、第２の処理
要求解析実行機構５１−１により第１のデー
タベース処理実行制御機構５２−１に検索の
要求が送られ、そこでリレーシヨンＲ４７−
１−１の検索が行われ、その結果が第２の処
理要求解析実行機構５１−１に返される（ス
テツプ606）。
要求解析実行機構５１−１により第１のデー
タベース処理実行制御機構５２−１に検索の
要求が送られ、そこでリレーシヨンＲ４７−
１−１の検索が行われ、その結果が第２の処
理要求解析実行機構５１−１に返される（ス
テツプ606）。
この例では、第１回目の検索で、タプル
（ａあ）、（ｂあ）が、第２回目ではタプル
（ｃい）、（ｄい）が、第３回目では（ｅう）、
（ｆう）が検索されると仮定する。
（ａあ）、（ｂあ）が、第２回目ではタプル
（ｃい）、（ｄい）が、第３回目では（ｅう）、
（ｆう）が検索されると仮定する。
(d) 第２の処理要求解析実行機構５１−１によ
り、すべての処理が終了したかどうかが判断
される（ステツプ607）。終了ならば（Ｄの
(g)）ステツプ609へ進み、未終了ならば（Ｄ
の(e)）ステツプ608へ進む。
り、すべての処理が終了したかどうかが判断
される（ステツプ607）。終了ならば（Ｄの
(g)）ステツプ609へ進み、未終了ならば（Ｄ
の(e)）ステツプ608へ進む。
この例では、Ｄの(c)の仮定により第１回目
および第２回目にはステツプ608へ進み、第
３回目にステツプ609へ進む。
および第２回目にはステツプ608へ進み、第
３回目にステツプ609へ進む。
(e) 第２の処理要求解析実行機構５１−１によ
り、第１の通信実行制御機構５０−１を介し
て、処理状態、即ちDBMS４０−１での処
理は継続中であること、および検索結果が
DBMS４０−２へ送られる。この時DBMS
４０−２での処理要求も同時に送られ（ステ
ツプ608）。（DBMS４０−２では上記処理要
求の受信に伴つて処理が始まる。） この例では、DBMS４０−２へ送られる
タプルは第１回目には（ａあ）、（ｂあ）が、
第２回目には（ｃい）、（ｄい）が送られると
仮定する。
り、第１の通信実行制御機構５０−１を介し
て、処理状態、即ちDBMS４０−１での処
理は継続中であること、および検索結果が
DBMS４０−２へ送られる。この時DBMS
４０−２での処理要求も同時に送られ（ステ
ツプ608）。（DBMS４０−２では上記処理要
求の受信に伴つて処理が始まる。） この例では、DBMS４０−２へ送られる
タプルは第１回目には（ａあ）、（ｂあ）が、
第２回目には（ｃい）、（ｄい）が送られると
仮定する。
(f) 第２の処理要求解析実行機構５１−１によ
つて、DBMS４０−１が第１の結合演算実
行サイトであつたかどうかが判断される（ス
テツプ610）。DBMS４０−１は第１の実行
サイトであつたと判断され、（Ｄの(c)）ステ
ツプ606へ進む。
つて、DBMS４０−１が第１の結合演算実
行サイトであつたかどうかが判断される（ス
テツプ610）。DBMS４０−１は第１の実行
サイトであつたと判断され、（Ｄの(c)）ステ
ツプ606へ進む。
(g) 第２の処理要求解析実行機構５１−１によ
り、第１の通信実行制御機構５０−１を介し
て、処理状態、即ちDBMS４０−１での処
理が終了したこと、および検索結果が
DBMS４０−２へ送られる。この時DBMS
４０−２での処理要求も同時に送られる（ス
テツプ609）。その後DBMS４０−１は再び
待ち状態（ステツプ600）に戻る。
り、第１の通信実行制御機構５０−１を介し
て、処理状態、即ちDBMS４０−１での処
理が終了したこと、および検索結果が
DBMS４０−２へ送られる。この時DBMS
４０−２での処理要求も同時に送られる（ス
テツプ609）。その後DBMS４０−１は再び
待ち状態（ステツプ600）に戻る。
この例では、検索結果はタプル（ｅう）、
（ｆう）であると仮定する。
（ｆう）であると仮定する。
(E) DBMS４０−２における結合演算処理
(a) 第２の通信実行制御機構５０−２は処理要
求待ち状態にある。DBMS４０−１からの
処理要求（Ｄの(e)による）は第２の通信実行
制御機構５０−２によつて受信され、処理要
求は第３の処理要求解析実行機構５１−２に
送られる（ステツプ600）。
求待ち状態にある。DBMS４０−１からの
処理要求（Ｄの(e)による）は第２の通信実行
制御機構５０−２によつて受信され、処理要
求は第３の処理要求解析実行機構５１−２に
送られる（ステツプ600）。
(b) 第３の処理要求解析実行機構５１−２によ
つて、処理要求の解析が行われる（ステツプ
601）。処理要求は第２の結合演算実行サイト
に対する結合演算処理要求（DBMS４０−
１から送られてきたタプルとリレーシヨンＰ
４７−２−１との結合演算の実行と、その結
果の計算機４５への送信）であると判断され
る。
つて、処理要求の解析が行われる（ステツプ
601）。処理要求は第２の結合演算実行サイト
に対する結合演算処理要求（DBMS４０−
１から送られてきたタプルとリレーシヨンＰ
４７−２−１との結合演算の実行と、その結
果の計算機４５への送信）であると判断され
る。
(c) 与えられた処理要求に従つて、第３の処理
要求解析実行機構５１−２により第２のデー
タベース処理実行制御機構５２−２に結合演
算の処理要求が送られ、そこでリレーシヨン
Ｐ４７−２−１とDBMS４０−１から送ら
れてきたタプルとの係合演算が行われる（ス
テツプ606）。
要求解析実行機構５１−２により第２のデー
タベース処理実行制御機構５２−２に結合演
算の処理要求が送られ、そこでリレーシヨン
Ｐ４７−２−１とDBMS４０−１から送ら
れてきたタプルとの係合演算が行われる（ス
テツプ606）。
この例では、Ｄの(c)およびＤの(g)の仮定に
よりリレーシヨンＰ４７−２−１と、第１回
目にはタプル（ａあ）、（ｂあ）と、第２回目
はタプル（ｃい）、（ｄい）が第３回目はタプ
ル（ｅう）、（ｆう）とに結合演算が施され
る。
よりリレーシヨンＰ４７−２−１と、第１回
目にはタプル（ａあ）、（ｂあ）と、第２回目
はタプル（ｃい）、（ｄい）が第３回目はタプ
ル（ｅう）、（ｆう）とに結合演算が施され
る。
その結合演算の結果は第１回目の処理では
タプル（ａあイ）、（ｂあイ）、第２回目では
タプル（ｃいロ）（ｄいロ）、第３回目では空
集合であると仮定する。
タプル（ａあイ）、（ｂあイ）、第２回目では
タプル（ｃいロ）（ｄいロ）、第３回目では空
集合であると仮定する。
(e) DBMS４０−２での処理がすべて終了し
たかどうかが、DBMS４０−１から送られ
てきた処理状態（DBMS４０−１における
処理は継続中かどうか）に基づき、第３の処
理要求解析実行機構５１−２で判断される
（ステツプ607）。終了ならば（Ｅの(h)）ステ
ツプ609へ進み、未終了であれば（Ｅの(e)）
ステツプ608へ進む。
たかどうかが、DBMS４０−１から送られ
てきた処理状態（DBMS４０−１における
処理は継続中かどうか）に基づき、第３の処
理要求解析実行機構５１−２で判断される
（ステツプ607）。終了ならば（Ｅの(h)）ステ
ツプ609へ進み、未終了であれば（Ｅの(e)）
ステツプ608へ進む。
この例では、Ｄの(d)により、第１回目およ
び第２回目にはステツプ608へ進み、第３回
目にステツプ609へ進む。
び第２回目にはステツプ608へ進み、第３回
目にステツプ609へ進む。
(e) 第３の処理要求解析実行機構５１−２によ
り、第２の通信実行制御機構５０−２を介し
て、処理状態、即ちDBMS４０−２での処
理は継続中であること、および結合演算結果
が計算機４５へ送られる（ステツプ608）。
り、第２の通信実行制御機構５０−２を介し
て、処理状態、即ちDBMS４０−２での処
理は継続中であること、および結合演算結果
が計算機４５へ送られる（ステツプ608）。
この例では、計算機４５へ送られる結合演
算結果はＥの(c)の仮定により、第１回目には
タプル（ａあイ）、（ｂあイ）、第２回目では
タプル（ｅいロ）、（ｄいロ）である。
算結果はＥの(c)の仮定により、第１回目には
タプル（ａあイ）、（ｂあイ）、第２回目では
タプル（ｅいロ）、（ｄいロ）である。
(f) 第３の処理要求解析実行機構５１−２によ
つて、DBMS４０−２が第１の結合演算実
行サイトであつたかどうかが判断される（ス
テツプ610）。DBMS４０−２は第１の実行
サイトではないと判断され（Ｅの(g)）ステツ
プ611へ進む。
つて、DBMS４０−２が第１の結合演算実
行サイトであつたかどうかが判断される（ス
テツプ610）。DBMS４０−２は第１の実行
サイトではないと判断され（Ｅの(g)）ステツ
プ611へ進む。
(g) DBMS４０−１からの、次の処理要求が
第２の通信実行制御機構５０−２によつて受
信され、この処理要求は処理要求解析実行機
構５１−２に送られる（ステツプ611）。その
後（Ｅの(c)）ステツプ606へ進む。
第２の通信実行制御機構５０−２によつて受
信され、この処理要求は処理要求解析実行機
構５１−２に送られる（ステツプ611）。その
後（Ｅの(c)）ステツプ606へ進む。
(h) 第３の処理要求解析実行機構５１−２によ
り、第２の通信実行制御機構５０−２を介し
て、処理状態、即ちDBMS４０−２での処
理が終了したこと、および結合演算結果が計
算機４５へ送られる（ステツプ609）。その後
DBMS４０−２は再び待ち状態（ステツプ
600）に戻る。
り、第２の通信実行制御機構５０−２を介し
て、処理状態、即ちDBMS４０−２での処
理が終了したこと、および結合演算結果が計
算機４５へ送られる（ステツプ609）。その後
DBMS４０−２は再び待ち状態（ステツプ
600）に戻る。
この例では、結合演算結果は、Ｅの(c)の仮
定により空集合である。
定により空集合である。
結合演算処理において、Ｂの(g)〜(j)、Ｄの(a)〜
(g)、Ｅの(a)〜(h)の処理は、計算機４５→DBMS
４０−１→DBMS４０−２→計算機４５の順に
よるパイプライン処理になつている。また、通常
の処理では、まずAP４６からの結合演算の要求
に先だつて、リレーシヨンの定義が行われてい
る。
(g)、Ｅの(a)〜(h)の処理は、計算機４５→DBMS
４０−１→DBMS４０−２→計算機４５の順に
よるパイプライン処理になつている。また、通常
の処理では、まずAP４６からの結合演算の要求
に先だつて、リレーシヨンの定義が行われてい
る。
（発明の効果）
以上、詳細に説明したように本発明によれば、
分散データベース管理システムにおける結合演算
処理に際して、分散データベース管理システムを
構成する各計算機間のデータ転送回数を減少させ
ることが出来、また結合演算の前処理による処理
負荷を取り除くことが出来るため、分散データベ
ース管理システムでの結合演算処理を高速に行な
うことが可能である。更に、結合演算処理に係わ
る計算機を通じて結合演算処理が順次段階的に行
われるので結合演算を高速に行うことが可能であ
る。
分散データベース管理システムにおける結合演算
処理に際して、分散データベース管理システムを
構成する各計算機間のデータ転送回数を減少させ
ることが出来、また結合演算の前処理による処理
負荷を取り除くことが出来るため、分散データベ
ース管理システムでの結合演算処理を高速に行な
うことが可能である。更に、結合演算処理に係わ
る計算機を通じて結合演算処理が順次段階的に行
われるので結合演算を高速に行うことが可能であ
る。
第１図は本発明の実施例の構成図、第２図はリ
レーシヨンの例、第３図は従来の結合演算処理方
式の構成図、第４図は本発明による結合演算処理
方式の概略説明図、第５図、第６図は第１図に示
す実施例の結合演算処理の流れを示すフローチヤ
ートである。 ４０−１……サイトＡ、４０−２……サイト
Ｂ、４１……通信網、４２……分散データベース
管理システム、４３−１，４３−２……データベ
ース、４４……分散データベース、４５……計算
機、４６……AP、４７−１−１，４７−１−２，
５６……リレーシヨン、４８……処理手順決定管
理機構、４９−１−１，４９−２−１……定義情
報、５０−１，５０−２……通信実行制御機構、
５１−１，５１−２……処理要求解析実行機構、
５２−１，５２−２……データベース処理実行制
御機構、５５……DBMSアクセス管理機構、５
７……処理要求解析実行機構。
レーシヨンの例、第３図は従来の結合演算処理方
式の構成図、第４図は本発明による結合演算処理
方式の概略説明図、第５図、第６図は第１図に示
す実施例の結合演算処理の流れを示すフローチヤ
ートである。 ４０−１……サイトＡ、４０−２……サイト
Ｂ、４１……通信網、４２……分散データベース
管理システム、４３−１，４３−２……データベ
ース、４４……分散データベース、４５……計算
機、４６……AP、４７−１−１，４７−１−２，
５６……リレーシヨン、４８……処理手順決定管
理機構、４９−１−１，４９−２−１……定義情
報、５０−１，５０−２……通信実行制御機構、
５１−１，５１−２……処理要求解析実行機構、
５２−１，５２−２……データベース処理実行制
御機構、５５……DBMSアクセス管理機構、５
７……処理要求解析実行機構。
Claims (1)
- 【特許請求の範囲】 １ 複数の第１の計算機と、少なくとも一つの第
２の計算機と、前記第１の計算機及び前記第２の
計算機の各々とが直接的もしくは間接的に相互に
通信可能な通信網と、前記複数の第１の計算機に
分散されて格納されている分散データベースとが
存在し、前記第２の計算機の結合演算指示に基づ
いて、前記複数の第１の計算機が前記分散データ
ベースに対して結合演算処理を実行する分散デー
タベース管理システムにおける結合演算処理方式
において、 前記第１の計算機は、 前記第２の計算機及び前記第１の計算機から送
信された処理要求を受信する受信手段と、 前記受信手段により受信された前記処理要求を
解析し判断する処理要求解析手段と、 前記処理要求解析手段が前記第２の計算機から
送信されたリレーシヨン定義要求であると判断し
た場合、前記第１の計算機自身が有する部分にお
ける前記分散データベースについてリレーシヨン
定義情報を作成し記憶するリレーシヨン定義情報
作成手段と、 前記処理要求解析手段が前記第２の計算機から
送信されたリレーシヨン定義情報読出要求である
と判断した場合、前記リレーシヨン定義情報作成
手段により作成され記憶されている前記リレーシ
ヨン定義情報を読み出すリレーシヨン定義情報読
出手段と、 前記処理要求解析手段が前記第２の計算機もし
くは前記第１の計算機から送信された結合演算処
理要求であると判断した場合、 前記結合演算処理要求に基づいて、前記第２の
計算機または以降の前記第１の計算機で行うべき
指示情報を作成する指示情報作成手段と、 前記結合演算処理要求及び前記リレーシヨン定
義情報とに基づいて、前記第１の計算機自身が有
する部分における前記分散データベースについて
の結合演算処理を実行する結合演算処理手段と、 前記指示情報作成手段により作成された前記指
示情報及び前記結合演算処理手段により実行され
た前記結合演算処理の結果とに基づいて、新たな
結合演算処理要求を作成する結合演算処理要求作
成手段と、 前記処理要求に基づいて、前記第１の計算機及
び前記第２の計算機の中から送信対象とすべき計
算機を決定する送信先決定手段と、 前記リレーシヨン定義情報読出手段により読み
出された前記リレーシヨン定義情報及び前記結合
演算処理要求作成手段により作成された結合演算
処理要求を、前記送信先決定手段により決定され
た計算機に送信する送信手段とを有すること を特徴とする分散データベース管理システムにお
ける結合演算処理方式。
Priority Applications (3)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| JP60047452A JPS61208124A (ja) | 1985-03-12 | 1985-03-12 | 分散デ−タベ−ス管理システムにおける結合演算処理方式 |
| US06/837,283 US4811207A (en) | 1985-03-12 | 1986-03-06 | Join operation processing system in distributed data base management system |
| GB8606157A GB2172418B (en) | 1985-03-12 | 1986-03-12 | Join operation processing system in distributed data base management system |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| JP60047452A JPS61208124A (ja) | 1985-03-12 | 1985-03-12 | 分散デ−タベ−ス管理システムにおける結合演算処理方式 |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| JPS61208124A JPS61208124A (ja) | 1986-09-16 |
| JPH0556541B2 true JPH0556541B2 (ja) | 1993-08-19 |
Family
ID=12775543
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| JP60047452A Granted JPS61208124A (ja) | 1985-03-12 | 1985-03-12 | 分散デ−タベ−ス管理システムにおける結合演算処理方式 |
Country Status (3)
| Country | Link |
|---|---|
| US (1) | US4811207A (ja) |
| JP (1) | JPS61208124A (ja) |
| GB (1) | GB2172418B (ja) |
Cited By (1)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN105745802A (zh) * | 2013-11-21 | 2016-07-06 | 泰科电子瑞侃有限责任公司 | 连接器组件 |
Families Citing this family (54)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US4967341A (en) * | 1986-02-14 | 1990-10-30 | Hitachi, Ltd. | Method and apparatus for processing data base |
| FR2619239A1 (fr) * | 1987-08-07 | 1989-02-10 | Sagem | Procede d'archivage de cartes geographiques et procede de lecture des cartes archivees |
| JP2525047B2 (ja) * | 1987-12-18 | 1996-08-14 | インターナショナル・ビジネス・マシーンズ・コーポレーション | 複合予定表作成方法 |
| US5513332A (en) * | 1988-05-31 | 1996-04-30 | Extended Systems, Inc. | Database management coprocessor for on-the-fly providing data from disk media to all without first storing data in memory therebetween |
| US4933848A (en) * | 1988-07-15 | 1990-06-12 | International Business Machines Corporation | Method for enforcing referential constraints in a database management system |
| US5345587A (en) | 1988-09-14 | 1994-09-06 | Digital Equipment Corporation | Extensible entity management system including a dispatching kernel and modules which independently interpret and execute commands |
| US5101345A (en) * | 1988-11-29 | 1992-03-31 | International Business Machines Inc. | Method of filing stapled documents with a staple relationship involving one or more application programs |
| US5220516A (en) * | 1989-02-21 | 1993-06-15 | International Business Machines Corp. | Asynchronous staging of objects between computer systems in cooperative processing systems |
| US5197005A (en) * | 1989-05-01 | 1993-03-23 | Intelligent Business Systems | Database retrieval system having a natural language interface |
| US5185887A (en) * | 1989-07-06 | 1993-02-09 | Hitachi, Ltd. | Database generation management method and system |
| JPH07104871B2 (ja) * | 1989-08-31 | 1995-11-13 | 三菱電機株式会社 | リレーショナル・データベースにおけるジョイン処理方式 |
| US5241648A (en) * | 1990-02-13 | 1993-08-31 | International Business Machines Corporation | Hybrid technique for joining tables |
| AU9030391A (en) * | 1990-10-16 | 1992-05-20 | Consilium, Inc. | Object-oriented architecture for factory floor management |
| US6101490A (en) * | 1991-07-19 | 2000-08-08 | Hatton; Charles Malcolm | Computer system program for creating new ideas and solving problems |
| US5668986A (en) * | 1991-10-02 | 1997-09-16 | International Business Machines Corporation | Method and apparatus for handling data storage requests in a distributed data base environment |
| US5555403A (en) * | 1991-11-27 | 1996-09-10 | Business Objects, S.A. | Relational database access system using semantically dynamic objects |
| US6578027B2 (en) | 1996-08-20 | 2003-06-10 | Business Objects, Sa | Relational database access system using semantically dynamic objects |
| JP3526585B2 (ja) * | 1992-03-12 | 2004-05-17 | 株式会社リコー | 分散データベースの質問処理最適化方式 |
| US5423035A (en) * | 1992-12-23 | 1995-06-06 | Hughes Aircraft Company | Method for evaluating relational database queries with automatic indexing and ordering of join components |
| US5652897A (en) * | 1993-05-24 | 1997-07-29 | Unisys Corporation | Robust language processor for segmenting and parsing-language containing multiple instructions |
| US5680618A (en) * | 1993-05-26 | 1997-10-21 | Borland International, Inc. | Driver query and substitution for format independent native data access |
| US5584024A (en) * | 1994-03-24 | 1996-12-10 | Software Ag | Interactive database query system and method for prohibiting the selection of semantically incorrect query parameters |
| US5913032A (en) * | 1994-04-04 | 1999-06-15 | Inprise Corporation | System and methods for automatically distributing a particular shared data object through electronic mail |
| US5740423A (en) * | 1995-12-28 | 1998-04-14 | Csg Systems, Inc. | System and method for accessing distributed data on a plurality of databases |
| US5799284A (en) * | 1996-03-13 | 1998-08-25 | Roy E. Bourquin | Software and hardware for publishing and viewing products and services for sale |
| US5899997A (en) * | 1996-04-03 | 1999-05-04 | Transparency Systems, Inc. | Object-oriented query mechanism |
| US5892909A (en) * | 1996-09-27 | 1999-04-06 | Diffusion, Inc. | Intranet-based system with methods for co-active delivery of information to multiple users |
| US20050021477A1 (en) * | 1997-01-29 | 2005-01-27 | Ganapathy Krishnan | Method and system for securely incorporating electronic information into an online purchasing application |
| US6990458B2 (en) * | 1997-08-28 | 2006-01-24 | Csg Systems, Inc. | System and method for computer-aided technician dispatch and communication |
| US6510429B1 (en) * | 1998-04-29 | 2003-01-21 | International Business Machines Corporation | Message broker apparatus, method and computer program product |
| US6996612B1 (en) | 1999-12-30 | 2006-02-07 | Vignette Corporation | Method of providing information related to activity of a user and a data processing system program product |
| US7860969B2 (en) * | 2000-06-02 | 2010-12-28 | Vignette Software Llc | Method for continuous, frame-specific click-stream recording |
| US7155506B1 (en) | 2000-06-02 | 2006-12-26 | Vignette Corporation | Method for continous, frame-specific click-stream recording |
| US6865574B1 (en) | 2000-06-02 | 2005-03-08 | Vignette Corporation | Method for client-side personalization |
| US7251687B1 (en) | 2000-06-02 | 2007-07-31 | Vignette Corporation | Method for click-stream analysis using web directory reverse categorization |
| US6640221B1 (en) | 2000-07-10 | 2003-10-28 | Sas Institute Inc. | System and method for configuring, sequencing and viewing joins in a query |
| US7660869B1 (en) | 2000-08-21 | 2010-02-09 | Vignette Software, LLC | Network real estate analysis |
| US7278105B1 (en) | 2000-08-21 | 2007-10-02 | Vignette Corporation | Visualization and analysis of user clickpaths |
| US6850941B1 (en) | 2000-12-21 | 2005-02-01 | Vignette Corporation | Method and system for native-byte form handling |
| US7194506B1 (en) | 2000-12-21 | 2007-03-20 | Vignette Corporation | Method and system for cache management of locale-sensitive content |
| US6892377B1 (en) | 2000-12-21 | 2005-05-10 | Vignette Corporation | Method and system for platform-independent file system interaction |
| US20020165755A1 (en) * | 2001-03-29 | 2002-11-07 | Kitts Brendan J. | Method of predicting behavior of a customer at a future date and a data processing system readable medium |
| US7197474B1 (en) | 2001-07-12 | 2007-03-27 | Vignette Corporation | Method of modeling product demand subject to a large number of interactions |
| US8307045B1 (en) | 2001-08-22 | 2012-11-06 | Open Text S.A. | System and method for creating target-specific data conversion templates using a master style template |
| US7788681B1 (en) | 2003-09-16 | 2010-08-31 | Vignette Software, LLC | System and method for incorporating web services in a web site |
| US8046377B2 (en) * | 2004-12-20 | 2011-10-25 | Sap Ag | Method for calculating distributed joins in main memory with minimal communicaton overhead |
| US8271478B2 (en) * | 2006-07-27 | 2012-09-18 | Sap Ag | Fast algorithms for computing semijoin reduction sequences |
| US7636712B2 (en) * | 2006-11-14 | 2009-12-22 | Microsoft Corporation | Batching document identifiers for result trimming |
| US8046750B2 (en) | 2007-06-13 | 2011-10-25 | Microsoft Corporation | Disco: a simplified distributed computing library |
| JP5659757B2 (ja) * | 2010-12-09 | 2015-01-28 | 日本電気株式会社 | 分散データベース管理システム、分散データベース管理方法 |
| WO2012104943A1 (ja) * | 2011-02-02 | 2012-08-09 | 日本電気株式会社 | 結合処理装置、データ管理装置及び文字列類似結合システム |
| US8793287B2 (en) * | 2011-05-27 | 2014-07-29 | Sap Ag | Equi-joins between split tables |
| US8825633B2 (en) | 2012-05-15 | 2014-09-02 | Sas Institute Inc. | System, method, and data structure for automatically generating database queries which are data model independent and cardinality independent |
| US10402388B1 (en) | 2017-01-31 | 2019-09-03 | Levyx, Inc. | Partition-based analytic systems and methods |
Family Cites Families (4)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US4435758A (en) * | 1980-03-10 | 1984-03-06 | International Business Machines Corporation | Method for conditional branch execution in SIMD vector processors |
| JPS583031A (ja) * | 1981-06-30 | 1983-01-08 | Fujitsu Ltd | リレ−シヨナル・モデルにおけるジヨイン演算処理方式 |
| US4422145A (en) * | 1981-10-26 | 1983-12-20 | International Business Machines Corporation | Thrashing reduction in demand accessing of a data base through an LRU paging buffer pool |
| US4631664A (en) * | 1983-07-19 | 1986-12-23 | Bachman Information Systems, Inc. | Partnership data base management system and method |
-
1985
- 1985-03-12 JP JP60047452A patent/JPS61208124A/ja active Granted
-
1986
- 1986-03-06 US US06/837,283 patent/US4811207A/en not_active Expired - Lifetime
- 1986-03-12 GB GB8606157A patent/GB2172418B/en not_active Expired
Cited By (1)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN105745802A (zh) * | 2013-11-21 | 2016-07-06 | 泰科电子瑞侃有限责任公司 | 连接器组件 |
Also Published As
| Publication number | Publication date |
|---|---|
| GB2172418B (en) | 1989-06-21 |
| GB8606157D0 (en) | 1986-04-16 |
| GB2172418A (en) | 1986-09-17 |
| US4811207A (en) | 1989-03-07 |
| JPS61208124A (ja) | 1986-09-16 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| JPH0556541B2 (ja) | ||
| US11886284B2 (en) | System and method for data redistribution in a database | |
| Madria et al. | A transaction model to improve data availability in mobile computing | |
| US5263156A (en) | Parallel, distributed optimistic concurrency control certification using hardware filtering | |
| US7814065B2 (en) | Affinity-based recovery/failover in a cluster environment | |
| US5781910A (en) | Preforming concurrent transactions in a replicated database environment | |
| US5903887A (en) | Method and apparatus for caching result sets from queries to a remote database in a heterogeneous database system | |
| US6850927B1 (en) | Evaluating queries with outer joins by categorizing and processing combinations of relationships between table records | |
| EP1649374A2 (en) | Parallel recovery by non-failed nodes | |
| JPH05334165A (ja) | 並列データベース処理システムおよびその２次キー検索方法 | |
| Cornell et al. | On optimal site assignment for relations in the distributed database environment | |
| US7246120B2 (en) | Techniques for achieving higher availability of resources during reconfiguration of a cluster | |
| US7921220B2 (en) | Reducing occurrences of two-phase commits in a multi-node computing system | |
| Gardarin et al. | A distributed control algorithm for reliably and consistently updating replicated databases | |
| Lavenberg et al. | Stochastic modeling of processor scheduling with application to data base management systems | |
| JPH07141237A (ja) | データベースアクセス制御装置 | |
| Agrawal et al. | SPEEDITY-A real time commit protocol | |
| JPH103458A (ja) | データベース管理システムの負荷分散方法 | |
| JP2980610B2 (ja) | トランザクション管理装置 | |
| Li | Performance models of distributed database systems | |
| Bray | Data management requirements: The similarity of memory management, database systems, and message processing | |
| CN119739789A (zh) | 多模态数据库跨引擎并行处理方法、装置、设备及介质 | |
| JPH02285460A (ja) | コンピュータ負荷平準化方法 | |
| Wong | Integrated transaction management for distributed decision-making. | |
| JPH02139668A (ja) | 関係データベースシステム |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| EXPY | Cancellation because of completion of term |