JP5840580B2

JP5840580B2 - Distributed information synchronization system and distributed information synchronization method

Info

Publication number: JP5840580B2
Application number: JP2012185855A
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: 2016-01-06
Anticipated expiration: 2032-08-24
Also published as: JP2014044532A

Description

本発明は、データ構造が異なるデータベース間で情報の同期処理を行う分散情報同期システムおよび分散情報同期方法に関する。 The present invention relates to a distributed information synchronization system and a distributed information synchronization method for performing information synchronization processing between databases having different data structures.

近年、情報取得の利便性から、データベースを各端末装置で分散保持して利用することが行われている。分散されたデータベースでは、情報の更新処理を行う際に、データベース間で情報の同期をとることが必要であり、複数システムのデータベースの情報の同期をとる方式としては、変更された情報を同値で他のシステムのデータベースの情報を更新することが可能となっている。 In recent years, for convenience of information acquisition, a database has been distributed and held in each terminal device. In a distributed database, it is necessary to synchronize information between databases when performing information update processing. As a method of synchronizing information in databases of multiple systems, the changed information is the same value. It is possible to update information in databases of other systems.

［online］、ＣｏｄｅＺｉｎｅ、［平成２４年７月１９日検索］、インターネット＜URL:http://codezine.jp/article/detail/1749＞[Online], CodeZine, [Search July 19, 2012], Internet <URL: http: //codezine.jp/article/detail/1749>

しかしながら、複数システムのデータベース間で情報の同期をとる方式はあったが、同期元と同期先で決められた項目に同値を設定する方式のため、テーブル構造（データフォーマット）が異なるデータベース間では同期処理を行うことができなかった。 However, there was a method to synchronize information between databases of multiple systems. However, synchronization is established between databases with different table structures (data formats) because the same value is set for items determined by the synchronization source and synchronization destination. Processing could not be performed.

本発明は、このような問題点に鑑みてなされたものであり、本発明の目的は、テーブル構造（データフォーマット）が異なるデータベース間においても同期処理を行うことができる分散情報同期システムおよび分散情報同期方法を提供することにある。 The present invention has been made in view of such problems, and an object of the present invention is to provide a distributed information synchronization system and distributed information capable of performing synchronization processing between databases having different table structures (data formats). It is to provide a synchronization method.

また、本発明は、テーブル構造の異なるデータベースを各々保持する複数の情報保有装置と、当該複数の情報保有装置とネットワークを介して接続され、前記情報保有装置が保持するデータベース間の情報の同期をとるための同期ルール情報を保持して前記同期ルール情報に従い情報の演算処理を行う情報連携装置からなる分散情報同期システムであって、前記情報保有装置は、前記データベースの情報が変更されたことを検知し、変更された情報を前記情報連携装置に送信する手段と、前記情報連携装置から受信した、同期するために必要な情報に基づいて、必要付随項目を抽出し、前記変更された情報と前記必要付随項目とを含む同期情報を前記情報連携装置に送信する手段と、を備え、前記情報連携装置は、前記情報保有装置から受信した、前記変更された情報に基づいて、同期するために必要な情報を抽出して、当該情報を前記情報保有装置に送信する手段と、前記情報保有装置から受信した前記同期情報に含まれる前記変更された情報と前記必要付随項目とを結合する演算処理を行う手段と、前記同期ルール情報に従って、演算処理が行われた同期情報を他の情報保有装置へ送信する手段と、を備え、前記他の情報保有装置は、前記情報連携装置から受信した、前記演算処理が行われた同期情報に基づいて前記データベースの情報を更新する手段を備えることを特徴とする。 Further, the present invention provides a plurality of information holding devices each holding a database having a different table structure, and synchronization of information between the databases held by the information holding devices connected to the plurality of information holding devices. A distributed information synchronization system comprising an information cooperation device that holds synchronization rule information for performing information processing in accordance with the synchronization rule information, wherein the information holding device has changed information in the database Means for detecting and transmitting changed information to the information cooperation device, and extracting necessary accompanying items based on the information received from the information cooperation device and necessary for synchronization , and the changed information and means for transmitting the synchronization information including said required sub items in the information link device, the information association system, received from the information retaining unit Said, on the basis of the changed information, to extract the information necessary to synchronize, and means for transmitting the information to the information retaining unit, included in the synchronization information received from the information retaining unit Means for performing arithmetic processing for combining the changed information and the necessary accompanying items, and means for transmitting the synchronous information subjected to arithmetic processing in accordance with the synchronization rule information to another information holding device, The other information holding device includes means for updating the information in the database based on the synchronization information that has been received from the information cooperation device and has undergone the arithmetic processing.

また、本発明は、テーブル構造の異なるデータベースを各々保持する複数の情報保有装置と、当該複数の情報保有装置とネットワークを介して接続され、前記情報保有装置が保持するデータベース間の情報の同期をとるための同期ルール情報を保持して前記同期ルール情報に従い情報の演算処理を行う情報連携装置からなる分散情報同期システムの分散情報同期方法であって、前記情報保有装置が、前記データベースの情報が変更されたことを検知し、変更された情報を前記情報連携装置に送信するステップと、前記情報連携装置が、前記情報保有装置から受信した、前記変更された情報に基づいて、同期するために必要な情報を抽出して、当該情報を前記情報保有装置に送信するステップと、前記情報保有装置が、前記情報連携装置から受信した、前記同期するために必要な情報に基づいて、必要付随項目を抽出し、前記変更された情報と前記必要付随項目とを含む同期情報を前記情報連携装置に送信するステップと、前記情報連携装置が、前記情報保有装置から受信した前記同期情報に含まれる前記変更された情報と前記必要付随項目とを結合する演算処理を行うステップと、前記情報連携装置が、前記同期ルール情報に従って、演算処理が行われた同期情報を他の情報保有装置へ送信するステップと、前記他の情報保有装置が、前記情報連携装置から受信した、前記演算処理が行われた同期情報に基づいて前記データベースの情報を更新するステップと、を含むことを特徴とする。 Further, the present invention provides a plurality of information holding devices each holding a database having a different table structure, and synchronization of information between the databases held by the information holding devices connected to the plurality of information holding devices. A shared information synchronization method of a distributed information synchronization system comprising an information cooperation device that holds synchronization rule information for performing information processing according to the synchronization rule information, and the information holding device stores information in the database In order to synchronize based on the changed information received from the information holding device, the step of detecting the change and transmitting the changed information to the information cooperation device Extracting necessary information and transmitting the information to the information holding device; and receiving the information from the information cooperation device. Was based on the information necessary for the synchronization, to extract the required sub items, and transmitting the synchronization information including said required sub items with the changed information to the information link device, the information link A device performing a calculation process of combining the changed information included in the synchronization information received from the information holding device and the necessary associated item; and the information cooperation device calculates according to the synchronization rule information. A step of transmitting the synchronization information that has been processed to another information holding device; and the other information holding device that has received the information processing device from the information cooperation device and that is based on the synchronization information that has been subjected to the arithmetic processing. Updating the information.

本発明は、テーブル構造（データフォーマット）が異なるデータベース間においても同期処理を行うことができる。 The present invention can perform synchronization processing between databases having different table structures (data formats).

本発明の第１の実施形態に係る分散情報同期システムのブロック図である。1 is a block diagram of a distributed information synchronization system according to a first embodiment of the present invention. 情報保有装置保有情報のテーブル構成例を示す図である。It is a figure which shows the table structural example of information holding apparatus holding information. 情報保有装置保有情報のテーブル構成例を示す図である。It is a figure which shows the table structural example of information holding apparatus holding information. 情報保有装置保有情報のテーブル構成例を示す図である。It is a figure which shows the table structural example of information holding apparatus holding information. 情報連携装置のルール設定例を示す図である。It is a figure which shows the example of a rule setting of an information cooperation apparatus. 情報連携装置のルール設定例を示す図である。It is a figure which shows the example of a rule setting of an information cooperation apparatus. 情報保有装置の情報が変更された場合のシーケンス例を示す図である。It is a figure which shows the example of a sequence when the information of an information holding apparatus is changed. 本発明の第２の実施形態に係る分散情報同期システムのブロック図である。It is a block diagram of the distributed information synchronization system which concerns on the 2nd Embodiment of this invention. 情報保有装置保有情報のテーブル構成例を示す図である。It is a figure which shows the table structural example of information holding apparatus holding information. 情報保有装置保有情報のテーブル構成例を示す図である。It is a figure which shows the table structural example of information holding apparatus holding information. 情報保有装置保有情報のテーブル構成例を示す図である。It is a figure which shows the table structural example of information holding apparatus holding information. 情報連携装置のルール設定例を示す図である。It is a figure which shows the example of a rule setting of an information cooperation apparatus. 情報連携装置のルール設定例を示す図である。It is a figure which shows the example of a rule setting of an information cooperation apparatus. 情報保有装置の情報が変更された場合のシーケンス例を示す図である。It is a figure which shows the example of a sequence when the information of an information holding apparatus is changed.

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

図１は、本発明の第１の実施形態に係る分散情報同期システムのブロック図である。図１に示す分散情報同期システムは、情報保有装置１０ａ、１０ｂ、１０ｃと、情報連携装置２０とにより構成される。情報保有装置１０ａ、１０ｂ、１０ｃと、情報連携装置２０は、通信ネットワークを介して接続されている。なお、図１においては、説明を簡単にするために、情報保有装置１０ａ、１０ｂ、１０ｃのみを示しているが、本発明はこれに限定されず、３つ以上の情報保有装置を備えることがあるものとする。 FIG. 1 is a block diagram of a distributed information synchronization system according to the first embodiment of the present invention. The distributed information synchronization system shown in FIG. 1 includes information holding devices 10a, 10b, and 10c and an information cooperation device 20. The information holding devices 10a, 10b, and 10c and the information cooperation device 20 are connected via a communication network. In FIG. 1, only the information holding devices 10a, 10b, and 10c are shown for simplicity of explanation, but the present invention is not limited to this, and may include three or more information holding devices. It shall be.

情報保有装置１０ａは、同期情報送信部１０１ａと情報変更検知部１０２ａと同期処理部１０３ａと情報保有装置保有情報１０４ａとで構成される。情報保有装置保有情報１０４ａは、利用者情報などからなるデータベースを格納する記憶装置である。情報保有装置１０ａは、例えば年金情報などの利用者情報を管理する。 The information holding device 10a includes a synchronization information transmission unit 101a, an information change detection unit 102a, a synchronization processing unit 103a, and information holding device holding information 104a. The information holding device holding information 104a is a storage device that stores a database including user information and the like. The information holding device 10a manages user information such as pension information.

情報保有装置１０ｂ、１０ｃも情報保有装置１０ａと同様の構成である。情報保有装置１０ｂは、同期情報送信部１０１ｂと情報変更検知部１０２ｂと同期処理部１０３ｂと情報保有装置保有情報１０４ｂとで構成される。情報保有装置１０ｃは、同期情報送信部１０１ｃと情報変更検知部１０２ｃと同期処理部１０３ｃと情報保有装置保有情報１０４ｃとで構成される。 The information holding devices 10b and 10c have the same configuration as the information holding device 10a. The information holding device 10b includes a synchronization information transmission unit 101b, an information change detection unit 102b, a synchronization processing unit 103b, and information holding device holding information 104b. The information holding device 10c includes a synchronization information transmission unit 101c, an information change detection unit 102c, a synchronization processing unit 103c, and information holding device holding information 104c.

情報連携装置２０は、同期情報演算部２０１と同期情報送信部２０２と同期ポリシー情報２０３とで構成される。同期ポリシー情報２０３は、同期項目対応情報と同期ルール情報からなる。情報連携装置２０は、同期ルールを管理し、ルールに従い情報演算を行い、演算した情報を対象の情報保有装置１０ａ、１０ｂ、１０ｃに送信する。 The information linkage apparatus 20 includes a synchronization information calculation unit 201, a synchronization information transmission unit 202, and synchronization policy information 203. The synchronization policy information 203 includes synchronization item correspondence information and synchronization rule information. The information cooperation apparatus 20 manages the synchronization rule, performs information calculation according to the rule, and transmits the calculated information to the target information holding apparatuses 10a, 10b, and 10c.

同期情報演算部２０１は、同期情報送信部１０１ａと通信手段１ａで接続され、同期情報送信部１０１ｂと通信手段１ｂで接続され、同期情報送信部１０１ｃと通信手段１ｃで接続されている。 The synchronization information calculation unit 201 is connected to the synchronization information transmission unit 101a by the communication unit 1a, is connected to the synchronization information transmission unit 101b by the communication unit 1b, and is connected to the synchronization information transmission unit 101c by the communication unit 1c.

同期情報送信部２０２は、同期処理部１０３ａと通信手段２ａで接続され、同期処理部１０３ｂと通信手段２ｂで接続され、同期処理部１０３ｃと通信手段２ｃで接続されている。 The synchronization information transmission unit 202 is connected to the synchronization processing unit 103a by the communication unit 2a, is connected to the synchronization processing unit 103b by the communication unit 2b, and is connected to the synchronization processing unit 103c by the communication unit 2c.

図２は、情報保有装置保有情報１０４ａのテーブル構成例を示す図である。図２（ａ）は、情報保有装置保有情報の例を示しており、図２（ｂ）は、同期項目情報の例を示している。図３は、情報保有装置保有情報１０４ｂのテーブル構成例を示す図である。図３（ａ）は、情報保有装置保有情報の例を示しており、図３（ｂ）は、同期項目情報の例を示している。図４は、情報保有装置保有情報１０４ｃのテーブル構成例を示す図である。図４（ａ）は、情報保有装置保有情報の例を示しており、図４（ｂ）は、同期項目情報の例を示している。 FIG. 2 is a diagram illustrating a table configuration example of the information holding device holding information 104a. FIG. 2A shows an example of information holding device possession information, and FIG. 2B shows an example of synchronization item information. FIG. 3 is a diagram illustrating a table configuration example of the information holding device holding information 104b. FIG. 3A shows an example of information holding device possession information, and FIG. 3B shows an example of synchronization item information. FIG. 4 is a diagram illustrating a table configuration example of the information holding device holding information 104c. FIG. 4A shows an example of information holding device possession information, and FIG. 4B shows an example of synchronization item information.

図２〜４に示すとおり、各情報保有装置でテーブル構造が異なっており、各情報保有装置は、テーブル構造が異なるデータベースで情報を管理する。また、各情報保有装置は、自情報保有装置で情報が更新された場合、他の情報保有装置と同期をとるために必要な項目情報も管理する。 As shown in FIGS. 2 to 4, each information holding device has a different table structure, and each information holding device manages information in a database having a different table structure. Each information holding device also manages item information necessary to synchronize with other information holding devices when the information is updated in the own information holding device.

図５および図６は、情報連携装置２０のルール設定例を示す図である。図５は、同期ポリシー情報２０３中の同期項目対応情報の例を示しており、図６は、同期ポリシー情報２０３中の同期ルール情報の例を示している。情報連携装置２０は、同期する項目の対応情報と、どのような演算処理を行って各情報保有装置が保持するデータベース間の情報の同期をとるかという同期ルール情報とを管理する。 5 and 6 are diagrams illustrating an example of rule setting of the information cooperation apparatus 20. FIG. 5 shows an example of synchronization item correspondence information in the synchronization policy information 203, and FIG. 6 shows an example of synchronization rule information in the synchronization policy information 203. The information cooperation apparatus 20 manages correspondence information of items to be synchronized and synchronization rule information indicating what kind of arithmetic processing is performed to synchronize information between databases held by each information holding apparatus.

図７は、情報保有装置１０ａの情報が変更された場合のシーケンス例を示す図である。なお、ここでは利用者姓（ａ＿ｌａｓｔ）と住民異動日（ａ＿ｃｈａｎｇｅ＿ｄａｙ）が変更されているものとする。また、情報保有装置１０ａの識別子をａとし、情報保有装置１０ｂの識別子をｂとし、情報保有装置１０ｃの識別子をｃとする。 FIG. 7 is a diagram illustrating a sequence example when the information of the information holding device 10a is changed. Here, it is assumed that the user surname (a_last) and the resident change date (a_change_day) have been changed. The identifier of the information holding device 10a is a, the identifier of the information holding device 10b is b, and the identifier of the information holding device 10c is c.

（Ａ）同期情報検知処理
情報保有装置１０ａの情報変更検知部１０２ａは、利用者の情報が変更されたことを検知すると、図２（ｂ）の同期項目情報から必要付随項目を検索、抽出する。記述例ではａ＿ｌａｓｔが変更されているので、必要付随項目はａ＿ｆｉｒｓｔとなる。情報変更検知部１０２ａは、情報保有措置１０ａの識別子（ａ）と、変更された情報（ａ＿ｌａｓｔ．佐々木、ａ＿ｃｈａｎｇｅ＿ｄａｙ．２０１２．０７．０７）と、必要付随項目（ａ＿ｆｉｒｓｔ．太郎）を同期情報送信部１０１ａへ送信する。 (A) Synchronization information detection processing When the information change detection unit 102a of the information holding device 10a detects that the user information has been changed, the information change detection unit 102a searches for and extracts necessary accompanying items from the synchronization item information in FIG. . Since a_last is changed in the description example, the necessary accompanying item is a_first. The information change detection unit 102a receives the identifier (a) of the information holding measure 10a, the changed information (a_last.Sasaki, a_change_day.2012.07.07), and the necessary associated item (a_first.Taro) 101a.

（Ｂ）同期情報送信処理
同期情報送信部１０１ａは、同期情報検知処理で得られた情報を情報連携装置２０の同期情報演算部２０１へ送信する。 (B) Synchronization Information Transmission Processing The synchronization information transmission unit 101a transmits information obtained by the synchronization information detection processing to the synchronization information calculation unit 201 of the information cooperation device 20.

（Ｃ）同期情報演算処理
情報連携装置２０の同期情報演算部２０１は、図６に示す同期ルール情報に従って演算を行い、情報保有装置１０ａのａ＿ｌａｓｔが変更されているため、ルールＮｏ．１よりＯｐｅ１の演算で「佐々木太郎」（＝“佐々木”＋“ ”＋“太郎”）という結果を得て、ルールＮｏ．２より佐々木という結果を得て、情報保有装置１０ａのａ＿ｃｈａｎｇｅ＿ｄａｙが変更されているため、ルールＮｏ．ｍより２０１２．０７．０７という結果を得て、ルールＮｏ．ｎよりＯｐｅ３の演算で「平成２４．０７．０７」（西暦から和暦に変換）という結果を得て、演算結果を同期情報送信部２０２へ送信する。 (C) Synchronization information calculation processing The synchronization information calculation unit 201 of the information cooperation device 20 performs calculation according to the synchronization rule information shown in FIG. 6 and the a_last of the information holding device 10a is changed. 1 to obtain the result “Taro Sasaki” (= “Sasaki” + “” + “Taro”) by the operation of Ope1. 2. Since the result of Sasaki is obtained from No. 2 and a_change_day of the information holding device 10a is changed, the rule No. m, a result of 2012.07.07 was obtained. The result of “Heisei 24.07.07” (converted from the Western calendar to the Japanese calendar) is obtained by the operation of Ope3 from n, and the calculation result is transmitted to the synchronization information transmitting unit 202.

記述例では、情報保有装置１０ａの利用者姓と利用者名を情報保有装置１０ｂに送信するために、利用者姓と利用者名の文字列を結合する演算を行い、また、情報保有装置１０ａの住民異動日を情報保有装置１０ｃに送信するために、西暦から和暦に変換する演算を行っている。 In the description example, in order to transmit the user surname and user name of the information holding device 10a to the information holding device 10b, an operation for combining the user surname and the character string of the user name is performed, and the information holding device 10a In order to transmit the inhabitant change date to the information holding device 10c, an operation for converting from the Western calendar to the Japanese calendar is performed.

（Ｄ）同期情報送信処理
同期情報送信部２０２は、演算結果を同期ルール情報に従い情報保有装置１０ｂの同期処理部１０３ｂに送信する。同様に、同期情報送信部２０２は、演算結果を同期ルール情報に従い情報保有装置１０ｃの同期処理部１０３ｃに送信する。 (D) Synchronization Information Transmission Processing The synchronization information transmission unit 202 transmits the calculation result to the synchronization processing unit 103b of the information holding device 10b according to the synchronization rule information. Similarly, the synchronization information transmission unit 202 transmits the calculation result to the synchronization processing unit 103c of the information holding device 10c according to the synchronization rule information.

（Ｅ）同期処理
情報保有装置１０ｂの同期処理部１０３ｂは、受信した演算結果で情報保有装置保有情報１０４ｂを更新する。同様に、情報保有装置１０ｃの同期処理部１０３ｃは、受信した演算結果で情報保有装置保有情報１０４ｃを更新する。 (E) Synchronization processing The synchronization processing unit 103b of the information holding device 10b updates the information holding device holding information 104b with the received calculation result. Similarly, the synchronization processing unit 103c of the information holding device 10c updates the information holding device holding information 104c with the received calculation result.

次に、本発明の第２の実施形態に係る分散情報同期システムについて説明する。第１の実施形態が、同期に必要な項目を情報保有装置で保持している場合であるのに対して、第２の実施形態は、同期に必要な項目を情報保有装置が情報連携装置に問い合わせる場合である。 Next, a distributed information synchronization system according to the second embodiment of the present invention will be described. The first embodiment is a case where the information holding device holds the items necessary for synchronization, whereas the second embodiment is configured so that the information holding device stores the items necessary for synchronization in the information cooperation device. This is a case of inquiring.

図８は、本発明の第２の実施形態に係る分散情報同期システムのブロック図である。図８に示す分散情報同期システムは、情報保有装置１０ａ、１０ｂ、１０ｃと、情報連携装置３０とにより構成される。情報保有装置１０ａ、１０ｂ、１０ｃと、情報連携装置３０は、通信ネットワークを介して接続されている。なお、図８においては、説明を簡単にするために、情報保有装置１０ａ、１０ｂ、１０ｃのみを示しているが、本発明はこれに限定されず、３つ以上の情報保有装置を備えることがあるものとする。 FIG. 8 is a block diagram of a distributed information synchronization system according to the second embodiment of the present invention. The distributed information synchronization system illustrated in FIG. 8 includes information holding devices 10 a, 10 b, and 10 c and an information cooperation device 30. The information holding apparatuses 10a, 10b, and 10c and the information cooperation apparatus 30 are connected via a communication network. In FIG. 8, only the information holding devices 10a, 10b, and 10c are shown for simplicity of explanation, but the present invention is not limited to this and may include three or more information holding devices. It shall be.

情報連携装置３０は、同期情報演算部３０１と同期情報送信部３０２と同期ポリシー情報３０３と同期情報受信部３０４とで構成される。同期ポリシー情報３０３は、同期項目対応情報と同期ルール情報からなる。情報連携装置３０は、同期ルールを管理し、ルールに従い情報演算を行い、演算した情報を対象の情報保有装置１０ａ、１０ｂ、１０ｃに送信する。 The information linkage apparatus 30 includes a synchronization information calculation unit 301, a synchronization information transmission unit 302, synchronization policy information 303, and a synchronization information reception unit 304. The synchronization policy information 303 includes synchronization item correspondence information and synchronization rule information. The information cooperation apparatus 30 manages the synchronization rule, performs information calculation according to the rule, and transmits the calculated information to the target information holding apparatuses 10a, 10b, and 10c.

同期情報受信部３０４は、同期情報送信部１０１ａと通信手段１ａで接続され、同期情報送信部１０１ｂと通信手段１ｂで接続され、同期情報送信部１０１ｃと通信手段１ｃで接続されている。 The synchronization information receiving unit 304 is connected to the synchronization information transmitting unit 101a through the communication unit 1a, connected to the synchronization information transmitting unit 101b through the communication unit 1b, and connected to the synchronization information transmitting unit 101c through the communication unit 1c.

同期情報送信部３０２は、同期処理部１０３ａと通信手段２ａで接続され、同期処理部１０３ｂと通信手段２ｂで接続され、同期処理部１０３ｃと通信手段２ｃで接続されている。 The synchronization information transmission unit 302 is connected to the synchronization processing unit 103a by the communication unit 2a, is connected to the synchronization processing unit 103b by the communication unit 2b, and is connected to the synchronization processing unit 103c and the communication unit 2c.

図９は、情報保有装置保有情報１０４ａのテーブル構成例を示す図であり、図１０は、情報保有装置保有情報１０４ｂのテーブル構成例を示す図であり、図１１は、情報保有装置保有情報１０４ｃのテーブル構成例を示す図である。 9 is a diagram showing a table configuration example of the information holding device possession information 104a, FIG. 10 is a diagram showing an example of a table configuration of the information holding device possession information 104b, and FIG. 11 is a diagram showing the information holding device possession information 104c. It is a figure which shows the example of a table structure.

図９〜１１に示すとおり、各情報保有装置でテーブル構造が異なっており、各情報保有装置は、テーブル構造が異なるデータベースで情報を管理する。 As shown in FIGS. 9 to 11, each information holding device has a different table structure, and each information holding device manages information in a database having a different table structure.

図１２および図１３は、情報連携装置３０のルール設定例を示す図である。図１２は、同期ポリシー情報３０３中の同期項目対応情報の例を示しており、図１３は、同期ポリシー情報３０３中の同期ルール情報の例を示している。情報連携装置３０は、同期する項目の対応情報と、どのような演算処理を行って各情報保有装置が保持するデータベース間の情報の同期をとるかという同期ルール情報とを管理する。 12 and 13 are diagrams illustrating an example of rule setting of the information cooperation apparatus 30. FIG. FIG. 12 shows an example of the synchronization item correspondence information in the synchronization policy information 303, and FIG. 13 shows an example of the synchronization rule information in the synchronization policy information 303. The information cooperation apparatus 30 manages correspondence information of items to be synchronized and synchronization rule information indicating what kind of arithmetic processing is performed to synchronize information between databases held by each information holding apparatus.

図１４は、情報保有装置１０ａの情報が変更された場合のシーケンス例を示す図である。なお、ここでは利用者姓（ａ＿ｌａｓｔ）と住民異動日（ａ＿ｃｈａｎｇｅ＿ｄａｙ）が変更されているものとする。また、情報保有装置１０ａの識別子をａとし、情報保有装置１０ｂの識別子をｂとし、情報保有装置１０ｃの識別子をｃとする。 FIG. 14 is a diagram illustrating a sequence example when the information of the information holding device 10a is changed. Here, it is assumed that the user surname (a_last) and the resident change date (a_change_day) have been changed. The identifier of the information holding device 10a is a, the identifier of the information holding device 10b is b, and the identifier of the information holding device 10c is c.

（Ａ）同期情報検知処理
情報保有装置１０ａの情報変更検知部１０２ａは、利用者の情報が変更されたことを検知し、情報保有装置１０ａの識別子（ａ）と、変更された項目（ａ＿ｌａｓｔ、ａ＿ｃｈａｎｇｅ＿ｄａｙ）を同期情報送信部１０１ａへ送信する。 (A) Synchronization information detection processing The information change detection unit 102a of the information holding device 10a detects that the user information has been changed, and the identifier (a) of the information holding device 10a and the changed item (a_last, a_change_day) is transmitted to the synchronization information transmitting unit 101a.

（Ｂ）同期情報送信処理
同期情報送信部１０１ａは、情報保有装置１０ａの識別子（ａ）と、変更された情報（ａ＿ｌａｓｔ、ａ＿ｃｈａｎｇｅ＿ｄａｙ）を情報連携装置３０の同期情報受信部３０４へ送信する。 (B) Synchronization Information Transmission Processing The synchronization information transmission unit 101a transmits the identifier (a) of the information holding device 10a and the changed information (a_last, a_change_day) to the synchronization information reception unit 304 of the information linkage device 30.

（Ｃ）同期項目情報送信処理
情報連携装置３０の同期情報受信部３０４は、受信した情報で同期ルール情報の更新内容を検索し、他の情報保有装置１０ｂ、１０ｃと同期するために必要な項目（ａ＿ｌａｓｔ、ａ＿ｆｉｒｓｔ、ａ＿ｃａｈｎｇｅ＿ｄａｙ）を抽出し、必要な項目を同期情報送信部１０１ａへ送信する。 (C) Synchronization item information transmission process The synchronization information receiving unit 304 of the information cooperation device 30 searches for the updated content of the synchronization rule information from the received information, and is an item necessary for synchronizing with the other information holding devices 10b and 10c. (A_last, a_first, a_change_day) are extracted, and necessary items are transmitted to the synchronization information transmitting unit 101a.

（Ｄ）同期情報送信処理
同期情報送信部１０１ａは、必要な項目を受信し、情報保有装置１０ａの識別子（ａ）と、同期に必要な情報（ａ＿ｌａｓｔ．佐々木、ａ＿ｆｉｒｓｔ．太郎、ａ＿ｃｈａｎｇｅ＿ｄａｙ．２０１２．０７．０７）を同期情報受信部３０４へ送信する。 (D) Synchronization Information Transmission Processing The synchronization information transmission unit 101a receives necessary items, and includes an identifier (a) of the information holding device 10a and information necessary for synchronization (a_last.Sasaki, a_first.Taro, a_change_day.2012. 07.07) is transmitted to the synchronization information receiving unit 304.

（Ｅ）同期情報受信処理
同期情報受信部３０４は、必要な情報を受信し、受信した情報を情報連携装置３０の同期情報演算部３０１へ送信する。 (E) Synchronization Information Reception Processing The synchronization information reception unit 304 receives necessary information and transmits the received information to the synchronization information calculation unit 301 of the information linkage apparatus 30.

（Ｆ）同期情報演算処理
情報連携装置３０の同期情報演算部３０１は、図１３に示す同期ルール情報に従って演算を行い、情報保有装置１０ａのａ＿ｌａｓｔが変更されているため、ルールＮｏ．１よりＯｐｅ１の演算で「佐々木太郎」（＝“佐々木”＋“ ”＋“太郎”）という結果を得て、ルールＮｏ．２より佐々木という結果を得て、情報保有装置１０ａのａ＿ｃｈａｎｇｅ＿ｄａｙが変更されているため、ルールＮｏ．ｍより２０１２．０７．０７という結果を得て、ルールＮｏ．ｎよりＯｐｅ３の演算で「平成２４．０７．０７」（西暦から和暦に変換）という結果を得て、演算結果を同期情報送信部３０２へ送信する。 (F) Synchronization Information Calculation Processing The synchronization information calculation unit 301 of the information cooperation device 30 performs calculation according to the synchronization rule information shown in FIG. 13 and the a_last of the information holding device 10a is changed. 1 to obtain the result “Taro Sasaki” (= “Sasaki” + “” + “Taro”) by the operation of Ope1. 2. Since the result of Sasaki is obtained from No. 2 and a_change_day of the information holding device 10a is changed, the rule No. m, a result of 2012.07.07 was obtained. The result of “Heisei 24.07.07” (converted from the Western calendar to the Japanese calendar) is obtained by the operation of Ope3 from n, and the calculation result is transmitted to the synchronization information transmitting unit 302.

（Ｇ）同期情報送信処理
同期情報送信部３０２は、演算結果を同期ルール情報に従い情報保有装置１０ｂの同期処理部１０３ｂに送信する。同様に、同期情報送信部３０２は、演算結果を同期ルール情報に従い情報保有装置１０ｃの同期処理部１０３ｃに送信する。 (G) Synchronization information transmission processing The synchronization information transmission unit 302 transmits the calculation result to the synchronization processing unit 103b of the information holding device 10b according to the synchronization rule information. Similarly, the synchronization information transmission unit 302 transmits the calculation result to the synchronization processing unit 103c of the information holding device 10c according to the synchronization rule information.

（Ｈ）同期処理
情報保有装置１０ｂの同期処理部１０３ｂは、受信した演算結果で情報保有装置保有情報１０４ｂを更新する。同様に、情報保有装置１０ｃの同期処理部１０３ｃは、受信した演算結果で情報保有装置保有情報１０４ｃを更新する。 (H) Synchronization processing The synchronization processing unit 103b of the information holding device 10b updates the information holding device holding information 104b with the received calculation result. Similarly, the synchronization processing unit 103c of the information holding device 10c updates the information holding device holding information 104c with the received calculation result.

上述したように、本発明によれば、情報保有装置と接続している情報連携装置に同期のルールを設定することで、任意の情報保有装置の情報が更新された場合に、情報連携装置が同期ルールに従って演算処理を行うため、テーブル構造（データフォーマット）が異なる他の情報保有装置との間で情報の同期処理を行うことが可能となる。 As described above, according to the present invention, when information of an arbitrary information holding device is updated by setting a synchronization rule in the information cooperation device connected to the information holding device, Since the arithmetic processing is performed according to the synchronization rule, it is possible to perform information synchronization processing with other information holding apparatuses having different table structures (data formats).

１０ａ、１０ｂ、１０ｃ情報保有装置
２０、３０情報連携装置
１０１ａ、１０１ｂ、１０１ｃ同期情報送信部
１０２ａ、１０２ｂ、１０２ｃ情報変更検知部
１０３ａ、１０３ｂ、１０３ｃ同期処理部
１０４ａ、１０４ｂ、１０４ｃ情報保有装置保有情報
２０１、３０１同期情報演算部
２０２、３０２同期情報送信部
２０３、３０３同期ポリシー情報
３０４同期情報受信部 10a, 10b, 10c Information holding device 20, 30 Information cooperation device 101a, 101b, 101c Synchronization information transmission unit 102a, 102b, 102c Information change detection unit 103a, 103b, 103c Synchronization processing unit 104a, 104b, 104c Information holding device holding information 201, 301 Synchronization information calculation unit 202, 302 Synchronization information transmission unit 203, 303 Synchronization policy information 304 Synchronization information reception unit

Claims

A plurality of information holding devices each holding a database having a different table structure, and synchronization rule information connected to the plurality of information holding devices via a network to synchronize information between the databases held by the information holding device Is a distributed information synchronization system composed of an information cooperation device that performs an arithmetic processing of information according to the synchronization rule information,
The information holding device is:
Means for detecting that the information in the database has been changed, and transmitting the changed information to the information cooperation device;
Means for extracting necessary accompanying items based on information necessary for synchronization received from the information cooperation device and transmitting synchronization information including the changed information and the necessary accompanying items to the information cooperation device And comprising
The information linkage apparatus
Means for extracting information necessary for synchronization based on the changed information received from the information holding device and transmitting the information to the information holding device;
Means for performing arithmetic processing for combining the changed information and the necessary accompanying items included in the synchronization information received from the information holding device;
In accordance with the synchronization rule information, comprising:
The other information holding device includes a means for updating information in the database based on synchronization information received from the information cooperation device and subjected to the arithmetic processing.

A plurality of information holding devices each holding a database having a different table structure, and synchronization rule information connected to the plurality of information holding devices via a network to synchronize information between the databases held by the information holding device A distributed information synchronization method of a distributed information synchronization system comprising an information cooperation apparatus that performs an arithmetic operation process of information according to the synchronization rule information,
The information holding device detects that the information in the database has been changed, and transmits the changed information to the information cooperation device;
Extracting the information necessary for synchronization based on the changed information received from the information holding device, and transmitting the information to the information holding device;
Based on the information necessary for synchronization, received from the information cooperation device, the information holding device extracts necessary accompanying items, and the synchronization information including the changed information and the necessary accompanying items is Transmitting to the information linkage apparatus;
The information cooperation device performing a calculation process for combining the changed information included in the synchronization information received from the information holding device and the necessary associated items;
The information linking device, according to the synchronization rule information, transmitting the synchronization information that has undergone arithmetic processing to another information holding device;
Updating the information in the database based on the synchronization information on which the arithmetic processing is performed, received by the other information holding device from the information cooperation device;
A distributed information synchronization method comprising: