(57)【要約】【課題】処理件数の増大による処理時間の増大を防止してデータチェックを行いながらデータを取り込むことを可能とする。【解決手段】図示しないが、外部システムからの連携データファイル15を中間テーブル11に一括して取り込む手段と、複数のテーブル上のレコードを照合する手段と、複数件のレコードから特定の条件に合致するレコードを抽出する手段と、抽出条件に合致するレコードを別のテーブルに一括して格納する手段とを備える。中間テーブル11に格納された複数のデータファイルの各項目毎に、事前に登録されている各項目毎の正しい仕様、ルールを格納しているコードテーブル14と照合を行い、不整合であるか、予め規定されたエラー条件に合致するレコードを一括して抽出してエラーデータテーブル13に登録し、エラーテーブルに格納されなかった中間テーブル内のデータファイルを正常データテーブル12に格納する。【選択図】図１
2012022386.tif 000002
【特許請求の範囲】
【請求項１】
外部システムからデータを受信して取り込みを行うデータ連携システムにおいて、
前記外部システムからの連携データファイルを中間テーブルに一括して取り込むデータ取り込み手段と、複数のテーブル上にあるレコードを照合するレコード照合手段と、複数件のレコードから特定の条件に合致するレコードを抽出するレコード抽出手段と、抽出条件に合致するレコードを別のテーブルに一括して格納するレコード格納手段とを備え、
前記データ取り込み手段は、前記外部システムからの連携データファイルを受領し、受領した連携データファイルを中間テーブルに一括して取り込み、
前記レコード照合手段は、前記中間テーブルに格納された連携データファイルの複数のデータファイルの各項目毎に、事前に登録されている各項目毎の正しい仕様、ルールを格納しているコードテーブルと照合を行い、
前記レコード抽出手段は、前記照合の結果、不整合であるか、予め規定されたエラー条件に合致するレコードを一括して抽出し、
前記レコード格納手段は、前記レコード抽出手段により抽出されたレコードを含むデータファイルをエラーデータテーブルに一括登録し、
前記レコード照合手段は、前記中間テーブルと前記エラーデータテーブルとを照合し、
前記レコード抽出手段は、前記中間テーブルと前記エラーデータテーブルとの照合の結果、エラーデータテーブルに存在しないレコードを含むデータファイルを中間テーブルから一括して抽出し、
前記レコード格納手段は、前記レコード抽出手段により前記中間テーブルから一括して抽出されたデータファイルを正常データテーブルに一括して登録することを特徴とするデータ連携システム。
【請求項２】
外部システムからデータを受信して取り込みを行うデータ連携システムにおけるデータ取り込み方法において、
前記データ連携システムは、
前記外部システムからの連携データファイルを中間テーブルに一括して取り込むデータ取り込み手段と、複数のテーブル上にあるレコードを照合するレコード照合手段と、複数件のレコードから特定の条件に合致するレコードを抽出するレコード抽出手段と、抽出条件に合致するレコードを別のテーブルに一括して格納するレコード格納手段とを備え、
前記データ取り込み手段は、前記外部システムからの連携データファイルを受領し、受領した連携データファイルを中間テーブルに一括して取り込み、
前記レコード照合手段は、前記中間テーブルに格納された連携データファイルの複数のデータファイルの各項目毎に、事前に登録されている各項目毎の正しい仕様、ルールを格納しているコードテーブルと照合を行い、
前記レコード抽出手段は、前記照合の結果、不整合であるか、予め規定されたエラー条件に合致するレコードを一括して抽出し、
前記レコード格納手段は、前記レコード抽出手段により抽出されたレコードを含むデータファイルをエラーデータテーブルに一括登録し、
前記レコード照合手段は、前記中間テーブルと前記エラーデータテーブルとを照合し、
前記レコード抽出手段は、前記中間テーブルと前記エラーデータテーブルとの照合の結果、エラーデータテーブルに存在しないレコードを含むデータファイルを中間テーブルから一括して抽出し、
前記レコード格納手段は、前記レコード抽出手段により前記中間テーブルから一括して抽出されたデータファイルを正常データテーブルに一括して登録することを特徴とするデータ取り込み方法。
【発明の詳細な説明】
【技術分野】
【０００１】
本発明は、データ連携システム及びデータ取り込み方法に係り、特に、外部システムからデータ受信して取り込みを行うデータ連携において、処理件数の増大による処理時間の増大を防止してデータチェックを行いながらデータを取り込むことができるデータ連携システム及びデータ取り込み方法に関する。
【背景技術】
【０００２】
一般に、外部システムやファイルからデータを取り込む際には、対象のデータ、レコードを入力順に読み込みを行って、読み込んだ各データ、レコード毎にそこに保持されている項目の妥当性のチェックと必要な計算や変換処理とを行い、正常データと異常データとに振り分けながら記憶媒体に書き込みを行う処理を最終レコードまで繰り返すという方法が取られている。この方法は、処理件数がＮ倍となった場合に、処理時間もそれに比例して概ねＮ倍となるため処理件数の多い場合や、処理時間に制約のあるスケジュールの下で運用されるデータ連携システムに適用するには不向きな方法である。
【発明の概要】
【発明が解決しようとする課題】
【０００３】
外部システムやファイルからデータの取り込みを行う処理をデータ連携システムとしてシステム化する背景には、システム化により人手の介在を排除することによるデータ取り込み時のミスを防止することと、扱うデータ件数が多いことに起因する人手による作業時間の限界を取り除くこととがある。特に、後者が目的の場合、取り込むべきデータ件数が膨大なケースがほとんどである。
【０００４】
この場合、前述した従来技術による取り込んだデータを１件ずつチェックする方法は、人手をコンピューターに置き換えることにより１件当りの処理時間を短縮することを実現することが可能であるが、チェック処理やデータ記憶媒体との間でのデータ読み込み、書き込みプロセスが処理件数に比例した回数発生することとなり、結果として処理件数に比例した処理時間の増大を招くことになるという問題点を生じてしまう。
【０００５】
本発明の目的は、前述した従来技術の問題点を解決し、処理件数の増大による処理時間の増大を防止してデータチェックを行いながらデータを取り込むことを可能にしたデータ連携システム及びデータ取り込み方法を提供することにある。
【課題を解決するための手段】
【０００６】
本発明によれば前記目的は、外部システムからデータを受信して取り込みを行うデータ連携システムにおいて、前記外部システムからの連携データファイルを中間テーブルに一括して取り込むデータ取り込み手段と、複数のテーブル上にあるレコードを照合するレコード照合手段と、複数件のレコードから特定の条件に合致するレコードを抽出するレコード抽出手段と、抽出条件に合致するレコードを別のテーブルに一括して格納するレコード格納手段とを備え、前記データ取り込み手段は、前記外部システムからの連携データファイルを受領し、受領した連携データファイルを中間テーブルに一括して取り込み、前記レコード照合手段は、前記中間テーブルに格納された連携データファイルの複数のデータファイルの各項目毎に、事前に登録されている各項目毎の正しい仕様、ルールを格納しているコードテーブルと照合を行い、前記レコード抽出手段は、前記照合の結果、不整合であるか、予め規定されたエラー条件に合致するレコードを一括して抽出し、前記レコード格納手段は、前記レコード抽出手段により抽出されたレコードを含むデータファイルをエラーデータテーブルに一括登録し、前記レコード照合手段は、前記中間テーブルと前記エラーデータテーブルとを照合し、前記レコード抽出手段は、前記中間テーブルと前記エラーデータテーブルとの照合の結果、エラーデータテーブルに存在しないレコードを含むデータファイルを中間テーブルから一括して抽出し、前記レコード格納手段は、前記レコード抽出手段により前記中間テーブルから一括して抽出されたデータファイルを正常データテーブルに一括して登録することにより達成される。
【発明の効果】
【０００７】
本発明によれば、システム稼動日程、時間帯よって、データ連携によりデータの取り込み件数（業務、取引量に影響される）が変動することがあっても、常に一定時間内でのデータの取り込みを行うことが可能となる。
【図面の簡単な説明】
【０００８】
【図１】本発明の一実施形態によるデータ連携システムの構成を示すブロック図である。
【図２】本発明の実施形態での処理動作を説明するフローチャートである。
【図３】連携データファイルを中間テーブルへ取り込む処理を説明するイメージを示す図である。
【図４】中間テーブルからエラーデータを抽出する処理を説明するイメージを示す図である。
【図５】中間テーブルから正常データを抽出する処理を説明するイメージを示す図である。
【発明を実施するための形態】
【０００９】
以下、本発明によるデータ連携システム及びデータ取り込み方法の実施形態を図面により詳細に説明する。
【００１０】
図１は本発明の一実施形態によるデータ連携システムの構成を示すブロック図である。
【００１１】
図１に示す本発明の実施形態によるデータ連携システムは、よく知られている一般的なＤＢＭＳ（DataBaseManagementSystem）内に構築されているものとしており、図示ＤＢＭＳは、その詳細を示していないが、ＣＰＵ、メインメモリ、ＨＤＤ等による記憶装置、接続されているデータベースを持つ外部記憶装置へのアクセスのためのインタフェース装置等を備えて構成されている。
【００１２】
そして、ＤＢＭＳ内のメインメモリ内には、図示していないが、本発明の実施形態で利用する外部からの連携データファイルを中間テーブルに一括して取り込む機能を構築するデータ取り込みプログラム、複数のテーブル上にあるＮ対Ｍ件のレコードを照合する機能（ＳＱＬステートメント）を構築する照合プログラム、複数件のレコードから特定の条件に合致するレコードを抽出する機能（ＳＱＬステートメント）を構築する抽出プログラム、抽出条件に合致するレコードを別のテーブルに一括して追加して格納する機能（ＳＱＬステートメント）を構築するデータ追加格納プログラムが格納されている。これらのプログラムは、ＤＢＭＳが有するＣＰＵにより実行されることにより、それぞれの機能を構築する。
【００１３】
また、ＤＢＭＳ内のメインメモリ内には、本発明により、外部から取り込んだ連携データファイルを格納する中間テーブル１１、中間テーブル１１から抽出した正常データファイルを格納する正常データテーブル１２、中間テーブル１１から抽出したエラーデータファイルを格納するエラーデータテーブル１３及び中間テーブル１１内の各連携データファイルのファイル内容の妥当性チェックのための情報が予め格納されたコードテーブル１４が格納されている。
【００１４】
外部からの連携データファイル１５は、複数のデータファイルにより構成され、各データファイルは、複数の項目により構成されている。そして、外部からの連携データファイル１５が取り込まれて中間テーブル１１に格納された際、連携データファイル１５の複数の項目を有する各データファイルは、中間テーブル１１内に１行のファイルとして格納される。この結果、中間テーブル１１に格納された連携データファイル１５は、図１に示しているように列方向に同一の項目が並んだものとなる。
【００１５】
図２は本発明の実施形態での処理動作を説明するフローチャート、図３は連携データファイルを中間テーブルへ取り込む処理を説明するイメージを示す図、図４は中間テーブルからエラーデータを抽出する処理を説明するイメージを示す図、図５は中間テーブルから正常データを抽出する処理を説明するイメージを示す図であり、次に、図２〜図５を参照して本発明の実施形態での処理動作を説明する。なお、ここで説明する処理を実施するに当たって、中間テーブル１１、エラーデータテーブル１３は、予め初期化されていて空の状態とされているものとする。
【００１６】
（１）トランザクションの処理が開始されると、データ取り込みプログラムが外部システムからの連携データファイル１５を受領し、受領した連携データファイルを中間テーブル１１に一括して取り込む。ここでの処理を示しているのが図３に示しているイメージである（ステップ２０１、２０２）。
【００１７】
（２）中間テーブル１１に格納された処理すべき各データファイルの項目の番号を１に設定し、照合プログラムが、中間テーブル１１内の全てのデータファイルの１番目の項目について、事前にシステムに登録されているコードテーブル（各項目毎の正しい仕様、ルールを格納している）と照合を行い、抽出プログラムが、照合の結果、不整合であるか、予め規定されたエラー条件に合致するレコードを一括して抽出する（ステップ２０３、２０４）。
【００１８】
（３）次に、データ追加格納プログラムが、ステップ２０４で抽出されたレコードを含むデータファイルをエラーデータテーブルに一括登録する（ステップ２０５）。
【００１９】
（４）そして、ステップ２０４、２０５で処理した項目が、各データファイルの最後の項目番号のものか否かを判定し、処理した項目が最後の項目番号の項目でなかった場合、項目番号を１つだけ増加し、ステップ２０４からの処理に戻って処理を繰り返す（ステップ２０６、２０７）。
【００２０】
ステップ２０３からステップ２０７までの処理（ステップ２０４、２０５の処理の繰り返し）を示しているのが図４に示しているイメージである。
【００２１】
（５）ステップ２０６の判定で、ステップ２０４、２０５で処理した項目が各データファイルの最後の項目番号のものであった場合、照合プログラムが、中間テーブル１１とエラーデータテーブル１３とを照合し、抽出プログラムが、照合の結果、エラーデータテーブルに存在しない（項目チェックでエラーとならなかった）レコードを含むデータファイルを中間テーブル１１から一括して抽出する（ステップ２０８）。
【００２２】
（６）次に、データ追加格納プログラムが、ステップ２０８の処理で抽出されたデータファイルを正常データテーブル１２に一括して登録し、ここでのトランザクションの処理を終了する（ステップ２０９、２１０）。
【００２３】
ステップ２０９での処理を示しているのが図５に示しているイメージである。
【００２４】
前述した本発明の実施形態での各処理は、プログラムにより構成し、本発明が備えるＣＰＵに実行させることができ、また、それらのプログラムは、ＦＤ、ＣＤＲＯＭ、ＤＶＤ等の記録媒体に格納して提供することができ、また、ネットワークを介してディジタル情報により提供することができる。
【００２５】
前述した本発明の実施形態によれば、システム稼動日程、時間帯よって、データ連携によりデータの取り込み件数（業務、取引量に影響される）が変動することがあっても、データ取り込みの際の処理をデータの件数に依存することなく、データの項目数に依存する処理としているため、常に一定時間内でのデータの取り込みを行うことが可能となる。
【００２６】
これにより、本発明の実施形態は、データの取り込み件数が変動的かつ多件数の場合に特に効果が期待でき、また、業種、業態に係らない広範囲なシステム間データ連携に利用することが可能となる。
【００２７】
また、本発明の実施形態によれば、一定時間での処理が可能となるため、システム、業務を安定して運用させることが可能となる。さらに、本発明の実施形態は、一般的なＤＢＭＳとして標準的に実装された機能を利用しているため、ＤＢＭＳ及びプログラミング言語の種類を選ばすに実現することが可能となり、このため、システム実現のための設備投資も最小限に留めることが可能となる。
【符号の説明】
【００２８】
１１  中間テーブル
１２  正常データテーブル
１３  エラーデータテーブル
１４  コードテーブル
１５  連携データファイル
【図１】
2012022386.tif 000003
【図２】
2012022386.tif 000004
【図３】
2012022386.tif 000005
【図４】
2012022386.tif 000006
【図５】
2012022386.tif 000007