International Business Machines Corporation

James D Spyker

Paul Michael Cadarette

Yongfeng Yao

Nirmal Kumar

Pravin Kailashnath Kedia

Daniel Martin

Namik Hrle

Chandrasekaran Mohan

Anjan G Lukkoor

Dev K Sarkar

Sriram Kolinjivadi Padmanabhan

Alexander Gorelik

Sunil Sarin

Phillip Koza

Victor L Szabo

Christopher R G O'Quinn

Elaine Pang

Nina Li

Aspects of the present invention disclose a method, computer program product, and system for analyzing change stream data. The method includes identifying, by one or more computer processors, a list of changes in a replication stream. The method further includes determining, by one or more computer processors, if one or more changes in the list of changes matches a criteria for a hint. The method further includes in response to determining that one or more of the changes in the list of changes matches the criteria for a hint, inserting, by one or more computer processors, the hint into the list of changes prior to a first change of the one or more changes that triggers a match in criteria.

Supplementing change streams

A computer-implemented method for operating a database management system which includes a source database and a target database. A database management system is configured for asynchronously replicating data changes of the source database to the target database. The database management system receiving a request to perform a database statement. The method can identify the most recently committed one of a plurality of transactions having been committed in the source database before the receiving of the request. Identifying repeatedly the one of the plurality of transactions having been replicated most recently to the target database. Execution of the requested statement in the target database is delayed until an evaluation of the repeatedly identified most recently replicated transaction returns that the identified most recently committed transaction has been replicated to the target database. After the delaying execution, the method executes the requested statement in the target database.

Database management system and method of operation

A system and method for performing a dynamic rollover of source and target latency in a replication environment. One or more tables of a source data store being replicated to a target data store are parked, wherein any subsequent changes for the parked tables are not replicated to the target data store. Open transactions are identified where the parked tables affect the source and target latency, wherein the open transactions are in-progress and not completed. The source and target latency are then calculated for the identified open transactions.

Dynamic roll-over of source and target latency in a replication environment

A method, computer program product, and computer system for handling open transactions in a data replication environment is provided. The method includes determining a database user that initiated an earliest open transaction in a transaction log. The method further includes, upon determining that the database user does not have access privileges for one or more tables of a target database corresponding to one or more tables of a source database associated with the earliest open transaction, skipping replication of the earliest open transaction to the target database, such that the data replication system no longer waits for the earliest open transaction to complete. The skipping includes discarding, from the transaction log, one or more entries related to the earliest open transaction, and identifying, in the transaction log, a next earliest open transaction.

ACL based open transactions in replication environment

Provided are a computer program product, system, and method for performing conflict analysis of replicated changes among nodes in a network A first node and a second node include a first instance and second instance of a data set, respectively. The second node receives a first transaction replicated from the first node, applied to the first instance of the data set. The second node determines a conflict that would occur between the replicated first transaction and a second transaction applied to the second instance of the data set. A conflict policy is applied at the second node to perform a first action in response to determining the conflict. The conflict policy is applied to the first node to perform a second action at the first node to handle the conflict when the first node receives a replication of the second transaction to the second instance of the data set.

Performing conflict analysis of replicated changes among nodes in a network

A primary system is established at a first site. The primary system hosts an application and a primary database for remote users that use the application to manage data of the primary database. A unified data layer is established at a remote site. The unified data layer provides access to data of the primary database without providing access to the primary database. A triggering event that impairs the ability of the primary system to host the application is detected. A recovery system is instantiated in response to detecting the triggering event. The recovery system includes both a recovery instance of the application and a recovery database for the data of the application. The recovery database is populated using the unified data layer. The recovery system is activated such that remote users can access the recovery instance of the application to manage data of the recovery database.

Unified data layer backup system

A computer-implemented method for replicating the effect of batch jobs using a replication agent is provided. The computer-implemented method comprises a replicating agent maintaining a maximum level in rows and a minimum level in rows for one or more columns in a database table of one or more database systems. The replicating agent further analyzes a mapping defined in the replicating agent to identify source columns of a source database system of the one or more database systems which are mapped to a target column of a target database system of the one or more database systems. According to at least one embodiment, the replicating agent further identifies a logical clause of the source database system and the target database system to define a range refresh. The replication agent further initiates the defined range refresh.

Replication of batch jobs of computing systems

A method for replicating the effect of batch jobs using a replication agent is provided. The method comprises a replicating agent maintaining a maximum level in rows and a minimum level in rows for one or more columns in a database table of one or more database systems. The replicating agent further analyzes a mapping defined in the replicating agent to identify source columns of a source database system of the one or more database systems which are mapped to a target column of a target database system of the one or more database systems. According to at least one embodiment, the replicating agent further identifies a logical clause of the source database system and the target database system to define a range refresh. The replication agent further initiates the defined range refresh.

An approach for inter-table parallel refresh in a database management system (DBMS). An inter-table refresher receives DBMS source and target databases comprising source parent and related source child datasets. The inter-table refresher determines a collection of the source parent and the related source child datasets and creates a collection of parent and child refresh segments based on the collection of the source parent and child datasets. The inter-table refresher creates a collection of parent and child refresh batches based on the collection of parent and child refresh segments respectively and outputs an inter-table refresh batch schedule based on the collection of the parent refresh batches and the collection of the child refresh batches where the collection of the parent refresh batches and the collection of the child refresh batches operate concurrently and a current child refresh batch follows the completion of a respective current parent refresh batch.

Inter-table parallel refresh maximizer

A computer-implemented method includes, by a streaming analytics component, identifying a source database table and a target database table. The target database table includes one or more target database rows and one or more target database columns. The method further includes identifying a change stream including a plurality of row-level modifications that cause the target database table to replicate the source database table. The method further includes determining that each row-level modification affects one or more common columns of the target database columns, wherein the common columns exhibit one or more common values for those of the target database rows that are affected by the row-level modifications. The method further includes generating, based on the common values and the common columns, a reconstructed modification statement and sending the reconstructed modification statement to an apply component. A corresponding computer program product and computer system are also disclosed.

Change stream analytics for data replication systems

A method for handling of open transactions in a data replication environment. The method includes querying one or more tables of a source database to determine a first open transaction associated with the one or more tables of the source database. The method further includes determining a database user that initiated the first open transaction. The method further includes querying one or more tables of the target database corresponding to the one or more tables of the source database associated with the first open transaction, to determine whether the database user has access privileges for the one or more tables of the target database and dynamically skipping replication of the first open transaction to the target database, such that the data replication system no longer waits for the first open transaction to complete.

Growing community of inventors

Toronto, Canada

James D Spyker