(57)【要約】【課題】複製元データ処理システムに記憶されたデータを複製先データ処理システムに複製する際のデータ複製元データ処理システムの占有時間を短縮する。【解決手段】複製元ＤＢ１１は、ネットワーク１５を介して中間ＤＢ１２と制御装置１４とに接続されている。中間ＤＢ１２は、ネットワーク１５を介して複製元ＤＢ１１と複製先ＤＢ１３と制御装置１４とに接続され、複製元ＤＢ１１から供給されたデータを格納する。複製先ＤＢ１３は、ネットワーク１５を介して中間ＤＢ１２と制御装置１４とに接続され、中間ＤＢ１２から供給されたデータを記憶することにより、複製元ＤＢ１１に記憶されたデータを複製する。制御装置１４は、ネットワーク１５を介して接続されている複製元ＤＢ１１と中間ＤＢ１２と複製先ＤＢ１３とを制御する。【選択図】　図１
2004139453.tif 000002
【特許請求の範囲】
【請求項１】
複製元データ処理システムに記憶されているデータを中間データ処理システムに格納し、格納したデータを複製先データ処理システムに複製するデータ複製システムにおいて、
複製元データ処理システムに記憶されているデータが更新されたタイミングを検出する更新タイミング検出手段と、
複製元データ処理システムに記憶されているデータの中間データ処理システムへの格納が完了したタイミングを検出する格納完了タイミング検出手段と、
中間データ処理システムに格納したデータの複製先データ処理システムへの複製が完了したタイミングを検出する複製完了タイミング検出手段と、
前記検出した更新タイミングと格納完了タイミングと複製完了タイミングとに基づいて、中間データ処理システムに格納したデータの削除と、複製元データ処理システムに記憶されているデータの中間データ処理システムへの格納と、中間データ処理システムに格納したデータの複製先データ処理システムへの複製と、を指示する指示手段と、
を備えるデータ複製システム。
【請求項２】
前記指示手段は、更新タイミングが格納完了タイミングより先の場合、中間データ処理システムに格納したデータの削除と複製元データ処理システムに記憶されているデータの中間データ処理システムへの格納と、中間データ処理システムに格納したデータの複製先データ処理システムへの複製と、を指示する、
ことを特徴とする請求項１に記載のデータ複製システム。
【請求項３】
前記指示手段は、格納完了タイミングが複製完了タイミングより先の場合、中間データ処理システムに格納したデータの削除と、複製元データ処理システムに記憶されているデータの中間データ処理システムへの格納と、を指示する、
ことを特徴とする請求項１又は請求項２に記載のデータ複製システム。
【請求項４】
前記指示手段は、格納完了タイミングが複製完了タイミングより後の場合、中間データ処理システムに格納したデータの複製先データ処理システムへの複製を指示する、
ことを特徴とする請求項１乃至３のいずれか１項に記載のデータ複製システム。
【請求項５】
複製元データ処理システムと、中間データ処理システムと複製先データ処理システムに接続され、データの複製処理を制御するシステムであって、
複製元データ処理システムに記憶されているデータが更新されたタイミングを検出する更新タイミング検出手段と、
複製元データ処理システムに記憶されているデータの中間データ処理システムへの格納が完了したタイミングを検出する格納完了タイミング検出手段と、
中間データ処理システムに格納したデータの複製先データ処理システムへの複製が完了したタイミングを検出する複製完了タイミング検出手段と、
更新タイミングが格納完了タイミングより先の場合、中間データ処理システムに格納したデータの削除と、複製元データ処理システムに記憶されているデータの中間データ処理システムへの格納と、中間データ処理システムに格納したデータの複製先データ処理システムへの複製と、を指示する第１の指示手段と、
格納完了タイミングが複製完了タイミングより先の場合、中間データ処理システムに格納したデータの削除と、複製元データ処理システムに記憶されているデータの中間データ処理システムへの格納と、を指示する第２の指示手段と、
格納完了タイミングが複製完了タイミングより後の場合、中間データ処理システムに格納したデータの複製先データ処理システムへの複製を指示する第３の指示手段と、
を備えるデータ複製システム。
【請求項６】
複製元データ処理システムに記憶されているデータが更新されたタイミングを検出する更新タイミング検出工程と、
複製元データ処理システムに記憶されているデータの中間データ処理システムへの格納が完了したタイミングを検出する格納完了タイミング検出工程と、
中間データ処理システムに格納したデータの複製先データ処理システムへの複製が完了したタイミングを検出する複製完了タイミング検出工程と、
前記検出した更新タイミングと格納完了タイミングと複製完了タイミングとに基づいて、中間データ処理システムに格納したデータの削除と、複製元データ処理システムに記憶されているデータの中間データ処理システムへの格納と、中間データ処理システムに格納したデータの複製先データ処理システムへの複製と、を指示する指示工程と、
を備えるデータ複製方法。
【請求項７】
コンピュータに
複製元データ処理システムに記憶されているデータが更新されたタイミングを検出する更新タイミング検出工程、
複製元データ処理システムに記憶されているデータの中間データ処理システムへの格納が完了したタイミングを検出する格納完了タイミング検出工程、
中間データ処理システムに格納したデータの複製先データ処理システムへの複製が完了したタイミングを検出する複製完了タイミング検出工程、
前記検出した更新タイミングと格納完了タイミングと複製完了タイミングとに基づいて、中間データ処理システムに格納したデータの削除と、複製元データ処理システムに記憶されているデータの中間データ処理システムへの格納と、中間データ処理システムに格納したデータの複製先データ処理システムへの複製と、を指示する指示工程、
として機能させるコンピュータプログラム。
【発明の詳細な説明】
【０００１】
【発明の属する技術分野】
本発明は、データ複製システム及びデータ複製方法に関し、特に、複製元データ処理システムに記憶されたデータを複製先データ処理システムに複製する際の、データ複製元データ処理システムの占有時間を短縮するシステム及び方法に関する。
【０００２】
【従来の技術】
業務等において発生するデータを抽出し、目的別にこれらデータを整理、統合して蓄積し、これらデータに基づいて企業活動に関する情報を提供するシステムであるデータ・ウエアハウス（ＤＷＨ）が知られている。
【０００３】
近年、このＤＷＨの一部の機能を外部の企業に委託することが行われることがある。この場合においては、外部の企業の複製元データベースから必要なデータを自己の企業の複製先データベースに複製する必要がある。
【０００４】
この場合、データの複製は、複製元データベースから複製先データベースにデータをインサートし、複製先データベースのデータを更新することにより行っている（特許文献１）。
【０００５】
また、データの複製は、複製対象の複製元データベースから一度ローカルファイルに出力してから、複製先データベースのネットワークサーバのローダ機能に取り込ませることによっても可能である。
【０００６】
【特許文献１】
特開２０００−３３９２１０
【０００７】
【発明が解決しようとする課題】
しかし、データを複製先データベースに複製する間、複製元データベースは、データの追加、更新を防止するために、複製元データベース全体に対しデータの書き込みを禁止する必要がある。また、複製の処理能力の低下を防止するために、複製元データベースへの他の企業からのアクセスも禁止する必要がある。このため、データが大量である場合は、複製元データベース全体に対してのデータの書き込み及びアクセスを禁止する時間がその分長くなるという問題が生じる。
【０００８】
さらに、複製元データベースから一度ローカルファイルに出力して複製する場合、ローカルファイルにデータを出力する際にエラーが生じても、ローカルファイルをロールバック処理等により復旧することはできない。このため、再度、複製元データベースからローカルファイルにデータを出力する必要があり、この場合、複製元データベース全体に対してのデータの書き込み及びアクセスを禁止しなければならない。
【０００９】
本発明は、上記の問題を解決するためになされたものであって、データを複製する際のデータ複製元データ処理システムの占有時間の短いシステム及び方法を提供することを目的とする。
【００１０】
【課題を解決するための手段】
上記目的を達成するため、本発明の第１の観点に係るデータ複製システムは、
複製元データ処理システムに記憶されているデータを中間データ処理システムに格納し、格納したデータを複製先データ処理システムに複製するデータ複製システムにおいて、
複製元データ処理システムに記憶されているデータが更新されたタイミングを検出する更新タイミング検出手段と、
複製元データ処理システムに記憶されているデータの中間データ処理システムへの格納が完了したタイミングを検出する格納完了タイミング検出手段と、
中間データ処理システムに格納したデータの複製先データ処理システムへの複製が完了したタイミングを検出する複製完了タイミング検出手段と、
前記検出した更新タイミングと格納完了タイミングと複製完了タイミングとに基づいて、中間データ処理システムに格納したデータの削除と、複製元データ処理システムに記憶されているデータの中間データ処理システムへの格納と、中間データ処理システムに格納したデータの複製先データ処理システムへの複製と、を指示する指示手段と、
を備える。
【００１１】
また、前記指示手段は、例えば、更新タイミングが格納完了タイミングより先の場合、中間データ処理システムに格納したデータの削除と複製元データ処理システムに記憶されているデータの中間データ処理システムへの格納と、中間データ処理システムに格納したデータの複製先データ処理システムへの複製と、を指示してもよい。
【００１２】
さらに、前記指示手段は、例えば、格納完了タイミングが複製完了タイミングより先の場合、中間データ処理システムに格納したデータの削除と、複製元データ処理システムに記憶されているデータの中間データ処理システムへの格納と、を指示してもよい。
【００１３】
またさらに、例えば、前記指示手段は、格納完了タイミングが複製完了タイミングより後の場合、中間データ処理システムに格納したデータの複製先データ処理システムへの複製を指示してもよい。
【００１４】
上記目的を達成するため、本発明の第２の観点に係るデータ複製システムは、
複製元データ処理システムと、中間データ処理システムと複製先データ処理システムに接続され、データの複製処理を制御するシステムであって、
複製元データ処理システムに記憶されているデータが更新されたタイミングを検出する更新タイミング検出手段と、
複製元データ処理システムに記憶されているデータの中間データ処理システムへの格納が完了したタイミングを検出する格納完了タイミング検出手段と、
中間データ処理システムに格納したデータの複製先データ処理システムへの複製が完了したタイミングを検出する複製完了タイミング検出手段と、
更新タイミングが格納完了タイミングより先の場合、中間データ処理システムに格納したデータの削除と、複製元データ処理システムに記憶されているデータの中間データ処理システムへの格納と、中間データ処理システムに格納したデータの複製先データ処理システムへの複製と、を指示する第１の指示手段と、
格納完了タイミングが複製完了タイミングより先の場合、中間データ処理システムに格納したデータの削除と、複製元データ処理システムに記憶されているデータの中間データ処理システムへの格納と、を指示する第２の指示手段と、
格納完了タイミングが複製完了タイミングより後の場合、中間データ処理システムに格納したデータの複製先データ処理システムへの複製を指示する第３の指示手段と、を備える。
【００１５】
上記目的を達成するため、本発明の第３の観点に係るデータ複製方法は、
複製元データ処理システムに記憶されているデータが更新されたタイミングを検出する更新タイミング検出工程と、
複製元データ処理システムに記憶されているデータの中間データ処理システムへの格納が完了したタイミングを検出する格納完了タイミング検出工程と、
中間データ処理システムに格納したデータの複製先データ処理システムへの複製が完了したタイミングを検出する複製完了タイミング検出工程と、
前記検出した更新タイミングと格納完了タイミングと複製完了タイミングとに基づいて、中間データ処理システムに格納したデータの削除と、複製元データ処理システムに記憶されているデータの中間データ処理システムへの格納と、中間データ処理システムに格納したデータの複製先データ処理システムへの複製と、を指示する指示工程と、を備える。
【００１６】
上記目的を達成するため、本発明の第４の観点に係るコンピュータプログラムは、コンピュータに、
複製元データ処理システムに記憶されているデータが更新されたタイミングを検出する更新タイミング検出工程、
複製元データ処理システムに記憶されているデータの中間データ処理システムへの格納が完了したタイミングを検出する格納完了タイミング検出工程、
中間データ処理システムに格納したデータの複製先データ処理システムへの複製が完了したタイミングを検出する複製完了タイミング検出工程、
前記検出した更新タイミングと格納完了タイミングと複製完了タイミングとに基づいて、中間データ処理システムに格納したデータの削除と、複製元データ処理システムに記憶されているデータの中間データ処理システムへの格納と、中間データ処理システムに格納したデータの複製先データ処理システムへの複製と、を指示する指示工程、を実行させる。
【００１７】
【発明の実施の形態】
本発明の実施の形態のデータベース（ＤＢ）複製システムについて図面を参照して説明する。
【００１８】
このデータベース複製システム１は、図１に示すように、複製元ＤＢ１１と、中間ＤＢ１２と、複製先ＤＢ１３と、制御装置１４と、ネットワーク１５とから構成されている。このネットワーク１５は、有線回線により構築されても無線回線により構築されてもよい。また、インターネットなどのオープンなネットワークでも、一企業内のＬＡＮ等のクローズされたネットワークでもよい。
【００１９】
複製元ＤＢ１１は、ネットワーク１５を介して中間ＤＢ１２と制御装置１４とに接続され、図示しない入力装置に更新データを入力することにより、記憶しているデータを更新することができる。また、複製元ＤＢ１１は、制御装置１４の制御の下、記憶しているデータを中間ＤＢ１２に供給する。
【００２０】
中間ＤＢ１２は、ネットワーク１５を介して複製元ＤＢ１１と複製先ＤＢ１３と制御装置１４とに接続され、複製元ＤＢ１１から供給されたデータを格納する。また、中間ＤＢ１２は、制御装置１４の制御の下、格納したデータを複製先ＤＢ１３に供給し、格納したデータを削除する。
【００２１】
複製先ＤＢ１３は、ネットワーク１５を介して中間ＤＢ１２と制御装置１４とに接続され、中間ＤＢ１２から供給されたデータを記憶することにより、複製元ＤＢ１１に記憶されたデータを複製して記憶する。
【００２２】
制御装置１４は、通常のコンピュータ或いはデータベース装置、又は、コンピュータ、ＣＰＵ（Ｃｅｎｔｒａｌ　Ｐｒｏｃｅｓｓｉｎｇ　Ｕｎｉｔ）、ＲＯＭ（Ｒｅａｄ　Ｏｎｌｙ　Ｍｅｍｏｒｙ）、ＲＡＭ（Ｒａｍｄｏｍ　Ａｃｃｅｓｓ　Ｍｅｍｏｒｙ）等を備えた専用の転送制御装置等から構成され、ネットワーク１５を介して、複製元ＤＢ１１と中間ＤＢ１２と複製先ＤＢ１３とに接続されている。
【００２３】
制御装置１４は、複製元ＤＢ１１に格納されたデータを複製先ＤＢ１３に複製する動作全般を制御する。具体的には、制御装置１４は、複製元ＤＢ１１に格納されたデータを中間ＤＢ１２に格納する動作（第１のコピー動作）、中間ＤＢ１２に格納されたデータの複製先ＤＢ１３への複製動作（第２のコピー動作）、中間ＤＢ１２に格納されたデータの削除動作などを制御する。
制御装置１４は、タイマ回路１４１を内蔵し、複製動作を制御するため、制御装置１４は、複製元ＤＢ１１上のデータの更新タイミングＴ２１と、中間ＤＢ１２の格納完了タイミングＴ２２と、複製先ＤＢ１３への複製完了タイミングＴ２３とを検出する。更新タイミングＴ２１は、複製元ＤＢ１１上でデータが最後に更新されたタイミングを示す。格納完了タイミングＴ２２は、複製元ＤＢ１１に記憶されているデータの中間ＤＢ１２への格納（第１のコピー動作）が完了したタイミングである。複製完了タイミングＴ２３は、中間ＤＢ１２に記憶されているデータの複製先ＤＢ１３への複製（第２のコピー動作）が完了したタイミングである。
【００２４】
制御装置１４は、タイマ回路１４１を内蔵し、このタイマ回路１４１により各タイミングの先後を判別する。また、制御装置１４は、書き換え可能な不揮発性メモリ、例えば、フラッシュメモリ１４２を内蔵する。制御装置１４は、更新タイミングＴ２１と格納完了タイミングＴ２２と複製完了タイミングＴ２３とを、タイマ回路１４１に基づいて検出し、フラッシュメモリ１４２に図２に示す検出テーブルを作成する。
【００２５】
前記構成を有するデータベース複製システム１のデータ格納動作について説明する。
この格納動作は、複製元ＤＢ１１上のデータが更新されている場合に、これを中間ＤＢ１２に格納する動作（第１のコピー動作）である。
【００２６】
制御装置１４は、複製元ＤＢ１１を常時監視し、複製元ＤＢ１１に記憶されているデータが更新されるごとに、更新タイミングＴ２１をタイマ回路１４１のカウント値と対応付けてフラッシュメモリ１４２の検出テーブル（図２）に上書き保存する。
【００２７】
制御装置１４は、所定のタイミング（例えば、周期的に或いは他の処理の空き時間等）になると、図３のフローチャートに示すデータ格納処理を開始する。このデータ格納動作は、中間ＤＢ１２に格納したデータを削除した後に複製元ＤＢ１１に記憶されているデータを中間ＤＢ１２へ格納する動作である。
【００２８】
データ格納処理を開始すると、制御装置１４は、前回のデータ格納処理以降、複製元ＤＢ１１に記録されたデータが更新されているか否かを判別する（ステップＳ３０１）。制御装置１４は、この判別をフラッシュメモリ１４２の検出テーブル（図２）に記憶された更新タイミングＴ２１に対応するカウント値と格納完了タイミングＴ２２に対応するカウント値とを比較することにより行う。ここで、格納完了タイミングＴ２２とは、前述のように、複製元ＤＢ１１に記憶されたデータの中間ＤＢ１２への格納が完了したタイミングである。
【００２９】
複製元ＤＢ１１上のデータが更新されていないと判断した場合（ステップＳ３０１；ＮＯ）、制御装置１４は、データ格納処理（中間ＤＢ１２への格納処理）を終了する。
【００３０】
複製元ＤＢ１１上のデータが更新されていると判別した場合（ステップＳ３０１；ＹＥＳ）、制御装置１４は、前回のデータ格納処理により中間ＤＢ１２に格納されたデータの複製先ＤＢ１３への複製が完了しているか否かを判別する（ステップＳ３０２）。制御装置１４は、この判別をフラッシュメモリ１４２の検出テーブル（図２）に記憶された格納完了タイミングＴ２２に対応するカウント値と複製完了タイミングＴ２３に対応するカウント値とを比較することにより行う。ここで、複製完了タイミングＴ２３とは、中間ＤＢ１２に格納されたデータの複製先ＤＢ１３への複製が完了したタイミングである。
【００３１】
複製先ＤＢ１３への複製がまだ完了していないと判別された場合（ステップＳ３０２；ＮＯ）、制御装置１４は、中間ＤＢ１２に格納されたデータを複製先ＤＢ１３にインサートし（ステップＳ３０３）、複製先ＤＢ１３のデータを更新する（ステップＳ３０４）。これにより、前回のデータ格納処理タイミングに複製元ＤＢ１１に記憶されていたデータを複製先ＤＢ１３に複製することができる。
【００３２】
複製完了後、制御装置１４は、複製完了タイミングＴ２３をタイマ回路１４１のカウント値と対応付けてフラッシュメモリ１４２の検出テーブル（図２）に上書き保存する（ステップＳ３０５）。
【００３３】
複製先ＤＢ１３への複製が完了している判別された場合（ステップＳ３０２；ＹＥＳ）又は前記ステップＳ３０３とＳ３０４とＳ３０５とにより複製先ＤＢ１３への複製が完了した場合、制御装置１４は、中間ＤＢ１２に格納されているデータを削除する（ステップＳ３０６）。
【００３４】
制御装置１４は、複製元ＤＢ１１の更新データを中間ＤＢ１２に格納するため、中間ＤＢ１２に複製元ＤＢ１１を占有させる（ステップＳ３０７）。
【００３５】
制御装置１４は、複製元ＤＢ１１の更新データを中間ＤＢ１２にインサートし（ステップＳ３０８）、更新データを中間ＤＢ１２に格納する。
【００３６】
格納完了後、制御装置１４は、格納完了タイミングＴ２２をタイマ回路１４１のカウント値と対応付けてフラッシュメモリ１４２の検出テーブル（図２）に上書き保存し（ステップＳ３０９）、中間ＤＢ１２の複製元ＤＢ１１に対する占有を解除する（ステップＳ３１０）。
【００３７】
前記格納動作により、更新処理することなくインサート処理のみで更新データを中間ＤＢ１２に格納することができるので、中間ＤＢ１２の複製元ＤＢ１１に対する占有時間を短縮することができる。
【００３８】
次に、中間ＤＢ１２上のデータを複製先ＤＢ１３に複製するデータ複製動作（第２のコピー動作）について説明する。
【００３９】
制御装置１４は、所定のタイミングになると、図４のフローチャートに示すデータ複製処理を開始する。このデータ複製動作は、前記データ格納動作により中間ＤＢ１２に格納したデータを複製先ＤＢ１３に供給し、複製元ＤＢ１１のデータを複製先ＤＢ１３に複製させる動作である。
【００４０】
制御装置１４は、前回のデータ格納処理により中間ＤＢ１２に格納されたデータの複製先ＤＢ１３への複製が完了しているか否かを判別する（ステップＳ４０１）。制御装置１４は、この判別をフラッシュメモリ１４２の検出テーブル（図２）に記憶された格納完了タイミングＴ２２に対応するカウント値と複製完了タイミングＴ２３に対応するカウント値とを比較することにより行う。
【００４１】
複製先ＤＢ１３への複製が完了していると判断した場合（ステップＳ４０１；ＹＥＳ）、制御装置１４は、データ複製処理を終了する。
【００４２】
複製先ＤＢ１３への複製がまだ完了していないと判別された場合（ステップＳ４０１；ＮＯ）、制御装置１４は、中間ＤＢ１２に格納されたデータを複製先ＤＢ１３にインサートし（ステップＳ４０２）、複製先ＤＢ１３のデータを更新することにより（ステップＳ４０３）、複製元ＤＢ１１のデータを複製先ＤＢ１３に複製する。
【００４３】
複製完了後、制御装置１４は、複製完了タイミングＴ２３をタイマ回路１４１のカウント値と対応付けてフラッシュメモリ１４２の検出テーブル（図２）に上書き保存する（ステップＳ４０４）。
【００４４】
これにより、複製元ＤＢ１１のデータを複製先ＤＢ１３に複製することができる。
【００４５】
前記データ格納動作及びデータ複製動作により、複製元ＤＢ１１のデータを複製先ＤＢ１３に複製する際の、複製元ＤＢ１１に対する占有時間を短縮することができる。また、複製元ＤＢ１１のデータの中間ＤＢ１２への格納が完了していれば、データ複製動作においてエラーが発生しても、再度複製元ＤＢ１１を占有しなくてもよい。
【００４６】
なお、本発明は、上記実施の形態に限定されず、種々の変形及び応用が可能である。上記実施の形態は、データベース複製システム１に関するものであるが、複製されるデータはデータベースのデータに限られず、音楽データや画像データ等様々なデータに関しても適用可能である。
【００４７】
上記実施の形態のデータベース複製システム１の中間ＤＢ１２及び複製先ＤＢ１３は複数あってもよい。
【００４８】
また、データ格納動作及びデータ複製動作の開始タイミングは任意であり、設定により変更可能である。さらに、手動でデータ格納動作及びデータ複製動作を開始することもできる。またさらに、データ格納動作及びデータ複製動作を常時稼働させることもできる。
【００４９】
さらにまた、データ格納動作とデータ複製動作とを別動作にせず、図５に示すように一連の動作にすることもできる。この場合でも別途、データ格納動作とデータ複製動作とを開始することができるようにしてもよい。
【００５０】
【発明の効果】
本発明により、複製元データ処理システムに記憶されたデータを複製先データ処理システムに複製する際のデータ複製元データ処理システムの占有時間を短縮することができる。
【図面の簡単な説明】
【図１】本発明の実施の形態のデータベース複製システムの構成を示すブロック図である。
【図２】更新タイミングと格納完了タイミングと複製完了タイミングとの先後を判別するための検出テーブルのフォーマット図である。
【図３】更新データを中間ＤＢに格納させるデータ格納動作のフローチャート図である。
【図４】複製元ＤＢのデータを複製先ＤＢに複製させるデータ複製動作のフローチャート図である。
【図５】データ格納動作及びデータ複製動作を一連の動作にした場合のフローチャート図である。
【符号の説明】
１　　　データベース複製システム
１１　　複製元データベース
１２　　中間データベース
１３　　複製先データベース
１４　　制御装置
１４１　タイマ回路
１４２　フラッシュメモリ
【図１】
2004139453.tif 000003
【図２】
2004139453.tif 000004
【図３】
2004139453.tif 000005
【図４】
2004139453.tif 000006
【図５】
2004139453.tif 000007