JPH103458A - データベース管理システムの負荷分散方法 - Google Patents
データベース管理システムの負荷分散方法Info
- Publication number
- JPH103458A JPH103458A JP8154097A JP15409796A JPH103458A JP H103458 A JPH103458 A JP H103458A JP 8154097 A JP8154097 A JP 8154097A JP 15409796 A JP15409796 A JP 15409796A JP H103458 A JPH103458 A JP H103458A
- Authority
- JP
- Japan
- Prior art keywords
- processing
- processing device
- database management
- management system
- load
- 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.)
- Granted
Links
Landscapes
- Information Retrieval, Db Structures And Fs Structures Therefor (AREA)
- Multi Processors (AREA)
Abstract
(57)【要約】
【課題】 各処理装置１，２，３にそれぞれデータベー
ス１４，２４，３４が接続され、それぞれデータベース
管理システム１１，２１，３１によってデータベース管
理を行うシステムにおいて、データベースの検索に続く
表の結合処理を未処理分の負荷の大きさに基づいて負荷
分散する。 【解決手段】 処理行数カウンタ１２，２２，３２は、
結合処理の処理行数に応じて更新される未処理分の累積
処理行数を保持する。表ｘと表ｙの検索処理を終えた
後、データベース管理システム１１は結合処理を行う処
理装置を割り当てるに当り、結合処理に伴うネットワー
ク１０のデータ転送の負荷を削減するように処理装置を
選択する。２つの処理装置のネットワーク負荷が同等で
あるとき、処理行数カウンタ１２，２２，３２の値に基
づいて負荷の少ない処理装置を選択する。
ス１４，２４，３４が接続され、それぞれデータベース
管理システム１１，２１，３１によってデータベース管
理を行うシステムにおいて、データベースの検索に続く
表の結合処理を未処理分の負荷の大きさに基づいて負荷
分散する。 【解決手段】 処理行数カウンタ１２，２２，３２は、
結合処理の処理行数に応じて更新される未処理分の累積
処理行数を保持する。表ｘと表ｙの検索処理を終えた
後、データベース管理システム１１は結合処理を行う処
理装置を割り当てるに当り、結合処理に伴うネットワー
ク１０のデータ転送の負荷を削減するように処理装置を
選択する。２つの処理装置のネットワーク負荷が同等で
あるとき、処理行数カウンタ１２，２２，３２の値に基
づいて負荷の少ない処理装置を選択する。
Description
【０００１】
【発明の属する技術分野】本発明は、データベース管理
システムの負荷分散方法に係わり、特に複数の情報処理
装置がネットワークを介して相互に接続されるシステム
において情報処理装置の負荷を分散させる方法に関す
る。
システムの負荷分散方法に係わり、特に複数の情報処理
装置がネットワークを介して相互に接続されるシステム
において情報処理装置の負荷を分散させる方法に関す
る。
【０００２】
【従来の技術】複数の処理装置がネットワークを介して
相互に接続されるシステムにおいて、各処理装置のＣＰ
Ｕ利用率を計測しＣＰＵ利用率に応じて負荷を分散させ
る方法が行われている。すなわちこの方法は、新しいジ
ョブや処理をいずれかの処理装置に割り当てる時点でＣ
ＰＵ利用率が最も低い処理装置を選択することによって
処理装置の負荷を分散させるものである。しかしこの方
法は、一時点のＣＰＵ利用率に基づいて処理装置にかか
っている負荷の大きさを推測するものであり、必ずしも
各処理装置が実際に保持している負荷の大きさを反映し
ているとは言えない。
相互に接続されるシステムにおいて、各処理装置のＣＰ
Ｕ利用率を計測しＣＰＵ利用率に応じて負荷を分散させ
る方法が行われている。すなわちこの方法は、新しいジ
ョブや処理をいずれかの処理装置に割り当てる時点でＣ
ＰＵ利用率が最も低い処理装置を選択することによって
処理装置の負荷を分散させるものである。しかしこの方
法は、一時点のＣＰＵ利用率に基づいて処理装置にかか
っている負荷の大きさを推測するものであり、必ずしも
各処理装置が実際に保持している負荷の大きさを反映し
ているとは言えない。
【０００３】なおこの種の技術として関連するものに
は、例えば特開平４−１２９３９９号公報や特開平５−
１５１１７７号公報などがある。
は、例えば特開平４−１２９３９９号公報や特開平５−
１５１１７７号公報などがある。
【０００４】
【発明が解決しようとする課題】ＣＰＵ利用率は必ずし
も処理装置が将来消化すべき負荷の大きさを反映するも
のではないので、ＣＰＵ利用率に従って負荷分散制御を
行うと、正しく負荷分散ができず、１つの処理装置に処
理が集中してしまう場合があった。
も処理装置が将来消化すべき負荷の大きさを反映するも
のではないので、ＣＰＵ利用率に従って負荷分散制御を
行うと、正しく負荷分散ができず、１つの処理装置に処
理が集中してしまう場合があった。
【０００５】本発明の目的は、データベース管理システ
ムにおいて未処理分の負荷の大きさに応じて負荷の分散
制御を行い、上記問題を解決することにある。
ムにおいて未処理分の負荷の大きさに応じて負荷の分散
制御を行い、上記問題を解決することにある。
【０００６】
【課題を解決するための手段】本発明は、各処理装置に
少なくとも１つの表から構成されるデータベースが接続
され、並列してデータベースの検索を行うシステムにお
いて、各処理装置では検索結果の表の結合処理を行うと
きの処理行数に応じて未処理分の処理件数を示す累積処
理行数を常時更新し、２つの処理装置に関する結合処理
に伴って発生するネットワークの負荷が同等である場合
に累積処理行数の少ない処理装置に結合処理を割り当て
る負荷分散方法を特徴とする。処理装置の負荷を示す指
標として結合処理の処理行数を採用する理由は、結合処
理の処理行数からこの処理にかかるＣＰＵ時間を予測で
き、処理装置が保持する負荷の大きさをほぼ把握できる
ためである。
少なくとも１つの表から構成されるデータベースが接続
され、並列してデータベースの検索を行うシステムにお
いて、各処理装置では検索結果の表の結合処理を行うと
きの処理行数に応じて未処理分の処理件数を示す累積処
理行数を常時更新し、２つの処理装置に関する結合処理
に伴って発生するネットワークの負荷が同等である場合
に累積処理行数の少ない処理装置に結合処理を割り当て
る負荷分散方法を特徴とする。処理装置の負荷を示す指
標として結合処理の処理行数を採用する理由は、結合処
理の処理行数からこの処理にかかるＣＰＵ時間を予測で
き、処理装置が保持する負荷の大きさをほぼ把握できる
ためである。
【０００７】
【発明の実施の形態】以下、本発明の一実施形態につい
て図面を用いて説明する。
て図面を用いて説明する。
【０００８】図１は、本実施形態の並列計算機システム
の構成図である。並列計算機システムは、複数の処理装
置１，２，３とこれらの処理装置を相互に接続するネッ
トワーク１０から構成される。各処理装置１，２，３
は、それぞれデータベース１４，２４，３４を接続す
る。これらのデータベースは、リレーショナル・データ
ベースであり、データベース１４は表Ａと表Ｂ、データ
ベース２４は表Ｃと表Ｄ、データベース３４は表Ｅから
構成される。データベース管理システム１１，２１，３
１は、それぞれデータベース１４，２４，３４を管理す
るプログラムであり、それぞれ検索結果を結合するとき
の未処理分の累積処理行数を保持する処理行数カウンタ
１２，２２，３２を有する。ＵＡＰ（ユーザ・アプリケ
ーション・プログラム）１３，２３，３３は、それぞれ
データベース管理システム１１，２１，３１へデータベ
ースの検索要求を発行するプログラムである。データベ
ース管理テーブル１５は、データベースを構成する表の
名称とその表を所有する処理装置との対応を格納するテ
ーブルであり、処理装置１に接続される記憶装置上に格
納される。図示していないが、データベース管理テーブ
ル１５は処理装置２及び３にもそれぞれ接続される。
の構成図である。並列計算機システムは、複数の処理装
置１，２，３とこれらの処理装置を相互に接続するネッ
トワーク１０から構成される。各処理装置１，２，３
は、それぞれデータベース１４，２４，３４を接続す
る。これらのデータベースは、リレーショナル・データ
ベースであり、データベース１４は表Ａと表Ｂ、データ
ベース２４は表Ｃと表Ｄ、データベース３４は表Ｅから
構成される。データベース管理システム１１，２１，３
１は、それぞれデータベース１４，２４，３４を管理す
るプログラムであり、それぞれ検索結果を結合するとき
の未処理分の累積処理行数を保持する処理行数カウンタ
１２，２２，３２を有する。ＵＡＰ（ユーザ・アプリケ
ーション・プログラム）１３，２３，３３は、それぞれ
データベース管理システム１１，２１，３１へデータベ
ースの検索要求を発行するプログラムである。データベ
ース管理テーブル１５は、データベースを構成する表の
名称とその表を所有する処理装置との対応を格納するテ
ーブルであり、処理装置１に接続される記憶装置上に格
納される。図示していないが、データベース管理テーブ
ル１５は処理装置２及び３にもそれぞれ接続される。
【０００９】ＵＡＰ１３から表ｘと表ｙを検索した後に
表の結合を行うＳＱＬが発行されたとき、データベース
管理システム１１はデータベース管理テーブル１５を参
照して表ｘ及び表ｙを所有する処理装置の番号を求め、
各表を有する処理装置のデータベース管理システムへ検
索要求を発行する。各データベース管理システムはそれ
ぞれ表ｘ及び表ｙを検索し、検索処理が終了したときヒ
ットした検索行数ｘn及びｙnをデータベース管理システ
ム１１に報告する。データベース管理システム１１は、
検索結果及び結合結果のネットワーク１０を介するデー
タ転送量を削減するように表ｘ又は表ｙを所有する処理
装置のいずれか一方に表の結合処理要求を発行する。結
合処理要求を受けた処理装置のデータベース管理システ
ムは、他方の表を所有する処理装置のデータベース管理
システムへ検索結果を要求し、検索結果を受けたとき処
理行数カウンタ１２，２２又は３２に結合処理の処理行
数を加算してから結合処理を行う。結合処理が終了した
とき、処理行数カウンタから結合処理行数を減算した
後、データベース管理システム１１へ結合結果を送信
し、データベース管理システム１１がＵＡＰ１３に結合
結果を渡す。表ｘ又は表ｙを所有する処理装置のいずれ
を選択しても処理装置間転送が同等になるとき、データ
ベース管理システム１１は表ｘ及び表ｙを有する各処理
装置の処理行数カウンタの処理行数を比較し、負荷の少
ない処理装置のデータベース管理システムへ表の結合要
求を発行する。
表の結合を行うＳＱＬが発行されたとき、データベース
管理システム１１はデータベース管理テーブル１５を参
照して表ｘ及び表ｙを所有する処理装置の番号を求め、
各表を有する処理装置のデータベース管理システムへ検
索要求を発行する。各データベース管理システムはそれ
ぞれ表ｘ及び表ｙを検索し、検索処理が終了したときヒ
ットした検索行数ｘn及びｙnをデータベース管理システ
ム１１に報告する。データベース管理システム１１は、
検索結果及び結合結果のネットワーク１０を介するデー
タ転送量を削減するように表ｘ又は表ｙを所有する処理
装置のいずれか一方に表の結合処理要求を発行する。結
合処理要求を受けた処理装置のデータベース管理システ
ムは、他方の表を所有する処理装置のデータベース管理
システムへ検索結果を要求し、検索結果を受けたとき処
理行数カウンタ１２，２２又は３２に結合処理の処理行
数を加算してから結合処理を行う。結合処理が終了した
とき、処理行数カウンタから結合処理行数を減算した
後、データベース管理システム１１へ結合結果を送信
し、データベース管理システム１１がＵＡＰ１３に結合
結果を渡す。表ｘ又は表ｙを所有する処理装置のいずれ
を選択しても処理装置間転送が同等になるとき、データ
ベース管理システム１１は表ｘ及び表ｙを有する各処理
装置の処理行数カウンタの処理行数を比較し、負荷の少
ない処理装置のデータベース管理システムへ表の結合要
求を発行する。
【００１０】図２は、データベース管理テーブル１５の
データ形式を示す図である。データベース管理テーブル
１５は、表の識別子とその表を有する処理装置の番号と
の対応を保持する。
データ形式を示す図である。データベース管理テーブル
１５は、表の識別子とその表を有する処理装置の番号と
の対応を保持する。
【００１１】図３は、ＵＡＰ１３から表ｘと表ｙを検索
した後に表の結合を行うＳＱＬが発行された後のデータ
ベース管理システム１１の処理の流れを示すフローチャ
ートである。ただしステップ４１，４３及び４５は、ネ
ットワーク１０を介する処理装置のデータ転送及び他の
データベース管理システムの処理を伴う場合がある。デ
ータベース管理システム１１は、データベース管理テー
ブル１５を参照して表ｘと表ｙを所有する処理装置の番
号を求め、検索処理を実行する（ステップ４１）。すな
わち表ｘと表ｙを所有する処理装置のデータベース管理
システムへそれぞれトランザクションＩＤと表ｘ又は表
ｙを指定して検索要求を送信する。処理装置１が表ｘと
表ｙのいずれか一方又は両方を所有するのであれば、デ
ータベース管理システム１１中の検索処理プログラムへ
検索要求を発行するだけである。検索処理が終了したと
き、データベース管理システム１１は同一のトランザク
ションＩＤ、検索の結果ヒットした行数ｘn，ｙn及び処
理行数カウンタの値を受け取る。次にデータベース管理
システム１１は、表ｘと表ｙが同一処理装置であれば
（ステップ４２ＹＥＳ）、表ｘのある処理装置による結
合処理を行う（ステップ４３）。表ｘと表ｙを所有する
処理装置が異なるとき（ステップ４２ＮＯ）、表ｘと表
ｙのヒットした検索行数を比較する（ステップ４４）。
表ｘの検索行数が大きければ（ｘn＞ｙn）、表ｘのある
処理装置による結合処理を行う（ステップ４３）。表ｙ
の検索行数が大きければ（ｘn＜ｙn）、表ｙのある処理
装置による結合処理を行う（ステップ４５）。表ｘの検
索行数と表ｙの検索行数が等しいとき（ｘn＝ｙn）、Ｕ
ＡＰ１３と表ｘが同一処理装置にあれば（ステップ４６
ＹＥＳ）、表ｘのある処理装置による結合処理を行う
（ステップ４３）。ＵＡＰ１３と表ｘのある処理装置が
異なり（ステップ４６ＮＯ）、ＵＡＰ１３と表ｙが同一
処理装置にあれば（ステップ４７ＹＥＳ）、表ｙのある
処理装置による結合処理を行う（ステップ４５）。ＵＡ
Ｐ１３，表ｘ及び表ｙが別々の処理装置にあれば（ステ
ップ４７ＮＯ）、データベース管理システム１１は、表
ｘを有する処理装置の処理行数ｐ（ｘ）mと表ｙを有す
る処理装置の処理行数ｐ（ｙ）mとを比較する（ステッ
プ４８）。処理行数ｐ（ｘ）mの方が小さいか等しけれ
ば（ｐ（ｘ）m≦ｐ（ｙ）m）、表ｘのある処理装置によ
る結合処理を行う（ステップ４３）。処理行数ｐ（ｙ）
mの方が小さければ（ｐ（ｘ）m＞ｐ（ｙ）m）、表ｙの
ある処理装置による結合処理を行う（ステップ４５）。
した後に表の結合を行うＳＱＬが発行された後のデータ
ベース管理システム１１の処理の流れを示すフローチャ
ートである。ただしステップ４１，４３及び４５は、ネ
ットワーク１０を介する処理装置のデータ転送及び他の
データベース管理システムの処理を伴う場合がある。デ
ータベース管理システム１１は、データベース管理テー
ブル１５を参照して表ｘと表ｙを所有する処理装置の番
号を求め、検索処理を実行する（ステップ４１）。すな
わち表ｘと表ｙを所有する処理装置のデータベース管理
システムへそれぞれトランザクションＩＤと表ｘ又は表
ｙを指定して検索要求を送信する。処理装置１が表ｘと
表ｙのいずれか一方又は両方を所有するのであれば、デ
ータベース管理システム１１中の検索処理プログラムへ
検索要求を発行するだけである。検索処理が終了したと
き、データベース管理システム１１は同一のトランザク
ションＩＤ、検索の結果ヒットした行数ｘn，ｙn及び処
理行数カウンタの値を受け取る。次にデータベース管理
システム１１は、表ｘと表ｙが同一処理装置であれば
（ステップ４２ＹＥＳ）、表ｘのある処理装置による結
合処理を行う（ステップ４３）。表ｘと表ｙを所有する
処理装置が異なるとき（ステップ４２ＮＯ）、表ｘと表
ｙのヒットした検索行数を比較する（ステップ４４）。
表ｘの検索行数が大きければ（ｘn＞ｙn）、表ｘのある
処理装置による結合処理を行う（ステップ４３）。表ｙ
の検索行数が大きければ（ｘn＜ｙn）、表ｙのある処理
装置による結合処理を行う（ステップ４５）。表ｘの検
索行数と表ｙの検索行数が等しいとき（ｘn＝ｙn）、Ｕ
ＡＰ１３と表ｘが同一処理装置にあれば（ステップ４６
ＹＥＳ）、表ｘのある処理装置による結合処理を行う
（ステップ４３）。ＵＡＰ１３と表ｘのある処理装置が
異なり（ステップ４６ＮＯ）、ＵＡＰ１３と表ｙが同一
処理装置にあれば（ステップ４７ＹＥＳ）、表ｙのある
処理装置による結合処理を行う（ステップ４５）。ＵＡ
Ｐ１３，表ｘ及び表ｙが別々の処理装置にあれば（ステ
ップ４７ＮＯ）、データベース管理システム１１は、表
ｘを有する処理装置の処理行数ｐ（ｘ）mと表ｙを有す
る処理装置の処理行数ｐ（ｙ）mとを比較する（ステッ
プ４８）。処理行数ｐ（ｘ）mの方が小さいか等しけれ
ば（ｐ（ｘ）m≦ｐ（ｙ）m）、表ｘのある処理装置によ
る結合処理を行う（ステップ４３）。処理行数ｐ（ｙ）
mの方が小さければ（ｐ（ｘ）m＞ｐ（ｙ）m）、表ｙの
ある処理装置による結合処理を行う（ステップ４５）。
【００１２】図４は、ステップ４３及びステップ４５の
結合処理をさらに展開して示すフローチャートである。
ＵＡＰ１３のある処理装置１のデータベース管理システ
ム１１は、一方の表を有し結合処理を行う処理装置へ検
索時のトランザクションＩＤと表ｘ，表ｙを指定して結
合処理要求を送信する（ステップ５１）。結合処理を行
う処理装置は、この結合処理要求を受信したとき（ステ
ップ５２）、他方の表を有する処理装置へ検索時のトラ
ンザクションＩＤを指定して検索結果要求を送信する
（ステップ５３）。他方の表を有する処理装置は、この
検索結果要求を受信すると（ステップ５４）、結合処理
を行う処理装置へトランザクションＩＤを指定して検索
結果とヒットした検索行数を送信する（ステップ５
５）。結合処理を行う処理装置は、この検索結果を受信
すると（ステップ５６）、処理行数カウンタに結合処理
の処理行数を加算することによって処理行数カウンタを
更新し（ステップ５７）、表ｘと表ｙの検索結果につい
て結合処理を行う（ステップ５８）。結合処理が終了す
ると、処理行数カウンタから結合処理の処理行数を減算
することによって処理行数カウンタを更新する（ステッ
プ５９）。次に結合処理を行う処理装置は、処理装置１
へ結合処理要求時のトランザクションＩＤを指定して結
合結果を送信する（ステップ６０）。データベース管理
システム１１はこの結合結果を受信し（ステップ６
１）、ＵＡＰ１３へ渡す（ステップ６２）。ＵＡＰ１３
のある処理装置１と結合処理を行う処理装置とが同一処
理装置であれば、同一処理装置の処理はデータベース管
理システム１１内の処理となり、ネットワーク１０を介
する結合処理要求と結合結果の転送はない。また結合処
理を行う処理装置と他方の表を有する処理装置とが同一
処理装置であれば、同一処理装置の処理は同一データベ
ース管理システム内の処理となり、ネットワーク１０を
介する検索結果要求と検索結果の転送はない。なお図４
の例では結合処理の処理行数をヒットした検索行数ｘn
とｙnの和としたが、他にｘnとｙnの積のようにｘnとｙ
nの関数で表現できるものであればよい。
結合処理をさらに展開して示すフローチャートである。
ＵＡＰ１３のある処理装置１のデータベース管理システ
ム１１は、一方の表を有し結合処理を行う処理装置へ検
索時のトランザクションＩＤと表ｘ，表ｙを指定して結
合処理要求を送信する（ステップ５１）。結合処理を行
う処理装置は、この結合処理要求を受信したとき（ステ
ップ５２）、他方の表を有する処理装置へ検索時のトラ
ンザクションＩＤを指定して検索結果要求を送信する
（ステップ５３）。他方の表を有する処理装置は、この
検索結果要求を受信すると（ステップ５４）、結合処理
を行う処理装置へトランザクションＩＤを指定して検索
結果とヒットした検索行数を送信する（ステップ５
５）。結合処理を行う処理装置は、この検索結果を受信
すると（ステップ５６）、処理行数カウンタに結合処理
の処理行数を加算することによって処理行数カウンタを
更新し（ステップ５７）、表ｘと表ｙの検索結果につい
て結合処理を行う（ステップ５８）。結合処理が終了す
ると、処理行数カウンタから結合処理の処理行数を減算
することによって処理行数カウンタを更新する（ステッ
プ５９）。次に結合処理を行う処理装置は、処理装置１
へ結合処理要求時のトランザクションＩＤを指定して結
合結果を送信する（ステップ６０）。データベース管理
システム１１はこの結合結果を受信し（ステップ６
１）、ＵＡＰ１３へ渡す（ステップ６２）。ＵＡＰ１３
のある処理装置１と結合処理を行う処理装置とが同一処
理装置であれば、同一処理装置の処理はデータベース管
理システム１１内の処理となり、ネットワーク１０を介
する結合処理要求と結合結果の転送はない。また結合処
理を行う処理装置と他方の表を有する処理装置とが同一
処理装置であれば、同一処理装置の処理は同一データベ
ース管理システム内の処理となり、ネットワーク１０を
介する検索結果要求と検索結果の転送はない。なお図４
の例では結合処理の処理行数をヒットした検索行数ｘn
とｙnの和としたが、他にｘnとｙnの積のようにｘnとｙ
nの関数で表現できるものであればよい。
【００１３】上記実施形態によれば、検索処理は検索対
象の表を管理するデータベース管理システムのみが実行
できるから、データベース管理システム１１はそれぞれ
の表を管理する処理装置へ検索要求を発行する。表ｘと
表ｙが同一処理装置にあれば（ステップ４２ＹＥＳ）、
検索結果の送信のためのネットワーク１０の負荷がかか
らないから、表ｘ及び表ｙのある同一処理装置で結合処
理を行えばよい。表ｘと表ｙを所有する処理装置が異な
るとき（ステップ４２ＮＯ）、ヒットした検索行数ｘn
とｙnのうち検索行数の多い方の処理装置で結合処理を
行うので、検索結果の転送のためにネットワーク１０に
かかる負荷が少ない。検索行数ｘn，ｙnが同じ場合（ｘ
n＝ｙn）には、ＵＡＰと一方の表が同一処理装置にある
ような処理装置で結合処理を行うので、結合結果の転送
のためにネットワーク１０の負荷がかからない。なお一
般に検索結果のデータ量に比べて結合結果のデータ量が
小さいとみなしている。検索行数ｘn，ｙnが等しく、Ｕ
ＡＰ，表ｘ，表ｙがそれぞれ別の処理装置にある場合
（ステップ４７ＮＯ）には、表ｘのある処理装置で結合
処理を行っても表ｙのある処理装置で結合処理を行って
もネットワーク１０の負荷は同じであるので、データベ
ース管理システム１１は、表ｘを有する処理装置の処理
行数カウンタの内容と表ｙを有する処理装置の処理行数
カウンタの内容を比較して、いずれか累積負荷の小さい
方の処理装置へ結合処理要求を発行する。結合処理を行
う処理装置の負荷は、結合処理の処理行数に応じて増加
するものとみなし得る。
象の表を管理するデータベース管理システムのみが実行
できるから、データベース管理システム１１はそれぞれ
の表を管理する処理装置へ検索要求を発行する。表ｘと
表ｙが同一処理装置にあれば（ステップ４２ＹＥＳ）、
検索結果の送信のためのネットワーク１０の負荷がかか
らないから、表ｘ及び表ｙのある同一処理装置で結合処
理を行えばよい。表ｘと表ｙを所有する処理装置が異な
るとき（ステップ４２ＮＯ）、ヒットした検索行数ｘn
とｙnのうち検索行数の多い方の処理装置で結合処理を
行うので、検索結果の転送のためにネットワーク１０に
かかる負荷が少ない。検索行数ｘn，ｙnが同じ場合（ｘ
n＝ｙn）には、ＵＡＰと一方の表が同一処理装置にある
ような処理装置で結合処理を行うので、結合結果の転送
のためにネットワーク１０の負荷がかからない。なお一
般に検索結果のデータ量に比べて結合結果のデータ量が
小さいとみなしている。検索行数ｘn，ｙnが等しく、Ｕ
ＡＰ，表ｘ，表ｙがそれぞれ別の処理装置にある場合
（ステップ４７ＮＯ）には、表ｘのある処理装置で結合
処理を行っても表ｙのある処理装置で結合処理を行って
もネットワーク１０の負荷は同じであるので、データベ
ース管理システム１１は、表ｘを有する処理装置の処理
行数カウンタの内容と表ｙを有する処理装置の処理行数
カウンタの内容を比較して、いずれか累積負荷の小さい
方の処理装置へ結合処理要求を発行する。結合処理を行
う処理装置の負荷は、結合処理の処理行数に応じて増加
するものとみなし得る。
【００１４】なお上記実施形態では、ＵＡＰはいずれか
の処理装置内に所在したが、ＵＡＰが処理装置１，２，
３とは別にネットワーク１０に接続されたクライアント
装置内にあってもよい。このとき処理装置１，２及び３
は、データベースを管理するサーバとして機能する。ク
ライアントからネットワーク１０を介して処理装置１，
２又は３へＳＱＬが発行されると、これを受けた処理装
置のデータベース管理システムは、関連する処理装置と
共同して図３及び図４に示す上記処理を行った後、ネッ
トワーク１０を介して結合結果をクライアントへ送信す
る。
の処理装置内に所在したが、ＵＡＰが処理装置１，２，
３とは別にネットワーク１０に接続されたクライアント
装置内にあってもよい。このとき処理装置１，２及び３
は、データベースを管理するサーバとして機能する。ク
ライアントからネットワーク１０を介して処理装置１，
２又は３へＳＱＬが発行されると、これを受けた処理装
置のデータベース管理システムは、関連する処理装置と
共同して図３及び図４に示す上記処理を行った後、ネッ
トワーク１０を介して結合結果をクライアントへ送信す
る。
【００１５】
【発明の効果】本発明によれば、結合処理の累積処理行
数を常時更新することによって各処理装置が保持する未
処理分の負荷の大きさを予測できるため、この処理行数
に基づいて結合処理の処理装置への割当をすれば、従来
問題であった負荷の集中を防ぐことができる。
数を常時更新することによって各処理装置が保持する未
処理分の負荷の大きさを予測できるため、この処理行数
に基づいて結合処理の処理装置への割当をすれば、従来
問題であった負荷の集中を防ぐことができる。
【図１】実施形態の並列計算機システムの構成図であ
る。
る。
【図２】実施形態のデータベース管理テーブル１５のデ
ータ形式を示す図である。
ータ形式を示す図である。
【図３】実施形態の結合処理の負荷を分散させる処理の
流れを示すフローチャートである。
流れを示すフローチャートである。
【図４】図３の結合処理を展開して示すフローチャート
である。
である。
１，２，３：処理装置、１１，２１，３１：データベー
ス管理システム、１２，２２，３２：処理行数カウン
タ、１４，２４，３４：データベース
ス管理システム、１２，２２，３２：処理行数カウン
タ、１４，２４，３４：データベース
Claims (1)
- 【請求項１】複数の情報処理装置がネットワークを介し
て相互に接続され、各情報処理装置には少なくとも１つ
の表から構成されるデータベースが接続され、各情報処
理装置内のデータベース管理システムが接続されるデー
タベース内の表の検索処理を行うとともに該ネットワー
ク上のデータ転送量を削減するようにいずれかのデータ
ベース管理システムが検索結果の表の結合処理を行うシ
ステムの負荷分散方法において、 各情報処理装置では結合処理の処理行数に応じて未処理
分の累積処理行数を常時更新し、 ２つの情報処理装置に関する該データ転送量が同等であ
る場合に該累積処理行数の少ない情報処理装置によって
該結合処理を行うことを特徴とするデータベース管理シ
ステムの負荷分散方法。
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| JP15409796A JP3712791B2 (ja) | 1996-06-14 | 1996-06-14 | データベース管理方法及びその情報処理装置 |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| JP15409796A JP3712791B2 (ja) | 1996-06-14 | 1996-06-14 | データベース管理方法及びその情報処理装置 |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| JPH103458A true JPH103458A (ja) | 1998-01-06 |
| JP3712791B2 JP3712791B2 (ja) | 2005-11-02 |
Family
ID=15576855
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| JP15409796A Expired - Fee Related JP3712791B2 (ja) | 1996-06-14 | 1996-06-14 | データベース管理方法及びその情報処理装置 |
Country Status (1)
| Country | Link |
|---|---|
| JP (1) | JP3712791B2 (ja) |
Cited By (4)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| JP2010271998A (ja) * | 2009-05-22 | 2010-12-02 | Nippon Telegr & Teleph Corp <Ntt> | データベース管理方法、データベース装置、およびプログラム |
| WO2012063301A1 (ja) * | 2010-11-08 | 2012-05-18 | 株式会社日立製作所 | 計算機システム、マルチテナント制御方法及びマルチテナント制御プログラム |
| JP2014211679A (ja) * | 2013-04-17 | 2014-11-13 | 株式会社東芝 | データベースシステム |
| JP2018010424A (ja) * | 2016-07-12 | 2018-01-18 | 株式会社東芝 | データベースシステム、データ結合方法、統合サーバ、データ結合プログラム、データベースシステム連携方法、および、データベースシステム連携プログラム |
-
1996
- 1996-06-14 JP JP15409796A patent/JP3712791B2/ja not_active Expired - Fee Related
Cited By (5)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| JP2010271998A (ja) * | 2009-05-22 | 2010-12-02 | Nippon Telegr & Teleph Corp <Ntt> | データベース管理方法、データベース装置、およびプログラム |
| WO2012063301A1 (ja) * | 2010-11-08 | 2012-05-18 | 株式会社日立製作所 | 計算機システム、マルチテナント制御方法及びマルチテナント制御プログラム |
| JPWO2012063301A1 (ja) * | 2010-11-08 | 2014-05-12 | 株式会社日立製作所 | 計算機システム、マルチテナント制御方法及びマルチテナント制御プログラム |
| JP2014211679A (ja) * | 2013-04-17 | 2014-11-13 | 株式会社東芝 | データベースシステム |
| JP2018010424A (ja) * | 2016-07-12 | 2018-01-18 | 株式会社東芝 | データベースシステム、データ結合方法、統合サーバ、データ結合プログラム、データベースシステム連携方法、および、データベースシステム連携プログラム |
Also Published As
| Publication number | Publication date |
|---|---|
| JP3712791B2 (ja) | 2005-11-02 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| US8041685B2 (en) | Method of changing system configuration in shared-nothing database management system | |
| US4811207A (en) | Join operation processing system in distributed data base management system | |
| CN107545338B (zh) | 业务数据处理方法及业务数据处理系统 | |
| US5220655A (en) | Distributed computer network for tracking the access path of a user | |
| JP5536568B2 (ja) | トランザクションを集約して処理する方法、システム、およびプログラム | |
| US5903887A (en) | Method and apparatus for caching result sets from queries to a remote database in a heterogeneous database system | |
| CN102197395A (zh) | 存储器端存储请求管理 | |
| CN112419044A (zh) | 信用审核的方法、设备、电子装置和存储介质 | |
| US7246120B2 (en) | Techniques for achieving higher availability of resources during reconfiguration of a cluster | |
| CN112597173A (zh) | 一种分布式数据库集群系统对等处理系统及处理方法 | |
| US6850957B2 (en) | Information system and data access method | |
| JP4021287B2 (ja) | データベース検索プログラム、データベース検索方法及びデータベース検索装置 | |
| JPH103458A (ja) | データベース管理システムの負荷分散方法 | |
| JPH05173990A (ja) | データ処理システム | |
| US7792274B2 (en) | Techniques for performing multi-media call center functionality in a database management system | |
| CN112860494A (zh) | 一种数据中心切换方法及其相关设备 | |
| US20240054132A1 (en) | Computer system and query processing method | |
| CN107870924A (zh) | 查询数据的方法和数据查询系统 | |
| EP1213672A2 (en) | Item allocation method, system and program for workflow system | |
| CN117675847A (zh) | 数据采集方法、装置以及计算机可读存储介质 | |
| US20050155037A1 (en) | Systems and methods for providing a return value to an application program | |
| CN108763315A (zh) | 数据统计管理方法及装置 | |
| KR102571783B1 (ko) | 대용량 검색 처리를 수행하는 검색 처리 시스템 및 그 제어방법 | |
| JPH01166230A (ja) | 分散システムにおけるデータベースの配置方式 | |
| JPS63137356A (ja) | 計算機ネツトワ−クにおける資源情報の分散管理方法 |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| A61 | First payment of annual fees (during grant procedure) |
Free format text: JAPANESE INTERMEDIATE CODE: A61 Effective date: 20050818 |
|
| R150 | Certificate of patent or registration of utility model |
Free format text: JAPANESE INTERMEDIATE CODE: R150 |
|
| LAPS | Cancellation because of no payment of annual fees |