JPH113263A - 複製データベース整合装置及び複製データベース整合方法 - Google Patents
複製データベース整合装置及び複製データベース整合方法Info
- Publication number
- JPH113263A JPH113263A JP9154920A JP15492097A JPH113263A JP H113263 A JPH113263 A JP H113263A JP 9154920 A JP9154920 A JP 9154920A JP 15492097 A JP15492097 A JP 15492097A JP H113263 A JPH113263 A JP H113263A
- Authority
- JP
- Japan
- Prior art keywords
- information
- site
- database
- reflection
- replication
- 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
Landscapes
- Information Retrieval, Db Structures And Fs Structures Therefor (AREA)
Abstract
(57)【要約】
【課題】 複数のデータベースシステムでデータの更新
が行われても、複製データベースシステムのデータの整
合性を保証する複製データベース整合装置と複製データ
ベース整合方式を提供する。 【解決手段】 自サイトのデータベース更新時に、収集
される更新後情報に更新情報の整合性を調査するために
使用する情報を持つヘッダ情報を付加して自サイトの反
映情報を作成し、自サイトの反映情報を自サイトの専用
ファイルに格納すると同時に、自サイトの反映情報を他
サイトに転送し、他サイトの反映情報を他サイトから受
信したときに、該他サイトの反映情報を自サイトの専用
ファイルに格納し、自サイトの専用ファイル内の反映情
報の整合性を調査し、整合性を保つために必要な反映情
報を選択し、該整合性を保つために必要な反映情報によ
り自サイトのデータベースの更新を行う。
が行われても、複製データベースシステムのデータの整
合性を保証する複製データベース整合装置と複製データ
ベース整合方式を提供する。 【解決手段】 自サイトのデータベース更新時に、収集
される更新後情報に更新情報の整合性を調査するために
使用する情報を持つヘッダ情報を付加して自サイトの反
映情報を作成し、自サイトの反映情報を自サイトの専用
ファイルに格納すると同時に、自サイトの反映情報を他
サイトに転送し、他サイトの反映情報を他サイトから受
信したときに、該他サイトの反映情報を自サイトの専用
ファイルに格納し、自サイトの専用ファイル内の反映情
報の整合性を調査し、整合性を保つために必要な反映情
報を選択し、該整合性を保つために必要な反映情報によ
り自サイトのデータベースの更新を行う。
Description
【０００１】
【発明の属する技術分野】本発明は、複製データベース
システムにおける複製データベース整合装置、複製デー
タベース整合方法及びそれらに使われる記録媒体に関す
る。
システムにおける複製データベース整合装置、複製デー
タベース整合方法及びそれらに使われる記録媒体に関す
る。
【０００２】
【従来の技術】従来の複製データベースシステムは、あ
るサイトにあるマスター・データベースの複製を別のサ
イトに作り、マスター・データベースと複製との整合性
が維持されるように運用されるシステムである。
るサイトにあるマスター・データベースの複製を別のサ
イトに作り、マスター・データベースと複製との整合性
が維持されるように運用されるシステムである。
【０００３】従来の複製データベースシステムではマス
ター・データベースと複製との整合性を維持するため
に、例えば定期的にマスター・データベースの更新内容
がマスター・データベースのあるサイトから複製のある
サイトに通信回路を経由して送られ、その更新内容によ
って複製が更新されている。
ター・データベースと複製との整合性を維持するため
に、例えば定期的にマスター・データベースの更新内容
がマスター・データベースのあるサイトから複製のある
サイトに通信回路を経由して送られ、その更新内容によ
って複製が更新されている。
【０００４】例えば本支店のある会社においては、本社
がマスター・データベースのあるサイトとして選ばれ、
支店が複製のあるサイトとして選ばれる。この場合、支
店で例えば顧客のデータベースをアクセスする度に通信
回路を経由して本社のマスター・データベースにアクセ
スする必要が無くなり、アクセスタイムが短縮された
り、通信費用を少なく抑えられるなどのメリットが生じ
るので一般に普及している。
がマスター・データベースのあるサイトとして選ばれ、
支店が複製のあるサイトとして選ばれる。この場合、支
店で例えば顧客のデータベースをアクセスする度に通信
回路を経由して本社のマスター・データベースにアクセ
スする必要が無くなり、アクセスタイムが短縮された
り、通信費用を少なく抑えられるなどのメリットが生じ
るので一般に普及している。
【０００５】ところで、特開平８−７７０５３号公報に
記載の複製データベース反映装置及び複製データベース
反映方法では、複製元データベース（マスター・データ
ベース）でデータベース更新後に得られた更新後データ
に付加情報を加えて反映情報を作成し、複製先データベ
ース（複製）に反映情報を転送し、その反映情報から直
接複製先データベースへの反映処理を行うことにより、
低負荷で物理構造の異なるデータベース間の複製処理を
おこなうことを可能にしている。
記載の複製データベース反映装置及び複製データベース
反映方法では、複製元データベース（マスター・データ
ベース）でデータベース更新後に得られた更新後データ
に付加情報を加えて反映情報を作成し、複製先データベ
ース（複製）に反映情報を転送し、その反映情報から直
接複製先データベースへの反映処理を行うことにより、
低負荷で物理構造の異なるデータベース間の複製処理を
おこなうことを可能にしている。
【０００６】
【発明が解決しようとする課題】しかしながら、従来の
複製データベースシステムは、マスター・データベース
は１つであり、その内容を他サイトの複製に反映させれ
ばよいという思想で設計されていたので、複数のデータ
ベースをマスター・データベースとその複製に分類する
という従来の基本的な構成から進んで、複数のデータベ
ースを均等なものとして扱おうとした場合、即ち、どの
データベースにおいてもデータの更新をする場合には、
従来の複製を更新する方法（複製データベース反映方
法）を相互のデータベースに施していると、同時に複数
のデータベースの同一のテーブルの同一のレコードを異
なった値で更新した場合、それぞれの反映情報が複製先
データベース装置に転送され、互いに相手の反映情報に
よって変更されてしまう可能性があった。
複製データベースシステムは、マスター・データベース
は１つであり、その内容を他サイトの複製に反映させれ
ばよいという思想で設計されていたので、複数のデータ
ベースをマスター・データベースとその複製に分類する
という従来の基本的な構成から進んで、複数のデータベ
ースを均等なものとして扱おうとした場合、即ち、どの
データベースにおいてもデータの更新をする場合には、
従来の複製を更新する方法（複製データベース反映方
法）を相互のデータベースに施していると、同時に複数
のデータベースの同一のテーブルの同一のレコードを異
なった値で更新した場合、それぞれの反映情報が複製先
データベース装置に転送され、互いに相手の反映情報に
よって変更されてしまう可能性があった。
【０００７】例えば、図５を参照して説明すると、２つ
のデータベースシステム（データベースシステムＡ（符
号５０１）及びデータベースシステムＢ（符号５０
２））より構成される複製データベースシステムのある
テーブルのあるレコード（５０５ａ及び５０５ｂ）のあ
る項目に文字列“ＳＵＮ”が格納されていたとする。デ
ータベースシステムＡ（符号５０１）でこの項目値を
“ＭＯＮ”（符号５０７）に更新し、データベースシス
テムＢ（符号５０２）で同時にこの項目値を“ＴＵＥ”
（符号５０８）に更新した場合、各々のデータベースシ
ステムにある複製データベース反映装置（５０３及び５
０４）は、他方の複製データベース反映装置（５０４及
び５０３）にそれぞれ“ＭＯＮ”、“ＴＵＥ”を反映情
報として転送し、複製データベース反映装置（５０４及
び５０３）がその反映情報を元にしてデータ更新を行
う。そのため、それぞれのデータベースシステムで、こ
の項目の値が“ＴＵＥ”、“ＭＯＮ”に変更されてしま
い、複製データベースシステム間でデータの矛盾が発生
し整合性が保たれない。
のデータベースシステム（データベースシステムＡ（符
号５０１）及びデータベースシステムＢ（符号５０
２））より構成される複製データベースシステムのある
テーブルのあるレコード（５０５ａ及び５０５ｂ）のあ
る項目に文字列“ＳＵＮ”が格納されていたとする。デ
ータベースシステムＡ（符号５０１）でこの項目値を
“ＭＯＮ”（符号５０７）に更新し、データベースシス
テムＢ（符号５０２）で同時にこの項目値を“ＴＵＥ”
（符号５０８）に更新した場合、各々のデータベースシ
ステムにある複製データベース反映装置（５０３及び５
０４）は、他方の複製データベース反映装置（５０４及
び５０３）にそれぞれ“ＭＯＮ”、“ＴＵＥ”を反映情
報として転送し、複製データベース反映装置（５０４及
び５０３）がその反映情報を元にしてデータ更新を行
う。そのため、それぞれのデータベースシステムで、こ
の項目の値が“ＴＵＥ”、“ＭＯＮ”に変更されてしま
い、複製データベースシステム間でデータの矛盾が発生
し整合性が保たれない。
【０００８】そこで本発明は、複製データベースシステ
ムにおいて、複数のデータベースシステムでデータの更
新が行われても、複数のデータベースシステムのデータ
の整合性を保証する複製データベース整合装置及び複製
データベース整合方式を提供することを目的とする。
ムにおいて、複数のデータベースシステムでデータの更
新が行われても、複数のデータベースシステムのデータ
の整合性を保証する複製データベース整合装置及び複製
データベース整合方式を提供することを目的とする。
【０００９】
【課題を解決するための手段】本発明による複製データ
ベース整合装置は、各サイトでデータベース更新が行わ
れる複製データベースシステムで使用される複製データ
ベース整合装置において、データベース更新時に収集さ
れる更新後情報に更新情報の整合性を調査するために使
用する情報を持つヘッダ情報を付加した反映情報の集合
である複製更新履歴情報ファイルと、自サイトのデータ
ベース更新時に、前記更新後情報に前記ヘッダ情報を付
加して自サイトの前記反映情報を作成し、前記自サイト
の反映情報を前記自サイトの前記複製更新履歴情報ファ
イルに格納すると同時に、前記自サイトの反映情報を他
サイトに転送し、他サイトの前記反映情報を他サイトか
ら受信したときに、該他サイトの反映情報を前記自サイ
トの複製更新履歴情報ファイルに格納する反映情報複製
装置と、前記自サイトの前記複製更新履歴情報ファイル
内の前記反映情報の整合性を調査し、整合性を保つため
に必要な反映情報を選択し、該整合性を保つために必要
な反映情報により前記自サイトのデータベースの更新を
行う反映情報反映装置とを備えることを特徴とする。
ベース整合装置は、各サイトでデータベース更新が行わ
れる複製データベースシステムで使用される複製データ
ベース整合装置において、データベース更新時に収集さ
れる更新後情報に更新情報の整合性を調査するために使
用する情報を持つヘッダ情報を付加した反映情報の集合
である複製更新履歴情報ファイルと、自サイトのデータ
ベース更新時に、前記更新後情報に前記ヘッダ情報を付
加して自サイトの前記反映情報を作成し、前記自サイト
の反映情報を前記自サイトの前記複製更新履歴情報ファ
イルに格納すると同時に、前記自サイトの反映情報を他
サイトに転送し、他サイトの前記反映情報を他サイトか
ら受信したときに、該他サイトの反映情報を前記自サイ
トの複製更新履歴情報ファイルに格納する反映情報複製
装置と、前記自サイトの前記複製更新履歴情報ファイル
内の前記反映情報の整合性を調査し、整合性を保つため
に必要な反映情報を選択し、該整合性を保つために必要
な反映情報により前記自サイトのデータベースの更新を
行う反映情報反映装置とを備えることを特徴とする。
【００１０】また、本発明による複製データベース整合
装置は、前記ヘッダ情報が、更新時間、発生システム
名、レコード番号、項目、更新前データ、更新後データ
であることを特徴とする。
装置は、前記ヘッダ情報が、更新時間、発生システム
名、レコード番号、項目、更新前データ、更新後データ
であることを特徴とする。
【００１１】本発明による複製データベース整合方法
は、各サイトでデータベース更新が行われる複製データ
ベースシステムで使用される複製データベース整合方法
において、自サイトのデータベース更新時に、収集され
る更新後情報に更新情報の整合性を調査するために使用
する情報を持つヘッダ情報を付加して自サイトの反映情
報を作成し、前記自サイトの反映情報を前記自サイトの
複製更新履歴情報ファイルに格納すると同時に、前記自
サイトの反映情報を他サイトに転送する手順と、他サイ
トの前記反映情報を他サイトから受信したときに、該他
サイトの反映情報を前記自サイトの複製更新履歴情報フ
ァイルに格納する手順と、前記自サイトの前記複製更新
履歴情報ファイル内の前記反映情報の整合性を調査し、
整合性を保つために必要な反映情報を選択し、該整合性
を保つために必要な反映情報により前記自サイトのデー
タベースの更新を行う手順とを有することを特徴とす
る。
は、各サイトでデータベース更新が行われる複製データ
ベースシステムで使用される複製データベース整合方法
において、自サイトのデータベース更新時に、収集され
る更新後情報に更新情報の整合性を調査するために使用
する情報を持つヘッダ情報を付加して自サイトの反映情
報を作成し、前記自サイトの反映情報を前記自サイトの
複製更新履歴情報ファイルに格納すると同時に、前記自
サイトの反映情報を他サイトに転送する手順と、他サイ
トの前記反映情報を他サイトから受信したときに、該他
サイトの反映情報を前記自サイトの複製更新履歴情報フ
ァイルに格納する手順と、前記自サイトの前記複製更新
履歴情報ファイル内の前記反映情報の整合性を調査し、
整合性を保つために必要な反映情報を選択し、該整合性
を保つために必要な反映情報により前記自サイトのデー
タベースの更新を行う手順とを有することを特徴とす
る。
【００１２】また、本発明による複製データベース整合
方法は、前記ヘッダ情報が、更新時間、発生システム
名、レコード番号、項目、更新前データ、更新後データ
であることを特徴とする。
方法は、前記ヘッダ情報が、更新時間、発生システム
名、レコード番号、項目、更新前データ、更新後データ
であることを特徴とする。
【００１３】本発明による記録媒体は、上記の複製デー
タベース整合方法をコンピュータに実行させるためのプ
ログラムを記録したことを特徴とする。
タベース整合方法をコンピュータに実行させるためのプ
ログラムを記録したことを特徴とする。
【００１４】また、本発明による記録媒体は、データベ
ース更新時に収集される更新後情報に更新情報の整合性
を調査するために使用する情報を持つヘッダ情報を付加
した反映情報の集合である複製更新履歴情報ファイルを
記録したことを特徴とする。
ース更新時に収集される更新後情報に更新情報の整合性
を調査するために使用する情報を持つヘッダ情報を付加
した反映情報の集合である複製更新履歴情報ファイルを
記録したことを特徴とする。
【００１５】更に、本発明による記録媒体は、前記ヘッ
ダ情報が、更新時間、発生システム名、レコード番号、
項目、更新前データ、更新後データであることを特徴と
する。
ダ情報が、更新時間、発生システム名、レコード番号、
項目、更新前データ、更新後データであることを特徴と
する。
【００１６】
【発明の実施の形態】次に本発明の一実施形態を図を参
照して説明する。
照して説明する。
【００１７】図１は、本実施形態による複製データベー
ス整合装置を含む複製データベースシステムの全体構成
図である。データベースシステムＡ（符号１２０）は、
あるサイトにあるデータベースシステムであり、データ
ベースシステムＢ（符号１２１）は、別のサイトにある
データベースシステムである。本発明の複製データベー
ス整合装置は、反映情報複製装置（１０１及び１０２）
と反映情報反映装置１０３と複製更新履歴情報ファイル
（１０４及び１０５）から構成される。
ス整合装置を含む複製データベースシステムの全体構成
図である。データベースシステムＡ（符号１２０）は、
あるサイトにあるデータベースシステムであり、データ
ベースシステムＢ（符号１２１）は、別のサイトにある
データベースシステムである。本発明の複製データベー
ス整合装置は、反映情報複製装置（１０１及び１０２）
と反映情報反映装置１０３と複製更新履歴情報ファイル
（１０４及び１０５）から構成される。
【００１８】反映情報複製装置１０１は、データベース
（ＤＢ）１１１の更新後に得られ更新履歴情報ファイル
１１２に記録される更新後情報１１３に、更新時間、発
生システム名、レコード番号、項目、更新前データ、更
新後データで構成されるヘッダ情報を付加した反映情報
１０６を作成し、複製更新履歴情報ファイル１０４に格
納する機能を有する。
（ＤＢ）１１１の更新後に得られ更新履歴情報ファイル
１１２に記録される更新後情報１１３に、更新時間、発
生システム名、レコード番号、項目、更新前データ、更
新後データで構成されるヘッダ情報を付加した反映情報
１０６を作成し、複製更新履歴情報ファイル１０４に格
納する機能を有する。
【００１９】反映情報複製装置（１０１及び１０２）
は、複製更新履歴情報ファイル（１０４及び１０５）の
反映情報（１０６及び１０７）をデータベースシステム
間で複製する機能を有する。但し、図１では、反映情報
複製装置１０１から反映情報複製装置１０２に向かう方
向の複写のみ図示している。
は、複製更新履歴情報ファイル（１０４及び１０５）の
反映情報（１０６及び１０７）をデータベースシステム
間で複製する機能を有する。但し、図１では、反映情報
複製装置１０１から反映情報複製装置１０２に向かう方
向の複写のみ図示している。
【００２０】また、反映情報反映装置１０３は、複製更
新履歴情報ファイル１０５の反映情報１０７のデータを
調べて更新履歴に矛盾が無いかを調査する機能を有す
る。また、矛盾を解消するために必要であれば、他デー
タベースシステム１２０から転送された反映情報１０７
で、自データベースシステム１２１のデータベース１１
４の更新を実行する機能を有する。
新履歴情報ファイル１０５の反映情報１０７のデータを
調べて更新履歴に矛盾が無いかを調査する機能を有す
る。また、矛盾を解消するために必要であれば、他デー
タベースシステム１２０から転送された反映情報１０７
で、自データベースシステム１２１のデータベース１１
４の更新を実行する機能を有する。
【００２１】次に、本実施形態の動作について図２を参
照して詳細に説明する。
照して詳細に説明する。
【００２２】アプリケーション１２２がデータベース１
１１の更新を実行する（Ｓ２０１）とデータベースマネ
ジメントシステム（ＤＢＭＳ）１１０は、データベース
更新後にリカバリ用の更新後情報１１３を更新履歴情報
ファイル１１２に出力する（Ｓ２０２）。ここで、複製
データベース整合装置の反映情報複製装置１０１は、リ
カバリ用の更新履歴情報ファイル１１２の更新後情報１
１３から反映情報１０６を作成し、反映情報ファイル
（複製履歴情報ファイル）１０４に格納する（Ｓ２０
３）。次に、チェックポイントをみて反映情報を複写先
に転送する必要があるかどうかを判断する（Ｓ２０
４）。チェックポイントは反映情報が新たに作成された
ときにセットされ、反映情報の転送が完了した場合や、
転送する必要が無くなった場合にリセットされるもので
ある。反映情報複製装置１０１は、転送するべき反映情
報１０６を複製先の複製データベース整合装置の反映情
報複製装置１０２に転送する（Ｓ２０５）。
１１の更新を実行する（Ｓ２０１）とデータベースマネ
ジメントシステム（ＤＢＭＳ）１１０は、データベース
更新後にリカバリ用の更新後情報１１３を更新履歴情報
ファイル１１２に出力する（Ｓ２０２）。ここで、複製
データベース整合装置の反映情報複製装置１０１は、リ
カバリ用の更新履歴情報ファイル１１２の更新後情報１
１３から反映情報１０６を作成し、反映情報ファイル
（複製履歴情報ファイル）１０４に格納する（Ｓ２０
３）。次に、チェックポイントをみて反映情報を複写先
に転送する必要があるかどうかを判断する（Ｓ２０
４）。チェックポイントは反映情報が新たに作成された
ときにセットされ、反映情報の転送が完了した場合や、
転送する必要が無くなった場合にリセットされるもので
ある。反映情報複製装置１０１は、転送するべき反映情
報１０６を複製先の複製データベース整合装置の反映情
報複製装置１０２に転送する（Ｓ２０５）。
【００２３】複製先データベースシステム１２１の複製
データベース整合装置の反映情報複製装置１０２は、転
送された反映情報を受信し（Ｓ２０６）、複製更新履歴
情報ファイル１０５に格納する（マージする）（Ｓ２０
７）。反映情報反映装置１０３は、複製更新履歴情報フ
ァイル１０５中の反映情報１０７の整合性を調査する
（Ｓ２０８）。反映情報反映装置１０３は、整合性の調
査結果で矛盾が検出されなかった反映情報１０７を取得
して、矛盾が有ったためにリカバリする反映情報１０７
を作成する（Ｓ２０９）。反映情報反映装置１０３は、
データベース１１４に反映させるべき反映情報１０７か
らデータベースの更新を実施する（Ｓ２１０）。この場
合、反映情報反映装置１０３は、このデータベース更新
時に発生する更新後情報からの反映情報の作成は行わな
い。これは新たに整合性チェックの動作を引き起こすの
を防止するためである。
データベース整合装置の反映情報複製装置１０２は、転
送された反映情報を受信し（Ｓ２０６）、複製更新履歴
情報ファイル１０５に格納する（マージする）（Ｓ２０
７）。反映情報反映装置１０３は、複製更新履歴情報フ
ァイル１０５中の反映情報１０７の整合性を調査する
（Ｓ２０８）。反映情報反映装置１０３は、整合性の調
査結果で矛盾が検出されなかった反映情報１０７を取得
して、矛盾が有ったためにリカバリする反映情報１０７
を作成する（Ｓ２０９）。反映情報反映装置１０３は、
データベース１１４に反映させるべき反映情報１０７か
らデータベースの更新を実施する（Ｓ２１０）。この場
合、反映情報反映装置１０３は、このデータベース更新
時に発生する更新後情報からの反映情報の作成は行わな
い。これは新たに整合性チェックの動作を引き起こすの
を防止するためである。
【００２４】なお、説明のために、もととなるデータ更
新をデータベースシステム１２０で行い、これに応じ
て、データベースシステム１２１のデータを更新すると
して説明をしてきたが、実際には、もととなるデータ更
新とそれを反映したデータ更新は相互に行われ、実際の
各々のデータベースシステムの構成は、データベースシ
ステム１２０とデータベースシステム１２１の構成要素
を合わせたものになる。
新をデータベースシステム１２０で行い、これに応じ
て、データベースシステム１２１のデータを更新すると
して説明をしてきたが、実際には、もととなるデータ更
新とそれを反映したデータ更新は相互に行われ、実際の
各々のデータベースシステムの構成は、データベースシ
ステム１２０とデータベースシステム１２１の構成要素
を合わせたものになる。
【００２５】
【実施例】次に本発明の実施例について図面を参照して
説明する。
説明する。
【００２６】図３を参照するとデータベースシステムＡ
（符号３０１）には、“曜日”項目の値が“ＳＵＮ”で
あるレコード番号が００１のレコード３０３ａが存在
し、また、同じレコード３０３ｂがデータベースシステ
ムＢ（符号３０２）にも存在する。
（符号３０１）には、“曜日”項目の値が“ＳＵＮ”で
あるレコード番号が００１のレコード３０３ａが存在
し、また、同じレコード３０３ｂがデータベースシステ
ムＢ（符号３０２）にも存在する。
【００２７】ここで、データベースシステムＡ（符号３
０１）のレコード番号が００１のレコード３０３ａの
“曜日”項目が“ＭＯＮ”（３１２）に変更された場
合、データベースシステムＡ（符号３０１）の反映情報
複製装置３０６が、複製更新履歴情報ファイル３０５に
反映情報００１（符号３１０）を作成する。データベー
スシステムＡ（符号３０１）の反映情報複製装置３０６
は、複製更新履歴情報ファイル３１０の複製をデータベ
ースシステムＢ（符号３０２）で行うために、追加され
た反映情報００１（符号３１０）をデータベースシステ
ムＢ（符号３０２）の反映情報複製装置３０７に転送す
る。
０１）のレコード番号が００１のレコード３０３ａの
“曜日”項目が“ＭＯＮ”（３１２）に変更された場
合、データベースシステムＡ（符号３０１）の反映情報
複製装置３０６が、複製更新履歴情報ファイル３０５に
反映情報００１（符号３１０）を作成する。データベー
スシステムＡ（符号３０１）の反映情報複製装置３０６
は、複製更新履歴情報ファイル３１０の複製をデータベ
ースシステムＢ（符号３０２）で行うために、追加され
た反映情報００１（符号３１０）をデータベースシステ
ムＢ（符号３０２）の反映情報複製装置３０７に転送す
る。
【００２８】データベースシステムＢ（符号３０２）の
反映情報複製装置３０７は、反映情報００１（符号３１
０ｂ）を受信し、複製更新履歴情報ファイル３０８に格
納する。データベースシステムＢ（符号３０２）の反映
情報反映装置３１５は、追加された反映情報３１０ｃと
既存の反映情報に矛盾が発生していないかを調査する。
反映情報の調査は、更新時間順に各項目について変更前
データと変更後データの整合性を調査することで行う。
図では、反映情報０００（符号３０９）で“曜日”項目
が“ＳＡＴ”から“ＳＵＮ”に変更され、反映情報００
１（符号３１０）で“ＳＵＮ”から“ＭＯＮ”に変更さ
れているので変更に連続性があり矛盾は検出されない。
反映情報の整合性調査が正常で終了した場合、データベ
ースシステムＢ（符号３０２）の反映情報反映装置３１
５は、複製更新履歴情報ファイル３０８から反映情報０
０１（符号３１０ｃ）を取得し、データベースシステム
Ｂ（符号３０２）のレコード番号が００１のレコード３
０３ｂの“曜日”項目を“ＳＵＮ”から“ＭＯＮ”に変
更する。
反映情報複製装置３０７は、反映情報００１（符号３１
０ｂ）を受信し、複製更新履歴情報ファイル３０８に格
納する。データベースシステムＢ（符号３０２）の反映
情報反映装置３１５は、追加された反映情報３１０ｃと
既存の反映情報に矛盾が発生していないかを調査する。
反映情報の調査は、更新時間順に各項目について変更前
データと変更後データの整合性を調査することで行う。
図では、反映情報０００（符号３０９）で“曜日”項目
が“ＳＡＴ”から“ＳＵＮ”に変更され、反映情報００
１（符号３１０）で“ＳＵＮ”から“ＭＯＮ”に変更さ
れているので変更に連続性があり矛盾は検出されない。
反映情報の整合性調査が正常で終了した場合、データベ
ースシステムＢ（符号３０２）の反映情報反映装置３１
５は、複製更新履歴情報ファイル３０８から反映情報０
０１（符号３１０ｃ）を取得し、データベースシステム
Ｂ（符号３０２）のレコード番号が００１のレコード３
０３ｂの“曜日”項目を“ＳＵＮ”から“ＭＯＮ”に変
更する。
【００２９】図４は、反映情報のすれ違いが発生した場
合の処理装置の動作及び処理方法を説明する図である。
データベースシステムＡ（符号３０１）とデータベース
システムＢ（符号３０２）のレコード番号が００１のレ
コード（３０３ａ及び３０３ｂ）の曜日の項目には、初
期の値として“ＳＵＮ”が設定されている。ここで、デ
ータベースシステムＡ（符号３０１）のレコード番号が
００１のレコード（３０３ａ）の曜日が“ＭＯＮ”（３
１２）に更新される。同時にデータベースシステムＢ
（符号３０２）のレコード番号が００１のレコード（３
０３ｂ）の曜日が“ＴＵＥ”（３１３）に更新される。
データベースシステムＡ（符号３０１）の反映情報複製
装置３０６とデータベースシステムＢ（符号３０２）の
反映情報複製装置３０７は、それぞれ反映情報００１
（符号３１０ａ）と反映情報００２（符号３１１ａ）を
作成する。次にデータベースシステムＡ（符号３０１）
の反映情報複製装置３０６は、反映情報００１（符号３
１０ａ）をデータベースシステムＢ（符号３０２）の反
映情報複製装置３０７に、同様に、データベースシステ
ムＢ（符号３０２）の反映情報複製装置３０７は、反映
情報００２（符号３１１ａ）をデータベースシステムＡ
（符号３０１）の反映情報複製装置３０６に転送する。
両方の反映情報複製装置（３０６及び３０７）は、相手
側から受信した反映情報を複製更新履歴情報ファイル
（３０５及び３０８）に格納する。
合の処理装置の動作及び処理方法を説明する図である。
データベースシステムＡ（符号３０１）とデータベース
システムＢ（符号３０２）のレコード番号が００１のレ
コード（３０３ａ及び３０３ｂ）の曜日の項目には、初
期の値として“ＳＵＮ”が設定されている。ここで、デ
ータベースシステムＡ（符号３０１）のレコード番号が
００１のレコード（３０３ａ）の曜日が“ＭＯＮ”（３
１２）に更新される。同時にデータベースシステムＢ
（符号３０２）のレコード番号が００１のレコード（３
０３ｂ）の曜日が“ＴＵＥ”（３１３）に更新される。
データベースシステムＡ（符号３０１）の反映情報複製
装置３０６とデータベースシステムＢ（符号３０２）の
反映情報複製装置３０７は、それぞれ反映情報００１
（符号３１０ａ）と反映情報００２（符号３１１ａ）を
作成する。次にデータベースシステムＡ（符号３０１）
の反映情報複製装置３０６は、反映情報００１（符号３
１０ａ）をデータベースシステムＢ（符号３０２）の反
映情報複製装置３０７に、同様に、データベースシステ
ムＢ（符号３０２）の反映情報複製装置３０７は、反映
情報００２（符号３１１ａ）をデータベースシステムＡ
（符号３０１）の反映情報複製装置３０６に転送する。
両方の反映情報複製装置（３０６及び３０７）は、相手
側から受信した反映情報を複製更新履歴情報ファイル
（３０５及び３０８）に格納する。
【００３０】次に反映情報反映装置（３１４及び３１
５）が複製更新履歴情報ファイル（３０５及び３０８）
の整合性を調査する。この場合、反映情報００１（符号
３１０）で“曜日”項目の更新後データが“ＭＯＮ”に
更新されているにも関わらず、反映情報００２（符号３
１１）の更新前データは、”ＭＯＮ”ではなく“ＳＵ
Ｎ”になっているので、矛盾が発生している。
５）が複製更新履歴情報ファイル（３０５及び３０８）
の整合性を調査する。この場合、反映情報００１（符号
３１０）で“曜日”項目の更新後データが“ＭＯＮ”に
更新されているにも関わらず、反映情報００２（符号３
１１）の更新前データは、”ＭＯＮ”ではなく“ＳＵ
Ｎ”になっているので、矛盾が発生している。
【００３１】データベースシステムＡ（符号３０１）の
反映情報反映装置３１４は、反映情報００１（符号３１
０）と反映情報００２（符号３１１）が同時に発生した
ものであると判断し、レコード００１の“曜日”項目を
適切な値に修正する。適切な値を選択する方法として、
“最後に更新した値を有効にする”方法や“最初に更新
した値を有効にする”などを選択することができる。こ
こでは、“最後に更新した値を有効にする”方法を採用
している。そのため、データベースシステムＡ（符号３
０１）の反映情報反映装置３１４は、反映情報００２
（符号３１１）の反映処理を実施してレコード番号が０
０１のレコード（符号３０３ａ）の曜日を”ＴＵＥ”に
する。
反映情報反映装置３１４は、反映情報００１（符号３１
０）と反映情報００２（符号３１１）が同時に発生した
ものであると判断し、レコード００１の“曜日”項目を
適切な値に修正する。適切な値を選択する方法として、
“最後に更新した値を有効にする”方法や“最初に更新
した値を有効にする”などを選択することができる。こ
こでは、“最後に更新した値を有効にする”方法を採用
している。そのため、データベースシステムＡ（符号３
０１）の反映情報反映装置３１４は、反映情報００２
（符号３１１）の反映処理を実施してレコード番号が０
０１のレコード（符号３０３ａ）の曜日を”ＴＵＥ”に
する。
【００３２】データベースシステムＢ（符号３０２）の
反映情報反映装置３１５も同様な矛盾を検出するが、反
映情報００２（符号３１１）が有効で有るために反映処
理は行わない。
反映情報反映装置３１５も同様な矛盾を検出するが、反
映情報００２（符号３１１）が有効で有るために反映処
理は行わない。
【００３３】
【発明の効果】以上説明したように本発明によれば、各
データベースシステムで取得された複製更新履歴情報フ
ァイルをマージし、そのファイル内の反映情報の整合性
チェックを実施する事により、どのデータベースシステ
ムのデータも同一の状態に保てるから、複製データベー
スシステムにおけるデータの一意性が完全に保証され
る。
データベースシステムで取得された複製更新履歴情報フ
ァイルをマージし、そのファイル内の反映情報の整合性
チェックを実施する事により、どのデータベースシステ
ムのデータも同一の状態に保てるから、複製データベー
スシステムにおけるデータの一意性が完全に保証され
る。
【図１】本発明の複製データベースシステムの構成図で
ある。
ある。
【図２】本発明の動作シーケンスフローである。
【図３】本発明の実施例である。
【図４】本発明の実施例である。
【図５】従来の複製データベース反映装置を含む複製デ
ータベースシステムの構成図である。
ータベースシステムの構成図である。
１０１、１０２ 反映情報複製装置 １０３ 反映情報反映装置 １０４、１０５ 複製更新履歴情報ファイル １０６、１０７ 反映情報 １１０、１１３ データベースマネジメントシステム
（ＤＢＭＳ） １１１、１１４ データベース（ＤＢ） １１２ 更新履歴情報ファイル １１３ 更新後情報 １２０、１２１ データベースシステム
（ＤＢＭＳ） １１１、１１４ データベース（ＤＢ） １１２ 更新履歴情報ファイル １１３ 更新後情報 １２０、１２１ データベースシステム
Claims (7)
- 【請求項１】 各サイトでデータベース更新が行われる
複製データベースシステムで使用される複製データベー
ス整合装置において、 データベース更新時に収集される更新後情報に更新情報
の整合性を調査するために使用する情報を持つヘッダ情
報を付加した反映情報の集合である複製更新履歴情報フ
ァイルと、 自サイトのデータベース更新時に、前記更新後情報に前
記ヘッダ情報を付加して自サイトの前記反映情報を作成
し、前記自サイトの反映情報を前記自サイトの前記複製
更新履歴情報ファイルに格納すると同時に、前記自サイ
トの反映情報を他サイトに転送し、他サイトの前記反映
情報を他サイトから受信したときに、該他サイトの反映
情報を前記自サイトの複製更新履歴情報ファイルに格納
する反映情報複製装置と、 前記自サイトの前記複製更新履歴情報ファイル内の前記
反映情報の整合性を調査し、整合性を保つために必要な
反映情報を選択し、該整合性を保つために必要な反映情
報により前記自サイトのデータベースの更新を行う反映
情報反映装置とを備えることを特徴とする複製データベ
ース整合装置。 - 【請求項２】 前記ヘッダ情報は、更新時間、発生シス
テム名、レコード番号、項目、更新前データ、更新後デ
ータであることを特徴とする請求項１に記載の複製デー
タベース整合装置。 - 【請求項３】 各サイトでデータベース更新が行われる
複製データベースシステムで使用される複製データベー
ス整合方法において、 自サイトのデータベース更新時に、収集される更新後情
報に更新情報の整合性を調査するために使用する情報を
持つヘッダ情報を付加して自サイトの反映情報を作成
し、前記自サイトの反映情報を前記自サイトの複製更新
履歴情報ファイルに格納すると同時に、前記自サイトの
反映情報を他サイトに転送する手順と、 他サイトの前記反映情報を他サイトから受信したとき
に、該他サイトの反映情報を前記自サイトの複製更新履
歴情報ファイルに格納する手順と、 前記自サイトの前記複製更新履歴情報ファイル内の前記
反映情報の整合性を調査し、整合性を保つために必要な
反映情報を選択し、該整合性を保つために必要な反映情
報により前記自サイトのデータベースの更新を行う手順
とを有することを特徴とする複製データベース整合方
法。 - 【請求項４】 前記ヘッダ情報は、更新時間、発生シス
テム名、レコード番号、項目、更新前データ、更新後デ
ータであることを特徴とする請求項３に記載の複製デー
タベース整合方法。 - 【請求項５】 請求項３又は４に記載の複製データベー
ス整合方法をコンピュータに実行させるためのプログラ
ムを記録したことを特徴とする記録媒体。 - 【請求項６】 データベース更新時に収集される更新後
情報に更新情報の整合性を調査するために使用する情報
を持つヘッダ情報を付加した反映情報の集合である複製
更新履歴情報ファイルを記録したことを特徴とする記録
媒体。 - 【請求項７】 前記ヘッダ情報は、更新時間、発生シス
テム名、レコード番号、項目、更新前データ、更新後デ
ータであることを特徴とする記録媒体。
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| JP9154920A JPH113263A (ja) | 1997-06-12 | 1997-06-12 | 複製データベース整合装置及び複製データベース整合方法 |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| JP9154920A JPH113263A (ja) | 1997-06-12 | 1997-06-12 | 複製データベース整合装置及び複製データベース整合方法 |
Publications (1)
| Publication Number | Publication Date |
|---|---|
| JPH113263A true JPH113263A (ja) | 1999-01-06 |
Family
ID=15594850
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| JP9154920A Pending JPH113263A (ja) | 1997-06-12 | 1997-06-12 | 複製データベース整合装置及び複製データベース整合方法 |
Country Status (1)
| Country | Link |
|---|---|
| JP (1) | JPH113263A (ja) |
Cited By (2)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| JP2009080707A (ja) * | 2007-09-27 | 2009-04-16 | Jfe Steel Kk | データベース同期更新処理方法、データベース同期更新処理システム、データベース同期更新処理プログラム、現品充当方法 |
| JP2015153372A (ja) * | 2014-02-19 | 2015-08-24 | 日本電信電話株式会社 | データベースシステムおよびデータ更新方法 |
-
1997
- 1997-06-12 JP JP9154920A patent/JPH113263A/ja active Pending
Cited By (2)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| JP2009080707A (ja) * | 2007-09-27 | 2009-04-16 | Jfe Steel Kk | データベース同期更新処理方法、データベース同期更新処理システム、データベース同期更新処理プログラム、現品充当方法 |
| JP2015153372A (ja) * | 2014-02-19 | 2015-08-24 | 日本電信電話株式会社 | データベースシステムおよびデータ更新方法 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| Pu et al. | Regeneration of replicated objects: A technique and its Eden implementation | |
| Herlihy | Dynamic quorum adjustment for partitioned data | |
| US6529917B1 (en) | System and method of synchronizing replicated data | |
| US5675802A (en) | Version control system for geographically distributed software development | |
| EP1618504B1 (en) | System and method for a consistency check of a database backup | |
| CA2933790C (en) | Apparatus and method for creating a real time database replica | |
| US7383293B2 (en) | Database backup system using data and user-defined routines replicators for maintaining a copy of database on a secondary server | |
| US8046327B2 (en) | Partially replicated distributed database with multiple levels of remote clients | |
| US7149759B2 (en) | Method and system for detecting conflicts in replicated data in a database network | |
| EP0663641A1 (en) | Summary catalogs | |
| KR100280221B1 (ko) | 데이터 베이스에 있어서의 메모리 공간의 최적화 방법 | |
| US7487385B2 (en) | Apparatus and method for recovering destroyed data volumes | |
| US20100169289A1 (en) | Two Phase Commit With Grid Elements | |
| EP1035482A2 (en) | Remote file version reconciliation using hash codes | |
| US7631020B1 (en) | Method and system of generating a proxy for a database | |
| US12373419B1 (en) | Method for comparing rows of subsets of two database tables without regard to an original order of rows and columns in either database table | |
| CN116414848A (zh) | 数据库主备复制一致性验证方法、装置和计算机设备 | |
| Shapiro et al. | CPCMS: A Configuration Management System Based on Cryptographic Names. | |
| JPH1153239A (ja) | データベースのロールバック処理方法及び前記ロールバック処理方法の手順を記録した記録媒体 | |
| US8452823B2 (en) | Method for coordinating relationships between multiple physical entities | |
| JP2001229062A (ja) | 分散ファイル管理方法 | |
| Pâris | Using Volatile Witnesses to Extend the Applicability of Available Copy Protocols. | |
| Shaposhnikov | Algorithms for efficient transaction management and consistent queries in client-server semantic object-oriented parallel databases | |
| Hu | Exploiting laziness for improving performance in data replication management | |
| JPH04162154A (ja) | 設計データ管理システム |