公开(公告)号：US10678808B2

公开(公告)日：2020-06-09

申请号：US15692141

申请日：2017-08-31

Applicant: ORACLE INTERNATIONAL CORPORATION

Inventor： Edwina Ming-Yue Lu ,  Nimar Singh Arora ,  Lik Wong

IPC: G06F16/20 ,  G06F16/27 ,  G06F16/23

Abstract: Techniques are provided for eager replication of uncommitted transactions. In embodiments, a replication client receives, in a data stream, change records corresponding to database changes applied to a source database in a transaction. The change records does not include a commit record that indicates that the transaction is committed on the source database. Before receiving the commit record, the replication client computes transaction dependency data based on the change records and detects, based on the transaction dependency data, that the transaction can be at least partially applied to a target database. Also before receiving the commit record, the replication client applies, to a target database and based on the detecting, at least some of the change records. Upon receiving the commit record of the transaction, the replication client completes applying the change records and commits the transaction on the target database.

公开(公告)号：US09747356B2

公开(公告)日：2017-08-29

申请号：US14162053

申请日：2014-01-23

Applicant: Oracle International Corporation

Inventor： Edwina Ming-Yue Lu ,  Nimar Singh Arora ,  Lik Wong

IPC: G06F17/30

CPC classification number: G06F17/30575 ,  G06F17/30368 ,  G06F17/30377

Abstract: Techniques are provided for eager replication of uncommitted transactions. A first plurality of change records is received, corresponding to database changes applied to a source database in a first transaction. First transaction dependency data is computed based on the first transaction. At least a portion of the first plurality of change records is applied to the target database before processing a commit record indicating that has been committed on the source database. Target dependency data is updated after processing the first commit record to reflect completion of the first transaction, the target dependency data including dependency data for a plurality of transactions applied or scheduled to be applied on a target database.

公开(公告)号：US09589041B2

公开(公告)日：2017-03-07

申请号：US13951281

申请日：2013-07-25

Applicant: Oracle International Corporation

Inventor： Hung V. Tran ,  Lik Wong ,  Nimar Singh Arora ,  Thuvan Hoang ,  Edwina Ming-Yue Lu ,  Tianshu Li

IPC: G06F17/00 ,  G06F17/30

CPC classification number: G06F17/30578 ,  G06F17/00

Abstract: Techniques are provided for client and server integration for scalable replication. A replication client transmits change records to a database server over a stream. The database server determines at least one batch comprising change records for at least one transaction. The database server generates dependency data for at least one change record in a batch based on at least one constraint identifier for at least one column. The database server determines an ordered grouping of the change records based on an operation type of each change record and the dependency data of each change record, wherein change records sharing operation types are grouped together unless a division based on the dependency data is determined. The database server generates a reordered transaction comprising a plurality of reordered operations based on the ordered grouping of the change records of the particular batch.

Abstract translation: 为客户端和服务器集成提供了可扩展复制的技术。 复制客户端通过流将更改记录传输到数据库服务器。 数据库服务器至少确定一个包含至少一个交易的更改记录的批次。 数据库服务器基于至少一个列的至少一个约束标识符来为批次中的至少一个改变记录生成依赖性数据。 数据库服务器基于每个改变记录的操作类型和每个改变记录的依赖性数据来确定改变记录的有序分组，其中改变记录共享操作类型被分组在一起，除非确定基于依赖性数据的划分。 数据库服务器基于特定批次的改变记录的有序分组来生成包括多个重新排序的操作的重排序事务。

公开(公告)号：US20170364571A1

公开(公告)日：2017-12-21

申请号：US15692141

申请日：2017-08-31

Applicant: ORACLE INTERNATIONAL CORPORATION

Inventor： Edwina Ming-Yue Lu ,  Nimar Singh Arora ,  Lik Wong

IPC: G06F17/30

CPC classification number: G06F16/27 ,  G06F16/2358 ,  G06F16/2379

Abstract: Techniques are provided for eager replication of uncommitted transactions. In embodiments, a replication client receives, in a data stream, change records corresponding to database changes applied to a source database in a transaction. The change records does not include a commit record that indicates that the transaction is committed on the source database. Before receiving the commit record, the replication client computes transaction dependency data based on the change records and detects, based on the transaction dependency data, that the transaction can be at least partially applied to a target database. Also before receiving the commit record, the replication client applies, to a target database and based on the detecting, at least some of the change records. Upon receiving the commit record of the transaction, the replication client completes applying the change records and commits the transaction on the target database.

公开(公告)号：US20150033232A1

公开(公告)日：2015-01-29

申请号：US13949594

申请日：2013-07-24

Applicant: Oracle International Corporation

Inventor： Edwina Ming-Yue Lu ,  Nimar Singh Arora ,  Lik Wong

IPC: G06F9/46 ,  G06F17/30

CPC classification number: G06F9/466 ,  G06F9/5083 ,  G06F17/30371

Abstract: Techniques are provided for automatic parallelism tuning. At least one batch of change records is assigned to one or more apply processes in a set of active apply processes. A first throughput value is periodically determined based on a number of processed change records in a first time interval. An increment adjustment is periodically performed, including adding an additional apply process, determining a second throughput value, and removing the additional apply process from the set of active apply processes if the second throughput value is not greater than a previous first throughput value by at least an increment threshold. A decrement adjustment is periodically performed, including removing an apply process, determining a third throughput value, and replacing the removed apply process in the set of active apply processes if the third throughput value is not greater than the previous first throughput value by at least a decrement threshold.

Abstract translation: 提供了自动并行调谐技术。 至少一批更改记录被分配给一组活动应用进程中的一个或多个应用进程。 基于在第一时间间隔中的处理的改变记录的数量来周期性地确定第一吞吐量值。 定期执行增量调整，包括添加附加的应用过程，确定第二吞吐量值，以及如果第二吞吐量值不大于先前的第一吞吐量值至少至少在一组活动应用进程中移除附加应用进程 增量阈值。 如果第三吞吐量值不大于先前的第一吞吐量值，则定期执行递减调整，包括去除应用进程，确定第三吞吐量值，以及替换所述一组活动应用进程中的所移除的应用进程， 递减阈值

公开(公告)号：US20150205850A1

公开(公告)日：2015-07-23

申请号：US14162053

申请日：2014-01-23

Applicant: Oracle International Corporation

Inventor： Edwina Ming-Yue Lu ,  Nimar Singh Arora ,  Lik Wong

IPC: G06F17/30 ,  H04L29/06 ,  G06F11/14

CPC classification number: G06F17/30575 ,  G06F17/30368 ,  G06F17/30377

Abstract: Techniques are provided for eager replication of uncommitted transactions. A first plurality of change records is received, corresponding to database changes applied to a source database in a first transaction. First transaction dependency data is computed based on the first transaction. At least a portion of the first plurality of change records is applied to the target database before processing a commit record indicating that has been committed on the source database. Target dependency data is updated after processing the first commit record to reflect completion of the first transaction, the target dependency data including dependency data for a plurality of transactions applied or scheduled to be applied on a target database.

Abstract translation: 提供技术用于急速复制未提交的交易。 接收第一个多个更改记录，对应于在第一个事务中应用于源数据库的数据库更改。 基于第一个事务来计算第一个事务相关性数据。 在处理指示已经在源数据库上提交的提交记录之前，将第一多个改变记录的至少一部分应用于目标数据库。 在处理第一提交记录以反映第一事务的完成之后更新目标依赖性数据，目标依赖性数据包括应用或调度为应用于目标数据库的多个事务的依赖性数据。

公开(公告)号：US09063773B2

公开(公告)日：2015-06-23

申请号：US13949594

申请日：2013-07-24

Applicant: Oracle International Corporation

Inventor： Edwina Ming-Yue Lu ,  Nimar Singh Arora ,  Lik Wong

IPC: G06F9/46 ,  G06F17/30

CPC classification number: G06F9/466 ,  G06F9/5083 ,  G06F17/30371

Abstract: Techniques are provided for automatic parallelism tuning. At least one batch of change records is assigned to one or more apply processes in a set of active apply processes. A first throughput value is periodically determined based on a number of processed change records in a first time interval. An increment adjustment is periodically performed, including adding an additional apply process, determining a second throughput value, and removing the additional apply process from the set of active apply processes if the second throughput value is not greater than a previous first throughput value by at least an increment threshold. A decrement adjustment is periodically performed, including removing an apply process, determining a third throughput value, and replacing the removed apply process in the set of active apply processes if the third throughput value is not greater than the previous first throughput value by at least a decrement threshold.

Abstract translation: 提供了自动并行调谐技术。 至少一批更改记录被分配给一组活动应用进程中的一个或多个应用进程。 基于在第一时间间隔中的处理的改变记录的数量来周期性地确定第一吞吐量值。 定期执行增量调整，包括添加附加的应用过程，确定第二吞吐量值，以及如果第二吞吐量值不大于先前的第一吞吐量值至少至少在一组活动应用进程中移除附加应用进程 增量阈值。 如果第三吞吐量值不大于先前的第一吞吐量值，则定期执行递减调整，包括去除应用进程，确定第三吞吐量值，以及替换所述一组活动应用进程中的已移除的应用进程， 递减阈值

公开(公告)号：US20150032695A1

公开(公告)日：2015-01-29

申请号：US13951281

申请日：2013-07-25

Applicant: Oracle International Corporation

Inventor： Hung V. Tran ,  Lik Wong ,  Nimar Singh Arora ,  Thuvan Hoang ,  Edwina Ming-Yue Lu ,  Tianshu Li

IPC: G06F17/30

CPC classification number: G06F17/30578 ,  G06F17/00

Abstract: Techniques are provided for client and server integration for scalable replication. A replication client transmits change records to a database server over a stream. The database server determines at least one batch comprising change records for at least one transaction. The database server generates dependency data for at least one change record in a batch based on at least one constraint identifier for at least one column. The database server determines an ordered grouping of the change records based on an operation type of each change record and the dependency data of each change record, wherein change records sharing operation types are grouped together unless a division based on the dependency data is determined. The database server generates a reordered transaction comprising a plurality of reordered operations based on the ordered grouping of the change records of the particular batch.

Abstract translation: 为客户端和服务器集成提供了可扩展复制技术。 复制客户端通过流将更改记录传输到数据库服务器。 数据库服务器至少确定一个包含至少一个交易的更改记录的批次。 数据库服务器基于至少一个列的至少一个约束标识符来为批次中的至少一个改变记录生成依赖性数据。 数据库服务器基于每个改变记录的操作类型和每个改变记录的依赖性数据来确定改变记录的有序分组，其中改变记录共享操作类型被分组在一起，除非确定基于依赖性数据的划分。 数据库服务器基于特定批次的改变记录的有序分组来生成包括多个重新排序的操作的重排序事务。