JP3358103B2 - データ統合方法 - Google Patents

Description

【発明の詳細な説明】

【０００１】

【発明の属する技術分野】本発明は、複数の提供側業務
システムのデータベースに含まれるレコードから新しい
レコードを作成するデータ統合技術に係り、特に、複数
の提供側業務システムからのデータベースデータを受信
する業務システムの構築や、データウェアハウス（複数
の提供側業務システムからのデータベースデータを抽出
して構築される意志決定支援用のデータベース）の構築
などを高効率化するのに好適なデータ統合方法に関する
ものである。

【０００２】

【従来の技術】データ統合（以下、統合という）とは、
複数の業務システムのデータベースに含まれるレコード
のうち、指定された条件、すなわち統合条件を満たすレ
コード同士をまとめて、新しいレコード（統合レコー
ド）を作成する処理のことである。尚、統合前のレコー
ドが統合条件を満たす最大の回数を統合基数と呼ぶ。

【０００３】図２４を用いて、設備設計レコードと設備
現況レコードの統合例を説明する。ここで、統合条件、
および、統合基数に関して以下の仮定をおく。 統合条件：設備設計．設備コード＝設備現況．設備コード ＡＮＤ 設備設計．工事完了日＝設備現況．最新工事完了日 統合基数：設備設計：１（設備設計レコード２４１に対応する設備現況レコー ド２４２は１つ） 設備現況：１（設備現況レコード２４２に対応する最新の設備設計 レコード２４１は１つ） この場合、設備設計レコード２４１と設備現況レコード
２４２の図中の矢印で対応付けられた組み合わせ３組が
統合される。

【０００４】次に、図２５，２６を用いて、伝送路レコ
ードと専用線レコードの統合例を説明する。図２５に示
すように、伝送路２５１は、高々２本の専用線２５２を
収容し、専用線２５２は、必ず１本の伝送路２５１に収
容されるとする。すなわち、統合基数は以下と仮定す
る。 統合基数：伝送路：２（伝送路が収容する専用線は２本） 専用線：１（専用線が収容される伝送路は１本） また、統合条件に関して以下の仮定をおく。 統合条件：伝送路．伝送路コード＝専用線．収容伝送路
コード この場合、図２６における矢印で対応付けて示されるよ
うに、伝送路レコード２６１が１つと専用線２６２が２
つの組み合わせ３組が統合される。

【０００５】従来、このような統合は、個別にアプリケ
ーションプログラムを作成することによって実現されて
いた。以下、従来の統合処理に係る２つの代表的技術を
説明する。まず、全レコードファイルの利用による統合
技術に関して、図２７を用いて説明する。統合処理を行
なう利用側システム２７７は、提供側システムＸ２７１
と提供側システムＹ２７４から、それぞれ、全レコード
ファイルＸ２７３と全レコードファイルＹ２７６を受信
して、受信した全レコードファイルＸ２７３内のレコー
ドと、全レコードファイルＹ２７６内のレコードとの間
で統合処理を行なう。この技術の問題は、提供側データ
ベースＸ２７２、あるいは、提供側データベースＹ４０
５の全レコードの量が多い場合、全レコードファイルの
送信に多くの時間が必要となり、提供側システムＸ２７
１あるいは提供側システムＹ２７４の性能を大きく圧迫
してしまうことである。

【０００６】次に、差分ファイルの利用および提供側デ
ータベースへのアドホックアクセスによる統合技術に関
して、図２８を用いて説明する。統合処理を行なう利用
者側システム２８７は、提供側システムＸ２８１と提供
側システムＹ２８４から、それぞれ前回受信後の差分フ
ァイル（差分ファイルＸ２８３，差分ファイルＹ２８
６）を受信した後、以下の手順で統合を行なう。まず、
差分ファイルＸ２８３と差分ファイルＹ２８６との間で
統合を行なう。そして、差分ファイルＸ２８３のレコー
ドの中で、統合条件を満たす回数が統合基数に達しなか
ったレコードについて、提供側システムＹ２８４のデー
タベースＹ２８５にアドホックアクセス２８９を行な
い、統合相手のレコードを検索し、統合を試みる。同様
に、差分ファイルＹ２８６のレコードの中で、統合条件
を満たす回数が統合基数に達しなかったレコードについ
て、提供側システムＸ２８１のデータベースＸ２８２に
アドホックアクセス２８８を行ない、統合相手のレコー
ドを検索し、統合を試みる。

【０００７】この統合技術を用いれば、統合処理時点
で、新たに統合可能なレコードは全て統合される。しか
し、この技術の問題は、提供側データベースＸ２８２へ
のアドホックなアクセス２８８、あるいは、提供側デー
タベースＹ２８５へのアドホックなアクセス２８９が発
生する場合、提供側システムＸ２８１、あるいは、提供
側システムＹ２８４の性能を圧迫することである。

【０００８】また、上述の２つの統合技術には、提供側
データベースへのレコードの投入漏れを見つけることが
難しいという共通の問題点がある。この問題の簡単な解
決技術としては、統合条件を満たす回数が統合基数未満
の全てのレコードを、統合処理システムの運用者にエラ
ー通知し、運用者が、各レコードの統合相手の投入漏れ
の有無を確認するというものが考えられる。しかし、一
般に、各提供側システムの運用（データ投入、および、
差分ファイルの統合処理システムへの送信）が同期して
いる保証はなく、本来、統合条件を満たすべきレコード
の一部の受信時期が、他のレコードの受信時期とずれる
ことがありうる。その結果、上述の解決技術では、単
に、受信時期がずれているだけのレコードが、大量に、
運用者にエラー通知される危険性があり、上述の解決策
は、非現実的である。

【０００９】

【発明が解決しようとする課題】解決しようとする問題
点は、従来の技術では、提供側システムからの全レコー
ド送信、あるいは、提供側システムへのアドホックなア
クセスが必要であり、提供側システムの性能を圧迫して
しまう点と、提供側データベースへのレコードの投入漏
れを高信頼かつ効率的に見つけることができない点であ
る。本発明の目的は、これら従来技術の課題を解決し、
差分ファイルを送信した提供側システムからの全レコー
ド送信、あるいは、提供側システムへのアドホックなア
クセスを不要とし、提供者側システムの性能圧迫の軽減
を可能とすると共に、提供側データベースへのレコード
の投入漏れの容易な検出を可能とするデータ統合方法を
提供することである。

【００１０】

【課題を解決するための手段】上記目的を達成するた
め、本発明のデータ統合方法は、（１）複数のデータベ
ースから送信された各ファイルを受信し、この受信した
各ファイル内の各レコードが予め指定された統合条件を
満たすか否かを評価し、この統合条件を満足したレコー
ド同士をまとめて、新しいレコードを作成するデータ統
合方法において、評価時に、各レコードの統合条件を満
足した回数を各レコード毎に計数し、この回数が、統合
条件を満足する最大回数を表す統合基数に達したか否か
を判別し、統合条件を満足した回数が統合基数に達しな
かったレコードを、統合条件を満足した回数を対応付け
て一時蓄積し、新たに各データベースから送信された前
回ファイルとの差分ファイルを受信し、この差分ファイ
ル内のレコードの評価時、一時蓄積したレコードを含め
て評価および計数を行ない、一時蓄積したレコードの
内、統合条件を満足した回数が統合基数に達したレコー
ドを一時蓄積から破棄し、各差分ファイル内のレコード
および一時蓄積したレコードの内、統合条件を満足した
回数が統合基数に達しなかったレコードを、次の差分フ
ァイル受信時の再評価用に、統合条件を満足した回数を
対応付けて一時蓄積することを特徴とする。また、
（２）複数のデータベースから送信された各ファイルを
受信し、この受信した各ファイル内の各レコードが予め
指定された統合条件を満たすか否かを評価し、この統合
条件を満足したレコード同士をまとめて、新しいレコー
ドを作成するデータ統合方法において、評価時に、各レ
コードの統合条件を満足した回数を各レコード毎に計数
し、この回数が、統合条件を満足する最大回数を表す統
合基数に達したか否かを判別し、統合条件を満足した回
数が統合基数に達しなかったレコードを、統合条件を満
足した回数と最初に受信した日時を対応付けて一時蓄積
し、新たに各データベースから送信された前回ファイル
との差分ファイルを受信し、この差分ファイル内のレコ
ードの評価時、一時蓄積したレコードを含めて評価およ
び計数を行ない、一時蓄積したレコードの内、統合条件
を満足した回数が統合基数に達したレコードを一時蓄積
から破棄し、各差分ファイル内のレコードおよび一時蓄
積したレコードの内、統合条件を満足した回数が統合基
数に達しなかったレコードを、次の差分ファイル受信時
の再評価用に、統合条件を満足した回数と最初に受信し
た日時を対応付けて一時蓄積し、かつ、この再評価用に
一時蓄積するレコードの内、受信日時から予め設定され
た蓄積期限を越えたレコードを抽出して、エラー通知す
ることを特徴とする。また、（３）複数のデータベース
から送信された各ファイルを受信し、この受信した各フ
ァイル内の各レコードが予め指定された統合条件を満た
すか否かを評価し、この統合条件を満足したレコード同
士をまとめて、新しいレコードを作成するデータ統合方
法において、評価時に、各レコードの統合条件を満足し
た回数を各レコード毎に計数し、この回数が、統合条件
を満足する最大回数を表す統合基数に達したか否かを判
別し、統合条件を満足した回数が統合基数に達しなかっ
たレコードを、統合条件を満足した回数と評価を受けた
総回数（被統合処理回数）を対応付けて一時蓄積し、新
たに各データベースから送信された前回ファイルとの差
分ファイルを受信し、この差分ファイル内のレコードの
評価時、一時蓄積したレコードを含めて評価および計数
を行ない、一時蓄積したレコードの内、統合条件を満足
した回数が統合基数に達したレコードを一時蓄積から破
棄し、各差分ファイル内のレコードおよび一時蓄積した
レコードの内、統合条件を満足した回数が統合基数に達
しなかったレコードを、次の差分ファイル受信時の再評
価用に、統合条件を満足した回数と被統合処理回数を対
応付けて一時蓄積し、かつ、この再評価用に一時蓄積す
るレコードの内、被統合処理回数が予め設定された回数
を越えたレコードを抽出して、エラー通知することを特
徴とする。また、（４）上記（１）から（３）のいずれ
かに記載のデータ統合方法において、レコードへの統合
条件を満足した回数の対応付けは、各レコードに、統合
条件を満足した回数を登録するフィールドを追加して行
なうことを特徴とする。

【００１１】

【発明の実施の形態】本発明においては、統合条件を満
たした回数が統合基数に満たないレコードを、統合条件
を満たす可能性を残しているレコードとして、統合条件
を満たした回数を対応付けて、図２に示す一時蓄積部２
に一時的に蓄積する。そして、統合条件の評価の際、受
信ファイル内の各レコードに加えて、一時蓄積部２に蓄
積した各レコードも評価対象としてデータ統合処理を行
なう。この時、新たに統合したレコードに関して、統合
条件を満足した回数を加算する。この加算結果が統合基
数に達したレコードは、一時蓄積部２から削除し、統合
基数に満たないレコードのみ、加算結果を対応付けて一
時蓄積部２に蓄積する。

【００１２】このように、各レコードが統合条件を満た
す可能性があるか否かの判断を、統合条件を満足した回
数が統合基数に達したか否かで行なう。このことによ
り、提供側システムから受信するファイルを、全レコー
ドファイルではなく、前回受信後の差分ファイルとする
場合、従来必要であったアドホックアクセスは、一時蓄
積部２へのアクセスによって代替でき不要となる。すな
わち、新たに統合条件を満たす可能性のあるレコード
は、新たに受信した差分ファイル内のレコード、およ
び、以前に受信したファイル内のレコードの内、統合条
件を満たした総回数が統合基数に達しないレコードであ
り、この以前に受信したファイル内のレコードは、以前
の統合処理において一時蓄積部２に蓄積されている。従
って、新たに統合条件を満たしうるレコードは、受信し
た差分ファイル内、あるいは、一時蓄積部２に全て存在
しており、本発明により、新たに統合可能なレコードは
漏れなく統合されることになる。

【００１３】また、本発明においては、一時蓄積された
レコードの一時蓄積期限の閾値として一時蓄積期限日時
を予め設定して管理する。すなわち、レコードの一時蓄
積部２への蓄積時、統合条件を満たした回数と共に、レ
コードの最初の受信日時も対応付けておく。そして、一
時蓄積部２に一時蓄積したレコードに対して、最初の受
信日時から統合処理時点までの経過日時を算出し、この
経過日時が、一時蓄積期限日時を越えるか否かを判別す
る。このことにより、例えば、提供側のデータベースへ
のレコードの投入漏れがあった場合のエラーを効率良く
検出することができる。

【００１４】すなわち、提供側のデータベースへのレコ
ードの投入漏れがあった場合、そのレコードとの統合相
手となるレコードの統合条件満足回数が統合基数に達す
ることはないため、本発明によれば、所定の時期に、運
用者にエラー通知される。運用者は、このエラー通知に
基づき、レコードの投入漏れの有無を確認できる。ここ
で、運用者にエラー通知が行なわれるのは、一時蓄積期
限で示される期間を越えて一時蓄積されたレコードだけ
である。これにより、本来、統合条件を満たすべき複数
のレコードの受信時期にずれが生じた場合でも、そのず
れが一時蓄積期限内ならば、先行して、受信したレコー
ドが運用者にエラー通知されることはない。従って、大
量のレコードが運用者にエラー通知される危険性は少な
く、本発明は、提供側データベースへのレコードの投入
漏れを見つけるための現実的な解となる。

【００１５】また、本発明においては、一時蓄積したレ
コードの一時蓄積期限の閾値として、統合処理が行なわ
れた回数（被統合処理回数＝一時蓄積された回数）を予
め設定して管理する。すなわち、レコードの一時蓄積部
２への蓄積時、統合条件を満たした回数と共に、一時蓄
積された回数（被統合処理回数）も対応付けておく。そ
して、一時蓄積部２に一時蓄積したレコードに対して、
その蓄積回数を加算し、この加算結果が、被統合処理回
数を越えるか否かを判別する。これにより、上述の一時
蓄積期限日時を一時蓄積期限の閾値として用いた場合と
同様、提供側のデータベースへのレコードの投入漏れの
エラー検出を効率良く行なうことができ、レコードの投
入漏れを見つけるための現実的な解となる。

【００１６】

【実施例】以下、本発明の実施例を、図面により詳細に
説明する。図１は、本発明のデータ統合方法の本発明に
係る処理の第１の実施例を示すフローチャートであり、
図２は、その処理を行なうシステムの構成例を示すブロ
ック図である。図２における本発明のデータ統合処理を
行なうシステムは、統合制御用情報を管理する統合制御
情報管理部１と、レコードを一時的に蓄積する一時蓄積
部２と、レコードにフィールドを追加する統合前処理部
３と、統合レコードを作成する統合レコード作成部４
と、レコードの破棄、あるいは、一時蓄積部２への蓄積
を行なう統合後処理部５とからなる。

【００１７】このような構成のデータ統合処理システム
による本発明に係る動作説明を、図１に基づき行なう。
まず、統合制御情報管理部１において、統合条件および
レコードタイプの組み合わせ毎に統合基数を予め設定し
管理する（ステップ１０１）。提供側システムからファ
イルを受信すると（ステップ１０２）、統合前処理部３
において、図３に示すように、受信したファイル内のレ
コード３１に統合条件満足回数フィールド３２を追加す
る（ステップ１０３）。

【００１８】次に、統合レコード作成部４において、受
信ファイル内のレコードおよび一時蓄積部に蓄積された
レコードについて統合条件を評価し、統合条件を満たす
レコードの組み合わせから統合レコードを作成する（ス
テップ１０４）。そして、統合後処理部５において、受
信ファイル内のレコードおよび一時蓄積部２に蓄積され
たレコードの内、次の図４において詳細を示すように、
一部のレコードを破棄し、残りを一時蓄積部２に蓄積す
る（ステップ１０５）。

【００１９】図４は、図１における統合後処理の本発明
に係る詳細動作例を示すフローチャートである。以降の
動作を受信ファイル内の各レコードおよび一時蓄積部に
蓄積された各レコードについて行なう（ステップ４０
１）。まず、受信ファイル内の各レコードおよび一時蓄
積部に蓄積された各レコードの内、未処理のレコードを
一つ取り出し（ステップ４０２）、図３の統合条件満足
回数フィールド３２に対して新たに統合条件を満たした
回数を加算する（ステップ４０３）。次に、統合条件満
足回数フィールド３２の値を統合制御情報管理部１で管
理された統合基数と比較し（ステップ４０４）、この統
合条件満足回数フィールド３２の値が統合基数に達した
レコードを破棄し（ステップ４０５）、達しないレコー
ドを一時蓄積部２に蓄積する（ステップ４０６）。

【００２０】このような処理の具体的な例を、設備設計
レコードと設備現況レコードとの統合の例を用いて、図
５〜図７に従って説明する。尚、ここで、統合条件は以
下の通りとする。 設備設計、設備コード＝設備現況、設備コードＡＮＤ
設備設計、工事完了日＝設備現況、最新工事完了日 また、統合基数は以下の通りとする。 設備設計：１（設備設計レコードに対応する設備現況レ
コードは１つ） 設備現況：１（設備現況レコードに対応する最新の設備
設計レコードは１つ） また、提供側システムおよび統合処理システムとも初期
状態とする ・一回目のファイル受信時の各提供側データベースの内
容は、対応する受信ファイルの内容と等しいものとす
る。 ・統合処理システムの一時蓄積部２に蓄積されているレ
コードはないものとする。

【００２１】まず、図５に示すように、設備設計レコー
ド一回目受信ファイル５１として４つのレコード（設備
コード１００１〜１００４）を、また、設備現況レコー
ド一回目受信ファイル５２として２つのレコード（設備
コード１００１，１００２）を受信する。それぞれの受
信ファイル内のレコードに対して統合条件を評価し、図
６の一回目統合処理で作成された統合レコード６１とし
て示すように、統合レコードを２つ（設備コード１００
１，１００２）作成する。しかし、統合条件満足回数が
統合基数未満（＝０）の、設備設計レコードの２つ（設
備コード１００３，１００４）は、図６の一回目統合処
理終了時点で一時蓄積部に蓄積された設備設計レコード
６２として示すように図２の一時蓄積部２に蓄積する。

【００２２】次に、図７に示すように、設備設計レコー
ド二回目受信ファイル７１として２つのレコード（設備
コード１００５，１００６）を、また、設備現況レコー
ド二回目受信ファイル７２として４つのレコード（設備
コード１００３〜１００６）を受信する。受信ファイル
７１，７２内のレコードと、図２の一時蓄積部２に蓄積
された図６のレコード６２に対して統合条件を評価する
ことにより、二回目統合処理で作成された統合レコード
７３で示すように、統合レコードを４つ（設備コード１
００３〜１００６）作成する。

【００２３】このように、各回の統合処理において、受
信ファイル内のレコードに加えて、図２の一時蓄積部２
に蓄積されたレコードも統合条件評価対象とすることに
より、新たに統合可能なレコードを漏れなく統合するこ
とができる。また、図２の一時蓄積部２へのアクセスに
より、従来の技術で必要であった提供側データベースへ
のアドホックアクセスが代替され、不要となる。

【００２４】次に、本発明の第２の実施例を、図８〜図
１５に従って説明する。図８は、本発明のデータ統合方
法の本発明に係る処理の第２の実施例を示すフローチャ
ートである。本例の処理は、第１の実施例と同様に図２
に示す構成のシステムにより行なわれる。まず、統合制
御情報管理部１において、統合条件およびレコードタイ
プの組み合わせ毎に統合基数を予め設定し管理する（ス
テップ８０１）。提供側システムからファイルを受信す
ると（ステップ８０２）、統合前処理部３において、図
９に示すように、受信したファイル内のレコード９１
に、統合条件満足回数フィールド９２と受信日時フィー
ルド９３を追加し、統合条件満足回数フィールド９２の
初期値として「０」を設定し、受信日時フィールド９３
の初期値として受信日時を設定する（ステップ８０
３）。

【００２５】次に、統合レコード作成部４において、受
信ファイル内のレコードおよび一時蓄積部２に蓄積した
各レコードについて統合条件を評価し、統合条件を満た
すレコードの組み合わせから統合レコードを作成する
（ステップ８０４）。そして、統合後処理部５におい
て、受信ファイル内のレコードおよび一時蓄積部２に蓄
積したレコードの内、次の図１０において詳細を示すよ
うに、一部のレコードを破棄し、残りを一時蓄積部２に
蓄積し、さらに、一時蓄積部２に蓄積されたレコードの
内一時蓄積期限を越えて一時蓄積されているレコードを
エラー通知する（ステップ８０５）。

【００２６】図１０は、図８における統合後処理の本発
明に係る詳細動作例を示すフローチャートである。以降
の動作を受信ファイル内の各レコードおよび一時蓄積部
２に蓄積された各レコードについて行なう（ステップ１
１１）。まず、受信ファイル内の各レコードおよび一時
蓄積部２に蓄積された各レコードの内、未処理のレコー
ドを一つ取り出し（ステップ１１２）、図９の統合条件
満足回数フィールド９２に対して新たに統合条件を満た
した回数を加算する（ステップ１１３）。

【００２７】次に、この統合条件満足回数フィールド９
２の値を統合制御情報管理部１に管理された統合基数と
比較し（ステップ１１４）、統合条件満足回数フィール
ド９２の値が統合基数に達したレコードを破棄し（ステ
ップ１１５）、達しないレコードを一時蓄積部２に蓄積
する（ステップ１１６）。さらに、この一時蓄積部２に
蓄積したレコードについて、図９の受信日時フィールド
９３の値から統合処理時点までの経過日時と、統合制御
情報管理部１に管理された一時蓄積期限とを比較し（ス
テップ１１７）、経過日時が統合制御情報管理部１に管
理された一時蓄積期限を過ぎているレコードを運用者に
エラー通知する（ステップ１１８）。

【００２８】このような処理の具体的な例を、設備設計
レコードと設備現況レコードとの統合の例を用いて、図
１１〜図１６に従って説明する。尚、ここで、統合条件
は以下の通りとする。 設備設計、設備コード＝設備現況、設備コードＡＮＤ
設備設計、工事完了日＝設備現況、最新工事完了日 また、統合基数は以下の通りとする。 設備設計：１（設備設計レコードに対応する設備現況レ
コードは１つ） 設備現況：１（設備現況レコードに対応する最新の設備
設計レコードは１つ）

【００２９】また、一時蓄積期限は１日とする。また、
提供側システムおよび統合処理システムとも初期状態と
する ・一回目のファイル受信時の各提供側データベースの内
容は、対応する受信ファイルの内容と等しいものとす
る。 ・統合処理システムの一時蓄積部２に蓄積されているレ
コードは無いものとする。 そして、各提供側システムからのファイル受信は一日一
回とする。

【００３０】まず、図１１に示すように、設備設計レコ
ード一回目受信ファイル１１１ａとして１つのレコード
（設備コード１００２）を、また、設備現況レコード一
回目受信ファイル１１２ａとして、同じく１つのレコー
ド（設備コード１００１）を受信する。それぞれの受信
ファイル（１１１ａ，１１２ａ）内のレコードに対して
統合条件を評価する。ここでは、統合条件を満たすレコ
ードはないので、統合レコードは作成されない。そし
て、統合条件満足回数が統合基数未満（＝０）であるレ
コード（すなわち受信ファイル１１１ａ，１１２ａ内の
全レコード）を、それぞれ、一時蓄積部に蓄積された設
備設計レコード１１３ａ、一時蓄積部に蓄積された設備
現況レコード１１４ａとして、図２の一時蓄積部２に蓄
積する。

【００３１】次に、図１２に示すように、設備設計レコ
ード二回目受信ファイル１２１として２つのレコード
（設備コード１００３，１００４）を、また、設備現況
レコード二回目受信ファイル１２２として２つのレコー
ド（設備コード１００２，１００３）を受信する。これ
らの受信ファイル（１２１，１２２）内のレコードと、
図２の一時蓄積部２に蓄積された図１１のレコード１１
３ａ，１１４ａに対して統合条件を評価することによ
り、図１３における統合レコード１３１で示すように、
統合レコードを２つ（設備コード１００２，１００３）
作成する。しかし、設備コード１００１，１００４に関
しては、統合条件を満たさないので、統合条件満足回数
を統合基数未満（＝０）として、図１３に示す一時蓄積
部に蓄積された設備設計レコード１３２、一時蓄積部に
蓄積された設備現況レコード１３３として、図２の一時
蓄積部２に蓄積する。

【００３２】さらに、図１４に示すように、設備設計レ
コード三回目受信ファイル１４１として２つのレコード
（設備コード１００５，１００６）を、また、設備現況
レコード三回目受信ファイル１４２として２つのレコー
ド（設備コード１００４，１００５）を受信する。そし
て、これらの受信ファイル（１４１，１４２）内のレコ
ードと、図２の一時蓄積部２に蓄積された図１３のレコ
ード１３２，１３３に対して統合条件を評価することに
より、図１５における統合レコード１５１で示すよう
に、統合レコードを２つ（設備コード１００４，１００
５）作成する。

【００３３】しかし、設備コード１００１，１００６に
関しては、統合条件を満たさないので、統合条件満足回
数を統合基数未満（＝０）として、図１５に示す一時蓄
積部に蓄積された設備設計レコード１５２、一時蓄積部
に蓄積された設備現況レコード１５３として、図２の一
時蓄積部２に蓄積する。ここで、この一時蓄積部２に蓄
積するレコード（１５２，１５３）の内、受信日時フィ
ールドの値から統合処理時点までの経過日時が一時蓄積
期限（＝１日）を過ぎたもの、すなわち、設備コード１
００１の設備現況レコードが統合処理システム運用者に
エラー通知される。

【００３４】運用者は、このようにしてエラー通知され
たレコードをチェックし、例えば、設備設計レコード１
００１が投入漏れであることを検出する。このように、
本実施例においては、レコードの投入漏れがある場合、
いずれは、その統合相手のレコードが運用者にエラー通
知される。また、受信日のずれが１日（＝一時蓄積期
限）以内のレコードが、受信日のずれだけに起因してエ
ラー通知されることはない。従って、少ない数（本実施
例では「１」）のレコードだけが運用者にエラー通知さ
れることになる。

【００３５】次に、本発明の第３の実施例を、図１６〜
図２３に従って説明する。図１６は、本発明のデータ統
合方法の本発明に係る処理の第３の実施例を示すフロー
チャートである。本例の処理は、第１，第２の実施例と
同様に図２に示す構成のシステムにより行なわれる。ま
ず、統合制御情報管理部１により、統合条件およびレコ
ードタイプの組み合わせ毎に統合基数を予め設定し管理
する（ステップ１６１）。提供側システムからファイル
を受信すると（ステップ１６２）、統合前処理部３にお
いて、図１７に示すように、受信したファイル内のレコ
ード１７１に、統合条件満足回数フィールド１７２と被
統合処理回数フィールド１７３を追加し、統合条件満足
回数フィールド１７２および被統合処理回数フィールド
１７３の初期値としてそれぞれ「０」を設定する（ステ
ップ１６３）。

【００３６】次に、統合レコード作成部４において、受
信ファイル内のレコードおよび一時蓄積部２に蓄積した
各レコードについて統合条件を評価し、統合条件を満た
すレコードの組み合わせから統合レコードを作成する
（ステップ１６４）。そして、統合後処理部５におい
て、受信ファイル内のレコードおよび一時蓄積部２に蓄
積したレコードの内、次の図１８において詳細を示すよ
うに、一部のレコードを破棄し、残りを一時蓄積部２に
蓄積し、さらに、一時蓄積部２に蓄積されたレコードの
内、一時蓄積期限を越えて一時蓄積されているレコード
をエラー通知する（ステップ１６５）。

【００３７】図１８は、図１６における統合後処理の本
発明に係る詳細動作例を示すフローチャートである。以
降の動作を受信ファイル内の各レコードおよび一時蓄積
部に蓄積された各レコードについて行なう（ステップ１
８１）。まず、受信ファイル内の各レコードおよび一時
蓄積部２に蓄積された各レコードの内、未処理のレコー
ドを一つ取り出し（ステップ１８２）、図１７の統合条
件満足回数フィールド１７２に対して新たに統合条件を
満たした回数を加算し（ステップ１８３）、また、図１
７の被統合処理回数フィールド１７３に対して「１」を
加算する（ステップ１８４）。

【００３８】次に、図１７の統合条件満足回数フィール
ド１７２の値を統合制御情報管理部１に管理された統合
基数と比較し（ステップ１８５）、この統合条件満足回
数フィールド９２の値が統合基数に達したレコードを破
棄し（ステップ１８６）、達しないレコードを一時蓄積
部２に蓄積する（ステップ１８７）。さらに、この一時
蓄積部２に蓄積したレコードについて、図１７の被統合
処理回数フィールド１７３の値と統合制御情報管理部１
に管理された一時蓄積期限とを比較し（ステップ１８
８）、この被統合処理回数フィールド１７３の値が統合
制御情報管理部１に管理された一時蓄積期限を過ぎてい
るレコードを運用者にエラー通知する（ステップ１８
９）。

【００３９】このような処理の具体的な例を、設備設計
レコードと設備現況レコードとの統合の例を用いて、図
１９〜図２３に従って説明する。統合条件を以下の通り
とする。 設備設計、設備コード＝設備現況、設備コードＡＮＤ
設備設計、工事完了日＝設備現況、最新工事完了日 また、統合基数を以下の通りとする。 設備設計：１（設備設計レコードに対応する設備現況レ
コードは１つ） 設備現況：１（設備現況レコードに対応する最新の設備
設計レコードは１つ）

【００４０】また、一時蓄積期限は２回とする。また、
提供側システムおよび統合処理システムとも初期状態と
する ・一回目のファイル受信時の各提供側データベースの内
容は、対応する受信ファイルの内容と等しいものとす
る。 ・統合処理システムの一時蓄積部２に蓄積されているレ
コードはないものとする。

【００４１】まず、図１９に示すように、設備設計レコ
ード一回目受信ファイル１９１として１つのレコード
（設備コード１００２）を、また、設備現況レコード一
回目受信ファイル１９２として、同じく１つのレコード
（設備コード１００１）を受信する。それぞれの受信フ
ァイル（１９１，１９２）内のレコードに対して統合条
件を評価する。ここでは、統合条件を満たすレコードは
ないので、統合レコードは作成されない。そして、統合
条件満足回数が統合基数未満（＝０）であるレコード
（すなわち受信ファイル１９１，１９２内の全レコー
ド）を、それぞれ、一時蓄積部に蓄積された設備設計レ
コード１９３および一時蓄積部に蓄積された設備現況レ
コード１９４として示すように、一時蓄積部２に蓄積す
る。この時、それぞれのレコード（設備コード１００
１，１００２）の被統合処理回数は「１」に加算され
る。

【００４２】次に、図２０に示すように、設備設計レコ
ード二回目受信ファイル２０１として２つのレコード
（設備コード１００３，１００４）を、また、設備現況
レコード二回目受信ファイル２０２として２つのレコー
ド（設備コード１００２，１００３）を受信する。これ
らの受信ファイル２０１，２０２内のレコードと、図２
の一時蓄積部２に蓄積された図１９のレコード１９３，
１９４に対して統合条件を評価することにより、図２１
における統合レコード２１１で示すように、統合レコー
ドを２つ（設備コード１００２，１００３）作成する。
しかし、設備コード１００１，１００４に関しては、統
合条件を満たさないので、統合条件満足回数を統合基数
未満（＝０）として、図２０において、それぞれ、一時
蓄積部に蓄積された設備設計レコード２１２、一時蓄積
部に蓄積された設備現況レコード２１３として示すよう
に、図２の一時蓄積部２に蓄積する。ここで、設備コー
ド１００１のレコードの被統合処理回数は「２」とな
る。

【００４３】さらに、図２２に示すように、設備設計レ
コード三回目受信ファイル２２１として２つのレコード
（設備コード１００５，１００６）を、また、設備現況
レコード三回目受信ファイル２２２ととして２つのレコ
ード（設備コード１００４，１００５）を受信する。そ
して、これらの受信ファイル２２１，２２２内のレコー
ドと、図２の一時蓄積部２に蓄積された図２１のレコー
ド２１２，２１３に対して統合条件を評価することによ
り、図２３における統合レコード２３１で示す統合レコ
ードを２つ（設備コード１００４，１００５）作成す
る。

【００４４】しかし、設備コード１００１，１００６に
関しては、統合条件を満たさないので、統合条件満足回
数を統合基数未満（＝０）とし、図２３における一時蓄
積部に蓄積された設備設計レコード２３２、一時蓄積部
に蓄積された設備現況レコード２３３として、図２の一
時蓄積部２に蓄積する。ここで、一時蓄積部２に蓄積す
るレコード（２３２，２３３）の内、被統合処理回数が
一時蓄積期限（＝２回）を過ぎたもの、すなわち、設備
コード１００１の設備現況レコードが統合処理システム
運用者にエラー通知される。

【００４５】運用者は、このようにしてエラー通知され
たレコードをチェックし、例えば、設備設計データベー
スへの設備レコード１００１が投入漏れであることを検
出する。このように、本実施例においては、レコードの
投入漏れがある場合、いずれは、その統合相手のレコー
ドが運用者にエラー通知される。また、受信のずれが２
回（＝一時蓄積期限）以内のレコードが、受信回数のず
れだけに起因してエラー通知されることはない。従っ
て、少ない数（本実施例では「１」）のレコードだけが
運用者にエラー通知されることになる。

【００４６】以上、図１〜図２３を用いて説明したよう
に、本実施例のデータ統合方法では、受信ファイル内の
レコードに加えて、一時蓄積部に蓄積されたレコードを
も統合処理対象とする。このことにより、提供側システ
ムからの受信ファイルを全レコードファイルではなく、
差分ファイルとすることができる。さらに、一時蓄積部
２へのアクセスにより、提供側システムへのアドホック
アクセスを代替できる。従って、従来の技術に比較し、
提供側システムの性能圧迫を軽減できる。また、統合条
件を満たした総回数が統合基数に達したレコードは、一
時蓄積部２に蓄積されることなく破棄されるので、一時
蓄積部２に蓄積されるレコード数が際限なく拡張し続け
ることはない。

【００４７】さらに、レコードの投入漏れがあった場
合、その統合相手レコードの統合条件満足回数が統合基
数に達することはないため、いずれ統合相手レコードが
運用者にエラー通知される。運用者は、このエラー通知
に基づきレコードの投入漏れの有無を確認できる。この
場合、本実施例では、運用者にエラー通知が行なわれる
のは、一時蓄積期限で示される期間を越えて一時蓄積さ
れたレコードだけである。これにより、本来、統合条件
を満たすべき複数のレコードの受信時期にずれが生じた
場合でも、そのずれが一時蓄積期限以内ならば、先行し
て受信したレコードが運用者にエラー通知されることは
ない。従って、大量のレコードが運用者にエラー通知さ
れる危険性は少なく、本実施例は、レコードの投入漏れ
を見つけるための現実的な解となる。

【００４８】尚、本発明は、図１〜図２３を用いて説明
した実施例に限定されるものではなく、その要旨を逸脱
しない範囲において種々変更可能である。例えば、運用
者がエラー通知されたレコードを一時蓄積部２から削除
することにより、一時蓄積部に蓄積されるレコード数を
制限することが可能となる。

【００４９】

【発明の効果】本発明によれば、提供側システムからの
全レコード送信、あるいは、提供側システムへのアドホ
ックなアクセスが不要となり、提供側システムの性能の
圧迫を軽減できると共に、提供側データベースへのレコ
ードの投入漏れを高信頼かつ効率的に検出することが可
能である。

【図面の簡単な説明】

【図１】本発明のデータ統合方法の本発明に係る処理の
第１の実施例を示すフローチャートである。

【図２】図１における処理を行なうシステムの構成例を
示すブロック図である。

【図３】図１における処理の対象となるレコードの構成
例を示す説明図である。

【図４】図１における統合後処理の本発明に係る詳細動
作例を示すフローチャートである。

【図５】図１における処理の具体的な例を示す説明図の
１／３部分である。

【図６】図１における処理の具体的な例を示す説明図の
２／３部分である。

【図７】図１における処理の具体的な例を示す説明図の
３／３部分である。

【図８】本発明のデータ統合方法の本発明に係る処理の
第２の実施例を示すフローチャートである。

【図９】図８における処理の対象となるレコードの構成
例を示す説明図である。

【図１０】図８における統合後処理の本発明に係る詳細
動作例を示すフローチャートである。

【図１１】図８における処理の具体的な例を示す説明図
の１／５部分である。

【図１２】図８における処理の具体的な例を示す説明図
の２／５部分である。

【図１３】図８における処理の具体的な例を示す説明図
の３／５部分である。

【図１４】図８における処理の具体的な例を示す説明図
の４／５部分である。

【図１５】図８における処理の具体的な例を示す説明図
の５／５部分である。

【図１６】本発明のデータ統合方法の本発明に係る処理
の第３の実施例を示すフローチャートである。

【図１７】図１６における処理の対象となるレコードの
構成例を示す説明図である。

【図１８】図１６における統合後処理の本発明に係る詳
細動作例を示すフローチャートである。

【図１９】図１６における処理の具体的な例を示す説明
図の１／５部分である。

【図２０】図１６における処理の具体的な例を示す説明
図の２／５部分である。

【図２１】図１６における処理の具体的な例を示す説明
図の３／５部分である。

【図２２】図１６における処理の具体的な例を示す説明
図の４／５部分である。

【図２３】図１６における処理の具体的な例を示す説明
図の５／５部分である。

【図２４】従来の設備設計レコードと設備現況レコード
の統合例を示す説明図である。

【図２５】従来のデータ統合対象となる伝送路と専用線
との関係を示す説明図である。

【図２６】従来の伝送路レコードと専用線レコードの統
合例を示す説明図である。

【図２７】従来の全レコードファイル利用による統合処
理例を示す説明図である。

【図２８】従来の差分ファイル利用による統合処理例を
示す説明図である。

【符号の説明】

１：統合制御情報管理部，２：一時蓄積部、３：統合前
処理部、４：統合レコード作成部、５：統合後処理部、
３１：受信したファイル内のレコード、３２：統合条件
満足回数フィールド、５１：設備設計レコード一回目受
信ファイル、５２：設備現況レコード一回目受信ファイ
ル、６１：一回目統合処理で作成された統合レコード、
６２：一回目統合処理終了時点で一時蓄積部に蓄積され
た設備設計レコード、７１：設備設計レコード二回目受
信ファイル、７２：設備現況レコード二回目受信ファイ
ル、７３：二回目統合処理で作成された統合レコード、
９１：受信したファイル内のレコード、９２：統合条件
満足回数フィールド、９３：受信日時フィールド、１１
１ａ：設備設計レコード一回目受信ファイル、１１２
ａ：設備現況レコード一回目受信ファイル、１１３ａ：
一時蓄積部に蓄積された設備設計レコード、１１４ａ：
一時蓄積部に蓄積された設備現況レコード、１２１：設
備設計レコード二回目受信ファイル、１２２：設備現況
レコード二回目受信ファイル、１３１：二回目統合処理
で作成された統合レコード、１３２：一時蓄積部に蓄積
された設備設計レコード、１３３：一時蓄積部に蓄積さ
れた設備現況レコード、１４１：設備設計レコード三回
目受信ファイル、１４２：設備現況レコード三回目受信
ファイル、１５１：三回目統合処理で作成された統合レ
コード、１５２：一時蓄積部に蓄積された設備設計レコ
ード、１５３：一時蓄積部に蓄積された設備現況レコー
ド、１７１：受信したファイル内のレコード、１７２：
統合条件満足回数フィールド、１７３：被統合処理回数
フィールド、１９１：設備設計レコード一回目受信ファ
イル、１９２：設備現況レコード一回目受信ファイル、
１９３：一時蓄積部に蓄積された設備設計レコード、１
９４：一時蓄積部に蓄積された設備現況レコード、２０
１：設備設計レコード二回目受信ファイル、２０２：設
備現況レコード二回目受信ファイル、２１１：二回目統
合処理で作成された統合レコード、２１２：一時蓄積部
に蓄積された設備設計レコード、２１３：一時蓄積部に
蓄積された設備現況レコード、２２１：設備設計レコー
ド三回目受信ファイル、２２２：設備現況レコード三回
目受信ファイル、２３１：三回目統合処理で作成された
統合レコード、２３２：一時蓄積部に蓄積された設備設
計レコード、２３３：一時蓄積部に蓄積された設備現況
レコード、２４１：設備設計レコード、２４２：設備現
況レコード、２５１：伝送路、２５２：専用線、２６
１：伝送路レコード、２６２：専用線レコード、２７
１：提供側システムＸ、２７２：データベースＸ、２７
３：全レコードファイルＸ、２７４：提供側システム
Ｙ、２７５：データベースＹ、２７６：全レコードファ
イルＹ、２７７：利用側システム、２８１：提供側シス
テムＸ、２８２データベースＸ、２８３：全差分ファイ
ルＸ、２８４：提供側システムＹ、２８５：データベー
スＹ、２８６：差分ファイルＹ、２８７：利用側システ
ム、２８８，２８９：アドホックアクセス。

───────────────────────────────────────────────────── フロントページの続き (72)発明者 奥村 昌和 東京都新宿区西新宿三丁目19番２号 日 本電信電話株式会社内 (56)参考文献 特開 平４−199237（ＪＰ，Ａ) 特開 平４−360248（ＪＰ，Ａ) 特開 平６−214843（ＪＰ，Ａ) 特開 平５−225250（ＪＰ，Ａ) 特開 平５−81337（ＪＰ，Ａ) (58)調査した分野(Int.Cl.⁷，ＤＢ名) G06F 12/00 512 G06F 12/00 510 G06F 12/00 545

Claims (4)

(57)【特許請求の範囲】
1. 【請求項１】 複数のデータベースから送信された各フ
   ァイルを受信し、該受信した各ファイル内の各レコード
   が予め指定された統合条件を満たすか否かを評価し、該
   統合条件を満足したレコード同士をまとめて、新しいレ
   コードを作成するデータ統合方法において、上記評価
   時、上記各レコードの上記統合条件を満足した回数を各
   レコード毎に計数し、該回数が、上記統合条件を満足す
   る最大回数を表す統合基数に達したか否かを判別し、上
   記統合条件を満足した回数が上記統合基数に達しなかっ
   たレコードを、上記統合条件を満足した回数を対応付け
   て一時蓄積し、新たに上記各データベースから送信され
   た前回ファイルとの差分ファイルを受信し、該差分ファ
   イル内のレコードの評価時、上記一時蓄積したレコード
   を含めて上記評価および計数を行ない、上記一時蓄積し
   たレコードの内、上記統合条件を満足した回数が上記統
   合基数に達したレコードを一時蓄積から破棄し、上記各
   差分ファイル内のレコードおよび上記一時蓄積したレコ
   ードの内、上記統合条件を満足した回数が上記統合基数
   に達しなかったレコードを、次の差分ファイル受信時の
   上記評価用に、上記統合条件を満足した回数を対応付け
   て一時蓄積することを特徴とするデータ統合方法。
2. 【請求項２】 複数のデータベースから送信された各フ
   ァイルを受信し、該受信した各ファイル内の各レコード
   が予め指定された統合条件を満たすか否かを評価し、該
   統合条件を満足したレコード同士をまとめて、新しいレ
   コードを作成するデータ統合方法において、上記評価
   時、上記各レコードの上記統合条件を満足した回数を各
   レコード毎に計数し、該回数が、上記統合条件を満足す
   る最大回数を表す統合基数に達したか否かを判別し、上
   記統合条件を満足した回数が上記統合基数に達しなかっ
   たレコードを、上記統合条件を満足した回数と最初に受
   信した日時を対応付けて一時蓄積し、新たに上記各デー
   タベースから送信された前回ファイルとの差分ファイル
   を受信し、該差分ファイル内のレコードの評価時、上記
   一時蓄積したレコードを含めて上記評価および計数を行
   ない、上記一時蓄積したレコードの内、上記統合条件を
   満足した回数が上記統合基数に達したレコードを一時蓄
   積から破棄し、上記各差分ファイル内のレコードおよび
   上記一時蓄積したレコードの内、上記統合条件を満足し
   た回数が上記統合基数に達しなかったレコードを、次の
   差分ファイル受信時の再評価用に、上記統合条件を満足
   した回数と最初に受信した日時を対応付けて一時蓄積
   し、かつ、該再評価用に一時蓄積するレコードの内、上
   記受信日時から予め設定された蓄積期限を越えたレコー
   ドを抽出して、エラー通知することを特徴とするデータ
   統合方法。
3. 【請求項３】 複数のデータベースから送信された各フ
   ァイルを受信し、該受信した各ファイル内の各レコード
   が予め指定された統合条件を満たすか否かを評価し、該
   統合条件を満足したレコード同士をまとめて、新しいレ
   コードを作成するデータ統合方法において、上記評価
   時、上記各レコードの上記統合条件を満足した回数を各
   レコード毎に計数し、該回数が、上記統合条件を満足す
   る最大回数を表す統合基数に達したか否かを判別し、上
   記統合条件を満足した回数が上記統合基数に達しなかっ
   たレコードを、上記統合条件を満足した回数と上記評価
   を受けた総回数（被統合処理回数）を対応付けて一時蓄
   積し、新たに上記各データベースから送信された前回フ
   ァイルとの差分ファイルを受信し、該差分ファイル内の
   レコードの評価時、上記一時蓄積したレコードを含めて
   上記評価および計数を行ない、上記一時蓄積したレコー
   ドの内、上記統合条件を満足した回数が上記統合基数に
   達したレコードを一時蓄積から破棄し、上記各差分ファ
   イル内のレコードおよび上記一時蓄積したレコードの
   内、上記統合条件を満足した回数が上記統合基数に達し
   なかったレコードを、次の差分ファイル受信時の再評価
   用に、上記統合条件を満足した回数と上記被統合処理回
   数を対応付けて一時蓄積し、かつ、該再評価用に一時蓄
   積するレコードの内、上記被統合処理回数が予め設定さ
   れた回数を越えたレコードを抽出して、エラー通知する
   ことを特徴とするデータ統合方法。
4. 【請求項４】 請求項１から請求項３のいずれかに記載
   のデータ統合方法において、上記レコードへの上記統合
   条件を満足した回数の対応付けは、上記レコードに、上
   記統合条件を満足した回数を登録するフィールドを追加
   して行なうことを特徴とするデータ統合方法。