"クライアント端末からのリクエストに対して予め保持するデータベースに格納されたデータを利用した処理を行い当該処理結果であるリクエスト応答を前記クライアント端末に返信するDBサーバと、前記DBサーバから転送された処理要求に基づく処理を行う異なる複数のノードとを備えた分散データベース管理システムであって、前記DBサーバは、前記各ノードにおけるデータ処理に係る負荷情報および処理時間を示す処理負荷統計情報と前記各ノード内に処理対象データとして予め記憶されたローカルデータとを取得する処理負荷統計情報取得部と、前記リクエストを解析し当該リクエストに対する処理内容および処理手順を示す前記処理構成情報を生成するリクエスト解析部と、前記処理構成情報に基づき前記ローカルデータから処理対象データを特定し、前記処理負荷統計情報に基づき前記各ノードにおける処理負荷が平均化されるように前記処理対象データを前記各ノードに分配する部分要求分配部とを備え、前記各ノードは、自己内に保持するデータおよび前記DBサーバから送り込まれた処理対象データを利用して前記処理構成情報に基づく処理を行うと共に、前記処理構成情報に基づき他のノードまたは前記DBサーバに前記処理結果を転送する部分処理実行部と、を備えたことを特徴とする分散データベース管理システム。請求項1に記載の分散データベース管理システムにおいて、前記DBサーバに対して前記部分処理要求の処理用に新たに一のノードが接続された場合に、当該ノードを含む前記各ノードの処理負荷統計情報を再取得する統計情報再取得手段と、前記処理負荷統計情報に基づき前記部分処理要求を更新して生成する部分処理要求更新生成手段を備えたことを特徴とする分散データベース管理システム。請求項1に記載の分散データベース管理システムにおいて、前記一のノードにおける前記DBサーバに対する接続を解除した場合に、前記DBサーバに対して接続された他のノードそれぞれの処理負荷統計情報を再取得する統計情報再取得手段と、当該再取得された処理負荷統計情報に基づき前記部分処理要求を更新して生成する部分処理要求更新生成手段を備えたことを特徴とする分散データベース管理システム。請求項1に記載の分散データベース管理システムにおいて、前記DBサーバに対して前記部分処理要求の処理用に新たに他のノードが接続された場合に、当該ノードを含む前記各ノードの処理負荷統計情報を再取得し、前記DBサーバに対する一のノードの接続を解除した場合に、前記DBサーバに対する接続が維持されている他のノードそれぞれの処理負荷統計情報を再取得する統計情報再取得手段と、再取得された処理負荷統計情報に基づき前記部分処理要求を更新して生成する部分処理要求更新生成手段とを備えたことを特徴とする分散データベース管理システム。請求項1に記載の分散データベース管理システムにおいて、前記リクエスト解析部が異なる複数の処理構成情報を生成した場合に、前記部分処理要求生成部は、処理構成情報のうちデータ処理量を算出し、当該データ処理量が最小となる処理構成情報を選出する処理構成情報選出手段を備えたことを特徴とした分散データベース管理システム。請求項1、3、または4に記載の分散データベース管理システムにおいて、前記ノードは他のノードとの通信異常を検知した場合に前記通信異常が検知されたノードを障害ノードとして前記DBサーバに通知する通信障害通知手段を備え前記DBサーバは、前記障害ノードとして通知されたノードに対して応答要求を行い、当該応答要求に対する正常な応答がない場合に、当該ノードにおける前記DBサーバとの接続を解除する制御を行う接続解除制御手段を備えたことを特徴とする分散データベース管理システム。クライアント端末からのリクエストに応じて予め保持するデータベースを利用した問い合わせ処理を行いDBサーバと、前記DBサーバから転送された処理要求に対する処理をそれぞれが行う複数のノードとを備えた分散DB処理システムにあって、前記リクエストに対するリクエスト応答を前記クライアント端末に返信するための分散データベース管理方法であって、前記各ノードにおけるデータ処理に係る負荷情報および処理時間を示す処理負荷統計情報と前記各ノード内に処理対象データとして予め記憶されたローカルデータとを取得し、前記リクエストを解析し当該リクエストに対する処理内容および処理手順を示す情報としての前記処理構成情報を生成し、前記処理構成情報に基づき前記ローカルデータから処理対象データを特定し、前記処理負荷統計情報に基づき前記各ノードにおける処理負荷が平均化されるように前記処理対象データを前記各ノードに分配する、これら動作工程を前記DBサーバが実行し、次いで、前記各ノードが自己内に保持するデータおよび前記DBサーバから送り込まれた処理対象データを利用して前記処理構成情報に基づく処理を行うと共に、前記処理構成情報に基づき他のノードまたは前記DBサーバに前記処理結果を転送することを特徴とした分散データベース管理方法。クライアント端末からのリクエストに応じて予め保持するデータベースを利用した問い合わせ処理を行いDBサーバと、前記DBサーバから分配された処理要求に対する処理を行うと共にこの処理結果を処理手順情報に基づき他のノードに転送する異なる複数のノードとを備えた分散DB処理システムにあって、前記クライアント端末に前記リクエストに対するリクエスト応答を返信するための分散DB処理プログラムであって、前記各ノードにおけるデータ処理に係る負荷情報および処理時間を示す処理負荷統計情報と前記各ノード内に処理対象データとして予め記憶されたローカルデータと取得する処理負荷統計情報取得機能と、前記リクエストを解析し当該リクエストに対する処理内容および処理手順を示す情報としての前記処理構成情報を生成するリクエスト解析機能と、前記処理構成情報に基づき前記ローカルデータから処理対象データを特定し、前記処理負荷統計情報に基づき前記各ノードにおける処理負荷が平均化されるように前記処理対象データを前記各ノードに分配する部分要求分配機能と、を前記DBサーバのコンピュータにより実現することを特徴とした分散DB処理プログラム。しかしながら、上記非特許文献1~3を組み合わせたシステムにおいても、既存のデータベース管理システムに対して他のデータベース環境を備えたノードを組み込む場合や、稼働中のデータベースノードを既存のデータベース管理システムから除外する場合には、各ノードにおける処理負荷が極端に高まってしまったり、異なるノード間における通信トラフィックが膨大に増えてしまうといった不都合が生じ得る。[発明の目的]本発明は、上記関連技術の有する不都合を改善し、メモリ資源を共有する異なる計算機ノード間で行われるデータ通信量を有効に軽減し得る分散データ管理システム、分散データ管理方法、および分散データ管理プログラムを提供することを、その目的とする。上記目的を達成するために、本発明に係る分散データ管理システムは、クライアント端末からのリクエストに対して予め保持するデータベースに格納されたデータを利用した処理を行い当該処理結果であるリクエスト応答を前記クライアント端末に返信するDBサーバと、前記DBサーバから転送された処理要求に基づく処理を行う異なる複数のノードとを備えた分散データベース管理システムであって、前記DBサーバは、前記各ノードにおけるデータ処理に係る負荷情報および処理時間を示す処理負荷統計情報と前記各ノード内に処理対象データとして予め記憶されたローカルデータとを取得する処理負荷統計情報取得部と、前記リクエストを解析し当該リクエストに対する処理内容および処理手順を示す前記処理構成情報を生成するリクエスト解析部と、前記処理構成情報に基づき前記ローカルデータから処理対象データを特定し、前記処理負荷統計情報に基づき前記各ノードにおける処理負荷が平均化されるように前記処理対象データを前記各ノードに分配する部分要求分配部とを備え、前記各ノードは、自己内に保持するデータおよび前記DBサーバから送り込まれた処理対象データを利用して前記処理構成情報に基づく処理を行うと共に、前記処理構成情報に基づき他のノードまたは前記DBサーバに前記処理結果を転送する部分処理実行部と、を備えた構成をとっている。また、本発明にかかる分散共有メモリ管理方法は、クライアント端末からのリクエストに応じて予め保持するデータベースを利用した問い合わせ処理を行いDBサーバと、前記DBサーバから転送された処理要求に対する処理をそれぞれが行う複数のノードとを備えた分散DB処理システムにあって、前記リクエストに対するリクエスト応答を前記クライアント端末に返信するための分散データベース管理方法であって、前記各ノードにおけるデータ処理に係る負荷情報および処理時間を示す処理負荷統計情報と前記各ノード内に処理対象データとして予め記憶されたローカルデータとを取得し、前記リクエストを解析し当該リクエストに対する処理内容および処理手順を示す情報としての前記処理構成情報を生成し、前記処理構成情報に基づき前記ローカルデータから処理対象データを特定し、前記処理負荷統計情報に基づき前記各ノードにおける処理負荷が平均化されるように前記処理対象データを前記各ノードに分配する、これら動作工程を前記DBサーバが実行し、次いで、前記各ノードが自己内に保持するデータおよび前記DBサーバから送り込まれた処理対象データを利用して前記処理構成情報に基づく処理を行うと共に、前記処理構成情報に基づき他のノードまたは前記DBサーバに前記処理結果を転送することを特徴としたている。また、本発明にかかる分散共有メモリ管理プログラムは、クライアント端末からのリクエストに応じて予め保持するデータベースを利用した問い合わせ処理を行いDBサーバと、前記DBサーバから分配された処理要求に対する処理を行うと共にこの処理結果を処理手順情報に基づき他のノードに転送する異なる複数のノードとを備えた分散DB処理システムにあって、前記クライアント端末に前記リクエストに対するリクエスト応答を返信するための分散DB処理プログラムであって、前記各ノードにおけるデータ処理に係る負荷情報および処理時間を示す処理負荷統計情報と前記各ノード内に処理対象データとして予め記憶されたローカルデータと取得する処理負荷統計情報取得機能と、前記リクエストを解析し当該リクエストに対する処理内容および処理手順を示す情報としての前記処理構成情報を生成するリクエスト解析機能と、前記処理構成情報に基づき前記ローカルデータから処理対象データを特定し、前記処理負荷統計情報に基づき前記各ノードにおける処理負荷が平均化されるように前記処理対象データを前記各ノードに分配する部分要求分配機能と、を前記DBサーバのコンピュータにより実現することを特徴としている。本発明は、以上のように構成され機能するので、これによると、異なるノード上に設定された共有メモリ内におけるデータの一貫性を保ちつつノード間通信を有効に軽減し得る分散共有メモリ管理システム、分散共有メモリ管理方法、分散共有メモリ管理プログラムを提供することができる。[実施形態]次に、本発明の実施形態について、その基本的構成内容を説明する。本実施形態である分散データベース管理システム分散データ管理システム1は、クライアント端末からのSQL問合せ要求を受け付け、この問合せ要求に応じてデータベースを利用した実行処理を行い、この処理結果である問合せ応答をクライアント端末51~5nに返す処理を行うマネージャ装置100と、マネージャ装置100に対してネットワークを介して接続し、マネージャ装置100との情報連携を行い上記問合せ要求に応じたデータベース検索処理を行う異なる複数ノード11~1Nを備えている。クライアント端末51,52,,5nはそれぞれ演算装置31、メモリメインメモリ33、データ記憶装置補助記憶装置32を有する通常のコンピュータであり、通信インタフェース34からマネージャ装置100に対してSQL要求を送信し、また、この通信インタフェース34でマネージャ装置100から送り込まれたSQL応答を受信する。尚、クライアント端末52,,5nはそれぞれ同一の内部構成を有するものとする図2。このため、以下の説明においては、クライアント端末52について説明するが、その他のクライアント端末それぞれにおいても同様の動作機能を備えているため置き換え可能である。ノード11は、自己が備えたデータベースシステムDBMSに格納されたデータを検索し取得するデータ収集部111と、DBMS114に記憶された統計情報を収集する統計情報収集部112と、データ収集部111により取得したデータと上記統計情報をマネージャ装置100に送信すると共に、他のノードにおけるDBMSとのデータ連携を行う連携部113を備えている。尚、ノードを新規に分散環境に追加する際スケールアウトには、ネットワーク越しにマネージャ装置100のアドレスと認証を受ける必要があるものとする。マネージャ装置100へのアクセスが認証された場合につまり、参加可能であると認証された場合に、各ノード11~1Nは、データと統計情報をマネージャ装置100に対して定期的に送信するものとする。マネージャ装置100は、クライアント端末51~5Nそれぞれからの問合せSQL問合せの受け付けと問合せ応答の返却を行うAPIApplicationProgramInterface部と、受け付けた問合せ内容に基づき一連の処理フローを生成する問合せ解析器102と、問合せ解析器102で作成した異なる複数の処理フローの中で最もデータ転送量が少ない処理フローを選び出す最適化器103と、選出された処理フローを、分散環境を構成する各ノードに部分問い合わせ部分要求としてとして送信する問合せ配布部104を備えている。また、マネージャ装置100は、ネットワークを介して各ノード内のDBMSに格納されたデータ、および統計情報を収集するデータ採取部106と、データ採取部106で取得したデータを一時的に保持する一時データ保持DB107と、ノードから収集したデータおよび統計情報を記憶すると共に当該データの更新、および読み出しを管理する分散環境情報DB105と、分散環境情報DB105に格納された統計情報に基づき分散環境としての各ノードに分配するデータを決定するデータ分配決定部108と、上記決定に応じて各ノードに対しデータの配布を行うデータ配布部109を備えている。データ採取部106は、各ノードから取得した統計情報を含むノード情報統計情報、接続情報、アクセス時間図14を一時データ保管DBと分散環境情報DB105に格納する。データ分配決定部108は、分散環境を構成する各ノードのノード情報に基づいて分散環境のノードそれぞれにおける処理負荷、およびノード間の通信負荷アクセス時間に基づき算出が平均化するように、各ノードに対して、分散環境情報DB105に格納されたデータの配布先を決定するデータ分配決定部。また、データ採取部106は、分散環境を構成するノードが除去されるときスケールインに、削除対象のノードが有するデータを取得し、テーブル情報として分散環境情報DB105に格納する。更に、データ採取部106は、分散環境に対して新たにノードが組み込まれるときにスケールアウト、組み込み対象のノードが有するDBMSのデータを取得し、テーブル情報として分散環境情報DB105に格納する。これにより、分散環境情報DB105におけるデータベース40図3が更新される。データ分配決定部108は、データベース内容が更新された分散環境情報DB105における格納データについて、上述のように、分散環境を構成する各ノードのノード情報に基づいて分散環境のノードそれぞれにおける処理負荷、およびノード間の通信負荷アクセス時間に基づき算出が平均化するように、各ノードに対して、分散環境情報DB105に格納されたデータの配布先を決定する。問合わせ配布部104は、クライアント端末51~5nからの問合せを受け取った場合にAPI部101、解析処理と部分問合せ一部を分散情報として各ノードに対して配布する。問合わせ最適化器103は、クライアント端末51~5nそれぞれからの問合せ要求の内容をログ問合せ要求ログとして分散環境情報DB105に格納する要求ログ保存機能。尚、この問合せ要求ログは、分散環境のノードにおいて障害が発生した時に、ノードの動作状態の復旧のために利用される。また、分散環境の各ノードは、マネージャ装置100から送り込まれた部分問合せに対する処理を行うと共に、その処理結果を予め設定された処理フローである処理木に基づき他のノードに転送し、処理結果を生成する。また、各ノードは要求に対する最終的な処理結果をマネージャ装置100に送信する。マネージャ装置100のAPI部101は、ノードから処理結果を取得した場合に、これを問合せ応答として対応するクライアント端末51~5nへ送る。これにより、本実施形態では、予め形成された分散データベース管理システムの分散環境既存DBMSに対して、新たに別のデータベース管理システムを有するノードが組み込まれる場合でも、分散環境の各ノードにおける処理負荷を有効に抑制し、且つSQL要求に対する分散環境におけるデータベース検索処理を迅速化することを可能とする。ここで、分散環境情報DB内で管理される統計情報のスキーマの一例を図13に示す。図13のテーブル情報には、ノードの識別情報nodeAカラム、マネージャ装置100~送り込まれた部分問合せ内容を示す問合せカラム、および部分問合せが送り込まれた時刻を示す時刻カラムを含み構成される。また、図14は、データ取得部106が各ノードから取得したデータテーブルデータの一例を示す。ここでは、一時データ保持DB107に一時的に格納されたテーブル情報を示す。一時データ保持DB107には、分散環境の各ノードに係るノードの動作状態を示す統計情報、ノードにおける利用者の情報を示す接続情報、および異なるノード間、およびノードとマネージャ装置間におけるアクセス時間を示すテーブル情報として格納されているものとする。分散環境情報DB105は、一時データ保持DB107に格納された上記テーブル情報が格納された場合、これらのデータを既存のデータベースのテーブル情報に対して値の加減算、組み合わせや結合する処理を行う。クライアント端末51は、図2に示すように、通信インタフェース34を介してメモリ33上に予め配置された問合せ要求をマネージャ装置100に送信する。また、クライアント端末51は、マネージャ装置100からの問合せ応答を通信インタフェース34を介して取得し、データ記憶装置32に格納する。分散環境情報DB105は、図3に示すように、異なる複数のアプリケーションプログラム実行部61,62,と、データ制御管理を行う管理部4と、データベース処理対象となるデータを格納する分散環境管理用データベース40を備えている。また、管理部4は、図3に示すように、入出力処理対象となるデータを分散環境管理用データベース40に対してノードから取得したデータの書き込みおよび読み出しを行うファイルマネジャ41と、分散環境情報DB105のデータアクセス処理手段42は、予め設定された排他制御プログラムに基づき複数トランザクションの同時実行制御機能と、ノードにおける障害回復を実現するためのログ情報トランザクションログ46を保持管理するトランザクションログ記憶機能を有する。更に、管理部4は、各ノードに分配された部分問合せにかかる解析を行う問合せ解析手段44と、問合せ最適化器103と同等の処理として、データベースの定義情報を管理するディクショナリ47を備え上記解析結果から最適なデータ処理を決定する問合わせ最適化処理手段43を備えた構成であってもよい。また、分散環境DBMS105は、当該分散環境DBMS105全体の管理制御に加えて、入出力の管理等を行うシステム制御手段と、分散環境DBMS105における処理対象となるデータを格納するデータベースバッファを備えている。問合せ解析手段44は、図7に示すように、各ノードから取得した部分問合せの構文解析および意味解析を行うステップS311:解析機能図9と共に、適切な処理手順を示す手順情報を生成するステップS312:静的最適化処理機能。尚、この静的最適化処理は、図10に示すように、アプリケーション61,62,の実行結果として、部分問合せに含まれる述語選択推定を行うステップS401と共に、抽出された述語から処理手順候補となる処理木を生成するステップS402。また、最適化処理手段43は、図8に示すように、静的最適化処理で生成された処理手順候補から最適なものを選択し動的最適化処理機能:ステップS315、上記処理手順に対応したコードの生成およびコードの解釈実行を行うコード解釈実行機能を有するコード生成機能:ステップS316。また、最適化処理手段43は、ディクショナリ47内でアクセスしたデータの条件判定、編集、レコード追加等を行うディクショナリデータ制御機能。排他制御手段45は、データアクセス処理手段42におけるデータベースレコードの読み書きを制御し、データアクセス処理手段42とのデータベースバッファ制御を共用するリソースの排他制御を実現する。これにより、本実施形態では、既存のSQL型データベースシステム本実施形態ではマネージャ装置100およびノード11~1Nからなる分散環境へのノード組み込み、および分散環境における構成ノードの着脱にかかる、各ノードにおける処理負荷を抑制することが可能となる。尚、本実施形態では、分散データベース管理システム1をリレーショナル型として記載しているが、データベース管理システム1は、XMLデータベース、オブジェクトデータベース、Key-Value型データベースでも、分散環境へと移行する際にそれぞれのノードが同じデータベース型であれば、分散環境への導入移行が可能であるものとする。尚、各ノードのデータベース型が異なる場合には、データを統一的に扱うために,エージェント部分にマッパーが必要になる。このマッパーがそれぞれのデータベース型の異なりを吸収し、データ配置を透過的に行えるようにすることが可能となる。[実施形態の動作説明]次に、上記実施形態における全体的な動作内容について説明する。マネージャ装置DBサーバ100は、各ノード11~1Nにおけるデータ処理に係る負荷情報および処理時間を示す処理負荷統計情報を取得する処理負荷統計情報取得工程。また、問合せ解析器102は、クライアント端末51からのリクエストを解析し、このリクエストに対する処理内容および処理手順を示す情報としての処理木情報を生成するリクエスト解析工程。データ採取部106は、各ノードのデータベースから処理負荷統計情報および処理対象データを取得し、処理木情報および処理負荷統計情報に基づいて、各ノードにおける処理負荷が平均化されるように処理対象データを各ノードに分配する部分要求分配工程。ノード計算ノードがマネージャ装置100から送り込まれた部分処理要求の実行処理を行い、その処理結果を処理木情報処理構成情報に基づき他のノードに転送する部分処理結果転送工程。ノードから取得した前記部分処理要求の処理結果をクライアント端末のリクエストに対するリクエスト応答として返信する処理結果返信工程。ここで、上記処理負荷統計情報取得工程、リクエスト解析工程、部分要求分配工程、部分処理結果転送工程、および処理結果返信工程については、その実行内容をプログラム化し、コンピュータに実行させるように構成してもよい。また、本プログラムは、非一時的な記憶媒体、例えば、DVD、CD、フラッシュメモリなどに記録されてもよい。その場合、本プログラムは、記録媒体からコンピュータによって読み出され、実行される。次に、本実施形態である分散データベース管理システム1の動作について、フローチャートに基づき具体的に説明する。ここでは、まず、分散データベース管理システム1のスケールイン時、およびスケールアウト時における動作内容である管理フェーズ管理面について説明し、次いで、クライアント端末からの問合せを処理する動作内容である業務フェーズ業務面について説明する。[管理フェーズ:スケールアウト時の動作説明]はじめに、分散環境としての分散DB管理システム1にノードを組み込む、つまり、分散環境のノード数を増やす場合を示すスケールアウト時の動作について、図4のフローチャートに基づき説明する。尚、マネージャ装置100に分散環境へ導入されるノードに係るノード情報はデータベース管理者により予め登録されているものとする。まず、分散環境に参加するノード分散環境参加ノード15とするが、マネージャ装置100に対して認証要求を送信する開始:ステップS100。マネージャ装置100の分散環境情報DB105は、認証要求をデータ採取部106を介して認証要求を受け取り、この認証要求に対する認証処理を行うステップS101。ここで、認証不可である場合は、スケールアウト処理は終了するステップS107。認証可であった場合イエス:ステップS102、マネージャ装置100のデータ採取部106が、管理データ、および統計情報を収集するステップS103。このとき、認証可能となったノードの連携部113は、管理データおよび統計情報をマネージャ装置100へ送信する。次いで、データ採取部106は、ノード15から収集した管理データおよび統計情報を一時データ保持DB107と分散環境情報DB105とに格納し、格納データを更新するステップS104。尚、分散環境情報DB105には、予めアクセス可能に設定されているノードやそのアカウントが登録されているものとする。次に、データ分配決定部108が、分散環境情報DB105に格納された統計情報に基づきデータ配布先を決定しステップS105、データ配布部109が、各ノード11,12,,Nそれぞれに対して分散データを配布するステップS106。これにより、各ノードにおけるDBMSにおける格納データが更新されるステップS107。[管理フェーズ:スケールイン時の動作説明]次に、分散データベース管理システム分散環境1の特定のノード除外対象ノードが分散環境から除外されるスケールインスケールドロップ時の動作内容について、図6のフローチャートに基づき説明する。まず、分散環境である分散データベース管理システムから退避するここでは、マネージャ装置100に対する通信接続を解除するものとするノード退避対象ノードが、マネージャ装置100に対して退避要求を送信するステップS301。次に,この退避要求を受信したAPI部101が、分散環境情報DB40中に格納された退避対象ノードのノード情報を削除するステップS302。次いで、データ分配決定部108が、分散環境情報DB105の分散データベース40における保存データの更新を検知しステップS303、更新された分散データベース40に格納されたデータについて、退避対象のノードを除いた分散環境におけるデータ配布先を新たに決定するステップS304。次いで、データ配布部109が上記決定されたデータ配布先である各ノードに対してデータ配布を行う。これにより、各ノードにおける記憶容量に格納されたデータが更新される。[業務フェーズ]次いで、クライアント端末からの問合せに対して、マネージャ装置100およびノード11~1Nからなる分散環境で問合せ応答を生成する処理を行う動作内容としての業務フェーズ業務面について説明する。まず、マネージャ装置100のAPI101が、クライアント端末51~5nそれぞれからネットワークを介して送り込まれたSQL問合せを受け付ける。次いで、問合せ解析器102が、受け付けた問合せ内容に基づき一連の処理フローを示すツリー構造の処理木処理木図を生成する。また、問い合わせ解析器は、生成された異なる複数の処理木のうち、各ノードの統計情報に基づき処理負荷、およびデータ転送負荷を算出し、データ転送負荷が最も低い処理木を選択する。次に、問合せ配布部104が、選出された処理木を部分木に分割し、分割した処理木情報としての部分問合せ要求を、該当するノードに配布を行う。分散環境のノードはそれぞれ連携部113に対応で部分問合せ要求を受け付け、問合せ処理の実行を行う。また、各ノードは、処理結果部分処理結果を部分木で示される次のノードへと転送する。ここで、ノードは、最終的な処理結果を部分木の内容に基づきマネージャ装置に送信する。マネージャ装置100はこの処理結果を要求応答としてクライアント端末51に対応返信する。[分散データ配布先決定機能]ここで、分散データベース管理システム1における分散データの配布先を決定する動作内容について、図5のフローチャートに基づき説明する。まず、マネージャ装置100のデータ採取部106が、ノード11,12,,NそれぞれのDBMS114,124,,1N4に記憶された統計情報と、各ノードにおけるデータアクセス状況を示す情報を収集するステップS201。このとき、データ採取部106は各ノードに対して統計情報を要求するリクエスト情報を送信し、各ノードはこのリクエスト情報に応じて自己が保持する統計情報を返す設定であってもよい。次いで、データ採取部106が、データ分散配置環境である各ノードにおけるレプリケーション機能の有無を確認するレプリケーション機能有効:ステップS202。ここで、レプリケーションが有効になっていた場合にはYES:ステップS202別ノードにも情報源が複製されているため、データ採取部106は、各ノードにおけるDBMSに格納されたデータと不一致な部分データを分散環境情報DB105から検索抽出しステップS208、抽出した不一致部分データの複製を各ノードに対して分配送信するステップS209。一方、レプリケーションが向こうである場合にはNO:ステップS202、データ採取部106は分散環境情報DB105から一定期間における各ノードの処理時間に係る情報を取得するステップ203と共に、一時保管DB107から一定時間内における各ノード上での演算数とその演算のデータ処理量の平均の値を取得するステップ204。次いで、データ採取部106は、各ノードの処理時間とデータ処理量の比から各ノードに対する情報源格納データの分配先を決定しステップS205、次に、上記実施形態における障害復旧時の動作内容について、図11、12のフローチャートに基づき説明する。ここで、ノード側における動作障害の内容としては、トランザクション障害とシステム障害が想定される。まず、トランザクション障害が生じた場合の動作内容について、図11に基づき説明する。マネージャ装置100から分散環境各ノードへ配布した問合せ処理の中で,1部のノードでトランザクションが異常終了した場合には、その問合せ処理は異常終了となる。このとき、各ノードにおける連携部113,123,133,,1N3は、問合せ処理にかかるデータの送受信が異常となったノードをマネージャ装置に通知をするステップS410。ここで、データの送受信に異常が生じたノードがマネージャ装置100に対して送受信以上の発生を通知できる場合は、このノードがマネージャ装置100にデータの送受信における異常を通知する。マネージャ装置100のAPI部101が異常状態の通知を受け、異常終了となったノードを特定するステップS411と共に、配布部104が、異常状態になったノードに対して、以上終了した問合せ処理の再実行を要求するステップS412。ここで、要求が正常に行われた場合イエス:ステップS413には、問合せ処理は正常に終了したとみなす完了:ステップS415。一方、要求が異常終了になった一定時間返ってこない、再び動作異常が通知されるなどした場合にはシステム障害と判断し、マネージャ装置100に予め設定されたすステム障害対応処理を実行するステップS414。次に、システム障害発生時における、マネージャ装置50の動作内容について、図12のフローチャートに基づき説明する。API部101がノードにおけるシステム障害を検出した場合ステップS420、API部101が故障ノードを特定しステップS421、次いで、分散環境情報DB105は、DB40における登録内容に基づき分散環境故障ノードを含むにおけるレプリケーション機能の有無を確認するステップS422。ここで、レプリケーションが有効になっていた場合には、別ノードにも情報源が複製されているので、マネージャ装置100側でシステム障害と判断したノードを除いた環境を想定し、問合せ最適化器103が、これに基づき問合せ最適化を再実行し、次いで、算出された問合せプランを問合せ配布部104が各ノードに配布する。一方、レプリケーションが有効になっていない場合にはNO:ステップS422、障害時の遅延は,問合せ最適化器103で算出された処理時間となるため、故障ノードに対して故障に係るログ情報を分散環境情報DB105から取得し、ロールバック/ロールフォワードの実行要求としてログを故障ノードへ送るステップS423。ここで、故障ノードはログ情報およびロールバック/フォワードの実行要求に応じての障害の復旧処理を実行するステップS424。また、データ配布部109は、故障ノードにおけるロールバック/フォワードの復旧処理が終了した後に要求を再送することにより問合せ処理の再実行を要求する。以上のように、本実施形態では、分散環境下において各ノードにおける処理負荷を考慮したデータ配置を行うことが可能となる。これにより、処理負荷の低いノードに対して問合せ処理を分配し、各ノードそれぞれにおける問合せ処理にかかる処理負荷が平均化されるように、処理負荷が高いことに起因する動作異常の発生を有効に抑制することができ、更には、問合せ処理を迅速に行うことができ、これにより、問合せ実行時間が短縮される。また、本実施形態は、既存DBMSにマネージャと連携する機能を有するエージェントを導入することにより実現可能であり、このため、エージェントとマネージャ装置が自律的にやり取りを行うことにより、利用者は煩雑なDBMSの連携を意識することなく、既存DBMSを柔軟に分散環境へと移行することが可能となる。上述した実施形態については、その新規な技術的内容の要点をまとめると、以下のようになる。尚、上記の実施形態の一部又は全部は、新規な技術として以下のようにまとめられるが、本発明は必ずしもこれに限定されるものではない。付記1クライアント端末からのリクエストに対して予め保持するデータベースに格納されたデータを利用した処理を行い当該処理結果であるリクエスト応答を前記クライアント端末に返信するDBサーバと、前記DBサーバから転送された処理要求に基づく処理を行う異なる複数のノードとを備えた分散データベース管理システムであって、前記DBサーバは、前記各ノードにおけるデータ処理に係る負荷情報および処理時間を示す処理負荷統計情報と前記各ノード内に処理対象データとして予め記憶されたローカルデータとを取得する処理負荷統計情報取得部と、前記リクエストを解析し当該リクエストに対する処理内容および処理手順を示す前記処理構成情報を生成するリクエスト解析部と、前記処理構成情報に基づき前記ローカルデータから処理対象データを特定し、前記処理負荷統計情報に基づき前記各ノードにおける処理負荷が平均化されるように前記処理対象データを前記各ノードに分配する部分要求分配部とを備え、前記各ノードは、自己内に保持するデータおよび前記DBサーバから送り込まれた処理対象データを利用して前記処理構成情報に基づく処理を行うと共に、前記処理構成情報に基づき他のノードまたは前記DBサーバに前記処理結果を転送する部分処理実行部と、を備えたことを特徴とする分散データベース管理システム。付記2付記1に記載の分散データベース管理システムにおいて、前記DBサーバに対して前記部分処理要求の処理用に新たに一のノードが接続された場合に、当該ノードを含む前記各ノードの処理負荷統計情報を再取得する統計情報再取得手段と、前記処理負荷統計情報に基づき前記部分処理要求を更新して生成する部分処理要求更新生成手段を備えたことを特徴とする分散データベース管理システム。付記3付記1に記載の分散データベース管理システムにおいて、前記一のノードにおける前記DBサーバに対する接続を解除した場合に、前記DBサーバに対して接続された他のノードそれぞれの処理負荷統計情報を再取得する統計情報再取得手段と、当該再取得された処理負荷統計情報に基づき前記部分処理要求を更新して生成する部分処理要求更新生成手段を備えたことを特徴とする分散データベース管理システム。付記4付記1に記載の分散データベース管理システムにおいて、前記DBサーバに対して前記部分処理要求の処理用に新たに他のノードが接続された場合に、当該ノードを含む前記各ノードの処理負荷統計情報を再取得し、前記DBサーバに対する一のノードの接続を解除した場合に、前記DBサーバに対する接続が維持されている他のノードそれぞれの処理負荷統計情報を再取得する統計情報再取得手段と、再取得された処理負荷統計情報に基づき前記部分処理要求を更新して生成する部分処理要求更新生成手段とを備えたことを特徴とする分散データベース管理システム。付記5付記1に記載の分散データベース管理システムにおいて、前記リクエスト解析部が異なる複数の処理構成情報を生成した場合に、前記部分処理要求生成部は、処理構成情報のうちデータ処理量を算出し、当該データ処理量が最小となる処理構成情報を選出する処理構成情報選出手段を備えたことを特徴とした分散データベース管理システム。付記6付記1、3、または4に記載の分散データベース管理システムにおいて、前記ノードは他のノードとの通信異常を検知した場合に前記通信異常が検知されたノードを障害ノードとして前記DBサーバに通知する通信障害通知手段を備え前記DBサーバは、前記障害ノードとして通知されたノードに対して応答要求を行い、当該応答要求に対する正常な応答がない場合に、当該ノードにおける前記DBサーバとの接続を解除する制御を行う接続解除制御手段を備えたことを特徴とする分散データベース管理システム。付記7クライアント端末からのリクエストに応じて予め保持するデータベースを利用した問い合わせ処理を行いDBサーバと、前記DBサーバから転送された処理要求に対する処理をそれぞれが行う複数のノードとを備えた分散DB処理システムにあって、前記リクエストに対するリクエスト応答を前記クライアント端末に返信するための分散データベース管理方法であって、前記各ノードにおけるデータ処理に係る負荷情報および処理時間を示す処理負荷統計情報と前記各ノード内に処理対象データとして予め記憶されたローカルデータとを取得し、前記リクエストを解析し当該リクエストに対する処理内容および処理手順を示す情報としての前記処理構成情報を生成し、前記処理構成情報に基づき前記ローカルデータから処理対象データを特定し、前記処理負荷統計情報に基づき前記各ノードにおける処理負荷が平均化されるように前記処理対象データを前記各ノードに分配する、これら動作工程を前記DBサーバが実行し、次いで、前記各ノードが自己内に保持するデータおよび前記DBサーバから送り込まれた処理対象データを利用して前記処理構成情報に基づく処理を行うと共に、前記処理構成情報に基づき他のノードまたは前記DBサーバに前記処理結果を転送することを特徴とした分散データベース管理方法。付記8クライアント端末からのリクエストに応じて予め保持するデータベースを利用した問い合わせ処理を行いDBサーバと、前記DBサーバから分配された処理要求に対する処理を行うと共にこの処理結果を処理手順情報に基づき他のノードに転送する異なる複数のノードとを備えた分散DB処理システムにあって、前記クライアント端末に前記リクエストに対するリクエスト応答を返信するための分散DB処理プログラムであって、前記各ノードにおけるデータ処理に係る負荷情報および処理時間を示す処理負荷統計情報と前記各ノード内に処理対象データとして予め記憶されたローカルデータと取得する処理負荷統計情報取得機能と、前記リクエストを解析し当該リクエストに対する処理内容および処理手順を示す情報としての前記処理構成情報を生成するリクエスト解析機能と、前記処理構成情報に基づき前記ローカルデータから処理対象データを特定し、前記処理負荷統計情報に基づき前記各ノードにおける処理負荷が平均化されるように前記処理対象データを前記各ノードに分配する部分要求分配機能と、を前記DBサーバのコンピュータにより実現することを特徴とした分散DB処理プログラム。"