Method, computer program product, and computer-implemented apparatus for monitoring a transaction stream and maintaining a transaction pattern table
A transaction pattern table is maintained using a transaction stream monitor that monitors a transaction stream. Transactions are completed within a transaction processing system, and transactions are replicated from a source database to a target database by a replication engine. The transaction pattern table includes a plurality of records. Each record includes a transaction pattern. Each completed transaction is a series of one or more transaction steps or operations, and the transaction pattern is a series of one or more transaction steps or operations of the completed transaction. In operation, each transaction step or operation is analyzed in the transaction stream by the transaction stream monitor. It is then detected as to whether a transaction step or operation begins a new transaction. Monitoring of the transaction stream continues for transaction steps or operations for the detected new transaction and the transaction steps or operations for the transaction for the detected new transaction are entered into a change pattern. A first action is taken with respect to the change pattern for the transaction for the detected new transaction when a transaction step or operation for the detected new transaction is an abort or rollback operation, and a second action is taken with respect to the change pattern for the transaction for the detected new transaction when a transaction step or operation for the detected new transaction is a commit operation.
1 . An automated method of maintaining a transaction pattern table using a transaction stream monitor that monitors a transaction stream from a change log, wherein transactions are completed within a transaction processing system, and wherein the transactions are replicated from a source database to a target database by a replication engine, the transaction pattern table including a plurality of records, each record including a transaction pattern, wherein each completed transaction is a series of one or more transaction steps or operations, and the transaction pattern is a series of one or more transaction steps or operations of the completed transaction, the method comprising:
(a) analyzing each transaction step or operation in the transaction stream from the change log by the transaction stream monitor;
(b) detecting whether a transaction step or operation begins a new transaction;
(c) continuing to monitor the transaction stream from the change log for transaction steps or operations for the detected new transaction and entering the transaction steps or operations into a change pattern for only the detected new transaction,
wherein the transaction pattern table maintains records for one or more transaction patterns; and
(d) taking a first action with respect to the change pattern for the detected new transaction when a transaction step or operation for the detected new transaction is an abort or rollback operation, and taking a second action with respect to the change pattern for the detected new transaction when a transaction step or operation for the detected new transaction is a commit operation.
2 . The method of claim 1 wherein the second action checks the transaction pattern table to determine whether the change pattern already exists in the transaction pattern table.
3 . The method of claim 2 wherein each record further includes a metric of occurrence of the transaction pattern, and wherein the metric of occurrence is incremented for the corresponding transaction pattern when the second action determines that the change pattern already exists in the transaction pattern table.
4 . The method of claim 2 wherein the change pattern is entered into the transaction pattern table as a new transaction pattern when the second action determines that the change pattern does not already exist as a transaction pattern in the transaction pattern table.
5 . The method of claim 1 wherein the first action terminates building of the change pattern for the transaction and returns to monitoring the transaction stream.
6 . The method of claim 1 wherein the target database is in a target system, and wherein the transaction pattern table is periodically replicated to the target system.
7 . The method of claim 1 wherein each record further includes a metric of occurrence of the transaction pattern, and wherein the metric of occurrence of the transaction pattern for each record of the transaction pattern table is a count that is continuously updated based on completed transactions that match the transaction pattern.
8 . A computer program product for maintaining a transaction pattern table using a transaction stream monitor that monitors a transaction stream from a change log, wherein transactions are completed within a transaction processing system, and wherein the transactions are replicated from a source database to a target database by a replication engine, the transaction pattern table including a plurality of records, each record including a transaction pattern, wherein each completed transaction is a series of one or more transaction steps or operations, and the transaction pattern is a series of one or more transaction steps or operations of the completed transaction, the computer program product comprising a non-transitory computer readable storage medium tangibly embodying non-transitory computer executable program instructions thereon, that, when executed by one or more processors, cause one or more computing devices to:
(a) analyze each transaction step or operation in the transaction stream from the change log by the transaction stream monitor;
(b) detect whether a transaction step or operation begins a new transaction;
(c) continue to monitor the transaction stream from the change log for transaction steps or operations for the detected new transaction and enter the transaction steps or operations into a change pattern for only the detected new transaction,
wherein the transaction pattern table maintains records for one or more transaction patterns; and
(d) take a first action with respect to the change pattern for the detected new transaction when a transaction step or operation for the detected new transaction is an abort or rollback operation, and take a second action with respect to the change pattern for the detected new transaction when a transaction step or operation for the detected new transaction is a commit operation.
9 . The computer program product of claim 8 wherein the second action checks the transaction pattern table to determine whether the change pattern already exists in the transaction pattern table.
10 . The computer program product of claim 9 wherein each record further includes a metric of occurrence of the transaction pattern, and wherein the metric of occurrence is incremented for the corresponding transaction pattern when the second action determines that the change pattern already exists in the transaction pattern table.
11 . The computer program product of claim 9 wherein the change pattern is entered into the transaction pattern table as a new transaction pattern when the second action determines that the change pattern does not already exist as a transaction pattern in the transaction pattern table.
12 . The computer program product of claim 8 wherein the first action terminates building of the change pattern for the transaction and returns to monitoring the transaction stream.
13 . The computer program product of claim 8 wherein the target database is in a target system, and wherein the transaction pattern table is periodically replicated to the target system.
14 . The computer program product of claim 8 wherein each record further includes a metric of occurrence of the transaction pattern, and wherein the metric of occurrence of the transaction pattern for each record of the transaction pattern table is a count that is continuously updated based on completed transactions that match the transaction pattern.
15 . A computer-implemented apparatus for maintaining a transaction pattern table using a transaction stream monitor that monitors a transaction stream from a change log, wherein transactions are completed within a transaction processing system, and wherein the transactions are replicated from a source database to a target database by a replication engine, the transaction pattern table including a plurality of records, each record including a transaction pattern, wherein each completed transaction is a series of one or more transaction steps or operations, and the transaction pattern is a series of one or more transaction steps or operations of the completed transaction, the apparatus comprising:
(a) a memory configured to store the transaction pattern table including the plurality of records; and
(b) a computer processor configured to:
(i) analyze each transaction step or operation in the transaction stream from the change log by the transaction stream monitor;
(ii) detect whether a transaction step or operation begins a new transaction;
(iii) continue to monitor the transaction stream from the change log for transaction steps or operations for the detected new transaction and enter the transaction steps or operations into a change pattern for only the detected new transaction,
wherein the transaction pattern table maintains records for one or more transaction patterns; and
(iv) take a first action with respect to the change pattern for the detected new transaction when a transaction step or operation for the detected new transaction is an abort or rollback operation, and take a second action with respect to the change pattern for the detected new transaction when a transaction step or operation for the detected new transaction is a commit operation.
16 . The computer-implemented apparatus of claim 15 wherein the second action checks the transaction pattern table to determine whether the change pattern already exists in the transaction pattern table.
17 . The computer-implemented apparatus of claim 16 wherein each record further includes a metric of occurrence of the transaction pattern, and wherein the metric of occurrence is incremented for the corresponding transaction pattern when the second action determines that the change pattern already exists in the transaction pattern table.
18 . The computer-implemented apparatus of claim 16 wherein the change pattern is entered into the transaction pattern table as a new transaction pattern when the second action determines that the change pattern does not already exist as a transaction pattern in the transaction pattern table.
19 . The computer-implemented apparatus of claim 15 wherein the first action terminates building of the change pattern for the transaction and returns to monitoring the transaction stream.
20 . The computer-implemented apparatus of claim 15 wherein the target database is in a target system, and wherein the transaction pattern table is periodically replicated to the target system.
21 . The computer-implemented apparatus of claim 15 wherein each record further includes a metric of occurrence of the transaction pattern, and wherein the metric of occurrence of the transaction pattern for each record of the transaction pattern table is a count that is continuously updated based on completed transactions that match the transaction pattern.