(57)【要約】      （修正有）【課題】データ処理に係る処理定義の構築を容易に行うことができるデータ処理装置およびデータ処理方法を提供する。【解決手段】データ処理装置は、部品プログラムを実行する順番を示す処理順情報と、部品プログラムに与えるパラメータ情報と、を別々に記憶している。そして、部品プログラムを処理順情報が示す順番にしたがって呼び出し、部品プログラムを呼び出す際に、当該部品プログラムに係る実行識別情報に関連付けられたパラメータ取得式情報を用いてパラメータ情報を取得して当該部品プログラムに与える。【選択図】図７
2020077080.tif 000002
【特許請求の範囲】
【請求項１】
複数の部品プログラムを組み合わせて構成したデータ処理を実行する装置であって、
前記部品プログラムを示す処理種別情報と、前記部品プログラムを実行する順番を示す処理順情報と、前記部品プログラムの実行を識別するための実行識別情報と、を関連付けて記憶する実行処理記憶部と、
前記実行識別情報と、前記部品プログラムに与えるパラメータ情報と、を関連付けて記憶するパラメータ記憶部と、
前記処理種別情報と、前記パラメータ情報を前記パラメータ記憶部から取得するためのパラメータ取得式情報と、を関連付けて記憶するパラメータ取得式記憶部と、
前記処理種別情報が示す前記部品プログラムを前記処理順情報が示す順番にしたがって呼び出し、前記部品プログラムを呼び出す際に、当該部品プログラムに係る前記実行識別情報に関連付けられた前記パラメータ取得式情報を用いて前記パラメータ記憶部から前記パラメータ情報を取得して当該部品プログラムに与えるデータ処理実行部と、を有することを特徴とするデータ処理装置。
【請求項２】
前記実行処理記憶部は、
１つまたは複数の前記部品プログラムを有する処理グループを示す処理グループ情報と、前記処理グループを実行する順番を示す実行順情報と、を関連付ける実行処理グループテーブルと、
前記処理グループ情報と、前記処理種別情報と、前記処理順情報と、前記実行識別情報と、を関連付ける処理グループ定義テーブルと、を記憶する、請求項１に記載のデータ処理装置。
【請求項３】
前記処理グループ定義テーブルは、前記処理グループ情報と、前記処理種別情報と、前記処理順情報と、前記実行識別情報と、に加えて、さらに、前記部品プログラムへの入力データを示す入力情報と、前記部品プログラムからの出力データを示す出力情報と、を関連付けるテーブルである、請求項２に記載のデータ処理装置。
【請求項４】
前記パラメータ記憶部は、前記実行識別情報と、前記パラメータ情報と、を関連付けるパラメータテーブルを記憶し、
前記パラメータ取得式記憶部は、前記処理種別情報と、前記パラメータ取得式情報と、を関連付けるパラメータ取得式テーブルを記憶する、請求項１〜請求項３のいずれか一項に記載のデータ処理装置。
【請求項５】
前記複数の部品プログラムで共通に利用される共通パラメータ情報を記憶する共通パラメータ記憶部をさらに有する、請求項１〜請求項４のいずれか一項に記載のデータ処理装置。
【請求項６】
前記パラメータ取得式情報は、データベース言語の言語仕様に基づくものである、請求項１〜請求項５のいずれか一項に記載のデータ処理装置。
【請求項７】
前記データ処理実行部におけるデータ処理の実行数が同時実行上限数を超えないように制御する並列実行数制御部をさらに有している、請求項１〜請求項６のいずれか一項に記載のデータ処理装置。
【請求項８】
複数の部品プログラムを組み合わせて構成したデータ処理をコンピュータで実行する方法であって、
前記部品プログラムを示す処理種別情報と、前記部品プログラムを実行する順番を示す処理順情報と、前記部品プログラムの実行を識別するための実行識別情報と、を関連付けて実行処理記憶部に記憶し、
前記実行識別情報と、前記部品プログラムに与えるパラメータ情報と、を関連付けてパラメータ記憶部に記憶し、
前記処理種別情報と、前記パラメータ情報を前記パラメータ記憶部から取得するためのパラメータ取得式情報と、を関連付けてパラメータ取得式記憶部に記憶し、
前記コンピュータが、前記処理種別情報が示す前記部品プログラムを前記処理順情報が示す順番にしたがって呼び出し、前記部品プログラムを呼び出す際に、当該部品プログラムに係る前記実行識別情報に関連付けられた前記パラメータ取得式情報を用いて前記パラメータ記憶部から前記パラメータ情報を取得して当該部品プログラムに与えることを特徴とするデータ処理方法。
【発明の詳細な説明】
【技術分野】
【０００１】
本発明は、データ処理装置およびデータ処理方法に関する。特に、データベースなどから必要なデータを抽出（Ｅｘｔｒａｃｔ）し、所定の形式に変換・加工（Ｔｒａｎｓｆｏｒｍ）したのち、データウエアハウスやデータレイクなどに登録（Ｌｏａｄ）するＥＴＬ処理を行うデータ処理装置およびデータ処理方法に関する。
【背景技術】
【０００２】
特許文献１にデータ処理装置の一例であるデータ連携システムが開示されている。特許文献１のデータ連携システムは、送信元システムから受信したデータを変換・加工して受信先システムへの送信データを生成するデータ変換・加工部分を有する。このデータ連携システムは、データ変換・加工用単体部品プログラムをデータ変換・加工部分で必要な処理の内容や順序に適う形で組み合わせることによってデータ処理に係る処理定義を構築している。
【０００３】
このようなデータ処理に係る処理定義を構築するためのツールとして、例えば、ＰＥＮＴＡＨＯ（登録商標）が知られている。ＰＥＮＴＡＨＯでは、グラフィカルユーザーインターフェース（ＧＵＩ）アプリケーションを用い、各種データの取り込み処理や変換・加工処理などを行う部品プログラムをマウス操作により配置して、配置した部品プログラムを矢印でつなぐことで処理の流れを定義する。ＰＥＮＴＡＨＯを用いることで、視覚的に処理定義を構築することができる。
【先行技術文献】
【特許文献】
【０００４】
【特許文献１】特開２００５−３２２１５９号公報
【発明の概要】
【発明が解決しようとする課題】
【０００５】
上述したＰＥＮＴＡＨＯでは、ＧＵＩアプリケーションにおいて各部品プログラムに対して直接パラメータを設定して定義ファイルを保存することによりデータ処理に係る処理定義を構築する。そのため、構築済の処理定義に対してパラメータの一部のみ異なる新たな処理定義を構築する場合にも、ＧＵＩアプリケーションを起動して各部品プログラムに対してパラメータを設定することが必要となる。これにより、処理定義を構築する作業がかえって煩雑となる。また、ＧＵＩアプリケーションの操作を習得している必要もある。
【０００６】
そこで、本発明は、データ処理に係る処理定義の構築を容易に行うことができるデータ処理装置およびデータ処理方法を提供することを目的とする。
【課題を解決するための手段】
【０００７】
上記目的を達成するために、本発明の一態様に係るデータ処理装置は、複数の部品プログラムを組み合わせて構成したデータ処理を実行する装置であって、前記部品プログラムを示す処理種別情報と、前記部品プログラムを実行する順番を示す処理順情報と、前記部品プログラムの実行を識別するための実行識別情報と、を関連付けて記憶する実行処理記憶部と、前記実行識別情報と、前記部品プログラムに与えるパラメータ情報と、を関連付けて記憶するパラメータ記憶部と、前記処理種別情報と、前記パラメータ情報を前記パラメータ記憶部から取得するためのパラメータ取得式情報と、を関連付けて記憶するパラメータ取得式記憶部と、前記処理種別情報が示す前記部品プログラムを前記処理順情報が示す順番にしたがって呼び出し、前記部品プログラムを呼び出す際に、当該部品プログラムに係る前記実行識別情報に関連付けられた前記パラメータ取得式情報を用いて前記パラメータ記憶部から前記パラメータ情報を取得して当該部品プログラムに与えるデータ処理実行部と、を有することを特徴とする。
【０００８】
本発明において、前記実行処理記憶部は、（１）１つまたは複数の前記部品プログラムを有する処理グループを示す処理グループ情報と、前記処理グループを実行する順番を示す実行順情報と、を関連付ける実行処理グループテーブルと、（２）前記処理グループ情報と、前記処理種別情報と、前記処理順情報と、前記実行識別情報と、を関連付ける処理グループ定義テーブルと、を記憶することが好ましい。
【０００９】
本発明において、前記処理グループ定義テーブルは、前記処理グループ情報と、前記処理種別情報と、前記処理順情報と、前記実行識別情報と、に加えて、さらに、前記部品プログラムへの入力データを示す入力情報と、前記部品プログラムからの出力データを示す出力情報と、を関連付けるテーブルであることが好ましい。
【００１０】
本発明において、前記パラメータ記憶部は、前記実行識別情報と、前記パラメータ情報と、を関連付けるパラメータテーブルを記憶し、前記パラメータ取得式記憶部は、前記処理種別情報と、前記パラメータ取得式情報と、を関連付けるパラメータ取得式テーブルを記憶することが好ましい。
【００１１】
本発明において、前記複数の部品プログラムで共通に利用される共通パラメータ情報を記憶する共通パラメータ記憶部をさらに有することが好ましい。
【００１２】
本発明において、前記パラメータ取得式情報は、データベース言語の言語仕様に基づくものであることが好ましい。
【００１３】
本発明において、前記データ処理実行部におけるデータ処理の実行数が同時実行上限数を超えないように制御する並列実行数制御部をさらに有していることが好ましい。
【００１４】
上記目的を達成するために、本発明の他の一態様に係るデータ処理方法は、複数の部品プログラムを組み合わせて構成したデータ処理をコンピュータで実行する方法であって、前記部品プログラムを示す処理種別情報と、前記部品プログラムを実行する順番を示す処理順情報と、前記部品プログラムの実行を識別するための実行識別情報と、を関連付けて実行処理記憶部に記憶し、前記実行識別情報と、前記部品プログラムに与えるパラメータ情報と、を関連付けてパラメータ記憶部に記憶し、前記処理種別情報と、前記パラメータ情報を前記パラメータ記憶部から取得するためのパラメータ取得式情報と、を関連付けてパラメータ取得式記憶部に記憶し、前記コンピュータが、前記処理種別情報が示す前記部品プログラムを前記処理順情報が示す順番にしたがって呼び出し、前記部品プログラムを呼び出す際に、当該部品プログラムに係る前記実行識別情報に関連付けられた前記パラメータ取得式情報を用いて前記パラメータ記憶部から前記パラメータ情報を取得して当該部品プログラムに与えることを特徴とする。
【発明の効果】
【００１５】
本発明によれば、部品プログラムを実行する順番を示す処理順情報と、部品プログラムに与えるパラメータ情報と、を別々に記憶している。そして、部品プログラムを処理順情報が示す順番にしたがって呼び出し、部品プログラムを呼び出す際に、当該部品プログラムに係る実行識別情報に関連付けられたパラメータ取得式情報を用いてパラメータ情報を取得して当該部品プログラムに与える。このようにしたことから、部品プログラムを実行する際にパラメータ情報を動的に与える構成を有するので、部品プログラムを実行する順番とパラメータ情報とを互いに独立して管理・変更することができる。また、部品プログラムに応じたパラメータ取得式情報を用いることにより、各種パラメータ形式に柔軟に対応することができる。そのため、データ処理に係る処理定義の構築を容易に行うことができる。
【００１６】
また、処理順情報やパラメータ情報などの各種情報をテーブル形式（表形式）で記憶することにより、これら情報について容易に理解することができ、管理・変更を容易に行うことができる。
【００１７】
また、複数の部品プログラムで共通に利用される共通パラメータ情報を記憶する共通パラメータ記憶部をさらに有することで、共通パラメータ情報を一元管理することができる。
【００１８】
また、パラメータ取得式情報が、データベース言語の言語仕様に基づくものであることで、パラメータ取得式情報について容易に理解することができ、管理・変更を容易に行うことができる。
【００１９】
また、データ処理実行部におけるデータ処理の実行数が同時実行上限数を超えないように制御する並列実行数制御部をさらに有していることで、データ処理装置の処理能力を超えたデータ処理が実行されることを抑制することができる。
【図面の簡単な説明】
【００２０】
【図１】本発明の一実施形態に係るデータ処理装置を有するデータ連携システムの概略構成を示す図である。
【図２】データ処理装置の機能ブロック図である。
【図３】データ処理装置が有する実行処理記憶部を説明する図である。
【図４】データ処理装置が有するパラメータ記憶部を説明する図である。
【図５】データ処理装置が有するパラメータ取得式記憶部を説明する図である。
【図６】データ処理装置が有する環境変数記憶部を説明する図である。
【図７】データ処理装置が有するデータ処理実行部の動作の一例を示すフローチャートである。
【図８】データ処理実行部によって取得される処理リスト情報の一例を示す図である。
【図９】データ処理実行部によって作成される処理日時管理テーブルの一例を示す図である。
【図１０】データ処理実行部によって作成される実行ログテーブルの一例を示す図である。
【図１１】データ処理実行部によって取得されるパラメータ情報データの一例を示す図である。
【発明を実施するための形態】
【００２１】
以下、本発明の一実施形態に係るデータ処理装置を有するデータ連携システムについて、図１〜図１１を参照して説明する。
【００２２】
図１は、本発明の一実施形態に係るデータ処理装置を有するデータ連携システムの概略構成を示す図である。図２は、図１のデータ処理装置の機能ブロック図である。図３〜図６は、図１のデータ処理装置が有する実行処理記憶部、パラメータ記憶部、パラメータ取得式記憶部および環境変数記憶部を説明する図である。図７は、図１のデータ処理装置が有するデータ処理実行部の動作の一例を示すフローチャートである。図８は、データ処理実行部によって取得される処理リスト情報である。図９および図１０は、データ処理実行部によって作成される処理日時管理テーブルおよび実行ログテーブルである。図１１は、データ処理実行部によって取得されるパラメータ情報データの一例を示す図である。
【００２３】
データ連携システム１は、図１に示すように、企業における販売管理や生産管理などの基幹業務に用いるデータベースを有する基幹システム１０と、企業の経営分析などに用いるデータを蓄えるデータウエアハウス２０と、を有している。また、データ連携システム１は、基幹システム１０のデータを変換・加工してデータウエアハウス２０に登録するデータ処理装置３０を有している。基幹システム１０と、データウエアハウス２０と、データ処理装置３０と、はローカルエリアネットワークやインターネットなどのネットワークを介して接続されている。
【００２４】
データ処理装置３０は、中央処理装置（ＣＰＵ）、メモリ、記憶装置およびネットワークや入出力装置が接続される各種外部インタフェースなどを備えたコンピュータで構成されている。データ処理装置３０は、データ処理として、基幹システム１０からデータを抽出（Ｅｘｔｒａｃｔ）し、所定の形式に変換・加工（Ｔｒａｎｓｆｏｒｍ）したのち、データウエアハウス２０に登録（Ｌｏａｄ）するＥＴＬ処理を行うものである。
【００２５】
本実施形態において、データ処理装置３０が実行するデータ処理は、１または複数の処理グループを有している。各処理グループは、１または複数の部品プログラムを有している。各部品プログラムは、１つの機能のみの単体処理または少数の単体処理を組み合わせた複合処理を行うものである。
【００２６】
データ処理装置３０は、図２に示すように、部品プログラム記憶部２０２と、実行処理記憶部２０３と、パラメータ記憶部２０４と、パラメータ取得式記憶部２０５と、共通パラメータ記憶部としての環境変数記憶部２０６と、ログ記憶部２０７と、並列実行数制御部２０８と、データ処理実行部２０９と、を有している。
【００２７】
部品プログラム記憶部２０２、実行処理記憶部２０３、パラメータ記憶部２０４、パラメータ取得式記憶部２０５、環境変数記憶部２０６およびログ記憶部２０７は、例えば、ハードディスク装置などの記憶装置により構成されている。各記憶部に対し１つのハードディスク装置を割り当てて構成してもよく、または、全ての記憶部を１つのハードディスク装置で構成してもよい。または、これら記憶部は、インターネットなどのネットワークを介してアクセス可能なクラウドストレージにより構成されていてもよい。
【００２８】
並列実行数制御部２０８およびデータ処理実行部２０９は、メモリ上に展開されたアプリケーションプログラムを中央処理装置（ＣＰＵ）が実行することにより実現される機能部である。
【００２９】
部品プログラム記憶部２０２は、部品プログラムの実行ファイルを記憶する。部品プログラム記憶部２０２に記憶された部品プログラムが行う処理の例を以下の（１）〜（６）に示す。
【００３０】
（１）対象データを抽出しファイルに出力するＤＢデータ抽出処理
（２）第１入力データに第２入力データの情報を追加するルックアップ処理
（３）２つの入力データを結合する結合処理
（４）入力データを編集し出力する値編集処理
（５）入力データを元にデータベース言語ＳＱＬの言語仕様に基づくＳＱＬステートメントを作成し実行するＳＱＬ実行処理
（６）データウエアハウス２０にデータを登録するデータ登録処理
【００３１】
もちろん、部品プログラム記憶部２０２は、ここに挙げた（１）〜（６）以外の処理を行う部品プログラムを記憶していてもよい。
【００３２】
実行処理記憶部２０３は、図３に示すように、実行ファイルテーブル３１０と、実行処理グループテーブル３２０と、処理グループ定義テーブル３３０と、を記憶する。
【００３３】
実行ファイルテーブル３１０は、処理種別情報３１１と、第１入力形式情報３１２と、第２入力形式情報３１３と、実行ファイル名情報３１４と、を関連付けた行データを格納するテーブルである。
【００３４】
処理種別情報３１１は、部品プログラムを示す情報である。本実施形態において、処理種別情報３１１は部品プログラムの名称（部品プログラム名）が設定される。
【００３５】
第１入力形式情報３１２は、処理種別情報３１１が示す部品プログラムの第１入力データの形式を示す情報である。本実施形態において、基幹システム１０などのデータベースから第１入力データを取得する場合は「table」が設定され、記憶装置に格納されたファイルやデータ処理により生成した中間ファイルなどから第１入力データを取得する場合は「file」が設定される。
【００３６】
第２入力形式情報３１３は、処理種別情報３１１が示す部品プログラムの第２入力データの形式を示す情報である。本実施形態において、基幹システム１０などのデータベースから第２入力データを取得する場合は「table」が設定され、記憶装置に格納されたファイルやデータ処理により生成した中間ファイルなどから第２入力データを取得する場合は「file」が設定される。
【００３７】
実行ファイル名情報３１４は、処理種別情報３１１が示す部品プログラムの実行ファイルの名称（ファイル名）を示す情報である。
【００３８】
本実施形態において、実行ファイルテーブル３１０では、（１）処理種別情報３１１、（２）第１入力形式情報３１２、（３）第２入力形式情報３１３、（４）実行ファイル名情報３１４、として、次の値が互いに関連付けられている。
【００３９】
（１）「DBデータ抽出」、（２）「table」、（３）「」、（４）「1340」；
【００４０】
（１）「ルックアップ」、（２）「file」、（３）「file」、（４）「1400」；
【００４１】
（１）「結合」、（２）「file」、（３）「file」、（４）「1150」；
【００４２】
（１）「値編集」、（２）「file」、（３）「」、（４）「1220」；
【００４３】
（１）「SQL実行」、（２）「file」、（３）「」、（４）「1200」；
【００４４】
（１）「SQL実行」、（２）「table」、（３）「」、（４）「1210」；
【００４５】
（１）「データ登録」、（２）「file」、（３）「」、（４）「1240」；
【００４６】
実行処理グループテーブル３２０は、処理ＩＤ情報３２１と、テーブルＩＤ情報３２２と、処理グループ情報３２３と、実行フラグ情報３２４と、実行順情報３２５と、を関連付けた行データを格納するテーブルである。
【００４７】
処理ＩＤ情報３２１は、複数の部品プログラムを組み合わせることにより構成されたデータ処理を一意に識別するための情報である。
【００４８】
テーブルＩＤ情報３２２は、処理ＩＤ情報３２１により識別されるデータ処理において生成された情報を格納するデータウエアハウス２０のデータテーブルを一意に識別するための情報である。
【００４９】
処理グループ情報３２３は、処理ＩＤ情報３２１により識別されるデータ処理が有する処理グループを示す情報である。処理グループは、１つの部品プログラム、または、複数の部品プログラムを組み合わせることにより構成されている。本実施形態において、処理グループ情報３２３には、処理グループの名称（処理グループ名）が設定される。
【００５０】
実行フラグ情報３２４は、処理ＩＤ情報３２１により識別されるデータ処理が有する処理グループのそれぞれの実行要否を示す情報である。本実施形態において、実行フラグ情報３２４には、処理グループを実行する場合は「Y」が設定され、処理グループを実行しない場合は「N」が設定される。
【００５１】
実行順情報３２５は、処理ＩＤ情報３２１により識別されるデータ処理が有する処理グループを実行する順番を示す情報である。
【００５２】
本実施形態において、実行処理グループテーブル３２０では、（１）処理ＩＤ情報３２１、（２）テーブルＩＤ情報３２２、（３）処理グループ情報３２３、（４）実行フラグ情報３２４、（５）実行順情報３２５、として次の値が互いに関連付けられている。
【００５３】
（１）「BJ01」、（２）「」、（３）「共通_処理日付更新」、（４）「Y」、（５）「1」；
【００５４】
（１）「BJ01」、（２）「」、（３）「BJ_データ抽出」、（４）「Y」、（５）「2」；
【００５５】
（１）「BJ01」、（２）「MITSUMORI」、（３）「BJ_見積情報生成登録」、（４）「Y」、（５）「3」；
【００５６】
処理グループ定義テーブル３３０は、処理グループ情報３３１と、処理順情報３３２と、実行識別情報３３３と、処理種別情報３３４と、部品プログラムからの出力データを示す出力情報としての第１出力ファイル情報３３５および第２出力ファイル情報３３６と、部品プログラムへの入力データを示す入力情報としての第１入力形式情報３３７、第１入力データ情報３３８、第２入力形式情報３３９および第２入力データ情報３４０と、を関連付けた行データを格納するテーブルである。
【００５７】
処理グループ情報３３１は、実行処理グループテーブル３２０の処理グループ情報３２３と同じく、処理グループを示す情報である。
【００５８】
処理順情報３３２は、処理グループ情報３３１が示す処理グループを構成する部品プログラムを実行する順番を示す情報である。
【００５９】
実行識別情報３３３は、同一の部品プログラムに異なるパラメータ情報を与えて実行する際にそれぞれの部品プログラムの実行を識別するための情報である。換言すると、部品プログラムに与えるパラメータ情報を識別するための情報でもある。
【００６０】
処理種別情報３３４は、実行ファイルテーブル３１０の処理種別情報３１１と同じく、部品プログラムを示す情報である。本実施形態において、処理種別情報３３４は処理グループ情報３３１と関連付けられることにより、処理グループ情報３３１が示す処理グループを構成する部品プログラムであることを示す。
【００６１】
第１出力ファイル情報３３５は、処理種別情報３３４が示す部品プログラムが出力するファイルを示す情報である。本実施形態において、第１出力ファイル情報には、ファイルのパスおよび名称（ファイル名）が設定される。
【００６２】
第２出力ファイル情報３３６は、処理種別情報３３４が示す部品プログラムが出力するファイルを示す情報である。本実施形態において、第２出力ファイル情報には、ファイルのパスおよび名称（ファイル名）が設定される。
【００６３】
第１入力形式情報３３７は、処理種別情報３３４が示す部品プログラムの第１入力データの形式を示す情報である。本実施形態において、基幹システム１０などのデータベースから第１入力データを取得する場合は「table」が設定され、記憶装置に格納されたファイルやデータ処理により生成した中間ファイルなどから第１入力データを取得する場合は「file」が設定される。
【００６４】
第１入力データ情報３３８は、処理種別情報３３４が示す部品プログラムの第１入力データを示す情報である。本実施形態において、第１入力形式情報３３７に「table」が設定されている場合、第１入力データ情報３３８にはＳＱＬステートメントが設定される。また、第１入力形式情報３３７に「file」が設定されている場合、第１入力データ情報３３８には第１入力データが格納されているファイルのパスおよび名称（ファイル名）が設定される。
【００６５】
第２入力形式情報３３９は、処理種別情報３３４が示す部品プログラムの第２入力データの形式を示す情報である。本実施形態において、基幹システム１０などのデータベースから第２入力データを取得する場合は「table」が設定され、記憶装置に格納されたファイルやデータ処理により生成した中間ファイルなどから第２入力データを取得する場合は「file」が設定される。
【００６６】
第２入力データ情報３４０は、処理種別情報３３４が示す部品プログラムの第２入力データを示す情報である。本実施形態において、第２入力形式情報３３９に「table」が設定されている場合、第２入力データ情報３４０にはＳＱＬステートメントが設定される。また、第２入力形式情報３３９に「file」が設定されている場合、第２入力データ情報３４０には第２入力データが格納されているファイルのパスおよび名称（ファイル名）が設定される。
【００６７】
本実施形態において、処理グループ定義テーブル３３０では、（１）処理グループ情報３３１、（２）処理順情報３３２、（３）実行識別情報３３３、（４）処理種別情報３３４、（５）第１出力ファイル情報３３５、（６）第２出力ファイル情報３３６、（７）第１入力形式情報３３７、（８）第１入力データ情報３３８、（９）第２入力形式情報３３９、（１０）第２入力データ情報３４０、として、次の値が互いに関連付けられている。
【００６８】
（１）「共通_処理日付更新」、（２）「1」、（３）「sql_処理日付更新」、（４）「SQL実行」、（５）「」、（６）「」、（７）「table」、（８）「select '${処理ID}' as [処理ID]」、（９）「」、（１０）「」；
【００６９】
（１）「BJ_データ抽出」、（２）「1」、（３）「BJ_データ抽出」、（４）「DBデータ抽出」、（５）「${作業パス}/見積ヘッダ.csv」、（６）「」、（７）「table」、（８）「select * from [見積ヘッダ情報]」、（９）「」、（１０）「」；
【００７０】
（１）「BJ_データ抽出」、（２）「2」、（３）「BJ_データ抽出」、（４）「DBデータ抽出」、（５）「${作業パス}/見積明細.csv」、（６）「」、（７）「table」、（８）「select * from [見積明細情報]」、（９）「」、（１０）「」；
【００７１】
（１）「BJ_データ抽出」、（２）「3」、（３）「BJ_データ抽出」、（４）「DBデータ抽出」、（５）「${作業パス}/CUST.csv」、（６）「」、（７）「table」、（８）「select 顧客ID,顧客名 from [顧客マスタ情報]」、（９）「」、（１０）「」；
【００７２】
（１）「BJ_データ抽出」、（２）「4」、（３）「BJ_データ抽出」、（４）「DBデータ抽出」、（５）「${作業パス}/PRODUCT.csv」、（６）「」、（７）「table」、（８）「select 商品ID,商品名 from [商品マスタ情報]」、（９）「」、（１０）「」；
【００７３】
（１）「BJ_見積情報生成登録」、（２）「1」、（３）「顧客名ルックアップ」、（４）「ルックアップ」、（５）「${作業パス}/見積ヘッダ編集.csv」、（６）「」、（７）「file」、（８）「${作業パス}/見積ヘッダ.csv」、（９）「file」、（１０）「${作業パス}/CUST.csv」；
【００７４】
（１）「BJ_見積情報生成登録」、（２）「2」、（３）「商品名ルックアップ」、（４）「ルックアップ」、（５）「${作業パス}/見積明細編集.csv」、（６）「」、（７）「file」、（８）「${作業パス}/見積明細.csv」、（９）「file」、（１０）「${作業パス}/PRODUCT.csv」；
【００７５】
（１）「BJ_見積情報生成登録」、（２）「3」、（３）「合計金額計算」、（４）「値編集」、（５）「${作業パス}/見積明細編集.csv」、（６）「」、（７）「file」、（８）「${作業パス}/見積明細編集.csv」、（９）「」、（１０）「」；
【００７６】
（１）「BJ_見積情報生成登録」、（２）「4」、（３）「見積情報結合」、（４）「結合」、（５）「${作業パス}/見積情報.csv」、（６）「」、（７）「file」、（８）「${作業パス}/見積ヘッダ編集.csv」、（９）「file」、（１０）「${作業パス}/見積明細編集.csv」；
【００７７】
（１）「BJ_見積情報生成登録」、（２）「5」、（３）「sql_テーブルクリア」、（４）「SQL実行」、（５）「」、（６）「」、（７）「table」、（８）「select '${テーブルID}' as [テーブルID]」、（９）「」、（１０）「」；
【００７８】
（１）「BJ_見積情報生成登録」、（２）「6」、（３）「tableout_データ登録」、（４）「データ登録」、（５）「」、（６）「」、（７）「file」、（８）「${作業パス}/見積情報.csv」、（９）「」、（１０）「」；
【００７９】
パラメータ記憶部２０４は、図４に示すように、ＤＢデータ抽出処理パラメータテーブル４１０と、ルックアップ処理パラメータテーブル４２０と、結合処理パラメータテーブル４３０と、値編集処理パラメータテーブル４４０と、ＳＱＬ実行処理パラメータテーブル４５０と、データ登録処理パラメータテーブル４６０と、を記憶する。
【００８０】
ＤＢデータ抽出処理パラメータテーブル４１０は、ＤＢデータ抽出処理に係る部品プログラムに与えるパラメータ情報が設定される。ＤＢデータ抽出処理パラメータテーブル４１０では、実行識別情報４１１と、部品プログラムに与えるパラメータ情報としての実行ファイル名情報４１２と、を関連付けた行データを格納するテーブルである。
【００８１】
実行識別情報４１１は、処理グループ定義テーブル３３０の実行識別情報３３３と同じく、同一の部品プログラムに異なるパラメータ情報を与えて実行する際にそれぞれの実行を一意に識別するための情報である。
【００８２】
実行ファイル名情報４１２は、実行識別情報４１１によって識別される実行に係る部品プログラムから呼び出される実行ファイルの名称（ファイル名）を示す情報である。
【００８３】
本実施形態において、ＤＢデータ抽出処理パラメータテーブル４１０では、（１）実行識別情報４１１、（２）実行ファイル名情報４１２、として、次の値が互いに関連付けられている。
【００８４】
（１）「BJ_データ抽出」、（２）「penDT_BJ0001」；
【００８５】
ルックアップ処理パラメータテーブル４２０は、ルックアップ処理に係る部品プログラムに与えるパラメータ情報が設定される。ルックアップ処理パラメータテーブル４２０は、実行識別情報４２１と、部品プログラムに与えるパラメータ情報としての第１結合条件情報４２２、第２結合条件情報４２３、取得項目情報４２４、取得項目別名情報４２５および初期値情報４２６と、を関連付けた行データを格納するテーブルである。
【００８６】
実行識別情報４２１は、処理グループ定義テーブル３３０の実行識別情報３３３と同じく、同一の部品プログラムに異なるパラメータ情報を与えて実行する際にそれぞれの実行を一意に識別するための情報である。
【００８７】
第１結合条件情報４２２は、ルックアップ処理の対象となる第１入力データと第２入力データとを結びつけるためのキーとなる項目を示す情報である。本実施形態において、第１結合条件情報４２２には、第１入力データに含まれる項目名が設定される。
【００８８】
第２結合条件情報４２３は、ルックアップ処理の対象となる第１入力データと第２入力データとを結びつけるためのキーとなる項目を示す情報である。本実施形態において、第２結合条件情報４２３には、第２入力データに含まれる項目名が設定される。
【００８９】
取得項目情報４２４は、第１結合条件情報４２２が示す第１入力データの項目と第２結合条件情報４２３が示す第２入力データの項目とが一致した場合に、第２入力データから取得する項目を示す情報である。本実施形態において、取得項目情報４２４には、第２入力データに含まれる項目名が設定される。
【００９０】
取得項目別名情報４２５は、第１結合条件情報４２２が示す第１入力データの項目と第２結合条件情報４２３が示す第２入力データの項目とが一致した場合に取得した第２入力データの項目を設定する第１入力データの項目を示す情報である。本実施形態において、取得項目別名情報４２５には、第１入力データに設定する項目名が設定される。
【００９１】
初期値情報４２６は、第１結合条件情報４２２が示す第１入力データの項目と第２結合条件情報４２３が示す第２入力データの項目とが一致しない場合に行う処理を示す情報である。
【００９２】
本実施形態において、ルックアップ処理パラメータテーブル４２０では、（１）実行識別情報４２１、（２）第１結合条件情報４２２、（３）第２結合条件情報４２３、（４）取得項目情報４２４、（５）取得項目別名情報４２５、（６）初期値情報４２６、として次の値が互いに関連付けられている。
【００９３】
（１）「顧客名ルックアップ」、（２）「CUST_ID」、（３）「顧客ID」、（４）「顧客名」、（５）「CUST_NAME」、（６）「廃止」；
【００９４】
（１）「商品名ルックアップ」、（２）「PRODUCT_ID」、（３）「商品ID」、（４）「商品名」、（５）「PRODUCT_NAME」、（６）「廃止」；
【００９５】
結合処理パラメータテーブル４３０は、結合処理に係る部品プログラムに与えるパラメータ情報が設定される。結合処理パラメータテーブル４３０は、実行識別情報４３１と、部品プログラムに与えるパラメータ情報としての区分情報４３２、第１結合条件情報４３３、第２結合条件情報４３４、取得項目情報４３５、取得項目別名情報４３６および除去項目名情報４３７と、を関連付けた行データを格納するテーブルである。
【００９６】
実行識別情報４３１は、処理グループ定義テーブル３３０の実行識別情報３３３と同じく、同一の部品プログラムに異なるパラメータ情報を与えて実行する際にそれぞれの実行を一意に識別するための情報である。
【００９７】
区分情報４３２は、結合処理の区分を示す情報である。本実施形態において、区分情報４３２には、内部結合「inner」／左外部結合「left」／右外部結合「right」が設定される。
【００９８】
内部結合では、第１入力データおよび第２入力データから、第１結合条件情報４３３が示す第１入力データの項目と第２結合条件情報４３４が示す第２入力データの項目とが一致する行データのみ抽出して結合する。左外部結合では、第１入力データおよび第２入力データから、第１結合条件情報４３３が示す第１入力データの項目と第２結合条件情報４３４が示す第２入力データの項目とが一致する行データを抽出して結合するとともに、第１入力データにしか存在しない行データも抽出する。右外部結合では、第１入力データおよび第２入力データから、第１結合条件情報４３３が示す第１入力データの項目と第２結合条件情報４３４が示す第２入力データの項目とが一致する行データを抽出して結合するとともに、第２入力データにしか存在しない行も抽出する。
【００９９】
第１結合条件情報４３３は、結合処理の対象となる第１入力データと第２入力データとを結びつけるためのキーとなる項目を示す情報である。本実施形態において、第１結合条件情報４３３には、第１入力データに含まれる項目名が設定される。
【０１００】
第２結合条件情報４３４は、結合処理の対象となる第１入力データと第２入力データとを結びつけるためのキーとなる項目を示す情報である。本実施形態において、第２結合条件情報４３４には、第２入力データに含まれる項目名が設定される。
【０１０１】
取得項目情報４３５は、結合処理により取得する項目を示す情報である。本実施形態において、取得項目情報４３５には、第１入力データまたは第２入力データに含まれる項目名が設定される。
【０１０２】
取得項目別名情報４３６は、結合処理により取得した取得項目情報４３５が示す項目を設定する別の項目の名称を示す情報である。なお、取得項目情報４３５および取得項目別名情報４３６がともに空欄の場合、取得可能な項目を全て取得する。
【０１０３】
除去項目名情報４３７は、結合処理によって得た行データから除去する項目の名称を示す情報である。
【０１０４】
本実施形態において、結合処理パラメータテーブル４３０では、（１）実行識別情報４３１、（２）区分情報４３２、（３）第１結合条件情報４３３、（４）第２結合条件情報４３４、（５）取得項目情報４３５、（６）取得項目別名情報４３６、（７）除去項目名情報４３７、として次の値が互いに関連付けられている。
【０１０５】
（１）「見積情報結合」、（２）「inner」、（３）「MTS_NO」、（４）「MTS_NO」、（５）「」、（６）「」、（７）「」；
【０１０６】
値編集処理パラメータテーブル４４０は、値編集処理に係る部品プログラムに与えるパラメータ情報が設定される。値編集処理パラメータテーブル４４０は、実行識別情報４４１と、部品プログラムに与えるパラメータ情報としての編集式情報４４２、項目名情報４４３、型情報４４４、長さ情報４４５、精度情報４４６および値編集処理順情報４４７と、を関連付けた行データを格納するテーブルである。
【０１０７】
実行識別情報４４１は、処理グループ定義テーブル３３０の実行識別情報３３３と同じく、同一の部品プログラムに異なるパラメータ情報を与えて実行する際にそれぞれの実行を一意に識別するための情報である。
【０１０８】
編集式情報４４２は、値編集処理に係る部品プログラムにて値編集に用いられる編集式を示す情報である。本実施形態において、編集式は、プログラミング言語Ｊａｖａ（登録商標）の言語仕様に基づくものである。
【０１０９】
項目名情報４４３は、編集式情報４４２に設定されている編集式を用いて編集された値が設定される項目の名称（項目名）を示す情報である。
【０１１０】
型情報４４４は、項目名情報４４３が示す項目名に係る値の型を示す情報である。
【０１１１】
長さ情報４４５は、項目名情報４４３が示す項目名に係る値の長さを示す情報である。
【０１１２】
精度情報４４６は、項目名情報４４３が示す項目名に係る値の精度を示す情報である。
【０１１３】
値編集処理順情報４４７は、値編集処理に係る部品プログラムによって値編集処理パラメータテーブル４４０に含まれる編集式を実行する順番を示す情報である。
【０１１４】
本実施形態において、値編集処理パラメータテーブル４４０では、（１）実行識別情報４４１、（２）編集式情報４４２、（３）項目名情報４４３、（４）型情報４４４と、（５）長さ情報４４５、（６）精度情報４４６、（７）値編集処理順情報４４７、として次の値が互いに関連付けられている。
【０１１５】
（１）「合計金額計算」、（２）「java.math.BigDecimal.valueOf(java.lang.Double. parseDouble(TANKA)*java.lang.Double.parseDouble(SURYO)).toPlainString()」、（３）「TTL_KNGK」、（４）「String」、（５）「」、（６）「」、（７）「1」；
【０１１６】
ＳＱＬ実行処理パラメータテーブル４５０は、ＳＱＬ実行処理に係る部品プログラムに与えるパラメータ情報が設定される。ＳＱＬ実行処理パラメータテーブル４５０は、実行識別情報４５１と、部品プログラムに与えるパラメータ情報としてのＳＱＬ生成式情報４５２と、を関連付けた行データを格納するテーブルである。
【０１１７】
実行識別情報４５１は、処理グループ定義テーブル３３０の実行識別情報３３３と同じく、同一の部品プログラムに異なるパラメータ情報を与えて実行する際にそれぞれの実行を一意に識別するための情報である。
【０１１８】
ＳＱＬ生成式情報４５２は、ＳＱＬ実行処理に係る部品プログラムに与えるＳＱＬステートメントを生成するためのＳＱＬ生成式を示す情報である。本実施形態において、ＳＱＬ生成式は、プログラミング言語Ｊａｖａ（登録商標）の言語仕様（関数、演算子）に基づいて表現されたＳＱＬステートメントが設定されている。
【０１１９】
本実施形態において、ＳＱＬ実行処理パラメータテーブル４５０では、（１）実行識別情報４５１、（２）ＳＱＬ生成式情報４５２、として、次の値が互いに関連付けられている。
【０１２０】
（１）「sql_処理日付更新」、（２）「"UPDATE [処理日付管理] SET [処理日時]=getdate() WHERE [処理ID]='" + 処理ID + "'"」；
【０１２１】
（１）「sql_テーブルクリア」、（２）「"TRUNCATE TABLE '" + テーブルID + "'"」；
【０１２２】
データ登録処理パラメータテーブル４６０は、データ登録処理に係る部品プログラムに与えるパラメータ情報が設定される。データ登録処理パラメータテーブル４６０は、実行識別情報４６１と、部品プログラムに与えるパラメータ情報としての登録テーブルＩＤ情報４６２、バルクインサートフラグ情報４６３、バルクインサート開始行情報４６４および改行コード変換フラグ情報４６５と、を関連付けた行データを格納するテーブルである。
【０１２３】
実行識別情報４６１は、処理グループ定義テーブル３３０の実行識別情報３３３と同じく、同一の部品プログラムに異なるパラメータ情報を与えて実行する際にそれぞれの実行を一意に識別するための情報である。
【０１２４】
登録テーブルＩＤ情報４６２は、データ処理によって生成したデータを登録するデータウエアハウス２０のテーブルを一意に識別するための情報である。
【０１２５】
バルクインサートフラグ情報４６３は、テーブルに複数の行データを一括して挿入するバルクインサートを行うか否かを示す情報である。バルクインサートフラグ情報４６３が「Y」のとき、テーブルに複数の行データを一括して挿入し、「N」のとき、テーブルに１つ行データを挿入する通常のインサートを行う。
【０１２６】
バルクインサート開始行情報４６４は、バルクインサートフラグ情報４６３が「Y」のときに行うバルクインサートにおいてデータの挿入を開始する行を示す情報である。
【０１２７】
改行コード変換フラグ情報４６５は、テーブルにデータを登録する際にデータに含まれる改行コードの変換を行うか否かを示す情報である。改行コード変換フラグ情報４６５が「Y」のとき、改行コードの変換を行い、「N」のとき改行コードの変換を行わない。
【０１２８】
本実施形態において、データ登録処理パラメータテーブル４６０では、（１）実行識別情報４６１、（２）登録テーブルＩＤ情報４６２、（３）バルクインサートフラグ情報４６３、（４）バルクインサート開始行情報４６４、（５）改行コード変換フラグ情報４６５、として、次の値が互いに関連付けられている。
【０１２９】
（１）「tableout_データ登録」、（２）「${テーブルID}」、（３）「N」、（４）「」、（５）「N」；
【０１３０】
パラメータ取得式記憶部２０５は、図５に示すように、パラメータ取得式テーブル５１０を記憶する。
【０１３１】
パラメータ取得式テーブル５１０は、処理種別情報５１１と、パラメータ取得式情報５１２と、を関連付けた行データを格納するテーブルである。
【０１３２】
処理種別情報５１１は、実行ファイルテーブル３１０の処理種別情報３１１と同じく、部品プログラムを示す情報である。
【０１３３】
パラメータ取得式情報５１２は、パラメータ記憶部２０４に記憶された各パラメータテーブルから各部品プログラムに与えるパラメータ情報を取得するため情報である。本実施形態において、パラメータ取得式情報５１２には、データベース言語ＳＱＬの言語仕様に基づくＳＱＬステートメントが設定される。
【０１３４】
本実施形態において、パラメータ取得式テーブル５１０では、（１）処理種別情報５１１、（２）パラメータ取得式情報５１２、として、次の値が互いに関連付けられている。
【０１３５】
（１）「DBデータ抽出」、（２）「"SELECT [実行ファイル名] as [PRM_01], '' [PRM_02], '' [PRM_03], '' [PRM_04], '' [PRM_05], '' [PRM_06], '' [PRM_07], '' [PRM_08], '' [PRM_09], '' [PRM_10] FROM [tblinput] WHERE [ETL_ID]='${ETL_ID}'"；
【０１３６】
（１）「ルックアップ」、（２）「"SELECT [結合条件1] as [PRM_01], [結合条件2] as [PRM_02], [取得項目] as [PRM_03], [取得項目別名] as [PRM_04], [初期値] as [PRM_05], '' [PRM_06], '' [PRM_07], '' [PRM_08], '' [PRM_09], '' [PRM_10] FROM [lookup] WHERE [ETL_ID]='${ETL_ID}'"；
【０１３７】
（１）「結合」、（２）「"SELECT LEFT('${実行ファイル名}',11) + (CASE WHEN [結合タイプ]='left' THEN '1' ELSE '2' END) as [PRM_01], [結合条件1] as [PRM_02], [結合条件2] as PRM_03, [項目別名] as [PRM_04], [項目名] as PRM_05, [除去項目] as PRM_06, '' [PRM_07], '' [PRM_08], '' [PRM_09], '' [PRM_10] FROM [join] WHERE [ETL_ID] ='${ETL_ID}'"；
【０１３８】
（１）「値編集」、（２）「SELECT '' PRM_01, '' PRM_02, '' PRM_03, '' PRM_04, '' PRM_05, '' PRM_06, '' PRM_07, '' PRM_08, '' PRM_09, '' PRM_10；
【０１３９】
（１）「SQL実行」、「"SELECT [SQL生成Java式] as PRM_01,'' [PRM_02], '' [PRM_03], '' [PRM_04], '' [PRM_05], '' [PRM_06], '' [PRM_07], '' [PRM_08], '' [PRM_09], '' [PRM_10] FROM [sql] WHERE [ETL_ID]='${ETL_ID}'"；
【０１４０】
（１）「データ登録」、（２）「"SELECT [登録テーブルID] as PRM_01, [バルクインサートフラグ] as PRM_02, [バルクインサート開始行] as PRM_03, [改行コード変換フラグ] as PRM_04, '' [PRM_06], '' [PRM_07], '' [PRM_08], '' [PRM_09], '' [PRM_10]
FROM [tableout] WHERE [ETL_ID]='${ETL_ID}'"；
【０１４１】
本実施形態において、パラメータ取得式情報５１２に設定されたＳＱＬステートメント（パラメータ取得式）では、ＤＢデータ抽出処理パラメータテーブル４１０を「tblinput」として参照し、ルックアップ処理パラメータテーブル４２０を「lookup」として参照し、結合処理パラメータテーブル４３０を「join」として参照し、ＳＱＬ実行処理パラメータテーブル４５０を「sql」として参照し、データ登録処理パラメータテーブル４６０を「tableout」として参照する。
【０１４２】
また、パラメータ取得式情報５１２に設定されたＳＱＬステートメントでは、ＤＢデータ抽出処理パラメータテーブル４１０の実行識別情報４１１、ルックアップ処理パラメータテーブル４２０の実行識別情報４２１、結合処理パラメータテーブル４３０の実行識別情報４３１、値編集処理パラメータテーブル４４０の実行識別情報４４１、ＳＱＬ実行処理パラメータテーブル４５０の実行識別情報４５１、および、データ登録処理パラメータテーブル４６０の実行識別情報４６１、を「ETL_ID」として参照する。
【０１４３】
また、パラメータ取得式情報５１２に設定されたＳＱＬステートメントでは、ルックアップ処理パラメータテーブル４２０の第１結合条件情報４２２を「結合条件1」として参照し、第２結合条件情報４２３を「結合条件2」として参照する。
【０１４４】
また、パラメータ取得式情報５１２に設定されたＳＱＬステートメントでは、結合処理パラメータテーブル４３０の区分情報４３２を「結合タイプ」として参照し、第１結合条件情報４３３を「結合条件1」として参照し、第２結合条件情報４３４を「結合条件2」として参照し、取得項目情報４３５を「項目名」として参照し、取得項目別名情報４３６を「項目別名」として参照し、除去項目名情報４３７を「除去項目」として参照する。
【０１４５】
また、パラメータ取得式情報５１２に設定されたＳＱＬステートメントでは、ＳＱＬ実行処理パラメータテーブル４５０のＳＱＬ生成式情報４５２を「SQL生成Java式」として参照する。
【０１４６】
環境変数記憶部２０６は、図６に示すように、環境変数テーブル６１０を記憶する。
【０１４７】
環境変数テーブル６１０は、１つのデータ処理において複数の部品プログラムで共通に利用される変数（共通パラメータ情報）、または、複数のデータ処理にまたがって共通に利用される変数（共通パラメータ情報）が設定される。環境変数テーブル６１０は、処理ＩＤ情報６１１と、変数名情報６１２と、設定値情報６１３と、を関連付けた行データを格納するテーブルである。
【０１４８】
処理ＩＤ情報６１１は、実行処理グループテーブル３２０の処理ＩＤ情報３２１と同じく、複数の部品プログラムを組み合わせることにより構成されたデータ処理を一意に識別するための情報である。または、処理ＩＤ情報６１１は、複数のデータ処理にまたがって共通に利用されることを示す情報である。前者の場合、各データ処理に割り当てられた固有の識別値（例えば、「BJ01」など）が設定され、後者の場合、共通で利用されることを示す識別値（例えば、「共通」など）が設定される。
【０１４９】
変数名情報６１２は、変数の名称（変数名）を示す情報である。
【０１５０】
設定値情報６１３は、変数名情報６１２が示す変数に設定される値である。
【０１５１】
本実施形態において、環境変数テーブル６１０では、（１）処理ＩＤ情報６１１、（２）変数名情報６１２、（３）設定値情報６１３、として、次の値が互いに関連付けられている。
【０１５２】
（１）「BJ01」、（２）「CSV項目区切文字」、（３）「,」；
【０１５３】
（１）「BJ01」、（２）「CSV項目囲み文字」、（３）「"」；
【０１５４】
（１）「BJ01」、（２）「作業パス」、（３）「${ルートパス}/rcv/BJ」；
【０１５５】
（１）「BJ01」、（２）「ＤＢ名」、（３）「B_S1」；
【０１５６】
（１）「共通」、（２）「文字コード」、（３）「UTF-8」；
【０１５７】
（１）「共通」、（２）「コミットサイズ」、（３）「100000」；
【０１５８】
（１）「共通」、（２）「CSVバッファサイズ」、（３）「100000」；
【０１５９】
（１）「共通」、（２）「ソートバッファサイズ」、（３）「100000」；
【０１６０】
（１）「共通」、（２）「ルートパス」、（３）「/opt/hulft/data」；
【０１６１】
（１）「共通」、（２）「ログファイル出力パス」、（３）「${ルートパス}/log」；
【０１６２】
（１）「共通」、（２）「共通ファイル格納パス」、（３）「${ルートパス}/common」；
【０１６３】
（１）「共通」、（２）「退避ファイル取得SQL」、（３）「SELECT distinct [出力ファイル1] FROM [処理グループ定義] a WHERE [入力形式1]='file' AND [実行処理グループ] IN (select [処理グループ] from [実行処理グループ] where 処理ID='${処理ID}' and [実行フラグ]='Y') 」；
【０１６４】
（１）「共通」、（２）「DBデータ抽出時の置換」、（３）「.replaceAll("\r\n",""). replaceAll("\r","").replaceAll("\t","")」；
【０１６５】
本実施形態において、環境変数テーブル６１０には、複数のデータ処理にまたがって共通で利用される変数として、データ処理において利用するコンピュータリソースの割り当てに係る「コミットサイズ」、「CSVバッファサイズ」、「ソートバッファサイズ」などが格納されている。これらコンピュータリソースの割り当てに係る変数を環境変数テーブル６１０に格納して共通に利用することで各変数の値の統一性を確保することができ、データ処理装置３０の安定稼働に貢献する。また、環境変数テーブル６１０には、複数の部品プログラムで共通に利用される変数（共通パラメータ情報）が格納されている。このようにすることで、共通パラメータ情報を一元管理することができる。
【０１６６】
ログ記憶部２０７は、データ処理において出力される実行ログや警告ログなどを記憶する。
【０１６７】
並列実行数制御部２０８は、例えば、外部インタフェースに接続されたネットワークや入力装置などから処理ＩＤ情報を含むデータ処理実行要求を受け付け、データ処理実行要求の処理ＩＤ情報により識別されるデータ処理を実行するようにデータ処理実行部２０９に要求する。このとき、並列実行数制御部２０８は、データ処理実行部２０９よって実行されるデータ処理の開始／終了を監視してデータ処理の実行数を管理し、データ処理の実行数が所定の同時実行上限数を超えないように制御する。本実施形態では、同時実行上限数は、データ処理を構成する処理グループ単位で設定されており、データ処理実行要求時に指定されるデータ処理を構成する処理グループの実行数を管理し、処理グループの実行数が所定の同時実行上限数を超えないように制御する。
【０１６８】
データ処理実行部２０９は、各記憶部に格納された各テーブルに格納されている情報に基づいて各種データ処理を実行する。
【０１６９】
以下に、データ処理実行部２０９の動作の一例について、図７のフローチャートを参照して説明する。
【０１７０】
データ処理実行部２０９は、並列実行数制御部２０８からデータ処理実行要求を受けると、データ処理実行要求に係るデータ処理の実行を開始する。
【０１７１】
ステップＳ１１０において、データ処理実行部２０９は、環境変数を取得する。具体的には、データ処理実行部２０９は、データ処理実行要求の処理ＩＤ情報と一致する処理ＩＤ情報６１１を含む行データを環境変数テーブル６１０から取得する。さらに、データ処理実行部２０９は、「共通」が設定された処理ＩＤ情報６１１を含む行データを環境変数テーブル６１０から取得する。そして、取得した行データに含まれる変数名情報６１２が示す変数に設定値情報６１３に設定された値を代入する。
【０１７２】
ステップＳ１２０において、データ処理実行部２０９は、図８に一例を示す処理リスト情報８１０を取得する。具体的には、データ処理実行部２０９は、以下の（ｉ）〜（ｉｖ）を行う。
【０１７３】
（ｉ）データ処理実行要求の処理ＩＤ情報と一致する処理ＩＤ情報３２１を含みかつ実行フラグ情報３２４に「Y」が設定された行データを実行処理グループテーブル３２０から取得する。
【０１７４】
（ｉｉ）上記（ｉ）で取得した実行処理グループテーブル３２０の行データの処理グループ情報３２３および処理グループ定義テーブル３３０の処理グループ情報３３１をキーとして、実行処理グループテーブル３２０から取得した行データの処理ＩＤ情報３２１、テーブルＩＤ情報３２２および実行順情報３２５と、処理グループ定義テーブル３３０の処理順情報３３２、実行識別情報３３３、処理種別情報３３４、第１出力ファイル情報３３５、第２出力ファイル情報３３６、第１入力形式情報３３７、第１入力データ情報３３８、第２入力形式情報３３９および第２入力データ情報３４０と、を取得する。
【０１７５】
（ｉｉｉ）上記（ｉｉ）で取得した処理グループ定義テーブル３３０の処理種別情報３３４、実行ファイルテーブル３１０の処理種別情報３１１およびパラメータ取得式テーブル５１０の処理種別情報５１１をキーとして、実行ファイルテーブル３１０の実行ファイル名情報３１４と、パラメータ取得式テーブル５１０のパラメータ取得式情報５１２と、を取得する。
【０１７６】
（ｉｖ）上記（ｉｉ）および（ｉｉｉ）で取得した各種情報を結合して処理リスト情報８１０を取得する。
【０１７７】
処理リスト情報８１０は、実行順情報８１１と、処理順情報８１２と、実行ファイル名情報８１３と、パラメータ取得式情報８１４と、処理ＩＤ情報８１５と、テーブルＩＤ情報８１６と、処理グループ情報８１７と、実行識別情報８１８と、処理種別情報８１９と、第１出力ファイル情報８２０と、第２出力ファイル情報８２１と、第１入力形式情報８２２と、第１入力データ情報８２３と、第２入力形式情報８２４と、第２入力データ情報８２５と、を互いに関連付けた行データの集まり（処理リスト）である。処理リスト情報８１０の行データは、部品プログラム、そのパラメータ情報およびその入出力データに係る情報を含んでいる。
【０１７８】
実行順情報８１１には、実行処理グループテーブル３２０の実行順情報３２５が設定される。
【０１７９】
処理順情報８１２には、処理グループ定義テーブル３３０の処理順情報３３２が設定される。
【０１８０】
実行ファイル名情報８１３には、実行ファイルテーブル３１０の実行ファイル名情報３１４が設定される。
【０１８１】
パラメータ取得式情報８１４には、パラメータ取得式テーブル５１０のパラメータ取得式情報５１２が設定される。
【０１８２】
処理ＩＤ情報８１５には、実行処理グループテーブル３２０の処理ＩＤ情報３２１が設定される。
【０１８３】
テーブルＩＤ情報８１６には、実行処理グループテーブル３２０のテーブルＩＤ情報３２２が設定される。
【０１８４】
処理グループ情報８１７、実行識別情報８１８、処理種別情報８１９、第１出力ファイル情報８２０、第２出力ファイル情報８２１、第１入力形式情報８２２、第１入力データ情報８２３、第２入力形式情報８２４および第２入力データ情報８２５には、処理グループ定義テーブル３３０の処理グループ情報３３１、実行識別情報３３３、処理種別情報３３４、第１出力ファイル情報３３５、第２出力ファイル情報３３６、第１入力形式情報３３７、第１入力データ情報３３８、第２入力形式情報３３９および第２入力データ情報３４０が設定される。
【０１８５】
本実施形態において、処理リスト情報８１０では、（１）実行順情報８１１、（２）処理順情報８１２、（３）実行ファイル名情報８１３、（４）パラメータ取得式情報８１４、（５）処理ＩＤ情報８１５、（６）テーブルＩＤ情報８１６、（７）処理グループ情報８１７、（８）実行識別情報８１８、（９）処理種別情報８１９、（１０）第１出力ファイル情報８２０、（１１）第２出力ファイル情報８２１、（１２）第１入力形式情報８２２、（１３）第１入力データ情報８２３、（１４）第２入力形式情報８２４、（１５）第２入力データ情報８２５、として、次の値が互いに関連付けられている。
【０１８６】
（１）「1」、（２）「1」、（３）「1210」、（４）「"SELECT [SQL生成Java式] as PRM_01,'' [PRM_02], '' [PRM_03], '' [PRM_04], '' [PRM_05], '' [PRM_06], '' [PRM_07], '' [PRM_08], '' [PRM_09], '' [PRM_10] FROM [sql] WHERE [ETL_ID]='${ETL_ID}'"」、（５）「BJ01」、（６）「」、（７）「共通_処理日付更新」、（８）「sql_処理日付更新」、（９）「SQL実行」、（１０）「」、（１１）「」、（１２）「table」、（１３）「select '${処理ID}' as [処理ID]」、（１４）「」、（１５）「」；
【０１８７】
（１）「2」、（２）「1」、（３）「1340」、（４）「"SELECT [実行ファイル名] as [PRM_01], '' [PRM_02], '' [PRM_03], '' [PRM_04], '' [PRM_05], '' [PRM_06], '' [PRM_07], '' [PRM_08], '' [PRM_09], '' [PRM_10] FROM [tblinput] WHERE [ETL_ID]='${ETL_ID}'"」、（５）「BJ01」、（６）「」、（７）「BJ_データ抽出」、（８）「BJ_データ抽出」、（９）「DBデータ抽出」、（１０）「${作業パス}/見積ヘッダ.csv」、（１１）「」、（１２）「table」、（１３）「select * from [見積ヘッダ情報]」、（１４）「」、（１５）「」；
【０１８８】
（１）「2」、（２）「2」、（３）「1340」、（４）「"SELECT [実行ファイル名] as [PRM_01], '' [PRM_02], '' [PRM_03], '' [PRM_04], '' [PRM_05], '' [PRM_06], '' [PRM_07], '' [PRM_08], '' [PRM_09], '' [PRM_10] FROM [tblinput] WHERE [ETL_ID]='${ETL_ID}'"」、（５）「BJ01」、（６）「」、（７）「BJ_データ抽出」、（８）「BJ_データ抽出」、（９）「DBデータ抽出」、（１０）「${作業パス}/見積明細.csv」、（１１）「」、（１２）「table」、（１３）「select * from [見積明細情報]」、（１４）「」、（１５）「」；
【０１８９】
（１）「2」、（２）「3」、（３）「1340」、（４）「"SELECT [実行ファイル名] as [PRM_01], '' [PRM_02], '' [PRM_03], '' [PRM_04], '' [PRM_05], '' [PRM_06], '' [PRM_07], '' [PRM_08], '' [PRM_09], '' [PRM_10] FROM [tblinput] WHERE [ETL_ID]='${ETL_ID}'"」、（５）「BJ01」、（６）「」、（７）「BJ_データ抽出」、（８）「BJ_データ抽出」、（９）「DBデータ抽出」、（１０）「${作業パス}/CUST.csv」、（１１）「」、（１２）「table」、（１３）「select 顧客ID,顧客名 from [顧客マスタ情報]」、（１４）「」、（１５）「」；
【０１９０】
（１）「2」、（２）「4」、（３）「1340」、（４）「"SELECT [実行ファイル名] as [PRM_01], '' [PRM_02], '' [PRM_03], '' [PRM_04], '' [PRM_05], '' [PRM_06], '' [PRM_07], '' [PRM_08], '' [PRM_09], '' [PRM_10] FROM [tblinput] WHERE [ETL_ID]='${ETL_ID}'"」、（５）「BJ01」、（６）「」、（７）「BJ_データ抽出」、（８）「BJ_データ抽出」、（９）「DBデータ抽出」、（１０）「${作業パス}/PRODUCT.csv」、（１１）「」、（１２）「table」、（１３）「select 商品ID,商品名 from [商品マスタ情報]」、（１４）「」、（１５）「」；
【０１９１】
（１）「3」、（２）「1」、（３）「1400」、（４）「"SELECT [結合条件1] as [PRM_01], [結合条件2] as [PRM_02], [取得項目] as [PRM_03], [取得項目別名] as [PRM_04], [初期値] as [PRM_05], '' [PRM_06], '' [PRM_07], '' [PRM_08], '' [PRM_09], '' [PRM_10] FROM [lookup] WHERE [ETL_ID]='${ETL_ID}'"」、（５）「BJ01」、（６）「MITSUMORI」、（７）「BJ_見積情報生成登録」、（８）「顧客名ルックアップ」、（９）「ルックアップ」、（１０）「${作業パス}/見積ヘッダ編集.csv」、（１１）「」、（１２）「file」、（１３）「${作業パス}/見積ヘッダ.csv」、（１４）「file」、（１５）「${作業パス}/CUST.csv」；
【０１９２】
（１）「3」、（２）「2」、（３）「1400」、（４）「"SELECT [結合条件1] as [PRM_01], [結合条件2] as [PRM_02], [取得項目] as [PRM_03], [取得項目別名] as [PRM_04], [初期値] as [PRM_05], '' [PRM_06], '' [PRM_07], '' [PRM_08], '' [PRM_09], '' [PRM_10] FROM [lookup] WHERE [ETL_ID]='${ETL_ID}'"」、（５）「BJ01」、（６）「MITSUMORI」、（７）「BJ_見積情報生成登録」、（８）「商品名ルックアップ」、（９）「ルックアップ」、（１０）「${作業パス}/見積明細編集.csv」、（１１）「」、（１２）「file」、（１３）「${作業パス}/見積明細.csv」、（１４）「file」、（１５）「${作業パス}/PRODUCT.csv」；
【０１９３】
（１）「3」、（２）「3」、（３）「1220」、（４）「SELECT '' PRM_01, '' PRM_02, '' PRM_03, '' PRM_04, '' PRM_05, '' PRM_06, '' PRM_07, '' PRM_08, '' PRM_09, '' PRM_10」、（５）「BJ01」、（６）「MITSUMORI」、（７）「BJ_見積情報生成登録」、（８）「合計金額計算」、（９）「値編集」、（１０）「${作業パス}/見積明細編集.csv」、（１１）「」、（１２）「file」、（１３）「${作業パス}/見積明細編集.csv」、（１４）「」、（１５）「」；
【０１９４】
（１）「3」、（２）「4」、（３）「1150」、（４）「"SELECT LEFT('${実行ファイル名}',11) + (CASE WHEN [結合タイプ]='left' THEN '1' ELSE '2' END) as [PRM_01], [結合条件1] as [PRM_02], [結合条件2] as PRM_03, [項目別名] as [PRM_04], [項目名] as PRM_05, [除去項目] as PRM_06, '' [PRM_07], '' [PRM_08], '' [PRM_09], '' [PRM_10] FROM [join] WHERE [ETL_ID]='${ETL_ID}'"」、（５）「BJ01」、（６）「MITSUMORI」、（７）「BJ_見積情報生成登録」、（８）「見積情報結合」、（９）「結合」、（１０）「${作業パス}/見積情報.csv」、（１１）「」、（１２）「file」、（１３）「${作業パス}/見積ヘッダ編集.csv」、（１４）「file」、（１５）「${作業パス}/見積明細編集.csv」；
【０１９５】
（１）「3」、（２）「5」、（３）「1210」、（４）「"SELECT [SQL生成Java式] as PRM_01,'' [PRM_02], '' [PRM_03], '' [PRM_04], '' [PRM_05], '' [PRM_06], '' [PRM_07], '' [PRM_08], '' [PRM_09], '' [PRM_10] FROM [sql] WHERE [ETL_ID]='${ETL_ID}'"」、（５）「BJ01」、（６）「MITSUMORI」、（７）「BJ_見積情報生成登録」、（８）「sql_テーブルクリア」、（９）「SQL実行」、（１０）「」、（１１）「」、（１２）「table」、（１３）「select '${テーブルID}' as [テーブルID]」、（１４）「」、（１５）「」；
【０１９６】
（１）「3」、（２）「6」、（３）「1240」、（４）「"SELECT [登録テーブルID] as PRM_01, [バルクインサートフラグ] as PRM_02, [バルクインサート開始行] as PRM_03, [改行コード変換フラグ] as PRM_04, '' [PRM_06], '' [PRM_07], '' [PRM_08], '' [PRM_09], '' [PRM_10] FROM [tableout] WHERE [ETL_ID]='${ETL_ID}'"」、（５）「BJ01」、（６）「MITSUMORI」、（７）「BJ_見積情報生成登録」、（８）「tableout_データ登録」、（９）「データ登録」、（１０）「」、（１１）「」、（１２）「file」、（１３）「${作業パス}/見積情報.csv」、（１４）「」、（１５）「」；
【０１９７】
ステップＳ１３０において、データ処理実行部２０９は、処理リスト情報８１０に格納されている行データからなる処理リストを全て実行したか否かを判定する。具体的には、データ処理実行部２０９は、実行順情報８１１が小さい方から順に、そして、実行順情報８１１が同じであれば処理順情報８１２が小さい方から順に、処理リスト情報８１０の行データを１つずつ取得する。このとき、処理リスト情報８１０から全ての行データを取得済みであり取得可能な行データが存在しなければ、処理リストを全て実行したものと判定してフローチャートを終了する（ステップＳ１３０でＹ）。または、処理リスト情報８１０に取得していない行データが残っており、行データを取得することができれば、処理リストの全部または一部を実行していないものと判定して次のステップに進む（ステップＳ１３０でＮ）。
【０１９８】
ステップＳ１４０において、データ処理実行部２０９は、ステップＳ１３０で取得した行データに係る部品プログラムに与えるパラメータ情報を取得する。具体的には、データ処理実行部２０９は、取得した行データのパラメータ取得式情報８１４に設定されたＳＱＬステートメントを実行することにより、部品プログラムに応じたパラメータ情報の集まりであるパラメータ情報データ１１１０を取得する。図１１にパラメータ情報データ１１１０の一例を示す。パラメータ情報データ１１１０については、後述する。
【０１９９】
ステップＳ１５０において、データ処理実行部２０９は、データ処理装置３０が有する計時機能を用いて、部品プログラムを実行する前の時点でのシステム時刻を取得する。
【０２００】
ステップＳ１６０において、データ処理実行部２０９は、各データ処理を実行した日付に関する情報が格納された処理日時管理テーブル９１０から処理日時に関する情報を取得する。具体的には、データ処理実行部２０９は、データ処理実行要求の処理ＩＤ情報と一致する処理ＩＤ情報を含む行データを処理日時管理テーブル９１０から取得する。処理日時管理テーブル９１０は、データ処理装置３０の記憶装置に記憶されている。
【０２０１】
処理日時管理テーブル９１０は、処理ＩＤ情報９１１と、処理日時情報９１２と、前回処理日時情報９１３と、項目０１情報９１４〜項目１０情報９２３と、を互いに関連付けた行データ格納するテーブルである。なお、本実施形態において、項目０１情報９１４〜項目１０情報９２３は未使用である。
【０２０２】
処理ＩＤ情報９１１は、実行処理グループテーブル３２０の処理ＩＤ情報３２１と同じく、複数の部品プログラムを組み合わせることにより構成されたデータ処理を一意に識別するための情報である。
【０２０３】
処理日時情報９１２は、処理ＩＤ情報９１１により識別されるデータ処理を実行した日時を示す情報である。
【０２０４】
前回処理日時情報９１３は、処理ＩＤ情報９１１により識別されるデータ処理を前回実行した日時を示す情報である。
【０２０５】
また、ステップＳ１６０において、データ処理実行部２０９は、処理日時管理テーブル９１０の処理日時情報９１２を前回処理日時情報９１３にコピーする。
【０２０６】
ステップＳ１７０において、データ処理実行部２０９は、部品プログラムを実行する。具体的には、ステップＳ１３０で取得した行データの実行ファイル名情報８１３に基づいて部品プログラムを呼び出して実行する。また、データ処理実行部２０９は、部品プログラムを呼び出す際にステップＳ１４０にて取得したパラメータ情報データ１１１０を、引数として当該部品プログラムに与える。また、データ処理実行部２０９は、ステップＳ１３０で取得した行データの第１入力形式情報８２２、第１入力データ情報８２３、第２入力形式情報８２４および第２入力データ情報８２５により指定される入力データを、引数として部品プログラムに与える。データ処理実行部２０９は、部品プログラムの実行により、第１出力ファイル情報８２０および第２出力ファイル情報８２１により指定されるファイルに出力データを出力する。
【０２０７】
ステップＳ１８０において、データ処理実行部２０９は、ログ記憶部２０７にログを出力する。具体的には、データ処理実行部２０９は、データ処理装置３０が有する計時機能を用いて、部品プログラムを実行した後の時点でのシステム時刻を取得し、ステップＳ１５０で取得したシステム時刻とともに、部品プログラムの実行開始時刻および実行終了時刻を含む実行ログテーブル１０１０（図１０）をログ記憶部２０７に出力する。
【０２０８】
実行ログテーブル１０１０の一例を図１０に示す。実行ログテーブル１０１０は、処理ＩＤ情報１０１１と、実行識別情報１０１２と、処理種別情報１０１３と、開始時刻情報１０１４と、終了時刻情報１０１５と、第１入力件数情報１０１６と、第２入力件数情報１０１７と、第１出力件数情報１０１８と、第２出力件数情報１０１９と、を互いに関連付けて格納するテーブルである。
【０２０９】
処理ＩＤ情報１０１１は、実行処理グループテーブル３２０の処理ＩＤ情報３２１と同じく、複数の部品プログラムを組み合わせることにより構成されたデータ処理を一意に識別するための情報である。本実施形態において、処理ＩＤ情報１０１１には、データ処理実行要求の処理ＩＤ情報が設定される。
【０２１０】
実行識別情報１０１２は、処理グループ定義テーブル３３０の実行識別情報３３３と同じく、同一の部品プログラムに異なるパラメータ情報を与えて実行する際にそれぞれの実行を一意に識別するための情報である。本実施形態において、実行識別情報１０１２には、ステップＳ１３０で取得した行データの実行識別情報８１８の値が設定される。
【０２１１】
処理種別情報１０１３は、実行ファイルテーブル３１０の処理種別情報３１１と同じく、部品プログラムを示す情報である。
【０２１２】
開始時刻情報１０１４は、処理種別情報１０１３が示す部品プログラムの実行を開始した時刻を示す情報である。
【０２１３】
終了時刻情報１０１５は、処理種別情報１０１３が示す部品プログラムの実行を終了した時刻を示す情報である。
【０２１４】
第１入力件数情報１０１６は、ステップＳ１３０で取得した行データの第１入力形式情報８２２および第１入力データ情報８２３により指定される第１入力データから入力されたデータの件数を示す情報である。
【０２１５】
第２入力件数情報１０１７は、ステップＳ１３０で取得した行データの第２入力形式情報８２４および第２入力データ情報８２５により指定される第２入力データから入力されたデータの件数を示す情報である。
【０２１６】
第１出力件数情報１０１８は、ステップＳ１３０で取得した行データの第１出力ファイル情報８２０により指定されるファイルに出力したデータの件数を示す情報である。
【０２１７】
第２出力件数情報１０１９は、ステップＳ１３０で取得した行データの第２出力ファイル情報８２１により指定されるファイルに出力したデータの件数を示す情報である。
【０２１８】
ステップＳ１９０において、データ処理実行部２０９は、部品プログラムの実行においてエラーが生じたか否かを判定する。データ処理実行部２０９は、エラーが生じていれば、フローチャートの処理を終了し（ステップＳ１９０でＹ）、エラーが生じていなければ、処理リスト情報８１０から次の行データを取得するために、ステップＳ１３０に戻る（ステップＳ１９０でＮ）。
【０２１９】
次に、部品プログラムの実行例として、図７のステップＳ１７０において、ＳＱＬ実行処理（実行順情報８１１＝「1」、処理順情報８１２＝「2」、実行識別情報８１８＝「sql_処理日付更新」、処理種別情報８１９＝「SQL実行」）に係る部品プログラムが呼び出された場合について説明する。
【０２２０】
データ処理実行部２０９は、図８のステップＳ１７０で呼び出された部品プログラムを実行すると、引数として、ステップＳ１３０で取得した行データの第１入力形式情報８２２および第１入力データ情報８２３と、を取得する。そして、データ処理実行部２０９は、第１入力形式情報８２２に「table」が設定されていることから、第１入力データはデータベースから取得するものと判断して、第１入力データ情報８２３をＳＱＬステートメントとして取得する。なお、第１入力形式情報８２２に「file」が設定されていた場合、第１入力データはデータベースから取得するものと判断して、第１入力データ情報８２３をファイルのパスおよび名称（ファイル名）として取得する。第２入力データについても同様である。
【０２２１】
また、データ処理実行部２０９は、引数として、ステップＳ１４０で取得したパラメータ情報データ１１１０（図１１）を取得する。
【０２２２】
パラメータ情報データ１１１０は、図１１に一例を示すように、ＰＲＭ＿０１情報１１１１〜ＰＲＭ＿１０情報１１２０を互いに関連付けた行データである。ＰＲＭ＿０１情報１１１１〜ＰＲＭ＿１０情報１１２０には、パラメータ取得式テーブル５１０のパラメータ取得式情報５１２を用いて、ＤＢデータ抽出処理パラメータテーブル４１０、ルックアップ処理パラメータテーブル４２０、結合処理パラメータテーブル４３０、値編集処理パラメータテーブル４４０、ＳＱＬ実行処理パラメータテーブル４５０およびデータ登録処理パラメータテーブル４６０から取得したパラメータ情報が設定される。図１１に示すパラメータ情報データ１１１０では、ＰＲＭ＿０１情報１１１１として「"UPDATE [処理日付管理] SET [処理日時]=getdate() WHERE [処理ID]='" + 処理ID + "'"」が設定されている。なお、値が設定されていないＰＲＭ＿０２情報１１１２〜ＰＲＭ＿１０情報１１２０は未使用である。
【０２２３】
次に、データ処理実行部２０９は、第１入力データ情報８２３のＳＱＬステートメント「select '${処理ID}' as [処理ID]」を実行する。さらに、データ処理実行部２０９は、ＰＲＭ＿０１情報１１１１をプログラミング言語Ｊａｖａ（登録商標）の言語仕様に基づき演算することにより取得したＳＱＬステートメントを実行する。これにより、ステップＳ１６０で取得した処理日時管理テーブル９１０において、現在のデータ処理の処理ＩＤ情報と関連付けられた処理日時情報９１２を更新する。
【０２２４】
そして、エラーが生じれば、エラーを警告する警告ログテーブル（図示なし）をログ記憶部２０７に出力し、エラーが生じなければ、そのまま部品プログラムの実行を終了する。
【０２２５】
他の部品プログラムについても、データ処理実行部２０９は、引数として、ステップＳ１３０で取得した行データにおける入力データに関する情報、および、ステップＳ１４０で取得したパラメータ情報データ１１１０を取得して、上記と同様に実行する。
【０２２６】
以上説明したように、本実施形態のデータ処理装置３０は、複数の部品プログラムを組み合わせて構成したデータ処理を実行する。データ処理装置３０は、部品プログラムを示す処理種別情報と、部品プログラムを実行する順番を示す処理順情報と、部品プログラムの実行を識別するための実行識別情報と、を関連付けて記憶する実行処理記憶部２０３を有する。データ処理装置３０は、実行識別情報と、部品プログラムに与えるパラメータ情報と、を関連付けて記憶するパラメータ記憶部２０４を有する。データ処理装置３０は、処理種別情報と、パラメータ情報をパラメータ記憶部から取得するためのパラメータ取得式情報と、を関連付けて記憶するパラメータ取得式記憶部２０５を有する。データ処理装置３０は、処理種別情報が示す部品プログラムを処理順情報が示す順番にしたがって呼び出し、部品プログラムを呼び出す際に、当該部品プログラムに係る実行識別情報に関連付けられたパラメータ取得式情報を用いてパラメータ記憶部２０４からパラメータ情報を取得して当該部品プログラムに与えるデータ処理実行部２０９を有する。
【０２２７】
本実施形態のデータ処理装置３０は、実行処理記憶部２０３が、（１）１つまたは複数の部品プログラムを有する処理グループを示す処理グループ情報と、処理グループを実行する順番を示す実行順情報と、を関連付ける実行処理グループテーブル３２０と、（２）処理グループ情報と、処理種別情報と、処理順情報と、実行識別情報と、第１出力ファイル情報と、第２出力ファイル情報と、第１入力形式情報と、第１入力データ情報と、第２入力形式情報と、第２入力データ情報と、を関連付ける処理グループ定義テーブル３３０と、を記憶する。
【０２２８】
本実施形態のデータ処理装置３０は、パラメータ記憶部２０４が、実行識別情報と、パラメータ情報と、を関連付けるＤＢデータ抽出処理パラメータテーブル４１０、ルックアップ処理パラメータテーブル４２０、結合処理パラメータテーブル４３０、値編集処理パラメータテーブル４４０、ＳＱＬ実行処理パラメータテーブル４５０およびデータ登録処理パラメータテーブル４６０を記憶する。また、パラメータ取得式記憶部２０５は、処理種別情報と、パラメータ取得式情報と、を関連付けるパラメータ取得式テーブル５１０を記憶する。
【０２２９】
本実施形態のデータ処理装置３０は、複数の部品プログラムで共通に利用される共通パラメータ情報を記憶する環境変数記憶部２０６を有する。
【０２３０】
本実施形態のデータ処理装置３０は、パラメータ取得式情報がデータベース言語ＳＱＬの言語仕様に基づくＳＱＬステートメントである。
【０２３１】
本実施形態のデータ処理装置３０は、データ処理実行部２０９におけるデータ処理の実行数が同時実行上限数を超えないように制御する並列実行数制御部２０８を有している。
【０２３２】
以上より、本実施形態のデータ処理装置３０によれば、部品プログラムを実行する順番を示す処理順情報と、部品プログラムに与えるパラメータ情報と、を別々に記憶している。そして、部品プログラムを処理順情報が示す順番にしたがって呼び出し、部品プログラムを呼び出す際に、当該部品プログラムに係る実行識別情報に関連付けられたパラメータ取得式情報を用いてパラメータ情報を取得して当該部品プログラムに与える。このようにしたことから、部品プログラムを実行する際にパラメータ情報を動的に与える構成を有するので、部品プログラムを実行する順番とパラメータ情報とを互いに独立して管理・変更することができる。また、部品プログラムに応じたパラメータ取得式情報を用いることにより、各種パラメータ形式に柔軟に対応することができる。そのため、データ処理に係る処理定義の構築を容易に行うことができる。
【０２３３】
また、処理順情報やパラメータ情報などの各種情報をテーブル形式（表形式）で記憶することにより、これら情報について容易に理解することができ、管理・変更を容易に行うことができる。
【０２３４】
また、複数の部品プログラムで共通に利用される共通パラメータ情報を記憶する共通パラメータ記憶部をさらに有することで、共通パラメータ情報を一元管理することができる。
【０２３５】
また、パラメータ取得式情報が、データベース言語ＳＱＬの言語仕様に基づくものであることで、パラメータ取得式情報について容易に理解することができ、管理・変更を容易に行うことができる。
【０２３６】
また、データ処理実行部２０９におけるデータ処理の実行数が同時実行上限数を超えないように制御する並列実行数制御部２０８を有していることで、データ処理装置３０の処理能力を超えたデータ処理が実行されることを抑制することができる。
【０２３７】
上記に本発明の実施形態を説明したが、本発明はこれらの例に限定されるものではない。前述の実施形態に対して、当業者が適宜、構成要素の追加、削除、設計変更を行ったものや、実施形態の特徴を適宜組み合わせたものも、本発明の要旨を備えている限り、本発明の範囲に含まれる。
【符号の説明】
【０２３８】
１…データ連携システム
１０…基幹システム
２０…データウエアハウス
３０…データ処理装置
２０２…部品プログラム記憶部
２０３…実行処理記憶部
２０４…パラメータ記憶部
２０５…パラメータ取得式記憶部
２０６…環境変数記憶部
２０７…ログ記憶部
２０８…並列実行数制御部
２０９…データ処理実行部
３１０…実行ファイルテーブル
３２０…実行処理グループテーブル
３３０…処理グループ定義テーブル
４１０…ＤＢデータ抽出処理パラメータテーブル
４２０…ルックアップ処理パラメータテーブル
４３０…結合処理パラメータテーブル
４４０…値編集処理パラメータテーブル
４５０…ＳＱＬ実行処理パラメータテーブル
４６０…データ登録処理パラメータテーブル
５１０…パラメータ取得式テーブル
６１０…環境変数テーブル
８１０…処理リスト情報
９１０…処理日時管理テーブル
１０１０…実行ログテーブル
１１１０…パラメータ情報データ
【図１】
2020077080.tif 000003
【図２】
2020077080.tif 000004
【図３】
2020077080.tif 000005
【図４】
2020077080.tif 000006
【図５】
2020077080.tif 000007
【図６】
2020077080.tif 000008
【図７】
2020077080.tif 000009
【図８】
2020077080.tif 000010
【図９】
2020077080.tif 000011
【図１０】
2020077080.tif 000012
【図１１】
2020077080.tif 000013