JPH034339A - 分散処理システムにおけるデータベース更新方式 - Google Patents

Abstract

(57)【要約】本公報は電子出願前の出願データであるた
め要約のデータは記録されません。

Description

【発明の詳細な説明】 ［産業上の利用分野］ 本発明は、通信回線で相互接続された分散処理システム
における分散データベースの更新方式に係り、特に、各
ノードに対しデータを効率よく配置し管埋する分散処理
システムにおけるデータベース更新方式に関する。

［従来の技術］ 従来、分散処理システムにおいて、複数の計算機システ
ム（ノード）における分散データベースの同期更新（同
時的な更新）を行なう方式として、例えば、「日経コン
ピュータ、１９８８年５月２３日号」（第１０１頁〜第
１１６頁、特に第１１４頁〜第１１５頁）に記載のよう
に、更新前後のファイル・イメージのジャーナルを、各
データ処理システム（各々のノード）で取得する方式が
知られている。また、特開昭６３−１５６２５８号公報
（第２頁）に記載のように、分散データベースシステム
のトランザクション処理において、トランザクションの
ログ（ジャーナル）を、各サイト（ノード）で取得し、
また、複数トランザクションについての間合せメツセー
ジおよび回答メツセージを一括して所要のサイトに送る
ことにより、メツセージ数を減少させる方式が知られて
いる。

［発明が解決しようとする課題］ 上記従来技術は、いずれも、ジャーナルを各ノードで取
得するようになっており、そのため以下に示すようにジ
ャーナル管理が複雑化する問題があった。

すなわち、ワークステーションや小型計算機システムの
データベースと大型計算機システムとを含む分散処理シ
ステムでは、大型計算機システムで集中してジャーナル
管理を行なうことができない。

障害が発生した場合、該障害となったデータベースの管
理光（該データベースが付いている計算機システム）の
計算機システム単位ｔこジャーナルが分散しているので
、データベースの回復方法が複雑である。

ワークステーションや小型計算機システムでそれぞれジ
ャーナルを取得できるようにするために、それらワーク
ステーションや小型計算機システム用のソフトウェア構
成・が複雑になり、処理性能や媒体利用効率が低下する
問題がある。

従って、本発明の目的は、上記従来技術の間層点を解消
し、ジャーナルを集中管理できるようにして、システム
全体の管理を一元化し、処理性能を向上すると共に、障
害時の回復処理を迅速化し、また、媒体の利用効率を向
上できるようにした分散処理システムにおけるデータベ
ース更新方式を提供することにある。

［課題を解決するための手段］ 上記目的を達成するため、本発明の分散処理システムに
おけるデータベース更新方式は、それぞれデータベース
を有する複数のノードと、ノード間の通信手段と、任意
の１つのノードからの更新要求により複数のノードで同
期をとってデータベースを更新する手段とを備えたもの
において、特徴として、サーバ側ノードおよびクライア
ント側ノードのジャーナルを一個所の特定ノードで取得
する手段を具備する。すなわち、データベースを管理す
る個々のノード（クライアント側ノードおよびサーバ側
ノード）が１通信回線を通じて、個々のデータベースの
更新情報を一個所の特定ノードに送り、それらの更新情
報のジャーナルを該特定ノードで集中して取得するよう
に構成したことを特徴とする。

ここで、クライアント側ノードとは、利用者によりトラ
ンザクション入力のあったノードをいい、サーバ側ノー
ドとは、要求に応じデータベースを提供するノードをい
う、勿論、クライアントがデータベース提供を兼ねるこ
ともあり、また、特定ノードがクライアントまたはサー
バを兼ねることもある。

あるノードのデータベースに障害が発生した際に、この
障害の回復指示は、前記−個所の特定ノードにより集中
的に実行される。

また、前記特定ノードに集中的に設けたジャーナル取得
手段とは別に、個々のノード（サーバ側ノードやクライ
アント側ノード）に、セキユア状態のトランザクション
のみのジャーナルを取得する手段を付加することができ
る。このため、該当トランザクションのコミット状態を
他のノードに送信後、ジャーナルとして取得した情報を
不要化する（不要となった旧履歴情報を抹消して別の新
しい履歴情報を格納できるようにする）。

［作用］ 上記構成に基づく作用を説明する。

本発明によれば、複数のノード（サーバ側およびクライ
アント側）におけるデータベースの更新ジャーナルを一
個所の特定ノードで取得するようにしたので、ジャーナ
ル管理が容易になり、処理性能が向上する。このことを
、クライアント側ノードが特定ノードになる場合とサー
バ側ノードが特定ノードになる場合について、以下に説
明する。

クライアント側のノードでジャーナルを一括して取得す
るには、サーバ側へのＤＢ更新要求に対する応答情報と
してＤＢ更新情報をクライアント側へ送信して、送信さ
れた情報をジャーナルに取得する（第２図の実施例）。

サーバ側のノードでジャーナルを一括して取得するには
、コミット保証の送信をクライアント側で行なった際に
クライアント側のＤＢ更新情報をサーバ側に同時に送信
して、送信された情報をジャーナルに取得する（第３図
の実施例）。

それによって、ＤＢの更新ジャーナルは一個所で取得さ
れる。

次に、データベース障害時の回復指示を一個所で行なう
には、ジャーナルを取得したノードからＤＢのバックア
ップからの回復指示を行ない、ＤＢバックアップ後に取
得したジャーナルのうち。

障害のあったＤＢのジャーナル情報を障害ＤＢの管理ノ
ードに対して送信して回復するように動作する。それに
よって、回復指示は一個所で行なえる（第７図の実施例
）。

クライアント側、サーバ側で処理するトランザクション
のみ取得する履歴情報の格納部を設けて、コミット時に
ＤＢの更新イメージとコミットを決定したことを示すジ
ャーナルを取得した後にコミット処理を行ない、コミッ
ト状態を他のノードに送信後、（送信してしまえば、こ
の格納部の情報は不要となるので、）ジャーナルとして
取得した情報の上から別のトラ・ンザクションの情報を
書き込み可能とすることで、不要化する。

これによって仕掛は中（セキユア状態）のトランザクシ
ョンについてのみ、ジャーナルを持つことが可能になる
。

［実施例］ 以下に１本発明の実施例を図面によって説明する。

第１図は１本発明の一実施例のシステム構成図である０
本実施例で、分散処理システムは、３つのノード１１，
１２．および１３、すなわち、計算機システム＃Ｉ、＃
ＩＩ、および＃■を含み、各ノード間に通信回線１１７
，１１８，１２７を設けている。ノード１１，１２．１
３には、それぞれ、データベース（ＤＢ）　１１５．１
２５．１３５が接続されると共に、端末システム１１６
，１２６゜１３６が接続され、それによって、本システ
ムは各端末システムより入力されたトランザクションの
処理を各ノードで行なうデータ処理システムを構成して
いる。

本実施例の特徴として、これらのノードのうちの特定の
１つ（この場合、ノード１１）のみに、集中的にジャー
ナル格納部１１４およびＤＢバックアップ格納部１１９
を設ける。各ノードで発生したジャーナルは、計算機シ
ステム＃■　（ノード１１）で取得され、格納部１１４
に格納される。

ＤＢバックアップ格納部１１９は、計算機システム３１
（ノード１１）のデータベース１１５だけでなく、計算
機システム＃ＩＩ、　ａｍ　（ノード１２゜１３）のデ
ータベース１２５，１３６のＤＢバックアップ情報も格
納するようになっている。なお、ＤＢバックアップデー
タは、一般に、トランザクション処理開始以前（通常は
、当日のオンライントランザクション処理の開始前、又
は前日のデータ処理終了後）に、オペレータにより取得
される。

ノード１２および１３には、仕掛は中のトランザクショ
ン（更新の途中のトランザクション、すなわち、セキユ
ア状態におけるトランザクション）に対してのみ、トラ
ンザクション履歴情報を取得するための、トランザクシ
ョン履歴格納部１２４および１３４を設ける・。なお、
ノード１におけるジャーナル格納部１１４は、トランザ
クション履歴格納部１２４，１３４と同様の機能を兼用
することができる。

各ノード１１．１２，１３には、オペレーティングシス
テム１１１，１２１，１３１が存在すると共に、トラン
ザクションの制御を行なうＤＢ／ＤＣプログラム１１２
，１２２，１３２と、各端末１１６，１２６，１３６か
らの入力メツセージに従い、自ノードや他ノードのデー
タベースの参照・更新を行なって、端末へ応答メツセー
ジを送信するアプリケーションプログラム（ＡＰ）　１
１３゜１２３．１３３とが存在する。

第２図は、第１図において、＃■計算機システム１１の
端末システム１１６から入力されたトランザクションに
よって、データベース１１５および１２５を更新する場
合の、ＤＢ／ＤＣプログラム１１２および１２２の処理
例を示す流れ図である。端末１１６からの入力によって
、トランザクションは開始する（２１）、ＡＰ１１３に
よる、ノード１のデータベースの更新要求後、このＡＰ
１１３からノード２のデータベース更新要求があると、
ノード２　ヘＤ　Ｍ　Ｌ　（Ｄａｔａ　Ｍａｎｉｐｕｌ
ａｔｉｏｎＬ　ａｎｇｕａｇｅ）が送信される（２２）
、ノード２では、ＤＭＬ処理として、ノード２のＤＢの
更新処理をメモリ上で行なうと共に、ノード２のＤＢの
更新情報をノード１へ送信する（２３）、ノード１は、
ＡＰ処理の終了時に、ノード２およびノード１のＤＢ更
新ジャーナル、コミットを決定したことを示すジャーナ
ルを取得してＤＢ１１５を更新しく２４）、ノード２ヘ
コミツト送信をする（２５）、ノード２は、ノード２の
ＤＢ１２５を更新してノード１ヘセキユア状態解消を送
信する（２６）、ノード１は、セキニア状態解消受信後
、コミット完了を示すジャーナルを取得して（２７）、
入力端末へ応答を返すなどしてトランザクション処理を
終了する（２８）。ノード２は処理２３と２６の間はセ
キユア状態（２９）であり、その間にシステムダウンし
た際にはノード１の指示によってシステム回復を行なう
。

第３図は第１図にお・いて、＃■計算機システム１２の
端末システム１２６から入力されたトランザクションに
よって、データベース１２５および１１５を更新する場
合の、ＤＢ／ＤＣプログラム１２２および１１２の処理
例を示す流れ図である。

端末システム１２６からの入力によってトランザクショ
ンが開始する（３０）、ＡＰ１２３によるノード２のＤ
Ｂ更新ＤＭＬ処理３１は、メモリ上の処理で行なわれる
。該ＡＰ１２３からのノードＩＤＢ更新要求があると、
ノード１へ該要求のＤＭＬを送信する（３２）、ノード
１では、要求を受けると、メモリ上での処理を行ない（
３３）、応答を返す、ＡＰの処理が終ると、ノード２は
コミット保証の送信を行ない（３４）、同時にノード２
のＤＢ更新情報を送信する（３４）、ノード１は、ノー
ド１およびノード２のＤＢ更新ジャーナルのコミットを
決定したことを示すジャーナルを取得して（３５）、応
答を返す、ノード２は、ＤＢ１２５を更新（３６）後、
コミット状態を送信しく３７）、ノード１はコミット決
定を受信したことを示すジャーナルを取得後、ＤＢ１１
５を更新して（３８）、ノード２に応答を返す、ノード
２は、端末システム１２６に応答を返すなどして、トラ
ンザクションを終了する（３９）。処理３５と３６の間
はセキユア状態であり、この間でダウンした場合に、ノ
ード２はノード１のジャーナル状態に従って回復する。

第４図は、第１図において、＃■計算機システム１２の
端末システム１２６から入力されたトランザクションに
よりデータベース１２５および１３５を更新する場合の
、ＤＢ／ＤＣプログラム１２２および１３２の処理例を
示す流れ図である。端末システム１２６からの入力によ
ってトランザクションが開始する（４１）。ＡＰ１２３
からノード２のＤＢ更新要求後、該ＡＰからノード゛３
のＤＢ更新要求が発生すると、ノード３へＤＭＬ送信を
行なう（４２）、ノード３は、ノード２からの該要求に
よって、メモリ上の処理としてＤＢを更新してＤＢ更新
情報をノード２へ送信する（４３）。ＡＰの処理終了に
よってノード２のトランザクション履歴格納部１２４に
ノード２およびノード３のＤＢ更新情報を取得し、ＤＢ
１２５の更新を行なうと共に、ノード１でジャーナルを
一元管理するためにノード１にノード２，３のＤＢ更新
情報を連絡して、ノード１からジャーナル取得完了を待
つ処理を行なう（４４）、ノード３ヘコミツト送信を行
ない（４５）、ノード３のＤＢを更新する（４６）。

ノード２は、ノード３からの受信完了でトランザクショ
ン履歴の情報を不要化して（４７）、トランザクション
履歴を別トランザクションで再使用を可能とする。（つ
まり、別の新しいトランザクション情報を重ね書きする
ことで、不要になった旧トランザクション情報を抹消す
る）。ノード１に全処理の終了を示すためにコミット完
了連絡を行ない（４８）、端末システム１２６へ応答を
返して、トランザクション処理を終了する（４９）。

処理４３から４６の間はセキユア状態であり、その間で
ダウンした際はノード２のトランザクション履歴に取得
された状態に従ってシステム回復を行なう。

第５図は本発明による通信回線によって送信するデータ
ベースの更新情報例である。メッセージ長５１は全体の
長さを示す。トランザクション状態５２はＤＢを更新し
たトランザクションの状態を示すものであり、トランザ
クションの発生したノード（メツセージを入力した端末
システムの管理光ノード）のノード名５２１、そのノー
ドでトランザクションを一意的゛に識別するために番号
付けしたトランザクション識別子５２２、トランザクシ
ョンが処理のどの過程にあるかを示すコミット状態５２
３、本トランザクションがアクセスしたＤＢ数５２４よ
り成る。データベースの物理アドレス５３は、ノード名
で、磁気ディスク装置の場合はボリューム名である。更
新位置、更新長５４は、磁気ディスク装置のシリンダ番
号、トラック番号と更新長を示している。更新前イメー
ジ５５はデータベースの更新前の情報であり、更新後イ
メージ５６はデータベースの更新後の情報である。

第６図は本発明によるトランザクション履歴の情報例で
ある。全体のデータ長６１とトランザクション状態６２
は第５図の５１と５２に相当する。

データベースの物理アドレス６３は第５図の５３に相当
する。更新位置、更新長６４は第５図の５４に相当する
。更新前イメージ６５は第５図の５５に相当する。更新
後イメージ６６は第５図の６６相当の情報である。

第７図は、第１図において本発明によるデータベース障
害時の回復指示を一個所で実行する実施例である０本実
施例では計算機システム１から他の計算機システム２，
３のデータベースの回復例を示している。ＤＢの回復に
は通信回線１１７゜１１８を用いてファイル転送によっ
て行なう、ＤＢバックアップ１１９を用いて回復指示（
７１）をファイル転送する。ＤＢバックアップ後のジャ
ーナル１１４を読み込み（７２）、障害の発生している
ＤＢに対するジャーナルか否か（７３）、およびコミッ
ト完了したトランザクションか否か（７４）のチエツク
後、ファイル転送によって更新後イメージに回復指示（
７５）を行なう、最終に取得されたジャーナルまでの処
理完了（７６）で、全処理が終了する。

［発明の効果］ 以上詳しく説明したように、本発明によれば、分散処理
システムにおいて、各所のノードのデータベースに関す
るジャーナルを一個所の特定ノードで集中して取得する
ことによって、ジャーナル管理が容易になり、ジャーナ
ルを管理する人手を減少することができるので、経済的
であると共に、この集中取得したジャーナルを見ること
によって。

システム全体の動作を把握することができ、性能向上を
図ることができる効果を奏する。

また、データベース障害時の回復指示を一個所で実行す
ることにより、他の計算機システムの省力化ができると
共に、迅速な回復処理を行なうことができる結果、信頼
性が向上する効果を奏する。

更に、セキユア状態のトランザクションのみのジャーナ
ルを取得する手段を設けたことによって、その格納のた
めの記憶媒体量を削減することができ、経済性がある等
の効果を奏する。

【図面の簡単な説明】

第１図は本発明の一実施例のシステム構成図、第２図、
第３図、および、第４図は本発明の一実施例によるＤＢ
／ＤＣの処理手順を示す流れ図、第５図は本発明の一実
施例によるデータベース更新情報の一例を示す図、第６
図は本発明の一実施例によるトランザクション履歴情報
の一例を示す図、第７図は本発明の一実施例によるデー
タベースの回復手順を示す流れ図である。 １１．１２．１３・旧・・ノード（計算機システム）、
２１〜２８．３０〜３９．４１〜４９・・・−Ｄ　Ｂ更
新手順、２４，２５・・・・・・＃■ノードでのジャー
ナル取得、４４・・・・・・トランザクション履歴格納
部での情報取得、７１〜７６・・・・・・データベース
回復手順、１１１，１２１，１３１・・・・・・オペレ
ーティングシステム、１１２，１２２，１３２・・・・
・・ＤＢ／ＤＣ（データベース／データコミュニケーシ
ョン）プログラム、１１３，１２３，１３３・・・・・
・アプリケーションプログラム、１１４・・・・・・ジ
ャーナル格納部、１１５，１２５，１３５・・・・・・
データベース、１１６．１２６，１３６・・・・・・端
末システム、１１７゜１１８．１２７・・・・・・通信
回線、１１９・・・・・・データベースバックアップ格
納部、１２４，１３４・・・・・・トランザクション履
歴格納部。 第２Ｆ：ｊＡ 言十亡１崎システム／（ノート”Ｉ） くフライアンｌ＞ 針算禍システム２〈ノーＦ′２） 〈サーＩぐ一便１〉 一３図 Ｓ五システム 第４図 第５図 第６（１

Claims (1)

1. 【特許請求の範囲】 １、それぞれデータベースを有する複数のノードと、ノ
   ード間の通信手段と、任意の１つのノードからの更新要
   求により複数のノードで同期をとつてデータベースを更
   新する手段とを備えた分散処理システムにおいて、サー
   バ側ノードおよびクライアント側ノードのジャーナルを
   一個所の特定ノードで取得する手段を具備したことを特
   徴とする分散処理システムにおけるデータベース更新方
   式。 ２、あるノードのデータベースに障害が発生した際に、
   該障害の回復指示を前記特定ノードにより実行するよう
   に構成したことを特徴とする請求項１記載の分散処理シ
   ステムにおけるデータベース更新方式。 ３、セキユア状態のトランザクションのみのジャーナル
   をサーバ側またはクライアント側で取得する手段を具備
   したことを特徴とする請求項１記載の分散処理システム
   におけるデータベース更新方式。