JPH10161916A - データベースの複製に伴う更新競合の検出方法 - Google Patents
データベースの複製に伴う更新競合の検出方法Info
- Publication number
- JPH10161916A JPH10161916A JP8318047A JP31804796A JPH10161916A JP H10161916 A JPH10161916 A JP H10161916A JP 8318047 A JP8318047 A JP 8318047A JP 31804796 A JP31804796 A JP 31804796A JP H10161916 A JPH10161916 A JP H10161916A
- Authority
- JP
- Japan
- Prior art keywords
- data
- update
- serial number
- database
- identifier
- 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
Links
- 230000010076 replication Effects 0.000 title claims 2
- 239000000284 extract Substances 0.000 abstract 1
Classifications
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR 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/27—Replication, distribution or synchronisation of data between databases or within a distributed database system; Distributed database system architectures therefor
- G06F16/275—Synchronous replication
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR 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/27—Replication, distribution or synchronisation of data between databases or within a distributed database system; Distributed database system architectures therefor
-
- 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/99951—File or database maintenance
- Y10S707/99952—Coherency, e.g. same view to multiple users
- Y10S707/99953—Recoverability
Landscapes
- Engineering & Computer Science (AREA)
- Databases & Information Systems (AREA)
- Theoretical Computer Science (AREA)
- Computing Systems (AREA)
- Data Mining & Analysis (AREA)
- Physics & Mathematics (AREA)
- General Engineering & Computer Science (AREA)
- General Physics & Mathematics (AREA)
- Information Retrieval, Db Structures And Fs Structures Therefor (AREA)
Abstract
(57)【要約】
【課題】 データベース１１０がデータベース１０４の
複製であり、後者へのデータ更新を前者へ反映するとき
正確に更新競合を検出する。 【解決手段】 更新情報作成部１０５はデータの更新が
あったときそのデータ識別子を更新データ識別子１０３
に保存する。データ転送部１０８は保存されたデータ識
別子を基に更新データをデータベース１０４から取り出
して付随する更新通番履歴とともにデータベースシステ
ム１０９へ送る。更新通番履歴はシステムの識別子と更
新回数を示す更新カウンタとを有する更新通番を累積す
るものである。データ受信部１１２は更新データとその
更新通番履歴を受信する。更新競合判定部１１５は受信
した更新通番とデータベース１１１中の対応する更新通
番履歴中の更新通番とを比較し、双方の最新の更新通番
が残りのいずれかの更新通番に一致しないとき更新競合
と判定する。
複製であり、後者へのデータ更新を前者へ反映するとき
正確に更新競合を検出する。 【解決手段】 更新情報作成部１０５はデータの更新が
あったときそのデータ識別子を更新データ識別子１０３
に保存する。データ転送部１０８は保存されたデータ識
別子を基に更新データをデータベース１０４から取り出
して付随する更新通番履歴とともにデータベースシステ
ム１０９へ送る。更新通番履歴はシステムの識別子と更
新回数を示す更新カウンタとを有する更新通番を累積す
るものである。データ受信部１１２は更新データとその
更新通番履歴を受信する。更新競合判定部１１５は受信
した更新通番とデータベース１１１中の対応する更新通
番履歴中の更新通番とを比較し、双方の最新の更新通番
が残りのいずれかの更新通番に一致しないとき更新競合
と判定する。
Description
【０００１】
【発明の属する技術分野】本発明は、複数のデータベー
スの内容を一致させるように一方のデータベースの更新
をデータの複製によって他方のデータベースに反映する
よう制御するデータベースシステムに係わり、特に各デ
ータベースが独立してデータ更新されるときの更新競合
を検出する方法に関する。
スの内容を一致させるように一方のデータベースの更新
をデータの複製によって他方のデータベースに反映する
よう制御するデータベースシステムに係わり、特に各デ
ータベースが独立してデータ更新されるときの更新競合
を検出する方法に関する。
【０００２】
【従来の技術】分散データベースの一形態として元とな
るデータベースの複製（レプリカ）を分散してもたせ、
各データベースを非同期に更新するいわゆるレプリケー
ションという分散更新技術が知られている。レプリケー
ションは、ネットワーク上の元となるデータベースをプ
ライマリデータベースとし、プライマリデータベースに
ついて行われた更新又は削除をセカンダリデータベース
に反映する技術である。このときセカンダリデータベー
スの対応するデータに更新又は削除が行われていると更
新競合が発生する。更新競合が生じたか否かを判定する
方式として、例えば「Ｌｏｔｕｓ ＮＯＴＥＳ ＲＥＬ
ＥＡＳＥ３．１Ｊ システム管理者ガイド」（ロータス
株式会社発行）Ｐ．１０〜１７によれば、データ内に更
新カウンタを記憶する領域を設けてデータの更新時にこ
の更新カウンタの値をアップし、データの複製処理を行
うときにこの更新カウンタの値の大小関係から更新競合
判定を行う。また文献「ネットワークコンピューティン
グ １９９４．２月 ＰＰ．１６〜２１ 分散ＲＤＢの
更新技術 トリガ／ストアドプロシジャに有効なレプリ
ケーション機能」によれば、複製処理時に複製元のデー
タベースシステムで行われたトランザクションの更新情
報を複製先に転送し、複製先のデータベースシステムは
この更新情報を基に所有するデータベースの更新を行
う。
るデータベースの複製（レプリカ）を分散してもたせ、
各データベースを非同期に更新するいわゆるレプリケー
ションという分散更新技術が知られている。レプリケー
ションは、ネットワーク上の元となるデータベースをプ
ライマリデータベースとし、プライマリデータベースに
ついて行われた更新又は削除をセカンダリデータベース
に反映する技術である。このときセカンダリデータベー
スの対応するデータに更新又は削除が行われていると更
新競合が発生する。更新競合が生じたか否かを判定する
方式として、例えば「Ｌｏｔｕｓ ＮＯＴＥＳ ＲＥＬ
ＥＡＳＥ３．１Ｊ システム管理者ガイド」（ロータス
株式会社発行）Ｐ．１０〜１７によれば、データ内に更
新カウンタを記憶する領域を設けてデータの更新時にこ
の更新カウンタの値をアップし、データの複製処理を行
うときにこの更新カウンタの値の大小関係から更新競合
判定を行う。また文献「ネットワークコンピューティン
グ １９９４．２月 ＰＰ．１６〜２１ 分散ＲＤＢの
更新技術 トリガ／ストアドプロシジャに有効なレプリ
ケーション機能」によれば、複製処理時に複製元のデー
タベースシステムで行われたトランザクションの更新情
報を複製先に転送し、複製先のデータベースシステムは
この更新情報を基に所有するデータベースの更新を行
う。
【０００３】
【発明が解決しようとする課題】上記最初の従来技術に
よれば、データ内に設けた更新カウンタの値の大小関係
によって更新競合判定を行うため、複数のシステム間で
データの複製処理を行うと更新回数が異なる競合は検出
できないという問題があった。また従来の複製元のデー
タベースシステムからトランザクション単位の更新情報
を転送する方式では、複製先のデータベースシステムの
有するデータベースにこの更新情報の反映を完了するま
で複製先のデータベース内のデータが最新状態にならず
時間がかかるという問題があった。
よれば、データ内に設けた更新カウンタの値の大小関係
によって更新競合判定を行うため、複数のシステム間で
データの複製処理を行うと更新回数が異なる競合は検出
できないという問題があった。また従来の複製元のデー
タベースシステムからトランザクション単位の更新情報
を転送する方式では、複製先のデータベースシステムの
有するデータベースにこの更新情報の反映を完了するま
で複製先のデータベース内のデータが最新状態にならず
時間がかかるという問題があった。
【０００４】本発明の目的は、正確な更新競合の検出を
可能とする方法を提供することにある。
可能とする方法を提供することにある。
【０００５】
【課題を解決するための手段】本発明は、データベース
の更新単位となるデータにプライマリ側及びセカンダリ
側のデータベースシステムに対応する識別子とこのデー
タの更新回数を更新通番としてこの更新通番をデータ更
新の都度累積する更新通番履歴に追加し、このデータを
セカンダリ側のデータベースに反映する際には更新デー
タとその更新通番履歴をプライマリ側からセカンダリ側
のデータベースシステムへ転送し、セカンダリ側では受
け取ったデータの更新通番履歴中の更新通番とセカンダ
リデータベース中の更新反映の対象となるデータの更新
通番履歴中の更新通番とを比較し、対象となるデータの
最新の更新通番が受け取ったデータの最新の更新通番を
除くいずれかの更新通番と一致せず、受け取ったデータ
の最新の更新通番が対象となるデータの最新の更新通番
を除くいずれかの更新通番と一致しないとき、更新競合
と判定する更新競合の検出方法を特徴とする。
の更新単位となるデータにプライマリ側及びセカンダリ
側のデータベースシステムに対応する識別子とこのデー
タの更新回数を更新通番としてこの更新通番をデータ更
新の都度累積する更新通番履歴に追加し、このデータを
セカンダリ側のデータベースに反映する際には更新デー
タとその更新通番履歴をプライマリ側からセカンダリ側
のデータベースシステムへ転送し、セカンダリ側では受
け取ったデータの更新通番履歴中の更新通番とセカンダ
リデータベース中の更新反映の対象となるデータの更新
通番履歴中の更新通番とを比較し、対象となるデータの
最新の更新通番が受け取ったデータの最新の更新通番を
除くいずれかの更新通番と一致せず、受け取ったデータ
の最新の更新通番が対象となるデータの最新の更新通番
を除くいずれかの更新通番と一致しないとき、更新競合
と判定する更新競合の検出方法を特徴とする。
【０００６】本発明によれば、更新通番としてデータベ
ースシステムに対応する識別子をもっているために、複
製される側のシステムが複数ある場合にも正確に更新競
合を検出することができる。またトランザクション単位
の更新情報の転送でなく、更新の対象となるデータを単
位として更新反映を行うので、更新データをセカンダリ
データベースに反映する時間を速めることができる。
ースシステムに対応する識別子をもっているために、複
製される側のシステムが複数ある場合にも正確に更新競
合を検出することができる。またトランザクション単位
の更新情報の転送でなく、更新の対象となるデータを単
位として更新反映を行うので、更新データをセカンダリ
データベースに反映する時間を速めることができる。
【０００７】
【発明の実施の形態】以下本発明の一実施形態について
図面を用いて説明する。
図面を用いて説明する。
【０００８】図１は、本実施形態の計算機システムの構
成図である。１０１は第１の計算機上で動作するプライ
マリレプリカ側のデータベースシステムである。１０２
は更新通番履歴を有し複製の元となるプライマリレプリ
カデータ、１０３は更新されたデータのデータ識別子を
保持する更新データ識別子、１０４はプライマリレプリ
カデータ１０２と更新データ識別子１０３を格納し外部
記憶装置上に設けられたデータベースである。１０５は
更新されたデータのデータ識別子を更新データ識別子１
０３に格納する更新情報作成部、１０６は更新データ識
別子１０３を参照してデータベース１０４から更新され
たプライマリレプリカデータを取得する更新データ取得
部、１０７は取得された更新データと参照関係にある参
照関係データを取得する参照関係データ取得部、１０８
は取得された更新データと参照関係データを転送するデ
ータ転送部である。データ転送部１０８は、更新データ
取得部１０６と参照関係データ取得部１０７とを包含す
る。更新情報作成部１０５、更新データ取得部１０６、
参照関係データ取得部１０７及びデータ転送部１０８
は、データベースシステム１０１を構成するプログラム
であり、第１の計算機の主記憶装置に格納され処理装置
によって実行される。なお図１ではデータベースシステ
ム１０１及びデータベースシステム１０９に対してデー
タの参照、更新などの要求を発行するアプリケーション
プログラムの図示を省略している。
成図である。１０１は第１の計算機上で動作するプライ
マリレプリカ側のデータベースシステムである。１０２
は更新通番履歴を有し複製の元となるプライマリレプリ
カデータ、１０３は更新されたデータのデータ識別子を
保持する更新データ識別子、１０４はプライマリレプリ
カデータ１０２と更新データ識別子１０３を格納し外部
記憶装置上に設けられたデータベースである。１０５は
更新されたデータのデータ識別子を更新データ識別子１
０３に格納する更新情報作成部、１０６は更新データ識
別子１０３を参照してデータベース１０４から更新され
たプライマリレプリカデータを取得する更新データ取得
部、１０７は取得された更新データと参照関係にある参
照関係データを取得する参照関係データ取得部、１０８
は取得された更新データと参照関係データを転送するデ
ータ転送部である。データ転送部１０８は、更新データ
取得部１０６と参照関係データ取得部１０７とを包含す
る。更新情報作成部１０５、更新データ取得部１０６、
参照関係データ取得部１０７及びデータ転送部１０８
は、データベースシステム１０１を構成するプログラム
であり、第１の計算機の主記憶装置に格納され処理装置
によって実行される。なお図１ではデータベースシステ
ム１０１及びデータベースシステム１０９に対してデー
タの参照、更新などの要求を発行するアプリケーション
プログラムの図示を省略している。
【０００９】１０９は第２の計算機上で動作するセカン
ダリレプリカ側のデータベースシステムである。１１０
はプライマリレプリカデータ１０２を複製した更新通番
履歴を有するセカンダリレプリカデータ、１１１はセカ
ンダリレプリカデータを格納し外部記憶装置上に設けら
れたデータベースである。１１２はネットワーク１１３
を経由して第１の計算機から転送された更新データと参
照関係データを受信するデータ受信部、１１４は転送さ
れてきたデータを受信データとして主記憶上に一時的に
格納する受信データ格納領域、１１５はデータ受信部１
１２の一部であり、受信データと受信データに対応する
セカンダリレプリカデータ１１０の更新競合判定を行う
更新競合判定部である。データ受信部１１２及び更新競
合判定部１１５は、データベースシステム１０９を構成
するプログラムであり、第２の計算機の主記憶装置に格
納され処理装置によって実行される。
ダリレプリカ側のデータベースシステムである。１１０
はプライマリレプリカデータ１０２を複製した更新通番
履歴を有するセカンダリレプリカデータ、１１１はセカ
ンダリレプリカデータを格納し外部記憶装置上に設けら
れたデータベースである。１１２はネットワーク１１３
を経由して第１の計算機から転送された更新データと参
照関係データを受信するデータ受信部、１１４は転送さ
れてきたデータを受信データとして主記憶上に一時的に
格納する受信データ格納領域、１１５はデータ受信部１
１２の一部であり、受信データと受信データに対応する
セカンダリレプリカデータ１１０の更新競合判定を行う
更新競合判定部である。データ受信部１１２及び更新競
合判定部１１５は、データベースシステム１０９を構成
するプログラムであり、第２の計算機の主記憶装置に格
納され処理装置によって実行される。
【００１０】図２は、プライマリレプリカデータ１０２
及びセカンダリレプリカデータ１１０のデータ構成図で
ある。プライマリレプリカデータ１０２及びセカンダリ
レプリカデータ１１０は、それぞれ複数組のデータ２０
１と付随する更新通番履歴２０７から構成される。各デ
ータ２０１はデータベースシステム内のデータを一意に
識別するためのデータ識別子２０２、更新通番の履歴を
保持する更新通番履歴２０７を指すデータ識別子２０３
及び属性データ２０４から構成される。ここでデータ２
０１は、プライマリレプリカデータ１０２及びセカンダ
リレプリカデータ１１０の中で参照及び更新の単位とな
るデータである。属性データ２０４は、データ識別子２
０２及びデータ識別子２０３以外の１個以上のデータ項
目から構成される一般データである。更新通番履歴２０
７の各エントリは、ノード番号２０５と更新カウンタ２
０６から構成される更新通番２０８である。ノード番号
２０５は計算機の識別子又はデータベースシステムの識
別子であり、更新カウンタ２０６はデータ更新の回数を
示す数字である。図２の例によれば更新通番履歴２０７
は、データ２０１の最新の（４回目の）更新時の更新通
番２０８、３回目の更新時の更新通番２０８、２回目の
更新時の更新通番２０８、最初の更新時の更新通番を保
有する。なお図２の例では保持する更新通番２０８の個
数を４とし４世代までの更新通番を保持しているが、保
持する世代の数は任意である。
及びセカンダリレプリカデータ１１０のデータ構成図で
ある。プライマリレプリカデータ１０２及びセカンダリ
レプリカデータ１１０は、それぞれ複数組のデータ２０
１と付随する更新通番履歴２０７から構成される。各デ
ータ２０１はデータベースシステム内のデータを一意に
識別するためのデータ識別子２０２、更新通番の履歴を
保持する更新通番履歴２０７を指すデータ識別子２０３
及び属性データ２０４から構成される。ここでデータ２
０１は、プライマリレプリカデータ１０２及びセカンダ
リレプリカデータ１１０の中で参照及び更新の単位とな
るデータである。属性データ２０４は、データ識別子２
０２及びデータ識別子２０３以外の１個以上のデータ項
目から構成される一般データである。更新通番履歴２０
７の各エントリは、ノード番号２０５と更新カウンタ２
０６から構成される更新通番２０８である。ノード番号
２０５は計算機の識別子又はデータベースシステムの識
別子であり、更新カウンタ２０６はデータ更新の回数を
示す数字である。図２の例によれば更新通番履歴２０７
は、データ２０１の最新の（４回目の）更新時の更新通
番２０８、３回目の更新時の更新通番２０８、２回目の
更新時の更新通番２０８、最初の更新時の更新通番を保
有する。なお図２の例では保持する更新通番２０８の個
数を４とし４世代までの更新通番を保持しているが、保
持する世代の数は任意である。
【００１１】例えば図２の例においてデータ２０１は、
更新データの識別子ＤＩＤ＿１、この更新データに対応
する更新通番履歴２０７のデータ識別子ＤＩＤ＿１１及
び属性データ２０４から構成される。また対応する更新
通番履歴２０７は、ノード番号１のシステムで４回目の
更新が行われ、その前にノード番号１のシステムで３回
目の更新が行われ、その前にノード番号１のシステムで
２回目の更新が行われ、その前にノード番号１のシステ
ムでデータが生成されたことを示している。
更新データの識別子ＤＩＤ＿１、この更新データに対応
する更新通番履歴２０７のデータ識別子ＤＩＤ＿１１及
び属性データ２０４から構成される。また対応する更新
通番履歴２０７は、ノード番号１のシステムで４回目の
更新が行われ、その前にノード番号１のシステムで３回
目の更新が行われ、その前にノード番号１のシステムで
２回目の更新が行われ、その前にノード番号１のシステ
ムでデータが生成されたことを示している。
【００１２】図３は、更新データ識別子１０３のデータ
構成図である。更新データ識別子１０３は、データベー
スシステム１０１内で更新されたデータのデータ識別子
２０２を要素として更新順に保持する。更新データ識別
子１０３内で同一のデータ識別子が重複してもよい。図
３の例によれば更新データ識別子１０３はデータ識別子
２０２としてＤＩＤ＿１、ＤＩＤ＿１０、ＤＩＤ＿５、
ＤＩＤ＿１等によって識別されるデータがそれぞれ順に
更新されたことを示している。データ識別子ＤＩＤ＿１
が重複しているのは、この識別子をもつデータが２回更
新されたことを示している。
構成図である。更新データ識別子１０３は、データベー
スシステム１０１内で更新されたデータのデータ識別子
２０２を要素として更新順に保持する。更新データ識別
子１０３内で同一のデータ識別子が重複してもよい。図
３の例によれば更新データ識別子１０３はデータ識別子
２０２としてＤＩＤ＿１、ＤＩＤ＿１０、ＤＩＤ＿５、
ＤＩＤ＿１等によって識別されるデータがそれぞれ順に
更新されたことを示している。データ識別子ＤＩＤ＿１
が重複しているのは、この識別子をもつデータが２回更
新されたことを示している。
【００１３】データベースシステム１０１及びデータベ
ースシステム１０９は、データ２０１が生成又は更新さ
れるごとにデータ識別子２０３によって指される更新通
番履歴２０７に更新通番２０８を格納する新たなエント
リを確保し、ノード番号２０５に自システムの識別子を
格納し、更新カウンタ２０６に更新回数を格納する。デ
ータ２０１が生成されたときの更新カウンタ２０６は１
であり、以後更新のたびに前回の更新カウンタ２０６に
１を加えた通番を更新カウンタ２０６に格納する。
ースシステム１０９は、データ２０１が生成又は更新さ
れるごとにデータ識別子２０３によって指される更新通
番履歴２０７に更新通番２０８を格納する新たなエント
リを確保し、ノード番号２０５に自システムの識別子を
格納し、更新カウンタ２０６に更新回数を格納する。デ
ータ２０１が生成されたときの更新カウンタ２０６は１
であり、以後更新のたびに前回の更新カウンタ２０６に
１を加えた通番を更新カウンタ２０６に格納する。
【００１４】図４は、更新情報作成部１０５の処理の流
れを示すフローチャートである。プライマリレプリカデ
ータ１０２内のデータの更新が行われると、制御はデー
タベースシステム１０１内の更新情報作成部１０５に移
り処理が開始される。ステップ４０１により更新データ
が複製の対象のデータであるか判定し、複製対象のデー
タである場合にステップ４０２でこの更新データの有す
るデータ識別子２０２をデータベース１０４内の更新デ
ータ識別子１０３に順に格納する。複製の対象データと
は、ユーザによって指定された複製の必要なデータであ
る。
れを示すフローチャートである。プライマリレプリカデ
ータ１０２内のデータの更新が行われると、制御はデー
タベースシステム１０１内の更新情報作成部１０５に移
り処理が開始される。ステップ４０１により更新データ
が複製の対象のデータであるか判定し、複製対象のデー
タである場合にステップ４０２でこの更新データの有す
るデータ識別子２０２をデータベース１０４内の更新デ
ータ識別子１０３に順に格納する。複製の対象データと
は、ユーザによって指定された複製の必要なデータであ
る。
【００１５】図５は、データ転送部１０８の処理の流れ
を示すフローチャートである。アプリケーションプログ
ラムから複製処理要求があったとき、あるいは指定され
た時刻に定期的に発生する複製処理要求があったとき、
制御はデータベースシステム１０１内の更新データ取得
部１０６に移る。ステップ５０１で更新データ取得部１
０６の処理を行って更新されたデータを取得し、ステッ
プ５０２で参照関係データ取得部１０７の処理を行って
この更新データと参照関係にあるデータを取得する。ス
テップ５０３で更新データ取得部１０６及び参照関係デ
ータ取得部１０７が取得したデータをネットワーク１１
３を介して第２計算機のデータベースシステム１０９に
転送する。
を示すフローチャートである。アプリケーションプログ
ラムから複製処理要求があったとき、あるいは指定され
た時刻に定期的に発生する複製処理要求があったとき、
制御はデータベースシステム１０１内の更新データ取得
部１０６に移る。ステップ５０１で更新データ取得部１
０６の処理を行って更新されたデータを取得し、ステッ
プ５０２で参照関係データ取得部１０７の処理を行って
この更新データと参照関係にあるデータを取得する。ス
テップ５０３で更新データ取得部１０６及び参照関係デ
ータ取得部１０７が取得したデータをネットワーク１１
３を介して第２計算機のデータベースシステム１０９に
転送する。
【００１６】図６は、更新データ取得部１０６の処理の
流れを示すフローチャートである。ステップ６０１で更
新データ識別子１０３に保持されたデータ識別子２０２
を１つ取得し、ステップ６０２でこのデータ識別子２０
２に対応するデータ２０１をデータベース１０４から取
得する。そしてステップ６０３でデータ識別子２０３を
参照することによってデータベース１０４からこのデー
タ２０１に対応する更新通番履歴２０７を取得する。
流れを示すフローチャートである。ステップ６０１で更
新データ識別子１０３に保持されたデータ識別子２０２
を１つ取得し、ステップ６０２でこのデータ識別子２０
２に対応するデータ２０１をデータベース１０４から取
得する。そしてステップ６０３でデータ識別子２０３を
参照することによってデータベース１０４からこのデー
タ２０１に対応する更新通番履歴２０７を取得する。
【００１７】図７は、参照関係データ取得部１０７の処
理の流れを示すフローチャートである。ステップ７０１
で更新データ取得部１０６が取得した更新データと参照
関係にあるデータが存在するか、すなわち更新データの
属性データ２０４内に参照関係にあるデータ２０１のデ
ータ識別子２０２が保持されているか否かをチェックす
る。保持されていればステップ７０２でこのデータ識別
子２０２に対応するデータ２０１をデータベース１０４
から取得し、ステップ７０３でこの参照関係データに対
応する更新通番履歴２０７を取得する。保持されていな
ければ、処理を終了する。
理の流れを示すフローチャートである。ステップ７０１
で更新データ取得部１０６が取得した更新データと参照
関係にあるデータが存在するか、すなわち更新データの
属性データ２０４内に参照関係にあるデータ２０１のデ
ータ識別子２０２が保持されているか否かをチェックす
る。保持されていればステップ７０２でこのデータ識別
子２０２に対応するデータ２０１をデータベース１０４
から取得し、ステップ７０３でこの参照関係データに対
応する更新通番履歴２０７を取得する。保持されていな
ければ、処理を終了する。
【００１８】データ転送部１０８は、更新データ識別子
１０３に残りのデータ識別子２０２があれば各データ識
別子２０２について更新データ取得部１０６の処理（ス
テップ５０１）、参照関係データ取得部１０７の処理
（ステップ５０２）及びデータ転送（ステップ５０３）
を繰り返す。更新データ識別子１０３内のデータ識別子
２０２が尽きたとき、処理を終了して待ち状態となる。
１０３に残りのデータ識別子２０２があれば各データ識
別子２０２について更新データ取得部１０６の処理（ス
テップ５０１）、参照関係データ取得部１０７の処理
（ステップ５０２）及びデータ転送（ステップ５０３）
を繰り返す。更新データ識別子１０３内のデータ識別子
２０２が尽きたとき、処理を終了して待ち状態となる。
【００１９】図８は、データベースシステム１０９内の
データ受信部１１２の処理の流れを示すフローチャート
である。ステップ８０１で第１の計算機のデータベース
システム１０１から転送されたデータを受信し、ステッ
プ８０２で受信したデータを主記憶装置上の受信データ
格納領域１１４に保持する。ステップ８０３で受信デー
タ格納領域１１４に保持された次の１つの受信データの
データ識別子２０２と同一のデータ識別子２０２をもつ
セカンダリレプリカデータ１１０中のデータ２０１とそ
の更新通番履歴２０７（以下対象データと呼ぶ）をデー
タベース１１１から取得する。データ２０１の属性デー
タ２０４中に参照関係にあるデータ２０１のデータ識別
子２０２が存在し、受信データが参照関係にあるデータ
を伴っているならば、参照関係にあるデータ２０１とそ
の更新通番履歴２０７もデータベース１１１から取得す
る。もしセカンダリレプリカデータ１１０中に対象デー
タが見当らず、受信データの更新通番履歴２０７中の更
新通番２０８の更新カウンタ２０６が１であれば、受信
データは生成データであるから、次のステップ８０４を
スキップしてステップ８０５に移る。ステップ８０４で
更新競合判定部１１５の処理を行って受信データと対象
データとの更新競合判定を行う。ステップ８０５ではこ
の判定結果に基づいて受信データによってデータベース
１１１を更新する。受信データが生成データであれば受
信データの複製データを作成してデータベース１１１に
格納する。
データ受信部１１２の処理の流れを示すフローチャート
である。ステップ８０１で第１の計算機のデータベース
システム１０１から転送されたデータを受信し、ステッ
プ８０２で受信したデータを主記憶装置上の受信データ
格納領域１１４に保持する。ステップ８０３で受信デー
タ格納領域１１４に保持された次の１つの受信データの
データ識別子２０２と同一のデータ識別子２０２をもつ
セカンダリレプリカデータ１１０中のデータ２０１とそ
の更新通番履歴２０７（以下対象データと呼ぶ）をデー
タベース１１１から取得する。データ２０１の属性デー
タ２０４中に参照関係にあるデータ２０１のデータ識別
子２０２が存在し、受信データが参照関係にあるデータ
を伴っているならば、参照関係にあるデータ２０１とそ
の更新通番履歴２０７もデータベース１１１から取得す
る。もしセカンダリレプリカデータ１１０中に対象デー
タが見当らず、受信データの更新通番履歴２０７中の更
新通番２０８の更新カウンタ２０６が１であれば、受信
データは生成データであるから、次のステップ８０４を
スキップしてステップ８０５に移る。ステップ８０４で
更新競合判定部１１５の処理を行って受信データと対象
データとの更新競合判定を行う。ステップ８０５ではこ
の判定結果に基づいて受信データによってデータベース
１１１を更新する。受信データが生成データであれば受
信データの複製データを作成してデータベース１１１に
格納する。
【００２０】図９は、更新競合判定部１１５の処理の流
れを示すフローチャートである。ステップ９０１で対象
データの保持する更新通番履歴２０７の中の最新の更新
通番２０８が受信データの保持する更新通番履歴２０７
の中の最新の更新通番２０８を除くいずれかの更新通番
２０８に一致するか否か判定する。この条件を満足し一
致する更新通番２０８があれば、受信データによる前回
更新以後の対象データの更新がないのであるから、「競
合していない（非競合）」と判定し（ステップ９０
４）、一致しなければステップ９０２に移る。ステップ
９０２で受信データの保持する最新の更新通番２０８と
対象データの保持する最新の更新通番２０８とを比較す
る。同じであれば複製処理中に重複して同一のデータが
「再度転送されたもの（再送）」と判定（ステップ９０
６）し、異なればステップ９０３に移る。ステップ９０
３で受信データの保持する最新の更新通番２０８が対象
データの保持する最新の更新通番２０８を除く更新通番
履歴２０７に存在すれば、複製処理中に重複して同一の
データが再度転送されたが対象データは「再度転送前に
更新されたもの（再送）」と判定し（ステップ９０
６）、存在しなければ「競合する（競合）」と判定（ス
テップ９０５）する。すなわちステップ９０１、ステッ
プ９０２及びステップ９０３のいずれの条件も満足しな
いということは、受信データの保持する更新通番履歴２
０７の中の最新の更新通番２０８を除くいずれかの更新
通番２０８が対象データの保持する更新通番履歴２０７
の中の最新の更新通番２０８を除くいずれかの更新通番
２０８に一致するケースであるから、このようなケース
は受信データによる前回更新以後に対象データはデータ
ベースシステム１０９による更新を受けていることを意
味しており、受信データに関して更新の競合が生じてい
ることを示している。なお受信データの保持する更新通
番履歴２０７の中の最古の更新通番２０８、すなわちデ
ータ生成時の更新通番２０８は、生成データが正常にデ
ータベース１１１に反映されているならば必ず対象デー
タの保持する更新通番履歴２０７の中の最古の更新通番
２０８に一致する。
れを示すフローチャートである。ステップ９０１で対象
データの保持する更新通番履歴２０７の中の最新の更新
通番２０８が受信データの保持する更新通番履歴２０７
の中の最新の更新通番２０８を除くいずれかの更新通番
２０８に一致するか否か判定する。この条件を満足し一
致する更新通番２０８があれば、受信データによる前回
更新以後の対象データの更新がないのであるから、「競
合していない（非競合）」と判定し（ステップ９０
４）、一致しなければステップ９０２に移る。ステップ
９０２で受信データの保持する最新の更新通番２０８と
対象データの保持する最新の更新通番２０８とを比較す
る。同じであれば複製処理中に重複して同一のデータが
「再度転送されたもの（再送）」と判定（ステップ９０
６）し、異なればステップ９０３に移る。ステップ９０
３で受信データの保持する最新の更新通番２０８が対象
データの保持する最新の更新通番２０８を除く更新通番
履歴２０７に存在すれば、複製処理中に重複して同一の
データが再度転送されたが対象データは「再度転送前に
更新されたもの（再送）」と判定し（ステップ９０
６）、存在しなければ「競合する（競合）」と判定（ス
テップ９０５）する。すなわちステップ９０１、ステッ
プ９０２及びステップ９０３のいずれの条件も満足しな
いということは、受信データの保持する更新通番履歴２
０７の中の最新の更新通番２０８を除くいずれかの更新
通番２０８が対象データの保持する更新通番履歴２０７
の中の最新の更新通番２０８を除くいずれかの更新通番
２０８に一致するケースであるから、このようなケース
は受信データによる前回更新以後に対象データはデータ
ベースシステム１０９による更新を受けていることを意
味しており、受信データに関して更新の競合が生じてい
ることを示している。なお受信データの保持する更新通
番履歴２０７の中の最古の更新通番２０８、すなわちデ
ータ生成時の更新通番２０８は、生成データが正常にデ
ータベース１１１に反映されているならば必ず対象デー
タの保持する更新通番履歴２０７の中の最古の更新通番
２０８に一致する。
【００２１】更新競合判定部１１５の処理（ステップ８
０４）の後、データ受信部１１２は「非競合」の判定の
場合にはステップ８０５で受信データによるデータベー
ス１１１の更新処理を行う。「再送」の判定の場合には
同一のデータの再送であるから受信データを捨てて更新
処理を行わない。「競合」の判定の場合にはデータベー
スシステム１０９内の別の処理プログラムによつて更新
競合の場合の処理を行うが、詳細説明を省略する。受信
データが参照関係にあるデータを伴っているときには、
参照関係にあるデータ２０１とその更新通番履歴２０７
についてステップ８０４の処理を繰り返す。更新データ
とともに参照関係データについても更新競合判定を行う
理由は、更新データが更新されたとき参照関係データが
更新される可能性高いためである。１つの受信データに
ついてステップ８０３〜８０５の処理が終了したとき、
ステップ８０２に戻り受信データ格納領域１１４中に残
りの受信データがあれば次の受信データについて上記処
理を繰り返す。ステップ８０１及び８０２の処理は、デ
ータベースシステム１０１からの転送データがある限り
常時行う。
０４）の後、データ受信部１１２は「非競合」の判定の
場合にはステップ８０５で受信データによるデータベー
ス１１１の更新処理を行う。「再送」の判定の場合には
同一のデータの再送であるから受信データを捨てて更新
処理を行わない。「競合」の判定の場合にはデータベー
スシステム１０９内の別の処理プログラムによつて更新
競合の場合の処理を行うが、詳細説明を省略する。受信
データが参照関係にあるデータを伴っているときには、
参照関係にあるデータ２０１とその更新通番履歴２０７
についてステップ８０４の処理を繰り返す。更新データ
とともに参照関係データについても更新競合判定を行う
理由は、更新データが更新されたとき参照関係データが
更新される可能性高いためである。１つの受信データに
ついてステップ８０３〜８０５の処理が終了したとき、
ステップ８０２に戻り受信データ格納領域１１４中に残
りの受信データがあれば次の受信データについて上記処
理を繰り返す。ステップ８０１及び８０２の処理は、デ
ータベースシステム１０１からの転送データがある限り
常時行う。
【００２２】図１０ａ及び図１０ｂは、本実施形態の処
理の過程を具体例によって示す図である。図１０ａに示
すようにノード番号１をもつデータベースシステム１０
１がデータベース１０４を更新した結果、プライマリレ
プリカデータ１０２にデータ２０１−１、２０１−２及
び２０１−３が格納され、更新データ識別子１０３に更
新されたデータのデータ識別子２０２が格納されてい
る。データ２０１−１はデータ識別子２０２としてＤＩ
Ｄ＿１を有し、更新通番履歴２０７−１を指すデータ識
別子２０３としてＤＩＤ＿１１を保持し、データ２０１
−２と参照関係にありデータ２０１−２のデータ識別子
２０２を属性データ２０４中に保持している。データ２
０１−２はデータ識別子２０２としてＤＩＤ＿２を有
し、更新通番履歴２０７−２を指すデータ識別子２０３
としてＤＩＤ＿２１を保持している。データ２０１−３
はデータ識別子２０２としてＤＩＤ＿３を有し、更新通
番履歴２０７−３を指すデータ識別子２０３としてＤＩ
Ｄ＿３１を保持している。
理の過程を具体例によって示す図である。図１０ａに示
すようにノード番号１をもつデータベースシステム１０
１がデータベース１０４を更新した結果、プライマリレ
プリカデータ１０２にデータ２０１−１、２０１−２及
び２０１−３が格納され、更新データ識別子１０３に更
新されたデータのデータ識別子２０２が格納されてい
る。データ２０１−１はデータ識別子２０２としてＤＩ
Ｄ＿１を有し、更新通番履歴２０７−１を指すデータ識
別子２０３としてＤＩＤ＿１１を保持し、データ２０１
−２と参照関係にありデータ２０１−２のデータ識別子
２０２を属性データ２０４中に保持している。データ２
０１−２はデータ識別子２０２としてＤＩＤ＿２を有
し、更新通番履歴２０７−２を指すデータ識別子２０３
としてＤＩＤ＿２１を保持している。データ２０１−３
はデータ識別子２０２としてＤＩＤ＿３を有し、更新通
番履歴２０７−３を指すデータ識別子２０３としてＤＩ
Ｄ＿３１を保持している。
【００２３】また図１０ｂに示すようにノード番号２を
もつデータベースシステム１０が保有するデータベース
１１１にはデータ２０１−１、２０１−２及び２０１−
３のそれぞれ第２のレプリカデータが格納されている。
ただし各更新通番履歴２０７の内容が示すように、同一
のデータ識別子２０２をもつ各データ２０１の内容はデ
ータベース１０４とデータベース１１１との間で一致し
ていない。
もつデータベースシステム１０が保有するデータベース
１１１にはデータ２０１−１、２０１−２及び２０１−
３のそれぞれ第２のレプリカデータが格納されている。
ただし各更新通番履歴２０７の内容が示すように、同一
のデータ識別子２０２をもつ各データ２０１の内容はデ
ータベース１０４とデータベース１１１との間で一致し
ていない。
【００２４】複製処理要求があつたとき、更新データ取
得部１０６はまず更新データ識別子１０３からデータ識
別子ＤＩＤ＿１を取得する（ステップ６０１）。次に取
得したデータ識別子ＤＩＤ＿１に対応するデータ２０１
−１をデータベース１０４から取得し（ステップ６０
２）、このデータの保持するデータ識別子ＤＩＤ＿１１
を基に対応する更新通番履歴２０７−１をデータベース
１０４から取得する（ステップ６０３）。そして参照関
係データ取得部１０７はデータ２０１−１の保持する参
照関係データのデータ識別子ＤＩＤ＿２に対応する参照
関係のデータ２０１−２とその更新通番履歴２０７−２
をデータベース１０４から取得する（ステップ７０２及
びステップ７０３）。次にデータ転送部１０８はデータ
２０１−１とこのデータの有する更新通番履歴２０７−
１及び参照関係のデータ２０１−２とその更新通番履歴
２０７−２をデータベースシステム１０９に転送する
（ステップ５０３）。
得部１０６はまず更新データ識別子１０３からデータ識
別子ＤＩＤ＿１を取得する（ステップ６０１）。次に取
得したデータ識別子ＤＩＤ＿１に対応するデータ２０１
−１をデータベース１０４から取得し（ステップ６０
２）、このデータの保持するデータ識別子ＤＩＤ＿１１
を基に対応する更新通番履歴２０７−１をデータベース
１０４から取得する（ステップ６０３）。そして参照関
係データ取得部１０７はデータ２０１−１の保持する参
照関係データのデータ識別子ＤＩＤ＿２に対応する参照
関係のデータ２０１−２とその更新通番履歴２０７−２
をデータベース１０４から取得する（ステップ７０２及
びステップ７０３）。次にデータ転送部１０８はデータ
２０１−１とこのデータの有する更新通番履歴２０７−
１及び参照関係のデータ２０１−２とその更新通番履歴
２０７−２をデータベースシステム１０９に転送する
（ステップ５０３）。
【００２５】データ受信部１１２は、ステップ８０１で
転送されたデータ２０１−１とこのデータの更新通番履
歴２０７−１及び参照関係のデータ２０１−２とその更
新通番履歴２０７−２を受信し、それぞれ受信データ格
納領域１１４に格納する（ステップ８０２）。そしてデ
ータ２０１−１及び２０１−２に対応する対象データで
あるデータ２０１−１及び２０１−２並びにそれぞれの
データの更新通番履歴２０７−１及び２０７−２をデー
タベース１１１から取得する（ステップ８０３）。
転送されたデータ２０１−１とこのデータの更新通番履
歴２０７−１及び参照関係のデータ２０１−２とその更
新通番履歴２０７−２を受信し、それぞれ受信データ格
納領域１１４に格納する（ステップ８０２）。そしてデ
ータ２０１−１及び２０１−２に対応する対象データで
あるデータ２０１−１及び２０１−２並びにそれぞれの
データの更新通番履歴２０７−１及び２０７−２をデー
タベース１１１から取得する（ステップ８０３）。
【００２６】更新競合判定部１１５は、対象データのデ
ータ２０１−１の最新の更新通番「１−３」が受信デー
タ中のデータ２０１−１の最新の更新通番２０８を除く
更新通番履歴２０７−１中に存在するため、ステップ９
０１で「非競合」と判定する。同様に対象データのデー
タ２０１−２についても最新の更新通番「１−２」が受
信データ中のデータ２０１−２の更新通番履歴２０７に
存在するため、ステップ９０１で「非競合」と判定す
る。そしてステップ８０５で受信データによって対象デ
ータのデータ２０１及び更新通番履歴２０７を更新す
る。
ータ２０１−１の最新の更新通番「１−３」が受信デー
タ中のデータ２０１−１の最新の更新通番２０８を除く
更新通番履歴２０７−１中に存在するため、ステップ９
０１で「非競合」と判定する。同様に対象データのデー
タ２０１−２についても最新の更新通番「１−２」が受
信データ中のデータ２０１−２の更新通番履歴２０７に
存在するため、ステップ９０１で「非競合」と判定す
る。そしてステップ８０５で受信データによって対象デ
ータのデータ２０１及び更新通番履歴２０７を更新す
る。
【００２７】更新データ取得部１０６は次に更新データ
識別子１０３からデータ識別子ＤＩＤ＿１の次のデータ
識別子ＤＩＤ＿３を取得し、上記のように更新データ取
得部１０６、参照関係データ取得部１０７、データ転送
部１０８、データ受信部１１２及び更新競合判定部１１
５の処理を行う。この場合にはデータ識別子ＤＩＤ＿３
を有するデータ２０１−３とその更新通番履歴２０７−
２は受信データ格納領域１１４に格納され、更新競合判
定部１１５はステップ９０１、９０２及び９０３のいず
れの条件も満足しないので「競合」と判定する。
識別子１０３からデータ識別子ＤＩＤ＿１の次のデータ
識別子ＤＩＤ＿３を取得し、上記のように更新データ取
得部１０６、参照関係データ取得部１０７、データ転送
部１０８、データ受信部１１２及び更新競合判定部１１
５の処理を行う。この場合にはデータ識別子ＤＩＤ＿３
を有するデータ２０１−３とその更新通番履歴２０７−
２は受信データ格納領域１１４に格納され、更新競合判
定部１１５はステップ９０１、９０２及び９０３のいず
れの条件も満足しないので「競合」と判定する。
【００２８】なお上記処理においてデータ２０１−１の
ように同じデータ２０１に複数回の更新が行われると同
一データを繰り返しデータベースシステム１０９に転送
することになるので、データ転送部１０８内に転送した
データ２０１のデータ識別子２０２を保持する領域を設
け同一データの転送をスキツプすることによって同一デ
ータの再転送を防ぎ、データ転送の効率を向上できる。
ように同じデータ２０１に複数回の更新が行われると同
一データを繰り返しデータベースシステム１０９に転送
することになるので、データ転送部１０８内に転送した
データ２０１のデータ識別子２０２を保持する領域を設
け同一データの転送をスキツプすることによって同一デ
ータの再転送を防ぎ、データ転送の効率を向上できる。
【００２９】上記実施形態では第１の計算機上にデータ
ベースシステム１０１を配置し、ネットワーク１１３を
介して第１の計算機と接続される第２の計算機上にデー
タベースシステム１０９を配置したが、同一の計算機上
にデータベースシステム１０１とデータベースシステム
１０９とを配置してもよく、ネットワーク１１３を介す
るデータ転送を除いて上記構成及び動作の説明がそのま
ま適用できる。
ベースシステム１０１を配置し、ネットワーク１１３を
介して第１の計算機と接続される第２の計算機上にデー
タベースシステム１０９を配置したが、同一の計算機上
にデータベースシステム１０１とデータベースシステム
１０９とを配置してもよく、ネットワーク１１３を介す
るデータ転送を除いて上記構成及び動作の説明がそのま
ま適用できる。
【００３０】
【発明の効果】以上説明したように本発明によれば、複
数データベースシステムの有するプライマリレプリカデ
ータ及びセカンダリレプリカデータの更新競合判定を正
確に行うことができる。
数データベースシステムの有するプライマリレプリカデ
ータ及びセカンダリレプリカデータの更新競合判定を正
確に行うことができる。
【図１】実施形態の計算機システムの構成図である。
【図２】実施形態のプライマリレプリカデータ１０２及
びセカンダリレプリカデータ１１０のデータ構成図であ
る。
びセカンダリレプリカデータ１１０のデータ構成図であ
る。
【図３】実施形態の更新データ識別子１０３のデータ構
成図である。
成図である。
【図４】実施形態の更新情報作成部１０５の処理の流れ
を示すフローチャートである。
を示すフローチャートである。
【図５】実施形態のデータ転送部１０８の処理の流れを
示すフローチャートである。
示すフローチャートである。
【図６】実施形態における更新データ取得部１０６の処
理の流れを示すフローチャートである。
理の流れを示すフローチャートである。
【図７】実施形態の参照関係データ取得部１０７の処理
の流れを示すフローチャートである。
の流れを示すフローチャートである。
【図８】実施形態のデータ受信部１１２の処理の流れを
示すフローチャートである。
示すフローチャートである。
【図９】実施形態の更新競合判定部１１５の処理の流れ
を示すフローチャートである。
を示すフローチャートである。
【図１０ａ】実施形態の処理の過程を具体例によつて示
す図である。
す図である。
【図１０ｂ】実施形態の処理の過程を具体例によつて示
す図（続き）である。
す図（続き）である。
１０１：データベースシステム、１０２：プライマリレ
プリカデータ、１０３：更新データ識別子、１０９：デ
ータベースシステム、１１０：セカンダリレプリカデー
タ、１１５：更新競合判定部、２０１：データ、２０
２：データ識別子、２０５：ノード番号、２０６：更新
カウンタ、２０７：更新通番履歴、２０８：更新通番
プリカデータ、１０３：更新データ識別子、１０９：デ
ータベースシステム、１１０：セカンダリレプリカデー
タ、１１５：更新競合判定部、２０１：データ、２０
２：データ識別子、２０５：ノード番号、２０６：更新
カウンタ、２０７：更新通番履歴、２０８：更新通番
───────────────────────────────────────────────────── フロントページの続き (72)発明者 丸山 剛男 神奈川県横浜市戸塚区戸塚町5030番地 株 式会社日立製作所ソフトウェア開発本部内 (72)発明者 田中 仁士 神奈川県横浜市戸塚区戸塚町5030番地 株 式会社日立製作所ソフトウェア開発本部内 (72)発明者 西川 記史 神奈川県川崎市麻生区王禅寺1099番地 株 式会社日立製作所システム開発研究所内 (72)発明者 高谷 秀之 兵庫県尼崎市下坂部３丁目11番１号 日立 機電工業株式会社内
Claims (3)
- 【請求項１】第１のデータベースを保有する第１のデー
タベースシステムと、第１のデータベースと同一内容に
一致させるように第１のデータベースへのデータ更新が
データの複製によって反映される第２のデータベースを
保有する第２のデータベースシステムとを有するシステ
ムについて同一データ識別子をもつデータベース中のデ
ータが第１のデータベースシステムと第２のデータベー
スシステムとの双方で独立に更新される更新競合を検出
する方法において、 該データに第１／第２のデータベースシステムに対応す
る識別子と該データの更新回数を更新通番として累積す
る更新通番履歴を付随させるように該データベースを構
成し、 第１及び第２のデータベースシステムによって該データ
を更新するたびに付随する更新通番履歴に該更新通番を
追加し、第１のデータベースシステムによって該データ
を第２のデータベースに反映する際には更新された該デ
ータと該更新通番履歴とを第２のデータベースシステム
へ転送し、 第２のデータベースシステムによって受け取った該デー
タの更新通番履歴中の更新通番と第２のデータベース中
の更新反映の対象となるデータの更新通番履歴中の更新
通番とを比較し、対象となるデータの最新の更新通番が
受け取ったデータの最新の更新通番を除くいずれかの更
新通番と一致せず、受け取ったデータの最新の更新通番
が対象となるデータの最新の更新通番を除くいずれかの
更新通番と一致しないとき、更新競合と判定することを
特徴とするデータベースの複製に伴う更新競合の検出方
法。 - 【請求項２】第１のデータベースシステムによって第１
のデータベース中のデータが更新されるごとに更新され
るデータのデータ識別子を記憶装置に格納し、第１のデ
ータベース中の更新されたデータを第２のデータベース
システムへ転送するとき、該記憶装置から該データ識別
子を順に取り出し、取り出したデータ識別子に対応する
該データと該更新通番履歴とを第２のデータベースシス
テムへ転送することを特徴とする請求項１記載のデータ
ベースの複製に伴う更新競合の検出方法。 - 【請求項３】更新された該データとその更新通番履歴と
を第２のデータベースシステムへ転送するとき、該デー
タと参照関係にあるデータとその更新通番履歴も第２の
データベースシステムへ転送し、参照関係にあるデータ
についても上記更新競合の検出を行うことを特徴とする
請求項１記載のデータベースの複製に伴う更新競合の検
出方法。
Priority Applications (2)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| JP8318047A JPH10161916A (ja) | 1996-11-28 | 1996-11-28 | データベースの複製に伴う更新競合の検出方法 |
| US08/979,946 US5946689A (en) | 1996-11-28 | 1997-11-26 | Distributed database system and method of detecting contention in data update involved in replication of database data |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| JP8318047A JPH10161916A (ja) | 1996-11-28 | 1996-11-28 | データベースの複製に伴う更新競合の検出方法 |
Publications (1)
| Publication Number | Publication Date |
|---|---|
| JPH10161916A true JPH10161916A (ja) | 1998-06-19 |
Family
ID=18094906
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| JP8318047A Pending JPH10161916A (ja) | 1996-11-28 | 1996-11-28 | データベースの複製に伴う更新競合の検出方法 |
Country Status (2)
| Country | Link |
|---|---|
| US (1) | US5946689A (ja) |
| JP (1) | JPH10161916A (ja) |
Cited By (9)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| JP2001154917A (ja) * | 1999-10-01 | 2001-06-08 | Ncr Internatl Inc | データベース管理システムにおけるデータ管理システム |
| US6711592B2 (en) | 2000-06-27 | 2004-03-23 | Oki Electric Industry Co, Ltd. | Information processing system |
| US7930271B2 (en) | 2000-10-09 | 2011-04-19 | Maximum Availability Ltd. | Method and apparatus for data processing |
| CN1977265B (zh) | 2004-07-01 | 2011-06-22 | 苹果公司 | 基于状态的同步 |
| KR20110093860A (ko) * | 2008-11-06 | 2011-08-18 | 아마데우스 에스.에이.에스. | 데이터 베이스 내 대용량 업데이트를 실시간으로 집적하는 방법 |
| JP2013041520A (ja) * | 2011-08-19 | 2013-02-28 | Nippon Telegr & Teleph Corp <Ntt> | データ保持システム、データ保持装置及びデータ保持方法 |
| CN103164418A (zh) * | 2011-12-12 | 2013-06-19 | 阿里巴巴集团控股有限公司 | 一种序列号的处理方法及设备 |
| JP2014523024A (ja) * | 2011-06-23 | 2014-09-08 | アリババ・グループ・ホールディング・リミテッド | 増分データの抽出 |
| CN110990350A (zh) * | 2019-11-28 | 2020-04-10 | 泰康保险集团股份有限公司 | 日志的解析方法及装置 |
Families Citing this family (45)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| JP3302522B2 (ja) * | 1994-12-26 | 2002-07-15 | 富士通株式会社 | データベースシステムおよびその情報活用支援装置 |
| SE9702015L (sv) * | 1997-05-28 | 1998-11-29 | Ericsson Telefon Ab L M | Metod vid distribuerad databas, samt ett system anpassat att verka enligt metoden |
| US6006206A (en) * | 1997-09-08 | 1999-12-21 | Reuters Limited | Data health monitor for financial information communications networks |
| US6178529B1 (en) | 1997-11-03 | 2001-01-23 | Microsoft Corporation | Method and system for resource monitoring of disparate resources in a server cluster |
| GB9727463D0 (en) * | 1997-12-30 | 1998-02-25 | Orange Personal Comm Serv Ltd | Telecommunications system |
| US6374268B1 (en) * | 1998-04-14 | 2002-04-16 | Hewlett-Packard Company | Methods and systems for an incremental file system |
| US6360331B2 (en) * | 1998-04-17 | 2002-03-19 | Microsoft Corporation | Method and system for transparently failing over application configuration information in a server cluster |
| US6449734B1 (en) * | 1998-04-17 | 2002-09-10 | Microsoft Corporation | Method and system for discarding locally committed transactions to ensure consistency in a server cluster |
| US6243825B1 (en) | 1998-04-17 | 2001-06-05 | Microsoft Corporation | Method and system for transparently failing over a computer name in a server cluster |
| US6192377B1 (en) * | 1998-05-13 | 2001-02-20 | Oracle Corporation | Method and apparatus for determing whether a transaction can use a version of a data item |
| US6886017B1 (en) * | 1999-04-30 | 2005-04-26 | Elata Limited | System and method for managing distribution of content to a device |
| US6839894B1 (en) * | 1999-11-19 | 2005-01-04 | Oracle International Corporation | Method and apparatus for debugging a software program using dynamic debug patches and copy on write views |
| US6671825B1 (en) | 1999-11-19 | 2003-12-30 | Oracle International Corporation | Method and apparatus for debugging a software program |
| US6604205B1 (en) * | 2000-02-07 | 2003-08-05 | Hewlett-Packard Development Co., L.P. | System and method for state synchronization |
| US6542907B1 (en) * | 2000-03-31 | 2003-04-01 | International Business Machines Corporation | Method and apparatus for decentralized, invertible generation of bounded-length globally unique replica identifiers |
| KR20010095973A (ko) * | 2000-04-14 | 2001-11-07 | 장헌정 | 데이터베이스 관리 방법 |
| US6529917B1 (en) * | 2000-08-14 | 2003-03-04 | Divine Technology Ventures | System and method of synchronizing replicated data |
| KR100346891B1 (ko) * | 2000-08-31 | 2002-08-03 | 삼성증권주식회사 | 분산 데이터 복제방법 |
| US6694337B1 (en) * | 2000-10-26 | 2004-02-17 | Intel Corporation | Synchronizing databases |
| US6557089B1 (en) | 2000-11-28 | 2003-04-29 | International Business Machines Corporation | Backup by ID-suppressed instant virtual copy then physical backup copy with ID reintroduced |
| DE10061102B4 (de) * | 2000-12-07 | 2010-09-02 | Tc Trust Center Gmbh | System zur Statusabfrage von digitalen Zertifikaten |
| JP2002297593A (ja) * | 2001-03-30 | 2002-10-11 | Toshiba Corp | ベースホスト切替型データベース管理システム |
| US20020177437A1 (en) * | 2001-05-23 | 2002-11-28 | David Chesavage | System and method for maintaining a distributed object system |
| US20020178140A1 (en) * | 2001-05-25 | 2002-11-28 | Woodmansee Donald Ernest | Method for characterizing and storing data analyses in an analysis database |
| WO2003009139A1 (en) * | 2001-07-16 | 2003-01-30 | Transact In Memory, Inc. | Parallelized redo-only logging and recovery for highly available main memory database systems |
| DE10148877A1 (de) * | 2001-10-04 | 2003-04-30 | Siemens Ag | Verfahren zum Verteilen von Daten in einem Datennetz |
| US6938031B1 (en) * | 2001-10-19 | 2005-08-30 | Data Return Llc | System and method for accessing information in a replicated database |
| US6889333B2 (en) * | 2001-11-01 | 2005-05-03 | Microsoft Corporation | System and method for replicating data in a distributed system |
| US7024429B2 (en) | 2002-01-31 | 2006-04-04 | Nextpage,Inc. | Data replication based upon a non-destructive data model |
| EP1376396A1 (en) | 2002-06-28 | 2004-01-02 | Sap Ag | Decentralized data distribution |
| US7076508B2 (en) * | 2002-08-12 | 2006-07-11 | International Business Machines Corporation | Method, system, and program for merging log entries from multiple recovery log files |
| US7152076B2 (en) * | 2003-01-23 | 2006-12-19 | Microsoft Corporation | System and method for efficient multi-master replication |
| US7383289B2 (en) | 2003-12-02 | 2008-06-03 | Sap Aktiengesellschaft | Updating and maintaining data in a multi-system network using asynchronous message transfer |
| KR100521742B1 (ko) * | 2003-12-17 | 2005-10-17 | 한국전자통신연구원 | 엑스엠엘 문서의 구조 및 속성 정보의 손실 없이 엑스엠엘문서를 원격 서버로 복제하는 엑스엠엘 데이터베이스이중화 장치 및 그 방법 |
| US20060004806A1 (en) * | 2004-06-01 | 2006-01-05 | Kraft Frank M | Updating data in a multi-system network that utilizes asynchronous message transfer |
| US9020887B2 (en) | 2004-12-21 | 2015-04-28 | Proofpoint, Inc. | Managing the status of documents in a distributed storage system |
| US7523146B2 (en) * | 2005-06-21 | 2009-04-21 | Apple Inc. | Apparatus and method for peer-to-peer N-way synchronization in a decentralized environment |
| US8495015B2 (en) | 2005-06-21 | 2013-07-23 | Apple Inc. | Peer-to-peer syncing in a decentralized environment |
| JP4906072B2 (ja) * | 2006-05-01 | 2012-03-28 | キヤノン株式会社 | 情報処理装置ならびに情報処理方法 |
| US7860826B2 (en) | 2006-08-04 | 2010-12-28 | Apple Inc. | Method and system for using global equivalency sets to identify data during peer-to-peer synchronization |
| US7760767B2 (en) * | 2007-01-05 | 2010-07-20 | Apple Inc. | Wide area peer-to-peer synching in a decentralized environment |
| US7657769B2 (en) * | 2007-01-08 | 2010-02-02 | Marcy M Scott | N-way synchronization of data |
| JP6191159B2 (ja) * | 2013-02-25 | 2017-09-06 | 日本電気株式会社 | サーバ、バックアップシステム、バックアップ方法、および、コンピュータ・プログラム |
| CN104750797A (zh) * | 2015-03-13 | 2015-07-01 | 深圳市梦域科技有限公司 | 一种数据读取的方法及终端 |
| JP7007565B2 (ja) * | 2017-11-20 | 2022-01-24 | 富士通株式会社 | 情報処理装置および情報処理プログラム |
Family Cites Families (9)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US5117351A (en) * | 1988-10-21 | 1992-05-26 | Digital Equipment Corporation | Object identifier generator for distributed computer system |
| US5499367A (en) * | 1991-11-15 | 1996-03-12 | Oracle Corporation | System for database integrity with multiple logs assigned to client subsets |
| US5440727A (en) * | 1991-12-18 | 1995-08-08 | International Business Machines Corporation | Asynchronous replica management in shared nothing architectures |
| GB2273183A (en) * | 1992-12-04 | 1994-06-08 | Ibm | Replicated distributed databases. |
| US5553279A (en) * | 1993-10-08 | 1996-09-03 | International Business Machines Corporation | Lossless distribution of time series data in a relational data base network |
| JPH08339381A (ja) * | 1995-06-13 | 1996-12-24 | Hitachi Ltd | 並列データベースシステムの動作解析方法 |
| US5740348A (en) * | 1996-07-01 | 1998-04-14 | Sun Microsystems, Inc. | System and method for selecting the correct group of replicas in a replicated computer database system |
| US5878434A (en) * | 1996-07-18 | 1999-03-02 | Novell, Inc | Transaction clash management in a disconnectable computer and network |
| US5884325A (en) * | 1996-10-09 | 1999-03-16 | Oracle Corporation | System for synchronizing shared data between computers |
-
1996
- 1996-11-28 JP JP8318047A patent/JPH10161916A/ja active Pending
-
1997
- 1997-11-26 US US08/979,946 patent/US5946689A/en not_active Expired - Fee Related
Cited By (12)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| JP2001154917A (ja) * | 1999-10-01 | 2001-06-08 | Ncr Internatl Inc | データベース管理システムにおけるデータ管理システム |
| US6711592B2 (en) | 2000-06-27 | 2004-03-23 | Oki Electric Industry Co, Ltd. | Information processing system |
| US7930271B2 (en) | 2000-10-09 | 2011-04-19 | Maximum Availability Ltd. | Method and apparatus for data processing |
| US8818939B2 (en) | 2000-10-09 | 2014-08-26 | Maximum Availability Ltd. | Method and apparatus for data processing |
| CN1977265B (zh) | 2004-07-01 | 2011-06-22 | 苹果公司 | 基于状态的同步 |
| KR20110093860A (ko) * | 2008-11-06 | 2011-08-18 | 아마데우스 에스.에이.에스. | 데이터 베이스 내 대용량 업데이트를 실시간으로 집적하는 방법 |
| JP2014523024A (ja) * | 2011-06-23 | 2014-09-08 | アリババ・グループ・ホールディング・リミテッド | 増分データの抽出 |
| JP2013041520A (ja) * | 2011-08-19 | 2013-02-28 | Nippon Telegr & Teleph Corp <Ntt> | データ保持システム、データ保持装置及びデータ保持方法 |
| CN103164418A (zh) * | 2011-12-12 | 2013-06-19 | 阿里巴巴集团控股有限公司 | 一种序列号的处理方法及设备 |
| CN103164418B (zh) * | 2011-12-12 | 2016-05-04 | 阿里巴巴集团控股有限公司 | 一种序列号的处理方法及设备 |
| CN110990350A (zh) * | 2019-11-28 | 2020-04-10 | 泰康保险集团股份有限公司 | 日志的解析方法及装置 |
| CN110990350B (zh) * | 2019-11-28 | 2023-06-16 | 泰康保险集团股份有限公司 | 日志的解析方法及装置 |
Also Published As
| Publication number | Publication date |
|---|---|
| US5946689A (en) | 1999-08-31 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| JPH10161916A (ja) | データベースの複製に伴う更新競合の検出方法 | |
| CN109739935B (zh) | 数据读取方法、装置、电子设备以及存储介质 | |
| US9652519B2 (en) | Replicating data across multiple copies of a table in a database system | |
| JP4414381B2 (ja) | ファイル管理プログラム、ファイル管理装置、ファイル管理方法 | |
| US6662196B2 (en) | Collision avoidance in bidirectional database replication | |
| US6785696B2 (en) | System and method for replication of distributed databases that span multiple primary nodes | |
| US7107294B2 (en) | Method and apparatus for interrupting updates to a database to provide read-only access | |
| US6189011B1 (en) | Method of maintaining a network of partially replicated database system | |
| US6604117B2 (en) | Method of maintaining a network of partially replicated database system | |
| US6092083A (en) | Database management system which synchronizes an enterprise server and a workgroup user client using a docking agent | |
| JP2531776B2 (ja) | デ―タベ―スを回復する方法 | |
| US20030115268A1 (en) | Conflict resolution for collaborative work system | |
| van Renesse et al. | Voting with ghosts | |
| US11809385B1 (en) | Efficient data backup in a distributed storage system | |
| JPH0773087A (ja) | データ処理システムにおけるファイル状態の回復方法 | |
| JP2008176813A (ja) | データ処理の方法及び装置 | |
| CN109542682A (zh) | 一种数据备份方法、装置、设备和存储介质 | |
| JP2009522677A (ja) | ノードの番号付けによるファイル・システムのダンプ／復元のための方法、システム、およびデバイス | |
| EP1010096B1 (en) | Method of maintaining a network of partially replicated database system | |
| CN111240891A (zh) | 基于数据库多表间数据一致性的数据恢复方法及装置 | |
| US7519633B2 (en) | Asynchronous replication of data | |
| JP2000284998A (ja) | データ更新制御システム、データ更新制御方法、その方法を実行させるためのプログラムを記録したコンピュータ読み取り可能な記録媒体 | |
| JP2001282599A (ja) | データ管理方法および装置並びにデータ管理プログラムを格納した記録媒体 | |
| CN114077593B (zh) | 一种数据库的日志同步方法、装置、设备及介质 | |
| US20030220939A1 (en) | Information processing system, information processing method, and information processing program |