SYSTEM FOR HIGH-THROUGHPUT HANDLING OF TRANSACTIONS IN A DATA-PARTITIONED, DISTRIBUTED, RELATIONAL DATABASE MANAGEMENT SYSTEM

摘要

The present invention is directed to a novel, a topic-based messaging architecture (including schema, protocols, naming conventions, etc.) to be used in a distributed data-oriented OLTP environment. According to an aspect of the claimed subject matter, the topic-based messaging architecture can be implemented as a type of publication-subscription (“pub-sub”) messaging pattern. In one or more embodiments of the topic-based system, messages are published to “topics,” or named logical channels. Subscribers in a topic-based system will receive all messages published to the topics to which they subscribe, and all subscribers to a topic will receive the same messages. The publisher is responsible for defining the classes of messages to which subscribers can subscribe. The topic-based messaging interface improves the scalability of a distributed database management system and provides a robust mechanism for message delivery.

主权项

1. A computing device for executing data-oriented transactions in a distributed, multi-partition data management system, the computing device comprising:
a memory operable to store a plurality of programmed instructions; a processor configured to execute the plurality of programmed instructions to perform data-oriented transactions by generating an execution plan for performing database actions in a database stored across a plurality of partitions comprised in a plurality of remote computing devices, allocating a commit channel for database action instructions, and determining a logic corresponding to the commit channel, the logic channel being mapped to at least one remote computing device of the plurality of remote computing devices; and a message bus communicatively coupling the computing device with the plurality of remote computing devices, wherein the processor is further configured to identify and distribute instructions to perform a database action to the at least one remote computing device based on the logic channel, wherein the execution plan organizes the database actions among a plurality of phases separated by a plurality of synchronization points, further wherein database actions corresponding to a same phase of the plurality of phases are performed in parallel with results from each phase of the plurality of phases being collected at a synchronization point of the plurality of synchronization points corresponding to the phase.