[發(fā)明專利]一種數(shù)據(jù)庫集群的數(shù)據(jù)節(jié)點(diǎn)擴(kuò)展方法及裝置

在審

• 申請?zhí)枺?/td>: 201710028521.1
• 申請日: 2017-01-16
• 公開（公告）號: CN106777344A
• 公開（公告）日: 2017-05-31
• 發(fā)明（設(shè)計(jì)）人: 岳遠(yuǎn)方
• 申請（專利權(quán)）人: 鄭州云海信息技術(shù)有限公司
• 主分類號: G06F17/30
• 分類號: G06F17/30
• 代理公司: 北京集佳知識產(chǎn)權(quán)代理有限公司11227
• 代理人: 羅滿

技術(shù)領(lǐng)域

本發(fā)明涉及數(shù)據(jù)節(jié)點(diǎn)擴(kuò)展技術(shù)領(lǐng)域，更具體地說，涉及一種Postgres-XL數(shù)據(jù)庫集群的數(shù)據(jù)節(jié)點(diǎn)擴(kuò)展方法及裝置。

背景技術(shù)

Postgres-XL是一個(gè)基于PostgreSQL數(shù)據(jù)庫的橫向擴(kuò)展開源SQL數(shù)據(jù)庫集群，具有足夠的靈活性來處理不同的數(shù)據(jù)庫工作負(fù)載。在使用基于Postgres-XL數(shù)據(jù)庫集群時(shí)，若想增加數(shù)據(jù)節(jié)點(diǎn)，目前只能在判定待添加的節(jié)點(diǎn)的信息正確時(shí)，通過手動執(zhí)行add_datanode接口添加節(jié)點(diǎn)，每次只能增加一個(gè)數(shù)據(jù)節(jié)點(diǎn)，也就是說，原生集群是不支持批量增加數(shù)據(jù)節(jié)點(diǎn)的，只能通過命令重復(fù)多次的添加，不僅添加速度慢，還增加人工成本。

因此，如何實(shí)現(xiàn)批量的添加數(shù)據(jù)節(jié)點(diǎn)，減少人工成本，是本領(lǐng)域技術(shù)人員需要解決的問題。

發(fā)明內(nèi)容

本發(fā)明的目的在于提供一種Postgres-XL數(shù)據(jù)庫集群的數(shù)據(jù)節(jié)點(diǎn)擴(kuò)展方法及裝置，以實(shí)現(xiàn)實(shí)現(xiàn)批量的添加數(shù)據(jù)節(jié)點(diǎn)，減少人工成本。

為實(shí)現(xiàn)上述目的，本發(fā)明實(shí)施例提供了如下技術(shù)方案：

一種Postgres-XL數(shù)據(jù)庫集群的數(shù)據(jù)節(jié)點(diǎn)擴(kuò)展方法，包括：

獲取待添加的多個(gè)數(shù)據(jù)節(jié)點(diǎn)的節(jié)點(diǎn)信息；

將每個(gè)數(shù)據(jù)節(jié)點(diǎn)的節(jié)點(diǎn)信息，按照信息類型分別存入對應(yīng)的容器；

統(tǒng)計(jì)待添加的數(shù)據(jù)節(jié)點(diǎn)的總節(jié)點(diǎn)數(shù)量，根據(jù)所述總結(jié)點(diǎn)數(shù)量生成對應(yīng)的節(jié)點(diǎn)添加指令，通過所述節(jié)點(diǎn)添加指令多次調(diào)用add_datanode接口進(jìn)行節(jié)點(diǎn)的添加。

其中，所述將每個(gè)數(shù)據(jù)節(jié)點(diǎn)的節(jié)點(diǎn)信息，按照信息類型分別存入對應(yīng)的容器，包括：

將每個(gè)數(shù)據(jù)節(jié)點(diǎn)的節(jié)點(diǎn)地址信息存入節(jié)點(diǎn)地址容器，將每個(gè)數(shù)據(jù)節(jié)點(diǎn)的端口號信息存入端口號容器，將每個(gè)數(shù)據(jù)節(jié)點(diǎn)的節(jié)點(diǎn)名稱信息存入節(jié)點(diǎn)名稱容器；其中，同一數(shù)據(jù)節(jié)點(diǎn)的節(jié)點(diǎn)地址信息、端口號信息、節(jié)點(diǎn)名稱信息在對應(yīng)容器的下標(biāo)相同。

其中，所述根據(jù)所述總結(jié)點(diǎn)數(shù)量生成對應(yīng)的節(jié)點(diǎn)添加指令，包括：

若所述總結(jié)點(diǎn)數(shù)量為N，則生成的節(jié)點(diǎn)添加指令為：執(zhí)行N次add_datanode函數(shù)，從而實(shí)現(xiàn)添加N個(gè)數(shù)據(jù)節(jié)點(diǎn)；其中，N為正整數(shù)。

其中，所述通過所述節(jié)點(diǎn)添加指令多次調(diào)用add_datanode接口進(jìn)行節(jié)點(diǎn)的添加，包括：

從各個(gè)容器中獲取與待添加的目標(biāo)數(shù)據(jù)節(jié)點(diǎn)對應(yīng)的節(jié)點(diǎn)信息；

判斷與目標(biāo)數(shù)據(jù)節(jié)點(diǎn)對應(yīng)的節(jié)點(diǎn)信息是否正確；

若是，則調(diào)用add_datanode接口添加目標(biāo)節(jié)點(diǎn)，選定下一個(gè)待添加的目標(biāo)數(shù)據(jù)節(jié)點(diǎn)，并繼續(xù)執(zhí)行所述從各個(gè)容器中獲取與待添加的目標(biāo)數(shù)據(jù)節(jié)點(diǎn)對應(yīng)的節(jié)點(diǎn)信息的步驟；

若否，則發(fā)出節(jié)點(diǎn)信息錯(cuò)誤提示，選定下一個(gè)待添加的目標(biāo)數(shù)據(jù)節(jié)點(diǎn)，并繼續(xù)執(zhí)行所述從各個(gè)容器中獲取與待添加的目標(biāo)數(shù)據(jù)節(jié)點(diǎn)對應(yīng)的節(jié)點(diǎn)信息的步驟。

一種Postgres-XL數(shù)據(jù)庫集群的數(shù)據(jù)節(jié)點(diǎn)擴(kuò)展裝置，包括：

獲取模塊，用于獲取待添加的多個(gè)數(shù)據(jù)節(jié)點(diǎn)的節(jié)點(diǎn)信息；

存儲模塊，用于將每個(gè)數(shù)據(jù)節(jié)點(diǎn)的節(jié)點(diǎn)信息，按照信息類型分別存入對應(yīng)的容器；

指令生成模塊，用于統(tǒng)計(jì)待添加的數(shù)據(jù)節(jié)點(diǎn)的總節(jié)點(diǎn)數(shù)量，根據(jù)所述總結(jié)點(diǎn)數(shù)量生成對應(yīng)的節(jié)點(diǎn)添加指令；

節(jié)點(diǎn)添加模塊，用于通過所述節(jié)點(diǎn)添加指令多次調(diào)用add_datanode接口進(jìn)行節(jié)點(diǎn)的添加。

其中，所述存儲模塊將每個(gè)數(shù)據(jù)節(jié)點(diǎn)的節(jié)點(diǎn)地址信息存入節(jié)點(diǎn)地址容器，將每個(gè)數(shù)據(jù)節(jié)點(diǎn)的端口號信息存入端口號容器，將每個(gè)數(shù)據(jù)節(jié)點(diǎn)的節(jié)點(diǎn)名稱信息存入節(jié)點(diǎn)名稱容器；其中，同一數(shù)據(jù)節(jié)點(diǎn)的節(jié)點(diǎn)地址信息、端口號信息、節(jié)點(diǎn)名稱信息在對應(yīng)容器的下標(biāo)相同。

其中，若所述總結(jié)點(diǎn)數(shù)量為N，則所述指令生成模塊生成的節(jié)點(diǎn)添加指令為：執(zhí)行N次add_datanode函數(shù)，從而實(shí)現(xiàn)添加N個(gè)數(shù)據(jù)節(jié)點(diǎn)；其中，N為正整數(shù)。

其中，所述節(jié)點(diǎn)添加模塊包括：

節(jié)點(diǎn)信息獲取單元，用于從各個(gè)容器中獲取與待添加的目標(biāo)數(shù)據(jù)節(jié)點(diǎn)對應(yīng)的節(jié)點(diǎn)信息；

判斷單元，用于判斷與目標(biāo)數(shù)據(jù)節(jié)點(diǎn)對應(yīng)的節(jié)點(diǎn)信息是否正確；

第一添加單元，用于判定與目標(biāo)數(shù)據(jù)節(jié)點(diǎn)對應(yīng)的節(jié)點(diǎn)信息正確時(shí)，調(diào)用add_datanode接口添加目標(biāo)節(jié)點(diǎn)，選定下一個(gè)待添加的目標(biāo)數(shù)據(jù)節(jié)點(diǎn)，并觸發(fā)所述節(jié)點(diǎn)信息獲取單元；

第二添加單元，用于判定與目標(biāo)數(shù)據(jù)節(jié)點(diǎn)對應(yīng)的節(jié)點(diǎn)信息不正確時(shí)，發(fā)出節(jié)點(diǎn)信息錯(cuò)誤提示，選定下一個(gè)待添加的目標(biāo)數(shù)據(jù)節(jié)點(diǎn)，并觸發(fā)所述節(jié)點(diǎn)信息獲取單元。