JP4295326B2

JP4295326B2 - 計算機システム

Info

Publication number: JP4295326B2
Application number: JP2007002416A
Authority: JP
Inventors: 聡渡辺; 芳生鈴木; 真二藤原; 信男河村
Original assignee: Hitachi Ltd
Current assignee: Hitachi Ltd
Priority date: 2007-01-10
Filing date: 2007-01-10
Publication date: 2009-07-15
Anticipated expiration: 2027-01-10
Also published as: JP2008171117A; US20080208923A1; US7890467B2

Description

本発明は、バックアップデータの検定技術に関し、特に、バックアップシステムのデータ一致の検定方法、プログラム、および、記憶媒体などに適用して有効な技術に関する。

二つの計算機システムを用いた、データのバックアップシステムが広く用いられている。データのバックアップとは、一方の計算機システムのデータと同じデータを作成し、他方の計算機システムに保存することである。バックアップ元の計算機システムをプライマリシステム、バックアップ先の計算機システムをセカンダリシステムとよぶ。また、セカンダリシステムに保存するデータをバックアップデータと呼ぶ。二重化システムによるデータのバックアップについては、例えば、非特許文献１に記載されている。

二重化システムによるバックアップの方式として、ログ転送方式がある。ログ転送方式とは、プライマリシステムのデータ更新ログをセカンダリシステムに転送し、セカンダリシステムでバックアップデータを作成する方式である。ログ転送方式では、バックアップ開始の段階で、プライマリシステムのデータとセカンダリシステムのバックアップデータを同一にする。バックアップの開始後は、プライマリシステムのデータ更新ログをセカンダリシステムに転送する。セカンダリシステムでは、転送されたデータ更新ログをもとにバックアップデータを更新し、最新のバックアップデータを作成する。データ更新ログをバックアップデータに反映する処理は、ログ適用と呼ばれる。ログ転送方式については、前記非特許文献１に記載されている。

ログ転送方式では、正常にバックアップデータが作成されていることを確認するため、両システムのデータの一致を検定する必要がある。二つのデータの一致を検定する方法として、データを数値とみなして合計した値を照合するチェックサム方式がある。両システムのデータの一致を検定する場合、プライマリシステムのデータのチェックサムと、セカンダリサイトのバックアップデータのチェックサムを照合して、データが一致しているか否かを検定する。

計算機システムのデータを管理するソフトウェアとして、ＤａｔａｂａｓｅＭａｎａｇｅｍｅｎｔＳｙｓｔｅｍ（以下、ＤＢＭＳとする）が広く用いられている。一般に、ＤＢＭＳは、データ本体とデータ更新ログを用いてデータを管理しており、ＤＢＭＳが管理するデータのバックアップには、上記のログ転送方式が広く用いられている。

一般に、ＤＢＭＳはデータ本体を一定サイズ（８ＫＢなど）のデータ領域に区切って管理している。このデータ領域はページと呼ばれ、番号付けをして管理されている。データ更新ログには、ページ番号とデータ変更の内容が記載される。例えば、ページ番号１００番のページに、Ｉｔｅｍ＿ＩＤが１、Ｑｕａｎｔｉｔｙが１０のデータを追加した場合、「ページ１００番にＩｔｅｍ＿ＩＤが１、Ｑｕａｎｔｉｔｙが１０のデータを追加」といった内容のデータ更新ログが記録される。このようなデータ更新ログを受信したセカンダリシステムでは、バックアップデータのページ１００番に、Ｉｔｅｍ＿ＩＤが１、Ｑｕａｎｔｉｔｙが１０のデータを追加する。
ＣＨＲＩＳＴＯＳＡ．ＰＯＬＹＺＯＩＳ，ＨＥＣＴＯＲＧＡＲＣＩＡ−ＭＯＬＩＮＡ，"ＥｖａｌｕａｔｉｏｎｏｆＲｅｍｏｔｅＢａｃｋｕｐＡｌｇｏｒｉｔｈｍｓｆｏｒＴｒａｎｓａｃｔｉｏｎ−ＰｒｏｃｅｓｓｉｎｇＳｙｓｔｅｍｓ"，ＡＣＭＴｒａｎｓａｃｔｉｏｎｓｏｎＤａｔａｂａｓｅＳｙｓｔｅｍｓ，Ｖｏｌ．１９，Ｎｏ．３，Ｓｅｐｔｅｍｂｅｒ１９９４，Ｐａｇｅｓ４２３−４４９

本発明が解決しようとする一つ目の課題は、チェックサムを算出するタイミングを両システムで同期することである。プライマリシステム側のデータが更新されているのに、そのデータ更新ログがバックアップデータに適用されていなければ、チェックサムは一致しない。そのため、例えば、プライマリシステム側でデータ更新を一旦停止してチェックサムを算出し、セカンダリシステム側では全てのデータ更新ログを適用した時点でチェックサムを算出して、両チェックサムを照合する必要がある。しかし、このような方法では、プライマリシステムのデータ更新を停止するデメリットが生じてしまう。

本発明が解決しようとする二つ目の課題は、両システムのデータの内容が同じ場合にも、不一致と判定されてしまう可能性があることである。例えば、「ページ１００番にＩｔｅｍ＿ＩＤが１、Ｑｕａｎｔｉｔｙが１０のデータを追加」と記載されたデータ更新ログをバックアップデータに適用する場合、１００番のページのどこにデータを格納するかはセカンダリシステム側で決定する。プライマリシステム側でデータを格納した位置と、セカンダリシステム側でデータを格納した位置が異なれば、両システムのチェックサムの値が異なり、不一致と判定されてしまう。例えば、プライマリシステム側ではページの先頭にデータを格納し、セカンダリシステム側ではページの終端にデータを格納した場合、プライマリシステム側だけ、ページ先頭のデータが上書きされ、両システムのチェックサムは一致しなくなる。すなわち、ＤＢＭＳが管理しているデータとしては同一の内容であるが、データの格納位置が異なるため、チェックサムが一致しない可能性がある。

そこで、本発明は、一つ目の課題、二つ目の課題を解決し、チェックサム算出のタイミングを同期すること、および、データの格納位置によらず、データの一致の検定を可能にするバックアップデータの検定技術を提供することを目的とするものである。

本発明の前記ならびにその他の目的と新規な特徴は、本明細書の記述および添付図面から明らかになるであろう。

本願において開示される発明のうち、代表的なものの概要を簡単に説明すれば、次のとおりである。

本発明は、プライマリシステムからセカンダリシステムにデータ更新ログを送信してデータをバックアップするシステムにおいて、プライマリシステムのデータとセカンダリシステムのデータの一致を検定するために、以下のような特徴を有するものである。

（１）プライマリシステムで動作するソフトウェア（プログラムによる機能）は、データ格納領域からデータを抽出するデータ領域抽出手段と、プライマリシステムのデータ格納領域のチェックサムを算出するチェックサム算出手段と、チェックサムを含むデータチェックログを生成するデータチェックログ生成手段と、データチェックログとデータ更新ログをセカンダリシステムに送信するログ送信手段を含むものである。

（２）セカンダリシステムで動作するソフトウェア（プログラムによる機能）は、プライマリシステムからログを受信するログ受信手段と、受信したデータ更新ログをもとにバックアップデータを作成するログ適用手段と、データ格納領域からデータを抽出するデータ領域抽出手段と、セカンダリシステムのデータ格納領域のチェックサムを算出するチェックサム算出手段と、算出したチェックサムとデータチェックログに含まれるチェックサムを照合するチェックサム照合手段を含むものである。

（３）データ更新ログとデータチェックログに順序が定められており、その順序は、データ更新ログの該当データが更新された順序、および、データチェックログの該当チェックサムが算出された順序に従って定められている。

本願において開示される発明のうち、代表的なものによって得られる効果を簡単に説明すれば以下のとおりである。

本発明によれば、データチェックログ生成手段を設け、データ更新ログとデータチェックログに順序をつけてセカンダリサイトに送信することで、チェックサム算出のタイミングを同期することができる。また、データ領域抽出手段を設けることで、データの格納位置によらず、データの一致の検定を可能にすることができる。この結果、バックアップデータのチェック作業を簡便に行なうことが可能になる。

以下、本発明の実施の形態を図面に基づいて詳細に説明する。なお、実施の形態を説明するための全図において、同一の部材には原則として同一の符号を付し、その繰り返しの説明は省略する。

図１は、本発明の一実施の形態の二重化システムによるデータのバックアップシステムのシステム構成例を示す図である。

本実施の形態の二重化システムによるデータのバックアップシステムは、二つの計算機システムを含む。バックアップ元の計算機システムをプライマリサイトのプライマリシステム１０１、バックアップ先の計算機システムをセカンダリサイトのセカンダリシステム１０２と呼ぶ。プライマリシステム１０１は、サーバ１０３と外部記憶装置１０４を含む。セカンダリシステム１０２は、サーバ１０５と外部記憶装置１０６を含む。プライマリシステム１０１とセカンダリシステム１０２は、ネットワーク１０７によって接続されている。また、ネットワーク１０７には、操作端末１０８が接続されている。操作端末１０８を操作することにより、サーバ１０３へのコマンドの投入や、サーバ１０５からの応答の受信ができる。

図２は、本実施の形態の二重化システムによるデータのバックアップシステムのシステム構成例を詳細に示す図である。

プライマリシステムのサーバ１０３は、中央演算装置（ＣＰＵ）２０１とメモリ領域２０２を含み、ＤＢＭＳ２０３を動作させている。ＤＢＭＳ２０３は、データ管理を行なうソフトウェアであり、メモリ領域２０２にそのプログラムが格納され、ＣＰＵ２０１によって実行される。ＤＢＭＳ２０３は、操作端末１０８からコマンドを受付けるコマンド受付手段２０４、データ操作を実行するＳＱＬ実行手段２０５、ログを出力するログ出力手段２０６、データを入出力するデータ入出力手段２０７、データ格納領域からデータを抽出するデータ領域抽出手段２０８、データ格納領域のチェックサムを算出するチェックサム算出手段２０９、チェックサムを含むデータチェックログを生成するデータチェックログ生成手段２１０、データチェックログとデータ更新ログをセカンダリシステム１０２に送信するログ送信手段２１１の各種手段を含む。プライマリサイトの外部記憶装置１０４は、ストレージ制御部２１２とログ格納領域２１３とデータ格納領域２１４を含む。ログ格納領域２１３とデータ格納領域２１４は、ストレージ制御部２１２からの指示に従って、データを格納する装置である。

セカンダリシステムのサーバ１０５は、中央演算装置（ＣＰＵ）２２１とメモリ領域２２２を含み、ログ適用ソフトウェア２２３を動作させている。ログ適用ソフトウェア２２３は、バックアップデータの作成を行なうソフトウェアであり、メモリ領域２２２にそのプログラムが格納され、ＣＰＵ２２１によって実行される。ログ適用ソフトウェア２２３は、プライマリシステム１０１からログを受信するログ受信手段２２４、受信したデータ更新ログをもとにバックアップデータを作成するログ適用手段２２５、ログを入出力するログ入出力手段２２６、データを入出力するデータ入出力手段２２７、データ格納領域からデータを抽出するデータ領域抽出手段２２８、データ格納領域のチェックサムを算出するチェックサム算出手段２２９、算出したチェックサムとデータチェックログに含まれるチェックサムを照合するチェックサム照合手段２３０、データ操作を実行するＳＱＬ実行手段２３２の各種手段を含む。セカンダリサイトの外部記憶装置１０６は、ストレージ制御部２３３とログ格納領域２３４とデータ格納領域２３５を含む。ログ格納領域２３４とデータ格納領域２３５は、ストレージ制御部２３２からの指示に従って、データを格納する装置である。

ストレージ制御部２１２は、ログ格納領域２１３およびデータ格納領域２１４を、一定の領域（５１２バイトなど）に区切って管理している。区切られた領域はロジカルブロックと呼ばれ、ロジカルブロックアドレス（ＬＢＡ）と呼ばれる番号が付けられている。図３（外部記憶装置にデータを格納する方法の例）は、ログ格納領域２１３やデータ格納領域２１４にデータを格納する例を示す図である。図３の例では、ＬＢＡ３０１、データ３０２において、ＬＢＡ０番にデータ“ＡＡＡ”が格納され、ＬＢＡ１番にデータ“ＢＢＢ”が格納されている。ストレージ制御部２１２がサーバ１０３から、「ＬＢＡ０番のデータをＲｅａｄ」というコマンドを受付けた場合、データ“ＡＡＡ”をサーバに送信する。また、ストレージ制御部２１２がサーバ１０３から、「ＬＢＡ１番にデータ“ＡＢＣＤ”をＷｒｉｔｅ」というコマンドを受付けた場合、データ“ＡＢＣＤ”をＬＢＡ１番に格納する。このように、サーバ１０３は、ＬＢＡを指定してストレージ制御部２１２に指示を出すことにより、外部記憶装置１０４のデータを操作する。

ＤＢＭＳ２０３は、データ格納領域２１４を一定サイズ（８ＫＢなど）に区切って管理している。このデータ領域はページと呼ばれ、番号付けをして管理されている。ページとＬＢＡの対応関係を管理するため、ＤＢＭＳ２０３は、図４（テーブルと格納領域の対応関係の管理方法の例）に例示するデータ領域管理テーブルをメモリ領域２０２に格納している。データ領域管理テーブルには、テーブル名４０１と開始ＬＢＡ４０２と終了ＬＢＡ４０３が記載されている。図４の例では、ＳｔｏｃｋテーブルがＬＢＡ０番からＬＢＡ７９９９番に格納され、ＣｕｓｔｏｍｅｒテーブルがＬＢＡ１００００番から１７９９９番に格納されていることを示している。従って、ページサイズが８ＫＢでロジカルブロックのサイズが５１２バイトであるとすると、Ｓｔｏｃｋテーブルのページ０番をＲｅａｄする場合には、データ格納領域２１４のＬＢＡ０番からＬＢＡ１５番のデータをＲｅａｄする。また、Ｓｔｏｃｋテーブルのページ１番のページにデータを書き込む場合には、データ格納領域２１４のＬＢＡ１６番からＬＢＡ３１番にデータをＷｒｉｔｅする。

図５（ページの格納方法の例）は、ページにデータを格納する方法を示す概念図である。ページ５０１は８ＫＢのデータ領域であり、ページ５０１の終端に、データポインタ５０２が格納されている。データポインタ５０２は、ページの先頭から何バイト目にデータが格納されているかを示しており、図５の例では、ページの先頭から１０バイト目と、ページの先頭から５０バイト目に、データが格納されていることを示している。

また、ＤＢＭＳ２０３は、図６（テーブルのカラムの管理方法の例）に例示するデータ形式管理テーブルをメモリ領域２０２に格納している。データ形式管理テーブルには、テーブル名６０１とデータ形式６０２が記載されている。図６に示す例では、Ｓｔｏｃｋテーブルには、Ｉｔｅｍ＿ＩＤとＱｕａｎｔｉｔｙが整数型（ＩＮＴ）で格納されており、Ｃｕｓｔｏｍｅｒテーブルには、Ｃｕｓｔｏｍｅｒ＿ＩＤが整数型で、Ｎａｍｅが３０個の文字列（ＣＨＡＲ［３０］）で格納されていることを示している。図５に例示したページの例では、１番目のデータとして「１，５０」が格納されている。このページがＳｔｏｃｋテーブルのページである場合、図６のデータ形式管理テーブルをもとに、Ｓｔｏｃｋテーブルのデータとして、Ｉｔｅｍ＿ＩＤが１でＱｕａｎｔｉｔｙが５０のデータが格納されていることが分かる。なお、Ｉｔｅｍ＿ＩＤ、Ｑｕａｎｔｉｔｙ、Ｃｕｓｔｏｍｅｒ＿ＩＤ、Ｎａｍｅなどはカラム名と呼ばれる場合がある。

ＤＢＭＳ２０３は、ログ格納領域２１３を一定サイズ（１０２４バイトなど）に区切って管理している。従って、ロジカルブロックのサイズが５１２バイトとすると、１番目のログはログ格納領域２１３のＬＢＡ０番からＬＢＡ１番に格納され、２番目のログはログ格納領域２１３のＬＢＡ２番からＬＢＡ３番に格納される。

以上、ＤＢＭＳ２０３が、データ格納領域２１４にページを格納する方法と、ログ格納領域２１３にログを格納する方法について説明した。データ入出力手段２０７は上記の方法を用いて、ページの入出力を行なう。また、ログ出力手段２０６は上記の方法を用いてログの出力を行なう。

ログ適用ソフトウェア２２３が、データ格納領域２３５にページを格納する方法と、ログ格納領域２３４にログを格納する方法もこれと同様である。すなわち、プライマリサイトと同様に、データ領域管理テーブルとデータ形式管理テーブルをメモリ領域２２２に格納する。データ入出力手段２２７とログ入出力手段２２６は、これらのテーブルの情報を用いて、外部記憶装置１０６に格納されているデータの操作をする。

以下、ＤＢＭＳ２０３と、ログ適用ソフトウェア２２３の動作を説明する。

図７は、コマンド受付手段２０４の動作を示すフローチャートである。コマンド受付手段２０４は、操作端末１０８からコマンドを受付けると動作を開始する。判断７０１では、受付けたコマンドが、ＳＱＬ文であるか、データチェックコマンドであるかを判断する。受付けたコマンドがＳＱＬ文である場合には、処理７０２に進み、ＳＱＬ実行手段２０５にＳＱＬ文を通知する。また、受付けたコマンドがデータチェックコマンドである場合には、処理７０３に進み、チェックサム算出手段２０９に通知する。なお、チェック対象のデータ領域を指定したデータチェックコマンドと、ＳＱＬ文を指定したデータチェックコマンドを受付けることもできる。

図８は、ＳＱＬ実行手段２０５の動作を示すフローチャートである。代表的なＳＱＬ文の種別としては、ＳＥＬＥＣＴ文、ＩＮＳＥＲＴ文、ＵＰＤＡＴＥ文がある。ＳＱＬ文としては、他にも、ＤＥＬＥＴＥ文やＦＥＴＣＨ文などがあるが、以下では、ＳＥＬＥＣＴ文、ＩＮＳＥＲＴ文、ＵＰＤＡＴＥ文を用いて、ＳＱＬ実行手段２０５の動作を説明する。

判断８０１では、ＳＱＬ文の種別を判定し、処理内容を分岐する。ＳＥＬＥＣＴ文は、指定されたデータを読み込むＳＱＬ文であり、例えば、「ＳＥＬＥＣＴＱｕａｎｔｉｔｙｆｒｏｍＳｔｏｃｋｗｈｅｒｅ１０＜＝Ｉｔｅｍ＿ＩＤａｎｄＩｔｅｍ＿ＩＤ＜＝１９」といったものである。これは、Ｓｔｏｃｋテーブルから、Ｉｔｅｍ＿ＩＤが１０以上１９以下のＱｕａｎｔｉｔｙのデータを読み込む指示である。このようなＳＱＬ文を受付けた場合、処理８０２では、データ入出力手段２０７を用いて、データ格納領域２１４からＳｔｏｃｋテーブルのページを読み込み、Ｉｔｅｍ＿ＩＤが１０以上１９以下のＱｕａｎｔｉｔｙのデータを抽出する。抽出されるデータは、図９（ＳＱＬ実行手段のＳＱＬ実行例）に例示されるように、Ｉｔｅｍ＿ＩＤとＱｕａｎｔｉｔｙの組となる。図９の例では、Ｉｔｅｍ＿ＩＤが１０のＱｕａｎｔｉｔｙは１であり、Ｉｔｅｍ＿ＩＤが１１のＱｕａｎｔｉｔｙは２であることを示している。処理８０３では、抽出したデータを操作端末１０８に送信する。なお、後に説明するように、ＳＱＬ実行手段２０５は、チェックサム算出手段２０９から指示を受けた場合は、抽出したデータをチェックサム算出手段２０９に送信する。

ＩＮＳＥＲＴ文は、指定されたデータを追加するＳＱＬ文であり、例えば、「ＩＮＳＥＲＴＩＮＴＯＳｔｏｃｋ（Ｉｔｅｍ＿ＩＤ、Ｑｕａｎｔｉｔｙ）ＶＡＬＵＥＳ（１００，５０）」といった形式で記述される。これは、Ｓｔｏｃｋテーブルに、Ｉｔｅｍ＿ＩＤが１００でＱｕａｎｔｉｔｙが５０のデータを追加する指示である。このようなＳＱＬ文を受付けた場合、処理８０４で、データ入出力手段２０７を用いてデータ格納領域２１４からＳｔｏｃｋテーブルのページを読み込み、データを格納する空きがあるページを検索する。例えば、ページ５００番に空きがあった場合、処理８０５において、ページ５００番にＩｔｅｍ＿ＩＤが１００でＱｕａｎｔｉｔｙが５０のデータを追加する。この際、図５に例示したように、ページ内にデータを追加するとともに、ページの終端にデータポインタを追加する。処理８０６では、データ更新のログを出力するため、ログ出力手段２０７に通知する。

ＵＰＤＡＴＥ文は、指定されたデータの内容を書き換えるＳＱＬ文であり、例えば、「ＵＰＤＡＴＥＳＴＯＣＫＳＥＴＱｕａｎｔｉｔｙ＝１０１ＷｈｅｒｅＩｔｅｍ＿ＩＤ＝１」という形式で記述される。これは、ＳｔｏｃｋテーブルのＩｔｅｍ＿ＩＤが１のデータのＱｕａｎｔｉｔｙを１０１に書き換える指示である。このようなＳＱＬ文を受付けた場合、処理８０８では、データ入出力手段２０７を用いて、Ｉｔｅｍ＿ＩＤが１のデータを格納しているページを読み込む。Ｉｔｅｍ＿ＩＤが１のデータがページ番号３のページに格納されていた場合、処理８０９において、ページ番号３のＩｔｅｍ＿ＩＤが１のＱｕａｎｔｉｔｙを１０１に変更する。処理８０６では、ＩＮＳＥＲＴ文の場合と同様に、このデータ更新のログを出力するため、ログ出力手段２０６に通知する。そして、処理８０７において、操作端末１０８に通知する。

図１０は、ログ出力手段２０６の動作を示すフローチャートである。通知を受けたログ出力手段２０６は、処理１００１において、ログの通し番号を付与する。通し番号を付与されたデータ更新ログとは、「ログ番号１番、ページ５００番にＩｔｅｍ＿ＩＤが１００でＱｕａｎｔｉｔｙが５０のデータを追加」、あるいは、「ログ番号２番、ページ３番のＩｔｅｍ＿ＩＤが１のＱｕａｎｔｉｔｙのデータを１０１に変更」といった内容である。ログの通し番号は、データが更新された順序、または、データチェックログのチェックサムが算出された順序に従って付与される。そのため、この番号によってチェックサムを算出した時点で、どのデータ更新まで完了していたかを判定できる。ログ出力手段２０６は、処理１００２において、ログ送信手段２１１に通知する。ログ送信手段２１１は、ログをログ受信手段２２４に対して送信する。また、ログ出力手段２０６は、処理１００３において、ログ格納領域２１３にログを出力する。

図１１は、チェックサム算出手段２０９の動作を示すフローチャートである。チェックサム算出手段２０９は、コマンド受付手段２０４から通知を受けると動作を開始する。判断１１０１では、データチェックコマンドの種別を判断する。

ＳＱＬ文指定のデータチェックコマンドには、データチェックに用いるＳＱＬ文が記載されている。例えば、「ＳＱＬ文”ＳＥＬＥＣＴＱｕａｎｔｉｔｙｆｒｏｍＳｔｏｃｋｗｈｅｒｅ１０＜＝Ｉｔｅｍ＿ＩＤａｎｄＩｔｅｍ＿ＩＤ＜＝１９”によってデータをチェック」といったコマンドを受付ける。このようなコマンドを受付けた場合、処理１１０５によってこのＳＱＬ文をＳＱＬ実行手段２０５に通知する。ＳＱＬ実行手段２０５は、このＳＱＬ文の実行結果をチェックサム算出手段２０９に通知する。ＳＱＬ実行手段２０５から通知される結果とは、例えば、図９に例示するＳＱＬ文の実行結果である。処理１１０６では、この結果のチェックサムを算出する。図９の実行結果の場合、ＳＱＬ文の実行結果として通知されたＱｕａｎｔｉｔｙの値、１から１０を合計して５５というチェックサムを算出する。算出したチェックサム、および、ＳＱＬ文は処理１１０４においてデータチェックログ生成手段２１０に通知される。

データ領域指定のチェックコマンドには、チェック対象のテーブル名が記載されている。例えば、「Ｓｔｏｃｋテーブルのデータをチェック」といったコマンドを受付ける。このようなコマンドを受付けた場合、処理１１０２は、データ領域抽出手段２０８に通知する。後に説明するように、データ領域抽出手段２０８は、図１２（データ領域抽出手段のデータ抽出方法の例）に例示するように、Ｓｔｏｃｋテーブルに格納された各ページのデータを通知する。図１２の例では、ページ番号０にＩｔｅｍ＿ＩＤが１でＱｕａｎｔｉｔｙが１００のデータと、Ｉｔｅｍ＿ＩＤが１００でＱｕａｎｔｉｔｙが１のデータが格納され、ページ番号１にＩｔｅｍ＿ＩＤが２でＱｕａｎｔｉｔｙが２１のデータが格納されていることを示している。処理１１０３では、これをもとに各ページのチェックサムを算出する。データ領域抽出手段２０８から図１２に例示するデータが通知された場合、処理１１０３は各ページのデータを合計し、図１３（チェックサム算出手段のチェックサム算出例）に示すように、ページ０のチェックサムとして２０２を算出し、ページ１のチェックサムとして２３を算出する。処理１１０４において、算出したチェックサムをデータチェックログ生成手段２１０に通知する。以上では、データ領域指定のチェックコマンドに、チェック対象のテーブル名を記載する例を用いて説明したが、全てのテーブルをチェックするコマンドを受付ける実施の形態も考えられる。この場合、図４に例示したデータ領域管理テーブルに登録されている全てのテーブルに対してチェックサムの算出をする。

なお、以上では、データが数値の場合の例を用いて説明したが、数値以外のデータであっても、チェックサムの算出は可能である。例えば、データ“Ａ”は、計算機システムの内部では、１６進数の４１として管理され、アスキーコードによって“Ａ”に変換されている。このように、計算システムでは、データを数値として管理しており、数値以外のデータであっても、チェックサムを算出することができる。

図１４は、データ領域抽出手段２０８の動作を示すフローチャートである。データ領域抽出手段２０８は、チェックサム算出手段２０９から通知を受けると動作を開始する。処理１４０１では、データ入出力手段２０７を用いて、チェックサム算出手段２０９から通知されたテーブルのページを読み込む。処理１４０２では、図５に例示したデータポインタをもとに、読み込んだページから実際にデータが格納された領域を抽出する。判断１４０３において、指定された領域の全てのページに対してデータの抽出が完了したか否かを判定する。これは、図４に例示したデータ領域管理テーブルの終了ＬＢＡ４０３を参照することで判定できる。全てのページに対してデータの抽出が完了した場合、処理１４０４において、抽出結果をチェックサム算出手段２０９に通知する。この抽出結果は、図１２に例示したように、ページ番号とデータの組である。

図１５は、データチェックログ生成手段２１０の動作を示すフローチャートである。データチェックログ生成手段２１０は、チェックサム算出手段２０９から通知を受けることで動作を開始する。判断１５０１において、データチェックコマンドの種別を判定する。この判断は、チェックサム算出手段２０９から、ＳＱＬ文とチェックサムの組を通知されるか、ページ番号とチェックサムの組を通知されるかによって判断する。

ＳＱＬ文指定のデータチェックコマンドの場合、処理１５０３においてデータチェックログが生成される。この場合、データチェックログは、データチェック用のＳＱＬ文と、ＳＱＬ文の実行結果のチェックサムを含む。例えば、図１６（データチェックログの記載内容の例）に例示するように、データチェック用のＳＱＬ文として”ＳＥＬＥＣＴＱｕａｎｔｉｔｙｆｒｏｍＳｔｏｃｋｗｈｅｒｅ１０＜＝Ｉｔｅｍ＿ＩＤａｎｄＩｔｅｍ＿ＩＤ＜＝１９”が記載され、チェックサムとして５５が記載される。

データ領域指定のデータチェックコマンドの場合、処理１５０２においてデータチェックログが生成される。この場合、データチェックログは、データ領域名、ページ番号、および、各ページのチェックサムを含む。例えば、図１７（データチェックログの記載内容の別の例）に例示するように、Ｓｔｏｃｋテーブルのページ番号１のチェックサムが２０２であり、ページ番号２のチェックサムが２３であることが記載される。

処理１５０２、または、処理１５０３で生成されたデータチェックログは、処理１５０４においてログ出力手段２０６に通知される。図１０を用いて説明したように、ログ出力手段２０６は、通し番号を付与して、ログ格納領域２１３にログを格納するとともに、ログ送信手段２１１に通知する。

以上のように、ログの通し番号は、データ更新ログの該当データを更新した順序と、データチェックログの該当チェックサムを算出した順序に従って付与される。従って、この通し番号によって、チェックサムを算出した時点で、どのデータ更新までが完了していたかが判定できる。すなわち、セカンダリサイトでは、データチェックログに付与された通し番号までのデータ更新ログを適用した時点で、チェックサムを算出することにより、プライマリサイトと同期してチェックサムを算出することができる。

図１８は、ログ受信手段２２４の動作を示すフローチャートである。判断１８０１では、ログの通し番号が連番になっているか否かをチェックする。すなわち、今回受信したログの番号が、前回に受信したログの番号の次の番号になっているかをチェックする。連番になっていない場合には、処理１８０２で次のログの受信待ちを行なう。このような制御により、ログの通し番号の順序で、ログ適用とチェックサムの算出を行なうようにする。

処理１８０３では、ログ入出力手段２２６を用いて、受信したログをログ格納領域２３４に格納する。判断１８０４では、受信したログがデータ更新ログかデータチェックログかを判断をする。受信したログがデータ更新ログの場合には、処理１８０５に進み、ログ適用手段２２５に通知する。受信したログがデータチェックログの場合には、処理１８０６に進み、チェックサム算出手段２２９に通知する。

図１９は、ログ適用手段２２５の動作を示すフローチャートである。既に説明したように、データ更新ログには、ページ番号とそのページの変更方法が記載されている。例えば、データ更新ログには、「ログ番号１番、ページ５００番にＩｔｅｍ＿ＩＤが１００でＱｕａｎｔｉｔｙが５０のデータを追加」といった内容が記載されている。このようなデータ更新ログを受信した場合、処理１９０１では、データ入出力手段２２７を用いて、データ格納領域２３５からメモリ領域２２２にページ５００番を読み込む。処理１９０２では、メモリ領域２２２に読み込んだページに対して、データの更新を行なう。上記のデータ更新ログの場合には、Ｉｔｅｍ＿ＩＤが１００でＱｕａｎｔｉｔｙが５０のデータを追加する。この際、図５で例示したように、ページにデータを追加するとともに、データポインタを追加する。処理１９０３では、更新したページを、データ入出力手段２２７を用いて、データ格納領域２３５に書き込む。

図２０は、チェックサム算出手段２２９の動作を示すフローチャートである。チェックサム算出手段２２９は、ログ受信手段２２４から通知を受けることで動作を開始する。判断２００１では、ログ受信手段２２４から通知されたデータチェックコマンドの種別を判断する。データ領域指定のデータチェックコマンドの場合は、処理２００２でデータ領域抽出手段２２８に通知し、データ領域抽出手段２２８を用いて、指定したテーブルのデータを抽出する。処理２００３では、抽出したデータのチェックサムを算出する。ＳＱＬ文指定のデータチェックコマンドの場合は、処理２００５でＳＱＬ実行手段２３２に通知する。通知を受けたＳＱＬ実行手段２３２は、ＳＱＬ文を実行し、実行結果をチェックサム算出手段２２９に通知する。処理２００６で、ＳＱＬ文の実行結果のチェックサムを算出する。

チェックサム算出手段２２９のチェックサムの算出方法は、プライマリサイトのチェックサム算出手段２０９の方法と同様である。また、ＳＱＬ実行手段２３２の動作はプライマリサイトのＳＱＬ実行手段２０５と同様であり、データ領域抽出手段２２８の動作はプライマリサイトのデータ領域抽出手段２０８と同様である。

チェックサムの算出が完了すると、チェックサム算出手段２２９は、処理２００４において、受信したデータチェックログと算出したチェックサムをチェックサム照合手段２３０に通知する。

図２１は、チェックサム照合手段２３０の動作を示すフローチャートである。判断２１０１では、データチェックコマンドの種別の判定を行なう。データ領域指定のデータチェックコマンドの場合、処理２１０２に進み、チェックサムの照合を行なう。図１７に示したように、データ領域指定のデータチェックコマンドの場合、受信したログには、ページ番号と各ページのチェックサムが記載されている。また、図１３に示したようにチェックサム算出手段２２９は、各ページのチェックサムを算出している。処理２１０２では、受信したログに記載されているチェックサムと、チェックサム算出手段２２９が算出したチェックサムをページごとに照合し、全てのチェックサムが同じ値であれば一致と判定し、一つでもチェックサムが異なっていれば不一致と判定する。

ＳＱＬ文指定のデータチェックコマンドの場合、処理２１０３に進み、チェックサムの照合を行なう。図１６に示したように、ＳＱＬ文指定のデータチェックコマンドの場合、受信したログには、ＳＱＬ文とその実行結果のチェックサムが記載されている。チェックサム算出手段２２９は、セカンダリサイトでＳＱＬ文を実行し、その実行結果のチェックサムを算出している。処理２１０３では、データチェックログに記載されているチェックサムと、チェックサム算出手段２２９で算出したチェックサムを照合し、その値が同じであれば一致と判定し、その値が異なれば不一致と判定する。処理２１０４では、操作端末１０８に照合結果を通知する。

以上説明したように、本実施の形態によれば、データチェックログ生成手段２１０などを設け、データ更新ログとデータチェックログに順序をつけてセカンダリサイトに送信することで、チェックサム算出のタイミングを同期することができる。また、データ領域抽出手段２０８，２２８などを設けることで、データの格納位置によらず、データの一致の検定を可能にすることができる。この結果、バックアップデータのチェック作業を簡便に行なうことが可能になる。

以上、本発明者によってなされた発明を実施の形態に基づき具体的に説明したが、本発明は前記実施の形態に限定されるものではなく、その要旨を逸脱しない範囲で種々変更可能であることはいうまでもない。

例えば、上記実施の形態では、ログ送信手段２１１がサーバ１０３で動作し、ログ受信手段２２４がサーバ１０５で動作する例を用いて説明したが、図２２に示すように、ログ送信手段２１１を外部記憶装置１０４で動作させ、ログ受信手段２２４を外部記憶装置１０６で動作させる実施の形態も考えられる。また、ログ適用ソフトウェア２２３をセカンダリサイトのサーバ１０５で動作させるのではなく、ログ適用ソフトウェア２２３を外部記憶装置１０６に付随するアプライアンスサーバ１１０で動作させる実施の形態も考えられる。この場合、ネットワーク１０７は、外部記憶装置１０４と外部記憶装置１０６を接続する。ログ送信手段２１１は、ログ出力手段２０６がストレージ制御部２１２にログ出力の要求を出したときに、該当ログをログ受信手段２２４に送信する。また、この構成では、操作端末１０８は、ネットワーク１０９を通じてサーバ１０３に接続されている。

また、上記実施の形態は、本発明を実施するための最良の実施の形態であり、本発明はこれらの実施の形態に限られるものではない。例えば、上記実施の形態では、ＤＢＭＳのページを用いて説明を行ったが、請求項に記載のデータ格納領域は、ＤＢＭＳのページだけを指すものではない。

また、本発明は、上記実施の形態で説明した、ＤＢＭＳの各種手段、ログ適用ソフトウェアの各種手段として機能させるためのプログラムや、フローチャートの各処理手順を実行させるためのプログラムを格納した記憶媒体などにも適用可能である。

本発明のバックアップデータの検定技術は、バックアップシステムのデータ一致の検定方法、プログラム、および、記憶媒体などに利用可能である。

本発明の一実施の形態の二重化システムによるデータのバックアップシステムのシステム構成例を示す図である。本発明の一実施の形態の二重化システムによるデータのバックアップシステムのシステム構成例を詳細に示す図である。本発明の一実施の形態のバックアップシステムにおいて、外部記憶装置にデータを格納する方法の例を示す図である。本発明の一実施の形態のバックアップシステムにおいて、テーブルと格納領域の対応関係の管理方法の例を示す図である。本発明の一実施の形態のバックアップシステムにおいて、ページの格納方法の例を示す図である。本発明の一実施の形態のバックアップシステムにおいて、テーブルのカラムの管理方法の例を示す図である。本発明の一実施の形態のバックアップシステムにおいて、コマンド受付手段の動作を示すフローチャートである。本発明の一実施の形態のバックアップシステムにおいて、ＳＱＬ実行手段の動作を示すフローチャートである。本発明の一実施の形態のバックアップシステムにおいて、ＳＱＬ実行手段のＳＱＬ実行例を示す図である。本発明の一実施の形態のバックアップシステムにおいて、ログ出力手段の動作を示すフローチャートである。本発明の一実施の形態のバックアップシステムにおいて、チェックサム算出手段の動作を示すフローチャートである。本発明の一実施の形態のバックアップシステムにおいて、データ領域抽出手段のデータ抽出方法の例を示す図である。本発明の一実施の形態のバックアップシステムにおいて、チェックサム算出手段のチェックサム算出例を示す図である。本発明の一実施の形態のバックアップシステムにおいて、データ領域抽出手段の動作を示すフローチャートである。本発明の一実施の形態のバックアップシステムにおいて、データチェックログ生成手段の動作を示すフローチャートである。本発明の一実施の形態のバックアップシステムにおいて、データチェックログの記載内容の例を示す図である。本発明の一実施の形態のバックアップシステムにおいて、データチェックログの記載内容の別の例を示す図である。本発明の一実施の形態のバックアップシステムにおいて、ログ受信手段の動作を示すフローチャートである。本発明の一実施の形態のバックアップシステムにおいて、ログ適用手段の動作を示すフローチャートである。本発明の一実施の形態のバックアップシステムにおいて、チェックサム算出手段の動作を示すフローチャートである。本発明の一実施の形態のバックアップシステムにおいて、チェックサム照合手段の動作を示すフローチャートである。本発明の一実施の形態のバックアップシステムにおいて、別のシステム構成例を詳細に示す図である。

符号の説明

１０１…プライマリシステム、１０２…セカンダリシステム、１０３…プライマリシステムのサーバ、１０４…プライマリシステムの外部記憶装置、１０５…セカンダリシステムのサーバ、１０６…セカンダリシステムの外部記憶装置、１０７…ネットワーク、１０８…操作端末、１０９…ネットワーク、１１０…アプライアンスサーバ、
２０１…ＣＰＵ、２０２…メモリ領域、２０３…ＤＢＭＳ、２０４…コマンド受付手段、２０５…ＳＱＬ実行手段、２０６…ログ出力手段、２０７…データ入出力手段、２０８…データ領域抽出手段、２０９…チェックサム算出手段、２１０…データチェックログ生成手段、２１１…ログ送信手段、２１２…ストレージ制御部、２１３…ログ格納領域、２１４…データ格納領域、２２１…ＣＰＵ、２２２…メモリ領域、２２３…ログ適用ソフトウェア、２２４…ログ受信手段、２２５…ログ適用手段、２２６…ログ入出力手段、２２７…データ入出力手段、２２８…データ領域抽出手段、２２９…チェックサム算出手段、２３０…チェックサム照合手段、２３２…ＳＱＬ実行手段、２３３…ストレージ制御部、２３４…ログ格納領域、２３５…データ格納領域。

Claims

計算機システムであって、
第一のサーバと、
前記第一のサーバに接続され、前記第一のサーバが利用する第一のデータ記憶領域と、第一のログ記憶領域と、を有する第一のストレージ装置と、
第二のサーバと、
前記第二のサーバに接続される第二のストレージ装置と、を備え、
前記第一のサーバは、
外部からの前記第一のデータ記憶領域に対する更新要求を前記第一のストレージ装置に送信するデータ出力手段と、
前記第一のデータ記憶領域に含まれるデータに対するデータチェックコマンドを外部から受領した場合は、前記チェックコマンドに対応するデータの第一のチェック処理を実行する第一のチェック処理実行手段と、
前記更新要求に対応する更新ログを、他のログ情報と順序関係を特定するための順序情報を付与して、前記第一のログ記憶領域に格納するよう前記第一のストレージ装置に送信し、前記第一のチェック処理実行手段によるチェック処理の第一の実行結果を含むチェックコマンドの処理履歴を示すチェックログを前記更新ログを含む他のログ情報と順序関係を特定するための順序情報を付与し、前記第一のログ記憶領域に格納するよう前記第一のストレージ装置に送信する第一のログ出力手段と、
前記第一のログ記憶領域に格納される一以上のログ情報を前記第二のサーバに送信するログ送信手段と、を有し、
前記第二のストレージ装置は、第二のログ記憶領域と第二のデータ記憶領域とを有し、
前記第二のサーバは、
前記第一のサーバから受信したログ情報を前記第二のストレージ装置の前記第二のログ記憶領域に格納する第二のログ出力手段と、
前記ログ情報に付与される順序情報に従って読み出されたログ情報が更新ログかチェックログであるかを判定するログ種別判定手段と、
前記ログ種別判定手段による判定結果、読み出されたログ情報が更新ログの場合は、前記第二のデータ記憶領域に前記更新ログを適用するログ適用手段と、
前記ログ種別判定手段による判定結果、読み出されたログ情報がチェックログの場合は、前記第二のデータ記憶領域に含まれるデータのチェックサムを算出するチェック処理を実行する第二のチェック処理実行手段と、
前記第二のチェック処理実行手段による第二の実行結果と前記ログ情報に含まれる第一の実行結果とを比較する実行結果比較手段と、を有することを、
特徴とする計算機システム。
請求項１記載の計算機システムであって、
前記第二のデータ記憶領域は、前記第一のデータ記憶領域に格納されるデータと同一または、前記第一のデータ記憶領域において現在より古い時点におけるデータと同一であるデータを格納する、ことを特徴とする計算機システム。
請求項１記載の計算機システムであって、
前記第一のサーバは、前記外部から受け付けるコマンドが、チェックコマンドであるか更新要求であるかを判別するコマンド受付手段を有することを特徴とする計算機システム。
請求項３記載の計算機システムであって、
前記第一のチェック処理実行手段は、
前記コマンド受付手段による前記判別結果、
前記外部から受け付けたコマンドがチェックコマンドであった場合、前記チェックコマンドで指定されるデータ領域を前記第一のデータ記憶領域から特定し、前記指定されたデータ領域を読み出し、前記指定されたデータ領域における第一のデータチェックサムを前記第一の実行結果として算出し、
前記第二のチェック処理実行手段は、
前記指定されたデータ領域に対応する前記第二のデータ記憶領域におけるデータ領域の第二のデータチェックサムを前記第二の実行結果として算出し、
前記実行結果比較手段は、前記第一のデータチェックサムと前記第二のデータチェックサムとを比較する、ことを特徴とする計算機システム。
請求項４記載の計算機システムであって、
前記データ領域は、ページ単位で指定され、
前記第一のデータチェックサムおよび前記第二のデータチェックサムはそれぞれページ単位で算出されることを特徴とする計算機システム。
請求項１記載の計算機システムであって、
前記チェックログは、ＳＱＬ文で記述されている、前記第一のデータ記憶領域に含まれるデータに対するデータチェックコマンドと前記第一の実行結果とを含むことを特徴とする計算機システム。
計算機システムであって、
第一のサーバと、
前記第一のサーバに第一の通信線を介して接続され、前記第一のサーバが利用する第一のデータ記憶領域と、第一のログ記憶領域と、を有する第一のストレージ装置と、
第二のサーバと、
前記第二のサーバに第二の通信線を介して接続される第二のストレージ装置と、を備え、
前記第一のサーバは、
外部からの前記第一のデータ記憶領域に対する更新要求を前記第一のストレージ装置に送信する前記第一の通信線を介して第一のデータ出力手段と、
前記第一のデータ記憶領域に含まれるデータに対するデータチェックコマンドを外部から受領した場合は、前記チェックコマンドに対応するデータの第一のチェック処理を実行する第一のチェック処理実行手段と、
前記更新要求に対応する更新ログに他のログ情報と順序関係を特定するための順序情報を付与して、前記更新ログを前記第一のストレージ装置に前記第一の通信線を介して出力し、前記第一のチェック処理実行手段によるチェック処理の第一の実行結果を含むチェックコマンドの処理履歴を示すチェックログに前記更新ログを含む他のログ情報と順序関係を特定するための順序情報を付与し、前記チェックログを前記第一のストレージ装置に前記第一の通信線を介して出力するログ出力手段と、を有し、
前記第一のストレージ装置は、
前記順序情報が付与されている前記更新ログを、前記第一のログ記憶領域に格納し、前記順序情報が付与されている前記チェックログを前記第一のログ記憶領域に格納する第一のログ格納手段と、
前記第一のログ記憶領域に格納される一以上のログ情報を前記第二のストレージ装置に第三の通信線を介して送信するログ送信手段と、を有し、
前記第二のストレージ装置は、第二のログ記憶領域と第二のデータ記憶領域とを備え、
前記第二のストレージ装置は、前記第一のストレージ装置から前記第三の通信線を介して受信したログ情報を前記第二のログ記憶領域に格納する第二のログ格納手段を有し、
前記第二のサーバは、
前記第二のストレージ装置の前記第二のログ記憶領域に格納されるログ情報を前記順序情報とともに前記第二の通信線を介して読み出すログ読み出し手段と、
前記ログ情報に付与される順序情報に従って読み出されたログ情報が更新ログかチェックログであるかを判定するログ種別判定手段と、
前記ログ種別判定手段による判定結果、読み出されたログ情報が更新ログの場合は、前記第二のストレージ装置の前記第二のデータ記憶領域に前記第二の通信線を介して前記更新ログを適用するログ適用手段と、
前記ログ種別判定手段による判定結果、読み出されたログ情報がチェックログの場合は、前記第二のデータ記憶領域に含まれるデータのチェックサムを算出するチェック処理を実行する第二のチェック処理実行手段と、
前記第二のチェック処理実行手段による第二の実行結果と前記ログ情報に含まれる第一の実行結果とを比較する実行結果比較手段と、を有することを、
特徴とする計算機システム。