[發明專利]數據處理方法、裝置、設備及存儲介質

在審

• 申請號: 202110033810.7
• 申請日: 2021-01-11
• 公開（公告）號: CN112765169A
• 公開（公告）日: 2021-05-07
• 發明（設計）人: 張揚
• 申請（專利權）人: 北京眾享比特科技有限公司
• 主分類號: G06F16/22
• 分類號: G06F16/22;G06F16/23;G06F16/242;G06F16/27
• 代理公司: 北京志霖恒遠知識產權代理事務所(普通合伙) 11435
• 代理人: 郭棟梁

1.一種數據處理方法，其特征在于，所述方法包括：

接收客戶端發送的數據處理請求，所述數據處理請求中攜帶有待處理數據；

響應于所述數據處理請求，基于預設的行分片規則和列分片規則對所述待處理數據進行處理生成處理結果；

將所述處理結果發送至所述客戶端。

2.根據權利要求1所述的方法，其特征在于，所述數據處理請求包括表創建請求，響應于所述數據處理請求，基于預設的行分片規則和列分片規則對所述待處理數據進行處理生成處理結果，包括：

響應于所述表創建請求，從所述待處理數據中提取數據庫表的列字段和所述數據庫表中的列前綴；

基于所述列前綴，確定所有第一列族分片；

對于每個所述第一列族分片，構建與所述第一列族分片對應的子表創建語句；

發送子表創建請求至每個第一列族分片服務器，以使得所述每個第一列族分片服務器對所述子表創建語句進行解析，創建子表；

當所有子表創建成功時，將主表結構與所述子表的映射關系存儲至全局表中。

3.根據權利要求1所述的方法，其特征在于，所述數據處理請求包括表刪除請求，響應于所述數據處理請求，基于預設的行分片規則和列分片規則對所述待處理數據進行處理生成處理結果，包括：

響應于所述表刪除請求，解析所述待處理語句，確定待刪除表名；

從全局表中確定所述待刪除表名對應的所有第二列族分片；

對于每個所述第二列族分片，構建與所述第二列族分片對應的子表刪除語句；

發送子表刪除請求至每個第二列族分片服務器，以使得所述第二列族分片服務器對所述子表刪除語句進行解析，刪除所述待刪除表名對應的子表；

當所有子表刪除成功時，將所述全局表中的主表結構與所述子表的映射記錄刪除。

4.根據權利要求1所述的方法，其特征在于，所述數據處理請求包括數據插入請求，響應于所述數據處理請求，基于預設的行分片規則和列分片規則對所述待處理數據進行處理生成處理結果，包括：

響應于所述數據插入請求，解析所述待處理語句，提取待插入列字段和插入值；

從全局表中確定所述待插入列字段對應的所有第三列族分片和第三列族分片服務器；

對于每個所述第三列族分片，構建與所述第三列族分片對應的子表插入語句；

發送子表數據插入請求至所述第三列族分片服務器，以使得所述第三列族分片服務器對所述子表插入語句進行解析，確定所述第三列族分片服務器對應的第一行服務器并將所述子表數據插入請求發送至所述第一行服務器；

接收插入結果，所述插入結果是所述第一行服務器接收并響應于所述子表數據插入請求，插入所述插入值后生成的。

5.根據權利要求1所述的方法，其特征在于，所述數據處理請求包括數據更新請求，響應于所述數據處理請求，基于預設的行分片規則和列分片規則對所述待處理數據進行處理生成處理結果，包括：

響應于所述數據更新請求，解析所述待處理語句，提取待更新列字段和更新值；

從全局表中確定所述待更新列字段對應的所有第四列族分片和第四列族分片服務器；

對于每個所述第四列族分片，構建與所述第四列族分片對應的數據查詢語句；

發送子表數據更新請求至所述第四列族分片服務器，以使得所述第四列族分片服務器對所述數據查詢語句進行解析，確定所述第四列族分片服務器對應的第二行服務器并將所述子表數據更新請求發送至所述第二行服務器；

接收更新結果，所述更新結果是所述第二行服務器接收并響應于所述子表數據更新請求，更新所述子表的更新值后生成的。