US 12,475,104 B2
Data processing method, distributed database system, electronic device and storage medium
Biao Lu, Hangzhou (CN); Yanfeng Lin, Hangzhou (CN); Xueqiang Wu, Hangzhou (CN); and Youyou Deng, Hangzhou (CN)
Assigned to HANGZHOU ALICLOUD FEITIAN INFORMATION TECHNOLOGY CO., LTD., Hangzhou (CN)
Appl. No. 18/685,170
Filed by HANGZHOU ALICLOUD FEITIAN INFORMATION TECHNOLOGY CO., LTD., Hangzhou (CN)
PCT Filed Oct. 11, 2022, PCT No. PCT/CN2022/124621
§ 371(c)(1), (2) Date Feb. 20, 2024,
PCT Pub. No. WO2023/066086, PCT Pub. Date Apr. 27, 2023.
Claims priority of application No. 202111207876.X (CN), filed on Oct. 18, 2021.
Prior Publication US 2024/0346010 A1, Oct. 17, 2024
Int. Cl. G06F 16/23 (2019.01); G06F 16/27 (2019.01)
CPC G06F 16/2365 (2019.01) [G06F 16/27 (2019.01)] 20 Claims
OG exemplary drawing
 
1. A data processing method, applied to a shard node of a distributed database system, comprising:
receiving a physical DDL instruction converted from a logic DDL instruction for change of data in the distributed database system;
executing the physical DDL instruction and generating a shard node mode snapshot for the shard node after the physical DDL instruction has been successfully executed, wherein the shard node mode snapshot corresponding to a shard node mode that is changed after the shard node has successfully executed the physical DDL instruction, wherein for each shard node, a shard node mode snapshot is generated for the shard node after the shard node has successfully executed the physical DDL instruction, and wherein the shard node mode snapshot describes logic structure and features of data stored in the corresponding shard node after the shard node has successfully executed the physical DDL instruction;
comparing the shard node mode snapshot with a global logic mode snapshot of the distributed database system, wherein the global logic mode snapshot corresponding to a global logic mode that is changed after all shard nodes in the database system have successfully executed the physical DDL instruction, wherein the global logic mode snapshot describes logic structure and features of all data stored in the all shard nodes in the database system; and
determining that the shard node mode snapshot is inconsistent with the global logic mode snapshot, adjusting log data of the shard node aggregated into a global log to be consistent with the global logic mode snapshot.