Replicating large statements with low latency

A computer system, comprising:

• one or more processors;
• one or more memory devices coupled to the one or more processors;
• and
• one or more computer readable storage devices coupled to the one or more processors, wherein the one or more storage devices contain program code executable by the one or more processors via the one or more memory devices to implement a method of replication, the method comprising:
• when a large statement is a single statement that is larger than a threshold, receiving, by the one or more processors of the computer system, the large statement as a set of files by a streamed transaction in an out-of-band transmission queue, each file of the set of files including at least one row that is changed, the set of files originating from the large statement that is at least 10 megabytes in size received at a source database management system that has identified the large statement is the single statement that is larger than the threshold;
• continuously applying, by the one or more processors of the computer system, changes in the set of files as they are received via the out-of-band transmission queue;
• when an additional transaction is a single statement that is smaller than a threshold, receiving, by the one or more processors of the computer system during the continuously applying changes in the set of files as they are received via the out-of-band transmission queue, the additional transaction via an inline transmission queue from the source database management system that has identified that the additional transaction is smaller than the threshold;
• and
• applying, by the one or more processors of the computer system, the additional transaction received via the inline transmission queue as the additional transaction is received during receiving the set of files by the streamed transaction or the continuously applying;
• and
• after the continuously applying, applying, by the one or more processors of the computer system, a commit or a rollback after receiving a large statement completion message by the source database management system, the large statement completion message reflecting an outcome at the source database management system.

A computer program product, comprising a computer readable hardware storage device storing a computer readable program code, the computer readable program code comprising an algorithm that when executed by one or more processors of a computer system implements a method of replication, the method comprising:

• when a large statement is a single statement that is larger than a threshold, receiving, by the one or more processors of the computer system, the large statement as a set of files by a streamed transaction in an out-of-band transmission queue, each file of the set of files including at least one row that is changed, the set of files originating from the large statement that is at least 10 megabytes in size received at a source database management system that has identified the large statement is the single statement that is larger than the threshold;
• continuously applying, by the one or more processors of the computer system, changes in the set of files as they are received via the out-of-band transmission queue;
• when an additional transaction is a single statement that is smaller than a threshold, receiving, by the one or more processors of the computer system during the continuously applying changes in the set of files as they are received via the out-of-band transmission queue, the additional transaction via an inline transmission queue from the source database management system that has identified that the additional transaction is smaller than the threshold;
• and
• applying, by the one or more processors of the computer system, the additional transaction received via the inline transmission queue as the additional transaction is received during receiving the set of files by the streamed transaction or the continuously applying;
• and
• after the continuously applying, applying, by the one or more processors of the computer system, a commit or a rollback after receiving a large statement completion message by the source database management system, the large statement completion message reflecting an outcome at the source database management system.