Subscription-based change data capture mechanism using database triggers

    公开(公告)号:US11775554B2

    公开(公告)日:2023-10-03

    申请号:US17244547

    申请日:2021-04-29

    Applicant: SAP SE

    CPC classification number: G06F16/27 G06F16/2282 G06F16/2379

    Abstract: Disclosed herein are system, method, and computer program product embodiments for replicating data from a source database table to a target database table. An embodiment operates by maintaining a master logging table in communication with a source database table and a subscriber logging table. Thereafter, a copy of a first modification of data of the source database table is provided to the master logging table as a record, where the first record includes the copy of the first modification of data. Subsequently, upon determining that the first record in the master logging table is committed, a copy of the first record is provided to the subscriber logging table. And after identifying a first target database associated with the master logging table, the first record is sent to the first target database.

    Parallel reads of data staging table

    公开(公告)号:US11740836B2

    公开(公告)日:2023-08-29

    申请号:US17393562

    申请日:2021-08-04

    Applicant: SAP SE

    Abstract: Systems and methods to read records of a data staging table, where each record of the data staging table is associated with a package identifier, a key value of a record of a first database table, values of one or more non-key fields of the record of the first database table, and a database operation, include reading of one or more records of the data staging table, each of the read one or more records associated with a package identifier indicating the record is not being processed, and not including a same key value as any other record of the data staging table associated with a package identifier indicating the record is being processed, updating the package identifier of each of the read records of the data staging table to a first package identifier indicating that the record is being processed, creating a transaction record of a transaction queue associating the data staging table and the first package identifier, determining that the read one or more records have been processed, and, in response to the determination, deleting the one or more read rows from the data staging table and the transaction record.

    Maintenance events in a data replication system

    公开(公告)号:US11429635B2

    公开(公告)日:2022-08-30

    申请号:US16860257

    申请日:2020-04-28

    Applicant: SAP SE

    Abstract: Systems and methods include detection of changes to data of a plurality of source objects of a source system, replicating the data changes to corresponding ones of the plurality of target objects, and, during the detection of changes to data and the replication of the data changes: detecting a first change to a first source object, identifying a first maintenance event based on the detected first change; determining a first one or more solutions to resolve the first maintenance event; presenting the first maintenance event and the first one or more solutions to resolve the first maintenance event to a user; receiving an indication from the user of a first solution of the first one or more solutions to resolve the first maintenance event; and, in response to the indication, executing the first solution.

    Parallel processing of changes in a distributed system

    公开(公告)号:US11372838B2

    公开(公告)日:2022-06-28

    申请号:US16935663

    申请日:2020-07-22

    Applicant: SAP SE

    Abstract: Systems and methods include reception of a request for changed data of an object from a subscriber, determination of a logging table associated with the object and comprising a plurality of logging table entries, determination of a pointer to a last-processed entry of the logging table based on the object and the subscriber, definition of a plurality of sub-portions of logging table entries subsequent to the last-processed entry, and reconstruction and transfer of first data associated with a first one of the plurality of sub-portions to the subscriber using a first process, and reconstruction and transfer, in parallel with the first process, second data associated with a second one of the plurality of sub-portions to the subscriber using a second process.

    PARALLEL PROCESSING OF CHANGES IN A DISTRIBUTED SYSTEM

    公开(公告)号:US20220027337A1

    公开(公告)日:2022-01-27

    申请号:US16935663

    申请日:2020-07-22

    Applicant: SAP SE

    Abstract: Systems and methods include reception of a request for changed data of an object from a subscriber, determination of a logging table associated with the object and comprising a plurality of logging table entries, determination of a pointer to a last-processed entry of the logging table based on the object and the subscriber, definition of a plurality of sub-portions of logging table entries subsequent to the last-processed entry, and reconstruction and transfer of first data associated with a first one of the plurality of sub-portions to the subscriber using a first process, and reconstruction and transfer, in parallel with the first process, second data associated with a second one of the plurality of sub-portions to the subscriber using a second process.

    Sequential processing of changes in a distributed system

    公开(公告)号:US11150964B1

    公开(公告)日:2021-10-19

    申请号:US15931740

    申请日:2020-05-14

    Applicant: SAP SE

    Abstract: Systems and methods include reception of a request for changed data of an object from a subscriber, determination of a logging table associated with the object, determination of a pointer to a last-processed entry of the logging table based on the object and the subscriber, determination of one or more entries of the logging table subsequent to the last-processed entry, determination of a last entry of the determined one or more entries, buffering of a pointer to the last entry, transferring of data reconstructed based on the one or more entries to the subscriber, and, in response to a determination that the transfer of data was successful, updating of the pointer to the last-processed entry of the logging table with the buffered pointer.

Patent Agency Ranking