JP5601028B2 - Database replication system, database replication method, information processing apparatus, and program - Google Patents
Database replication system, database replication method, information processing apparatus, and program Download PDFInfo
- Publication number
- JP5601028B2 JP5601028B2 JP2010118106A JP2010118106A JP5601028B2 JP 5601028 B2 JP5601028 B2 JP 5601028B2 JP 2010118106 A JP2010118106 A JP 2010118106A JP 2010118106 A JP2010118106 A JP 2010118106A JP 5601028 B2 JP5601028 B2 JP 5601028B2
- Authority
- JP
- Japan
- Prior art keywords
- database
- record
- information
- change
- processing apparatus
- Prior art date
- Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
- Expired - Fee Related
Links
- 230000010365 information processing Effects 0.000 title claims description 146
- 230000010076 replication Effects 0.000 title claims description 67
- 238000000034 method Methods 0.000 title claims description 44
- 230000008859 change Effects 0.000 claims description 228
- 230000008520 organization Effects 0.000 claims description 26
- 238000012545 processing Methods 0.000 claims description 25
- 230000008569 process Effects 0.000 description 19
- 230000006870 function Effects 0.000 description 8
- 230000005540 biological transmission Effects 0.000 description 7
- 230000009471 action Effects 0.000 description 4
- 238000010586 diagram Methods 0.000 description 4
- 238000012217 deletion Methods 0.000 description 3
- 230000037430 deletion Effects 0.000 description 3
- 239000000284 extract Substances 0.000 description 3
- 238000012546 transfer Methods 0.000 description 3
- 238000004891 communication Methods 0.000 description 2
- 230000001360 synchronised effect Effects 0.000 description 2
- 230000003247 decreasing effect Effects 0.000 description 1
- 230000000694 effects Effects 0.000 description 1
- 230000003287 optical effect Effects 0.000 description 1
- 239000004065 semiconductor Substances 0.000 description 1
Images
Landscapes
- Information Retrieval, Db Structures And Fs Structures Therefor (AREA)
Description
本発明は、データベースにおけるレコードの変更を他のデータベースに反映するデータベース・レプリケーション・システムに関する。 The present invention relates to a database replication system that reflects record changes in a database to other databases.
第１のデータベースにおけるレコードの変更を第２のデータベースに反映するデータベース・レプリケーション・システムが知られている。この種のデータベース・レプリケーション・システムの一つとして、特許文献１に記載のデータベース・レプリケーション・システムにおいて、第１のデータベース、及び、第２のデータベースのそれぞれは、１つのレコード形式を有するレコードを格納するテーブルを複数含む。
Database replication systems that reflect record changes in a first database to a second database are known. As one of this type of database replication system, in the database replication system described in
上記データベース・レプリケーション・システムは、第１のデータベースが含む第１のテーブルに格納されているレコードを、第２のデータベースが含むテーブルであって、当該第１のテーブルに対応するテーブルである第２のテーブルに格納するための命令を生成する。データベース・レプリケーション・システムは、生成された命令に従って、レコードを第２のテーブルに格納する。 In the database replication system, the second database includes a record stored in the first table included in the first database, and is a table corresponding to the first table. Generate instructions to store in the table. The database replication system stores the record in the second table according to the generated instruction.
ところで、データベースが、レコード形式を複数有する複数のレコードを格納するＶＳＡＭ（Ｖｉｒｔｕａｌ Ｓｔｏｒａｇｅ Ａｃｃｅｓｓ Ｍｅｔｈｏｄ）編成ファイルにより構成される場合がある。ＶＳＡＭ編成ファイルは、主にメインフレームにおいて利用されている。ＶＳＡＭ編成ファイルにより構成されたデータベースにおいては、例えば、ＣＯＢＯＬ（Ｃｏｍｍｏｎ Ｂｕｓｉｎｅｓｓ Ｏｒｉｅｎｔｅｄ Ｌａｎｇｕａｇｅ）におけるＲＥＤＥＦＩＮＥＳ句を用いて複数のレコード形式が定義される。 By the way, the database may be configured by a VSAM (Virtual Storage Access Method) organization file that stores a plurality of records having a plurality of record formats. The VSAM organization file is mainly used in the main frame. In a database composed of VSAM organization files, for example, a plurality of record formats are defined using a REDEFINES phrase in COBOL (Common Business Oriented Language).
ところで、上述したデータベース・レプリケーション・システムを用いた場合、ＶＳＡＭ編成ファイルにより構成されたデータベースにおけるレコードの変更を、他のデータベース（例えば、リレーショナル・データベース等）に反映することができない。また、ＥＴＬ（Ｅｘｔｒａｃｔ／Ｔｒａｎｓｆｏｒｍ／Ｌｏａｄ）ツールを利用して、ＶＳＡＭ編成ファイルにより構成されたデータベースに蓄積されているレコードを抽出し、抽出したレコードを上記他のデータベースへ反映する場合、比較的長い時間を要するという問題があった。 By the way, when the above-described database replication system is used, the change of the record in the database constituted by the VSAM organization file cannot be reflected in another database (for example, a relational database). In addition, when an ETL (Extract / Transform / Load) tool is used to extract a record accumulated in a database configured by a VSAM organization file and the extracted record is reflected in the other database, it is relatively long. There was a problem of taking time.
即ち、上記データベース・レプリケーション・システムにおいては、ＶＳＡＭ編成ファイルにより構成されたデータベースにおけるレコードの変更をリアルタイムに他のデータベースに反映することができない場合が生じるという問題があった。 That is, in the above-mentioned database replication system, there has been a problem that the change of the record in the database constituted by the VSAM organization file cannot be reflected in another database in real time.
このため、本発明の目的は、上述した課題である「ＶＳＡＭ編成ファイルにより構成されたデータベースにおけるレコードの変更をリアルタイムに他のデータベースに反映することができない場合が生じること」を解決することが可能なデータベース・レプリケーション・システムを提供することにある。 For this reason, the object of the present invention is to solve the above-mentioned problem that “record changes in a database constituted by a VSAM organization file cannot be reflected in another database in real time”. Is to provide a simple database replication system.
かかる目的を達成するため本発明の一形態であるデータベース・レプリケーション・システムは、
レコードの形式であるレコード形式を複数有する複数のレコードを格納するＶＳＡＭ（Ｖｉｒｔｕａｌ Ｓｔｏｒａｇｅ Ａｃｃｅｓｓ Ｍｅｔｈｏｄ）編成ファイルにより構成された第１のデータベースが蓄積しているレコードが変更された場合、１つのレコード形式を有するレコードを格納するテーブルを複数含む第２のデータベースに当該変更を反映する変更反映手段を備える。
In order to achieve such an object, a database replication system according to one aspect of the present invention provides:
When a record stored in the first database configured by a VSAM (Virtual Storage Access Method) organization file that stores a plurality of records having a plurality of record formats that are record formats is changed, one record format is changed. And a change reflecting means for reflecting the change in a second database including a plurality of tables for storing records.
また、本発明の他の形態であるデータベース・レプリケーション方法は、
レコードの形式であるレコード形式を複数有する複数のレコードを格納するＶＳＡＭ（Ｖｉｒｔｕａｌ Ｓｔｏｒａｇｅ Ａｃｃｅｓｓ Ｍｅｔｈｏｄ）編成ファイルにより構成された第１のデータベースが蓄積しているレコードが変更された場合、１つのレコード形式を有するレコードを格納するテーブルを複数含む第２のデータベースに当該変更を反映する方法である。
In addition, the database replication method according to another aspect of the present invention,
When a record stored in the first database configured by a VSAM (Virtual Storage Access Method) organization file that stores a plurality of records having a plurality of record formats that are record formats is changed, one record format is changed. In this method, the change is reflected in a second database including a plurality of tables for storing records.
また、本発明の他の形態である第２の情報処理装置は、
レコードの形式であるレコード形式を複数有する複数のレコードを格納するＶＳＡＭ（Ｖｉｒｔｕａｌ Ｓｔｏｒａｇｅ Ａｃｃｅｓｓ Ｍｅｔｈｏｄ）編成ファイルにより構成された第１のデータベースを保持する第１の情報処理装置と通信可能に構成された第２の情報処理装置である。
The second information processing apparatus according to another embodiment of the present invention
A first information processing apparatus configured to be able to communicate with a first information processing apparatus having a first database configured by a VSAM (Virtual Storage Access Method) organization file that stores a plurality of records having a plurality of record formats. 2 is an information processing apparatus.
更に、この第２の情報処理装置は、
１つのレコード形式を有するレコードを格納するテーブルを複数含む第２のデータベースを保持するとともに、
上記第１のデータベースが蓄積しているレコードが変更された場合、上記第１の情報処理装置から当該レコードの変更を表す変更ログ情報を受信する変更ログ情報受信手段と、
上記受信された変更ログ情報が表す上記レコードの変更を上記２のデータベースに反映する変更反映手段と、
を備える。
Furthermore, the second information processing apparatus
Holding a second database including a plurality of tables storing records having one record format;
Change log information receiving means for receiving change log information representing a change of the record from the first information processing apparatus when the record stored in the first database is changed;
Change reflecting means for reflecting the change of the record represented by the received change log information in the database of 2;
Is provided.
また、本発明の他の形態であるプログラムは、
レコードの形式であるレコード形式を複数有する複数のレコードを格納するＶＳＡＭ（Ｖｉｒｔｕａｌ Ｓｔｏｒａｇｅ Ａｃｃｅｓｓ Ｍｅｔｈｏｄ）編成ファイルにより構成された第１のデータベースを保持する第１の情報処理装置と通信可能に構成されるとともに、１つのレコード形式を有するレコードを格納するテーブルを複数含む第２のデータベースを保持する第２の情報処理装置に、
上記第１のデータベースが蓄積しているレコードが変更された場合、上記第１の情報処理装置から当該レコードの変更を表す変更ログ情報を受信する変更ログ情報受信手段と、
上記受信された変更ログ情報が表す上記レコードの変更を上記２のデータベースに反映する変更反映手段と、
を実現させるためのプログラムである。
Moreover, the program which is the other form of this invention is:
It is configured to be communicable with a first information processing apparatus that holds a first database configured by a VSAM (Virtual Storage Access Method) organization file that stores a plurality of records having a plurality of record formats that are record formats. In a second information processing apparatus holding a second database including a plurality of tables for storing records having one record format,
Change log information receiving means for receiving change log information representing a change of the record from the first information processing apparatus when the record stored in the first database is changed;
Change reflecting means for reflecting the change of the record represented by the received change log information in the database of 2;
It is a program for realizing.
本発明は、以上のように構成されることにより、ＶＳＡＭ編成ファイルにより構成されたデータベースにおけるレコードの変更をリアルタイムに他のデータベースに反映することができる。 By configuring as described above, the present invention can reflect a change in a record in a database configured by a VSAM organization file to another database in real time.
以下、本発明に係る、データベース・レプリケーション・システム、データベース・レプリケーション方法、情報処理装置、及び、プログラム、の各実施形態について図１〜図１９を参照しながら説明する。 Embodiments of a database replication system, a database replication method, an information processing apparatus, and a program according to the present invention will be described below with reference to FIGS.
＜第１実施形態＞
（構成）
図１に示したように、第１実施形態に係るデータベース・レプリケーション・システム１は、第１の情報処理装置（第１のデータベース・サーバ装置）１００と、第２の情報処理装置（第２のデータベース・サーバ装置）２００と、を含む。第１の情報処理装置１００及び第２の情報処理装置２００は、通信回線（本例では、ＩＰ（Ｉｎｔｅｒｎｅｔ Ｐｒｏｔｏｃｏｌ）網を構成する通信回線）ＮＷを介して、互いに通信可能に接続されている。
<First Embodiment>
(Constitution)
As shown in FIG. 1, the
第１の情報処理装置１００は、図示しない中央処理装置（ＣＰＵ；Ｃｅｎｔｒａｌ Ｐｒｏｃｅｓｓｉｎｇ Ｕｎｉｔ）、及び、記憶装置（メモリ及びハードディスク駆動装置（ＨＤＤ；Ｈａｒｄ Ｄｉｓｋ Ｄｒｉｖｅ））を備える。第１の情報処理装置１００は、記憶装置に記憶されているプログラムをＣＰＵが実行することにより、後述する機能を実現するように構成されている。
第２の情報処理装置２００も第１の情報処理装置１００と同様の構成を有する。
The first
The second
（機能）
図２は、上記のように構成されたデータベース・レプリケーション・システム１の機能を表すブロック図である。
(function)
FIG. 2 is a block diagram showing the functions of the
第１の情報処理装置１００の機能は、第１のデータベース部１０１と、アプリケーション実行部１０２と、一時変更ログ情報生成部１０３と、一時変更ログ情報記憶部１０４と、シーケンス情報記憶部１０５と、変更ログ情報生成部１０６と、変更ログ情報記憶部１０７と、ＦＤ（Ｆｉｌｅ Ｄｅｓｃｒｉｐｔｏｒ）情報取得部１０８と、ＦＤ情報記憶部１０９と、情報送信部１１０と、を含む。
The functions of the first
第１のデータベース部１０１は、レコードの形式であるレコード形式を複数有する複数のレコードを格納するＶＳＡＭ（Ｖｉｒｔｕａｌ Ｓｔｏｒａｇｅ Ａｃｃｅｓｓ Ｍｅｔｈｏｄ）編成ファイルにより構成された第１のデータベースを保持する。
The
アプリケーション実行部１０２は、第１のデータベース部１０１に蓄積されているレコードを用いた処理を行うアプリケーション・プログラムを実行する。アプリケーション実行部１０２は、アプリケーション・プログラムを実行することにより、第１のデータベース部１０１に蓄積されているレコードを変更（追加、削除、及び、更新）する。
The
このとき、アプリケーション実行部１０２は、レコードの変更をトランザクション処理として実行する。即ち、アプリケーション実行部１０２は、１つのトランザクション処理において、第１のデータベース部１０１に蓄積されているレコードを変更する旨を表す命令（変更命令）が生成された後に、コミット命令が生成された場合にのみ、当該変更命令を第１のデータベース部１０１へ出力する。これにより、当該変更命令に基づくレコードの変更が実際に第１のデータベースに反映される。
At this time, the
なお、アプリケーション実行部１０２は、複数のアプリケーション・プログラムを実行していてもよい。
The
一時変更ログ情報生成部１０３は、アプリケーション実行部１０２が、第１のデータベース部１０１に蓄積されているレコードを変更する旨を表す命令（変更命令）を生成した場合、一時変更ログ情報を生成する。一時変更ログ情報は、変更命令を生成したアプリケーション・プログラムを特定するためのアプリケーション特定情報と、当該変更命令に基づく変更後のレコードと、変更命令の種別（追加、削除、又は、更新）を特定するための命令種別情報と、を含む。
The temporary change log information generation unit 103 generates temporary change log information when the
一時変更ログ情報記憶部１０４は、一時変更ログ情報生成部１０３により生成された一時変更ログ情報を記憶する。
The temporary change log
シーケンス情報記憶部１０５は、シーケンス情報を記憶する。シーケンス情報は、コミット命令が生成された（即ち、コミット命令に基づく処理（コミット処理）が実行された）回数を表す情報である。本例では、シーケンス情報は、整数を表す。
The sequence
変更ログ情報生成部１０６は、アプリケーション実行部１０２がコミット命令を第１のデータベース部１０１へ出力した（即ち、コミット命令を生成した）場合、変更ログ情報を生成する。
The change log
具体的には、変更ログ情報生成部１０６は、生成されたコミット命令の対象となったトランザクション処理において生成された変更命令に基づいて生成された一時変更ログ情報を一時変更ログ情報記憶部１０４から取得する。また、変更ログ情報生成部１０６は、シーケンス情報記憶部１０５に記憶されているシーケンス情報を取得する。更に、変更ログ情報生成部１０６は、シーケンス情報記憶部１０５に記憶されているシーケンス情報を、当該シーケンス情報が表す値に１を加えた値に更新する。
Specifically, the change log
変更ログ情報記憶部１０７は、変更ログ情報生成部１０６により取得された変更ログ情報としての一時変更ログ情報と、変更ログ情報生成部１０６により取得されたシーケンス情報と、を対応付けて、当該変更ログ情報の基となった変更命令が生成された順に記憶する。
The change log
更に、変更ログ情報生成部１０６は、生成されたコミット命令を表すコミットログ情報を生成する。
変更ログ情報記憶部１０７は、変更命令に基づく変更ログ情報を記憶した後に、当該変更命令が生成されたトランザクション処理に対するコミット命令に基づいて変更ログ情報生成部１０６により生成された変更ログ情報としてのコミットログ情報と、変更ログ情報生成部１０６により取得されたシーケンス情報と、を対応付けて記憶する。
Furthermore, the change log
The change log
ＦＤ情報取得部１０８は、第１のデータベースに蓄積されているレコードが有するレコードの形式であるレコード形式を表すＦＤ情報を取得する。本例では、ＦＤ情報取得部１０８は、アプリケーション実行部１０２が実行するアプリケーション・プログラムのソースコードを解析することによりＦＤ情報を取得する。ＦＤ情報は、第１のデータベースにおけるレコード形式を定める第１の定義情報である。
The FD
本例では、アプリケーション実行部１０２が実行するアプリケーション・プログラムは、ＣＯＢＯＬ（Ｃｏｍｍｏｎ Ｂｕｓｉｎｅｓｓ Ｏｒｉｅｎｔｅｄ Ｌａｎｇｕａｇｅ）に従ったプログラムである。従って、ＦＤ情報取得部１０８は、ソースコードのうちのＦＤ句として記述された部分に基づいてＦＤ情報を取得する。
In this example, the application program executed by the
ＦＤ情報記憶部１０９は、ＦＤ情報取得部１０８により取得されたＦＤ情報と、ＦＤ情報が取得される基となったアプリケーション・プログラムを特定するためのアプリケーション特定情報（本例では、アプリケーション名（ＡＰ名））と、を対応付けて記憶する。
The FD
情報送信部１１０は、予め設定された送信周期が経過する毎に、ＦＤ情報記憶部１０９に記憶されている、ＦＤ情報及びアプリケーション特定情報を第２の情報処理装置２００へ送信する。更に、情報送信部１１０は、変更ログ情報記憶部１０７にコミットログ情報が記憶される毎に、変更ログ情報記憶部１０７に記憶されている、変更ログ情報及びシーケンス情報を、変更ログ情報記憶部１０７に記憶された順に第２の情報処理装置２００へ送信する。
The
変更ログ情報記憶部１０７は、情報送信部１１０により送信された変更ログ情報及びシーケンス情報を消去する。
The change log
第２の情報処理装置２００の機能は、第２のデータベース部２０１と、アプリケーション実行部２０２と、情報受信部（変更ログ情報受信手段）２０３と、ＦＤ情報解析部２０４と、テーブル生成部（テーブル生成手段）２０５と、分配条件記憶部（分配条件記憶手段）２０６と、反映処理部（変更反映手段）２０７と、を含む。
The functions of the second
第２のデータベース部２０１は、１つのレコード形式を有するレコードを格納するテーブルを複数含む第２のデータベースを保持する。
アプリケーション実行部２０２は、第２のデータベース部２０１に蓄積されているレコードを用いた処理を行うアプリケーション・プログラムを実行する。
The
The
情報受信部２０３は、第１の情報処理装置１００により送信された情報（ＦＤ情報並びにアプリケーション特定情報、及び、変更ログ情報及びシーケンス情報）を受信する。
The
ＦＤ情報解析部２０４は、情報受信部２０３により受信された、ＦＤ情報及びアプリケーション特定情報を受け付ける。ＦＤ情報解析部２０４は、受け付けたＦＤ情報が表すレコード形式を有するレコードを格納するテーブルを生成するためのＤＤＬ（Ｄａｔａ Ｄｅｆｉｎｉｔｉｏｎ Ｌａｎｇｕａｇｅ）情報（第２の定義情報）を生成する。本例では、ＤＤＬ情報は、ＳＱＬに従った情報である。
The FD
テーブル生成部２０５は、ＦＤ情報解析部２０４により生成されたＤＤＬ情報が表すテーブルが、第２のデータベースに既に生成されている（即ち、第２のデータベースが当該テーブルを含む）か否かを判定する。テーブル生成部２０５は、当該テーブルが第２のデータベースに生成されていないと判定した場合、当該ＤＤＬ情報に基づいて、第２のデータベースにテーブルを生成する。
The
ＦＤ情報解析部２０４は、受け付けたＦＤ情報及びアプリケーション特定情報に基づいて分配条件を生成する。分配条件は、第２のデータベースに含まれるテーブルであり、且つ、第１のデータベースにおいて変更されたレコードが格納されるべきテーブルを変更ログ情報に基づいて特定するための情報である。
The FD
分配条件記憶部２０６は、ＦＤ情報解析部２０４により生成された分配条件を記憶する。
反映処理部２０７は、情報受信部２０３により受信された、変更ログ情報及びシーケンス情報を受け付ける。
The distribution
The
反映処理部２０７は、受け付けた変更ログ情報及びシーケンス情報と、分配条件記憶部２０６に記憶されている分配条件と、に基づいて、第２のデータベースが含むテーブルであり、且つ、変更ログ情報が表すレコードの変更が反映されるべきテーブルを特定する。反映処理部２０７は、特定されたテーブルに、当該変更ログ情報が表すレコードの変更を反映する（即ち、レコードを追加する、レコードを削除する、又は、レコードを更新する）。
The
このとき、反映処理部２０７は、変更ログ情報とともに受け付けたシーケンス情報が表す値が小さいほど、当該変更ログ情報に基づく処理を早期に実行する。また、反映処理部２０７は、同一のシーケンス情報とともに受け付けた変更ログ情報に基づく処理を、情報受信部２０３により変更ログ情報が受信された順に実行する。
At this time, the
（作動）
次に、上記のように構成されたデータベース・レプリケーション・システム１の作動について説明する。
図３にフローチャートにより示したように、第１の情報処理装置１００は、ＦＤ情報を取得し、取得したＦＤ情報を第２の情報処理装置２００へ送信する。
(Operation)
Next, the operation of the
As illustrated by the flowchart in FIG. 3, the first
具体的に述べると、第１の情報処理装置１００は、アプリケーション・プログラムのソースコードのうちの、ＦＤ句として記述された部分（図４の（Ａ）〜（Ｃ））を抽出する（図３のステップＳ１０１）。次いで、第１の情報処理装置１００は、抽出されたＦＤ句のうちの、ＲＥＤＥＦＩＮＥＳ句として記述された部分（図４の（Ｂ）及び（Ｃ））を抽出する（図３のステップＳ１０２）。
Specifically, the first
第１の情報処理装置１００は、ＦＤ句として抽出された部分、及び、ＲＥＤＥＦＩＮＥＳ句として抽出された部分、に基づいてＦＤ情報を取得する。
次いで、第１の情報処理装置１００は、取得されたＦＤ情報と、ＦＤ情報が取得される基となったアプリケーション・プログラムを特定するためのアプリケーション特定情報（本例では、アプリケーション名（ＡＰ名））と、を対応付けて記憶装置に記憶させる（図３のステップＳ１０３）。
The first
Next, the first
そして、第１の情報処理装置１００は、予め設定された送信周期が経過する毎に、記憶装置に記憶されている、ＦＤ情報及びアプリケーション特定情報を第２の情報処理装置２００へ送信する（図３のステップＳ１０４）。
The first
また、図５にフローチャートにより示したように、第２の情報処理装置２００は、ＦＤ情報を第１の情報処理装置１００から受信し、受信したＦＤ情報に基づいて分配条件及びテーブルを生成する。
Further, as illustrated by the flowchart in FIG. 5, the second
具体的に述べると、第２の情報処理装置２００は、第１の情報処理装置１００からＦＤ情報を受信するまで待機する（図５のステップＳ２０１）。そして、第２の情報処理装置２００は、ＦＤ情報を受信すると、受信したＦＤ情報が表すレコード形式を有するレコードを格納するテーブルを生成するためのＤＤＬ情報（第２の定義情報、図６を参照）を生成する（図５のステップＳ２０２）。
Specifically, the second
更に、第２の情報処理装置２００は、受信したＦＤ情報及びアプリケーション特定情報に基づいて分配条件を生成する（図５のステップＳ２０３）。第２の情報処理装置２００は、生成した分配条件を記憶装置に記憶させる。
Further, the second
分配条件は、図７に示したように、アプリケーション特定情報（ＡＰ名）と、レコード形式名と、テーブル名と、条件情報と、を含む。レコード形式名は、第１のデータベースにおけるレコード形式の名称である。テーブル名は、第２のデータベースにおけるテーブルの名称である。条件情報は、本例では、レコード内のカラムである「ＫＥＹ」の値を定める情報である。 As shown in FIG. 7, the distribution condition includes application specifying information (AP name), a record format name, a table name, and condition information. The record format name is the name of the record format in the first database. The table name is the name of the table in the second database. In this example, the condition information is information that defines a value of “KEY” that is a column in the record.
次いで、第２の情報処理装置２００は、生成されたＤＤＬ情報が表すテーブルが、第２のデータベースに存在する（即ち、第２のデータベースが当該テーブルを含む）か否かを判定する（図５のステップＳ２０４）。
Next, the second
第２のデータベースが当該テーブルを含まない場合、第２の情報処理装置２００は、「Ｎｏ」と判定して、当該ＤＤＬ情報に基づいて、第２のデータベースにテーブルを生成する（図５のステップＳ２０５）。なお、第２のデータベースが当該テーブルを含む場合、第２の情報処理装置２００は、図５のステップＳ２０５の処理を実行しない。
If the second database does not include the table, the second
また、図８にフローチャートにより示したように、第１の情報処理装置１００は、一時変更ログ情報を生成する。
具体的に述べると、第１の情報処理装置１００は、第１のデータベース部１０１に蓄積されているレコードを変更する旨を表す命令（変更命令）がアプリケーション実行部１０２によって生成されるまで待機する（図８のステップＳ３０１）。
Further, as illustrated by the flowchart in FIG. 8, the first
More specifically, the first
そして、第１の情報処理装置１００は、変更命令がアプリケーション実行部１０２によって生成されると、一時変更ログ情報を生成する（図８のステップＳ３０２）。一時変更ログ情報は、図９に示したように、変更命令を生成したアプリケーション・プログラムを特定するためのアプリケーション特定情報（本例では、「ＡＰ０１」）と、当該変更命令に基づく変更後のレコード（本例では、「０１ＡＡＡＢＢ」等）と、変更命令の種別（追加、削除、又は、更新）を特定するための命令種別情報（本例では、「ＩＮＳＥＲＴ」）と、を含む。
Then, when the change instruction is generated by the
そして、第１の情報処理装置１００は、生成した一時変更ログ情報を記憶装置に記憶させる（図８のステップＳ３０３）。
そして、第１の情報処理装置１００は、図８のステップＳ３０１へ戻り、ステップＳ３０１〜ステップＳ３０３の処理を繰り返し実行する。
Then, the first
Then, the first
また、図１０にフローチャートにより示したように、第１の情報処理装置１００は、変更ログ情報を第２の情報処理装置２００へ送信する。
具体的に述べると、第１の情報処理装置１００は、実行中のトランザクション処理に対するコミット命令がアプリケーション実行部１０２によって生成されるまで待機する（図１０のステップＳ４０１）。
Further, as illustrated by the flowchart in FIG. 10, the first
More specifically, the first
そして、コミット命令がアプリケーション実行部１０２によって生成されると、生成されたコミット命令の対象となったトランザクション処理において生成された変更命令に基づいて生成された一時変更ログ情報を記憶装置から取得する（図１０のステップＳ４０２）。
Then, when the commit instruction is generated by the
次いで、第１の情報処理装置１００は、記憶装置に記憶されているシーケンス情報を取得する（図１０のステップＳ４０３）。そして、第１の情報処理装置１００は、記憶装置に記憶されているシーケンス情報を、当該シーケンス情報が表す値に１を加えた値に更新する。
Next, the first
次いで、第１の情報処理装置１００は、取得された変更ログ情報としての一時変更ログ情報と、取得されたシーケンス情報と、を対応付けて、当該変更ログ情報の基となった変更命令が生成された順に記憶装置に記憶させる（図１０のステップＳ４０４）。
Next, the first
更に、第１の情報処理装置１００は、生成されたコミット命令を表すコミットログ情報を生成する（図１０のステップＳ４０５）。次いで、第１の情報処理装置１００は、生成した変更ログ情報としてのコミットログ情報と、上記ステップＳ４０３にて取得されたシーケンス情報と、を対応付けて記憶装置に記憶させる（図１０のステップＳ４０６）。
Furthermore, the first
次いで、第１の情報処理装置１００は、記憶装置に記憶されている、変更ログ情報及びシーケンス情報を、記憶装置に記憶された順に第２の情報処理装置２００へ送信する（図１０のステップＳ４０７）。そして、第１の情報処理装置１００は、送信した変更ログ情報及びシーケンス情報を記憶装置から消去する。
そして、第１の情報処理装置１００は、図１０のステップＳ４０１へ戻り、ステップＳ４０１〜ステップＳ４０７の処理を繰り返し実行する。
Next, the first
Then, the first
即ち、コミット命令が生成されなかったトランザクション処理において生成された変更命令に基づく一時変更ログ情報は、第２の情報処理装置２００へ送信されない。
In other words, the temporary change log information based on the change instruction generated in the transaction process in which the commit instruction has not been generated is not transmitted to the second
また、図１１にフローチャートにより示したように、第２の情報処理装置２００は、変更ログ情報を第１の情報処理装置１００から受信し、受信した変更ログ情報を格納すべきテーブル毎に記憶する。
In addition, as illustrated by the flowchart in FIG. 11, the second
具体的に述べると、第２の情報処理装置２００は、第１の情報処理装置１００から変更ログ情報を受信するまで待機する（図１１のステップＳ５０１）。そして、第２の情報処理装置２００は、末尾の変更ログ情報がコミットログ情報である複数の変更ログ情報を受信すると、受信した複数の変更ログ情報のそれぞれに対して、ステップＳ５０２〜ステップＳ５０４の処理を行う。このとき、第２の情報処理装置２００は、受信した複数の変更ログ情報の先頭側から順に処理を行う。
Specifically, the second
そして、第２の情報処理装置２００は、処理対象となる変更ログ情報がコミットログ情報であるか否かを判定する（図１１のステップＳ５０２）。変更ログ情報がコミットログ情報でない（即ち、変更ログ情報が一時変更ログ情報である）場合、第２の情報処理装置２００は、変更ログ情報と、記憶装置に記憶されている分配条件と、に基づいて、当該変更ログ情報が表すレコードの変更が反映されるべきテーブルを特定する。
Then, the second
次いで、第２の情報処理装置２００は、変更ログ情報を、特定されたテーブルと対応付けて記憶装置に記憶させる。即ち、第２の情報処理装置２００は、変更ログ情報を、当該変更ログ情報が表すレコードの変更が反映されるべきテーブル毎に、記憶する（図１１のステップＳ５０４）。
Next, the second
そして、処理対象となる変更ログ情報がコミットログ情報になると、第２の情報処理装置２００は、図１１のステップＳ５０３及びステップＳ５０４の処理を実行することなく、ステップＳ５０１へ戻り、ステップＳ５０１〜ステップＳ５０４の処理を繰り返し実行する。
Then, when the change log information to be processed becomes commit log information, the second
また、図１２にフローチャートにより示したように、第２の情報処理装置２００は、変更ログ情報が表すレコードの変更を第２のデータベースに反映する。
In addition, as illustrated by the flowchart in FIG. 12, the second
具体的に述べると、第２の情報処理装置２００は、予め設定された反映周期が経過する毎に、記憶装置に変更ログ情報が記憶されているか否かを判定する。そして、記憶装置に変更ログ情報が記憶されている場合、第２の情報処理装置２００は、テーブル毎に、変更ログ情報を並び替える（図１２のステップＳ６０１）。
Specifically, the second
具体的には、第２の情報処理装置２００は、より小さい値を表すシーケンス情報とともに受信された変更ログ情報ほど、先頭側に配置する。更に、第２の情報処理装置２００は、同一のシーケンス情報とともに受信された変更ログ情報のうちの、受信された時点が早い変更ログ情報ほど、先頭側に配置する。
Specifically, the second
そして、第２の情報処理装置２００は、テーブル毎に、先頭側に配置された変更ログ情報から順に、当該変更ログ情報が表すレコードの変更を反映する（即ち、レコードを追加する、レコードを削除する、又は、レコードを更新する）（図１２のステップＳ６０２）。
これにより、第２のデータベースは、図１３に示したように、テーブル毎に、レコードの変更が反映される。
Then, the second
As a result, the second database reflects the change of the record for each table, as shown in FIG.
以上、説明したように、本発明の第１実施形態に係るデータベース・レプリケーション・システムによれば、ＶＳＡＭ編成ファイルにより構成されたデータベースにおけるレコードの変更をリアルタイムに他のデータベース（本例では、リレーショナル・データベース）に反映することができる。 As described above, according to the database replication system according to the first embodiment of the present invention, a record change in a database configured by a VSAM organization file is changed in real time to another database (in this example, a relational database). Database).
更に、第１実施形態に係るデータベース・レプリケーション・システムによれば、第１のデータベースにおいて、トランザクション処理にてレコードが変更された後にコミット処理が行われなかった場合に、当該レコードの変更が第２のデータベースに反映されることを防止することができる。即ち、第１のデータベースと第２のデータベースとを確実に同期させることができる。 Furthermore, according to the database replication system according to the first embodiment, when the commit process is not performed after the record is changed in the transaction process in the first database, the change of the record is second. Can be prevented from being reflected in the database. That is, the first database and the second database can be reliably synchronized.
加えて、第１実施形態に係るデータベース・レプリケーション・システムによれば、第２の情報処理装置２００において、レコード形式（テーブル）毎に並列して、レコードを変更するための処理を実行することができる。これにより、データベース・レプリケーション・システム１全体のスループットを向上させることができる。その理由は、レコード形式毎に、レコードの変更を表す情報を分割しているためである。
In addition, according to the database replication system according to the first embodiment, the second
＜第２実施形態＞
次に、本発明の第２実施形態に係るデータベース・レプリケーション・システムについて説明する。第２実施形態に係るデータベース・レプリケーション・システムは、上記第１実施形態に係るデータベース・レプリケーション・システムに対して、第１のデータベースに蓄積されているレコードがレコード毎に第１のレコード形式又は第２のレコード形式を有する点において相違している。従って、以下、かかる相違点を中心として説明する。
Second Embodiment
Next, a database replication system according to the second embodiment of the present invention will be described. The database replication system according to the second embodiment is different from the database replication system according to the first embodiment in that records stored in the first database are recorded in the first record format or the first record format. 2 in that it has two record formats. Accordingly, the following description will focus on such differences.
ところで、第２のデータベースを正規化するためには、ＶＳＡＭ編成ファイル内の１つのレコードに含まれる情報を複数のレコード形式（フォーマット）と対応付ける（マッピングする）必要がある。このため、第１の情報処理装置１００において、レコードの変更を表す情報を、第２のデータベースにおけるレコード形式に変換した配信イメージを作成する処理を行う必要があった。
Incidentally, in order to normalize the second database, it is necessary to associate (map) information included in one record in the VSAM organization file with a plurality of record formats (formats). For this reason, in the first
しかしながら、第１の情報処理装置１００において配信イメージを作成する処理を行うようにデータベース・レプリケーション・システム１が構成された場合、元の（第１のデータベースにおける）レコード単位で、レコードの変更を表す情報を転送できないという問題がある。即ち、この場合、何らかの障害が発生することにより、レコードの変更を表す情報の転送処理が失敗したとき、レコードの変更を表す情報においてレコードの一部のみに相当する部分だけが転送されてしまう虞がある。その結果、第２のデータベースにおいてレコード間の整合性が取れなくなる虞がある。
However, when the
そこで、第２実施形態に係るデータベース・レプリケーション・システム１において、第１の情報処理装置１００は、レコードの変更を表す情報を、第２のデータベースにおけるレコード形式に変換することなく第２の情報処理装置２００へ送信する。第２の情報処理装置２００は、受信した、レコードの変更を表す情報を、第２のデータベースにおけるレコード形式に変換し、変換した情報に基づいて、当該レコードの変更を第２のデータベースに反映する。
Therefore, in the
次に、第２実施形態に係るデータベース・レプリケーション・システム１の作動について説明する。
Next, the operation of the
本例では、第１のデータベース部１０１に蓄積されている各レコードは、第１のレコード形式又は第２のレコード形式を有する。具体的には、図１４に示したように、第１のレコード形式は、「ＦＯＲＭＡＴ０１」により定義されるレコード内のカラムである「列３」のデータとして、「ＦＯＲＭＡＴ０２」により定義されるレコードが挿入されたレコード形式である。また、第２のレコード形式は、「ＦＯＲＭＡＴ０１」により定義されるレコード内のカラムである「列３」のデータとして、「ＦＯＲＭＡＴ０３」により定義されるレコードが挿入されたレコード形式である。
In this example, each record stored in the
更に、第１のデータベース部１０１に蓄積されている各レコードは、当該レコードを特定するための情報としてのカラムである「ＰＫＥＹ」を、当該レコードの先頭に含む。第１の情報処理装置１００は、アプリケーション実行部１０２が実行するアプリケーション・プログラムのソースコードを解析することによりＦＤ情報を取得する。
Furthermore, each record stored in the
そして、図１５に示したように、第２の情報処理装置２００は、カラムとして「ＰＫＥＹ」が存在する場合、「ＦＯＲＭＡＴ０２」及び「ＦＯＲＭＡＴ０３」に対応するテーブルのカラムとして、「ＦＯＲＭＡＴ０１」に対応するテーブルのレコードを参照するための「ＰＫＥＹ」を追加したＤＤＬ情報を生成する。
Then, as illustrated in FIG. 15, when “PKEY” exists as a column, the second
また、第２の情報処理装置２００は、第１の情報処理装置１００から受信したＦＤ情報及びアプリケーション特定情報に基づいて、図１６に示したように、分配条件を生成する。
Further, the second
第１の情報処理装置１００は、変更命令がアプリケーション実行部１０２によって生成されると、図１７に示したように、一時変更ログ情報を生成する。一時変更ログ情報は、図９に示したように、変更命令を生成したアプリケーション・プログラムを特定するためのアプリケーション特定情報（本例では、「ＡＰ０１」）と、当該変更命令に基づく変更後のレコード（本例では、「００００１ＡＡＡＢＢ０２ＬＬＭＭＭ」等）と、変更命令の種別（追加、削除、又は、更新）を特定するための命令種別情報（本例では、「ＩＮＳＥＲＴ」）と、を含む。
When the change instruction is generated by the
そして、第１の情報処理装置１００は、生成された一時変更ログ情報を第２の情報処理装置２００へ送信する。第２の情報処理装置２００は、一時変更ログ情報を受信し、受信した一時変更ログ情報が表すレコードの変更を、第２のデータベースに反映する。
これにより、第２のデータベースは、図１８に示したように、テーブル毎に、レコードの変更が反映される。
Then, the first
Thereby, as shown in FIG. 18, the second database reflects the change of the record for each table.
以上、説明したように、本発明の第２実施形態に係るデータベース・レプリケーション・システム１によれば、第１実施形態と同様の作用及び効果を奏する。
As described above, according to the
更に、第２実施形態に係るデータベース・レプリケーション・システム１によれば、第１の情報処理装置１００が、レコードの変更を表す情報を、第２のデータベースにおけるレコード形式に変換することなく第２の情報処理装置２００へ送信するので、変換する場合と比較して、送信されるデータ量を少なくすることができる。その理由は、カラム「ＰＫＥＹ」の値を重複して送信する必要がないからである。
Furthermore, according to the
加えて、第１の情報処理装置１００から第２の情報処理装置２００へ送信される、レコードの変更を表す情報は、１つのレコードである。即ち、元の（第１のデータベースにおける）レコード単位で、レコードの変更を表す情報を転送することができる。従って、データベースの状態の管理を簡素化することができる。更に、第２のデータベースにおいてレコード間の整合性が取れなくなることを回避することができる。
In addition, information representing a record change transmitted from the first
＜第３実施形態＞
次に、本発明の第３実施形態に係るデータベース・レプリケーション・システムについて図１９を参照しながら説明する。
第３実施形態に係るデータベース・レプリケーション・システム３００は、
レコードの形式であるレコード形式を複数有する複数のレコードを格納するＶＳＡＭ（Ｖｉｒｔｕａｌ Ｓｔｏｒａｇｅ Ａｃｃｅｓｓ Ｍｅｔｈｏｄ）編成ファイルにより構成された第１のデータベースが蓄積しているレコードが変更された場合、１つのレコード形式を有するレコードを格納するテーブルを複数含む第２のデータベースに当該変更を反映する変更反映部（変更反映手段）３０１を備える。
<Third Embodiment>
Next, a database replication system according to a third embodiment of the present invention will be described with reference to FIG.
A
When a record stored in the first database configured by a VSAM (Virtual Storage Access Method) organization file that stores a plurality of records having a plurality of record formats that are record formats is changed, one record format is changed. A change reflection unit (change reflection unit) 301 that reflects the change in a second database including a plurality of tables that store the records having the record is provided.
これによれば、ＶＳＡＭ編成ファイルにより構成されたデータベースにおけるレコードの変更をリアルタイムに他のデータベース（例えば、リレーショナル・データベース等）に反映することができる。 According to this, the change of the record in the database configured by the VSAM organization file can be reflected in another database (for example, a relational database) in real time.
以上、上記実施形態を参照して本願発明を説明したが、本願発明は、上述した実施形態に限定されるものではない。本願発明の構成及び詳細に、本願発明の範囲内において当業者が理解し得る様々な変更をすることができる。 Although the present invention has been described with reference to the above embodiment, the present invention is not limited to the above-described embodiment. Various changes that can be understood by those skilled in the art can be made to the configuration and details of the present invention within the scope of the present invention.
なお、上記各実施形態においてデータベース・レプリケーション・システム１の各機能は、ＣＰＵがプログラム（ソフトウェア）を実行することにより実現されていたが、回路等のハードウェアにより実現されていてもよい。
In each of the above embodiments, each function of the
また、上記各実施形態においてプログラムは、記憶装置に記憶されていたが、コンピュータが読み取り可能な記録媒体に記憶されていてもよい。例えば、記録媒体は、フレキシブルディスク、光ディスク、光磁気ディスク、及び、半導体メモリ等の可搬性を有する媒体である。 In each of the above embodiments, the program is stored in the storage device, but may be stored in a computer-readable recording medium. For example, the recording medium is a portable medium such as a flexible disk, an optical disk, a magneto-optical disk, and a semiconductor memory.
また、上記実施形態の他の変形例として、上述した実施形態及び変形例の任意の組み合わせが採用されてもよい。 In addition, as another modified example of the above-described embodiment, any combination of the above-described embodiments and modified examples may be employed.
＜付記＞
上記実施形態の一部又は全部は、以下の付記のように記載され得るが、以下には限られない。
<Appendix>
A part or all of the above embodiment can be described as the following supplementary notes, but is not limited thereto.
（付記１）
レコードの形式であるレコード形式を複数有する複数のレコードを格納するＶＳＡＭ（Ｖｉｒｔｕａｌ Ｓｔｏｒａｇｅ Ａｃｃｅｓｓ Ｍｅｔｈｏｄ）編成ファイルにより構成された第１のデータベースが蓄積しているレコードが変更された場合、１つのレコード形式を有するレコードを格納するテーブルを複数含む第２のデータベースに当該変更を反映する変更反映手段を備えるデータベース・レプリケーション・システム。
(Appendix 1)
When a record stored in the first database configured by a VSAM (Virtual Storage Access Method) organization file that stores a plurality of records having a plurality of record formats that are record formats is changed, one record format is changed. A database replication system comprising a change reflection means for reflecting the change in a second database including a plurality of tables for storing records having the same.
これによれば、ＶＳＡＭ編成ファイルにより構成されたデータベースにおけるレコードの変更をリアルタイムに他のデータベース（例えば、リレーショナル・データベース等）に反映することができる。 According to this, the change of the record in the database configured by the VSAM organization file can be reflected in another database (for example, a relational database) in real time.
（付記２）
付記１に記載のデータベース・レプリケーション・システムであって、
前記第２のデータベースに含まれるテーブルであり、且つ、前記第１のデータベースにおいて変更されたレコードが格納されるべきテーブルを特定するための分配条件を記憶する分配条件記憶手段を備え、
前記変更反映手段は、前記記憶されている分配条件に基づいて特定されるテーブルに、前記変更を反映するように構成されたデータベース・レプリケーション・システム。
(Appendix 2)
The database replication system according to
A distribution condition storage means for storing a distribution condition for specifying a table that is a table included in the second database and in which a record changed in the first database is to be stored;
The change reflecting means is a database replication system configured to reflect the change in a table specified based on the stored distribution condition.
（付記３）
付記１又は付記２に記載のデータベース・レプリケーション・システムであって、
前記第１のデータベースにおいて変更されたレコードが格納されるべきテーブルを前記第２のデータベースが含まない場合、当該第１のデータベースにおける前記レコード形式を定める第１の定義情報を取得し、当該取得した第１の定義情報に基づいて当該第２のデータベースにおいて当該テーブルを生成するテーブル生成手段を備えるデータベース・レプリケーション・システム。
(Appendix 3)
A database replication system according to
When the second database does not include a table in which the record changed in the first database is to be stored, the first definition information defining the record format in the first database is acquired, and the acquired A database replication system comprising table generation means for generating the table in the second database based on first definition information.
（付記４）
付記３に記載のデータベース・レプリケーション・システムであって、
前記第１の定義情報は、ＣＯＢＯＬ（Ｃｏｍｍｏｎ Ｂｕｓｉｎｅｓｓ Ｏｒｉｅｎｔｅｄ Ｌａｎｇｕａｇｅ）に従った情報であるデータベース・レプリケーション・システム。
(Appendix 4)
The database replication system according to
The database definition system, wherein the first definition information is information according to COBOL (Common Business Oriented Language).
（付記５）
付記３又は付記４に記載のデータベース・レプリケーション・システムであって、
前記テーブル生成手段は、前記テーブルを生成するためのＳＱＬに従った第２の定義情報を、前記取得された第１の定義情報に基づいて生成し、当該生成した第２の定義情報に基づいて前記テーブルを生成するように構成されたデータベース・レプリケーション・システム。
(Appendix 5)
The database replication system according to
The table generation unit generates second definition information according to SQL for generating the table based on the acquired first definition information, and based on the generated second definition information. A database replication system configured to generate the table.
（付記６）
付記１乃至付記５のいずれか一項に記載のデータベース・レプリケーション・システムであって、
前記変更反映手段は、前記第１のデータベースにおいてトランザクション処理におけるコミット処理が行われた場合に、当該トランザクション処理において行われたレコードの変更を前記第２のデータベースに反映するように構成されたデータベース・レプリケーション・システム。
(Appendix 6)
The database replication system according to any one of
The change reflecting means is a database configured to reflect the change of the record made in the transaction processing in the second database when the commit processing in the transaction processing is performed in the first database. Replication system.
これによれば、第１のデータベースにおいて、トランザクション処理にてレコードが変更された後にコミット処理が行われなかった場合に、当該レコードの変更が第２のデータベースに反映されることを防止することができる。即ち、第１のデータベースと第２のデータベースとを確実に同期させることができる。 According to this, in the first database, when the commit process is not performed after the record is changed in the transaction process, it is possible to prevent the change of the record from being reflected in the second database. it can. That is, the first database and the second database can be reliably synchronized.
（付記７）
付記１乃至付記６のいずれか一項に記載のデータベース・レプリケーション・システムであって、
前記第１のデータベースを保持する第１の情報処理装置と、前記第２のデータベースを保持する第２の情報処理装置と、を含み、
前記第１の情報処理装置は、前記第１のデータベースにおけるレコードの変更を表す情報を、前記第２のデータベースにおけるレコード形式に変更することなく前記第２の情報処理装置へ送信するように構成されたデータベース・レプリケーション・システム。
(Appendix 7)
The database replication system according to any one of
A first information processing device that holds the first database; and a second information processing device that holds the second database;
The first information processing apparatus is configured to transmit information representing a change in a record in the first database to the second information processing apparatus without changing to a record format in the second database. Database replication system.
これによれば、レコードの変更を表す情報を、第２のデータベースにおけるレコード形式に変換する場合と比較して、送信されるデータ量を少なくすることができる。更に、第１のデータベースにおけるレコード単位で、レコードの変更を表す情報を転送することができる。従って、データベースの状態の管理を簡素化することができる。更に、第２のデータベースにおいてレコード間の整合性が取れなくなることを回避することができる。 According to this, compared with the case where the information showing the change of a record is converted into the record format in the second database, the amount of data to be transmitted can be reduced. Furthermore, it is possible to transfer information representing record changes in units of records in the first database. Therefore, management of the database state can be simplified. Furthermore, it is possible to avoid the loss of consistency between records in the second database.
（付記８）
レコードの形式であるレコード形式を複数有する複数のレコードを格納するＶＳＡＭ（Ｖｉｒｔｕａｌ Ｓｔｏｒａｇｅ Ａｃｃｅｓｓ Ｍｅｔｈｏｄ）編成ファイルにより構成された第１のデータベースが蓄積しているレコードが変更された場合、１つのレコード形式を有するレコードを格納するテーブルを複数含む第２のデータベースに当該変更を反映する、データベース・レプリケーション方法。
(Appendix 8)
When a record stored in the first database configured by a VSAM (Virtual Storage Access Method) organization file that stores a plurality of records having a plurality of record formats that are record formats is changed, one record format is changed. A database replication method for reflecting the change in a second database including a plurality of tables for storing records having the same.
（付記９）
付記８に記載のデータベース・レプリケーション方法であって、
前記第２のデータベースに含まれるテーブルであり、且つ、前記第１のデータベースにおいて変更されたレコードが格納されるべきテーブルを特定するための分配条件を記憶装置に記憶させるとともに、当該記憶装置に記憶されている分配条件に基づいて特定されるテーブルに、前記変更を反映する、データベース・レプリケーション方法。
(Appendix 9)
The database replication method according to attachment 8, wherein
A distribution condition for specifying a table that is included in the second database and in which a record changed in the first database is to be stored is stored in the storage device and stored in the storage device. A database replication method in which the change is reflected in a table specified based on a distributed condition.
（付記１０）
付記８又は付記９に記載のデータベース・レプリケーション方法であって、
前記第１のデータベースにおいて変更されたレコードが格納されるべきテーブルを前記第２のデータベースが含まない場合、当該第１のデータベースにおける前記レコード形式を定める第１の定義情報を取得し、当該取得した第１の定義情報に基づいて当該第２のデータベースにおいて当該テーブルを生成する、データベース・レプリケーション方法。
(Appendix 10)
The database replication method according to appendix 8 or
When the second database does not include a table in which the record changed in the first database is to be stored, the first definition information defining the record format in the first database is acquired, and the acquired A database replication method for generating the table in the second database based on the first definition information.
（付記１１）
レコードの形式であるレコード形式を複数有する複数のレコードを格納するＶＳＡＭ（Ｖｉｒｔｕａｌ Ｓｔｏｒａｇｅ Ａｃｃｅｓｓ Ｍｅｔｈｏｄ）編成ファイルにより構成された第１のデータベースを保持する第１の情報処理装置と通信可能に構成された第２の情報処理装置であって、
１つのレコード形式を有するレコードを格納するテーブルを複数含む第２のデータベースを保持するとともに、
前記第１のデータベースが蓄積しているレコードが変更された場合、前記第１の情報処理装置から当該レコードの変更を表す変更ログ情報を受信する変更ログ情報受信手段と、
前記受信された変更ログ情報が表す前記レコードの変更を前記２のデータベースに反映する変更反映手段と、
を備える第２の情報処理装置。
(Appendix 11)
A first information processing apparatus configured to be able to communicate with a first information processing apparatus having a first database configured by a VSAM (Virtual Storage Access Method) organization file that stores a plurality of records having a plurality of record formats. 2 information processing apparatus,
Holding a second database including a plurality of tables storing records having one record format;
A change log information receiving means for receiving change log information representing a change of the record from the first information processing apparatus when a record stored in the first database is changed;
Change reflecting means for reflecting the change of the record represented by the received change log information in the database of 2;
A second information processing apparatus.
（付記１２）
付記１１に記載の第２の情報処理装置であって、
前記第２のデータベースに含まれるテーブルであり、且つ、前記第１のデータベースにおいて変更されたレコードが格納されるべきテーブルを特定するための分配条件を記憶する分配条件記憶手段を備え、
前記変更反映手段は、前記記憶されている分配条件に基づいて特定されるテーブルに、前記変更を反映するように構成された第２の情報処理装置。
(Appendix 12)
The second information processing apparatus according to attachment 11, wherein
A distribution condition storage means for storing a distribution condition for specifying a table that is a table included in the second database and in which a record changed in the first database is to be stored;
The second information processing apparatus configured to reflect the change in a table specified based on the stored distribution condition.
（付記１３）
付記１１又は付記１２に記載の第２の情報処理装置であって、
前記第１のデータベースにおいて変更されたレコードが格納されるべきテーブルを前記第２のデータベースが含まない場合、当該第１のデータベースにおける前記レコード形式を定める第１の定義情報を受信し、当該受信した第１の定義情報に基づいて当該第２のデータベースにおいて当該テーブルを生成するテーブル生成手段を備える第２の情報処理装置。
(Appendix 13)
The second information processing apparatus according to appendix 11 or appendix 12,
When the second database does not include a table in which the record changed in the first database is to be stored, the first definition information defining the record format in the first database is received, and the received A second information processing apparatus comprising table generation means for generating the table in the second database based on the first definition information.
（付記１４）
レコードの形式であるレコード形式を複数有する複数のレコードを格納するＶＳＡＭ（Ｖｉｒｔｕａｌ Ｓｔｏｒａｇｅ Ａｃｃｅｓｓ Ｍｅｔｈｏｄ）編成ファイルにより構成された第１のデータベースを保持する第１の情報処理装置と通信可能に構成されるとともに、１つのレコード形式を有するレコードを格納するテーブルを複数含む第２のデータベースを保持する第２の情報処理装置に、
前記第１のデータベースが蓄積しているレコードが変更された場合、前記第１の情報処理装置から当該レコードの変更を表す変更ログ情報を受信する変更ログ情報受信手段と、
前記受信された変更ログ情報が表す前記レコードの変更を前記２のデータベースに反映する変更反映手段と、
を実現させるためのプログラム。
(Appendix 14)
It is configured to be communicable with a first information processing apparatus that holds a first database configured by a VSAM (Virtual Storage Access Method) organization file that stores a plurality of records having a plurality of record formats that are record formats. In a second information processing apparatus holding a second database including a plurality of tables for storing records having one record format,
A change log information receiving means for receiving change log information representing a change of the record from the first information processing apparatus when a record stored in the first database is changed;
Change reflecting means for reflecting the change of the record represented by the received change log information in the database of 2;
A program to realize
（付記１５）
付記１４に記載のプログラムであって、
前記第２の情報処理装置に、更に、
前記第２のデータベースに含まれるテーブルであり、且つ、前記第１のデータベースにおいて変更されたレコードが格納されるべきテーブルを特定するための分配条件を記憶装置に記憶させるとともに、
前記変更反映手段は、前記記憶されている分配条件に基づいて特定されるテーブルに、前記変更を反映するように構成されたプログラム。
(Appendix 15)
The program according to appendix 14, wherein
In the second information processing apparatus,
A storage condition is stored in the storage device for specifying a table that is included in the second database, and in which the table in which the record changed in the first database is to be stored,
The change reflecting means is a program configured to reflect the change in a table specified based on the stored distribution condition.
（付記１６）
付記１４又は付記１５に記載のプログラムであって、
前記第２の情報処理装置に、更に、
前記第１のデータベースにおいて変更されたレコードが格納されるべきテーブルを前記第２のデータベースが含まない場合、当該第１のデータベースにおける前記レコード形式を定める第１の定義情報を受信し、当該受信した第１の定義情報に基づいて当該第２のデータベースにおいて当該テーブルを生成するテーブル生成手段を実現させるためのプログラム。
(Appendix 16)
The program according to appendix 14 or appendix 15,
In the second information processing apparatus,
When the second database does not include a table in which the record changed in the first database is to be stored, the first definition information defining the record format in the first database is received, and the received A program for realizing table generation means for generating the table in the second database based on the first definition information.
本発明は、データベースにおけるレコードの変更を他のデータベースに反映するデータベース・レプリケーション・システム等に適用可能である。 The present invention can be applied to a database replication system or the like that reflects changes in records in a database to other databases.
１ データベース・レプリケーション・システム
１００ 第１の情報処理装置
１０１ 第１のデータベース部
１０２ アプリケーション実行部
１０３ 一時変更ログ情報生成部
１０４ 一時変更ログ情報記憶部
１０５ シーケンス情報記憶部
１０６ 変更ログ情報生成部
１０７ 変更ログ情報記憶部
１０８ ＦＤ情報取得部
１０９ ＦＤ情報記憶部
１１０ 情報送信部
２００ 第２の情報処理装置
２０１ 第２のデータベース部
２０２ アプリケーション実行部
２０３ 情報受信部
２０４ ＦＤ情報解析部
２０５ テーブル生成部
２０６ 分配条件記憶部
２０７ 反映処理部
３００ データベース・レプリケーション・システム
３０１ 変更反映部
DESCRIPTION OF
Claims (9)
前記第２のデータベースに含まれるテーブルであり、且つ、前記第１のデータベースにおいて変更されたレコードが格納されるべきテーブルを特定するための分配条件を記憶する分配条件記憶手段と、
前記第１のデータベースに蓄積されているレコードが有するレコードの形式であるレコード形式を表すレコード形式情報を取得するレコード形式取得手段と、
前記レコード形式情報に基づいて前記分配条件を生成し前記分配条件記憶手段に記憶する情報解析手段と、を備え、
前記変更反映手段は、前記記憶されている分配条件に基づいて特定されるテーブルに、前記変更を反映するように構成されたデータベース・レプリケーション・システム。 When a record stored in the first database configured by a VSAM (Virtual Storage Access Method) organization file that stores a plurality of records having a plurality of record formats that are record formats is changed, one record format is changed. A change reflecting means for reflecting the change in a second database including a plurality of tables for storing records having ;
Distribution condition storage means for storing distribution conditions for specifying a table that is a table included in the second database and in which a record that has been changed in the first database is to be stored;
Record format acquisition means for acquiring record format information representing a record format that is a format of a record included in the record stored in the first database;
Information analyzing means for generating the distribution condition based on the record format information and storing it in the distribution condition storage means,
The change reflecting means is a database replication system configured to reflect the change in a table specified based on the stored distribution condition.
前記第１のデータベースにおいて変更されたレコードが格納されるべきテーブルを前記第２のデータベースが含まない場合、当該第１のデータベースにおける前記レコード形式を定める第１の定義情報を取得し、当該取得した第１の定義情報に基づいて当該第２のデータベースにおいて当該テーブルを生成するテーブル生成手段を備えるデータベース・レプリケーション・システム。 The database replication system according to claim 1 , wherein
When the second database does not include a table in which the record changed in the first database is to be stored, the first definition information defining the record format in the first database is acquired, and the acquired A database replication system comprising table generation means for generating the table in the second database based on first definition information.
前記第１の定義情報は、ＣＯＢＯＬ（Ｃｏｍｍｏｎ Ｂｕｓｉｎｅｓｓ Ｏｒｉｅｎｔｅｄ Ｌａｎｇｕａｇｅ）に従った情報であるデータベース・レプリケーション・システム。 A database replication system according to claim 2 , wherein
The database definition system, wherein the first definition information is information according to COBOL (Common Business Oriented Language).
前記テーブル生成手段は、前記テーブルを生成するためのＳＱＬに従った第２の定義情報を、前記取得された第１の定義情報に基づいて生成し、当該生成した第２の定義情報に基づいて前記テーブルを生成するように構成されたデータベース・レプリケーション・システム。 A database replication system according to claim 2 or claim 3 , wherein
The table generation unit generates second definition information according to SQL for generating the table based on the acquired first definition information, and based on the generated second definition information. A database replication system configured to generate the table.
前記変更反映手段は、前記第１のデータベースにおいてトランザクション処理におけるコミット処理が行われた場合に、当該トランザクション処理において行われたレコードの変更を前記第２のデータベースに反映するように構成されたデータベース・レプリケーション・システム。 The database replication system according to any one of claims 1 to 4 , wherein
The change reflecting means is a database configured to reflect the change of the record made in the transaction processing in the second database when the commit processing in the transaction processing is performed in the first database. Replication system.
前記第１のデータベースを保持する第１の情報処理装置と、前記第２のデータベースを保持する第２の情報処理装置と、を含み、
前記第１の情報処理装置は、前記第１のデータベースにおけるレコードの変更を表す情報を、前記第２のデータベースにおけるレコード形式に変更することなく前記第２の情報処理装置へ送信するように構成されたデータベース・レプリケーション・システム。 A database replication system according to any one of claims 1 to 5 , wherein
A first information processing device that holds the first database; and a second information processing device that holds the second database;
The first information processing apparatus is configured to transmit information representing a change in a record in the first database to the second information processing apparatus without changing to a record format in the second database. Database replication system.
前記変更の反映は、前記第２のデータベースに含まれるテーブルであり、且つ、前記第１のデータベースにおいて変更されたレコードが格納されるべきテーブルを特定するための分配条件を、第１のデータベースに蓄積されているレコードが有するレコードの形式であるレコード形式を表すレコード形式情報に基づいて生成し記憶装置に記憶させるとともに、当該記憶装置に記憶されている分配条件に基づいて特定されるテーブルに、前記変更を反映する、データベース・レプリケーション方法。 When a record stored in the first database configured by a VSAM (Virtual Storage Access Method) organization file that stores a plurality of records having a plurality of record formats that are record formats is changed, one record format is changed. Reflect the change in a second database that includes a plurality of tables that store records ,
The reflection of the change is a table included in the second database, and a distribution condition for specifying a table in which the record changed in the first database is to be stored is stored in the first database. A table that is generated based on record format information that represents a record format that is a record format that the accumulated record has is stored in a storage device, and is specified in a table that is specified based on a distribution condition stored in the storage device. A database replication method that reflects the change.
１つのレコード形式を有するレコードを格納するテーブルを複数含む第２のデータベースを保持するとともに、
前記第１のデータベースが蓄積しているレコードが変更された場合、前記第１の情報処理装置から当該レコードの変更を表す変更ログ情報を受信する変更ログ情報受信手段と、
前記受信された変更ログ情報が表す前記レコードの変更を前記２のデータベースに反映する変更反映手段と、
前記第２のデータベースに含まれるテーブルであり、且つ、前記第１のデータベースにおいて変更されたレコードが格納されるべきテーブルを特定するための分配条件を記憶する分配条件記憶手段と、
前記第１のデータベースに蓄積されているレコードが有するレコードの形式であるレコード形式を表すレコード形式情報を取得して当該取得したレコード形式情報に基づいて前記分配条件を生成し前記分配条件記憶手段に記憶する情報解析手段と、を備え、
前記変更反映手段は、前記記憶されている分配条件に基づいて特定されるテーブルに、前記変更を反映するように構成された第２の情報処理装置。 A first information processing apparatus configured to be able to communicate with a first information processing apparatus having a first database configured by a VSAM (Virtual Storage Access Method) organization file that stores a plurality of records having a plurality of record formats. 2 information processing apparatus,
Holding a second database including a plurality of tables storing records having one record format;
A change log information receiving means for receiving change log information representing a change of the record from the first information processing apparatus when a record stored in the first database is changed;
Change reflecting means for reflecting the change of the record represented by the received change log information in the database of 2;
Distribution condition storage means for storing distribution conditions for specifying a table that is a table included in the second database and in which a record that has been changed in the first database is to be stored;
Record format information representing a record format which is a record format of the records stored in the first database is acquired, the distribution condition is generated based on the acquired record format information, and the distribution condition storage means An information analysis means for storing,
The second information processing apparatus configured to reflect the change in a table specified based on the stored distribution condition.
前記第１のデータベースが蓄積しているレコードが変更された場合、前記第１の情報処理装置から当該レコードの変更を表す変更ログ情報を受信する変更ログ情報受信手段と、
前記受信された変更ログ情報が表す前記レコードの変更を前記２のデータベースに反映する変更反映手段と、を実現させ、更に、
前記第２のデータベースに含まれるテーブルであり、且つ、前記第１のデータベースにおいて変更されたレコードが格納されるべきテーブルを特定するための分配条件を記憶装置に記憶させるとともに、
前記第１のデータベースに蓄積されているレコードが有するレコードの形式であるレコード形式を表すレコード形式情報を取得して当該取得したレコード形式情報に基づいて前記分配条件を生成して記憶させる情報解析手段を実現させ、
前記変更反映手段は、前記記憶されている分配条件に基づいて特定されるテーブルに、前記変更を反映するように構成されたプログラム。 It is configured to be communicable with a first information processing apparatus that holds a first database configured by a VSAM (Virtual Storage Access Method) organization file that stores a plurality of records having a plurality of record formats that are record formats. In a second information processing apparatus holding a second database including a plurality of tables for storing records having one record format,
A change log information receiving means for receiving change log information representing a change of the record from the first information processing apparatus when a record stored in the first database is changed;
A change reflection unit that reflects the change of the record represented by the received change log information in the database of 2 , and further,
A storage condition is stored in the storage device for specifying a table that is included in the second database, and in which the table in which the record changed in the first database is to be stored,
Information analysis means for acquiring record format information representing a record format that is a record format of the records stored in the first database, and generating and storing the distribution condition based on the acquired record format information Realized,
The change reflecting means is a program configured to reflect the change in a table specified based on the stored distribution condition .
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| JP2010118106A JP5601028B2 (en) | 2010-05-24 | 2010-05-24 | Database replication system, database replication method, information processing apparatus, and program |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| JP2010118106A JP5601028B2 (en) | 2010-05-24 | 2010-05-24 | Database replication system, database replication method, information processing apparatus, and program |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| JP2011248434A JP2011248434A (en) | 2011-12-08 |
| JP5601028B2 true JP5601028B2 (en) | 2014-10-08 |
Family
ID=45413656
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| JP2010118106A Expired - Fee Related JP5601028B2 (en) | 2010-05-24 | 2010-05-24 | Database replication system, database replication method, information processing apparatus, and program |
Country Status (1)
| Country | Link |
|---|---|
| JP (1) | JP5601028B2 (en) |
Families Citing this family (1)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| JP5827260B2 (en) * | 2013-03-22 | 2015-12-02 | 三菱電機インフォメーションシステムズ株式会社 | Method, apparatus and program for estimating foreign key in database |
Family Cites Families (2)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US5530855A (en) * | 1992-10-13 | 1996-06-25 | International Business Machines Corporation | Replicating a database by the sequential application of hierarchically sorted log records |
| JP2001297026A (en) * | 2000-04-11 | 2001-10-26 | Hitachi Ltd | Computer system having multiple database management systems |
-
2010
- 2010-05-24 JP JP2010118106A patent/JP5601028B2/en not_active Expired - Fee Related
Also Published As
| Publication number | Publication date |
|---|---|
| JP2011248434A (en) | 2011-12-08 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN109656934B (en) | Source Oracle database DDL synchronization method and device based on log analysis | |
| CN112000741B (en) | Internal and external network data exchange system, method, device, computer equipment and medium | |
| CN110032604B (en) | Data storage device, translation device and database access method | |
| CN107122355B (en) | Data Migration System and Method | |
| CN107122360B (en) | Data Migration System and Method | |
| JP5961689B2 (en) | Incremental data extraction | |
| JP5818394B2 (en) | System and method for operating a mass data platform | |
| US20190005105A1 (en) | Multi-replica asynchronous table replication | |
| CN102402596B (en) | A kind of reading/writing method of master slave separation database and system | |
| CN110413690A (en) | Method of data synchronization, server, electronic equipment, the storage medium of database | |
| CN105447014A (en) | Metadata management method based on binglog, and method and device used for providing metadata | |
| US10904316B2 (en) | Data processing method and apparatus in service-oriented architecture system, and the service-oriented architecture system | |
| CN107122361A (en) | Data mover system and method | |
| CN103793514A (en) | Database synchronization method and databases | |
| CN104809200A (en) | Database synchronization method and device | |
| US20120278429A1 (en) | Cluster system, synchronization controlling method, server, and synchronization controlling program | |
| US9218347B2 (en) | System and method for archiving to a single database table information located across multiple tables | |
| JP2015069461A (en) | Information processing device | |
| US20210318994A1 (en) | Extensible streams for operations on external systems | |
| US20160012070A1 (en) | Methods for managing a request to list previous versions of an object and devices thereof | |
| CN116501700A (en) | APP formatted file offline storage method, device, equipment and storage medium | |
| JP5601028B2 (en) | Database replication system, database replication method, information processing apparatus, and program | |
| US11442758B2 (en) | Integration flow execution renew | |
| CN110417892A (en) | Data Replication Link optimization method and device based on packet parsing | |
| CN111522688B (en) | Data backup method and device for distributed system |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| RD07 | Notification of extinguishment of power of attorney |
Free format text: JAPANESE INTERMEDIATE CODE: A7427 Effective date: 20120718 |
|
| A621 | Written request for application examination |
Free format text: JAPANESE INTERMEDIATE CODE: A621 Effective date: 20130403 |
|
| A131 | Notification of reasons for refusal |
Free format text: JAPANESE INTERMEDIATE CODE: A131 Effective date: 20140212 |
|
| A521 | Written amendment |
Free format text: JAPANESE INTERMEDIATE CODE: A523 Effective date: 20140404 |
|
| TRDD | Decision of grant or rejection written | ||
| A01 | Written decision to grant a patent or to grant a registration (utility model) |
Free format text: JAPANESE INTERMEDIATE CODE: A01 Effective date: 20140722 |
|
| A61 | First payment of annual fees (during grant procedure) |
Free format text: JAPANESE INTERMEDIATE CODE: A61 Effective date: 20140804 |
|
| R150 | Certificate of patent or registration of utility model |
Ref document number: 5601028 Country of ref document: JP Free format text: JAPANESE INTERMEDIATE CODE: R150 |
|
| LAPS | Cancellation because of no payment of annual fees |