Database management techniques for concurrent write request processing
AssigneeOptum, Inc.
InventorPaul W. Vaughan
Life of this patent
Estimating the term…
Abstract
Various embodiments of the present invention provide methods, apparatuses, systems, computing devices, computing entities, and/or the like for facilitating efficient and effective execution of database management operations. For example, various embodiments of the present invention describe techniques for performing one or more database update operations given a concurrent write request group for a database using P concurrent request processor computing nodes, a match result serialization queue, and a centralized match result serializer computing node.
Claims20
A computer-implemented method for performing one or more database update operations given a concurrent write request group for a database, the computer-implemented method comprising:
- identifying, using one or more processors, a match result serialization queue, wherein:
- (i) the match result serialization queue describes a serialization ordering of one or more unprocessed match result entries, (ii) each unprocessed match result entry corresponds to an unprocessed concurrent match result determination that has not been processed, and (iii) processing a particular unprocessed concurrent match result determination comprises generating a match result validation determination for the particular unprocessed concurrent match result determination;
- and
- performing, using the one or more processors, the one or more database update operations using the match result serialization queue, comprising, for each selected unprocessed match result entry that is selected from the one or more unprocessed match result entries described by the match result serialization queue in accordance with the serialization ordering:
- identifying a recently-processed match result list comprising one or more recently-processed match result entries, wherein:
- (i) each recently-processed match result entry corresponds to a recently-processed match result determination, and (ii) each recently-processed match result determination has been assigned an affirmative match result validation during a defined recency period before a current processing time,
- generating, based at least in part on whether the selected unprocessed match result entry matches at least one of the one or more recently-processed match result entries and using a centralized match result serializer computing node, a serialized match result determination for the selected unprocessed match result entry, wherein the recently-processed match result list is stored on a local storage medium of the centralized match result serializer computing node,
- generating, based at least in part on the serialized match result determination for the selected unprocessed match result entry, the match result validation determination for the selected unprocessed match result entry, and
- in response to determining that the match result validation determination for the selected unprocessed match result entry is a negative match result validation determination:
- (i) adding a new concurrent write request for the selected unprocessed match result entry to the concurrent write request group, and (ii) removing the selected unprocessed match result entry from the one or more unprocessed match result entries as described by the match result serialization queue.
A computing system for performing one or more database update operations given a concurrent write request group for a database, the computing system comprising one or more processors and a memory including program code, the memory and the program code configured to, with the one or more processors, cause the computing system to at least:
- identify, a match result serialization queue, wherein:
- (i) the match result serialization queue describes a serialization ordering of one or more unprocessed match result entries, (ii) each unprocessed match result entry corresponds to an unprocessed concurrent match result determination that has not been processed, and (iii) processing a particular unprocessed concurrent match result determination comprises generating a match result validation determination for the particular unprocessed concurrent match result determination;
- and
- perform the one or more database update operations using the match result serialization queue, comprising, for each selected unprocessed match result entry that is selected from the one or more unprocessed match result entries described by the match result serialization queue in accordance with the serialization ordering:
- identifying a recently-processed match result list comprising one or more recently-processed match result entries, wherein:
- (i) each recently-processed match result entry corresponds to a recently-processed match result determination, and (ii) each recently-processed match result determination has been assigned an affirmative match result validation during a defined recency period before a current processing time,
- generating, based at least in part on whether the selected unprocessed match result entry matches at least one of the one or more recently-processed match result entries and using a centralized match result serializer computing node, a serialized match result determination for the selected unprocessed match result entry, wherein the recently-processed match result list is stored on a local storage medium of the centralized match result serializer computing node,
- generating, based at least in part on the serialized match result determination for the selected unprocessed match result entry, the match result validation determination for the selected unprocessed match result entry, and
- in response to determining that the match result validation determination for the selected unprocessed match result entry is a negative match result validation determination:
- (i) adding a new concurrent write request for the selected unprocessed match result entry to the concurrent write request group, and (ii) removing the selected unprocessed match result entry from the one or more unprocessed match result entries as described by the match result serialization queue.
A computer program product for performing one or more database update operations given a concurrent write request group for a database, the computer program product comprising at least one non-transitory computer-readable storage medium having computer-readable program code portions stored therein, the computer-readable program code portions configured to:
- identify, a match result serialization queue, wherein:
- (i) the match result serialization queue describes a serialization ordering of one or more unprocessed match result entries, (ii) each unprocessed match result entry corresponds to an unprocessed concurrent match result determination that has not been processed, and (iii) processing a particular unprocessed concurrent match result determination comprises generating a match result validation determination for the particular unprocessed concurrent match result determination;
- and
- perform the one or more database update operations using the match result serialization queue, comprising, for each selected unprocessed match result entry that is selected from the one or more unprocessed match result entries described by the match result serialization queue in accordance with the serialization ordering:
- identifying a recently-processed match result list comprising one or more recently-processed match result entries, wherein:
- (i) each recently-processed match result entry corresponds to a recently-processed match result determination, and (ii) each recently-processed match result determination has been assigned an affirmative match result validation during a defined recency period before a current processing time,
- generating, based at least in part on whether the selected unprocessed match result entry matches at least one of the one or more recently-processed match result entries and using a centralized match result serializer computing node, a serialized match result determination for the selected unprocessed match result entry, wherein the recently-processed match result list is stored on a local storage medium of the centralized match result serializer computing node,
- generating, based at least in part on the serialized match result determination for the selected unprocessed match result entry, the match result validation determination for the selected unprocessed match result entry, and
- in response to determining that the match result validation determination for the selected unprocessed match result entry is a negative match result validation determination:
- (i) adding a new concurrent write request for the selected unprocessed match result entry to the concurrent write request group, and (ii) removing the selected unprocessed match result entry from the one or more unprocessed match result entries as described by the match result serialization queue.
Dependencies are inferred from the claim text.