Client-driven commit of distributed write transactions in a database environment

Patent metadata

Field	Value
Publication number	US-2021209092-A1
Application number	US-202117150868-A
Country	US
Kind code	A1
Filing date	Jan 15, 2021
Priority date	Jun 1, 2017
Publication date	Jul 8, 2021
Grant date	—

Abstract

Technologies are described for facilitating transaction processing in a distributed database environment. A database client sends database operations to a slave node, which mediates execution of the transaction. A connection between the database client and the slave node is associated with an identifier, and the transaction has an identifier. The database client sends a commit request to a master node over a network connection between the master node and the database client. The commit request includes the transaction identifier. The commit request can also include an indication of database nodes executing operations in the transaction.

First claim

What is claimed is:

1 . A method, implemented in a computing environment comprising a computing system implementing a coordinator node, the coordinator node in communication with a database client and at least first and second worker nodes, the computing system comprising at least one hardware processor and at least one memory coupled to the at least one hardware processor, the method comprising, by the coordinator node:
receiving a commit request from the database client, the commit request comprising a transaction identifier associated with a connection between the first worker node and the database client and a transaction having its execution mediated by the first worker node; sending precommit requests to the first and second worker nodes; marking the transaction as committed; and sending commit requests to the first and second worker nodes.

2 . The method of claim 1 , wherein the transaction does not include a write operation executed by the coordinator node.

3 . The method of claim 1 , wherein the commit request received from the database client further comprises a list of worker nodes involved in the transaction and precommit and commit requests are sent to nodes in the list.

4 . The method of claim 3 , further comprising:
calculating a checksum of the list; comparing the checksum with a reference value; and determining that the checksum matches the reference value.

5 . The method of claim 1 , further comprising:
receiving a notification that the transaction includes a write operation at the first worker node or the second worker node, when the notification is received before the write operation has completed.

6 . The method of claim 5 , wherein the notification that the transaction includes a write operation at the first worker node or the second worker node is received from the database client.

7 . The method of claim 5 , wherein the notification that the transaction includes a write operation at the first worker node or the second worker node is received from the first worker node.

8 . A computing system that implements a coordinator node, the coordinator node in communication with a database client and at least first and second worker nodes, the computing system comprising:
at least one hardware processor; at least one memory coupled to the at least one hardware processor; and one or more computer-readable storage media storing instructions that, when executed, cause the computing system to perform operations comprising:
receiving a commit request from the database client, the commit request comprising a transaction identifier associated with a connection between the first worker node and the database client and a transaction having its execution mediated by the first worker node;
sending precommit requests to the first and second worker nodes;
marking the transaction as committed; and
sending commit requests to the first and second worker nodes.

9 . The computing system of claim 8 , wherein the transaction does not include a write operation executed by the coordinator node.

10 . The computing system of claim 8 , wherein the commit request received from the database client further comprises a list of worker nodes involved in the transaction and precommit and commit requests are sent to nodes in the list.

11 . The computing system of claim 10 , the operations further comprising:
calculating a checksum of the list; comparing the checksum with a reference value; and determining that the checksum matches the reference value.

12 . The computing system of claim 8 , the operations further comprising:
receiving a notification that the transaction includes a write operation at the first worker node or the second worker node, when the notification is received before the write operation has completed.

13 . The computing system of claim 12 , wherein the notification that the transaction includes a write operation at the first worker node or the second worker node is received from the database client.

14 . The computing system of claim 12 , wherein the notification that the transaction includes a write operation at the first worker node or the second worker node is received from the first worker node.

15 . One or more computer readable storage media comprising:
computer-executable instructions that, when executed by a computing system implementing a database client, the database client being in communication with a master node and one or more slave nodes in a distributed database environment, the computing system comprising at least one hardware processor and at least one memory coupled to the at least one hardware processor, cause the computing system to establish a network connection with a first slave node of the one or more slave nodes; computer-executable instructions that, when executed by the computing system, cause the computing system to send a database operation for a transaction to be executed to the first slave node; computer-executable instructions that, when executed by the computing system, cause the computing system to generate a commit request for the transaction and to be sent to the distributed database system for execution to initiate a commit process for the transaction; and computer-executable instructions that, when executed by the computing system, cause the computing system to send the commit request for the transaction to the master node over a network connection between the database client and the master node.

16 . The one or more computer readable storage media of claim 15 , wherein the commit request comprises a list of nodes involved the transaction.

17 . The one or more computer readable storage media of claim 15 , wherein the commit request comprises information from which the master node can determine nodes involved in the transaction.

18 . The one or more computer readable storage media of claim 15 , further comprising:
computer-executable instructions that, when executed by the computing system, cause the computing system to, contemporaneously with sending the database operation to be executed to the first slave node, send a communication to the master node comprising information sufficient for the master node to determine the identity of a slave node of the one or more slaves nodes responsible for executing the database operation.

19 . The one or more computer readable storage media of claim 15 , further comprising:
computer-executable instructions that, when executed by the computing system, cause the computing system to, prior to sending the commit request, establish a network connection with the master node.

20 . The one or more computer readable storage media of claim 15 , wherein the transaction does not include a write operation executed by the master node.

21 . The one or more computer readable storage media of claim 15 , further comprising:
computer-executable instructions that, when executed by the computing system, cause the computing system to receive from the first slave node a node identifier for a node executing the database operation.

22 . The one or more computer readable storage media claim 21 , further comprising:
computer-executable instructions that, when executed by the computing system, cause the computing system to add the node identifier to a list of node identifiers associated with the transaction.

23 . A computing system that implements a database client, the database client being in communication with a distribute

Assignees

• Sap Se

Inventors

• Lee Juchang
• Kim Deok Koo
• Park Chang Gyoo
• Sung Nosub

Classifications

• G06F16/2365 Primary

  Ensuring data consistency and integrity · CPC title

• G06F16/28

  Databases characterised by their database models, e.g. relational or object models · CPC title