(57)【要約】【課題】  利用者にかかる負担を最小限にし、段階的にデータベースを統合する。【解決手段】  第１データベースのバックアップに基づいて、初期移行データを作成し、これを第１領域に移行する。次に、第１データベースの初期移行の時点から後の差分を、第１領域に反映する。その後、統合データベースシステムに業務の実行を切り替える。次に、第１領域のバックアップを、第２領域に作成する。続けて、第２ｎデータベースのバックアップに基づいて、初期移行データを作成し、第２領域に、これを移行する。続けて、第１領域における差分データ及び第２ｎデータベースにおける初期移行の時点から後の差分を、第２領域に反映する。また、第１領域が行っていた業務、及び、第２ｎデータベースが行っていた業務の実行を第２領域に切り替える。全てのデータベースシステムからの移行が終了するまで、同様の動作を繰り返す。【選択図】  図７
2008250733.tif 000002
【特許請求の範囲】
【請求項１】
稼動中の複数の移行前データベースを１つの移行後データベースに段階的に移行するデータベース移行方法であって、
前記複数の移行前データベース中の第１データベースの第１の時点におけるバックアップデータから抽出された第１抽出データを、前記移行後データベースの第１領域に移行する第１段階移行工程と；
前記第１データベースに対して前記第１の時点以降に更新されたデータである第１個別更新データを、前記第１領域に反映する第１段階差分更新工程と；
前記第１データベースを利用して行われていた業務の実行領域を、前記移行後データベースの第１領域に切り替える第１段階切替工程と；
前記第１段階差分更新工程が終了し、かつ、前記第１段階切替工程が終了した後の第２の時点における前記第１領域のバックアップデータを、前記移行後データベースの第２領域に作成する第１統合複製工程と；
前記複数の移行前データベース中の第２データベースの第３の時点におけるバックアップデータから抽出された第２抽出データを、前記第２領域に移行する第２段階移行工程と；
前記第１領域における前記第２の時点以降に更新されたデータである第１移行後更新データ及び前記第２データベースにおける前記第３の時点以降に更新されたデータである第２個別更新データを、前記第２領域に反映する第２段階差分更新工程と；
前記第１段階切替工程で切り替えられた業務、及び、前記第２データベースを利用して行われていた業務の実行領域を、前記第２領域に切り替える第２段階切替工程と；
を備えるデータベース移行方法。
【請求項２】
前記第１段階切替工程は、前記第１段階差分更新工程の終了後に行われ、
前記第２段階切替工程は、前記第２段階差分更新工程の終了後に行われる、
ことを特徴とする請求項１に記載のデータベース移行方法。
【請求項３】
前記第１段階切替工程は、前記第１段階差分更新工程の途中段階で行われ、
前記第２段階切替工程は、前記第２段階差分更新工程の途中段階で行われる、
ことを特徴とする請求項１に記載のデータベース移行方法。
【請求項４】
前記第１抽出データにおける複数の第１レコードのそれぞれには、前記第１段階差分更新工程において前記第１レコードのそれぞれの特定を可能とする第１差分更新用識別子が付与され、前記第１段階移行工程では、前記第１レコードのそれぞれに前記移行後データベース用の新たな第１移行後レコード識別子を更に付与し、
前記第２抽出データにおける複数の第２レコードのそれぞれには、前記第２段階差分更新工程において前記第２レコードのそれぞれの特定を可能とする第２差分更新用識別子が付与され、前記第２段階移行工程では、前記第２レコードのそれぞれに前記移行後データベース用の新たな第２移行後レコード識別子を更に付与する、
ことを特徴とする請求項１〜３のいずれか一項に記載のデータベース移行方法。
【請求項５】
前記第１段階差分更新工程は、
前記第１個別更新データにおける第１更新レコードに対応する第１対応レコードが前記第１領域に既に存在するか否かを判定する第１判定工程と；
前記第１判定工程における判定の結果が肯定的であった場合には、前記第１更新レコードに基づいて前記第１対応レコードを更新し、前記第１判定工程における判定の結果が否定的であった場合には、新たな第１更新レコード識別子が付与された前記第１更新レコードを前記第１領域に格納する第１更新工程と；を備え、
前記第２段階差分更新工程は、
前記第２個別更新データにおける第２更新レコードに対応する第２対応レコードが前記第２領域に既に存在するか否かを判定する第２判定工程と；
前記第２判定工程における判定の結果が肯定的であった場合には、前記第２更新レコードに基づいて前記第２対応レコードを更新し、前記第２判定工程における判定の結果が否定的であった場合には、新たな第２更新レコード識別子が付与された前記第２更新レコードを前記第２領域に格納する第２更新工程と；を備える、
ことを特徴とする請求項４に記載のデータベース移行方法。
【請求項６】
前記第２段階切替工程の開始後の第４の時点における前記第２領域のバックアップデータを、前記第１領域に作成する第２統合複製工程と；
前記複数の移行前データベース中の第３データベースの、第５の時点におけるバックアップデータから抽出された第３抽出データを、前記第１領域に移行する第３段階移行工程と；
前記第２領域における前記第４の時点以降に更新されたデータである第２移行後更新データ及び前記第３データベースにおける前記第５の時点以降に更新されたデータである第３個別更新データを、前記第１領域に反映する第３段階差分更新工程と；
前記第２段階切替工程で切り替えられた業務、及び、前記第３データベースを利用して行われていた業務の実行領域を、前記第１領域に切り替える第３段階切替工程と；
を更に備えることを特徴とする請求項１〜５のいずれか一項に記載のデータベース移行方法。
【請求項７】
複数の移行前データベースが移行される移行後データベースを有するデータベースシステムであって、
前記複数の移行前データベース中の第１データベースの第１の時点におけるバックアップデータから抽出された第１抽出データを、前記移行後データベースの第１領域に移行する第１段階移行手段と；
前記第１データベースに対して前記第１の時点以降に更新されたデータである第１個別更新データを、前記第１領域に反映する第１段階差分更新手段と；
前記第１データベースを利用して行われていた業務の実行領域を、前記第１領域に切り替える第１段階切替手段と；
前記第１段階差分更新手段による処理が完了し、かつ、前記第１段階切替手段による処理終了後の第２の時点における、前記第１領域のバックアップデータを、前記移行後データベースの第２領域に作成する第１統合複製手段と；
前記複数の移行前データベース中の第２データベースの第３の時点におけるバックアップデータから抽出された第２抽出データを、前記第２領域に移行する第２段階移行手段と；
前記第１領域における前記第２の時点以降に更新されたデータである第１移行後更新データ、及び、前記第２データベースにおける前記第３の時点以降に更新されたデータである第２個別更新データを、前記第２領域に反映する第２段階差分更新手段と；
前記第１段階切替手段により切り替えられた業務、及び、前記第２データベースを利用して行われていた業務の実行領域を、前記第２領域に切り替える第２段階切替手段と；
を備えるデータベースシステム。
【請求項８】
前記第１段階切替手段による処理は、前記第１段階差分更新手段による処理完了後に行われ、
前記第２段階切替手段による処理は、前記第２段階差分更新手段による処理完了後に行われる、ことを特徴とする請求項７に記載のデータベースシステム。
【請求項９】
前記第１段階切替手段による処理は、前記第１段階差分更新手段による処理の途中段階で行われ、
前記第２段階切替手段による処理は、前記第２段階差分更新手段による処理の途中段階で行われる、ことを特徴とする請求項７に記載のデータベースシステム。
【請求項１０】
前記第２段階切替手段による処理開始後の第４の時点における、前記第２領域のバックアップデータを前記第１領域に作成する第２統合複製手段と；
前記複数の移行前データベース中の第３データベースの、第５の時点におけるバックアップデータから抽出された第３抽出データを、前記第１領域に移行する第３段階移行手段と；
前記第２領域における前記第４の時点以降に更新されたデータである第２移行後更新データ、及び、前記第３データベースにおける前記第５の時点以降に更新されたデータである第３個別更新データを、前記第１領域に反映する第３段階差分更新手段と；
前記第２段階切替手段により切り替えられた業務、及び、前記第３データベースを利用して行われていた業務の実行領域を、前記第１領域に切り替える第３段階切替手段と；
を更に備えることを特徴とする、請求項７〜９のいずれか一項に記載のデータベースシステム。
【請求項１１】
前記第３段階切替手段による処理は、前記第３段階差分更新手段による処理終了後に行われる、ことを特徴とする請求項１０に記載のデータベースシステム。
【請求項１２】
前記第３段階切替手段による処理は、前記第３段階差分更新手段による処理の途中段階で行われる、ことを特徴とする請求項１０に記載のデータベースシステム。
【請求項１３】
請求項１〜６のいずれか一項に記載のデータベース移行方法を、演算装置に実行させるデータベース移行プログラム。
【発明の詳細な説明】
【技術分野】
【０００１】
本発明は、データベース移行方法、データベースシステム及びデータベース移行プログラムに係り、より詳しくは、稼動中の複数の移行前データベースを１つの移行後データベースに段階的に移行するデータベース移行方法、当該データベース移行方法により構築されるデータベースシステム、及び当該データベース移行方法を演算装置に実行させるデータベース移行プログラムに関するものである。
【背景技術】
【０００２】
従来から、様々な情報システムの分野において、データベースが広く用いられている。データベースはごく小規模なものから、場合によっては、銀行情報のデータベースや電話回線情報のデータベース等のような大規模なものが存在している。
【０００３】
このような様々な規模のデータベースの内の大規模なデータベースを新システムへ移行するといった場合には、移行に時間がかかってしまう。この点を解決するため、通常運用におけるバックアップを用いて、利用者に不便をかけずに移行を完了するための方法が、以下の特許文献１（以下、「従来例」という）に記載されている。この従来例の技術では、バックアップデータを用いてデータを移行し、バックアップを行った時点以降における旧システムの運用停止までに生じた差分を後から反映させるようにし、当該差分の反映期間という短い期間だけシステムとしての利用者へのサービス提供を停止させるようにしている。
【特許文献１】特開２００４−１３９２１７
【発明の開示】
【発明が解決しようとする課題】
【０００４】
ここで、例えば、サービスの都合上であったり、会社の合併であったりといった理由で、複数に分散して存在したデータベースを統合するような場合には、単純にデータ移行するだけではデータの整合性が保たれなくなってしまう。また、それが上述した銀行や電話回線のような大規模なサービスにおいては、従来例のように、ある時点におけるバックアップデータを移行した後に、旧システム全ての運用停止までの差分を送信して反映するとしても、反映のために多くの時間が必要となり、システム運用の停止時間が長くなってしまう。
【０００５】
このようにシステム運用の停止時間が長くなると、利用者に不便をかけることになってしまう。このため、複数に分散している大規模なデータベースを統合する際に、システム業務の停止時間を極力短くできる技術が待望されている。
【０００６】
本発明は、上記の点を鑑みてなされたものであり、システム業務の停止による利用者にかかる不便さを抑制することができるデータベース移行方法、当該データベース移行方法の実施に際して採用することができるデータベースシステム、及び当該データベース移行方法を演算装置に実行させるデータベース移行プログラムを提供することを目的とする。
【課題を解決するための手段】
【０００７】
本発明は、第１の観点からすると、稼動中の複数の移行前データベースを１つの移行後データベースに段階的に移行するデータベース移行方法であって、前記複数の移行前データベース中の第１データベースの第１の時点におけるバックアップデータから抽出された第１抽出データを、前記移行後データベースの第１領域に移行する第１段階移行工程と；前記第１データベースに対する前記第１の時点以降に更新されたデータである第１個別更新データを、前記第１領域に反映する第１段階差分更新工程と；前記第１データベースを利用して行われていた業務の実行領域を、前記移行後データベースの第１領域に切り替える第１段階切替工程と；前記第１段階差分更新工程が終了し、かつ、前記第１段階切替工程が終了した後の第２の時点における前記第１領域のバックアップデータを、前記移行後データベースの第２領域に作成する第１統合複製工程と；前記複数の移行前データベース中の第２データベースの第３の時点におけるバックアップデータから抽出された第２抽出データを、前記第２領域に移行する第２段階移行工程と；前記第１領域における前記第２の時点以降に更新されたデータである第１移行後更新データ及び前記第２データベースにおける前記第３の時点以降に更新されたデータである第２個別更新データを、前記第２領域に反映する第２段階差分更新工程と；前記第１段階切替工程で切り替えられた業務、及び、前記第２データベースを利用して行われていた業務の実行領域を、前記第２領域に切り替える第２段階切替工程と；を備えるデータベース移行方法である。
【０００８】
ここで、「第１データベース」及び「第２データベース」とは、移行対象となる複数のデータベースの一部を意味する。すなわち、「第１データベース」又は「第２データベース」は、１つのデータベースであってもよいし、２以上のデータベースであってもよい。本明細書においては、この意味で「第１データベース」及び「第２データベース」の用語を用いるものとする。
【０００９】
このデータベース移行方法では、まず、第１段階移行工程において、複数の移行前データベースにおける第１データベースの第１の時点におけるバックアップデータから抽出された第１抽出データを、移行後データベースの第１領域に移行する。
【００１０】
次に、第１段階差分更新工程において、第１データベースにおける第１の時点以降に更新されたデータである第１個別更新データを、第１領域に反映する。引き続き、第１段階切替工程において、第１データベースを利用して行われていた業務の実行領域を、移行後データベースの第１領域に切り替える。つまり、第１データベースが行っていた業務に関して稼動するデータベースが、第１データベースから移行後データベースに変更される。
【００１１】
次いで、第１段階差分更新工程が終了し、かつ、第１段階切替工程が終了した後の第２の時点における第１領域のバックアップデータが、第１統合複製工程において、移行後データベースの第２領域に作成される。これは、現在業務に利用されている領域である第１領域とは別に、他のデータベース移行用領域として第２領域を使うためである。
【００１２】
次に、第２段階移行工程において、複数の移行前データベース中の第２データベースの第３の時点におけるバックアップデータから抽出された第２抽出データを、第２領域に移行する。
【００１３】
次に、第２段階差分更新工程において、第１領域における第２の時点以降に更新されたデータである第１移行後更新データ及び第２データベースにおける第３の時点以降に更新されたデータである第２個別更新データを、第２領域に反映する。つまり、第２データベースにおける第３の時点から第２データベースシステムの稼動終了までに第２データベースに生じた差分を、キー項目等を考慮しつつ、第２領域に反映する。また、第２の時点以降に、第１領域において生じた差分を、第２領域に反映する。
【００１４】
そして、第２段階切替工程において、第１段階切替工程で切り替えられた業務、及び、第２データベースを利用して行われていた業務の実行領域を、第２領域に切り替える。つまり、第２データベースの機能が、新たに以降後データベースに移行する。
【００１５】
このように、移行前のデータベースごとに、まず、業務運用中に、当該移行前のデータベースのバックアップデータを移行後データベースに移行する。この後、当該バックアップデータの作成後、移行前のデータベースごとにおける業務運用終了までのデータベース更新データである差分データを移行後データベースへ移行後、又は、移行しつつ、移行後データベースが、順次、移行前のデータベースの業務運用停止後に当該業務運用を開始する。このため、移行前の各データベースが行っていた業務の停止時間を、利用者から見た場合に、従来の移行方法と比べて短くすることができる。
【００１６】
なお、本発明のデータベース移行方法においては、複数の移行前データベースと移行後データベースがそれぞれ個別のシステムであって通信等を介して移行する場合に適用することもできるし、複数の移行前データベースと移行後データベースとが同一のシステム内に存在する場合にも適用することができる。
【００１７】
したがって、本発明のデータベース移行方法によれば、利用者への提供業務の停止により利用者にかかる不便さを抑制しつつ、複数のデータベースを移行後データベースへ移行することができる。
【００１８】
本発明のデータベース移行方法では、前記第１段階切替工程が、前記第１段階差分更新工程の終了後に行われ、前記第２段階切替工程が、前記第２段階差分更新工程の終了後に行われるようにすることもできるし、前記第１段階切替工程が、前記第１段階差分更新工程の途中段階で行われ、前記第２段階切替工程が、前記第２段階差分更新工程の途中段階で行われるようにすることもできる。
【００１９】
本発明のデータベース移行方法では、前記第１抽出データにおける複数の第１レコードのそれぞれには、前記第１段階差分更新工程において前記第１レコードのそれぞれの特定を可能とする第１差分更新用識別子が付与され、前記第１段階移行工程では、前記第１レコードのそれぞれに前記移行後データベース用の新たな第１移行後レコード識別子を更に付与し、前記第２抽出データにおける複数の第２レコードのそれぞれには、前記第２段階差分更新工程において前記第２レコードのそれぞれの特定を可能とする第２差分更新用識別子が付与され、前記第２段階移行工程では、前記第２レコードのそれぞれに前記移行後データベース用の新たな第２移行後レコード識別子を更に付与する、とすることができる。
【００２０】
この場合には、移行後データベース用の新たなレコード識別子を移行前データベースが複数あることに対応して付与することにより、移行後データベースにおいて各移行データを一意とすることを簡易に実現することができる。また、抽出したそれぞれのデータを基に差分更新用の差分更新用識別子を付与することにより、移行当初における移行前データベースのバックアップデータを移行後データベースへ移行した後に、移行前データベースに発生した更新分である差分を容易に反映させることができる。
【００２１】
本発明のデータベース移行方法では、前記第１段階差分更新工程が、前記第１個別更新データにおける第１更新レコードに対応する第１対応レコードが前記第１領域に既に存在するか否かを判定する第１判定工程と；前記第１判定工程における判定の結果が肯定的であった場合には、前記第１更新レコードに基づいて前記第１対応レコードを更新し、前記第１判定工程における判定の結果が否定的であった場合には、新たな第１更新レコード識別子が付与された前記第１更新レコードを前記第１領域に格納する第１更新工程と；を備え、前記第２段階差分更新工程が、前記第２個別更新データにおける第２更新レコードに対応する第２対応レコードが前記第２領域に既に存在するか否かを判定する第２判定工程と；前記第２判定工程における判定の結果が肯定的であった場合には、前記第２更新レコードに基づいて前記第２対応レコードを更新し、前記第２判定工程における判定の結果が否定的であった場合には、新たな第２更新レコード識別子が付与された前記第２更新レコードを前記第２領域に格納する第２更新工程と；を備える、とすることができる。この場合には、第１及び第２個別差分データを移行後データベースに適切に反映することができる。
【００２２】
また、本発明のデータベース移行方法では、前記第２段階切替工程の開始後の第４の時点における前記第２領域のバックアップデータを前記第１領域に作成する第２統合複製工程と；前記複数の移行前データベース中の第３データベースの第５の時点におけるバックアップデータから抽出された第３抽出データを、前記第１領域に移行する第３段階移行工程と；前記第２領域における前記第４の時点以降に更新されたデータである第２移行後更新データ及び前記第３データベースにおける前記第５の時点以降に更新されたデータである第３個別更新データを、前記第１領域に反映する第３段階差分更新工程と；前記第２段階切替工程で切り替えられた業務、及び、前記第３データベースを利用して行われていた業務の実行領域を、前記第１領域に切り替える第３段階切替工程と；を更に備えるとすることができる。
【００２３】
上記の第２段階切替工程の後において更にデータベースの移行を進める必要がある場合には、まず、第２統合複製工程において、第２機能実行工程の開始後の第４の時点で、第２領域におけるデータの複製を移行後データベースの第１領域に作成する。現在、第２領域を業務運用に利用しており、第１領域は業務運用に利用していないので、複製先として第１領域を使用する。
【００２４】
次に、第３段階移行工程において、複数の移行前データベース中の第３データベースの第５の時点における、バックアップデータから抽出された第３抽出データを、第１領域に移行する。
【００２５】
次に、第３段階差分更新工程において、第２領域における第４の時点からの第２移行後更新データ及び第３データベースにおける第５の時点以降に更新されたデータである第３個別更新データを、第１領域に反映する。つまり、第３データベースにおける第５の時点から第３データベースの稼動終了までに第３データベースに生じた差分を、キー項目等を考慮しつつ、第１領域に反映する。また、第４の時点からの、第２領域において生じた差分を、第１領域に反映する。
【００２６】
また、第３段階切替工程において、第２段階切替工程で切り替えられた業務、及び、第３データベースを利用して行われていた業務の実行領域を、第１領域に切り替える。つまり、第３データベースの機能が、新たに移行後データベースに移行する。
【００２７】
このようにすることで、複数の移行前データベースからの移行に当たり、第１領域と第２領域をトグル構成にして使用することができる。したがって、資源を有効利用しつつ、簡易な構成でデータ移行を行うことができる。
【００２８】
本発明は、第２の観点からすると、複数の移行前データベースが移行される移行後データベースを有するデータベースシステムであって、前記複数の移行前データベース中の第１データベースの第１の時点におけるバックアップデータから抽出された第１抽出データを、前記移行後データベースの第１領域に移行する第１段階移行手段と；前記第１データベースに対して前記第１の時点以降に更新されたデータである第１個別更新データを、前記第１領域に反映する第１段階差分更新手段と；前記第１データベースを利用して行われていた業務の実行領域を、前記第１領域に切り替える第１段階切替手段と；前記第１段階差分更新手段による処理が完了し、かつ、前記第１段階切替手段による処理終了後の第２の時点における、前記第１領域のバックアップデータを、前記移行後データベースの第２領域に作成する第１統合複製手段と；前記複数の移行前データベース中の第２データベースの第３の時点におけるバックアップデータから抽出された第２抽出データを、前記第２領域に移行する第２段階移行手段と；前記第１領域における前記第２の時点以降に更新されたデータである第１移行後更新データ、及び、前記第２データベースにおける第３の時点以降に更新されたデータである第２個別更新データを、前記第２領域に反映する第２段階差分更新手段と；前記第１段階切替手段により切り替えられた業務、及び、前記第２データベースを利用して行われていた業務の実行領域を、前記第２領域に切り替える第２段階切替手段と；を備えるデータベースシステムである。
【００２９】
この移行後データベースでは、複数の移行前データベースにおける第１データベースの第１の時点において抽出された第１抽出データを受けると、第１段階移行手段が、第１抽出データを、移行後データベースの第１領域に移行する。この後、第１データベースの第１の時点からの第１個別更新データを第１データベースから受けると、第１段階差分更新手段が、当該更新データを第１領域に反映する。
【００３０】
かかる第１段階差分更新手段による当該更新データの第１領域への反映の完了後、あるいは反映中に、第１段階切替手段が、第１領域を業務利用領域とする移行後データベースに、第１データベースを利用して行われていた業務の実行を切り替える。つまり、第１データベースを利用して行われていた業務に関して、利用されるデータベースが、第１データベースから移行後データベースに変更される。
【００３１】
次に、第１段階差分更新手段による処理が終了し、かつ、第１段階切替手段による処理が終了した後の第２の時点における第１領域のバックアップデータを、移行後データベースの第２領域に作成する。引き続き、複数の移行前データベース中の第２データベースの第３の時点におけるバックアップデータから抽出された第２抽出データを受けると、第２段階移行手段が、第２移行データを第２領域に移行する。
【００３２】
続けて、第２段階差分更新手段が、第１領域における第２の時点からの第１移行後更新データ、及び、第２データベースにおける第３の時点からの第２個別更新データを第２領域に反映する。つまり、第２データベースにおける第３の時点から第２データベースの稼動終了までに第２データベースに生じた差分を、キー項目等を考慮しつつ、第２領域に反映する。また、第２の時点から、第１領域において生じた差分を、第２領域に反映する。
【００３３】
そして、第２段階切替手段が、第２領域を業務利用領域とする移行後データベースに、第１段階切替手段により切り替えられた業務、及び、第２データベースを利用して行われていた業務の実行領域を切り替える。つまり、第２データベースの機能が、移行後データベースに移行する。
【００３４】
すなわち、本発明のデータシステムは、上述した本発明のデータベース移行方法を実行する際に必要となるデータベースシステムとしての機能を果たすことができる。したがって、本発明のデータシステムは、本発明のデータベース移行方法の実施に際して採用することができる。
【００３５】
本発明のデータベースシステムでは、前記第１段階切替手段による処理は、前記第１段階差分更新手段による処理完了後に行われ、前記第２段階切替手段による処理は、前記第２段階差分更新手段による処理完了後に行われるようにすることもできるし、前記第１段階切替手段による処理は、前記第１段階差分更新手段による処理の途中段階で行われ、前記第２段階切替手段による処理は、前記第２段階差分更新手段による処理の途中段階で行われるようにすることもできる。
【００３６】
本発明のデータベースシステムは、前記第２段階切替手段による処理開始後の第４の時点における、前記第２領域のバックアップデータを前記移行後データベースの第１領域に作成する第２統合複製手段と；前記複数の移行前データベース中の第３データベースの、第５の時点におけるバックアップデータから抽出された第３抽出データを、前記第１領域に移行する第３段階移行手段と；前記第２領域における前記第４の時点以降に更新されたデータである第２移行後更新データ、及び、前記第３データベースにおける第５の時点以降に更新されたデータである第３個別更新データを、前記第１領域に反映する第３段階差分更新手段と；前記第２段階切替手段により切り替えられた業務、及び、前記第３データベースを利用して行われていた業務の実行領域を、前記第１領域に切り替える第３段階切替手段と；を更に備える、とすることができる。
【００３７】
上記の第２段階切替手段による処理の後において更にデータベースの移行を進める必要がある場合には、第２統合複製手段が、第２段階切替手段による処理開始後の第４の時点における第２領域におけるデータの複製を移行後データベースの第１領域に作成する。すなわち、現在、第２領域を業務運用に利用しており、第１領域は業務運用に利用していないので、複製先として第１領域を使用する。
【００３８】
次に、複数の移行前データベース中の第３データベースの第５の時点における第３データベースの第３個別バックアップデータから抽出された第３抽出データを第１領域に移行する。引き続き、第３段階差分更新手段が、第２領域における第４の時点からの第２統合更新データ、及び、第３データベースにおける第５の時点からの第３個別更新データを、第１領域に反映する。
【００３９】
つまり、第３データベースにおける第５の時点から第３データベースの稼動終了までに第３データベースに生じた差分を、キー項目等を考慮しつつ、第１領域に反映する。また、第４の時点からの、第２領域において生じた差分を、第１領域に反映する。
【００４０】
また、第３段階切替手段が、第１領域を業務利用領域とする移行後データベースに、第２段階切替手段により切り替えられた業務、及び、第３データベースを利用して行われていた業務の実行領域を切り替える。つまり、稼動する領域が、第２領域及び第３データベースから、第１領域に移行する。
【００４１】
このようにすることで、複数の移行前データベースからの移行に当たり、第１領域と第２領域をトグル構成にして使用できる。したがって、資源を有効に使用しつつ、簡易な構成でデータ移行を行うことができる。
【００４２】
ここで、前記第３段階切替手段による処理は、前記第３段階差分更新工程による処理終了後に行われるようにすることもできるし、前記第３段階切替手段による処理は、前記第３段階差分更新手段による処理の途中段階で行われるようにすることもできる。
【００４３】
本発明は、第３の観点からいって、本発明のデータベース移行方法を、演算装置に実行させるデータベース移行プログラムである。
【発明の効果】
【００４４】
以上説明したように、本発明のデータベース移行方法によれば、システム業務の停止による利用者にかかる不便さを抑制することができるという効果を奏する。
【００４５】
また、本発明のデータベースシステムは、本発明のデータベース移行方法の実施に際して採用することができるという効果を奏する。
【００４６】
また、本発明のデータベース移行プログラムは、本発明のデータベース移行の実施に際して採用することができるという効果を奏する。
【発明を実施するための最良の形態】
【００４７】
以下、本発明の実施形態を、図１〜図１１を参照しつつ説明する。なお、これらの図においては、同一又は同等の要素には同一の符号を付し、重複する説明を省略する。
【００４８】
［構成］
図１には、本発明の実施形態であるシステム１の概略図が示されている。この図１に示されるように、システム１は、個別のデータベースシステム群である、データベースシステム１０j（ｊ＝１、２、…Ｎ）と、それらを移行する先である統合データベースシステム１００と、これら全てを接続するネットワーク９０を備えている。データベースシステム１０jのデータベースデータは、ネットワーク９０を介し通信によって統合データベースシステム１００に移行される。
【００４９】
図２には、データベースシステム１０jの構成が示されている。この図２に示されるように、データベースシステム１０jは、業務処理部１９jを備えている。この業務処理部１９jは、内部の記憶領域として、データベース領域１１j、バックアップ領域１２j及び差分領域１３jが用意されている。
【００５０】
この業務処理部１９jは、ネットワークを介したデータベース登録要求に対応して、データベース領域１１j内のデータを更新する。また、業務処理部１９jは、不図示の操作入力手段を用いたオペレータによるデータベース登録要求入力に対応して、データベース領域１１j内のデータを更新する。
【００５１】
このデータベース領域１１j内には、図３Ａに示されるような形式を有する複数のレコードＲＣＤjk（ｋ＝１，２，…）が記憶される。ここで、レコードＲＣＤjkのそれぞれは、データベースシステム１０jごとに固有に付与された個別データベースキー（以下、「個別ＤＢキー」と記す）ＤＤＢＫjkと、レコードデータＲＤＤjkとから構成されている。
【００５２】
図２に戻り、業務処理部１９jは、通常の業務運用の動作において、定期的に、データベース領域１１j内のデータの複製をバックアップ領域１２j内に作成する。また、業務処理部１９jは、後述するスケジューラ１４jからの移行開始指令や、オペレータの指令に応答して、データベース領域１１j内のデータの複製をバックアップ領域１２j内に作成する。
【００５３】
また、業務処理部１９jは、スケジューラ１４jからの移行開始指令を受けると、以後の業務処理におけるデータベース領域１１j内のデータ更新に際して、データベース領域１１j内に格納する更新データを、差分領域１３jにも同時に格納する。さらに、業務処理部１９jは、スケジューラ１４jからの業務停止指令を受けると、以後の業務処理を停止する。
【００５４】
データベースシステム１０jは、スケジューラ１４j、抽出部１５j、差分抽出部１６j、ファイル作成部１７j及び転送部１８jを更に備えている。これらの要素１４j〜１８jは、データベース移行に際して機能を発揮する。
【００５５】
スケジューラ１４jは、データベース移行の際におけるデータベースシステム１０jの動作を制御する。このスケジューラ１４jは、データベース移行のためにデータベースシステム１０jとして行うべき動作の手順を実行する。そして、当該手順に従って、業務処理部１９jへ向けて移行開始指令や、業務停止指令を送るとともに、他の要素に対して、必要な指令を送る。
【００５６】
抽出部１５jは、スケジューラ１４jによる制御のもとで、バックアップ領域１２jにおける格納内容から、移行すべきデータを抽出する。この抽出部１５jは、バックアップ領域１２jにおける格納内容を単に複製するのではなく、データベース移行のためのデータの整理や項目内容のチェック及び変更も行う。なお、抽出部１５jの抽出結果データは、図３Ｂに示されるような形式を有する複数の移行用レコードＴＲＤjp（ｐ＝１，２，…）からなる。ここで、移行用レコードＴＲＤjpのそれぞれは、レコードデータＲＤＤjpと、個別ＤＢキーＤＤＢＫjpと、移行元であるデータベース１０jの識別子（以下、「移行元ＤＢ識別子」と記す）ＯＤＢjとから構成されている。
【００５７】
なお、以下の説明においては、図３Ｂに示されるように、個別ＤＢキーＤＤＢＫjpと移行元ＤＢ識別子とをまとめて、「差分更新用識別子ＤＵＩjp」と呼ぶものとする。この差分更新用識別子ＤＵＩjpを利用することにより、移行用レコードが複数のデータベースシステムから統合データベースシステム１００に移行された後であっても、個々の移行用レコードＴＲＤjpを一意的に特定できる。
【００５８】
差分抽出部１６jは、スケジューラ１４jによる制御のもとで、差分領域１３jにおける格納内容から、移行すべき差分データを抽出する。この差分抽出部１６jにおいても、抽出部１５jの場合と同様に、図３Ｂに示されたレコード形式の抽出結果を得るようになっている。
【００５９】
ファイル作成部１７jは、抽出部１５j又は差分抽出部１６jからデータを受けた場合に、移行ファイルを作成する。このファイル作成部１７jは、転送のためにデータ圧縮を行うようになっている。
【００６０】
転送部１８jは、ファイル作成部１７jから移行ファイルを受けた場合に、ネットワーク９０を介して、当該移行ファイルを統合データベースシステム１００に転送する。
【００６１】
図４には、統合データベースシステム１００の構成が示されている。この図４に示されるように、統合データベースシステム１００は、第１統合複製手段及び第２統合複製手段としても機能する業務処理部１１０（第１統合複製手段、第２統合複製手段）を備えている。この業務処理部１１０は、図５に示されるように、内部の記憶領域として、第１領域１１１、第２領域１１２及び差分領域１１３が用意されている。
【００６２】
この業務処理部１９jは、ネットワークを介したデータベース登録要求に対応して、上記の第１領域１１１及び第２領域１１２のいずれかを業務処理用領域として、当該業務処理用領域内のデータを更新する。また、業務処理部１１０は、不図示の操作入力手段を用いたオペレータによるデータベース登録要求入力に対応して、業務処理用領域内のデータを更新する。
【００６３】
この業務処理用領域内には、図６に示されるような形式を有する複数の統合レコードＩＲＤr（ｒ＝１，２，…）が記憶される。ここで、統合レコードＩＲＤrのそれぞれは、統合データベースシステム１００において固有に付与された統合データベースキー（以下、「統合ＤＢキー」と記す）ＩＤＢＫrと、レコードデータＲＤＤjpと、個別ＤＢキーＤＤＢＫjpと、移行元ＤＢ識別子ＯＤＢjとから構成されている。すなわち、統合レコードＩＲＤrは、移行用レコードＴＲＤjpに統合ＤＢキーＩＤＢＫrが付与されたものとなっている。
【００６４】
なお、移行されたレコードではなく、統合データベースシステム１００において新たに登録されたレコードの場合には、個別ＤＢキーＤＤＢＫjpの部分の内容には意味がなく、例えば「ｎｕｌｌ」データが挿入される。また、移行元ＤＢ識別子ＯＤＢjの部分には統合データベースシステム１００オリジナルのデータである旨の情報が挿入される。
【００６５】
図４に戻り、業務処理部１１０は、データベース移行が完了した後は、通常の業務運用の動作において、定期的に、第１領域１１１及び第２領域１１２の一方である業務処理用領域内のデータの複製を、第１領域１１１及び第２領域１１２の一方である他方のバックアップ領域に作成する。かかるデータベース移行の完了報告（以下、「移行完了報告」と記す）は、後述するスケジューラ１２０が業務処理部１１０に報告するようになっている。
【００６６】
また、業務処理部１１０は、データベース移行が完了する前である移行途中段階においては、複製元領域及び複製先領域を指定したスケジューラ１２０からの複製指令に従って、複製データを複製先領域内に作成する。また、業務処理部１１０は、データベース移行が完了する前である移行途中段階においては、業務処理部１１０が行った業務処理に伴う業務処理用領域内のデータ更新に際して、当該業務処理用領域内に格納する更新データ（統合更新データ）を差分領域１１３にも格納する。
【００６７】
さらに、業務処理部１１０は、データベース移行が完了する前である移行途中段階において、第１領域１１１及び第２領域１１２のいずれかの領域を業務処理用領域として指定した業務切替指令をスケジューラ１２０から受けると、指定された業務処理用領域を利用した業務処理を開始する。
【００６８】
なお、業務処理部１１０は、データベース移行の完了の前後にかかわらず、不図示の操作入力手段を用いたオペレータによるデータベース登録要求入力や複製作成要求入力に対応して、業務処理用領域内のデータ更新や、バックアップ領域内における複製データの作成を行う。
【００６９】
図４に示されるように、統合データベースシステム１００は、スケジューラ１２０（第１段階切替手段、第２段階切替手段、第３段階切替手段）と、受信部１３０と、ファイル取得部１４０とを備えている。また、統合データベースシステム１００は、移行部１５０（第１段階移行手段、第２段階移行手段、第３段階移行手段）と、差分更新部１６０（第１段階差分更新手段、第２段階差分更新手段の一部、第３段階差分更新手段の一部）と、差分抽出部１７０（第２段階差分更新手段の一部、第３段階差分更新手段の一部）とを更に備えている。これらの要素１２０〜１７０は、データベース移行に際して機能を発揮する。
【００７０】
スケジューラ１２０は、データベース移行の際における統合データベースシステム１００の動作を制御する。このスケジューラ１２０は、データベース移行のために統合データベースシステム１００として行うべき動作の手順を実行する。そして、当該手順に従って、業務処理部１１０へ向けて、上記の複製指令、業務切替指令、移行完了報告を送るとともに、他の要素に対して、必要な指令を送る。
【００７１】
受信部１３０は、データベースシステム１０jから送信された移行ファイルデータを、ネットワーク９０を介して受信する。そして、受信された移行ファイルデータをファイル取得部１４０へ送る。
【００７２】
ファイル取得部１４０は、受信部１３０からの移行ファイルデータを受けると、当該移行ファイルを解凍する。その後、移行ファイルが通常の移行ファイルか差分移行ファイルかに応じて、解凍された移行ファイルを移行部１５０又は差分更新部１６０に振り分けて送る。すなわち、移行ファイルが通常の移行ファイルである場合には、ファイル取得部１４０は、解凍された移行ファイルを移行部１５０へ送る。一方、移行ファイルが差分移行ファイルである場合には、ファイル取得部１４０は、解凍された移行ファイルを差分更新部１６０へ送る。
【００７３】
移行部１５０は、スケジューラ１２０による制御のもとで、ファイル取得部１４０からの移行ファイルに含まれるデータを第１領域１１１又は第２領域１１２へ移行する。なお、移行先の領域は、スケジューラ１２０により指定される。
【００７４】
かかるデータ移行に際して、移行部１５０は、まず、受信した移行ファイル内の各移行用レコードＴＲＤjpについて、統合データベースシステム１００において一意とするための識別子である統合ＤＢキーＩＤＢＫrを付与して、新たな統合レコードＩＲＤrを作成する。そして、移行部１５０は、指定された移行先領域に新たな統合レコードＩＲＤrを登録する。
【００７５】
差分更新部１６０は、スケジューラ１２０による制御のもとで、ファイル取得部１４０からの差分移行ファイルに含まれるデータ、及び、差分抽出部１７０による抽出結果を第１領域１１１又は第２領域１１２に反映する。なお、反映先の領域は、スケジューラ１２０により指定される。
【００７６】
かかるデータ反映のうち、差分移行ファイルに含まれるデータの反映に際しては、移行部１５０は、まず、差分移行ファイル内の各移行用レコードＴＲＤjpにおける差分更新用識別子ＤＵＩjpと同一の差分更新用識別子を有する統合レコードが既に存在するか否かを判定する。この判定が肯定的であった場合には、移行部１５０は、該当する統合レコードにおけるレコードデータを差分移行ファイル内の移行用レコードＴＲＤjpのレコードデータＲＤＤjpの内容に変更する。一方、当該判定が否定的であった場合には、移行部１５０は、差分移行ファイル内の各移行用レコードＴＲＤjpに新たな統合ＤＢキーＩＤＢＫrを付与して、新たな統合レコードＩＲＤrを作成する。そして、反映先の領域に新たな統合レコードＩＲＤrを登録する。
【００７７】
また、差分抽出部１７０による抽出結果の反映に際しては、移行部１５０は、まず、当該抽出結果における統合ＤＢキーＩＤＢＫrと同一の統合ＤＢキーを有する統合レコードが既に存在するか否かを判定する。この判定が肯定的であった場合には、移行部１５０は、該当する統合レコードにおけるレコードデータを抽出結果の統合レコードＴＲＤrのレコードデータＲＤＤjpの内容に変更する。一方、当該判定が否定的であった場合には、移行部１５０は、抽出結果の統合レコードＩＲＤrを、反映先の領域に登録する。
【００７８】
差分抽出部１７０は、スケジューラ１２０による制御のもとで、差分領域１１３から、スケジューラ１２０において設定された時点より後の更新内容を抽出する。この抽出結果は、差分更新部１６０へ送られる。
【００７９】
［動作］
次に、以上のように構成されたシステム１におけるデータベース移行について説明する。このデータベース移行の処理では、データベースシステム１０j（ｊ＝１，２，…，Ｎ）のそれぞれにおけるデータベースを、段階的に統合データベースシステム１００へ移行する。
【００８０】
前提として、当初はデータベースシステム１０jのそれぞれが、業務処理を行っているものとする。また、当初は、統合データベースシステム１００が業務処理を行っていないものとする。
【００８１】
かかるデータベース移行の処理では、図７に示されるように、まず、ステップＳ０１において、データベースシステム１０1における第１データベースを統合データベースシステム１００へ移行する。この第１データベース移行処理では、図８に示されるように、まず、ステップＳ１１において、第１データベースに関する初期データ移行が行われる。
【００８２】
かかる初期データ移行に際しては、図９のステップＳ２１において、まず、データベースシステム１０1における業務処理部１９1が、スケジューラ１４1からの複製指令に従って、データベース領域１１1内データの複製をバックアップ領域１２1内に作成する。引き続き、スケジューラ１４1からの抽出指令を受けた抽出部１５1が、バックアップ領域１２1内データに基づいて、統合データベースシステム１００へ移行すべきデータである移行データを抽出する。かかる抽出に際して抽出部１５1は、バックアップ領域１２1内の複数のレコードＲＣＤ1k（ｋ＝１，２，…）（図３Ａ参照）に基づいて、少なくとも１つの移行用レコードＴＲＤ1p（ｐ＝１，２，…）（図３Ｂ参照）を作成する。かかる抽出結果は、ファイル作成部１７1へ送られる。
【００８３】
次に、ステップＳ２２において、抽出部１５1による抽出結果を受けたファイル作成部１７1が、移行用レコードＴＲＤ1pを含むファイルを作成した後にデータ圧縮を施して、通常移行ファイルを作成する。この通常移行ファイルは、転送部１８1へ送られる。引き続き、移行ファイルを受けた転送部１８1は、ネットワーク９０を介して、当該通常移行ファイルを統合データベースシステム１００へ向けて送る。
【００８４】
データベースシステム１０1からの通常移行ファイルを受けた統合データベースシステム１００では、ステップＳ２３において、当該通常移行ファイル内データの第１領域１１１への登録処理が行われる。このステップＳ２３の処理では、図１０に示されるように、まず、受信処理が行われる。この受信処理では、まず、統合データベースシステム１００における受信部１３０が、ステップＳ２６において送信された通常移行ファイルを受信する。すると、受信部１３０はこれをファイル取得部１４０に送信する。引き続き、ファイル取得部１４０が、通常移行ファイルを解凍する。そして、ファイル取得部１４０が、受信した移行ファイルが差分移行ファイルであるか否かを判定する。ここでは、差分移行ファイルではない通常移行ファイルであるので、判定の結果は否定的なものとなり、ファイル取得部１４０は、通常移行ファイルを移行部１５０へ送る。
【００８５】
通常移行ファイルを受けた移行部１５０は、ステップＳ２７において、当該通常移行ファイル中の全レコードが処理済か否かを判定される。この判定の結果が肯定的なものであった場合は、ステップＳ２３が終了し、この結果としてステップＳ１１の処理が終了する。
【００８６】
ステップＳ２７における判定の結果が否定的であった場合には、移行部１５０は、ステップＳ２８において、当該通常移行ファイル中の各レコードについて、統合ＤＢキーを付与して、統合レコードを作成する。引き続き、ステップＳ２９において、移行部１５０は、作成された統合レコードを第１領域１１１に登録する。そして、処理はステップＳ２７へ戻る。
【００８７】
以後、ステップＳ２７における判定の結果が肯定的となるまで、ステップＳ２７〜Ｓ２９の処理が繰り返される。そして、当該移行ファイル中の全レコードが処理済となると、上述したように、ステップＳ２３が終了し、この結果としてステップＳ１１の処理が終了する。こうして、ステップＳ１１の処理が終了すると、処理は、図８のステップＳ１２へ進む。
【００８８】
ステップＳ１２では、所定のタイミングでデータベースシステム１０1による業務処理を停止させた後、先のバックアップ領域１２1内への複製作成の時点からデータベースシステム１０1による業務処理の停止までの期間に発生した第１データベースの更新分である差分データの統合データベースに反映する。
【００８９】
かかる差分データ反映処理では、図１１のステップＳ３１において、まず、スケジューラ１４1からの抽出指令を受けた差分抽出部１６1が、差分領域１３1内データに基づいて、統合データベースシステム１００へ反映すべきデータである差分データを抽出する。かかる抽出に際して差分抽出部１６1は、上述のステップＳ２１における抽出部１５1の場合と同様にして、差分反映用レコードを作成する。かかる抽出結果は、ファイル作成部１７1へ送られる。
【００９０】
次に、ステップＳ３２において、差分抽出部１６1による抽出結果を受けたファイル作成部１７1が、差分反映用レコードを含むファイルを作成した後にデータ圧縮を施して、差分移行ファイルを作成する。この差分移行ファイルは、転送部１８1へ送られる。引き続き、差分ファイルを受けた転送部１８1は、ネットワーク９０を介して、当該差分移行ファイルを統合データベースシステム１００へ向けて送る。
【００９１】
データベースシステム１０1からの差分移行ファイルを受けた統合データベースシステム１００では、ステップＳ３３において、当該差分移行ファイル内データの第１領域１１１への反映処理が行われる。このステップＳ３３の処理では、図１２に示されるように、まず、受信処理が行われる。この受信処理では、まず、統合データベースシステム１００における受信部１３０が、ステップＳ３４において送信された差分移行ファイルを受信する。すると、受信部１３０はこれをファイル取得部１４０に送信する。引き続き、ファイル取得部１４０が、差分移行ファイルを解凍する。そして、ファイル取得部１４０が、受信した移行ファイルが差分移行ファイルであるか否かを判定する。ここでは、差分移行ファイルであるので、判定の結果は肯定的なものとなり、ファイル取得部１４０は、差分移行ファイルを差分更新部１６０へ送る。
【００９２】
通常移行ファイルを受けた差分更新部１６０は、ステップＳ３５において、当該差分移行ファイル中の全レコードが処理済か否かを判定される。この判定の結果が肯定的なものであった場合は、ステップＳ２３が終了し、この結果としてステップＳ３３の処理が終了し、従ってステップＳ０１の処理が終了する。
【００９３】
ステップＳ３５における判定の結果が否定的なものであった場合には、処理はステップＳ３６に進む。このステップＳ３６では、差分更新部１６０は、差分移行ファイル中の各レコードについて、対応する統合レコードが第１領域１１１に存在するか否かを判定する。かかる判定に際して、差分更新部１６０は、差分移行ファイル内の各移行用レコードにおける差分更新用識別子と同一の差分更新用識別子を有する統合レコードが既に存在していない新規データであるか否かを判定する。
【００９４】
ステップＳ３６における判定の結果が肯定的であった場合には、処理はステップＳ３７へ進む。このステップＳ３７では、当該差分移行ファイル中の各レコードについて、統合ＤＢキーを付与して、統合レコードを作成する。引き続き、ステップＳ３８において、移行部１５０は、作成された統合レコードを第１領域１１１に登録する。そして、処理はステップＳ３５へ戻る。
【００９５】
ステップＳ３６における判定の結果が否定的であった場合には、処理はステップＳ３９へ進む。このステップＳ３９では、当該差分移行ファイル中の各レコードに対応する既存の統合レコードにおけるレコードデータ部分を、差分移行ファイル中の各レコードにおけるレコードデータ部分の内容に更新する。そして処理はステップＳ３５へ戻る。
【００９６】
以後、ステップＳ３５における判定の結果が肯定的となるまで、ステップＳ３５〜Ｓ３９の処理が繰り返される。そして、当該移行ファイル中の全レコードが処理済となると、上述したように、ステップＳ３３が終了し、この結果としてステップＳ０１の処理が終了する。こうして、ステップＳ０１の処理が終了すると、処理は、図７のステップＳ０２へ進む。
【００９７】
ステップＳ０２では、第１業務切換処理が行われる。この第１業務切換処理では、まず、スケジューラ１２０が、第１領域１１１を業務処理用領域に指定した業務切替指令を業務処理部１１０へ送る。この業務切替指令を受けた業務処理部１１０は、第１領域１１１を利用した業務処理を開始する。この結果、データベースシステム１０1が行っていた業務処理の実行が、統合データベースシステム１００による実行に切り替わる。
【００９８】
次に、ステップＳ０３において、パラメータｎに「１」が設定される。かかるパラメータｎは、統合データベースシステム１００におけるスケジューラ１２０により管理される。
【００９９】
次いで、ステップＳ０４において、データベースシステム１０2nにおける第（２ｎ）データベースを統合データベースシステム１００へ移行する。この第（２ｎ）データベース移行処理では、図１３に示されるように、まず、ステップＳ４１において、統合データベースシステム１００において、第１領域１１１内のデータの複製が第２領域１１２内に作成される。かかる複製処理に際しては、まず、スケジューラ１２０が、複製元領域を第１領域１１１に指定するとともに、複製先領域を第２領域１１２に指定した複製指令を業務処理部１１０へ送る。この複製指令を受けた業務処理部１１０は、第１領域１１１内のデータの複製を第２領域１１２内に作成する。
【０１００】
次に、ステップＳ４２において、第（２ｎ）データベースに関する初期データ移行が行われる。かかる初期データ移行に際しては、図１４のステップＳ５１において、まず、データベースシステム１０2nにおける業務処理部１９2nが、スケジューラ１４2nからの複製指令に従って、データベース領域１１2n内データの複製をバックアップ領域１２2n内に作成する。引き続き、スケジューラ１４2nからの抽出指令を受けた抽出部１５2nが、上述したステップＳ３１における抽出部１５1の場合と同様にして、バックアップ領域１２2n内データに基づいて、統合データベースシステム１００へ移行すべきデータである移行データを抽出し、抽出結果をファイル作成部１７2nへ送る。
【０１０１】
次いで、ステップＳ５２において、抽出部１５2nによる抽出結果を受けたファイル作成部１７2nが、上述したステップＳ３２における抽出部１５1の場合と同様に、移行用レコードを含むファイルを作成した後にデータ圧縮を施して通常移行ファイルを作成し、転送部１８2nへ送る。引き続き、通常移行ファイルを受けた転送部１８2nは、ネットワーク９０を介して、当該通常移行ファイルを統合データベースシステム１００へ向けて送る。
【０１０２】
データベースシステム１０2nからの通常移行ファイルを受けた統合データベースシステム１００では、ステップＳ５３において、当該通常移行ファイル内データの第２領域１１２への登録処理が行われる。このステップＳ５３の処理では、上述したステップＳ２３の場合と同様に、受信処理、統合ＤＢキーの付与処理が行われた後、作成された統合レコードが第２領域１１２に登録される。そして、ステップＳ５３の処理が終了し、この結果としてステップＳ４２の処理が終了する。この後、処理はステップＳ４３へ進む。
【０１０３】
ステップＳ４３では、所定のタイミングでデータベースシステム１０2nによる業務処理を停止させた後、先のバックアップ領域１２2n内への複製作成の時点からデータベースシステム１０2nによる業務処理の停止までの期間に発生した第（２ｎ）データベースの更新分である差分データの統合データベースに反映する。
【０１０４】
かかる差分データ反映処理では、図１５のステップＳ６１において、まず、スケジューラ１４2nからの抽出指令を受けた差分抽出部１６2nが、差分領域１３2n内データに基づいて、統合データベースシステム１００へ反映すべきデータである差分データを抽出する。かかる抽出に際して差分抽出部１６2nは、上述のステップＳ５１における抽出部１５2nの場合と同様にして、差分反映用レコードを作成する。かかる抽出結果は、ファイル作成部１７2nへ送られる。
【０１０５】
次に、ステップＳ６２において、差分抽出部１６2nによる抽出結果を受けたファイル作成部１７2nが、上述のステップＳ３２における差分抽出部１６1と同様にして、差分反映用レコードを含むファイルを作成した後にデータ圧縮を施して差分移行ファイルを作成し、転送部１８2nへ送る。引き続き、差分ファイルを受けた転送部１８2nは、ネットワーク９０を介して、当該差分移行ファイルを統合データベースシステム１００へ向けて送る。
【０１０６】
データベースシステム１０2nからの差分移行ファイルを受けた統合データベースシステム１００では、ステップＳ６３において、当該差分移行ファイル内データの第２領域１１２への反映処理、及び、上記のステップＳ４１における複製処理の後の業務処理により発生したデータ（以下、「内部差分データ」とも記す）の反映処理（以下、「内部差分反映処理」とも呼ぶ）が行われる。このステップＳ６３における差分移行ファイル内データの第２領域１１２への反映処理は、反映先領域が第２領域であることを除いて、上述したステップＳ３３の場合と同様に行われる。
【０１０７】
また、内部差分反映処理に際しては、まず、統合データベースシステム１００における差分抽出部１７０が、スケジューラ１２０からの差分抽出指令に従って、差分領域１１３内のデータから内部差分データを抽出し、差分更新部１６０へ送る。内部差分データを受けた差分更新部１６０は、統合ＤＢキーを比較することにより、内部差分データにおける各統合レコードに対応する統合レコードが既に第２領域１１２に存在していない新規データであるか否かを判定する。
【０１０８】
かかる内部差分反映用判定の結果が肯定的であった場合には、差分更新部１６０は、当該内部差分データ中の各レコードを第２領域１１２に登録する。一方、内部差分反映用判定の結果が否定的であった場合には、当該内部差分データ中の各レコードに対応する既存の統合レコードにおけるレコードデータ部分を、内部差分データの各レコードにおけるレコードデータ部分の内容に更新する。
【０１０９】
以上のようにしてステップ６３の処理を終了すると、ステップＳ４３の処理が終了する。この結果、ステップＳ０４の処理が終了し、処理は、図７のステップＳ０５へ進む。
【０１１０】
ステップＳ０５では、第（２ｎ）業務切換処理が行われる。この第（２ｎ）業務切換処理では、まず、スケジューラ１２０が、第２領域１１２を業務処理用領域に指定した業務切替指令を業務処理部１１０へ送る。この業務切替指令を受けた業務処理部１１０は、第２領域１１２を利用した業務処理を開始する。この結果、第（２ｎ）データベースシステム１０2nが行っていた業務処理の実行が、更に、統合データベースシステム１００による実行に切り替わる。
【０１１１】
次に、ステップＳ０６において、全てのデータベース移行が完了したか否かが判定される。このステップＳ０６における判定の結果が肯定的であった場合には、データベース移行処理が終了する。一方、ステップＳ０６における判定の結果が否定的であった場合には、処理は、ステップＳ０７へ進む。
【０１１２】
次いで、ステップＳ０７において、データベースシステム１０2n+1における第（２ｎ＋１）データベースを統合データベースシステム１００へ移行する。この第（２ｎ＋１）データベース移行処理では、図１６に示されるように、まず、ステップＳ７１において、統合データベースシステム１００において、第２領域１１２内のデータの複製が第１領域１１１内に作成される。かかる複製処理に際しては、まず、スケジューラ１２０が、複製元領域を第２領域１１２に指定するとともに、複製先領域を第１領域１１１に指定した複製指令を業務処理部１１０へ送る。この複製指令を受けた業務処理部１１０は、第２領域１１２内のデータの複製を第１領域１１１内に作成する。
【０１１３】
次に、ステップＳ７２において、第（２ｎ＋１）データベースに関する初期データ移行が行われる。かかる初期データ移行処理は、最終的な登録先が第１領域１１１である点を除いて、上述したステップＳ４２の場合と同様に行われる。引き続き、ステップＳ７３において、所定のタイミングでデータベースシステム１０2n+1による業務処理を停止させた後、先のバックアップ領域１２2n+1内への複製作成の時点からデータベースシステム１０2n+1による業務処理の停止までの期間に発生した第（２ｎ＋１）データベースの更新分である差分データの統合データベースに反映する。かかる差分データの反映処理は、反映先が第１領域１１１である点を除いて、上述したステップＳ４３の場合と同様に行われる。
【０１１４】
以上のようにしてステップ７３の処理が終了すると、ステップＳ０７の処理が終了する。この後、処理は、図７のステップＳ０８へ進む。
【０１１５】
ステップＳ０８では、第（２ｎ＋１）業務切換処理が行われる。この第（２ｎ＋１）業務切換処理では、まず、スケジューラ１２０が、第１領域１１１を業務処理用領域に指定した業務切替指令を業務処理部１１０へ送る。この業務切替指令を受けた業務処理部１１０は、第１領域１１１を利用した業務処理を開始する。この結果、第（２ｎ＋１）データベースシステム１０2n+1が行っていた業務処理の実行が、更に、統合データベースシステム１００による実行に切り替わる。
【０１１６】
次に、ステップＳ０９において、全てのデータベース移行が完了したか否かが判定される。このステップＳ０９における判定の結果が肯定的であった場合には、データベース移行処理が終了する。一方、ステップＳ０９における判定の結果が否定的であった場合には、処理は、ステップＳ１０へ進む。
【０１１７】
ステップＳ１０では、パラメータｎに「１」が加算される。この後、処理はステップＳ０４へ戻る。以後、ステップＳ０６又はステップＳ０９の判定の結果が肯定的となるまで、ステップＳ０４〜Ｓ１０の処理を繰り返す。そして、全てのデータベース移行が完了し、ステップＳ０６又はステップＳ０９の判定の結果が肯定的となると、システム１におけるデータベース移行処理が終了する。
【０１１８】
こうしてデータベース移行処理が終了すると、統合データベースシステム１００におけるスケジューラ１２０が、移行完了報告を業務処理部１１０へ送る。この移行完了報告を受けると、業務処理部１１０は、通常の業務処理を開始する。
【０１１９】
以上説明したように、本発明の実施形態においては、移行元のデータベースシステム１０j（ｊ＝１〜Ｎ）に、まず、業務運用中に、当該移行元のシステムにおけるデータベースのバックアップデータを統合データベースシステム１００に移行する。この後、当該バックアップデータの作成後、移行元のデータベースシステム１０jにおける業務運用終了までのデータベース更新データである差分データを統合データベース１００へ移行後、統合データベースシステム１００が、順次、移行元のシステムの業務運用停止後に当該業務運用を開始する。このため、移行元の各データベースシステム１０jが行っていた業務の停止時間を、利用者から見た場合に、従来の移行方法と比べて短くすることができる。
【０１２０】
また、本実施形態では、データベース移行中において、第１領域１１１と第２領域１１２とをトグルバッファとして使用し、業務処理用領域とバックアップ領域とをスワップしながら、第３データベース以降のデータベース移行を行う。このため、３つ以上のデータベースを統合データベースへ移行する場合において必要とする記憶容量を最小化することができる。
【０１２１】
［実施形態の変形］
上記の実施形態において、移行するタイミングに合わせて抽出対象のデータベースのバックアップを作成し、これよりデータを抽出するとした。しかし、データの抽出は通常運用におけるバックアップを対象に行い、これより抽出するとしてもよい。
【０１２２】
また、上記の実施形態においては、移行前データベースと移行後データベースはそれぞれ個別のシステム内に存在し、通信によって移行を行うとした。しかし、移行前データベースと移行後データベースが同じシステム内にある構成においても、本発明を適用することができる。
【０１２３】
また、上記の実施形態においては、当初、統合データベースシステム１００は業務処理を行っていないものとした。しかし、統合データベースシステム１００が業務処理を行っている状態から本発明の処理を開始することもできる。
【０１２４】
また、上記の実施形態において、図７の動作フローのステップＳ０２、ステップＳ０５、ステップＳ０８においては、それぞれ、データベースシステム１０1、データベースシステム１０2n、データベースシステム１０2n+1、の稼動を停止させた上で差分移行するとした。しかし、差分更新の途中で切替を行うこともできる。つまり、各データベースシステムの稼動を停止することをせず、切替後も差分移行を繰り返すことで、ノンストップの移行を実現させることもできる。
【０１２５】
この場合には、まず、一旦差分移行をした上で、切替を行う。その後、統合データベースシステム１００に対する更新は、業務処理部１１０の中に設けたバッファ（図示せず）に、更新記録として取る。そして、差分移行の対象となった時点から後に、各データベースシステムに更に発生した差分を移行した上で、当該更新記録を反映させる。差分の統合データベースに対する移行や当該更新記録の反映は、内部処理であるため、それほど時間はかからない。したがって、このようにすることで、差分を採取する対象の時間はだんだん短くなっていき、発生する差分も少なくなっていく。そして、差分が全くなくなったときに、差分移行が完了する。このようにすれば、各データベースシステムの稼動を停止することなく移行を行えるため、利用者に全く迷惑のかからないデータ移行が可能となる。
【産業上の利用可能性】
【０１２６】
以上説明したように、本発明のデータベース移行方法は、複数のデータベースからデータベースを統合するようなデータ移行にあたって使用することができる。
【０１２７】
以上説明したように、本発明の統合データベースシステムは、複数のデータベースからデータベースを統合するようなデータ移行を行うデータベースシステムに使用することができる。
【０１２８】
以上説明したように、本発明のデータベース移行プログラムは、複数のデータベースからデータベースを統合するようなデータ移行にあたって使用することができる。
【図面の簡単な説明】
【０１２９】
【図１】本発明の実施形態におけるデータベースシステムの構成を示す概略図である。
【図２】本発明の実施形態における個別のデータベースシステムの構成を示す概略図である。
【図３Ａ】本発明の実施形態における個別のデータベースシステム中のレコードのデータ構造を示す図である。
【図３Ｂ】本発明の実施形態における個別のデータベースシステムから抽出されたレコードのデータ構造を示す図である。
【図４】本発明の実施形態における統合データベースシステムの構成を示す概略図である。
【図５】本発明の実施形態における統合データベースシステムの業務処理部の構成を示す概略図である。
【図６】本発明の実施形態における統合データベースシステム中のレコードのデータ構造を示す図である。
【図７】本発明の実施形態における移行の手順を示すフローチャートである。
【図８】本発明の実施形態における第１データベースの移行処理を示すフローチャートである。
【図９】図８に示す移行処理における初期移行の処理を示すフローチャートである。
【図１０】図９に示す初期移行における移行データの登録の動作を示すフローチャートである。
【図１１】図８に示す移行処理における差分データの反映の処理を示すフローチャートである。
【図１２】図１１に示す差分データの更新の動作を示すフローチャートである。
【図１３】本発明の実施形態における第（２ｎ）データベースの移行処理を示すフローチャートである。
【図１４】図１３に示す移行処理における初期移行の処理を示すフローチャートである。
【図１５】図１３に示す移行処理における差分データの反映の処理を示すフローチャートである。
【図１６】本発明の実施形態における第（２ｎ＋１）データベースの移行処理を示すフローチャートである。
【符号の説明】
【０１３０】
１…システム、１０j…データベースシステム、１１j…データベース領域、１２j…バックアップ領域、１３j…差分領域、１４j…スケジューラ、１５j…抽出部、１６j…差分抽出部、１７j…ファイル作成部、１８j…転送部、１９j…業務処理部、９０…ネットワーク、１００…統合データベースシステム、１１０…業務処理部、１１１…第１領域、１１２…第２領域、１１３…差分領域、１２０…スケジューラ、１３０…受信部、１４０…ファイル取得部、１５０…移行部、１６０…差分更新部、１７０…差分抽出部。
【図１】
2008250733.tif 000003
【図２】
2008250733.tif 000004
【図３Ａ】
2008250733.tif 000005
【図３Ｂ】
2008250733.tif 000006
【図４】
2008250733.tif 000007
【図５】
2008250733.tif 000008
【図６】
2008250733.tif 000009
【図７】
2008250733.tif 000010
【図８】
2008250733.tif 000011
【図９】
2008250733.tif 000012
【図１０】
2008250733.tif 000013
【図１１】
2008250733.tif 000014
【図１２】
2008250733.tif 000015
【図１３】
2008250733.tif 000016
【図１４】
2008250733.tif 000017
【図１５】
2008250733.tif 000018
【図１６】
2008250733.tif 000019