(57)【特許請求の範囲】
【請求項１】
ホストシステムからオープンサーバにネットワークを介して必要な情報のみを一括して配信するデータベースの配信処理方式であって、
前記ホストシステムが、前記配信するデータベースの基となる基幹データベースと、前記基幹データベースのデータレコードヘの更新履歴を格納するジャーナルファイルと、前記基幹データベースから必要なデータレコードを送る時に、与えられた条件に合致するデータレコードを前記基幹データベースから抽出するＤＢ抽出手段と、前記ＤＢ抽出手段による基幹データベースからの抽出履歴を格納する抽出管理テーブルと、前記抽出管理テーブルに同一データベースから同一条件で抽出した履歴が存在する場合に起動され、前回のＤＢ抽出手段による抽出処理以降に更新された基幹データベースのデータレコードを、前記ジャーナルファイルを参照することにより認識し、抽出条件に合致する更新レコードだけを選択する更新ＤＢ抽出手段と、前記更新ＤＢ抽出手段が起動されない場合は前記ＤＢ抽出手段により抽出されたデータレコードを、前記更新ＤＢ抽出手段が起動された場合は前記更新ＤＢ抽出手段により抽出されたデータレコードを、前記ネットワークを介して前記オープンサーバヘ転送する抽出データ転送手段と、前記抽出データ転送手段が送受信するデータレコードを格納する転送ファイルとを備え、
前記オープンサーバが、前記基幹データベースから特定の条件に合致するデータレコードが格納され、前記オープンサーバ上のアプリケーションから参照される開放データベースと、前記ネットワークを介して前記ホストシステム側の抽出データ転送手段との間でデータレコードの送受信を行う抽出データ転送手段と、前記オープンサーバ側の抽出データ転送手段が送受信するデータレコードを格納する転送ファイルと、前記ホストシステム側の抽出データ転送手段から送られたデータレコードを、前記開放データベースに格納する開放ＤＢ更新手段とを備えたデータベース配信方式において、
前記ホストシステム側の抽出データ転送手段が、前記転送ファイルに格納されたデータレコードを前記ホストシステムから前記オープンサーバへ転送する際、前記更新ＤＢ抽出手段が起動され更新されたデータレコードのみが前記転送ファイルに格納された旨を、前記ＤＢ抽出手段より通知された場合は、更新モードの転送である旨を前記オープンサーバ側の抽出データ転送手段に前記ネットワークを介して伝えることを特徴とするデータベース高速配信方式。
【請求項２】
前記更新モードの転送以外の場合は、初期モードの転送として通知することを特徴とする、請求項１に記載のデータベース高速配信方式。
【請求項３】
前記オープンサーバ側の抽出データ転送手段が、前記転送ファイルの転送の終了通知を受けると前記開放ＤＢ更新手段を起動し、前記開放ＤＢ更新手段に初期モード／更新モードのモードの違いを通知することを特徴とする、請求項１または２に記載のデータベース高速配信方式。
【請求項４】
前記開放ＤＢ更新手段が、前記初期モードの場合は、前記開放データベースの該当する表名に対して、前記転送ファイルのデータレコードで全て置き換えるように更新することを特徴とする、請求項３に記載のデータベース高速配信方式。
【請求項５】
前記開放ＤＢ更新手段が、前記更新モードの場合は、前記開放データベースの該当する表名について、前記転送ファイル内のデータレコードについて存在するレコード番号のもののみを置き換えるように更新することを特徴とする、請求項３に記載のデータベース高速配信方式。
【請求項６】
前記更新ＤＢ抽出手段が、前記抽出管理テーブルと、前記ジャーナルファイルとを参照，比較することにより、前記基幹データベースから抽出された転送ファイル上のデータレコードの転送の必要の有無を判定し、転送の必要のないものは削除することを特徴とする、請求項３〜５のいずれかに記載のデータベース高速配信方式。
【発明の詳細な説明】
【０００１】
【発明の属する技術分野】
本発明は、データベースの配信制御方式に関し、特に、定期的にホストコンピュータからオープンサーバに基幹データベースのデータレコードを一括して配信する時の配信データのデータ量制御に関する。
【０００２】
【従来の技術】
従来例では、メインフレーム上に存在する基幹データベースから、オープンサーバ上にある部門データベースへネットワークを介して一括してデータを配信するデータベースの配信処理を行う場合、データベースのデータ量の増加に伴い配信するデータ量が増加し、配信時間が増大することに対して、所定時間内でデータ配信を行う必要があった。
【０００３】
これに対して、特開平４−３６３７７６号公報に示されるように、集配信管理データベースを設け、集配信状況を集配信管理データベースに格納することで集配信処理の開始や配信処理終了確認等を人間系の作業からマシン系に移行して自動化を行い、監視機能を強化することで、データ集配信の増大に対する作業要員等の人間系の負荷軽減を図り、所定時間内で効率良くデータ配信が行われるような方式が提案されている。
【０００４】
また、実開平３−２５９４７号公報に示されるように、ネットワーク負荷増大に対して配信ルートの迂回ルートの選択を行う配信コンピュータ間転送制御部を有し、データ配信の負荷分散を行い、ネットワーク系を効率良く利用することでデータ配信時間を抑える方式が提案されている。
【０００５】
【発明が解決しようとする課題】
上述した従来例では、定期的にデータベース配信を行う場合でも条件指定に合致するデータは更新の有無に限らず全てオープンサーバ上に配信している。つまり、人間系の作業やネットワーク系の効率を図ったとしても、データ量自体の削減には何ら対する手段が提供されていない。従って、データ転送するデータ量が増大するとネットワークに掛かる負荷がかなりのものになり、データ転送時間つまり配信時間が増大し、所定の時間内でデータベース配信処理が終了しないという問題を有する。
【０００６】
そこで、本発明の目的は、上記問題を解消すべく、転送するデータ量を削減し転送時間を短縮するデータベース高速配信方式を提供することにある。
【０００７】
【課題を解決するための手段】
上記目的を達成するため、本発明のデータベース高速配信方式は、ホストシステムからオープンサーバにネットワークを介して必要な情報のみを一括して配信するデータベースの配信処理方式であって、ホストシステムが、配信するデータベースの基となる基幹データベースと、基幹データベースのデータレコードヘの更新履歴を格納するジャーナルファイルと、基幹データベースから必要なデータレコードを送る時に、与えられた条件に合致するデータレコードを基幹データベースから抽出するＤＢ抽出手段と、ＤＢ抽出手段による基幹データベースからの抽出履歴を格納する抽出管理テーブルと、抽出管理テーブルに同一データベースから同一条件で抽出した履歴が存在する場合に起動され、前回のＤＢ抽出手段による抽出処理以降に更新された基幹データベースのデータレコードを、ジャーナルファイルを参照することにより認識し、抽出条件に合致する更新レコードだけを選択する更新ＤＢ抽出手段と、ネットワークを介して抽出されたデータレコードを、オープンサーバヘ転送する抽出データ転送手段と、抽出データ転送手段が送受信するデータレコードを格納する転送ファイルとを備え、オープンサーバが、基幹データベースから特定の条件に合致するデータレコードが格納され、オープンサーバ上のアプリケーションから参照される開放データベースと、抽出データ転送手段が送受信するデータレコードを格納する転送ファイルと、抽出データ転送手段から送られたデータレコードを、開放データベースに格納する開放ＤＢ更新手段とを備えたデータベース配信方式において、抽出データ転送手段が、転送ファイルに格納されたデータレコードをホストシステムからオープンサーバへ転送する際、更新ＤＢ抽出手段が起動され更新されたデータレコードのみが転送ファイルに格納された旨を、ＤＢ抽出手段より通知された場合は、更新モードの転送である旨をオープンサーバ側の抽出データ転送手段にネットワークを介して伝えることを特徴とする。
【００１７】
また、更新モードの転送以外の場合は、初期モードの転送として通知するのが好ましい。
【００１８】
さらに、抽出データ転送手段が、転送ファイルの転送の終了通知を受けると、開放ＤＢ更新手段を起動して初期モード／更新モードのモードの違いを通知するのが好ましい。
【００１９】
またさらに、開放ＤＢ更新手段が、初期モードの場合は、開放データベースの該当する表名に対して、転送ファイルのデータレコードで全て置き換えるように更新するのが好ましい。
【００２０】
また、開放ＤＢ更新手段が、更新モードの場合は、開放データベースの該当する表名について、転送ファイル内のデータレコードについて存在するレコード番号のもののみを置き換えるように更新するのが好ましい。
【００２１】
さらに、更新ＤＢ抽出手段が、抽出管理テーブルと、ジャーナルファイルとを参照，比較することにより、基幹データベースから抽出された転送ファイル上のデータレコードの転送の必要の有無を判定し、転送の必要のないものは削除するのが好ましい。
【００２２】
本発明のデータベース高速配信方式は、特に、ネットワークで接続されたホストシステムとオープンサーバと、ホストシステムに置かれている基幹データベースと、基幹データベースのデータレコードへの更新履歴が格納されているジャーナルファイルと、オープンサーバに置かれ基幹データベースから特定の条件に合致するデータレコードが転送されて格納されている開放データベースと、利用者から与えられた条件に合致するデータを基幹データベースから抽出するＤＢ抽出手段と、基幹データベースからの抽出履歴を格納している抽出管理テーブルと、前回のＤＢ抽出手段による抽出処理以降に更新された基幹データベースのデータレコードをジャーナルファイルを参照することで認識し、抽出条件に合致する更新レコードだけを選択する更新ＤＢ抽出手段と、ホストシステムとオープンサーバの各々に存在しネットワークを介して抽出されたデータレコードをホストシステムからオープンサーバへ転送する抽出データ転送手段と、ホストシステムとオープンサーバの各々に存在し抽出データ転送手段が送受信するデータレコードが格納されている転送ファイルと、抽出データ転送手段から送られたデータレコードを開放データベースに格納する開放ＤＢ更新手段とを備えている。
【００２３】
上記のように、本発明のデータベース高速配信方式は、ネットワークで接続されたホストシステムとオープンサーバとにおいて、ＤＢ抽出手段が、ホストシステムに置かれた基幹データベースから利用者から与えられた条件に合致するデータを抽出し、抽出管理テーブルを参照して以前に同一データベースから同一条件でデータ抽出した履歴が存在するか判定し、履歴が存在する場合に更新ＤＢ抽出手段を起動する。更新ＤＢ抽出手段が、前回のＤＢ抽出手段による抽出処理以降に更新された基幹データベースのデータレコードをジャーナルファイルを参照することで認識し、更新のあったデータレコードだけを選択して転送ファイルに格納し、抽出データ転送手段が、転送ファイルに格納されたデータレコードをホストシステムからオープンサーバへ転送し、開放ＤＢ更新手段が、更新されたデータレコードのみを開放データベースに更新する。
【００２４】
このようにして、基幹データベースから抽出したデータレコードのオープンサーバヘの転送において、定期的に行うデータベース配信においては、前回の配信時から更新されていないデータレコードについては、前回の転送済みのデータレコードを再利用しデータ転送しないことにより、転送するデータ量を削減し転送時間を短縮する。
【００２５】
【発明の実施の形態】
次に、本発明の実施例について図面を参照して詳細に説明する。
【００２６】
図１は、本発明のデータベース高速配信方式の実施例の構成を示すブロック図である。この方式は、ネットワークで接続されたホストシステム１と、オープンサーバ２とで構成されている。ホストシステム１は、基幹データベース３と、ジャーナルファイル４と、ＤＢ抽出手段５と、更新ＤＢ抽出手段６と、抽出管理テーブル７と、抽出データ転送手段８と転送ファイル９とを備える。抽出管理テーブル７には、ＤＢ（データベース）抽出手段５による抽出対象となった基幹データベース３の表名，抽出条件，抽出日時が抽出履歴として保持されている。ジャーナルファイル７には、基幹データベース３のデータレコードへの更新情報が格納されている。オープンサーバ２は、開放データベース１１と、開放ＤＢ更新手段１０と、抽出データ転送手段８と、転送ファイル９とを備える。なお、図示しないがオープンサーバ２は複数存在しても構わないが、簡単のためひとつの場合で説明する。基幹データベース３から利用者が特定条件に合致するデータレコードのみを開放データベース１１に転送しようとする時、ＤＢ抽出手段５は、まず利用者から与えられた条件に合致するデータレコードを基幹データベース３から抽出し、転送ファイル９に格納する。そして、基幹データベース３からの抽出履歴を格納している抽出管理テーブル７を参照し、以前に同一データベースから同一条件で抽出した履歴が存在するか判定する。該当する履歴が存在する場合、更新ＤＢ抽出手段６を起動する。更新ＤＢ抽出手段６は、転送ファイル９に格納されているデータレコード各々についてジャーナルファイル４を参照し、前回のＤＢ抽出手段５による抽出処理以降に更新されたデータレコードかを更新日時とデータベースの表名とレコード番号とを基に判定する。更新されているデータレコードについては転送ファイル９に残し、ジャーナルファイル４に履歴が存在しない、つまり、更新されていないデータレコードについては転送ファイル９から削除する。抽出データ転送手段８は、転送ファイル９に格納されたデータレコードをホストシステム１からオープンサーバ２へ転送する。この時、更新ＤＢ抽出手段６が起動され更新されたデータレコードのみが転送ファイル９に格納された旨を、ＤＢ抽出手段５より通知され、その場合は「更新モード」の転送である旨をオープンサーバ２側の抽出データ転送手段８にネットワークを介して伝える。それ以外の場合は「初期モード」の転送として通知する。オープンサーバ２側の抽出データ転送手段８は、転送ファイル９の転送の終了通知を受けると、開放ＤＢ更新手段１０を起動して「初期モード」／「更新モード」のモードの違いを通知する。開放ＤＢ更新手段１０は、「初期モード」の場合は、開放データベース１１の該当する表名に対して、転送ファイル９のデータレコードで全て置き換えるように更新する。「更新モード」の場合は、開放データベース１１の該当する表名について、転送ファイル９内のデータレコードについて存在するレコード番号のもののみを置き換えるように更新する。
【００２７】
本発明の実施例の特徴は、更新ＤＢ抽出手段６が以下を実施することにある。すなわち、抽出管理テーブル７と、ジャーナルファイル４とを参照，比較することにより、基幹データベース３から抽出された転送ファイル９上のデータレコードの転送の必要の有無を判定し、転送の必要のないものは削除することにある。
【００２８】
次に、図２，図３を参照して、本発明の実施例の動作について説明する。
【００２９】
図２は、ＤＢ抽出手段の動作を示すフローチャートである。基幹データベース３から利用者が特定条件に合致するデータレコードのみを開放データベース１１に転送しようとする時、その要求はＤＢ抽出手段５に伝えられる。ＤＢ抽出手段５では、この要求内容をもとにまず基幹データベース３から指定された条件を満たすデータレコードを抽出し、転送ファイル９に格納する（ステップ２１）。次に抽出管理テーブル７を参照し、以前に同一の表名に対して同じ操作が行われたかを検索する（ステップ２２）。同一条件の抽出が初めての場合は、抽出管理テーブル７に今回抽出を行ったデータベースの表名と抽出条件、および現在の日時を抽出日時として登録する（ステップ２３）。そして、転送ファイル９に格納したデータレコードを「初期モード」で転送するよう、抽出データ転送手段８を起動し制御を渡す（ステップ２４）。ＤＢ抽出手段５による抽出管理テーブル７の検索処理で、以前に同一の表名に対して同じ操作が行われていた場合は、更新ＤＢ抽出手段６を起動し、前回以降に更新されたデータレコードのみを選択する処理を実行する（ステップ２５）。その後、抽出管理テーブル７に存在する今回抽出を行ったデータベースの表名および抽出条件のテーブルエントリに対して、現在の日時を抽出日時として更新する（ステップ２６）。そして、転送ファイル９に格納したデータレコードを「更新モード」で転送するよう、抽出データ転送手段８を起動し制御を渡す（ステップ２７）。
【００３０】
図３は、更新ＤＢ抽出手段の動作を示すフローチャートである。更新ＤＢ抽出手段６では、転送ファイル９に格納されている抽出されたデータレコードについて、１レコードずつ参照し、該当データレコードのレコード番号を取得する（ステップ３１）。そして、前回の抽出日時以降に該当データレコードが更新されているかを、ジャーナルファイル４の前回の抽出日時以降のジャーナルデータを参照して、データベースの表名およびレコード番号をキーに判定する（ステップ３３）。該当するデータレコードがジャーナルファイル４中に存在しない場合は、該当データレコードは更新されていないと判断し、転送ファイル９から該当データレコードを削除する（ステップ３４）。該当するデータレコードがジャーナルファイル４中に存在している場合は、前回の抽出以降該当データレコードが更新されたと判断し、次のデータレコードを入手する（ステップ３３，３１）。転送ファイル９に格納された全てのデータレコードに関して上記処理を繰り返す（ステップ３２）。これにより転送ファイル９には、前回の抽出日時以降に更新のあったデータレコードのみが格納されるようになる。抽出データ転送手段８は、ホストシステム１とオープンサーバ２とでネットワークを介してホストシステム１上の転送ファイル９に格納されているデータレコードをオープンサーバ２上の転送ファイル９に格納し、転送が全て完了すると、「初期モード」／「更新モード」の区別を通知し、開放ＤＢ更新手段１０に制御を渡す。開放ＤＢ更新手段１０は、「更新モード」の場合、転送ファイル９に格納されているデータレコードを、開放データベース１１の以前に作成した該当する表に対して転送されたデータレコードについてのみ部分更新を行う。「初期モード」の場合には、転送ファイル９に格納されているデータレコードで開放データベース１１の該当する表に対して全更新を行う。
【００３１】
このように、本発明のデータベース高速配信方式は、基幹データベース３から指定条件に合致したデータレコードを転送する前に、ジャーナルファイル４を用いることで、転送すべきデータレコードを前回の抽出から更新のあったものに削減しているため、転送するデータレコードが必要なもののみとなる。これにより、基幹データベース３から抽出するデータレコードの件数が多くなっても、転送するデータレコードの量は増加しないため、所定時間内でデータベースの配信が行えるという効果がある。
【００３２】
次に、本発明の実施例の動作について詳細に説明する。なお、簡単のため対象とするデータレコードやジャーナルについては数を限定して説明する。
【００３３】
図４は、抽出管理テーブルとジャーナルファイルの内容を例示した図である。この図は、前回のデータベース配信処理が、表名“Ａ”に対して表の項目“Ｘ”＞１００という抽出条件で９月３０日２１：００に実行されたことを抽出管理テープル７のエントリで示している。また、ジャーナルファイル４を見ると、表名“Ａ”に対して、１０月１日１２：１５にレコード番号“１００”の、１０月５日１７：２０にレコード番号“５１”の、１０月７日２：４５にレコード番号“７５”の、それぞれのデータレコードに対して更新があったことを示している。
【００３４】
図５は、転送ファイルの内容を例示した図である。この図は、１０月１５日２１：２３にデータベース転送要求があり、ＤＢ抽出手段５によって基幹データベース３から抽出条件に該当するデータレコードが抽出された時の転送ファイル９の内容を示している。この時、表名“Ａ”に対してレコード番号“２３”，“４５”，“５１”，“５６”，“６０”，“７５”，“１００”，“１１２”の８件のデータレコードが条件に合致し転送ファイル９に格納されている。なお、データレコードイメージについては省略している。
【００３５】
次に、上述した図４、図５の状態からの動作について図２，図３を参照してさらに詳細に説明する。ＤＢ抽出手段５は、抽出管理テーブル７に今回抽出を行ったのと同一の表「表名“Ａ”」に対する同一の抽出条件「項目“Ｘ”＞１００」のテーブルエントリがあるため、更新ＤＢ抽出手段６を起動する（ステップ２５）。更新ＤＢ抽出手段６では、転送ファイル９に格納されている抽出されたレコード番号“２３”のデータレコードについて、ジャーナルファイル４を参照し、前回の抽出日時９月３０日２１：００以降に該当データレコードが更新されているかをデータベースの表名“Ａ”とレコード番号“２３”とをキーにチェックしていく（ステップ３３）。レコード番号“２３”のジャーナルレコードがないため、レコード番号“２３”のデータレコードは更新されていないと判断し、転送ファイル９から該当データレコードを削除する（図５に傍線で表示、ステップ３４）。同様に転送ファイル９に存在する全てのデータレコード（レコード番号“４５”，“５１”，“５６”，“６０”，“７５”，“１００”，“１１２”）について更新の有無をチェックし（ステップ３２）、更新のないものについては転送ファイル９から該当データレコードを削除する（ステップ３４）。その結果、転送ファイル９には、更新のあったレコード番号“５１”，“７５”，“１００”の３件のデータレコードのみが格納される。抽出データ転送手段８は、ホストシステム１での先の３件のデータレコードが格納された転送ファイル９の内容をオープンサーバ２側の転送ファイル９に送る。開放ＤＢ更新手段１０は、今回のような「更新モード」の場合、転送ファイル９に格納されているデータレコードのレコード番号について開放データベース１１上の表名“Ａ”の部分更新を行う。
【００３６】
【発明の効果】
本発明では、ジャーナルファイルを参照することで、転送すべきデータレコードを前回の抽出から更新のあったもののみに限定することができ、転送するデータレコードを少なくすることができる。従って、基幹データベースから抽出条件に合致するデータレコードの件数が多くなっても、ネットワーク負荷を増やさずに所定内の時間でデータベース配信が行えるという効果を奏する。
【図面の簡単な説明】
【図１】本発明の第１の実施例の構成を示すブロック図である。
【図２】図１のＤＢ抽出手段の動作を示すフローチャートである。
【図３】図１の更新ＤＢ抽出手段の動作を示すフローチャートである。
【図４】図１の抽出管理テーブルとジャーナルファイルの内容を例示した図である。
【図５】図１の転送ファイルの内容を例示した図である。
【符号の説明】
１  ホストシステム
２  オープンサーバ
３  基幹データベース
４  ジャーナルファイル
５  ＤＢ抽出手段
６  更新ＤＢ抽出手段
７  抽出管理テーブル
８  抽出データ転送手段
９  転送ファイル
１０  開放ＤＢ更新手段
１１  開放データベース
【図１】
0003709258.tif 000002
【図２】
0003709258.tif 000003
【図３】
0003709258.tif 000004
【図４】
0003709258.tif 000005
【図５】
0003709258.tif 000006