[發明專利]數據庫內的分片隊列

有效

• 申請號: 201480040639.0
• 申請日: 2014-06-05
• 公開（公告）號: CN105393251B
• 公開（公告）日: 2019-07-09
• 發明（設計）人: S·博塞;D·辛格;N·布哈特;S·賈納德哈南;G·加爾格;奇亮奭;A·薩克斯埃納;A·多寧
• 申請（專利權）人: 甲骨文國際公司
• 主分類號: G06F16/27
• 分類號: G06F16/27;G06F9/54
• 代理公司: 中國國際貿易促進委員會專利商標事務所 11038
• 代理人: 李曉芳

1.一種用于數據庫內分片隊列的方法，包括：

將來自特定隊列的多個入隊器的消息存儲到所述特定隊列的多個分片中；

其中，針對所述多個入隊器中的每個入隊器，來自此入隊器的所有消息只存儲到所述多個分片中的一個分片中，其中在每個分片中消息被入隊的次序被保留，但在多個分片之間消息被入隊的次序不被保留；

其中所述多個入隊器包括第一入隊器和第二入隊器；

其中存儲來自所述多個入隊器的消息包括：

將來自所述第一入隊器的所有消息存儲到被分配給所述多個分片中的第一分片的隊列表的第一一個或多個行中；以及

將來自所述第二入隊器的所有消息存儲到被分配給所述多個分片中的第二分片的隊列表的第二一個或多個行中；

其中，來自所述第一入隊器的一個或多個消息以及來自所述第二入隊器的一個或多個消息用于所述特定隊列的特定訂戶；

通過針對所述特定訂戶將消息從所述第一分片和所述第二分片二者出隊，來針對所述特定訂戶將消息從所述特定隊列出隊。

2.如權利要求1所述的方法，其中：

所述多個分片的每個分片包括一個或多個子分片；

每個子分片包括由關系數據庫系統維護的所述隊列表的一個或多個行；

所述隊列表的一個或多個分區被分配給每個子分片；

將來自所述第一入隊器的所有消息存儲到被分配給所述第一分片的所述隊列表的行包括：

針對來自所述第一入隊器的每個消息，與所述關系數據庫系統相關聯的數據庫服務器執行在所述隊列表中已被分配給所述第一分片的分區中插入行的數據庫命令。

3.如權利要求1所述的方法，還包括：

在易失性存儲器中，維護針對所述多個分片中的每個分片的消息高速緩存；

其中維護針對每個分片的消息高速緩存的步驟包括維護針對所述第一分片的第一消息高速緩存；以及

針對來自所述第一入隊器的每個消息，在所述第一消息高速緩存中存儲針對此消息的條目。

4.如權利要求3所述的方法，其中，針對所述特定訂戶將消息從所述特定隊列出隊包括：

通過從所述第一消息高速緩存讀取針對特定消息的條目，將由所述第一入隊器入隊的所述特定消息出隊，而無需執行訪問所述隊列表的任何分區的數據庫命令。

5.如權利要求3所述的方法，其中：

通過使用數據庫事務，所述第一入隊器在所述特定隊列中將一個或多個消息入隊；

該一個或多個消息對應于所述第一消息高速緩存中的一個或多個特定條目；

在所述數據庫事務提交之前，存儲到所述第一消息高速緩存中的對應于該一個或多個消息的條目包括該一個或多個消息對出隊器不可見的指示；以及

所述方法還包括：響應于檢測到所述數據庫事務的提交，更新所述一個或多個特定條目中的每個條目以指示對應于該條目的消息對出隊器可見。

6.如權利要求5所述的方法，其中：

所述消息高速緩存中的所述一個或多個特定條目中的特定條目對應于作為所述數據庫事務的一部分被入隊的第一消息；以及

所述方法還包括：對該特定條目，重置在所述數據庫事務提交時在所述第一消息高速緩存內經過該特定條目的一個或多個出隊指針。

7.如權利要求1所述的方法，其中由關系數據庫系統維護的出隊日志表在所述出隊日志表的分區內存儲跟蹤信息，該跟蹤信息跟蹤訂戶將消息從所述特定隊列出隊的出隊進展。

8.如權利要求7所述的方法，還包括：

響應于所述特定訂戶將對應于所述隊列表的給定分區中的給定行的消息出隊，更新所述出隊日志表的特定分區中的特定行；

其中所述特定行對應于所述給定行，并且所述特定分區對應于所述給定分區。

9.如權利要求8所述的方法，還包括，在故障之后，至少部分地基于所述出隊日志表的內容，在易失性存儲器中重建針對所述第一分片的消息高速緩存。