Granted Patent B2

US 12,443,624 · App. 18/573,942 · Granted Oct 14, 2025

Inventor: Zechao Zhuang (Hangzhou, CN)

Assignee: HANGZHOU ALICLOUD FEITIAN INFORMATION TECHNOLOGY CO., LTD.

G06F16/275G06F16/2358G06F16/2474

Abstract

Claims (50)

1. A data processing method, the method comprising, by a read-write node of a database system:

generating a temporary copy page when a data page does not satisfy a condition for writing into a disk; wherein the copy page comprises: a first sequence identifier of a log corresponding to modification of the data page at a first time, a second sequence identifier of a log corresponding to modification of the data page at a second time, and data information of the data page after a plurality of modifications over a period from the first time to the second time, the first time being earlier than the second time, and the second sequence identifier in the copy page being fixed without variation;

executing an operation of updating the first sequence identifier corresponding to the data page in the disk to the second sequence identifier in the copy page when the copy page satisfies the condition for writing into the disk, and

replacing the data page in the disk with the copy page to complete a data information update operation; and

wherein the data information update operation comprises an operation of replacing data information comprised in the data page in the disk with the data information comprised in the copy page.

2. The method according to claim 1 , further comprising:

acquiring sequence identifiers of logs applied by at least one read-only node;

determining a safe sequence identifier according to the sequence identifiers of the logs applied by the at least one read-only node; and

the copy page satisfying the condition for writing into the disk when the second sequence identifier is less than or equal to the safe sequence identifier.

3. The method according to claim 2 , wherein determining the safe sequence identifier according to the sequence identifiers of the logs applied by the at least one read-only node comprises:

determining a minimum sequence identifier according to the sequence identifiers of the logs applied by the at least one read-only node; and

using the minimum sequence identifier as the safe sequence identifier.

4. The method according to claim 2 , further comprising:

periodically sending read log position information to the at least one read-only node, the read log position information comprising a maximum sequence identifier among sequence identifiers of logs readable by the at least one read-only node from a shared storage; and

periodically receiving apply log position information fed back from the at least one read-only node, the apply log position information comprising sequence identifiers of logs applied by the at least one read-only node.

5. The method according to claim 1 , further comprising:

receiving a write request for the data page;

modifying the data page in a memory and generating a corresponding log according to the write request;

assigning a sequence identifier to the log; and

sending the log to a disk of a shared storage for storage.

6. The method according to claim 5 , wherein the data page is a hot page with a write request frequency greater than a preset frequency.

7. A non-transitory computer-readable storage medium that stores a computer program that, when executed by a computer, is capable of implementing steps of the method of claim 1 .

8. A data processing method, the method comprising, by a read-only node of a database system:

reading logs from a shared storage;

storing the read logs in a memory;

deleting, from the memory, logs respectively corresponding to a plurality of modifications of a data page over a period from a first time to a second time, after determining that a first sequence identifier corresponding to the data page is updated to a second sequence identifier comprised in a temporary copy page; and

wherein the copy page is generated when the data page does not satisfy a condition for writing into a disk, the copy page comprising: the first sequence identifier of a log corresponding to modification of the data page at the first time, the second sequence identifier of a log corresponding to modification of the data page at the second time, and data information of the data page after the plurality of modifications over the period from the first time to the second time, the first time being earlier than the second time, and the second sequence identifier in the copy page being fixed without variation;

wherein the data page in the disk is replaced with the copy page when the copy page satisfies the condition for writing into the disk, to complete a data information update operation; and

wherein the data information update operation comprises an operation of replacing data information comprised in the data page in the disk with the data information comprised in the copy page.

9. The method according to claim 8 , further comprising:

receiving a read request for the data page;

applying a log stored in the memory corresponding to modification of the data page at a third time to modify the data page, wherein the third time is later than the second time; and

providing, in response to the read request, feedback on the modified data page.

10. An electronic device comprising:

a processor; and

a memory comprising at least one instruction, at least one program, a code set, or an instruction set wherein the at least one instruction, the at least one program, the code set, or the instruction set is configured to be loaded and executed by the processor to implement the data processing method of claim 8 .

11. A non-transitory computer-readable storage medium that stores a computer program that, when executed by a computer, is capable of implementing steps of the method of claim 8 .

12. A database system, comprising:

a read-write node configured for:

generating a temporary copy page when a data page does not satisfy a condition for writing into a disk, wherein the copy page comprises: a first sequence identifier of a log corresponding to modification of the data page at a first time, a second sequence identifier of a log corresponding to modification of the data page at a second time, and data information of the data page after a plurality of modifications over a period from the first time to the second time, the first time being earlier than the second time, and the second sequence identifier in the copy page being fixed without variation;

executing an operation of updating the first sequence identifier corresponding to the data page in the disk to the second sequence identifier in the copy page when the copy page satisfies the condition for writing into the disk; and

replacing the data page in the disk with the copy page to complete a data information update operation; and wherein the data information update operation comprises an operation of replacing data information comprised in the data page in the disk with the data information comprised in the copy page;

a shared storage, having the disk, and configured for storing data pages and logs; and

a read-only node, configured for:

reading logs from the shared storage,

storing the read logs in a memory, and

deleting, from the memory, logs respectively corresponding to the plurality of modifications of the data page over the period from the first time to the second time after determining that the first sequence identifier corresponding to the data page is updated to the second sequence identifier comprised in the copy page.

13. An electronic device, comprising:

a processor; and

a memory comprising at least one instruction, at least one program, a code set, or an instruction set, wherein the at least one instruction, the at least one program, the code set, or the instruction set is configured to be loaded and executed by the processor to implement the data processing method of claim 1 .

Assignments (2)

Priority Claims (1)

Continuity (1)

References Cited (18)