JP2011076487A - 計算機、及びデータベース管理プログラム - Google Patents
計算機、及びデータベース管理プログラム Download PDFInfo
- Publication number
- JP2011076487A JP2011076487A JP2009228864A JP2009228864A JP2011076487A JP 2011076487 A JP2011076487 A JP 2011076487A JP 2009228864 A JP2009228864 A JP 2009228864A JP 2009228864 A JP2009228864 A JP 2009228864A JP 2011076487 A JP2011076487 A JP 2011076487A
- Authority
- JP
- Japan
- Prior art keywords
- node
- update
- database
- redo log
- information
- Prior art date
- Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
- Pending
Links
Images
Landscapes
- Information Retrieval, Db Structures And Fs Structures Therefor (AREA)
Abstract
【課題】共有ディスク装置を使用しない安価なハードウェア構成を前提として、単純な構成を有する多重化データベース制御システムを構築する。
【解決手段】ノード２は、自己が保有するデータベースの自己更新情報としての自ノード用ｒｅｄｏログ１２０と、自己が保有するデータベース以外の他の更新情報としての他ノード用ｒｅｄｏログ１３０と、を各データベース毎に分けて保有し、ノード２が自ノード用ｒｅｄｏログ１２０を更新する際に、他ノード用ｒｅｄｏログ１３０を参照することで、自己が保有するデータベースの更新と自己が保有する以外のデータベースの更新とで競合が発生しているか否かを判定することを特徴とする。
【選択図】図２
【解決手段】ノード２は、自己が保有するデータベースの自己更新情報としての自ノード用ｒｅｄｏログ１２０と、自己が保有するデータベース以外の他の更新情報としての他ノード用ｒｅｄｏログ１３０と、を各データベース毎に分けて保有し、ノード２が自ノード用ｒｅｄｏログ１２０を更新する際に、他ノード用ｒｅｄｏログ１３０を参照することで、自己が保有するデータベースの更新と自己が保有する以外のデータベースの更新とで競合が発生しているか否かを判定することを特徴とする。
【選択図】図２
Description
本発明は、多重化されたデータベースのうち少なくとも一つを備える計算機、及びデータベース管理プログラムに関する。
従来の多重化データベースにおいては、各ノードにデータそのものを格納するためのＤＢファイルと、更新履歴情報を逐次書き込むためのｒｅｄｏログとを持っている。
図１１（ａ）に示すように、多重化データベースは、データベースの可用性を向上するためにノードを２重化する。ノードの２重化を行う方法の一つに、分散トランザクションの機能を用いる方法がある。
図１１（ａ）に示すように、多重化データベースは、データベースの可用性を向上するためにノードを２重化する。ノードの２重化を行う方法の一つに、分散トランザクションの機能を用いる方法がある。
この方法では、更新を行う際に、クライアントから、両ノードに対して同一の内容の更新要求を行い、２フェーズコミット方式により、両ノード間のＤＢファイルの内容の整合を保障する。すなわち、この方法は、コミット要求時に、両ノードにコミット準備指示を行い、両ノードから準備完了応答を得られてから、両ノードに対してコミット指示を行う。なお、分散トランザクションの機能を用いる方法の詳細は、例えば、特許文献１に記載がある。
また、別の方法として、共有ディスクによる２重化の方法がある。図１１（ｂ）に示すように、ｒｅｄｏログとＤＢファイルとを共有ディスクに格納し、両ノードに接続することによって、データベースを２重化する。ｒｅｄｏログは、各ノード用に一つずつ用意されるが、ＤＢファイルは、物理的に同じものを共有する。なお、共有ディスクを用いる方法の詳細は、例えば、非特許文献１に記載がある。
この方法では、一つのディスク装置を共有してＤＢを構成しているため、片方のノードで実行された操作は、即時他ノードにも反映されている。
Barb Lundhild，Peter Sechser、"Oracle RAC 10g"、[online]、２００５年９月、Oracle Corporation、[平成２１年９月１６日検索]、インターネット<URL:http://otndnld.oracle.co.jp/products/database/oracle10g/clustering/pdf/TWP_RAC10g.pdf >
このように、分散トランザクションの機能を用いるデータベースの多重化方法は、更新操作に対する競合があれば、その時点で待ちが発生し、また、コミット動作中に障害が発生すると、自動的にロックを解除できなくなり、制御が複雑であるという問題がある。
また、共有ディスク装置を用いるデータベースの多重化方法では、共有ディスク装置が高価であり、両ノードを地理的に分散させた配置とすることができないという欠点がある。
また、共有ディスク装置を用いるデータベースの多重化方法では、共有ディスク装置が高価であり、両ノードを地理的に分散させた配置とすることができないという欠点がある。
本発明は前記問題に鑑みてなされたものであり、データベースを地理的に分散させた状態であっても、データベースの更新における競合を判定することができる、計算機、及びデータベース管理プログラムを提供することを目的とする。
前記目的を達成するために、本発明に係る計算機は、複数の同じ内容のデータベースに通信可能に接続されて多重化されたデータベースのうち少なくとも１つを備える計算機であって、自己が保有するデータベースの自己更新情報と、自己が保有するデータベース以外のデータベースの他の更新情報とを各データベース毎に分けて保有する記憶部と、前記自己更新情報を更新する際に、前記他の更新情報を参照することで、前記多重化されたデータベースの更新における競合を判定する競合判定部と、を備えることを特徴とする。
前記目的を達成するために、本発明に係るデータベース管理プログラムは、複数の同じ内容のデータベースに通信可能に接続されて多重化されたデータベースのうち少なくとも１つを備える計算機の制御装置に実行させるデータベース管理プログラムであって、前記自己の計算機が保有するデータベースの自己更新情報と、前記自己が保有するデータベース以外のデータベースの他の更新情報とを各データベース毎に分けて記憶部に保有させる機能と、前記自己情報を更新する際に、前記他の更新情報を参照することで、前記多重化されたデータベースの更新における競合を判定する機能と、を前記制御装置に実現させることを特徴とする。
本発明によれば、データベースを地理的に分散させた状態であっても、データベースの更新における競合を判定することができる。このため、共有ディスク装置を使用しない安価なハードウェア構成を前提として、分散トランザクション方式によるデータベース制御システムよりも単純な構成にすることができる。
≪第１実施形態に係るデータベース制御システムの構成≫
＜概要＞
図１は、第１実施形態に係るデータベース制御システムの構成図である。
データベース制御システム１は、ノード２Ａ，２Ｂ（以下、まとめてノード２と呼ぶときがある），クライアント８Ａ，８Ｂ，・・８Ｘ（以下、まとめてクライアント８と呼ぶときがある），及びネットワーク９を備えて構成される。データベース制御システム１は、クライアント８がネットワーク９を介してノード２が備える記憶装置２００Ａ，２００Ｂ（以下、まとめて記憶装置２００と呼ぶときがある）内に記憶されているデータベース（ＤＢ）２２０Ａ，２２０Ｂ（以下、まとめてデータベース（ＤＢ）２２０と呼ぶときがある）を更新する。データベース２２０の更新は、制御装置１００に記憶されるｒｅｄｏログ１２０，１３０（図２参照）を使って行われる。データベース２２０の更新処理についての詳細は後述する。
＜概要＞
図１は、第１実施形態に係るデータベース制御システムの構成図である。
データベース制御システム１は、ノード２Ａ，２Ｂ（以下、まとめてノード２と呼ぶときがある），クライアント８Ａ，８Ｂ，・・８Ｘ（以下、まとめてクライアント８と呼ぶときがある），及びネットワーク９を備えて構成される。データベース制御システム１は、クライアント８がネットワーク９を介してノード２が備える記憶装置２００Ａ，２００Ｂ（以下、まとめて記憶装置２００と呼ぶときがある）内に記憶されているデータベース（ＤＢ）２２０Ａ，２２０Ｂ（以下、まとめてデータベース（ＤＢ）２２０と呼ぶときがある）を更新する。データベース２２０の更新は、制御装置１００に記憶されるｒｅｄｏログ１２０，１３０（図２参照）を使って行われる。データベース２２０の更新処理についての詳細は後述する。
ここで、データベース２２０Ａ，及びデータベース２２０Ｂは同じ内容である。データベース制御システム１では、データベース２２０の更新に際し、クライアント８はノード２Ａ，又はノード２Ｂのどちらかにアクセスし、一方のデータベース２２０Ａ，又はデータベース２２０Ｂを更新する。更新したデータベース２２０を備える一方のノード２は、他方のノード２に更新情報を送信し、更新情報を受信した他方のノード２は、受信した更新情報を基に自己のデータベース２２０を更新する。このように、第１実施形態に係るデータベース制御システム１では、ノード２が相互に自己のデータベース２２０の更新情報を送信しあうことで、データベース２２０の内容の同一性を図っている。
図１に示すデータベース制御システム１は、データベース２２０を２重化する構成としているが、より多数のノード２を接続してデータベース２２０を３重，４重又はそれ以上の多重に構成してもよい。その場合、更新したデータベース２２０を備えるノード２は、多重化されたデータベース２２０を備えるすべてのノード２に対して、自己のデータベース２２０の更新情報を送信することになる。
また、データベース制御システム１は、ノード２Ａをあるローカルネットワークに接続し、ノード２Ｂをノード２Ａが属するローカルネットワークとは異なるローカルネットワークに接続し、それぞれのローカルネットワークをグローバルネットワークに接続するようにしてもよい。このような構成にすれば、ノード２を地理的に離した場所に設置することが可能となる。
以下、データベース制御システム１の各構成装置について説明する。
以下、データベース制御システム１の各構成装置について説明する。
＜ノード＞
ノード２は、ネットワークに接続され、データベースを備えるディスク装置である。例えば、３層アーキテクチャのクライアントサーバシステムにおけるデータアクセス層の処理を行うサーバ，集中処理システムにおけるホストコンピュータ等を含む広い概念である。
ノード２の構成は、装置の種類によって異なるが、クライアントサーバシステムにおけるサーバの場合には、例えば、制御装置１００，記憶装置２００，入力装置３，表示装置４，通信装置５，タイマ６で構成される。
ノード２は、ネットワークに接続され、データベースを備えるディスク装置である。例えば、３層アーキテクチャのクライアントサーバシステムにおけるデータアクセス層の処理を行うサーバ，集中処理システムにおけるホストコンピュータ等を含む広い概念である。
ノード２の構成は、装置の種類によって異なるが、クライアントサーバシステムにおけるサーバの場合には、例えば、制御装置１００，記憶装置２００，入力装置３，表示装置４，通信装置５，タイマ６で構成される。
（制御装置）
制御装置１００は、ＣＰＵ，メモリ（記憶部），及びこれらの周辺回路等（いずれも図示せず）から構成される。制御装置１００は、記憶装置２００に記憶されるＤＢＭＳ（DataBase Management System：データベース管理システム（データベース管理プログラム））２１０，及びＯＳ（Operating System）２３０をメモリにロードし実行することで、様々な機能を実現する。制御装置１００が備える機能については後記する。
制御装置１００は、ＣＰＵ，メモリ（記憶部），及びこれらの周辺回路等（いずれも図示せず）から構成される。制御装置１００は、記憶装置２００に記憶されるＤＢＭＳ（DataBase Management System：データベース管理システム（データベース管理プログラム））２１０，及びＯＳ（Operating System）２３０をメモリにロードし実行することで、様々な機能を実現する。制御装置１００が備える機能については後記する。
（記憶装置）
記憶装置２００は、ＨＤＤ（Hard Disk Drive）等で構成され、ＤＢＭＳ２１０，ＤＢ２２０，及びＯＳ２３０を記憶する。ＤＢＭＳ２１０は、データベースとして蓄えた情報を制御し、活用するためのソフトウェアである。ＤＢ２２０は、ＤＢＭＳ２１０の管理下で記憶装置２００に記憶されているデータである。ＯＳ２３０は、ノード２のコンピュータシステムを管理し、基本的なユーザ操作環境を提供するソフトウェアである。
ＤＢ２２０は、複数のファイルにより構成されている。ＤＢ２２０を構成するファイルについては後記する。
記憶装置２００は、ＨＤＤ（Hard Disk Drive）等で構成され、ＤＢＭＳ２１０，ＤＢ２２０，及びＯＳ２３０を記憶する。ＤＢＭＳ２１０は、データベースとして蓄えた情報を制御し、活用するためのソフトウェアである。ＤＢ２２０は、ＤＢＭＳ２１０の管理下で記憶装置２００に記憶されているデータである。ＯＳ２３０は、ノード２のコンピュータシステムを管理し、基本的なユーザ操作環境を提供するソフトウェアである。
ＤＢ２２０は、複数のファイルにより構成されている。ＤＢ２２０を構成するファイルについては後記する。
（入力装置，表示装置，通信装置，タイマ）
入力装置３は、キーボード，マウス等の操作入力用デバイスを含み、ノード２の操作者の入力操作を受け入れて、制御装置１００に対して出力する。
表示装置４は、ＬＣＤ，ＣＲＴ等であって、制御装置１００から渡される出力画像等を表示する。
通信装置５は、ＬＡＮ用のアダプタ装置，ＩＳＤＮ通信回線用のＴＡ，又はモデム等であって、制御装置１００の指示に従って動作し、ネットワーク９を介してノード２又はクライアント８とデータの送受信を行う。
タイマ６は、ノード２の時計であり、ＲＴＣ（Real Time Clock）等で構成される。タイマ６は、制御装置１００に時刻をデータとして提供する。
入力装置３は、キーボード，マウス等の操作入力用デバイスを含み、ノード２の操作者の入力操作を受け入れて、制御装置１００に対して出力する。
表示装置４は、ＬＣＤ，ＣＲＴ等であって、制御装置１００から渡される出力画像等を表示する。
通信装置５は、ＬＡＮ用のアダプタ装置，ＩＳＤＮ通信回線用のＴＡ，又はモデム等であって、制御装置１００の指示に従って動作し、ネットワーク９を介してノード２又はクライアント８とデータの送受信を行う。
タイマ６は、ノード２の時計であり、ＲＴＣ（Real Time Clock）等で構成される。タイマ６は、制御装置１００に時刻をデータとして提供する。
＜クライアント＞
クライアント８は、ネットワーク９を介してノード２が備えるＤＢ２２０の更新を要求する装置である。クライアント８は、ＰＣ（Personal Computer），携帯端末等で構成される。
クライアント８は、ネットワーク９を介してノード２が備えるＤＢ２２０の更新を要求する装置である。クライアント８は、ＰＣ（Personal Computer），携帯端末等で構成される。
＜ネットワーク＞
ネットワーク９は、ＬＡＮ（Local Area Network），ＷＡＮ（Wide Area Network）等であり、有線，無線のどちらか一方，又は両方で構成され、データ通信を実現する。
有線の例としては、光ファイバ，一般電話回線，専用線等が挙げられ、無線の例としては、赤外線等の電波が挙げられる。
ネットワーク９は、ＬＡＮ（Local Area Network），ＷＡＮ（Wide Area Network）等であり、有線，無線のどちらか一方，又は両方で構成され、データ通信を実現する。
有線の例としては、光ファイバ，一般電話回線，専用線等が挙げられ、無線の例としては、赤外線等の電波が挙げられる。
≪第１実施形態に係るデータベース制御システムを構成するノードの機能及び使用するフォーマット≫
＜ノードが備える機能＞
（概要）
図２は、第１実施形態に係るデータベース制御システムを構成するノードの機能構成図である。図２では、各機能を「○○部」と記載している。
ノード２は、第１実施形態に係るデータベース制御システム１を実現するために、図２に示す機能を有する。図２に記載される各部１１０，１１１，１１２，１１３，１１４は、ＤＢＭＳ２１０をメモリにロードし、ＣＰＵにより実行されることで実現される。通信部１４０は、ＯＳ２３０をメモリにロードし、ＣＰＵにより実行されることで実現される。また、ログ１２０，１３０はメモリ上に領域として確保される。
図２には、説明の便宜上、第１実施形態に係るデータベース制御システム１を説明するのに必要な機能以外の機能を図示していない。例えば、入力装置３，表示装置４，及びタイマ６を管理する機能等は図示していない。
＜ノードが備える機能＞
（概要）
図２は、第１実施形態に係るデータベース制御システムを構成するノードの機能構成図である。図２では、各機能を「○○部」と記載している。
ノード２は、第１実施形態に係るデータベース制御システム１を実現するために、図２に示す機能を有する。図２に記載される各部１１０，１１１，１１２，１１３，１１４は、ＤＢＭＳ２１０をメモリにロードし、ＣＰＵにより実行されることで実現される。通信部１４０は、ＯＳ２３０をメモリにロードし、ＣＰＵにより実行されることで実現される。また、ログ１２０，１３０はメモリ上に領域として確保される。
図２には、説明の便宜上、第１実施形態に係るデータベース制御システム１を説明するのに必要な機能以外の機能を図示していない。例えば、入力装置３，表示装置４，及びタイマ６を管理する機能等は図示していない。
（データベース（ＤＢ））
ＤＢ２２０は、ｒｅｄｏログファイル２２１，制御ファイル２２２，及びデータファイル２２３の３つのファイルで構成される。
ｒｅｄｏログファイル２２１は、データファイル２２３の更新情報を記憶しておくファイルである。制御ファイル２２２は、ｒｅｄｏログファイル２２１やデータファイル２２３のファイル名と保存場所を記録しておくファイルである。データファイル２２３は、実際のデータが入っているファイルである。
ＤＢ２２０は、ｒｅｄｏログファイル２２１，制御ファイル２２２，及びデータファイル２２３の３つのファイルで構成される。
ｒｅｄｏログファイル２２１は、データファイル２２３の更新情報を記憶しておくファイルである。制御ファイル２２２は、ｒｅｄｏログファイル２２１やデータファイル２２３のファイル名と保存場所を記録しておくファイルである。データファイル２２３は、実際のデータが入っているファイルである。
（ｒｅｄｏログ）
更新情報としてのｒｅｄｏログ１２０，１３０は、ＤＢ２２０の変更履歴データであり、その構成を図３に示す。ｒｅｄｏログ１２０，１３０の１エントリは、タイムスタンプ欄１２１，１３１、トランザクション番号欄１２２，１３２、ＤＢ操作コード欄１２３，１３３、ＤＢ操作アドレス欄１２４，１３４、ＤＢ操作パラメタ欄１２５，１３５で構成される。
ｒｅｄｏログ１２０，１３０は、ＤＢ２２０についての処理が行われるたびに、エントリが追加されていく。
なお、図２は、ノード２が２重化された場合の構成であり、仮にノード２が３重化，４重化された場合、各ノード２が備えるｒｅｄｏログの数は、ノード２の数分になり、３つ，４つとなる。
更新情報としてのｒｅｄｏログ１２０，１３０は、ＤＢ２２０の変更履歴データであり、その構成を図３に示す。ｒｅｄｏログ１２０，１３０の１エントリは、タイムスタンプ欄１２１，１３１、トランザクション番号欄１２２，１３２、ＤＢ操作コード欄１２３，１３３、ＤＢ操作アドレス欄１２４，１３４、ＤＢ操作パラメタ欄１２５，１３５で構成される。
ｒｅｄｏログ１２０，１３０は、ＤＢ２２０についての処理が行われるたびに、エントリが追加されていく。
なお、図２は、ノード２が２重化された場合の構成であり、仮にノード２が３重化，４重化された場合、各ノード２が備えるｒｅｄｏログの数は、ノード２の数分になり、３つ，４つとなる。
（ｒｅｄｏログ更新部）
図２に示す、ｒｅｄｏログ更新部１１１は、基本的にはｒｅｄｏログ１２０，１３０を更新する機能である。
以下、ｒｅｄｏログ更新部１１１の機能を自己のノード２でトランザクションが発生した場合と、他のノード２でトランザクションが発生した場合とに分けて説明する。
（１）自己のノードでトランザクションが発生した場合
ｒｅｄｏログ更新部１１１は、トランザクション（以下、「Ｔｘ」と称す場合がある）の開始時，ＤＢ２２０の更新操作（ｕｐｄａｔｅ，ｄｅｌｅｔｅ，ｉｎｓｅｒｔ）実行時，及びｃｏｍｍｉｔ（結果確定）実行時に、自ノード用ｒｅｄｏログ１２０にエントリを１行追加する。具体的には、以下の（ａ）〜（ｃ）の内容を設定したエントリを１行追加する。
図２に示す、ｒｅｄｏログ更新部１１１は、基本的にはｒｅｄｏログ１２０，１３０を更新する機能である。
以下、ｒｅｄｏログ更新部１１１の機能を自己のノード２でトランザクションが発生した場合と、他のノード２でトランザクションが発生した場合とに分けて説明する。
（１）自己のノードでトランザクションが発生した場合
ｒｅｄｏログ更新部１１１は、トランザクション（以下、「Ｔｘ」と称す場合がある）の開始時，ＤＢ２２０の更新操作（ｕｐｄａｔｅ，ｄｅｌｅｔｅ，ｉｎｓｅｒｔ）実行時，及びｃｏｍｍｉｔ（結果確定）実行時に、自ノード用ｒｅｄｏログ１２０にエントリを１行追加する。具体的には、以下の（ａ）〜（ｃ）の内容を設定したエントリを１行追加する。
（ａ）Ｔｘ開始時
ｒｅｄｏログ更新部１１１は、自ノード用ｒｅｄｏログ１２０のタイムスタンプ欄１２１に「時刻」を設定し、トランザクション番号欄１２２に「任意のＴｘ番号」を設定する。
（ｂ）ＤＢの更新操作実行時
ｒｅｄｏログ更新部１１１は、自ノード用ｒｅｄｏログ１２０のタイムスタンプ欄１２１に「時刻」を設定し、トランザクション番号欄１２２に「Ｔｘ開始時に設定したＴｘ番号」を設定し、ＤＢ操作コード欄１２３に「ｕｐｄａｔｅ」，「ｄｅｌｅｔｅ」，「ｉｎｓｅｒｔ」のうちのいずれかを設定し、ＤＢ操作アドレス欄１２４に「更新対象レコードのアドレス」を設定し、ＤＢ操作パラメタ欄１２５に「ＤＢの更新内容」を設定する。
ＤＢ操作コード欄１２３に「ｕｐｄａｔｅ」，「ｄｅｌｅｔｅ」，「ｉｎｓｅｒｔ」のうちのいずれかを設定するかは、更新対象レコードを更新するのか、削除するのか、それとも新たにレコードを追加するのかにより決定される。
ｒｅｄｏログ更新部１１１は、自ノード用ｒｅｄｏログ１２０のタイムスタンプ欄１２１に「時刻」を設定し、トランザクション番号欄１２２に「任意のＴｘ番号」を設定する。
（ｂ）ＤＢの更新操作実行時
ｒｅｄｏログ更新部１１１は、自ノード用ｒｅｄｏログ１２０のタイムスタンプ欄１２１に「時刻」を設定し、トランザクション番号欄１２２に「Ｔｘ開始時に設定したＴｘ番号」を設定し、ＤＢ操作コード欄１２３に「ｕｐｄａｔｅ」，「ｄｅｌｅｔｅ」，「ｉｎｓｅｒｔ」のうちのいずれかを設定し、ＤＢ操作アドレス欄１２４に「更新対象レコードのアドレス」を設定し、ＤＢ操作パラメタ欄１２５に「ＤＢの更新内容」を設定する。
ＤＢ操作コード欄１２３に「ｕｐｄａｔｅ」，「ｄｅｌｅｔｅ」，「ｉｎｓｅｒｔ」のうちのいずれかを設定するかは、更新対象レコードを更新するのか、削除するのか、それとも新たにレコードを追加するのかにより決定される。
（ｃ）ｃｏｍｍｉｔ（結果確定）実行時
ｒｅｄｏログ更新部１１１は、自ノード用ｒｅｄｏログ１２０のタイムスタンプ欄１２１に「時刻」を設定し、トランザクション番号欄１２２に「Ｔｘ開始時に設定したＴｘ番号」を設定し、ＤＢ操作コード欄１２３に「ｃｏｍｍｉｔ」又は「ｒｏｌｌｂａｃｋ」を設定する。
ＤＢ操作コード欄１２３に「ｃｏｍｍｉｔ」，「ｒｏｌｌｂａｃｋ」のどちらを設定するかは、後述する更新対象競合判定部１１２（図２参照）で更新対象レコードに競合がないと判定された場合は「ｃｏｍｍｉｔ」を設定し、更新対象レコードに競合があると判定された場合は「ｒｏｌｌｂａｃｋ」を設定する。
ｒｅｄｏログ更新部１１１は、自ノード用ｒｅｄｏログ１２０のタイムスタンプ欄１２１に「時刻」を設定し、トランザクション番号欄１２２に「Ｔｘ開始時に設定したＴｘ番号」を設定し、ＤＢ操作コード欄１２３に「ｃｏｍｍｉｔ」又は「ｒｏｌｌｂａｃｋ」を設定する。
ＤＢ操作コード欄１２３に「ｃｏｍｍｉｔ」，「ｒｏｌｌｂａｃｋ」のどちらを設定するかは、後述する更新対象競合判定部１１２（図２参照）で更新対象レコードに競合がないと判定された場合は「ｃｏｍｍｉｔ」を設定し、更新対象レコードに競合があると判定された場合は「ｒｏｌｌｂａｃｋ」を設定する。
また、ｒｅｄｏログ更新部１１１は、自ノード用ｒｅｄｏログ１２０にエントリを追加するたびに、図４に示すｒｅｄｏログ情報３００を作成する。すなわち、ｒｅｄｏログ更新部１１１は、（ａ）Ｔｘ開始時，（ｂ）ＤＢの更新操作実行時，（ｃ）ｃｏｍｍｉｔ実行時のすべてのタイミングでｒｅｄｏログ情報３００を作成する。ｒｅｄｏログ情報３００の構成は、ｒｅｄｏログ１２０，１３０の１エントリの構成と同じである。ｒｅｄｏログ更新部１１１は、ｒｅｄｏログ情報３００の各欄に、自ノード用ｒｅｄｏログ１２０の同一欄名に設定した内容と同じ内容を設定する。
ｒｅｄｏログ更新部１１１は、作成したｒｅｄｏログ情報３００を、他のノード２に対して送信するように通信部１４０に指示する。通信部１４０（図２参照）は、ｒｅｄｏログ情報３００を、ＴＣＰ（Transmission Control Protocol），ＩＰ（Internet Protocol）等の通信規約に従ってパケット化し、通信装置５（図１参照）を介して他のノード２に送信する。
ｒｅｄｏログ更新部１１１は、作成したｒｅｄｏログ情報３００を、他のノード２に対して送信するように通信部１４０に指示する。通信部１４０（図２参照）は、ｒｅｄｏログ情報３００を、ＴＣＰ（Transmission Control Protocol），ＩＰ（Internet Protocol）等の通信規約に従ってパケット化し、通信装置５（図１参照）を介して他のノード２に送信する。
（２）他のノードでトランザクションが発生した場合
ｒｅｄｏログ更新部１１１は、他のノード２から受信したｒｅｄｏログ情報３００を基に、他ノード用ｒｅｄｏログ１３０にエントリを追加する。具体的には、ｒｅｄｏログ更新部１１１は、他ノード用ｒｅｄｏログ１３０の各欄に、ｒｅｄｏログ情報３００の同一欄名に格納されている内容と同じ内容を設定し、エントリを追加する。これにより、一方のノード２の自ノード用ｒｅｄｏログ１２０の内容と、他方のノード２の他ノード用ｒｅｄｏログ１３０の内容は一致される。
ｒｅｄｏログ更新部１１１は、他のノード２から受信したｒｅｄｏログ情報３００を基に、他ノード用ｒｅｄｏログ１３０にエントリを追加する。具体的には、ｒｅｄｏログ更新部１１１は、他ノード用ｒｅｄｏログ１３０の各欄に、ｒｅｄｏログ情報３００の同一欄名に格納されている内容と同じ内容を設定し、エントリを追加する。これにより、一方のノード２の自ノード用ｒｅｄｏログ１２０の内容と、他方のノード２の他ノード用ｒｅｄｏログ１３０の内容は一致される。
（更新対象競合判定部）
図２に示す更新対象競合判定部１１２は、自己のノード２でトランザクションが発生し、かつ、ｃｏｍｍｉｔを行うときに、自己のノード２と他のノード２とで更新対象レコードが競合したか否かの判定を行う。更新対象競合判定部１１２は、更新対象レコードの競合の判定を、トランザクションの開始からｃｏｍｍｉｔを行うときまでの時間帯について、他ノード用ｒｅｄｏログ１３０の内容を調べることにより行う。
具体的には、更新対象競合判定部１１２は、自己のノード２でトランザクションが開始してからｃｏｍｍｉｔを行うときまでの時間帯において、自ノード用ｒｅｄｏログ１２０に追加したエントリのＤＢ操作アドレス欄１２４に設定したアドレスと、他ノード用ｒｅｄｏログ１３０に追加したエントリのＤＢ操作アドレス欄１３４に設定したアドレスとが一致し、かつ、他ノード用ｒｅｄｏログ１３０に、ＤＢ操作コード欄１３３に「ｃｏｍｍｉｔ」が設定されたエントリが追加されている場合に更新対象レコードが競合したと判定する。
図２に示す更新対象競合判定部１１２は、自己のノード２でトランザクションが発生し、かつ、ｃｏｍｍｉｔを行うときに、自己のノード２と他のノード２とで更新対象レコードが競合したか否かの判定を行う。更新対象競合判定部１１２は、更新対象レコードの競合の判定を、トランザクションの開始からｃｏｍｍｉｔを行うときまでの時間帯について、他ノード用ｒｅｄｏログ１３０の内容を調べることにより行う。
具体的には、更新対象競合判定部１１２は、自己のノード２でトランザクションが開始してからｃｏｍｍｉｔを行うときまでの時間帯において、自ノード用ｒｅｄｏログ１２０に追加したエントリのＤＢ操作アドレス欄１２４に設定したアドレスと、他ノード用ｒｅｄｏログ１３０に追加したエントリのＤＢ操作アドレス欄１３４に設定したアドレスとが一致し、かつ、他ノード用ｒｅｄｏログ１３０に、ＤＢ操作コード欄１３３に「ｃｏｍｍｉｔ」が設定されたエントリが追加されている場合に更新対象レコードが競合したと判定する。
仮に、自ノード用ｒｅｄｏログ１２０のＤＢ操作アドレス欄１２４と、他ノード用ｒｅｄｏログ１３０のＤＢ操作アドレス欄１３４とに設定したアドレスが一致しても、他ノード用ｒｅｄｏログ１３０に、ＤＢ操作コード欄１３３に「ｃｏｍｍｉｔ」が設定されたエントリが追加されていなければ更新対象レコードが競合したと判定しない。この場合には、他のノード２の更新対象競合判定部１１２が、更新対象レコードが競合したと判定することになる。すなわち、更新対象レコードが競合した場合に、先にｃｏｍｍｉｔが行われた更新処理を優先する。
（ｒｅｄｏログファイル更新部）
図２に示すｒｅｄｏログファイル更新部１１３は、自ノード用ｒｅｄｏログ１２０に、ＤＢ操作コード欄１２３に「ｃｏｍｍｉｔ」が設定されたエントリが追加されたときに、自ノード用ｒｅｄｏログ１２０の内容をｒｅｄｏログファイル２２１に書き出す。
また、ｒｅｄｏログファイル更新部１１３は、他ノード用ｒｅｄｏログ１３０に、ＤＢ操作コード欄１３３に「ｃｏｍｍｉｔ」が設定されたエントリが追加さたときに、他ノード用ｒｅｄｏログ１３０の内容をｒｅｄｏログファイル２２１に書き出す。
図２に示すｒｅｄｏログファイル更新部１１３は、自ノード用ｒｅｄｏログ１２０に、ＤＢ操作コード欄１２３に「ｃｏｍｍｉｔ」が設定されたエントリが追加されたときに、自ノード用ｒｅｄｏログ１２０の内容をｒｅｄｏログファイル２２１に書き出す。
また、ｒｅｄｏログファイル更新部１１３は、他ノード用ｒｅｄｏログ１３０に、ＤＢ操作コード欄１３３に「ｃｏｍｍｉｔ」が設定されたエントリが追加さたときに、他ノード用ｒｅｄｏログ１３０の内容をｒｅｄｏログファイル２２１に書き出す。
（データファイル更新部）
図２に示すデータファイル更新部１１４は、任意のタイミングでｒｅｄｏログファイル２２１の内容をデータファイル２２３に更新する。
図２に示すデータファイル更新部１１４は、任意のタイミングでｒｅｄｏログファイル２２１の内容をデータファイル２２３に更新する。
≪第１実施形態に係るデータベース制御システムのデータベース更新動作≫
以下、図５から図９を参照して第１実施形態に係るデータベース制御システムのデータベース更新動作について説明する。
図５は、第１実施形態に係るデータベース制御システムのデータベース更新動作（更新データの競合なし）の説明図である。
図５は、ノード２ＡでＴｘＡが、ノード２ＢでＴｘＢがほぼ同時に実行される場合の処理の流れを示している。ＴｘＡは、アドレス＃０００１のレコードを更新し、ＴｘＢは、アドレス＃０００２のレコードを更新するので、ＴｘＡとＴｘＢとでは更新対象レコードが競合しない。他ノード用ｒｅｄｏログ１３０上の白抜き矢印は、更新対象競合判定部１１２が競合判定を行う時間帯を表している。
以下、図５から図９を参照して第１実施形態に係るデータベース制御システムのデータベース更新動作について説明する。
図５は、第１実施形態に係るデータベース制御システムのデータベース更新動作（更新データの競合なし）の説明図である。
図５は、ノード２ＡでＴｘＡが、ノード２ＢでＴｘＢがほぼ同時に実行される場合の処理の流れを示している。ＴｘＡは、アドレス＃０００１のレコードを更新し、ＴｘＢは、アドレス＃０００２のレコードを更新するので、ＴｘＡとＴｘＢとでは更新対象レコードが競合しない。他ノード用ｒｅｄｏログ１３０上の白抜き矢印は、更新対象競合判定部１１２が競合判定を行う時間帯を表している。
なお、説明に際して、ｒｅｄｏログ１２０，１３０及びｒｅｄｏログ情報３００のデータの設定の記載については、一部省略する。
また、各ステップ後の、ノード２Ａの自ノード用ｒｅｄｏログ１２０Ａ，及びノード２Ｂの他ノード用ｒｅｄｏログ１３０Ｂの状態、さらに、ノード２Ｂの自ノード用ｒｅｄｏログ１２０Ｂ，及びノード２Ａの他ノード用ｒｅｄｏログ１３０Ａの状態を図６Ａ（ａ）〜（ｃ），及び図６Ｂ（ａ）〜（ｃ）に示す。
また、各ステップ後の、ノード２Ａの自ノード用ｒｅｄｏログ１２０Ａ，及びノード２Ｂの他ノード用ｒｅｄｏログ１３０Ｂの状態、さらに、ノード２Ｂの自ノード用ｒｅｄｏログ１２０Ｂ，及びノード２Ａの他ノード用ｒｅｄｏログ１３０Ａの状態を図６Ａ（ａ）〜（ｃ），及び図６Ｂ（ａ）〜（ｃ）に示す。
（ステップＳ００１Ａ）
ノード２Ａのｒｅｄｏログ更新部１１１Ａは、ＴｘＡの開始とともに、トランザクション番号欄１２２Ａに「任意のＴｘ番号」を設定したエントリを自ノード用ｒｅｄｏログ１２０Ａに１行追加する。また、ｒｅｄｏログ更新部１１１Ａは、追加したエントリと同じ内容でｒｅｄｏログ情報３００を作成し、このｒｅｄｏログ情報３００をノード２Ｂに送信する。
ノード２Ｂのｒｅｄｏログ更新部１１１Ｂは、受信したｒｅｄｏログ情報３００を基に、他ノード用ｒｅｄｏログ１３０Ｂにエントリを１行追加する。
ノード２Ａのｒｅｄｏログ更新部１１１Ａは、ＴｘＡの開始とともに、トランザクション番号欄１２２Ａに「任意のＴｘ番号」を設定したエントリを自ノード用ｒｅｄｏログ１２０Ａに１行追加する。また、ｒｅｄｏログ更新部１１１Ａは、追加したエントリと同じ内容でｒｅｄｏログ情報３００を作成し、このｒｅｄｏログ情報３００をノード２Ｂに送信する。
ノード２Ｂのｒｅｄｏログ更新部１１１Ｂは、受信したｒｅｄｏログ情報３００を基に、他ノード用ｒｅｄｏログ１３０Ｂにエントリを１行追加する。
（ステップＳ００１Ｂ）
ノード２Ｂのｒｅｄｏログ更新部１１１Ｂは、ＴｘＢの開始とともに、トランザクション番号欄１２２Ｂに「任意のＴｘ番号」を設定したエントリを自ノード用ｒｅｄｏログ１２０Ｂに１行追加する。また、ｒｅｄｏログ更新部１１１Ｂは、追加したエントリと同じ内容でｒｅｄｏログ情報３００を作成し、このｒｅｄｏログ情報３００をノード２Ａに送信する。
ノード２Ａのｒｅｄｏログ更新部１１１Ａは、受信したｒｅｄｏログ情報３００を基に、他ノード用ｒｅｄｏログ１３０Ａにエントリを１行追加する。
ノード２Ｂのｒｅｄｏログ更新部１１１Ｂは、ＴｘＢの開始とともに、トランザクション番号欄１２２Ｂに「任意のＴｘ番号」を設定したエントリを自ノード用ｒｅｄｏログ１２０Ｂに１行追加する。また、ｒｅｄｏログ更新部１１１Ｂは、追加したエントリと同じ内容でｒｅｄｏログ情報３００を作成し、このｒｅｄｏログ情報３００をノード２Ａに送信する。
ノード２Ａのｒｅｄｏログ更新部１１１Ａは、受信したｒｅｄｏログ情報３００を基に、他ノード用ｒｅｄｏログ１３０Ａにエントリを１行追加する。
（ステップＳ００２Ａ）
ノード２Ａのｒｅｄｏログ更新部１１１Ａは、ＤＢ操作コード欄１２３Ａに「ｕｐｄａｔｅ」を設定し、ＤＢ操作アドレス欄１２４Ａに「０００１」を設定し、ＤＢ操作パラメタ欄１２５Ａに「ＡＡＡＡＡ」を設定したエントリを、自ノード用ｒｅｄｏログ１２０Ａに１行追加する。また、ｒｅｄｏログ更新部１１１Ａは、追加したエントリと同じ内容でｒｅｄｏログ情報３００を作成し、このｒｅｄｏログ情報３００をノード２Ｂに送信する。
ノード２Ｂのｒｅｄｏログ更新部１１１Ｂは、受信したｒｅｄｏログ情報３００を基に、他ノード用ｒｅｄｏログ１３０Ｂにエントリを１行追加する。
ノード２Ａのｒｅｄｏログ更新部１１１Ａは、ＤＢ操作コード欄１２３Ａに「ｕｐｄａｔｅ」を設定し、ＤＢ操作アドレス欄１２４Ａに「０００１」を設定し、ＤＢ操作パラメタ欄１２５Ａに「ＡＡＡＡＡ」を設定したエントリを、自ノード用ｒｅｄｏログ１２０Ａに１行追加する。また、ｒｅｄｏログ更新部１１１Ａは、追加したエントリと同じ内容でｒｅｄｏログ情報３００を作成し、このｒｅｄｏログ情報３００をノード２Ｂに送信する。
ノード２Ｂのｒｅｄｏログ更新部１１１Ｂは、受信したｒｅｄｏログ情報３００を基に、他ノード用ｒｅｄｏログ１３０Ｂにエントリを１行追加する。
（ステップＳ００２Ｂ）
ノード２Ｂのｒｅｄｏログ更新部１１１Ｂは、ＤＢ操作コード欄１２３Ｂに「ｕｐｄａｔｅ」を設定し、ＤＢ操作アドレス欄１２４Ｂに「０００２」を設定し、ＤＢ操作パラメタ欄１２５Ｂに「ＢＢＢＢＢ」を設定したエントリを、自ノード用ｒｅｄｏログ１２０Ｂに１行追加する。また、ｒｅｄｏログ更新部１１１Ｂは、追加したエントリと同じ内容でｒｅｄｏログ情報３００を作成し、このｒｅｄｏログ情報３００をノード２Ａに送信する。
ノード２Ａのｒｅｄｏログ更新部１１１Ａは、受信したｒｅｄｏログ情報３００を基に、他ノード用ｒｅｄｏログ１３０Ａにエントリを１行追加する。
ノード２Ｂのｒｅｄｏログ更新部１１１Ｂは、ＤＢ操作コード欄１２３Ｂに「ｕｐｄａｔｅ」を設定し、ＤＢ操作アドレス欄１２４Ｂに「０００２」を設定し、ＤＢ操作パラメタ欄１２５Ｂに「ＢＢＢＢＢ」を設定したエントリを、自ノード用ｒｅｄｏログ１２０Ｂに１行追加する。また、ｒｅｄｏログ更新部１１１Ｂは、追加したエントリと同じ内容でｒｅｄｏログ情報３００を作成し、このｒｅｄｏログ情報３００をノード２Ａに送信する。
ノード２Ａのｒｅｄｏログ更新部１１１Ａは、受信したｒｅｄｏログ情報３００を基に、他ノード用ｒｅｄｏログ１３０Ａにエントリを１行追加する。
（ステップＳ００３Ａ）
ノード２Ａの更新対象競合判定部１１２Ａは、ｃｏｍｍｉｔを行うときに、ノード２Ａとノード２Ｂとで更新対象レコードが競合したか否かの判定を行う。ここで、現時点の時刻は「20090101010101005」とする。
更新対象競合判定部１１２Ａは、自ノード用ｒｅｄｏログ１２０Ａのタイムスタンプ欄１２１Ａを参照することで、ＴｘＡの開始が「20090101010101001」であることを把握し、他ノード用ｒｅｄｏログ１３０Ａのタイムスタンプ欄１３１Ａの日時が「20090101010101001」から「20090101010101005」までの間のエントリで自ノード用ｒｅｄｏログ１２０ＡのＤＢ操作アドレス欄１２４Ａの値と他ノード用ｒｅｄｏログ１３０ＡのＤＢ操作アドレス欄１３４Ａの値が一致するエントリがあるか否か調べるが、一致するエントリはないと分かる。その為、更新対象競合判定部１１２Ａは、更新対象レコードの競合はないと判定する。
ノード２Ａの更新対象競合判定部１１２Ａは、ｃｏｍｍｉｔを行うときに、ノード２Ａとノード２Ｂとで更新対象レコードが競合したか否かの判定を行う。ここで、現時点の時刻は「20090101010101005」とする。
更新対象競合判定部１１２Ａは、自ノード用ｒｅｄｏログ１２０Ａのタイムスタンプ欄１２１Ａを参照することで、ＴｘＡの開始が「20090101010101001」であることを把握し、他ノード用ｒｅｄｏログ１３０Ａのタイムスタンプ欄１３１Ａの日時が「20090101010101001」から「20090101010101005」までの間のエントリで自ノード用ｒｅｄｏログ１２０ＡのＤＢ操作アドレス欄１２４Ａの値と他ノード用ｒｅｄｏログ１３０ＡのＤＢ操作アドレス欄１３４Ａの値が一致するエントリがあるか否か調べるが、一致するエントリはないと分かる。その為、更新対象競合判定部１１２Ａは、更新対象レコードの競合はないと判定する。
次に、ノード２Ａのｒｅｄｏログ更新部１１１Ａは、更新対象レコードの競合はないと判定されたので、ＤＢ操作コード欄１２３Ａに「ｃｏｍｍｉｔ」を設定したエントリを、自ノード用ｒｅｄｏログ１２０Ａに１行追加する。また、ｒｅｄｏログ更新部１１１Ａは、追加したエントリと同じ内容でｒｅｄｏログ情報３００を作成し、このｒｅｄｏログ情報３００をノード２Ｂに送信する。さらに、ｒｅｄｏログファイル更新部１１３Ａは、自ノード用ｒｅｄｏログ１２０Ａの内容をｒｅｄｏログファイル２２１Ａに書き出す。
ノード２Ｂのｒｅｄｏログ更新部１１１Ｂは、受信したｒｅｄｏログ情報３００を基に、他ノード用ｒｅｄｏログ１３０Ｂにエントリを１行追加する。さらに、ｒｅｄｏログファイル更新部１１３Ｂは、他ノード用ｒｅｄｏログ１３０Ｂの内容をｒｅｄｏログファイル２２１Ｂに書き出す。
ノード２Ｂのｒｅｄｏログ更新部１１１Ｂは、受信したｒｅｄｏログ情報３００を基に、他ノード用ｒｅｄｏログ１３０Ｂにエントリを１行追加する。さらに、ｒｅｄｏログファイル更新部１１３Ｂは、他ノード用ｒｅｄｏログ１３０Ｂの内容をｒｅｄｏログファイル２２１Ｂに書き出す。
（ステップＳ００３Ｂ）
ノード２Ｂの更新対象競合判定部１１２Ｂは、ｃｏｍｍｉｔを行うときに、ノード２Ａとノード２Ｂとで更新対象レコードが競合したか否かの判定を行う。ここで、現時点の時刻は「20090101010101006」とする。
更新対象競合判定部１１２Ｂは、自ノード用ｒｅｄｏログ１２０Ｂのタイムスタンプ欄１２１Ｂを参照することで、ＴｘＢの開始が「20090101010101002」であることを把握し、他ノード用ｒｅｄｏログ１３０Ｂのタイムスタンプ欄１３１Ｂの日時が「20090101010101002」から「20090101010101006」までの間のエントリで自ノード用ｒｅｄｏログ１２０ＢのＤＢ操作アドレス欄１２４Ｂの値と他ノード用ｒｅｄｏログ１３０ＢのＤＢ操作アドレス欄１３４Ｂの値が一致するエントリがあるか否か調べるが、一致するエントリはないと分かる。その為、更新対象競合判定部１１２Ｂは、更新対象レコードの競合はないと判定する。
ノード２Ｂの更新対象競合判定部１１２Ｂは、ｃｏｍｍｉｔを行うときに、ノード２Ａとノード２Ｂとで更新対象レコードが競合したか否かの判定を行う。ここで、現時点の時刻は「20090101010101006」とする。
更新対象競合判定部１１２Ｂは、自ノード用ｒｅｄｏログ１２０Ｂのタイムスタンプ欄１２１Ｂを参照することで、ＴｘＢの開始が「20090101010101002」であることを把握し、他ノード用ｒｅｄｏログ１３０Ｂのタイムスタンプ欄１３１Ｂの日時が「20090101010101002」から「20090101010101006」までの間のエントリで自ノード用ｒｅｄｏログ１２０ＢのＤＢ操作アドレス欄１２４Ｂの値と他ノード用ｒｅｄｏログ１３０ＢのＤＢ操作アドレス欄１３４Ｂの値が一致するエントリがあるか否か調べるが、一致するエントリはないと分かる。その為、更新対象競合判定部１１２Ｂは、更新対象レコードの競合はないと判定する。
次に、ノード２Ｂのｒｅｄｏログ更新部１１１Ｂは、更新対象レコードの競合はないと判定されたので、ＤＢ操作コード欄１２３Ｂに「ｃｏｍｍｉｔ」を設定したエントリを、自ノード用ｒｅｄｏログ１２０Ｂに１行追加する。また、ｒｅｄｏログ更新部１１１Ｂは、追加したエントリと同じ内容でｒｅｄｏログ情報３００を作成し、このｒｅｄｏログ情報３００をノード２Ａに送信する。さらに、ｒｅｄｏログファイル更新部１１３Ｂは、自ノード用ｒｅｄｏログ１２０Ｂの内容をｒｅｄｏログファイル２２１Ｂに書き出す。
ノード２Ａのｒｅｄｏログ更新部１１１Ａは、受信したｒｅｄｏログ情報３００を基に、他ノード用ｒｅｄｏログ１３０Ａにエントリを１行追加する。さらに、ｒｅｄｏログファイル更新部１１３Ａは、他ノード用ｒｅｄｏログ１３０Ａの内容をｒｅｄｏログファイル２２１Ａに書き出す。
以上で、第１実施形態に係るデータベース制御システム１のデータベース更新動作（更新データの競合なし）の説明を終了する。
ノード２Ａのｒｅｄｏログ更新部１１１Ａは、受信したｒｅｄｏログ情報３００を基に、他ノード用ｒｅｄｏログ１３０Ａにエントリを１行追加する。さらに、ｒｅｄｏログファイル更新部１１３Ａは、他ノード用ｒｅｄｏログ１３０Ａの内容をｒｅｄｏログファイル２２１Ａに書き出す。
以上で、第１実施形態に係るデータベース制御システム１のデータベース更新動作（更新データの競合なし）の説明を終了する。
図７は、第１実施形態に係るデータベース制御システムのデータベース更新動作（更新データの競合あり）の説明図である。
図７は、ノード２ＡでＴｘＡが、ノード２ＢでＴｘＢがほぼ同時に実行される場合の処理の流れを示している。ＴｘＡ，ＴｘＢ共に、アドレス＃０００１のレコードを更新するので更新対象レコードが競合する。他ノード用ｒｅｄｏログ１３０上の白抜き矢印は、更新対象競合判定部１１２が競合判定を行う時間帯を表している。
図７は、ノード２ＡでＴｘＡが、ノード２ＢでＴｘＢがほぼ同時に実行される場合の処理の流れを示している。ＴｘＡ，ＴｘＢ共に、アドレス＃０００１のレコードを更新するので更新対象レコードが競合する。他ノード用ｒｅｄｏログ１３０上の白抜き矢印は、更新対象競合判定部１１２が競合判定を行う時間帯を表している。
なお、説明に際して、ｒｅｄｏログ１２０，１３０及びｒｅｄｏログ情報３００のデータの設定の記載については、一部省略する。
また、各ステップ後の、ノード２Ａの自ノード用ｒｅｄｏログ１２０Ａ，及びノード２Ｂの他ノード用ｒｅｄｏログ１３０Ｂの状態、さらに、ノード２Ｂの自ノード用ｒｅｄｏログ１２０Ｂ，及びノード２Ａの他ノード用ｒｅｄｏログ１３０Ａの状態を図６Ａ（ａ）〜（ｃ）及び図８（ａ）〜（ｃ）に示す。
また、各ステップ後の、ノード２Ａの自ノード用ｒｅｄｏログ１２０Ａ，及びノード２Ｂの他ノード用ｒｅｄｏログ１３０Ｂの状態、さらに、ノード２Ｂの自ノード用ｒｅｄｏログ１２０Ｂ，及びノード２Ａの他ノード用ｒｅｄｏログ１３０Ａの状態を図６Ａ（ａ）〜（ｃ）及び図８（ａ）〜（ｃ）に示す。
（ステップＳ００１Ａ，Ｓ００１Ｂ，Ｓ００２Ａ）
ステップＳ００１Ａ，Ｓ００１Ｂ，Ｓ００２Ａの処理は、前記第１実施形態に係るデータベース制御システムのデータベース更新動作（更新データの競合なし）の説明（図５参照）と同じなので説明を省略する。
ステップＳ００１Ａ，Ｓ００１Ｂ，Ｓ００２Ａの処理は、前記第１実施形態に係るデータベース制御システムのデータベース更新動作（更新データの競合なし）の説明（図５参照）と同じなので説明を省略する。
（ステップＳ００２Ｂ）
ノード２Ｂのｒｅｄｏログ更新部１１１Ｂは、ＤＢ操作コード欄１２３Ｂに「ｕｐｄａｔｅ」を設定し、ＤＢ操作アドレス欄１２４Ｂに「０００１」を設定し、ＤＢ操作パラメタ欄１２５Ｂに「ＢＢＢＢＢ」を設定したエントリを、自ノード用ｒｅｄｏログ１２０Ｂに１行追加する。また、ｒｅｄｏログ更新部１１１Ｂは、追加したエントリと同じ内容でｒｅｄｏログ情報３００を作成し、このｒｅｄｏログ情報３００をノード２Ａに送信する。
ノード２Ａのｒｅｄｏログ更新部１１１Ａは、受信したｒｅｄｏログ情報３００を基に、他ノード用ｒｅｄｏログ１３０Ａにエントリを１行追加する。
ノード２Ｂのｒｅｄｏログ更新部１１１Ｂは、ＤＢ操作コード欄１２３Ｂに「ｕｐｄａｔｅ」を設定し、ＤＢ操作アドレス欄１２４Ｂに「０００１」を設定し、ＤＢ操作パラメタ欄１２５Ｂに「ＢＢＢＢＢ」を設定したエントリを、自ノード用ｒｅｄｏログ１２０Ｂに１行追加する。また、ｒｅｄｏログ更新部１１１Ｂは、追加したエントリと同じ内容でｒｅｄｏログ情報３００を作成し、このｒｅｄｏログ情報３００をノード２Ａに送信する。
ノード２Ａのｒｅｄｏログ更新部１１１Ａは、受信したｒｅｄｏログ情報３００を基に、他ノード用ｒｅｄｏログ１３０Ａにエントリを１行追加する。
（ステップＳ００３Ａ）
ノード２Ａの更新対象競合判定部１１２Ａは、ｃｏｍｍｉｔを行うときに、ノード２Ａとノード２Ｂとで更新対象レコードが競合したか否かの判定を行う。ここで、現時点の時刻は「20090101010101005」とする。
更新対象競合判定部１１２Ａは、自ノード用ｒｅｄｏログ１２０Ａのタイムスタンプ欄１２１Ａを参照することで、ＴｘＡの開始が「20090101010101001」であることを把握し、他ノード用ｒｅｄｏログ１３０Ａのタイムスタンプ欄１３１Ａの日時が「20090101010101001」から「20090101010101005」までの間のエントリで、自ノード用ｒｅｄｏログ１２０ＡのＤＢ操作アドレス欄１２４Ａの値と他ノード用ｒｅｄｏログ１３０ＡのＤＢ操作アドレス欄１３４Ａの値とが一致するエントリがあるが、ＤＢ操作コード欄１３３Ａに「ｃｏｍｍｉｔ」が設定されたエントリがないと分かる。その為、更新対象競合判定部１１２Ａは、更新対象レコードの競合はないと判定する。
ノード２Ａの更新対象競合判定部１１２Ａは、ｃｏｍｍｉｔを行うときに、ノード２Ａとノード２Ｂとで更新対象レコードが競合したか否かの判定を行う。ここで、現時点の時刻は「20090101010101005」とする。
更新対象競合判定部１１２Ａは、自ノード用ｒｅｄｏログ１２０Ａのタイムスタンプ欄１２１Ａを参照することで、ＴｘＡの開始が「20090101010101001」であることを把握し、他ノード用ｒｅｄｏログ１３０Ａのタイムスタンプ欄１３１Ａの日時が「20090101010101001」から「20090101010101005」までの間のエントリで、自ノード用ｒｅｄｏログ１２０ＡのＤＢ操作アドレス欄１２４Ａの値と他ノード用ｒｅｄｏログ１３０ＡのＤＢ操作アドレス欄１３４Ａの値とが一致するエントリがあるが、ＤＢ操作コード欄１３３Ａに「ｃｏｍｍｉｔ」が設定されたエントリがないと分かる。その為、更新対象競合判定部１１２Ａは、更新対象レコードの競合はないと判定する。
次に、ノード２Ａのｒｅｄｏログ更新部１１１Ａは、更新対象レコードの競合はないと判定されたので、ＤＢ操作コード欄１２３Ａに「ｃｏｍｍｉｔ」を設定したエントリを、自ノード用ｒｅｄｏログ１２０Ａに１行追加する。また、ｒｅｄｏログ更新部１１１Ａは、追加したエントリと同じ内容でｒｅｄｏログ情報３００を作成し、このｒｅｄｏログ情報３００をノード２Ｂに送信する。さらに、ｒｅｄｏログファイル更新部１１３Ａは、自ノード用ｒｅｄｏログ１２０Ａの内容をｒｅｄｏログファイル２２１Ａに書き出す。
ノード２Ｂのｒｅｄｏログ更新部１１１Ｂは、受信したｒｅｄｏログ情報３００を基に、他ノード用ｒｅｄｏログ１３０Ｂにエントリを１行追加する。さらに、ｒｅｄｏログファイル更新部１１３Ｂは、他ノード用ｒｅｄｏログ１３０Ｂの内容をｒｅｄｏログファイル２２１Ｂに書き出す。
ノード２Ｂのｒｅｄｏログ更新部１１１Ｂは、受信したｒｅｄｏログ情報３００を基に、他ノード用ｒｅｄｏログ１３０Ｂにエントリを１行追加する。さらに、ｒｅｄｏログファイル更新部１１３Ｂは、他ノード用ｒｅｄｏログ１３０Ｂの内容をｒｅｄｏログファイル２２１Ｂに書き出す。
（ステップＳ００３Ｂ）
ノード２Ｂの更新対象競合判定部１１２Ｂは、ｃｏｍｍｉｔを行うときに、ノード２Ａとノード２Ｂとで更新対象レコードが競合したか否かの判定を行う。ここで、現時点の時刻は「20090101010101006」とする。
更新対象競合判定部１１２Ｂは、自ノード用ｒｅｄｏログ１２０Ｂのタイムスタンプ欄１２１Ｂを参照することで、ＴｘＢの開始が「20090101010101002」であることを把握し、他ノード用ｒｅｄｏログ１３０Ｂのタイムスタンプ欄１３１Ｂの日時が「20090101010101002」から「20090101010101006」までの間のエントリで自ノード用ｒｅｄｏログ１２０ＢのＤＢ操作アドレス欄１２４Ｂの値と他ノード用ｒｅｄｏログ１３０ＢのＤＢ操作アドレス欄１３４Ｂの値とが一致するエントリがあり、かつ、ＤＢ操作コード欄１３３Ｂに「ｃｏｍｍｉｔ」が設定されたエントリもあると分かる。その為、更新対象競合判定部１１２Ｂは、更新対象レコードの競合があると判定する。
ノード２Ｂの更新対象競合判定部１１２Ｂは、ｃｏｍｍｉｔを行うときに、ノード２Ａとノード２Ｂとで更新対象レコードが競合したか否かの判定を行う。ここで、現時点の時刻は「20090101010101006」とする。
更新対象競合判定部１１２Ｂは、自ノード用ｒｅｄｏログ１２０Ｂのタイムスタンプ欄１２１Ｂを参照することで、ＴｘＢの開始が「20090101010101002」であることを把握し、他ノード用ｒｅｄｏログ１３０Ｂのタイムスタンプ欄１３１Ｂの日時が「20090101010101002」から「20090101010101006」までの間のエントリで自ノード用ｒｅｄｏログ１２０ＢのＤＢ操作アドレス欄１２４Ｂの値と他ノード用ｒｅｄｏログ１３０ＢのＤＢ操作アドレス欄１３４Ｂの値とが一致するエントリがあり、かつ、ＤＢ操作コード欄１３３Ｂに「ｃｏｍｍｉｔ」が設定されたエントリもあると分かる。その為、更新対象競合判定部１１２Ｂは、更新対象レコードの競合があると判定する。
次に、ノード２Ｂのｒｅｄｏログ更新部１１１Ｂは、更新対象レコードの競合があると判定されたので、ＤＢ操作コード欄１２３Ｂに「ｒｏｌｌｂａｃｋ」を設定したエントリを、自ノード用ｒｅｄｏログ１２０Ｂに１行追加する。また、ｒｅｄｏログ更新部１１１Ｂは、追加したエントリと同じ内容でｒｅｄｏログ情報３００を作成し、このｒｅｄｏログ情報３００をノード２Ａに送信する。そして、ノード２Ｂは、ＴｘＢの実行を中止する。
ノード２Ａのｒｅｄｏログ更新部１１１Ａは、受信したｒｅｄｏログ情報３００を基に、他ノード用ｒｅｄｏログ１３０Ａにエントリを１行追加する。
以上で、第１実施形態に係るデータベース制御システムのデータベース更新動作（更新データの競合あり）の説明を終了する。このように、本実施形態に係るデータベース制御システムでは、更新操作において競合があっても、待ちが発生することがない。
ノード２Ａのｒｅｄｏログ更新部１１１Ａは、受信したｒｅｄｏログ情報３００を基に、他ノード用ｒｅｄｏログ１３０Ａにエントリを１行追加する。
以上で、第１実施形態に係るデータベース制御システムのデータベース更新動作（更新データの競合あり）の説明を終了する。このように、本実施形態に係るデータベース制御システムでは、更新操作において競合があっても、待ちが発生することがない。
≪第２実施形態に係るデータベース制御システムを構成するノードの機能及び使用するフォーマット≫
＜ノードが備える機能＞
（概要）
第１実施形態に係るノード２（図２参照）では、前記した通り、ノード２間で更新対象レコードが競合した場合に、先にｃｏｍｍｉｔした方を優先する。そして、自ノード用ｒｅｄｏログ１２０と他ノード用ｒｅｄｏログ１３０の情報を比較する際には、各ノード２で同期しているタイマ６（図１参照）に基づいてｒｅｄｏログ１２０，１３０のタイムスタンプ欄１２１，１３１に書き込まれる時刻の情報を利用して、参照するｒｅｄｏログ１２０，１３０の範囲を決定する。
＜ノードが備える機能＞
（概要）
第１実施形態に係るノード２（図２参照）では、前記した通り、ノード２間で更新対象レコードが競合した場合に、先にｃｏｍｍｉｔした方を優先する。そして、自ノード用ｒｅｄｏログ１２０と他ノード用ｒｅｄｏログ１３０の情報を比較する際には、各ノード２で同期しているタイマ６（図１参照）に基づいてｒｅｄｏログ１２０，１３０のタイムスタンプ欄１２１，１３１に書き込まれる時刻の情報を利用して、参照するｒｅｄｏログ１２０，１３０の範囲を決定する。
実際には、ノード２間でのｒｅｄｏログ情報３００の送信には、ある程度時間がかかるため、ｃｏｍｍｉｔを行うときに、即時に更新対象レコードの競合を判定することができない。すなわち、自己のノードでｃｏｍｍｉｔを行うときに、自己のノードが備える他ノード用ｒｅｄｏログ１３０には他のノードのｃｏｍｍｉｔの情報が反映されていないが、実際には、他のノードでｃｏｍｍｉｔが行われており、ｒｅｄｏログ情報３００の伝送遅延により自己のノードが備える他ノード用ｒｅｄｏログ１３０に他のノードのｃｏｍｍｉｔの情報が反映されていない場合である。この場合、自己のノードは、ｃｏｍｍｉｔを行う時点では他のノードがｃｏｍｍｉｔを行っているのか否かを判定することができない。
そのため、第２実施形態に係るノードは、更新情報がない場合も定期的にタイムスタンプ欄以外はデータを設定しないｒｅｄｏログ情報（以下、空のｒｅｄｏログ情報と称す）を他ノードに送信し、空のｒｅｄｏログ情報を受信したノードは、受信した時刻と空のｒｅｄｏログ情報のタイムスタンプ欄に格納される時刻との差を更新対象レコードが競合したか否かの判定に利用する。
ここで、第２実施形態に係るデータベース制御システムの構成は、図１に示す第１実施形態に係るデータベース制御システム１と同じである。
以下、第２実施形態に係るノードについて説明する。
ここで、第２実施形態に係るデータベース制御システムの構成は、図１に示す第１実施形態に係るデータベース制御システム１と同じである。
以下、第２実施形態に係るノードについて説明する。
図９は、第２実施形態に係るデータベース制御システムを構成するノードの機能構成図である。図９では、各機能を「○○部」と記載している。
第２実施形態に係るノード２は、第１実施形態に係るノード２（図２参照）の機能に加えてさらに、ｒｅｄｏログ情報送信遅延演算部１１５を備える。また、ｒｅｄｏログ更新部１１１，及び更新対象競合判定部１１２の機能が異なる。それ以外のデータ構成等は第１実施形態と同様である。以下、説明する。
第２実施形態に係るノード２は、第１実施形態に係るノード２（図２参照）の機能に加えてさらに、ｒｅｄｏログ情報送信遅延演算部１１５を備える。また、ｒｅｄｏログ更新部１１１，及び更新対象競合判定部１１２の機能が異なる。それ以外のデータ構成等は第１実施形態と同様である。以下、説明する。
（ｒｅｄｏログ更新部）
ｒｅｄｏログ更新部１１１は、第１実施形態に係るｒｅｄｏログ更新部１１１の機能に加えて、以下の機能を備える。
本実施形態に係るｒｅｄｏログ更新部１１１は、自ノード用ｒｅｄｏログ１２０の更新をしておらず、本来ならば、他ノードに対してｒｅｄｏログ情報を送信する必要がない場合でも、図４に示すタイムスタンプ欄３０１に「時刻」を設定し、それ以外の欄にはデータを設定しない空のｒｅｄｏログ情報３００を、定期的に他のノード２に送信する機能を備える。
ｒｅｄｏログ更新部１１１は、第１実施形態に係るｒｅｄｏログ更新部１１１の機能に加えて、以下の機能を備える。
本実施形態に係るｒｅｄｏログ更新部１１１は、自ノード用ｒｅｄｏログ１２０の更新をしておらず、本来ならば、他ノードに対してｒｅｄｏログ情報を送信する必要がない場合でも、図４に示すタイムスタンプ欄３０１に「時刻」を設定し、それ以外の欄にはデータを設定しない空のｒｅｄｏログ情報３００を、定期的に他のノード２に送信する機能を備える。
（ｒｅｄｏログ情報送信遅延演算部）
ｒｅｄｏログ情報送信遅延演算部１１５は、空のｒｅｄｏログ情報３００を受信したら、現在の時刻と、空のｒｅｄｏログ情報３００のタイムスタンプ欄３０１に設定される時刻との時間差をメモリ上に保存する。
ここで、メモリ上に保存する時間差は、現在の時刻と直近の空のｒｅｄｏログ情報３００に設定される時刻との単純な時間差だけでなく、現在の時刻と受信した複数個のｒｅｄｏログ情報３００に設定されている時刻との平均値との差としてもよい。また、メモリ上に保存される時間差には、上記以外にも種々の影響を考慮した値を設定することができる。
ｒｅｄｏログ情報送信遅延演算部１１５は、空のｒｅｄｏログ情報３００を受信したら、現在の時刻と、空のｒｅｄｏログ情報３００のタイムスタンプ欄３０１に設定される時刻との時間差をメモリ上に保存する。
ここで、メモリ上に保存する時間差は、現在の時刻と直近の空のｒｅｄｏログ情報３００に設定される時刻との単純な時間差だけでなく、現在の時刻と受信した複数個のｒｅｄｏログ情報３００に設定されている時刻との平均値との差としてもよい。また、メモリ上に保存される時間差には、上記以外にも種々の影響を考慮した値を設定することができる。
（更新対象競合判定部）
本実施形態に係る更新対象競合判定部１１２は、自己のノード２でトランザクションが発生し、かつ、ｃｏｍｍｉｔを行うときに、ｒｅｄｏログ情報送信遅延演算部１１５によりメモリ上に保存された時間差分だけ待って、自己のノード２（２Ａ）と他のノード２（２Ｂ）とで更新対象レコードが競合したか否かの判定を行う。
すなわち、更新対象競合判定部１１２は、トランザクションの開始からｃｏｍｍｉｔを行ったときからメモリ上に保存される時間差分加えた時間帯までの他ノード用ｒｅｄｏログ１３０の内容を調べることで更新対象レコードの競合を判定する。
本実施形態に係る更新対象競合判定部１１２は、自己のノード２でトランザクションが発生し、かつ、ｃｏｍｍｉｔを行うときに、ｒｅｄｏログ情報送信遅延演算部１１５によりメモリ上に保存された時間差分だけ待って、自己のノード２（２Ａ）と他のノード２（２Ｂ）とで更新対象レコードが競合したか否かの判定を行う。
すなわち、更新対象競合判定部１１２は、トランザクションの開始からｃｏｍｍｉｔを行ったときからメモリ上に保存される時間差分加えた時間帯までの他ノード用ｒｅｄｏログ１３０の内容を調べることで更新対象レコードの競合を判定する。
≪第２実施形態に係るデータベース制御システムのデータベース更新動作≫
以下、図１０を参照して第２実施形態に係るデータベース制御システムのデータベース更新動作について説明する。
図１０は、第２実施形態に係るデータベース制御システムのデータベース更新動作（更新データの競合あり）の説明図である。
図１０は、ノード２ＡでＴｘＡが、ノード２ＢでＴｘＢがほぼ同時に実行される場合の処理の流れを示している。ＴｘＡ，ＴｘＢ共に、アドレス＃０００１のレコードを更新するので更新対象レコードが競合する。以下、ステップＳ００３Ｂを使って本実施形態の動作を説明する。
以下、図１０を参照して第２実施形態に係るデータベース制御システムのデータベース更新動作について説明する。
図１０は、第２実施形態に係るデータベース制御システムのデータベース更新動作（更新データの競合あり）の説明図である。
図１０は、ノード２ＡでＴｘＡが、ノード２ＢでＴｘＢがほぼ同時に実行される場合の処理の流れを示している。ＴｘＡ，ＴｘＢ共に、アドレス＃０００１のレコードを更新するので更新対象レコードが競合する。以下、ステップＳ００３Ｂを使って本実施形態の動作を説明する。
なお、説明に際して、ｒｅｄｏログ１２０，１３０及びｒｅｄｏログ情報３００のデータの設定の記載については、一部省略する。
また、ステップ後の、ノード２Ａの自ノード用ｒｅｄｏログ１２０Ａ，及びノード２Ｂの他ノード用ｒｅｄｏログ１３０Ｂの状態、さらに、ノード２Ｂの自ノード用ｒｅｄｏログ１２０Ｂ，及びノード２Ａの他ノード用ｒｅｄｏログ１３０Ａの状態は図８（ａ）〜（ｃ）と同じである。
また、ステップ後の、ノード２Ａの自ノード用ｒｅｄｏログ１２０Ａ，及びノード２Ｂの他ノード用ｒｅｄｏログ１３０Ｂの状態、さらに、ノード２Ｂの自ノード用ｒｅｄｏログ１２０Ｂ，及びノード２Ａの他ノード用ｒｅｄｏログ１３０Ａの状態は図８（ａ）〜（ｃ）と同じである。
（ステップＳ００３Ｂ）
ノード２Ｂの更新対象競合判定部１１２Ｂは、ｃｏｍｍｉｔを行う前に、自ノードと他ノードとで更新対象レコードが競合したか否かの判定を行う。ここで、現時点の日時は「20090101010101006」だとする。また、ノード２Ｂのｒｅｄｏログ情報送信遅延演算部１１５は、空のｒｅｄｏログ情報を受信して一定の時間差があることを把握し、この時間差をメモリ上に保存している。
ノード２Ｂの更新対象競合判定部１１２Ｂは、ｃｏｍｍｉｔを行う前に、自ノードと他ノードとで更新対象レコードが競合したか否かの判定を行う。ここで、現時点の日時は「20090101010101006」だとする。また、ノード２Ｂのｒｅｄｏログ情報送信遅延演算部１１５は、空のｒｅｄｏログ情報を受信して一定の時間差があることを把握し、この時間差をメモリ上に保存している。
更新対象競合判定部１１２Ｂは、現時点からメモリ上に保存した時間差後に更新対象レコードが競合したか否かの判定を行う。更新対象競合判定部１１２Ｂは、自ノード用ｒｅｄｏログ１２０Ｂのタイムスタンプ欄１２１Ｂを参照することで、ＴｘＢの開始が「20090101010101002」であることを把握し、他ノード用ｒｅｄｏログ１３０Ｂのタイムスタンプ欄１３１Ｂの日時が「20090101010101002」から「20090101010101006」までの間のエントリで自ノード用ｒｅｄｏログ１２０ＢのＤＢ操作アドレス欄１２４Ｂの値と他ノード用ｒｅｄｏログ１３０ＢのＤＢ操作アドレス欄１３４Ｂの値とが一致するエントリがあり、かつ、ＤＢ操作コード欄１３３Ｂに「ｃｏｍｍｉｔ」が設定されたエントリもあると分かる。その為、更新対象競合判定部１１２Ｂは、更新対象レコードの競合があると判定する。
仮に、更新対象競合判定部１１２Ｂが、現時点「20090101010101006」で競合を判定した場合を想定する。現時点では、ノード２Ａのｃｏｍｍｉｔ情報がノード２Ｂに届いていないので、更新対象競合判定部１１２Ｂは、実際は競合があるのに、競合なしと判定してしまう。
以上で、第２実施形態に係るデータベース制御システムのデータベース更新動作（更新データの競合あり）の説明を終了する。
以上で、第２実施形態に係るデータベース制御システムのデータベース更新動作（更新データの競合あり）の説明を終了する。
なお、本実施形態に係るデータベース制御システムは、自己のノードでｃｏｍｍｉｔを行うときに、自己のノードが備える他ノード用ｒｅｄｏログ１３０には他のノードのｃｏｍｍｉｔの情報が反映されていないが、他のノードでｃｏｍｍｉｔが行われており、ｒｅｄｏログ情報３００の伝送遅延により自己のノードが備える他ノード用ｒｅｄｏログ１３０に他のノードのｃｏｍｍｉｔの情報が反映されていない場合に有効である。
（第２実施形態に係るデータベース制御システムの効果）
ノード間の伝送に遅延が生じても、更新対象レコードの競合の判定を行うことが可能になる。
ノード間の伝送に遅延が生じても、更新対象レコードの競合の判定を行うことが可能になる。
１ データベース制御システム
２（２Ａ，２Ｂ） ノード（計算機）
６（６Ａ，６Ｂ） タイマ
１００（１００Ａ，１００Ｂ） 制御装置
１１０（１１０Ａ，１１０Ｂ） データベース管理部
１１１（１１１Ａ，１１１Ｂ） ｒｅｄｏログ更新部
１１２（１１２Ａ，１１２Ｂ） 更新対象競合判定部
１１５（１１５Ａ，１１５Ｂ） ｒｅｄｏログ情報送信遅延演算部
１２０（１２０Ａ，１２０Ｂ） 自ノード用ｒｅｄｏログ（自己更新情報）
１３０（１３０Ａ，１３０Ｂ） 他ノード用ｒｅｄｏログ（他の更新情報）
２００（２００Ａ，２００Ｂ） 記憶装置
２１０（２１０Ａ，２１０Ｂ） ＤＢＭＳ（データベース管理プログラム）
２２０（２２０Ａ，２２０Ｂ） ＤＢ（データベース）
３００ ｒｅｄｏログ情報（更新データ）
２（２Ａ，２Ｂ） ノード（計算機）
６（６Ａ，６Ｂ） タイマ
１００（１００Ａ，１００Ｂ） 制御装置
１１０（１１０Ａ，１１０Ｂ） データベース管理部
１１１（１１１Ａ，１１１Ｂ） ｒｅｄｏログ更新部
１１２（１１２Ａ，１１２Ｂ） 更新対象競合判定部
１１５（１１５Ａ，１１５Ｂ） ｒｅｄｏログ情報送信遅延演算部
１２０（１２０Ａ，１２０Ｂ） 自ノード用ｒｅｄｏログ（自己更新情報）
１３０（１３０Ａ，１３０Ｂ） 他ノード用ｒｅｄｏログ（他の更新情報）
２００（２００Ａ，２００Ｂ） 記憶装置
２１０（２１０Ａ，２１０Ｂ） ＤＢＭＳ（データベース管理プログラム）
２２０（２２０Ａ，２２０Ｂ） ＤＢ（データベース）
３００ ｒｅｄｏログ情報（更新データ）
Claims (6)
- 複数の同じ内容のデータベースに通信可能に接続されて多重化されたデータベースのうち少なくとも１つを備える計算機であって、
自己が保有するデータベースの自己更新情報と、自己が保有するデータベース以外のデータベースの他の更新情報とを各データベース毎に分けて保有する記憶部と、
前記自己更新情報を更新する際に、前記他の更新情報を参照することで、前記多重化されたデータベースの更新における競合を判定する競合判定部と、
を備えることを特徴とする計算機。 - 前記他の更新情報は、自己以外の計算機が各々備えるデータベースの更新データを受信したときに前記記憶部に記憶される、
ことを特徴とする請求項１に記載の計算機。 - 前記競合判定部は、前記自己更新情報の更新の開始から結果確定までの時間帯で、前記自己更新情報の更新対象レコードのアドレスと前記他の更新情報の更新対象レコードのアドレスとが一致し、かつ、他の更新情報の更新処理が結果確定している場合に前記多重化されたデータベースの更新が競合したと判定する、
ことを特徴とする請求項２に記載の計算機。 - 自己以外の計算機が発信する発信時刻を記載したデータを受信する時刻と、この発信時刻との時間差を計算する遅延演算部をさらに備え、
前記競合判定部は、前記時間差だけ待って前記多重化されたデータベースの更新が競合したか否かの判定を行う、
ことを特徴とする請求項２又は請求項３に記載の計算機。 - 前記発信する発信時刻を記載したデータは、前記更新データである、
ことを特徴とする請求項４に記載の計算機。 - 複数の同じ内容のデータベースに通信可能に接続されて多重化されたデータベースのうち少なくとも１つを備える計算機の制御装置に実行させるデータベース管理プログラムであって、
前記自己の計算機が保有するデータベースの自己更新情報と、前記自己が保有するデータベース以外のデータベースの他の更新情報とを各データベース毎に分けて記憶部に保有させる機能と、
前記自己情報を更新する際に、前記他の更新情報を参照することで、前記多重化されたデータベースの更新における競合を判定する機能と、
を前記制御装置に実現させることを特徴とするデータベース管理プログラム。
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| JP2009228864A JP2011076487A (ja) | 2009-09-30 | 2009-09-30 | 計算機、及びデータベース管理プログラム |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| JP2009228864A JP2011076487A (ja) | 2009-09-30 | 2009-09-30 | 計算機、及びデータベース管理プログラム |
Publications (1)
| Publication Number | Publication Date |
|---|---|
| JP2011076487A true JP2011076487A (ja) | 2011-04-14 |
Family
ID=44020383
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| JP2009228864A Pending JP2011076487A (ja) | 2009-09-30 | 2009-09-30 | 計算機、及びデータベース管理プログラム |
Country Status (1)
| Country | Link |
|---|---|
| JP (1) | JP2011076487A (ja) |
Cited By (18)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| JP2013114623A (ja) * | 2011-11-30 | 2013-06-10 | Fujitsu Ltd | ストレージ装置、ストレージ制御プログラムおよびストレージ制御方法 |
| JP2015191307A (ja) * | 2014-03-27 | 2015-11-02 | 日本電気株式会社 | トランザクションシステム |
| CN106462449A (zh) * | 2014-06-26 | 2017-02-22 | 亚马逊科技公司 | 具有多项目事务支持的多数据库日志 |
| JP2017531256A (ja) * | 2014-09-10 | 2017-10-19 | アマゾン・テクノロジーズ・インコーポレーテッド | 拡張縮小可能なログベーストランザクション管理 |
| US10346434B1 (en) | 2015-08-21 | 2019-07-09 | Amazon Technologies, Inc. | Partitioned data materialization in journal-based storage systems |
| US10373247B2 (en) | 2014-09-19 | 2019-08-06 | Amazon Technologies, Inc. | Lifecycle transitions in log-coordinated data stores |
| US10698767B1 (en) | 2014-12-22 | 2020-06-30 | Amazon Technologies, Inc. | Decentralized management of multi-service workflows |
| US10866968B1 (en) | 2015-06-29 | 2020-12-15 | Amazon Technologies, Inc. | Compact snapshots of journal-based storage systems |
| US10866865B1 (en) | 2015-06-29 | 2020-12-15 | Amazon Technologies, Inc. | Storage system journal entry redaction |
| US11048669B2 (en) | 2015-12-29 | 2021-06-29 | Amazon Technologies, Inc. | Replicated state management using journal-based registers |
| CN113590387A (zh) * | 2021-08-02 | 2021-11-02 | 瀚高基础软件股份有限公司 | 一种数据库的控制文件的恢复方法及存储介质 |
| US11308127B2 (en) | 2015-03-13 | 2022-04-19 | Amazon Technologies, Inc. | Log-based distributed transaction management |
| US11341115B2 (en) | 2014-06-26 | 2022-05-24 | Amazon Technologies, Inc. | Multi-database log with multi-item transaction support |
| US11397709B2 (en) | 2014-09-19 | 2022-07-26 | Amazon Technologies, Inc. | Automated configuration of log-coordinated storage groups |
| US11599520B1 (en) | 2015-06-29 | 2023-03-07 | Amazon Technologies, Inc. | Consistency management using query restrictions in journal-based storage systems |
| US11609890B1 (en) | 2015-06-29 | 2023-03-21 | Amazon Technologies, Inc. | Schema management for journal-based storage systems |
| US11625700B2 (en) | 2014-09-19 | 2023-04-11 | Amazon Technologies, Inc. | Cross-data-store operations in log-coordinated storage systems |
| US11960464B2 (en) | 2015-08-21 | 2024-04-16 | Amazon Technologies, Inc. | Customer-related partitioning of journal-based storage systems |
-
2009
- 2009-09-30 JP JP2009228864A patent/JP2011076487A/ja active Pending
Cited By (24)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| JP2013114623A (ja) * | 2011-11-30 | 2013-06-10 | Fujitsu Ltd | ストレージ装置、ストレージ制御プログラムおよびストレージ制御方法 |
| US10007548B2 (en) | 2014-03-27 | 2018-06-26 | Nec Corporation | Transaction system |
| JP2015191307A (ja) * | 2014-03-27 | 2015-11-02 | 日本電気株式会社 | トランザクションシステム |
| US11341115B2 (en) | 2014-06-26 | 2022-05-24 | Amazon Technologies, Inc. | Multi-database log with multi-item transaction support |
| US11995066B2 (en) | 2014-06-26 | 2024-05-28 | Amazon Technologies, Inc. | Multi-database log with multi-item transaction support |
| JP2017520844A (ja) * | 2014-06-26 | 2017-07-27 | アマゾン・テクノロジーズ・インコーポレーテッド | マルチアイテムトランザクションサポートを有するマルチデータベースログ |
| CN106462449A (zh) * | 2014-06-26 | 2017-02-22 | 亚马逊科技公司 | 具有多项目事务支持的多数据库日志 |
| CN106462449B (zh) * | 2014-06-26 | 2019-10-29 | 亚马逊科技公司 | 具有多项目事务支持的多数据库日志 |
| JP2017531256A (ja) * | 2014-09-10 | 2017-10-19 | アマゾン・テクノロジーズ・インコーポレーテッド | 拡張縮小可能なログベーストランザクション管理 |
| US11397709B2 (en) | 2014-09-19 | 2022-07-26 | Amazon Technologies, Inc. | Automated configuration of log-coordinated storage groups |
| US10373247B2 (en) | 2014-09-19 | 2019-08-06 | Amazon Technologies, Inc. | Lifecycle transitions in log-coordinated data stores |
| US11625700B2 (en) | 2014-09-19 | 2023-04-11 | Amazon Technologies, Inc. | Cross-data-store operations in log-coordinated storage systems |
| US10698767B1 (en) | 2014-12-22 | 2020-06-30 | Amazon Technologies, Inc. | Decentralized management of multi-service workflows |
| US11308127B2 (en) | 2015-03-13 | 2022-04-19 | Amazon Technologies, Inc. | Log-based distributed transaction management |
| US11860900B2 (en) | 2015-03-13 | 2024-01-02 | Amazon Technologies, Inc. | Log-based distributed transaction management |
| US10866968B1 (en) | 2015-06-29 | 2020-12-15 | Amazon Technologies, Inc. | Compact snapshots of journal-based storage systems |
| US10866865B1 (en) | 2015-06-29 | 2020-12-15 | Amazon Technologies, Inc. | Storage system journal entry redaction |
| US12099486B2 (en) | 2015-06-29 | 2024-09-24 | Amazon Technologies, Inc. | Schema management for journal-based storage systems |
| US11599520B1 (en) | 2015-06-29 | 2023-03-07 | Amazon Technologies, Inc. | Consistency management using query restrictions in journal-based storage systems |
| US11609890B1 (en) | 2015-06-29 | 2023-03-21 | Amazon Technologies, Inc. | Schema management for journal-based storage systems |
| US10346434B1 (en) | 2015-08-21 | 2019-07-09 | Amazon Technologies, Inc. | Partitioned data materialization in journal-based storage systems |
| US11960464B2 (en) | 2015-08-21 | 2024-04-16 | Amazon Technologies, Inc. | Customer-related partitioning of journal-based storage systems |
| US11048669B2 (en) | 2015-12-29 | 2021-06-29 | Amazon Technologies, Inc. | Replicated state management using journal-based registers |
| CN113590387A (zh) * | 2021-08-02 | 2021-11-02 | 瀚高基础软件股份有限公司 | 一种数据库的控制文件的恢复方法及存储介质 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| JP2011076487A (ja) | 計算機、及びデータベース管理プログラム | |
| US20240179212A1 (en) | Hosted file sync with stateless sync nodes | |
| JP5193056B2 (ja) | 無線装置の最新データを維持するための方法及びシステム | |
| US8095504B2 (en) | N-way synchronization of computer databases | |
| JP2948496B2 (ja) | データ処理システム内で複写データ一貫性を維持するためのシステムおよび方法 | |
| US7013316B1 (en) | System and method for synchronizing multiple database files | |
| EP1014266B1 (en) | Method, apparatus and program storage device for a client and adaptive synchronization and transformation server | |
| KR100592647B1 (ko) | 서로 다른 클라이언트 사이의 데이터 동기화 시스템, 클라이언트들간의 업데이트 동기화 방법, 업데이트의 복제 방법, 및 컴퓨터 판독 가능 기록 매체 | |
| EP1636711B1 (en) | System and method for distribution of software licenses in a networked computing environment | |
| CN104239439A (zh) | 选择性的数据库复制 | |
| US20070124734A1 (en) | Maintaining coherency in a symbiotic computing system and method of operation thereof | |
| US7933868B2 (en) | Method and system for partition level cleanup of replication conflict metadata | |
| US20110082833A1 (en) | Database parallel editing method | |
| JP2003528395A (ja) | コンピュータネットワーク内でデータを自動的に配置するための方法及び装置 | |
| JP5724735B2 (ja) | データベース更新制御装置、データベース管理システムおよびデータベース更新制御プログラム | |
| JP2009518757A5 (ja) | ||
| JP2003296171A (ja) | 電子帳票管理方法及びプログラム | |
| EP1480130A2 (en) | Method and apparatus for moving data between storage devices | |
| US20100125549A1 (en) | Maintaining client data integrity in a distributed environment using asynchronous data submission | |
| CN109145054A (zh) | 一种管理客户端数据的方法 | |
| WO2020153053A1 (ja) | データベース管理サービス提供システム | |
| JP4923140B2 (ja) | データベース並行編集方式 | |
| JP2006268632A (ja) | 計算機システム及びストレージサーバ、検索サーバ、端末装置並びに検索方法 | |
| JP2008158978A (ja) | データベース同期システム、データベース同期方法、データベースサーバ、データベースサーバの制御方法、およびプログラム | |
| US20060167925A1 (en) | System and method for providing system objects to a database |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| A711 | Notification of change in applicant |
Free format text: JAPANESE INTERMEDIATE CODE: A712 Effective date: 20120813 |