CPC G06F 16/214 (2019.01) [G06F 11/1469 (2013.01); G06F 16/2365 (2019.01); G06F 16/25 (2019.01)] | 16 Claims |
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.
|