| 摘要 |
Embodiments of the present application provide methods for updating a data table of a KeyValue database, including: receiving a full data updating instruction, acquiring to-be-imported data according to the full data updating instruction, and generating a full data updating file according to the to-be-imported data; acquiring M rows of old data in a data table corresponding to the full data updating instruction, and generating a full data deleting file according to M RowKeys of the M rows of old data; importing the full data updating file into the data table; and importing the full data deleting file into the data table. According to the present application, full updating of a data table of a KeyValue database can be implemented, and an updating speed is fast and atomicity is better. The embodiments of the present invention further provide a related apparatus for updating table data. |
| 主权项 |
1. A method for updating a data table of a KeyValue database, comprising:
receiving a full data updating instruction; acquiring to-be-imported data according to the full data updating instruction, and generating a full data updating file according to the to-be-imported data, wherein the full data updating file comprises P rows of new data, wherein each row of new data comprises one row key and Q new column qualifiers, wherein a data type of each new column qualifier is a put type, and an update timestamp is set for each new column qualifier; acquiring M rows of old data in a data table corresponding to the full data updating instruction, wherein each row of old data comprises one row key and N old column qualifiers, and an original timestamp is set for each old column qualifier; generating a full data deleting file according to the M rows of old data, wherein the full data deleting file comprises M rows of delete data; wherein each row of delete data is in a one-to-one correspondence with each row of old data; wherein a data type of each row of delete data is a delete type; wherein a delete timestamp is set for each row of delete data; wherein a delete timestamp of an Rth row of delete data is greater than a maximum value of an original timestamp of the Rth row of old data; wherein the delete timestamp of the Rth row of delete data is less than a minimum value of an update timestamp of an Sth row of new data; and wherein the Rth row of delete data, the Rth row of old data, and the Sth row of new data have a same RowKey, 1≦R≦M, and 1≦S≦P; importing the full data updating file into the data table; and importing the full data deleting file into the data table. |
