Granted Patent B2

US 12,346,303 · App. 18/070,758 · Granted Jul 1, 2025

Inventor: Haixiang Li (Shenzhen, CN)

Assignee: Tencent Technology (Shenzhen) Company Limited

G06F16/2322G06F16/2365

Abstract

Claims (81)

1. A method for transaction processing, performed by a computer device, the method comprising:

obtaining a read set and a write set of a target transaction in response to a read-write operation of the target transaction;

determining a logical begin time and a logical end time of the target transaction in response to a validation instruction of the target transaction;

in response to the logical begin time and the logical end time conforming to a concurrent consistency level of the target transaction, to obtain an updated logical begin time:

obtaining to-be-written transaction information of a data item in the write set, the to-be-written transaction information being used for identifying a transaction that is modifying the data item;

in response to each piece of the to-be-written transaction information being null:

using the to-be-written transaction information as a transaction identifier of the target transaction;

updating the logical begin time to make the updated logical begin time greater than a maximum read transaction time stamp of the data item, the maximum read transaction time stamp representing a maximum value in logical end times of transactions that have read the data item;

adjusting the logical begin time based on an active transaction set in response to the updated logical begin time and the logical end time conforming to the concurrent consistency level of the target transaction, the active transaction set identifying transactions that have started but have not been committed; and

rolling back the target transaction in response to the updated logical begin time and the logical end time not conforming to the concurrent consistency level of the target transaction; and

rolling back the target transaction in response to any piece of the to-be-written transaction information being not null; and

committing the target transaction in response to the updated logical begin time being less than or equal to the logical end time.

2. The method according to claim 1 , wherein:

the active transaction set comprises a first transaction set and a second transaction set, the first transaction set identifying transactions in a committing status or in a passing-validation status, and the second transaction set identifying transactions in a running status; and

adjusting the logical begin time comprises:

updating the logical begin time to make the updated logical begin time greater than a maximum logical end time among logical end times of all transactions in the first transaction set;

updating logical end time of each transaction identified by the second transaction set in response to the updated logical begin time being less than or equal to the logical end time, to make the logical end time of the each transaction being less than the updated logical begin time; and

rolling back the target transaction in response to the updated logical begin time being greater than the logical end time.

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

rolling back a transaction in the second transaction set in response to a logical begin time of the transaction being greater than the updated logical end time.

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

obtaining a concurrent transaction of the target transaction in response to the concurrent consistency level being serialization consistency;

obtaining a latest completed transaction time stamp of a session to which the target transaction belongs in response to the logical end time of the target transaction being less than a logical begin time of the concurrent transaction or the logical begin time of the target transaction being greater than a logical end time of the concurrent transaction; and

determining that the target transaction conforms to the concurrent consistency level in response to the logical end time of the target transaction being greater than or equal to the latest completed transaction time stamp.

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

obtaining a concurrent write transaction of the target transaction in response to the concurrent consistency level is strict serializability consistency and the target transaction is a write transaction;

obtaining a concurrent read-only transaction of the concurrent write transaction in response to the logical end time of the target transaction being less than a logical begin time of the concurrent write transaction or the logical begin time of the target transaction being greater than a logical end time of the concurrent write transaction;

obtaining a latest completed transaction time stamp of a session to which the target transaction belongs in response to a logical begin time of the concurrent read-only transaction being greater than the logical begin time of the concurrent write transaction; and

determining that the target transaction conforms to the concurrent consistency level in a case that the logical end time of the target transaction is greater than or equal to the latest completed transaction time stamp.

6. The method according to claim 1 , wherein the method further comprises:

obtaining a concurrent write transaction of the target transaction in response to the concurrent consistency level being linearizability serializability consistency and the target transaction being a write transaction;

obtaining a concurrent read-only transaction of the concurrent write transaction in response to the target transaction and the concurrent write transaction passing serializability validation;

obtaining a latest completed transaction time stamp of a session to which the target transaction belongs in response to a logical begin time of the concurrent read-only transaction being greater than the logical begin time of the concurrent write transaction; and

determining that the target transaction conforms to the concurrent consistency level in response to the logical end time of the target transaction being greater than or equal to the latest completed transaction time stamp.

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

obtaining a concurrent transaction of the target transaction in response to the concurrent consistency level being sequential serializability consistency;

determining a first transaction belonging to a same session with the target transaction in response to the target transaction and the concurrent transaction passing serializability validation;

obtaining a latest completed transaction time stamp of the session in response to the logical end time of the target transaction being less than a logical begin time of the first transaction;

determining that the target transaction conforms to the concurrent consistency level in response to the logical end time of the target transaction being greater than or equal to the newest completed transaction time stamp; and

in response to the target transaction and the first transaction having a causal relationship, updating a logical begin time of a result transaction in the causal relationship, such that an updated logical begin time of the result transaction is greater than a logical end time of a reason transaction in the causal relationship.

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

obtaining a concurrent transaction of the target transaction in response to the concurrent consistency level is serializability consistency;

determining a first transaction belonging to a same session with the target transaction in response to the target transaction and the concurrent transaction pass serializability validation; and

determining that it conforms to the concurrent consistency level in response to the logical end time of the target transaction is less than a logical begin time of the first transaction and the logical begin time is less than or equal to the logical end time.

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

obtaining a result transaction having a causal relationship with the target transaction and caused by the target transaction in response to the concurrent consistency level is causal repeatable read consistency; and

updating a logical begin time of the result transaction to make an updated logical begin time of the result transaction greater than the logical end time of the target transaction, to make the target transaction conform to the concurrent consistency level.

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

determining that the target transaction conforms to the concurrent consistency level in response to the concurrent consistency level being one of repeatable read consistency, read committed consistency, or read uncommitted consistency.

11. A device for transaction processing, the device comprising a memory for storing computer instructions and a processor in communication with the memory, wherein, when the processor executes the computer instructions, the processor is configured to cause the device to:

obtain a read set and a write set of a target transaction in response to a read-write operation of the target transaction;

determine a logical begin time and a logical end time of the target transaction in response to a validation instruction of the target transaction;

in response to the logical begin time and the logical end time conforming to a concurrent consistency level of the target transaction, to obtain an updated logical begin time:

obtain to-be-written transaction information of a data item in the write set, the to-be-written transaction information being used for identifying a transaction that is modifying the data item;

in response to each piece of the to-be-written transaction information being null:

use the to-be-written transaction information as a transaction identifier of the target transaction;

update the logical begin time to make the updated logical begin time greater than a maximum read transaction time stamp of the data item, the maximum read transaction time stamp representing a maximum value in logical end times of transactions that have read the data item;

adjust the logical begin time based on an active transaction set in response to the updated logical begin time and the logical end time conforming to the concurrent consistency level of the target transaction, the active transaction set identifying transactions that have started but have not been committed; and

roll back the target transaction in response to the updated logical begin time and the logical end time not conforming to the concurrent consistency level of the target transaction; and

roll back the target transaction in response to any piece of the to-be-written transaction information being not null; and

commit the target transaction in response to the updated logical begin time being less than or equal to the logical end time.

12. The device according to claim 11 , wherein:

the active transaction set comprises a first transaction set and a second transaction set, the first transaction set identifying transactions in a committing status or in a passing-validation status, and the second transaction set identifying transactions in a running status; and

when the processor is configured to cause the device to adjust the logical begin time, the processor is configured to cause the device to:

update the logical begin time to make the updated logical begin time greater than a maximum logical end time among logical end times of all transactions in the first transaction set;

update logical end time of each transaction identified by the second transaction set in response to the updated logical begin time being less than or equal to the logical end time, to make the logical end time of the each transaction being less than the updated logical begin time; and

roll back the target transaction in response to the updated logical begin time being greater than the logical end time.

13. The device according to claim 12 , wherein, when the processor executes the computer instructions, the processor is configured to further cause the device to:

roll back a transaction in the second transaction set in response to a logical begin time of the transaction being greater than the updated logical end time.

14. A non-transitory storage medium for storing computer readable instructions, the computer readable instructions, when executed by a processor, causing the processor to:

obtain a read set and a write set of a target transaction in response to a read-write operation of the target transaction;

determine a logical begin time and a logical end time of the target transaction in response to a validation instruction of the target transaction;

in response to the logical begin time and the logical end time conforming to a concurrent consistency level of the target transaction, to obtain an updated logical begin time:

obtain to-be-written transaction information of a data item in the write set, the to-be-written transaction information being used for identifying a transaction that is modifying the data item;

in response to each piece of the to-be-written transaction information being null:

use the to-be-written transaction information as a transaction identifier of the target transaction;

update the logical begin time to make the updated logical begin time greater than a maximum read transaction time stamp of the data item, the maximum read transaction time stamp representing a maximum value in logical end times of transactions that have read the data item;

adjust the logical begin time based on an active transaction set in response to the updated logical begin time and the logical end time conforming to the concurrent consistency level of the target transaction, the active transaction set identifying transactions that have started but have not been committed; and

roll back the target transaction in response to the updated logical begin time and the logical end time not conforming to the concurrent consistency level of the target transaction; and

roll back the target transaction in response to any piece of the to-be-written transaction information being not null; and

commit the target transaction in response to the updated logical begin time being less than or equal to the logical end time.

Assignments (1)

Priority Claims (1)

Continuity (2)

References Cited (23)