US 11,768,855 B1
Replicating data across databases by utilizing validation functions for data completeness and sequencing
Abhishek Hodavdekar, Austin, TX (US); Eric A. Pinkham, Oakland, CA (US); Jeffrey Jow, Bellevue, WA (US); and Nathan D. Howell, Palo Alto, CA (US)
Assigned to Marqeta, Inc., Oakland, CA (US)
Filed by Marqeta, Inc., Oakland, CA (US)
Filed on Sep. 29, 2022, as Appl. No. 17/936,684.
Application 17/936,684 is a continuation of application No. 17/821,096, filed on Aug. 19, 2022.
Int. Cl. G06F 16/00 (2019.01); G06F 16/27 (2019.01)
CPC G06F 16/273 (2019.01) 20 Claims
OG exemplary drawing
 
1. A computer-implemented method comprising:
determining, by at least one processor in response to a request to merge data from one or more source servers to one or more destination servers, a plurality of database events corresponding to a card account transaction, wherein each database event of the plurality of database events comprises a database operation at the one or more source servers to write data to one or more database tables, delete data from the one or more database tables, or modify data at the one or more database tables, w herein determining the plurality of database events comprises:
accessing the plurality of database events from a plurality of log files at a plurality of source database tables according to a source schema at the one or more source servers; and
appending the plurality of database events from the plurality of source database tables into an event queue comprising an event history corresponding to the card account transaction;
determining, by the at least one processor for the plurality of database events, a plurality of database tables accessed at the one or more source servers to write, delete, or modify data in the plurality of database tables via a plurality of database operations in connection with the card account transaction according to event identifiers generated for the plurality of database events by the one or more source servers;
validating, by the at least one processor for the plurality of database tables, subsets of database events of the plurality of database events based on quantities of the subsets of database events and sequences of event identifiers generated for the subsets of database events by the one or more source servers; and
replicating, by the at least one processor in response to validating the subsets of database events, the plurality of database events from the one or more source servers to the one or more destination servers according to the source schema.