[發明專利]基于消息的大型事務應用裝置和方法

有效

• 申請號: 201110284525.9
• 申請日: 2011-09-22
• 公開（公告）號: CN102508834A
• 公開（公告）日: 2012-06-20
• 發明（設計）人: 栗竹冉
• 申請（專利權）人: 用友軟件股份有限公司
• 主分類號: G06F17/30
• 分類號: G06F17/30
• 代理公司: 北京友聯知識產權代理事務所(普通合伙) 11343
• 代理人: 尚志峰;汪海屏

1.一種基于消息的大型事務應用裝置，用于將應用于第一數據源的增量數據操作語句同步應用于第二數據源，其特征在于，包括：

分解單元，在從所述第一數據源中獲取增量數據操作語句，將所述增量數據操作語句按事務進行打包，判斷出所述事務為大型事務時，將所述大型事務分解為多份，將每份包含的所述增量數據操作語句構造成一個消息，將所述消息發送至應用單元；

所述應用單元，在接收到所述消息時，創建所述第二數據源的本地事務以及創建相應的應用任務，所述應用任務基于所述本地事務將所述消息中包含的增量數據操作語句應用于所述第二數據源。

2.根據權利要求1所述的基于消息的大型事務應用裝置，其特征在于，所述分解單元還包括：

消息構造模塊，將多份分解后的所述大型事務構成多個所述消息，多個所述消息構成一個消息組；

設置模塊，設置每個所述消息的屬性，所述屬性包括所屬消息組的身份識別信息、所屬消息組內的消息個數、所述消息的序號，所述消息組的身份識別信息包括所述第一數據源的名稱和所述第二數據源的本地事務標識。

3.根據權利要求1所述的基于消息的大型事務應用裝置，其特征在于，所述應用單元還包括：

第二判斷模塊，在當前的所述消息中包含的增量數據操作語句應用完成時，判斷所述消息是否屬于消息組，若判斷出屬于消息組，則根據當前的所述消息的屬性繼續判斷所述消息組中的消息是否全部處理完成，當判斷結果為全部處理完成時，提交所述第二數據源的本地事務，當判斷結果為沒有全部處理完成時，繼續處理剩余未處理的消息。

4.根據權利要求1所述的基于消息的大型事務應用裝置，其特征在于，所述分解單元還包括：

第一判斷模塊，在所述事務中的增量數據操作語句的個數超過預設的所述消息所能包含的增量數據操作語句的閾值時，判斷出所述事務為大型事務。

5.根據權利要求1至4中任一項所述的基于消息的大型事務應用裝置，其特征在于，所述應用單元基于XA接口規范創建所述第二數據源的本地事務，所述第一數據源為OLTP數據源，所述第二數據源為OLAP數據源。

6.一種基于消息的大型事務應用方法，用于將應用于第一數據源的增量數據操作語句同步應用于第二數據源，其特征在于，包括：

步驟202，從所述第一數據源中獲取增量數據操作語句，將所述增量數據操作語句按事務進行打包，當判斷出所述事務為大型事務時，將所述大型事務分解為多份，將每份包含的所述增量數據操作語句構造成一個消息；

步驟204，當接收到所述消息時，創建所述第二數據源的本地事務以及創建相應的應用任務，所述應用任務基于所述本地事務將所述消息中包含的增量數據操作語句應用于所述第二數據源。

7.根據權利要求6所述的基于消息的大型事務應用方法，其特征在于，所述步驟202還包括：將多份分解后的所述大型事務構成多個所述消息，多個所述消息構成一個消息組，設置每個所述消息的屬性，所述屬性包括所屬消息組的身份識別信息、所屬消息組內的消息個數、所述消息的序號，所述消息組的身份識別信息包括所述第一數據源的名稱和所述第二數據源的本地事務標識。

8.根據權利要求7所述的基于消息的大型事務應用方法，其特征在于，所述步驟204還包括：在當前的所述消息中包含的增量數據操作語句應用完成時，判斷所述消息是否屬于消息組，若判斷出屬于消息組，則根據當前的所述消息的屬性繼續判斷所述消息組中的消息是否全部處理完成，當判斷結果為全部處理完成時，提交所述第二數據源的本地事務，當判斷結果為沒有全部處理完成時，繼續處理剩余未處理的消息。

9.根據權利要求6所述的基于消息的大型事務應用方法，其特征在于，所述步驟202還包括：當所述事務中的增量數據操作語句的個數超過預設的所述消息所能包含的增量數據操作語句的閾值時，判斷出所述事務為大型事務。

10.根據權利要求6至9中任一項所述的基于消息的大型事務應用方法，其特征在于，所述第二數據源的本地事務基于XA接口規范創建而成，所述第一數據源為OLTP數據源，所述第二數據源為OLAP數據源。