JP5449485B2

JP5449485B2 - Replication system and its first and second database devices

Info

Publication number: JP5449485B2
Application number: JP2012184863A
Authority: JP
Inventors: 俊樹村田; 雄介中野; 紀貴堀米; 高太朗三上; 健二阿部; 潤子佐々木
Original assignee: Nippon Telegraph and Telephone Corp; NTT Inc USA
Current assignee: NTT Inc; NTT Inc USA
Priority date: 2012-08-24
Filing date: 2012-08-24
Publication date: 2014-03-19
Anticipated expiration: 2032-08-24
Also published as: JP2014044466A

Description

本発明は、レプリケーションシステムにおいて複数の情報を有し且つ当該情報間で関連をもつテーブルとともに使用されるデータベースの更新を迅速に行う技術に関するものである。 The present invention relates to a technique for quickly updating a database used in a replication system that has a plurality of information and is used together with a table related to the information.

近年、通信サービスにおいては、データのＩＰ化やサーバの仮想化（クラウド）等により安価で高付加価値のサービスをユーザが享受できるようになってきている。また、大規模災害時や装置障害時のサービス中断への影響をできる限り最小化する高信頼なネットワークを構築する技術の重要性が高まってきている。このためには、情報処理装置を装置単位で2 重化等の冗長化を図ったり、大規模災害に備え、複数の異なったロケーションに情報処理装置を設置し（例えば、両者間を50Km以上離れた都市間に情報処理装置を設置する等）、複数装置間を同期化（レプリケーション）することにより、片方が罹災し、障害状態となっても、稼働している残った情報処理装置によりサービスを継続可能としている。このような同期化処理において、ＩＰ化により、特に遠隔のＤＢ間でデータ通信を行う場合、パケットの転送遅延が大きくなるとともに（特にインターネット経由の場合等）、各パケットの転送経路が異なってくるため、ＤＢ間の複数のパケットの送信側順序と受信側順序が異なってくることもある。例えば、パケット１をパケット２より送信側情報処理装置から早く送信したが受信側情報処理装置には、パケット２が最初に到着するようなケースである。同期化においては、これらパケット遅延や送受パケット順序逆転を勘案する必要がある。 In recent years, in communication services, users have been able to enjoy inexpensive and high value-added services through data IP and server virtualization (cloud). In addition, the importance of technology for constructing a highly reliable network that minimizes the impact on service interruption in the event of a large-scale disaster or device failure is increasing. For this purpose, the information processing devices are made redundant, such as by duplication, or installed in multiple different locations in preparation for a large-scale disaster (for example, 50 km or more between them). By installing information processing devices between different cities, etc.) and synchronizing (replication) between multiple devices, even if one side suffers a failure and becomes in trouble, services can be provided by the remaining information processing devices in operation. It is possible to continue. In such synchronization processing, when data is communicated between remote DBs, the packet transfer delay increases (especially, via the Internet, etc.), and the transfer path of each packet differs due to the use of IP. For this reason, the order of transmission side and the order of reception side of a plurality of packets between DBs may be different. For example, the packet 1 is transmitted earlier than the packet 2 from the transmission side information processing apparatus, but the packet 2 arrives at the reception side information processing apparatus first. In synchronization, it is necessary to consider these packet delays and reversal of the order of transmitted and received packets.

中野雄介, 堀米紀貴, 大石秀昭, 岸田好司, “加入者データベースにお25 けるデータレプリケーション手法”, 電子情報通信学会ソサイエティ大会講演論文集,page 415, Aug.2011.Yusuke Nakano, Noriaki Horime, Hideaki Oishi, Koji Kishida, “Data Replication Method in Subscriber Database”, Proceedings of Society Conference of IEICE, page 415, Aug. 2011.

図８は、従来のレプリケーションシステムの構成の一例を示す図である。
レプリケーションシステム１０Ａは、通信ネットワークＮを介して接続された第１データベース装置１Ａと第２データベース装置２Ａとを備える。
第１データベース装置１Ａは、記憶部１１、更新処理部１２Ａを備え、記憶部１１は、データベース１１Ａ、空塞管理部１１Ｂ、チェーン情報記憶部１１Ｃを備える。第１データベース装置１Ａは、通信回線を介して、データ投入端末３に接続される。
第２データベース装置２Ａは、記憶部２１、更新処理部２２Ａを備え、記憶部２１は、データベース２１Ａ、空塞管理部２１Ｂ、チェーン情報記憶部２１Ｃを備える。 FIG. 8 is a diagram showing an example of the configuration of a conventional replication system.
The replication system 10A includes a first database device 1A and a second database device 2A connected via a communication network N.
The first database device 1A includes a storage unit 11 and an update processing unit 12A, and the storage unit 11 includes a database 11A, an empty block management unit 11B, and a chain information storage unit 11C. The first database device 1A is connected to the data input terminal 3 via a communication line.
The second database device 2A includes a storage unit 21 and an update processing unit 22A, and the storage unit 21 includes a database 21A, an airspace management unit 21B, and a chain information storage unit 21C.

図９に示すように、各データベース１１Ａ、２１Ａは、データを記憶するための複数のレコードを有する。図では、便宜的に、レコードの数は６とし、各レコードを示すIndex値「１」〜「６」も示す。
各空塞管理部１１Ｂ、２１Ｂは、それぞれデータベース１１Ａ、２１Ａにつき、各レコードが空きレコードか否かを示すステータスを有する。図では、対応するレコードのIndex値「１」〜「６」も示す。
各チェーン情報１１Ｄ、２１Ｄは、データベース１１Ａ、２１Ａの空きレコードならびに当該空きレコードにデータを書き込む順序を示すもので、それぞれ、チェーン情報記憶部１１Ｃ、２１Ｃに記憶される。図では、対応するレコードのIndex値「１」〜「６」も示す。
各チェーン情報１１Ｄ、２１Ｄは、データを書き込む順序の先頭のレコードのIndex値と同じ先頭Index、末尾のレコードのIndex値と同じ末尾Index、ならびに、各レコードにつき、１つ前の順序のレコードのIndex値と同じ前Indexおよび１つ後の順序のレコードのIndex値と同じ後Indexを有する。なお、空きレコードでないレコードの前Index、後Index、先頭のレコードの前Index、末尾のレコードの後Indexは、それぞれ「Null」となっている。 As shown in FIG. 9, each of the databases 11A and 21A has a plurality of records for storing data. In the figure, for convenience, the number of records is 6, and Index values “1” to “6” indicating the records are also shown.
Each empty block management unit 11B, 21B has a status indicating whether each record is an empty record for each of the databases 11A, 21A. In the figure, Index values “1” to “6” of corresponding records are also shown.
The chain information 11D and 21D indicate the empty records in the databases 11A and 21A and the order in which data is written in the empty records, and are stored in the chain information storage units 11C and 21C, respectively. In the figure, Index values “1” to “6” of corresponding records are also shown.
Each of the chain information 11D and 21D includes a head index that is the same as the index value of the first record in the data writing order, a tail index that is the same as the index value of the last record, and the index of the record in the previous order for each record. It has the same before index as the value and the same after index as the index value of the record in the next order. It should be noted that the front index, rear index, front index of the first record, and rear index of the last record are “Null”, respectively.

図１０は、レプリケーションシステム１０Ａにおける基本動作を示すシーケンス図である。
データ投入端末３は、データベース１１Ａの更新すべき部分に関する更新情報を第１データベース装置１Ａに送信する（Ｓ１０１）。
更新処理部１２Ａは、データベース１１Ａを更新情報に基づいて更新する（Ｓ１０３）。具体的には、更新処理部１２Ａは、先頭Indexに対応するレコードに対し、更新情報で指示されたデータを書き込む、または、更新情報で指示されたレコードのデータを消去する、または、更新情報で指示されたレコードのデータを更新情報で指示されたデータに変更する（Ｓ１０３）。
次に、更新処理部１２Ａは、このようにレコードを更新したなら、更新情報を受け付けないように、つまり、受け付けを一時的に中止する（Ｓ１０５）。この動作は、所謂データベースのロック（更新禁止）という。
更新処理部１２Ａは、このレコードにデータが書き込まれたなら、当該レコードに対応する空塞管理部１１Ｂのステータスを「使用中」に置き換える（Ｓ１０７）。
一方、更新処理部１２Ａは、このレコードからデータが消去されたなら、当該レコードに対応する空塞管理部１１Ｂのステータスを「空き」に置き換える（Ｓ１０７）。
また、更新処理部１２Ａは、データが書き込まれたなら、または、消去されたなら、チェーン情報１１Ｄを更新する（Ｓ１０７）。
記憶部１１は、こうしてデータベース１１Ａや空塞管理部１１Ｂやチェーン情報１１Ｄが更新されたら、更新内容を含む更新成功の更新応答を更新処理部１２Ａを送信する（Ｓ１０９）。
更新処理部１２Ａは、更新成功の更新応答を受信したなら、データベース１１Ａ、空塞管理部１１Ｂおよびチェーン情報１１Ｄの更新された部分に関する更新情報を第２データベース装置２Ａに送信する（Ｓ１１１）。 FIG. 10 is a sequence diagram showing a basic operation in the replication system 10A.
The data input terminal 3 transmits update information regarding the part to be updated in the database 11A to the first database device 1A (S101).
The update processing unit 12A updates the database 11A based on the update information (S103). Specifically, the update processing unit 12A writes the data instructed by the update information to the record corresponding to the head index, erases the data in the record instructed by the update information, or uses the update information. The data of the designated record is changed to the data designated by the update information (S103).
Next, when the record is updated in this way, the update processing unit 12A does not accept the update information, that is, temporarily suspends the acceptance (S105). This operation is called so-called database lock (update prohibition).
When the data is written in this record, the update processing unit 12A replaces the status of the empty / busy management unit 11B corresponding to the record with “in use” (S107).
On the other hand, when the data is deleted from this record, the update processing unit 12A replaces the status of the empty / busy management unit 11B corresponding to the record with “available” (S107).
Further, the update processing unit 12A updates the chain information 11D when data is written or erased (S107).
When the database 11A, the airspace management unit 11B, and the chain information 11D are updated in this manner, the storage unit 11 transmits an update success update response including the update content to the update processing unit 12A (S109).
When the update processing unit 12A receives the update response indicating that the update has been successful, the update processing unit 12A transmits update information regarding the updated portions of the database 11A, the air / vacancy management unit 11B, and the chain information 11D to the second database device 2A (S111).

更新処理部２２Ａは、データベース２１Ａを更新情報に基づいて更新する（Ｓ１１３）。具体的には、更新処理部２２Ａは、更新情報で指示されたレコードに更新情報で指示されたデータを書き込む、または、更新情報で指示されたレコードのデータを消去する、または、更新情報で指示されたレコードのデータを更新情報で指示されたデータに変更する（Ｓ１１３）。
更新処理部２２Ａは、例えば、更新情報で指示された空塞管理部２１Ｂの位置にあるステータスを、更新情報内に含まれるステータスで置き換える（Ｓ１１７）。
更新処理部２２Ａは、更新情報で指示されたチェーン情報の位置にある前Index、後Index、先頭Index、末尾Indexを、更新情報内に含まれる前Index、後Index、先頭Index、末尾Indexで置き換える（Ｓ１１７）。
記憶部２１は、こうしてデータベース２１Ａや空塞管理部２１Ｂやチェーン情報２１Ｄが更新されたら、更新内容を含む更新成功の更新応答を更新処理部２２Ａに送信する（Ｓ１１９）。
更新処理部２２Ａは、記憶部２１から更新成功の更新応答を受信したなら、第１データベース装置１Ａに更新成功の更新応答を送信する（Ｓ１２１）。 The update processing unit 22A updates the database 21A based on the update information (S113). Specifically, the update processing unit 22A writes the data indicated by the update information in the record indicated by the update information, erases the data of the record indicated by the update information, or indicates by the update information. The data of the recorded record is changed to the data indicated by the update information (S113).
For example, the update processing unit 22A replaces the status at the position of the air / vagment management unit 21B indicated by the update information with the status included in the update information (S117).
The update processing unit 22A replaces the previous index, the rear index, the head index, and the tail index at the position of the chain information indicated by the update information with the front index, the rear index, the head index, and the tail index included in the update information. (S117).
When the database 21A, the airspace management unit 21B, and the chain information 21D are updated in this way, the storage unit 21 transmits an update response indicating that the update has been successful, including the update content, to the update processing unit 22A (S119).
If the update processing unit 22A receives the update success response from the storage unit 21, the update processing unit 22A transmits the update success update response to the first database device 1A (S121).

更新処理部１２Ａは、更新成功の更新応答を受信したなら、更新成功の更新応答をデータ投入端末３に送信し（Ｓ１２３）、中止した更新情報の受け付けを再開する（Ｓ１２５）。つまり、データベースのロックを解除する。
ステップＳ１０５からステップＳ１２５の間は、更新情報の受け付けが中止されるので、その間に受信される更新情報に対しては（Ｓ１３１）、更新失敗の応答が返信される（Ｓ１３３）。 If the update processing unit 12A receives the update response indicating the successful update, the update processing unit 12A transmits the update response indicating the successful update to the data input terminal 3 (S123), and resumes accepting the canceled update information (S125). That is, unlock the database.
Since the acceptance of update information is canceled between step S105 and step S125, an update failure response is returned to the update information received during that time (S131) (S133).

次に、図１１を参照し、レプリケーションシステム１０Ａにおいて更新情報の受け付けを一時的に中止する理由を説明する。つまり、ステップＳ１０５、Ｓ１２５を実行しない場合について説明する。図９と同様、レコードの数は便宜的に６とする。
例えば、第１データベース装置１Ａにおいて、データベース１１ＡのIndex値「２」のレコードに「ＢＢ」が書き込まれると（Ｇ１）、空塞管理部１１ＢのIndex値「２」のステータスが「使用中」に変わり、チェーン情報１１ＤのIndex値「２」の後Indexが「Null」に変わり、Index値「４」の前Indexが「Null」に変わり、先頭Indexが「４」に変わる（Ｇ３）。
第１データベース装置１Ａは、Index値「２」のレコード、Index値「２」のステータス、Index値「２」の後Index、Index値「４」の前Indexおよび先頭Indexに関する更新情報を第２データベース装置２Ａに送信する（Ｇ５）。
また、第１データベース装置１Ａにおいて、データベース１１ＡのIndex値「４」のレコードに「ＤＤ」が書き込まれると（Ｇ１１）、空塞管理部１１ＢのIndex値「４」のステータスが「使用中」に変わり、チェーン情報１１ＤのIndex値「４」の後Indexが「Null」に変わり、Index値「５」の前Indexが「Null」に変わり、先頭Indexが「５」に変わる（Ｇ１３）。
第１データベース装置１Ａは、Index値「４」のレコード、Index値「４」のステータス、Index値「４」の後Index、Index値「５」の前Indexおよび先頭Indexに関する更新情報を第２データベース装置２Ａに送信する（Ｇ１５）。 Next, with reference to FIG. 11, a reason for temporarily stopping acceptance of update information in the replication system 10A will be described. That is, a case where steps S105 and S125 are not executed will be described. As in FIG. 9, the number of records is 6 for convenience.
For example, in the first database device 1A, when “BB” is written in the record of the index value “2” of the database 11A (G1), the status of the index value “2” of the air / vacancy management unit 11B becomes “in use”. The index is changed to “Null” after the index value “2” of the chain information 11D, the index before the index value “4” is changed to “Null”, and the head index is changed to “4” (G3).
The first database device 1A updates the update information related to the record with the index value “2”, the status with the index value “2”, the index after the index value “2”, the index before the index value “4”, and the top index. It transmits to the apparatus 2A (G5).
In addition, in the first database device 1A, when “DD” is written in the record with the index value “4” in the database 11A (G11), the status of the index value “4” in the empty block management unit 11B becomes “in use”. The index is changed to “Null” after the index value “4” of the chain information 11D, the index before the index value “5” is changed to “Null”, and the head index is changed to “5” (G13).
The first database device 1A updates the update information related to the record with the index value “4”, the status with the index value “4”, the index after the index value “4”, the index before the index value “5”, and the top index. It transmits to the apparatus 2A (G15).

例えば、ステップＧ５の更新情報よりもステップＧ１５の更新情報が早く受信された際には、第２データベース装置２Ａにおいては、データベース２１ＡのIndex値「４」のレコードに「ＤＤ」が書き込まれ、空塞管理部２１ＢのIndex値「４」のステータスが「使用中」に変わり、チェーン情報２１ＤのIndex値「４」の後Indexが「Null」に変わり、Index値「５」の前Indexが「Null」に変わり、先頭Indexが「５」に変わる（Ｇ２１）。
その後、ステップＧ５の更新情報が受信された際には、第２データベース装置２Ａにおいては、データベース２１ＡのIndex値「２」のレコードに「ＢＢ」が書き込まれ、空塞管理部２１ＢのIndex値「２」のステータスが「使用中」に変わり、チェーン情報２１ＤのIndex値「２」の後Indexが「Null」に変わり、先頭Indexが「４」に変わる（Ｇ２３）。
つまり、この時点では、チェーン情報１１Ｄとチェーン情報２１Ｄは互いに一致しておらず、チェーン情報２１Ｄにおいては、順序の矛盾がある。 For example, when the update information of step G15 is received earlier than the update information of step G5, in the second database device 2A, “DD” is written in the record of the index value “4” of the database 21A and is empty. The status of the index value “4” of the block management unit 21B changes to “in use”, the index value “4” of the chain information 21D changes to “Null”, and the index before the index value “5” becomes “Null” ", And the leading index changes to" 5 "(G21).
Thereafter, when the update information of step G5 is received, in the second database device 2A, “BB” is written in the record of the index value “2” of the database 21A, and the index value “ The status of “2” is changed to “in use”, the index value “2” of the chain information 21D is changed to “Null”, and the head index is changed to “4” (G23).
That is, at this time, the chain information 11D and the chain information 21D do not coincide with each other, and there is an order inconsistency in the chain information 21D.

すなわち、図１２に示すように、チェーン情報２１Ｄにおいては、Index値「４」の後Indexが「５」であり、Index値「５」の前Indexは「Null」であり、両者は矛盾する。
したがって、データベースのロックと解除（ステップＳ１０５、Ｓ１２５）を実行することで、このような矛盾の発生を防止する必要がある。
しかし、ステップＳ１０５、Ｓ１２５を実行すると、その一方で、あるレコードを更新している間は、他のレコードは更新できず、複数のレコードを更新するのに長時間を要する。
つまり、チェーン情報のような、複数の情報を有し且つ当該情報間で関連をもつテーブルとともに使用されるデータベースの更新が迅速に行えないという問題がある。 That is, as shown in FIG. 12, in the chain information 21D, the index after the index value “4” is “5”, the index before the index value “5” is “Null”, and both are contradictory.
Therefore, it is necessary to prevent such a contradiction from occurring by executing database lock and release (steps S105 and S125).
However, when steps S105 and S125 are executed, on the other hand, while a certain record is being updated, other records cannot be updated, and it takes a long time to update a plurality of records.
That is, there is a problem that a database used together with a table having a plurality of pieces of information such as chain information and related to the information cannot be updated quickly.

本発明は、上記の課題に鑑みてなされたものであり、その目的とするところは、レプリケーションシステムにおいて複数の情報を有し且つ当該情報間で関連をもつテーブルとともに使用されるデータベースの更新を迅速に行う技術を提供することにある。 The present invention has been made in view of the above-described problems, and an object of the present invention is to quickly update a database used together with a table having a plurality of information and having a relation between the information in the replication system. It is to provide technology to be performed.

上記の課題を解決するために、第１の本発明は、第１データベース装置と第２データベース装置を備えるレプリケーションシステムであって、前記第１データベース装置は、データを記憶するための複数のレコードを有する第１データベース、複数の情報を有し且つ当該情報間で関連をもつテーブルが記憶される第１テーブル記憶部、前記第１データベースを更新し、更新後の前記第１データベースに基づいて前記第１テーブル記憶部のテーブルを更新し、前記第１データベースの更新された部分に関する更新情報を前記第２データベース装置に送信する第１更新処理部を備え、前記第２データベース装置は、前記第１データベースに一致すべき第２データベース、複数の情報を有し且つ当該情報間で関連をもつテーブルが記憶される第２テーブル記憶部、前記更新情報に基づいて前記第２データベースを更新し、更新後の前記第２データベースに基づいて前記第２テーブル記憶部のテーブルを更新する第２更新処理部を備えることを特徴とする。 In order to solve the above-described problem, a first aspect of the present invention is a replication system including a first database device and a second database device, wherein the first database device stores a plurality of records for storing data. A first database having a plurality of pieces of information and storing a table related to the information; updating the first database; and updating the first database based on the updated first database. A first update processing unit that updates a table in a one-table storage unit and transmits update information related to the updated portion of the first database to the second database device, wherein the second database device includes the first database; A second database that stores a plurality of pieces of information and a table associated with the pieces of information. And a second update processing unit that updates the second database based on the update information and updates the table of the second table storage unit based on the updated second database. To do.

例えば、前記第２更新処理部は、前記第２データベースを更新したなら、前記第１更新処理部に更新応答を送信するものであり、前記第１更新処理部は、前記第２データベース装置に更新情報を送信してから、前記更新応答を受信するまでは、前記第１データベース装置の更新された部分を更新しない。 For example, when the second update processing unit updates the second database, the second update processing unit transmits an update response to the first update processing unit, and the first update processing unit updates the second database device. The updated portion of the first database device is not updated until the update response is received after the information is transmitted.

第２の本発明は、第１データベース装置と第２データベース装置を備えるレプリケーションシステムの前記第１データベース装置であって、前記第１データベース装置は、データを記憶するための複数のレコードを有する第１データベース、複数の情報を有し且つ当該情報間で関連をもつテーブルが記憶される第１テーブル記憶部、前記第１データベースを更新し、更新後の前記第１データベースに基づいて前記第１テーブル記憶部のテーブルを更新し、前記第１データベースの更新された部分に関する更新情報を前記第２データベース装置に送信する第１更新処理部を備え、前記第２データベース装置は、前記第１データベースに一致すべき第２データベース、複数の情報を有し且つ当該情報間で関連をもつテーブルが記憶される第２テーブル記憶部、前記更新情報に基づいて前記第２データベースを更新し、更新後の前記第２データベースに基づいて前記第２テーブル記憶部のテーブルを更新する第２更新処理部を備えることを特徴とする。 A second aspect of the present invention is the first database device of a replication system comprising a first database device and a second database device, wherein the first database device has a plurality of records for storing data. A database, a first table storage unit storing a plurality of pieces of information and a table related to the information, and updating the first database, and storing the first table based on the updated first database A first update processing unit that updates a table of a part and transmits update information regarding the updated portion of the first database to the second database device, wherein the second database device matches the first database Second database that stores a plurality of pieces of information and a table that has relations between the pieces of information. And a second update processing unit that updates the second database based on the update information and updates a table of the second table storage unit based on the updated second database. To do.

第３の本発明は、第１データベース装置と第２データベース装置を備えるレプリケーションシステムの前記第２データベース装置であって、前記第１データベース装置は、データを記憶するための複数のレコードを有する第１データベース、複数の情報を有し且つ当該情報間で関連をもつテーブルが記憶される第１テーブル記憶部、前記第１データベースを更新し、更新後の前記第１データベースに基づいて前記第１テーブル記憶部のテーブルを更新し、前記第１データベースの更新された部分に関する更新情報を前記第２データベース装置に送信する第１更新処理部を備え、前記第２データベース装置は、前記第１データベースに一致すべき第２データベース、複数の情報を有し且つ当該情報間で関連をもつテーブルが記憶される第２テーブル記憶部、前記更新情報に基づいて前記第２データベースを更新し、更新後の前記第２データベースに基づいて前記第２テーブル記憶部のテーブルを更新する第２更新処理部を備えることを特徴とする。 The third aspect of the present invention is the second database device of a replication system comprising a first database device and a second database device, wherein the first database device has a plurality of records for storing data. A database, a first table storage unit storing a plurality of pieces of information and a table related to the information, and updating the first database, and storing the first table based on the updated first database A first update processing unit that updates a table of a part and transmits update information regarding the updated portion of the first database to the second database device, wherein the second database device matches the first database Second database that stores a plurality of pieces of information and a table that has relations between the pieces of information. And a second update processing unit that updates the second database based on the update information and updates a table of the second table storage unit based on the updated second database. To do.

本発明によれば、レプリケーションシステムにおいて複数の情報を有し且つ当該情報間で関連をもつテーブルとともに使用されるデータベースの更新を迅速に行うことができる。 ADVANTAGE OF THE INVENTION According to this invention, the update of the database used with the table which has several information in a replication system and has a relationship between the said information can be performed rapidly.

本実施の形態に係るレプリケーションシステムの構成図である。It is a block diagram of the replication system which concerns on this Embodiment. 図１の各データベース１１Ａ、２１Ａ、各空塞管理部１１Ｂ、２１Ｂ、各チェーン情報１１Ｄ、２１Ｄを例示した図である。It is the figure which illustrated each database 11A, 21A of FIG. 1, each empty block management part 11B, 21B, and each chain information 11D, 21D. 図１のレプリケーションシステム１０における基本動作を示すシーケンス図である。It is a sequence diagram which shows the basic operation | movement in the replication system 10 of FIG. 図１のレプリケーションシステム１０の具体的な動作例（動作例１）を説明するための図である。It is a figure for demonstrating the specific operation example (operation example 1) of the replication system 10 of FIG. 図１のレプリケーションシステム１０の具体的な動作例（動作例２）を説明するための図である。It is a figure for demonstrating the specific operation example (operation example 2) of the replication system 10 of FIG. 変形例に係るチェーン情報を例示した図である。It is the figure which illustrated chain information concerning a modification. 変形例に係るデータベースを例示した図である。It is the figure which illustrated the database concerning a modification. 従来のレプリケーションシステム１０Ａの構成を示す図である。It is a figure which shows the structure of 10 A of conventional replication systems. 図８の各データベース１１Ａ、２１Ａ、各空塞管理部１１Ｂ、２１Ｂ、各チェーン情報１１Ｄ、２１Ｄを例示した図である。It is the figure which illustrated each database 11A, 21A of FIG. 8, each empty block management part 11B, 21B, and each chain information 11D, 21D. 図８のレプリケーションシステム１０Ａにおける基本動作を示すシーケンス図である。FIG. 9 is a sequence diagram showing a basic operation in the replication system 10A of FIG. 図８のレプリケーションシステム１０Ａにおいて更新情報の受け付けを一時的に中止する理由を説明するための図である。FIG. 9 is a diagram for explaining the reason for temporarily stopping acceptance of update information in the replication system 10A of FIG. 矛盾を含むチェーン情報の一例を示す図である。It is a figure which shows an example of the chain information containing a contradiction.

以下、本発明の実施の形態について図面を参照して説明する。 Hereinafter, embodiments of the present invention will be described with reference to the drawings.

図１は、本実施の形態に係るレプリケーションシステムの構成図である。 FIG. 1 is a configuration diagram of a replication system according to the present embodiment.

レプリケーションシステム１０は、通信ネットワークＮを介して接続された第１データベース装置１と第２データベース装置２とを備えるレプリケーションシステムである。 The replication system 10 is a replication system that includes a first database device 1 and a second database device 2 connected via a communication network N.

第１データベース装置１は、記憶部１１、更新処理部１２（本発明の第１更新処理部に相当）を備え、記憶部１１は、データベース１１Ａ（本発明の第１データベースに相当）、空塞管理部１１Ｂ、チェーン情報記憶部１１Ｃ（本発明の第１テーブル記憶部に相当）を備える。第１データベース装置１は、通信回線を介して、データ投入端末３に接続される。 The first database device 1 includes a storage unit 11 and an update processing unit 12 (corresponding to the first update processing unit of the present invention). The storage unit 11 includes a database 11A (corresponding to the first database of the present invention), an empty block A management unit 11B and a chain information storage unit 11C (corresponding to the first table storage unit of the present invention) are provided. The first database device 1 is connected to the data input terminal 3 via a communication line.

第２データベース装置２は、記憶部２１、更新処理部２２（本発明の第２更新処理部に相当）を備え、記憶部２１は、データベース２１Ａ（本発明の第２データベースに相当）、空塞管理部２１Ｂ、チェーン情報記憶部２１Ｃ（本発明の第２テーブル記憶部に相当）を備える。 The second database device 2 includes a storage unit 21 and an update processing unit 22 (corresponding to the second update processing unit of the present invention). The storage unit 21 includes a database 21A (corresponding to the second database of the present invention), an empty block A management unit 21B and a chain information storage unit 21C (corresponding to the second table storage unit of the present invention) are provided.

レプリケーションシステム１０は、通常では、まず、データベース１１Ａを更新し、データベース１１Ａを更新したら、データベース２１Ａをデータベース１１Ａに一致させるべく更新するようになっている。つまり、通常では、データベース１１Ａが所謂マスターデータベースである。 Normally, the replication system 10 first updates the database 11A, and when the database 11A is updated, the database 21A is updated to match the database 11A. That is, usually, the database 11A is a so-called master database.

しかし、場合によっては、まず、データベース２１Ａを更新し、次に、データベース１１Ａを更新することもある。この場合は、データベース２１Ａがマスターデータベースである。 However, in some cases, the database 21A is updated first, and then the database 11A is updated. In this case, the database 21A is a master database.

この目的故に、空塞管理部１１Ｂ、２１Ｂは同一構成を有し、チェーン情報記憶部１１Ｃ、２１Ｃは同一構成を有し、更新処理部１２、２２は同じ機能を備えている。 For this purpose, the airspace management units 11B and 21B have the same configuration, the chain information storage units 11C and 21C have the same configuration, and the update processing units 12 and 22 have the same function.

なお、以下の説明では、便宜上、データベース１１Ａがマスターデータベースである場合を主に述べる。 In the following description, the case where the database 11A is a master database is mainly described for convenience.

図２に示すように、各データベース１１Ａ、２１Ａは、データを記憶するための複数のレコードを有する。図では、便宜的に、レコードの数は６とし、各レコードを示すIndex値「１」〜「６」も示す。 As shown in FIG. 2, each of the databases 11A and 21A has a plurality of records for storing data. In the figure, for convenience, the number of records is 6, and Index values “1” to “6” indicating the records are also shown.

各空塞管理部１１Ｂ、２１Ｂは、それぞれデータベース１１Ａ、２１Ａにつき、各レコードが空きレコードか否かを示すステータスを有する。図では、対応するレコードのIndex値「１」〜「６」も示す。 Each empty block management unit 11B, 21B has a status indicating whether each record is an empty record for each of the databases 11A, 21A. In the figure, Index values “1” to “6” of corresponding records are also shown.

各チェーン情報１１Ｄ、２１Ｄは、データベース１１Ａ、２１Ａの空きレコードならびに当該空きレコードにデータを書き込む順序を示すもので、それぞれ、チェーン情報記憶部１１Ｃ、２１Ｃに記憶される。図では、対応するレコードのIndex値「１」〜「６」も示す。各チェーン情報１１Ｄ、２１Ｄは、データベース１１Ａ、２１Ａを高速に検索するのに使用される。 The chain information 11D and 21D indicate the empty records in the databases 11A and 21A and the order in which data is written in the empty records, and are stored in the chain information storage units 11C and 21C, respectively. In the figure, Index values “1” to “6” of corresponding records are also shown. The chain information 11D and 21D are used for searching the databases 11A and 21A at high speed.

各チェーン情報１１Ｄ、２１Ｄは、データを書き込む順序の先頭のレコードのIndex値と同じ先頭Index、末尾のレコードのIndex値と同じ末尾Index、ならびに、各レコードにつき、１つ前の順序のレコードのIndex値と同じ前Indexおよび１つ後の順序のレコードのIndex値と同じ後Indexを有する。なお、空きレコードでないレコードの前Index、後Index、先頭のレコードの前Index、末尾のレコードの後Indexは、それぞれ「Null」となっている。 Each of the chain information 11D and 21D includes a head index that is the same as the index value of the first record in the data writing order, a tail index that is the same as the index value of the last record, and the index of the record in the previous order for each record. It has the same before index as the value and the same after index as the index value of the record in the next order. It should be noted that the front index, rear index, front index of the first record, and rear index of the last record are “Null”, respectively.

つまり、各チェーン情報１１Ｄ、２１Ｄは、各レコードについての情報からなる複数の情報を有し且つ当該情報間で関連をもつテーブルである。 That is, each chain information 11D and 21D is a table having a plurality of information including information about each record and having a relation between the information.

図１に戻り、データ投入端末３は、更新すべき部分に関する更新情報を第１データベース装置１に送信するものである。 Returning to FIG. 1, the data input terminal 3 transmits update information regarding a portion to be updated to the first database device 1.

更新処理部１２は、データ投入端末３からの更新情報に基づき、データベース１１Ａを更新し、更新後のデータベース１１Ａに基づいて、空塞管理部１１Ｂおよびチェーン情報１１Ｄを更新し、データベース１１Ａおよび空塞管理部１１Ｂの更新された部分に関する更新情報を第２データベース装置２に送信するものである。なお、以下の説明では省略するが、更新処理部２２は、同様にデータベース２１Ａ、空塞管理部２１Ｂおよびチェーン情報２１Ｄを更新し、データベース２１Ａおよび空塞管理部２１Ｂの更新された部分に関する更新情報を第１データベース装置１に送信することができる。 The update processing unit 12 updates the database 11A based on the update information from the data input terminal 3, updates the empty / busy management unit 11B and the chain information 11D based on the updated database 11A, and updates the database 11A and the empty / busy Update information regarding the updated portion of the management unit 11B is transmitted to the second database device 2. Although not described in the following description, the update processing unit 22 similarly updates the database 21A, the vacancy management unit 21B, and the chain information 21D, and updates information regarding the updated portions of the database 21A and the vacancy management unit 21B. Can be transmitted to the first database device 1.

更新処理部２２は、第１データベース装置１からの更新情報に基づき、データベース２１Ａおよび空塞管理部２１Ｂを更新し、更新後のデータベース２１Ａまたは更新後の空塞管理部２１Ｂに基づいて、チェーン情報２１Ｄを更新するものである。以下の説明では省略するが、更新処理部１２は、同様にデータベース１１Ａ、空塞管理部１１Ｂおよびチェーン情報１１Ｄを更新することができる。 The update processing unit 22 updates the database 21A and the vacant / vacant management unit 21B based on the update information from the first database device 1, and the chain information based on the updated database 21A or the updated vacant / vacant management unit 21B. 21D is updated. Although omitted in the following description, the update processing unit 12 can similarly update the database 11A, the airspace management unit 11B, and the chain information 11D.

（基本動作）
図３は、レプリケーションシステム１０における基本動作を示すシーケンス図である。 (basic action)
FIG. 3 is a sequence diagram showing a basic operation in the replication system 10.

なお、便宜上、データベース２１Ａがマスターデータベースである場合だけを述べる。 For convenience, only the case where the database 21A is a master database will be described.

データ投入端末３は、データベース１１Ａの更新すべき部分に関する更新情報を第１データベース装置１に送信する（Ｓ１）。 The data input terminal 3 transmits update information regarding the part to be updated in the database 11A to the first database device 1 (S1).

更新処理部１２は、データベース１１Ａを更新情報に基づいて更新する（Ｓ３）。具体的には、更新処理部１２は、先頭Indexに対応するレコードに対し、更新情報で指示されたデータを書き込む、または、更新情報で指示されたレコードのデータを消去する、または、更新情報で指示されたレコードのデータを更新情報で指示されたデータに変更する（Ｓ３）。 The update processing unit 12 updates the database 11A based on the update information (S3). Specifically, the update processing unit 12 writes the data instructed by the update information to the record corresponding to the head index, erases the data in the record instructed by the update information, or uses the update information. The data of the instructed record is changed to the data instructed by the update information (S3).

次に、更新処理部１２は、このように更新したレコードについては、更新情報を受け付けないように、つまり、受け付けを一時的に中止する（Ｓ５）。この動作は、所謂レコードのロック（更新禁止）という。 Next, the update processing unit 12 does not accept update information for the record updated in this way, that is, temporarily suspends acceptance (S5). This operation is called so-called record lock (update prohibition).

更新処理部１２は、このレコードにデータが書き込まれたなら、当該レコードに対応する空塞管理部１１Ｂのステータスを「使用中」に置き換える（Ｓ７）。 When the data is written in this record, the update processing unit 12 replaces the status of the empty / busy management unit 11B corresponding to the record with “in use” (S7).

一方、更新処理部１２は、このレコードからデータが消去されたなら、当該レコードに対応する空塞管理部１１Ｂのステータスを「空き」に置き換える（Ｓ７）。 On the other hand, when the data is deleted from this record, the update processing unit 12 replaces the status of the empty / busy management unit 11B corresponding to the record with “available” (S7).

また、更新処理部１２は、データが書き込まれたなら、または、消去されたなら、チェーン情報１１Ｄを更新する（Ｓ７）。 Further, the update processing unit 12 updates the chain information 11D if data is written or erased (S7).

具体的には、チェーン情報１１Ｄが、データを書き込む順序でIndex値が「２−４−５−６」となるようなものの場合、更新処理部１２は、先頭Indexが示すレコードにデータを書き込んだなら、「２−４−５−６」が「４−５−６」となるようにチェーン情報１１Ｄを更新する。 Specifically, when the chain information 11D has an index value “2-4-5-6” in the order in which data is written, the update processing unit 12 has written the data in the record indicated by the first index. Then, the chain information 11D is updated so that “2-4-5-6” becomes “4-5-6”.

一方、チェーン情報１１Ｄが、データを書き込む順序でIndex値が「２−５−６」となるようなものの場合、更新処理部１２は、例えば、Index値「３」のレコードからデータを消去したなら、「２−５−６」が「２−５−６−３」となるようにチェーン情報１１Ｄを更新する。 On the other hand, when the chain information 11D is such that the index value is “2-5-6” in the order of writing data, the update processing unit 12 deletes the data from the record with the index value “3”, for example. The chain information 11D is updated so that “2-5-6” becomes “2-5-6-3”.

記憶部１１は、こうしてデータベース１１Ａや空塞管理部１１Ｂやチェーン情報１１Ｄが更新されたら、更新内容を含む更新成功の更新応答を更新処理部１２を送信する（Ｓ９）。 When the database 11A, the airspace management unit 11B, or the chain information 11D is updated in this manner, the storage unit 11 transmits an update response indicating that the update has been successful, including the update content, to the update processing unit 12 (S9).

更新処理部１２は、更新成功の更新応答を受信したなら、データベース１１Ａおよび空塞管理部１１Ｂの更新された部分に関する更新情報を第２データベース装置２に送信する（Ｓ１１）。 If the update processing unit 12 receives an update response indicating that the update has been successful, the update processing unit 12 transmits update information regarding the updated portions of the database 11A and the air / vacancy management unit 11B to the second database device 2 (S11).

更新処理部２２は、データベース２１Ａを更新情報に基づいて更新する（Ｓ１３）。具体的には、更新処理部２２は、更新情報で指示されたレコードに更新情報で指示されたデータを書き込む、または、更新情報で指示されたレコードのデータを消去する、または、更新情報で指示されたレコードのデータを更新情報で指示されたデータに変更する（Ｓ１３）。 The update processing unit 22 updates the database 21A based on the update information (S13). Specifically, the update processing unit 22 writes the data indicated by the update information in the record indicated by the update information, erases the data of the record indicated by the update information, or indicates by the update information. The data of the recorded record is changed to the data indicated by the update information (S13).

更新処理部２２は、例えば、更新情報で指示された空塞管理部２１Ｂの位置にあるステータスを、更新情報内に含まれるステータスで置き換える（Ｓ１７）。 For example, the update processing unit 22 replaces the status at the position of the air / vacancy management unit 21B indicated by the update information with the status included in the update information (S17).

記憶部２１は、こうしてデータベース２１Ａや空塞管理部２１Ｂが更新されたら、更新内容を含む更新成功の更新応答を更新処理部２２に送信する（Ｓ１９）。 When the database 21A and the air / vacancy management unit 21B are updated in this way, the storage unit 21 transmits an update success response including the update contents to the update processing unit 22 (S19).

また、更新処理部２２は、こうしてデータベース２１Ａが更新されたなら、更新後のデータベース２１Ａに基づいて、チェーン情報２１Ｄを更新する（Ｓ２１）。 Further, when the database 21A is updated in this manner, the update processing unit 22 updates the chain information 21D based on the updated database 21A (S21).

具体的には、チェーン情報２１Ｄが、データを書き込む順序でIndex値が「２−４−５−６」となるようなものの場合、更新処理部２２は、先頭Indexが示すレコードにデータを書き込んだなら、「２−４−５−６」が「４−５−６」となるようにチェーン情報２１Ｄを更新する。 Specifically, when the chain information 21D is such that the index value is “2-4-5-6” in the data writing order, the update processing unit 22 has written the data in the record indicated by the first index. Then, the chain information 21D is updated so that “2-4-5-6” becomes “4-5-6”.

一方、チェーン情報２１Ｄが、データを書き込む順序でIndex値が「２−５−６」となるようなものの場合、更新処理部２２は、例えば、Index値「３」のレコードからデータを消去したなら、「２−５−６」が「２−５−６−３」となるようにチェーン情報２１Ｄを更新する。 On the other hand, when the chain information 21D is such that the Index value is “2-5-6” in the order of writing data, the update processing unit 22 deletes the data from the record with the Index value “3”, for example. The chain information 21D is updated so that “2-5-6” becomes “2-5-6-3”.

更新処理部２２は、記憶部２１から更新成功の更新応答を受信したなら、第１データベース装置１に更新成功の更新応答を送信する（Ｓ２３）。 If the update processing unit 22 receives the update response indicating the successful update from the storage unit 21, the update processing unit 22 transmits an update response indicating the successful update to the first database device 1 (S23).

更新処理部１２は、更新成功の更新応答を受信したなら、更新成功の更新応答をデータ投入端末３に送信し（Ｓ２５）、更新情報の受け付けを中止したレコードについて、更新情報の受け付けを再開する（Ｓ２７）。つまり、レコードのロックを解除する。 If the update processing unit 12 receives the update response indicating the successful update, the update processing unit 12 transmits an update response indicating the successful update to the data input terminal 3 (S25), and resumes accepting the update information for the record for which the acceptance of the update information is stopped. (S27). That is, the record is unlocked.

（動作例１）
次に、図４を参照し、レプリケーションシステム１０の具体的な動作例（動作例１）について説明する。図２と同様、レコードの数は便宜的に６とする。 (Operation example 1)
Next, a specific operation example (operation example 1) of the replication system 10 will be described with reference to FIG. As in FIG. 2, the number of records is six for convenience.

まず、当初、各データベース１１Ａ、データベース２１Ａでは、Index値「１」のレコードにデータ「ＡＡ」、Index値「３」のレコードに「ＣＣ」があり、他のレコードは空きレコードになっている。つまり、データベース１１Ａとデータベース２１Ａは互いに一致している。 First, in each of the databases 11A and 21A, the record with the index value “1” has data “AA”, the record with the index value “3” has “CC”, and the other records are empty records. That is, the database 11A and the database 21A match each other.

また、当初、各空塞管理部１１Ｂ、空塞管理部２１Ｂでは、Index値「１」のステータスと、Index値「３」のステータスが「使用中」で、他のステータスは「空き」である。つまり、空塞管理部１１Ｂと空塞管理部２１Ｂは互いに一致している。 Initially, in each of the airfight management units 11B and the airfight management unit 21B, the status of the index value “1” and the status of the index value “3” are “in use”, and the other statuses are “empty”. . That is, the air / vagment management unit 11B and the air / vagment management unit 21B coincide with each other.

また、各チェーン情報１１Ｄ、チェーン情報２１Ｄでは、Index値「１」の前Index、Index値「１」の後Indexは「Null」であり、Index値「２」の前Index、Index値「２」の後Indexはそれぞれ、「Null」、「４」であり、Index値「３」の前Index、Index値「３」の後Indexは「Null」であり、Index値「４」の前Index、Index値「４」の後Indexはそれぞれ、「２」、「５」であり、Index値「５」の前Index、Index値「５」の後Indexはそれぞれ、「４」、「６」であり、Index値「６」の前Index、Index値「６」の後Indexはそれぞれ、「５」、「Null」であり、先頭Indexは「２」であり、末尾Indexは「６」である。つまり、チェーン情報１１Ｄとチェーン情報２１Ｄは互いに一致しており、各チェーン情報１１Ｄ、チェーン情報２１Ｄにおいては、順序の抜けや重複などの矛盾がない。 In each chain information 11D and chain information 21D, the index before Index value “1” and the index after Index value “1” are “Null”, the index before Index value “2”, and Index value “2”. The index after the index is “Null” and “4”, respectively, the index before the index value “3”, the index after the index value “3” is “Null”, the index before the index value “4”, Index The index after the value “4” is “2” and “5”, respectively, the index before the Index value “5”, and the index after the Index value “5” are “4” and “6”, respectively. The index before Index value “6”, the index after Index value “6” are “5” and “Null”, the leading Index is “2”, and the trailing Index is “6”. That is, the chain information 11D and the chain information 21D match each other, and the chain information 11D and the chain information 21D have no contradiction such as missing order or duplication.

例えば、第１データベース装置１において、データベース１１ＡのIndex値「２」のレコードに「ＢＢ」が書き込まれると（Ｔ１）、空塞管理部１１ＢのIndex値「２」のステータスが「使用中」に変わり、チェーン情報１１ＤのIndex値「２」の後Indexが「Null」に変わり、Index値「４」の前Indexが「Null」に変わり、先頭Indexが「４」に変わる（Ｔ３）。 For example, in the first database device 1, when “BB” is written in the record of the index value “2” of the database 11A (T1), the status of the index value “2” of the air / vacancy management unit 11B becomes “in use”. The index is changed to “Null” after the index value “2” of the chain information 11D, the index before the index value “4” is changed to “Null”, and the head index is changed to “4” (T3).

第１データベース装置１は、Index値「２」のレコード、Index値「２」のステータスに関する更新情報を第２データベース装置２に送信する（Ｔ５）。 The first database device 1 transmits to the second database device 2 update information related to the record having the index value “2” and the status having the index value “2” (T5).

また、第１データベース装置１において、データベース１１ＡのIndex値「４」のレコードに「ＤＤ」が書き込まれると（Ｔ１１）、空塞管理部１１ＢのIndex値「４」のステータスが「使用中」に変わり、チェーン情報１１ＤのIndex値「４」の後Indexが「Null」に変わり、Index値「５」の前Indexが「Null」に変わり、先頭Indexが「５」に変わる（Ｔ１３）。 Further, in the first database device 1, when “DD” is written in the record of the index value “4” of the database 11A (T11), the status of the index value “4” of the empty block management unit 11B becomes “in use”. The index is changed to “Null” after the index value “4” of the chain information 11D, the index before the index value “5” is changed to “Null”, and the head index is changed to “5” (T13).

第１データベース装置１は、Index値「４」のレコード、Index値「４」のステータスに関する更新情報を第２データベース装置２に送信する（Ｔ１５）。 The first database device 1 transmits to the second database device 2 update information regarding the record having the index value “4” and the status having the index value “4” (T15).

例えば、ステップＴ５の更新情報よりもステップＴ１５の更新情報が早く受信された際には、第２データベース装置２においては、データベース２１ＡのIndex値「４」のレコードに「ＤＤ」が書き込まれ、空塞管理部２１ＢのIndex値「４」のステータスが「使用中」に変わり、チェーン情報２１ＤのIndex値「２」の後Indexが「５」に変わり、Index値「４」の前Indexが「Null」に変わり、Index値「４」の後Indexが「Null」に変わる（Ｔ２１）。 For example, when the update information at step T15 is received earlier than the update information at step T5, in the second database device 2, “DD” is written in the record of the index value “4” of the database 21A and is empty. The status of the index value “4” of the block management unit 21B changes to “in use”, the index value “2” of the chain information 21D changes to “5”, and the index before the index value “4” becomes “Null” The index is changed to “Null” after the index value “4” (T21).

その後、ステップＴ５の更新情報が受信された際には、第２データベース装置２においては、データベース２１ＡのIndex値「２」のレコードに「ＢＢ」が書き込まれ、空塞管理部２１ＢのIndex値「２」のステータスが「使用中」に変わり、チェーン情報２１ＤのIndex値「２」の後Indexが「Null」に変わり、Index値「５」の前Indexが「Null」に変わり、先頭Indexが「５」に変わる（Ｔ２３）。 Thereafter, when the update information in step T5 is received, in the second database device 2, “BB” is written in the record of the index value “2” of the database 21A, and the index value “ The status of “2” is changed to “in use”, the index after the index value “2” of the chain information 21D is changed to “Null”, the index before the index value “5” is changed to “Null”, and the leading index is “ 5 "(T23).

つまり、チェーン情報１１Ｄとチェーン情報２１Ｄは互いに一致しており、各チェーン情報１１Ｄ、チェーン情報２１Ｄにおいては、順序の抜けや重複などの矛盾がない。 That is, the chain information 11D and the chain information 21D match each other, and the chain information 11D and the chain information 21D have no contradiction such as missing order or duplication.

（動作例２）
次に、図５を参照し、レプリケーションシステム１０の具体的な動作例（動作例２）について説明する。 (Operation example 2)
Next, a specific operation example (operation example 2) of the replication system 10 will be described with reference to FIG.

まず、当初、各データベース１１Ａ、データベース２１Ａでは、Index値「１」のレコードに「ＡＡ」、Index値「３」のレコードに「ＣＣ」、Index値「４」のレコードに「ＤＤ」があり、他のレコードは空きレコードになっている。つまり、データベース１１Ａとデータベース２１Ａは互いに一致している。 First, in each of the databases 11A and 21A, a record with an index value “1” has “AA”, a record with an index value “3” has “CC”, and a record with an index value “4” has “DD”. Other records are empty records. That is, the database 11A and the database 21A match each other.

また、当初、各空塞管理部１１Ｂ、空塞管理部２１Ｂでは、Index値「１」のステータス、Index値「３」のステータス、Index値「４」のステータスが「使用中」で、他のステータスは「空き」である。つまり、空塞管理部１１Ｂと空塞管理部２１Ｂは互いに一致している。 Initially, each of the airspace management units 11B and 21B has an index value “1” status, an index value “3” status, and an index value “4” status of “in use”. The status is “free”. That is, the air / vagment management unit 11B and the air / vagment management unit 21B coincide with each other.

また、各チェーン情報１１Ｄ、チェーン情報２１Ｄでは、Index値「１」の前Index、Index値「１」の後Indexは「Null」であり、Index値「２」の前Index、Index値「２」の後Indexはそれぞれ、「Null」、「５」であり、Index値「３」の前Index、Index値「３」の後Indexは「Null」であり、Index値「４」の前Index、Index値「４」の後Indexは「Null」であり、Index値「５」の前Index、Index値「５」の後Indexはそれぞれ、「２」、「６」であり、Index値「６」の前Index、Index値「６」の後Indexはそれぞれ、「５」、「Null」であり、先頭Indexは「２」であり、末尾Indexは「６」である。つまり、チェーン情報１１Ｄとチェーン情報２１Ｄは互いに一致しており、各チェーン情報１１Ｄ、チェーン情報２１Ｄにおいては、順序の抜けや重複などの矛盾がない。 In each chain information 11D and chain information 21D, the index before Index value “1” and the index after Index value “1” are “Null”, the index before Index value “2”, and Index value “2”. The index after the index is “Null” and “5”, respectively, the index before the index value “3”, the index after the index value “3” is “Null”, the index before the index value “4”, Index The index after the value “4” is “Null”, the index before the Index value “5”, the indexes after the Index value “5” are “2” and “6”, respectively, and the Index value “6”. The previous index and the subsequent index of index value “6” are “5” and “Null”, respectively, the leading index is “2”, and the trailing index is “6”. That is, the chain information 11D and the chain information 21D match each other, and the chain information 11D and the chain information 21D have no contradiction such as missing order or duplication.

例えば、第１データベース装置１において、データベース１１ＡのIndex値「３」のレコードから「ＣＣ」が消去されると（Ｔ３１）、空塞管理部１１ＢのIndex値「３」のステータスが「空き」に変わり、チェーン情報１１ＤのIndex値「３」の前Indexが「６」に変わり、Index値「６」の後Indexが「３」に変わり、末尾Indexが「３」に変わる（Ｔ３３）。 For example, in the first database device 1, when “CC” is deleted from the record having the index value “3” in the database 11A (T31), the status of the index value “3” in the empty block management unit 11B becomes “free”. The index before the index value “3” of the chain information 11D is changed to “6”, the index after the index value “6” is changed to “3”, and the end index is changed to “3” (T33).

第１データベース装置１は、Index値「３」のレコード、Index値「３」のステータスに関する更新情報を第２データベース装置２に送信する（Ｔ３５）。 The first database device 1 transmits to the second database device 2 update information regarding the record having the index value “3” and the status having the index value “3” (T35).

また、第１データベース装置１において、データベース１１ＡのIndex値「１」のレコードから「ＡＡ」が消去されると（Ｔ４１）、空塞管理部１１ＢのIndex値「１」のステータスが「空き」に変わり、チェーン情報１１ＤのIndex値「１」の前Indexが「３」に変わり、Index値「３」の後Indexが「１」に変わり、末尾Indexが「１」に変わる（Ｔ４３）。 In addition, in the first database device 1, when “AA” is deleted from the record with the index value “1” in the database 11A (T41), the status of the index value “1” in the empty block management unit 11B becomes “free”. The index before the index value “1” of the chain information 11D is changed to “3”, the index after the index value “3” is changed to “1”, and the end index is changed to “1” (T43).

第１データベース装置１は、Index値「１」のレコード、Index値「１」のステータスに関する更新情報を第２データベース装置２に送信する（Ｔ４５）。 The first database device 1 transmits to the second database device 2 update information related to the record having the index value “1” and the status having the index value “1” (T45).

例えば、ステップＴ３５の更新情報よりもステップＴ４５の更新情報が早く受信された際には、第２データベース装置２においては、データベース２１ＡのIndex値「１」のレコードから「ＡＡ」が消去され、空塞管理部２１ＢのIndex値「１」のステータスが「空き」に変わり、チェーン情報２１ＤのIndex値「１」の前Indexが「６」に変わり、Index値「６」の後Indexが「１」に変わり、末尾Indexが「１」に変わる（Ｔ５１）。 For example, when the update information in step T45 is received earlier than the update information in step T35, the second database device 2 deletes “AA” from the record of the index value “1” in the database 21A, and is empty. The status of the index value “1” of the block management unit 21B changes to “free”, the index before the index value “1” of the chain information 21D changes to “6”, and the index after the index value “6” is “1”. The end index is changed to “1” (T51).

その後、ステップＴ３５の更新情報が受信された際には、第２データベース装置２においては、データベース２１ＡのIndex値「３」のレコードから「ＣＣ」が消去され、空塞管理部２１ＢのIndex値「３」のステータスが「空き」に変わり、チェーン情報２１ＤのIndex値「１」の後Indexが「３」に変わり、Index値「３」の前Indexが「１」に変わり、末尾Indexが「３」に変わる（Ｔ５３）。 After that, when the update information in step T35 is received, in the second database device 2, “CC” is deleted from the record with the index value “3” in the database 21A, and the index value “ The status of “3” is changed to “empty”, the index is changed to “3” after the index value “1” of the chain information 21D, the index before the index value “3” is changed to “1”, and the end index is “3”. (T53).

つまり、チェーン情報１１Ｄとチェーン情報２１Ｄは互いに一致していないが、各チェーン情報１１Ｄ、チェーン情報２１Ｄにおいては、順序の抜けや重複などの矛盾がない。よって、データベース２１Ａがマスターデータベースとなっても問題はない。 That is, the chain information 11D and the chain information 21D do not match each other, but the chain information 11D and the chain information 21D have no contradiction such as missing order or duplication. Therefore, there is no problem even if the database 21A becomes the master database.

なお、このような場合であってもチェーン情報１１Ｄとチェーン情報２１Ｄを一致させるには、以下のようにすればよい。 Even in such a case, the chain information 11D and the chain information 21D may be matched as follows.

つまり、チェーン情報１１Ｄが、データを書き込む順序でIndex値が「２−５−６」となるようなもの場合、更新処理部１２は、例えば、Index値「３」のレコードからデータを消去したなら、「２−５−６」が「２−３−５−６」となるようにチェーン情報１１Ｄを更新し、チェーン情報２１Ｄが、データを書き込む順序でIndex値が「２−５−６」となるようなもの場合、更新処理部２２は、例えば、Index値「３」のレコードからデータを消去したなら、「２−５−６」が「２−３−５−６」となるようにチェーン情報２１Ｄを更新すればよい。 That is, if the chain information 11D is such that the index value is “2-5-6” in the data writing order, the update processing unit 12 deletes the data from the record with the index value “3”, for example. , The chain information 11D is updated so that “2-5-6” becomes “2-3-5-6”, and the index value becomes “2-5-6” in the order in which the chain information 21D writes data. In such a case, for example, if the data is deleted from the record with the index value “3”, the update processing unit 22 chains so that “2-5-6” becomes “2-3-5-6”. Information 21D may be updated.

（変形例）
本実施の形態では、各チェーン情報１１Ｄ、チェーン情報２１Ｄは、図６（ａ）に示すように、先頭Indexと後Indexだけからなるものとしてもよい。また、各チェーン情報１１Ｄ、チェーン情報２１Ｄは、図６（ｂ）に示すように、先頭Indexと後Indexだけからなるものとしてもよい。 (Modification)
In the present embodiment, each chain information 11D and chain information 21D may be composed of only a leading index and a trailing index, as shown in FIG. Further, each chain information 11D and chain information 21D may be composed of only a leading index and a trailing index, as shown in FIG. 6 (b).

また、各空塞管理部１１Ｂ、空塞管理部２１Ｂのステータスは、図７に示すように、それぞれデータベース１１Ａ、データベース２１Ａの対応するレコードに含めてもよい。 Further, the statuses of the air / burst management units 11B and 21B may be included in the corresponding records of the database 11A and the database 21A, respectively, as shown in FIG.

以上説明したように、本実施の形態によれば、第１データベース装置１から第２データベース装置２には、チェーン情報１１Ｄの更新された部分に関する更新情報を送信せず、更新処理部２２は、更新後のデータベース２１Ａに基づいてチェーン情報２１Ｄを更新するので、あるレコードを更新している間でも、他のレコードなら更新でき、もって、チェーン情報１１Ｄ、チェーン情報２１Ｄとともに使用されるデータベース１１Ａ、データベース２１Ａの更新を迅速に行うことができる。 As described above, according to the present embodiment, the update information on the updated portion of the chain information 11D is not transmitted from the first database device 1 to the second database device 2, and the update processing unit 22 Since the chain information 21D is updated based on the updated database 21A, it is possible to update other records even while a certain record is being updated. Thus, the database 11A and the database used together with the chain information 11D and the chain information 21D 21A can be updated quickly.

また、チェーン情報１１Ｄの更新された部分に関する更新情報を送信しないので、送信される更新情報の量を低減することができる。 Moreover, since the update information regarding the updated part of the chain information 11D is not transmitted, the amount of update information transmitted can be reduced.

なお、チェーン情報２１Ｄを更新する代わりに、更新後のデータベース２１Ａに基づいて新たにチェーン情報２１Ｄを生成し、これで既存のチェーン情報２１Ｄを置き換えてもよい。この場合であっても、結果的には、更新後のデータベース２１Ａに基づいてチェーン情報２１Ｄが更新されたことになる。 Instead of updating the chain information 21D, the chain information 21D may be newly generated based on the updated database 21A, and the existing chain information 21D may be replaced with this. Even in this case, as a result, the chain information 21D is updated based on the updated database 21A.

また、空塞管理部１１Ｂ、空塞管理部２１Ｂのステータスは、データベース１１Ａ、データベース２１Ａに基づいて、適宜取得できるので、空塞管理部１１Ｂ、空塞管理部２１Ｂを設けなくてもよい。 Moreover, since the status of the air / vagment management unit 11B and the air / vagment management unit 21B can be appropriately acquired based on the database 11A and the database 21A, the air / vagment management unit 11B and the air / vagment management unit 21B may not be provided.

また、本実施の形態では、複数の情報を有し且つ当該情報間で関連をもつテーブルの例として、チェーン情報を用いたが、チェーン情報に限らず、テーブルは、複数の情報を有し且つ当該情報間で関連をもつものであればよい。 In this embodiment, chain information is used as an example of a table having a plurality of information and having a relationship between the information. However, the table is not limited to the chain information, and the table has a plurality of information and What is necessary is just to have a relationship between the said information.

また、第１データベース装置１や第２データベース装置２としてコンピュータを機能させるためのコンピュータプログラムは、半導体メモリ、磁気ディスク、光ディスク、光磁気ディスク、磁気テープなどのコンピュータ読み取り可能な記録媒体に記録でき、また、インターネットなどの通信網を介して伝送させて、広く流通させることができる。 A computer program for causing a computer to function as the first database device 1 or the second database device 2 can be recorded on a computer-readable recording medium such as a semiconductor memory, a magnetic disk, an optical disk, a magneto-optical disk, or a magnetic tape, Further, it can be widely distributed by being transmitted via a communication network such as the Internet.

１第１データベース装置
２第２データベース装置
３データ投入端末
１０レプリケーションシステム
１１、２１記憶部
１１Ａ、２１Ａデータベース
１１Ｂ、２１Ｂ空塞管理部
１１Ｃ、２１Ｃチェーン情報記憶部
１１Ｄ、２１Ｄチェーン情報
１２、２２更新処理部 DESCRIPTION OF SYMBOLS 1 1st database apparatus 2 2nd database apparatus 3 Data input terminal 10 Replication system 11, 21 Memory | storage part 11A, 21A Database 11B, 21B Empty block management part 11C, 21C Chain information storage part 11D, 21D Chain information 12, 22 Update process Part

Claims

A replication system comprising a first database device and a second database device,
The first database device includes:
A first database having a plurality of records for storing data, a first table storage section storing a table having a plurality of information and related to the information, updating the first database, and after updating A first update processing unit that updates the table of the first table storage unit based on the first database, and transmits update information regarding the updated portion of the first database to the second database device;
The second database device includes:
A second database to be matched with the first database, a second table storage unit storing a table having a plurality of pieces of information and related to the information, and updating the second database based on the update information A replication system comprising: a second update processing unit that updates a table in the second table storage unit based on the updated second database.

When the second update processing unit has updated the second database, the second update processing unit transmits an update response to the first update processing unit;
The first update processing unit does not update the updated portion of the first database device until the update response is received after the update information is transmitted to the second database device. Item 1. The replication system according to item 1.

The first database device of a replication system comprising a first database device and a second database device,
The first database device includes:
A first database having a plurality of records for storing data, a first table storage section storing a table having a plurality of information and related to the information, updating the first database, and after updating A first update processing unit that updates the table of the first table storage unit based on the first database, and transmits update information regarding the updated portion of the first database to the second database device;
The second database device includes:
A second database to be matched with the first database, a second table storage unit storing a table having a plurality of pieces of information and related to the information, and updating the second database based on the update information A first database device of a replication system, comprising: a second update processing unit that updates a table in the second table storage unit based on the updated second database.

The second database device of a replication system comprising a first database device and a second database device,
The first database device includes:
A first database having a plurality of records for storing data, a first table storage section storing a table having a plurality of information and related to the information, updating the first database, and after updating A first update processing unit that updates the table of the first table storage unit based on the first database, and transmits update information regarding the updated portion of the first database to the second database device;
The second database device includes:
A second database to be matched with the first database, a second table storage unit storing a table having a plurality of pieces of information and related to the information, and updating the second database based on the update information A second database device of a replication system, comprising: a second update processing unit that updates a table in the second table storage unit based on the updated second database.