US 11,928,089 B2
Data processing method and device for distributed database, storage medium, and electronic device
Longbo Guo, Shenzhen (CN); Yan Ding, Shenzhen (CN); Yiliang Xu, Shenzhen (CN); Peng Zhang, Shenzhen (CN); and Jiashun Lu, Shenzhen (CN)
Assigned to ZTE CORPORATION, Shenzhen (CN)
Appl. No. 16/754,150
Filed by ZTE Corporation, Shenzhen (CN)
PCT Filed Nov. 29, 2018, PCT No. PCT/CN2018/118243
§ 371(c)(1), (2) Date Apr. 5, 2021,
PCT Pub. No. WO2019/109854, PCT Pub. Date Jun. 13, 2019.
Claims priority of application No. 201711287703.7 (CN), filed on Dec. 7, 2017.
Prior Publication US 2022/0229822 A1, Jul. 21, 2022
Int. Cl. G06F 16/21 (2019.01); G06F 11/14 (2006.01); G06F 16/23 (2019.01); G06F 16/25 (2019.01)
CPC G06F 16/214 (2019.01) [G06F 11/1469 (2013.01); G06F 16/2365 (2019.01); G06F 16/25 (2019.01)] 16 Claims
OG exemplary drawing
 
1. A data processing method for a distributed database, comprising:
after receiving an export request for exporting data from the distributed database, acquiring, by a database import and export management node, an active transaction list and export table distribution information at a current moment, wherein the active transaction list is used for identifying a completion degree of a current data import and export operation, and the export table distribution information is used for identifying a database that needs to export the data;
notifying, by the database import and export management node, the corresponding database that the corresponding database performs a data export operation according to the export table distribution information;
after determining that the corresponding database completes the data export operation, sending, by the database import and export management node, the active transaction list to a database agent node of the corresponding database to instruct the database agent node to generate a data consistency reverse compensation statement according to the active transaction list and a current log of the corresponding database; and
after receiving the data consistency reverse compensation statement returned by the database agent node, importing, by the database import and export management node, the data exported by the corresponding database into a predetermined database and instructing the predetermined database to execute the data consistency reverse compensation statement.