JPH06119227A - 分散データベース制御システム - Google Patents

分散データベース制御システム

Info

Publication number
JPH06119227A
JPH06119227A JP4292054A JP29205492A JPH06119227A JP H06119227 A JPH06119227 A JP H06119227A JP 4292054 A JP4292054 A JP 4292054A JP 29205492 A JP29205492 A JP 29205492A JP H06119227 A JPH06119227 A JP H06119227A
Authority
JP
Japan
Prior art keywords
copy
data base
update
database
computer
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
Application number
JP4292054A
Other languages
English (en)
Inventor
Suguru Kawakami
英 川上
Current Assignee (The listed assignees may be inaccurate. Google has not performed a legal analysis and makes no representation or warranty as to the accuracy of the list.)
Oki Electric Industry Co Ltd
Original Assignee
Oki Electric Industry Co Ltd
Priority date (The priority date 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 date listed.)
Filing date
Publication date
Application filed by Oki Electric Industry Co Ltd filed Critical Oki Electric Industry Co Ltd
Priority to JP4292054A priority Critical patent/JPH06119227A/ja
Publication of JPH06119227A publication Critical patent/JPH06119227A/ja
Pending legal-status Critical Current

Links

Landscapes

  • Information Retrieval, Db Structures And Fs Structures Therefor (AREA)

Abstract

(57)【要約】 【目的】 分散データベースの更新時間を短縮する。 【構成】 計算機1でデータベース15を更新する場
合、コピー種類指定手段73を参照し、これがデータベ
ース15が主であることを示しているときは、更新手段
34によりデータベース15のみを更新し、データベー
ス25等は更新しない。また、コピー種類指定手段73
がデータベース15が従であることを示しているとき
は、更新手段34により通信制御装置31を介して主の
データベースを格納した計算機にそのデータベースの更
新を依頼する。そして、従であるデータベース15は更
新しない。一方、主であるデータベースを格納した計算
機は、同期時期指定手段74に指定された同期時期が来
ると、データベースの更新履歴を従であるデータベース
を格納したすべての計算機に送り、更新を依頼する。

Description

【発明の詳細な説明】
【0001】
【産業上の利用分野】本発明は、分散データベースにお
ける重複した格納データを制御する分散データベース制
御システムに関するものである。
【0002】
【従来の技術】図2は、従来の分散データベース制御シ
ステム(分散DBMS)の機能の一例を示すブロック図
である。また、図3は、図2中の格納情報管理テーブル
の構造の説明図である。図示の分散データベース管理シ
ステムは、通信網45で接続された複数の計算機41、
42上の複数の分散データベース管理システム50、6
0で構成されている。例えば、計算機41で利用者から
データベースに対する検索要求があると、問合せ処理機
能51が格納情報管理テーブル54の内容を調べる。そ
して、自分のデータベース55に該当するデータが格納
されていれば、検索機能52を使用して、例えば、表5
6の内容を応答する。
【0003】また、計算機41で利用者からデータベー
スに対する更新要求があると、問合せ処理機能51が格
納情報管理テーブル54の内容を調べ、自分のデータベ
ース55の表56を更新するとともに該当する表66を
格納している計算機42に対しても更新を命令する。こ
れを受けた計算機42は、更新機能63を使用して、表
66の内容を更新し、更新が完了したことをこの命令を
出した計算機41に応答する。計算機42で更新要求が
あった場合も、計算機41と同様に問合せ処理機能61
が格納情報テーブル64の内容を調べ、自分のデータベ
ース65の表66を更新するとともに該当する表56を
格納している計算機41に対しても更新を命令する。デ
ータベースでは、一連のデータベースに対する処理のま
とまりをトランザクションと呼ぶ。例えば、銀行等の業
務処理において、口座Aから口座Bへの送金は、口座A
の更新と口座Bの更新から成っている。即ち、送金のト
ランザクションは、口座Aからの出金処理と口座Bへの
入金処理の2つの処理から成っている。この2つの処理
のうち、どちらか一方が失敗した状態であると、銀行全
体として、預金残高が正しくなくなってしまう。このた
め、データベースでは、一方の処理がうまく実行できな
い場合、他方の処理をロールバックして、データベース
の状態を正常に保つ。このために、トランザクションの
コミット要求に対し、そのトランザクションの正常終了
の通知を受け取らなかった場合に、トランザクションで
なされた更新処理の一部を無効にするロールバック要求
を出すことができる。
【0004】即ち、例えば、計算機41で利用者から、
トランザクションのコミット要求が出された場合、問合
せ処理機能51は、トランザクションに関係する計算機
42の分散DBMS60にコミットの準備を命令する。
このコミット準備命令に対するすべての応答が正常であ
れば、トランザクションに関係する分散DBMS60に
コミットを命令する。このコミット命令に対する応答に
1つでも異常があれば、トランザクションに関係した分
散DBMS60にロールバックを命令する。このよう
に、1つのトランザクションの中の更新が複数の計算機
41、42上で行なわれた場合、その更新を同期させる
ために、分散DBMS50、60同士がコミットの準備
とコミットの2回のやりとりを行なうことを2相コミッ
トシステムと呼んでいる。以下、2相コミットシステム
について説明する。
【0005】図4は、コミットメント制御の説明図、図
5は、分散データベースにおけるサブトランザクション
の説明図であり、図6は、2相コミット方式が正常な場
合の説明図、図7は、2相コミット方式でのサブトラン
ザクションの失敗例の説明図である。まず、トランザク
ション管理について説明すると、トランザクションは、
例えば、銀行業務の送金処理については、A口座からB
口座への送金の場合、A口座からの出金とB口座への入
金の2つのサブトランザクションから成る。このような
トランザクションを実行する場合、A口座からの出金
(図4の“更新1”)のみ完了し、B口座への入金(図
4の“更新2”)が障害により完了しないとすると、銀
行全体としてのデータベースの内容が狂ってしまう。こ
のため、トランザクションの開始から、“更新1”、
“更新2”の処理を一時保存用の他のファイルに保存
し、双方のサブトランザクションの完了後、コミットに
よりデータベースを更新するようにしている。これをコ
ミットメント制御という。“更新1”のみ完了し、“更
新2”が障害となると、“更新1”はデータベースには
反映されない。
【0006】上記の例で、分散データベースでは、通信
回線を介して分散して設置された各計算機で、それぞれ
のサブトランザクションが実行される。このように、分
散データベースでは、図5に示すように、利用者にとっ
てのトランザクションは各計算機で実行されるサブトラ
ンザクションの集まりとして実現される。分散データベ
ースで上述したコミットメント制御を行なうとすると、
図6及び図7に示すように、“サブトランザクション
1”と“サブトランザクション2”を別々の計算機でコ
ミットすることになる。この場合、トランザクションの
依頼側のマスタ計算機から、まず双方の計算機へコミッ
ト準備指示を順次出し、双方の計算機から準備完了の応
答を受けた後、コミット指示を各計算機に出すようにし
ている。これを2相コミット方式という。2相コミット
方式が正常に行なわれる場合は、図6に示すように、双
方の計算機からコミット準備指示に対する準備完了応答
が得られ、コミット指示が出される。これに対し、図7
に示すように、2相コミット方式で、例えば、“サブト
ランザクション2”を実行する計算機がコミット準備失
敗の場合は、各計算機に対し、アボート指示が出され、
双方の計算機とも実行を中止する。
【0007】
【発明が解決しようとする課題】しかしながら、上述し
た従来の技術には、次のような問題があった。即ち、こ
のように、従来分散データベースでは、同じデータを複
数のデータベースに格納する場合、複数の分散DBMS
に更新の命令を出す必要があり、さらに更新の同期をと
るために2相コミットシステムによって複数の分散DB
MSに対しコミットの準備とコミット要求を通信しなけ
ればならなかった。つまり、このようなシステムでは、
計算機間の通信が多く必要となり、データ処理性能の低
下の原因となっていた。本発明は、以上の点に着目して
なされたもので、同じデータを複数のデータベースに格
納する場合、必ずしも複数のデータベース上の同じデー
タを同期して更新する必要が無いことに着目し、更新の
性能が高い分散データベース制御システムを提供するこ
とを目的とするものである。
【0008】
【課題を解決するための手段】本発明の分散データベー
ス制御システムは、通信回線で接続された複数の計算機
内に同一データを重複分散して格納するデータベース
と、当該各データベースに重複して格納しているデータ
のコピーに対し、一部のコピーを主コピーに指定し、当
該主コピー以外の他のコピーを従コピーに指定するコピ
ー種類指定手段と、当該データについての更新要求に対
しては、前記主コピーを格納したデータベースを持つ計
算機で当該主コピーだけを更新し、その更新履歴を保存
する更新手段と、前記主コピーを格納した計算機が、前
記従コピーを格納した計算機に対し、更新履歴を送り、
当該更新履歴によって前記従コピーを前記主コピーと同
じ内容に更新する時期を指定する同期時期指定手段とを
備えたことを特徴とするものである。
【0009】
【作用】本発明の分散データベース制御システムにおい
ては、計算機で分散データベースを更新する場合、各デ
ータベースに格納された表などのデータが重複している
とき、更新手段によって、コピー種類指定手段に主コピ
ーと指定されているデータベースのみ更新する。このた
め、主コピーを格納している計算機で更新要求が生じた
ときは、自分のデータベースのみを更新し、従コピーを
格納している計算機で更新要求が生じたときは、主コピ
ーを格納している計算機に更新を依頼することになる。
複数の更新から成るトランザクションがコミット(実
行)されるとき、それぞれの更新について主コピーのみ
の更新を行なう。トランザクションを構成する複数の更
新のうちの一部が失敗したため、ロールバックしなけれ
ばならないときも主コピーの更新履歴のみをロールバッ
クする。一方、同期時期指定手段に主コピーと従コピー
とを一致させるための同期時期が指定されている。この
同期時期が来ると、主コピーを格納している計算機は各
従コピーを格納している計算機に主コピーの更新履歴を
送る。各従コピーを格納している計算機は、更新履歴を
受け取ると、各従コピーを更新手段によって更新する。
【0010】
【実施例】以下、本発明の実施例を図面を参照して詳細
に説明する。図1は、本発明の分散データベース制御シ
ステムの一実施例のブロック図である。図示のシステム
は、計算機1、2等から成る。各計算機1、2は、通信
網5で接続されている。各計算機1、2は、プロセッサ
30、35、通信制御装置31、36、主記憶装置3
2、37、磁気ディスク33、38等から成る。プロセ
ッサ30、35は、それぞれ磁気ディスク33、38に
格納されたデータベース15、25の更新処理等を行な
う。プロセッサ30、35は、このための更新手段34
を備えている。更新手段34、39は、磁気ディスクの
入出力プログラム等から成り、他の計算機のデータベー
スの更新依頼を出すときは、通信制御装置31、36に
その旨指示する。
【0011】通信制御装置31、36は、通信網5を介
して各計算機1、2相互の通信制御を行なう。この通信
制御装置31、36は、更新手段34、37から他の計
算機のデータベース更新依頼を受けたときは、該当する
計算機に対し、更新依頼を送信する。主記憶装置32、
37は、ランダム・アクセス・メモリ等から成り、磁気
ディスク33、38に格納されたデータを一時的に格納
する。データベース15、25を管理するための格納情
報管理テーブル14、24は、主記憶装置32、37に
常駐される。格納情報管理テーブル14、24は、それ
ぞれコピー種類指定手段73、83と、同期時期指定手
段74、84とを備えている。
【0012】コピー種類指定手段73、83は、各デー
タベース15、25に重複して格納しているデータのコ
ピーに対し、一部のコピーを主コピーに指定し、当該主
コピー以外の他のコピーを従コピーに指定する。同期時
期指定手段74、84は、主コピーを格納した計算機
が、従コピーを格納した計算機に対し、更新履歴を送
り、当該更新履歴によって従コピーを主コピーと同じ内
容に更新する時期を指定する。磁気ディスク33、37
は、データベース15、25の他、各種の制御プログラ
ム及び処理プログラムを格納している。次に、本発明の
システムの機能及び動作を説明する。
【0013】図8は、本発明の分散データベース制御シ
ステムの機能ブロック図であり、図9は、図8中の格納
情報管理テーブルの構造の説明図である。また、図10
は、データベース更新手順を説明するフローチャートで
あり、図11は、データベース同期手順を説明するフロ
ーチャートである。利用者からデータベースに対する検
索要求があった場合は、従来と同一の処理をする。本発
明では、図9に示すように格納情報管理テーブル14に
コピーの種類の欄と同期時期の欄が追加されている。こ
れらは、コピー種類指定手段73と、同期時期指定手段
74を構成する。 (A)利用者からデータベースに対する更新要求がある
と(図10ステップS1)、問合せ処理機能11が格納
情報管理テーブル14、24等の内容を調べる(ステッ
プS2、S3)。 (1)更新する表のコピーの種類欄73が同格であれ
ば、従来と同じ処理となる(ステップS4)。
【0014】(2)更新する表のコピーの種類欄73が
「主」であれば、その分散DBMSが管理しているデー
タベースを要求に従って更新する(ステップS5)。そ
して、さらに、表更新履歴17に、どの表のどのレコー
ドを更新したかを記録する(ステップS6)。 (3)更新する表のコピーの種類欄73が「従」であれ
ば、「主」の分散DBMSにデータベースの更新の要求
を転送する(ステップS7、S8)。「主」である分散
DBMSは、転送された更新要求を利用者から来た更新
要求と同様に処理する。つまり、データベース15を更
新し(ステップS5)、表更新履歴17に、どの表のど
のレコードを更新したかを記録し(ステップS6)、更
新を要求した分散DBMSに結果を応答する。一方、
「主」の分散DBMSからの更新結果を受けた分散DB
MSは、これを利用者に応答する。
【0015】(B)利用者から、トランザクションのコ
ミットが要求された場合、従来のシステムと同一の処理
をする。即ち、問合せ処理機能11は、トランザクショ
ンに関係した計算機の分散DBMSにコミットの準備を
命令する。このコミット準備命令に対するすべての応答
が正常であれば、トランザクションに関係した分散DB
MSにコミットを命令する。このコミット命令に対し、
データベースの更新は「主」のデータベースのみについ
て行なわれる(ステップS5、S8)。また、このコミ
ット命令に対する応答に1つでも異常があれば、トラン
ザクションに関係した分散DBMSにロールバックを命
令する。この場合、このロールバック命令に対し、デー
タベースの更新は「主」のデータベースのみについて行
なわれる(ステップS5、S8)。
【0016】(C)更新機能11は、格納情報管理テー
ブル14の同期時期21に書かれた時期が来ると(図1
1ステップS11)、表更新履歴17の内容により、そ
れまでになされた当該表に対する更新の履歴すべてを、
コピーの種類73が「従」である計算機の分散DBMS
に送る(ステップS12、S13)。これを受けた分散
DBMSの問合せ処理機能は更新機能によって、データ
ベースを更新し(図10ステップS9)、正常に終了し
たことを応答する。すべての「従」のコピーが完了した
ら、表更新履歴から、当該表の更新履歴を削除する。
【0017】
【発明の効果】以上説明したように、本発明の分散デー
タベース制御システムによれば、利用者から更新要求を
受付けたとき、主のコピーを格納しているデータベース
だけを更新し、従のコピーを格納しているデータベース
は、まとめて定期的に更新するようにしたので、データ
ベースを重複して格納しても、重複して格納していない
場合と同様の時間でデータベースを更新することができ
る。また、従来の分散DBMSのように重複して格納し
たデータを常に値が同じであるように保ちたいときは従
来と同様に更新の同期を取ることができる。
【図面の簡単な説明】
【図1】本発明の分散データベース制御システムの一実
施例のブロック図である。
【図2】従来の分散データベース制御システムの機能ブ
ロック図である。
【図3】従来の格納情報管理テーブルの構造の説明図で
ある。
【図4】コミットメント制御の説明図である。
【図5】分散データベースにおけるサブトランザクショ
ンの説明図である。
【図6】2相コミット方式が正常な場合の説明図であ
る。
【図7】2相コミット方式でのサブトランザクションの
失敗例の説明図である。
【図8】本発明の分散データベース制御システムの機能
ブロック図である。
【図9】本発明の格納情報管理テーブルの構造の説明図
である。
【図10】データベース更新手順を説明するフローチャ
ートである。
【図11】データベース同期手順を説明するフローチャ
ートである。
【符号の説明】
1、2 計算機 14、24 格納情報管理テーブル 15、25 データベース 34、39 更新手段 73 コピー種類指定手段 74 同期時期指定手段

Claims (1)

    【特許請求の範囲】
  1. 【請求項1】 通信回線で接続された複数の計算機内に
    同一データを重複分散して格納するデータベースと、 当該各データベースに重複して格納しているデータのコ
    ピーに対し、一部のコピーを主コピーに指定し、当該主
    コピー以外の他のコピーを従コピーに指定するコピー種
    類指定手段と、 当該データについての更新要求に対しては、前記主コピ
    ーを格納したデータベースを持つ計算機で当該主コピー
    だけを更新し、その更新履歴を保存する更新手段と、 前記主コピーを格納した計算機が、前記従コピーを格納
    した計算機に対し、更新履歴を送り、当該更新履歴によ
    って前記従コピーを前記主コピーと同じ内容に更新する
    時期を指定する同期時期指定手段とを備えたことを特徴
    とする分散データベース制御システム。
JP4292054A 1992-10-06 1992-10-06 分散データベース制御システム Pending JPH06119227A (ja)

Priority Applications (1)

Application Number Priority Date Filing Date Title
JP4292054A JPH06119227A (ja) 1992-10-06 1992-10-06 分散データベース制御システム

Applications Claiming Priority (1)

Application Number Priority Date Filing Date Title
JP4292054A JPH06119227A (ja) 1992-10-06 1992-10-06 分散データベース制御システム

Publications (1)

Publication Number Publication Date
JPH06119227A true JPH06119227A (ja) 1994-04-28

Family

ID=17776946

Family Applications (1)

Application Number Title Priority Date Filing Date
JP4292054A Pending JPH06119227A (ja) 1992-10-06 1992-10-06 分散データベース制御システム

Country Status (1)

Country Link
JP (1) JPH06119227A (ja)

Cited By (6)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
JPH11212848A (ja) * 1998-01-27 1999-08-06 Mitsubishi Electric Corp ネットワークシステム及びレプリカ維持方法
JP2006507551A (ja) * 2002-02-19 2006-03-02 クゥアルコム・インコーポレイテッド ウェブファームへのデータ配布における二相コミットのための方法および装置
JP2006079551A (ja) * 2004-09-13 2006-03-23 Canon Inc 通信システム及び通信装置、並びに通信方法
JP2009122935A (ja) * 2007-11-14 2009-06-04 Oki Electric Ind Co Ltd データベース提供装置、データベースクライアント端末、データベースシステム、データベース提供プログラム及びデータベースクライアントプログラム
WO2010032278A1 (ja) * 2008-09-17 2010-03-25 富士通株式会社 2相コミットによるデータ更新同期方法及びシステム
US8650274B2 (en) 2008-03-31 2014-02-11 Fujitsu Limited Virtual integrated management device for performing information update process for device configuration information management device

Cited By (7)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
JPH11212848A (ja) * 1998-01-27 1999-08-06 Mitsubishi Electric Corp ネットワークシステム及びレプリカ維持方法
JP2006507551A (ja) * 2002-02-19 2006-03-02 クゥアルコム・インコーポレイテッド ウェブファームへのデータ配布における二相コミットのための方法および装置
JP2006079551A (ja) * 2004-09-13 2006-03-23 Canon Inc 通信システム及び通信装置、並びに通信方法
JP2009122935A (ja) * 2007-11-14 2009-06-04 Oki Electric Ind Co Ltd データベース提供装置、データベースクライアント端末、データベースシステム、データベース提供プログラム及びデータベースクライアントプログラム
US8650274B2 (en) 2008-03-31 2014-02-11 Fujitsu Limited Virtual integrated management device for performing information update process for device configuration information management device
WO2010032278A1 (ja) * 2008-09-17 2010-03-25 富士通株式会社 2相コミットによるデータ更新同期方法及びシステム
US8572047B2 (en) 2008-09-17 2013-10-29 Fujitsu Limited Method and system for data update synchronization by two-phase commit

Similar Documents

Publication Publication Date Title
CA3121919C (en) System and method for augmenting database applications with blockchain technology
US7103586B2 (en) Collision avoidance in database replication systems
US5781910A (en) Preforming concurrent transactions in a replicated database environment
US6029177A (en) Method and system for maintaining the integrity of a database providing persistent storage for objects
US8713046B2 (en) Snapshot isolation support for distributed query processing in a shared disk database cluster
EP1704470B1 (en) Geographically distributed clusters
US5586310A (en) System for distributed database replicated read with exclusive central server transfer of primary copies
US7177866B2 (en) Asynchronous coordinated commit replication and dual write with replication transmission and locking of target database on updates only
EP0988596B1 (en) Method and system for recovery in a partitioned shared nothing database system using virtual shared disks
JPH0131216B2 (ja)
KR20030054442A (ko) 안전 기억장치가 없는 환경에서 로그정보를 이용한주메모리 상주 데이터베이스 관리시스템의 이중화 구조 및데이터 일치성 제어방법
EP1704480B1 (en) Cluster database with remote data mirroring
US20060200507A1 (en) Optimized statement caching for transaction replay
US11494347B1 (en) Efficient update-anywhere replication of queue operations on a replicated message queue
JPH06119227A (ja) 分散データベース制御システム
JPH0464146A (ja) 分散システムにおけるコミットメント処理の最適化方式
CA2618938C (en) Data consistency control method and software for a distributed replicated database system
US6539434B1 (en) UOWE's retry process in shared queues environment
JP2000187605A (ja) 純並列データベース管理システム
JP2629330B2 (ja) データ更新コミット処理方式
JP3253321B2 (ja) データベース・アクセスのための同期確認処理方式
JPH0498546A (ja) 重複データ更新方式
JPH0460850A (ja) トランザクション終了処理方式
JPH09171480A (ja) 情報記憶システムを備えるネットワークシステム、該システムの入力システムならびに自動運用システム、および該ネットワークシステムの自動運用方法
Bhalla et al. Implementing message oriented transaction processing for distributed database management systems