Transfer of data from positional data sources to partitioned databases in restartable environments
First Claim
Patent Images
1. A computer-implemented method for transferring data from data sources to database partitions, the method comprising:
- reading a record from a data source in a computer system, the record having a position that uniquely identifies the record in the data source relative to a starting position of the data source, wherein the record is to be written to one of a plurality of partitions of a database in the computer system, wherein the record is one of a plurality of records written to the one partition and the position of the record is farthest from the starting position of the data source among the plurality of records written to the one partition;
obtaining the position of the record in the data source;
initiating a transaction to write the record to the one partition and to store the position of the record in the database;
committing the transaction after the record is successfully written to the one partition and the position of the record is successfully stored in the database; and
upon a restart following a failure, avoiding writing the record of the committed transaction to the one partition by rejecting any record with a position that is less than or equal to the position of the committed transaction.
6 Assignments
0 Petitions
Accused Products
Abstract
Method, computer program product, and system for transferring data from positional data sources to partitioned databases are provided. A record is read from a positional data source. The record is to be written to one of a plurality of partitions of a database. A position of the record in the positional data source is obtained. A transaction is initiated to write the record to the one partition and to store the position of the record in the database. The transaction is committed after the record is successfully written to the one partition and the position of the record is successfully stored in the database.
-
Citations
19 Claims
-
1. A computer-implemented method for transferring data from data sources to database partitions, the method comprising:
-
reading a record from a data source in a computer system, the record having a position that uniquely identifies the record in the data source relative to a starting position of the data source, wherein the record is to be written to one of a plurality of partitions of a database in the computer system, wherein the record is one of a plurality of records written to the one partition and the position of the record is farthest from the starting position of the data source among the plurality of records written to the one partition; obtaining the position of the record in the data source; initiating a transaction to write the record to the one partition and to store the position of the record in the database; committing the transaction after the record is successfully written to the one partition and the position of the record is successfully stored in the database; and upon a restart following a failure, avoiding writing the record of the committed transaction to the one partition by rejecting any record with a position that is less than or equal to the position of the committed transaction. - View Dependent Claims (2, 3, 4, 5, 6, 7)
-
-
8. A system for transferring data from data sources to database partitions, the system comprising:
-
a processor; and a data engine executing on the processor, the data engine reading a record from a data source, the record having a position that uniquely identifies the record in the data source relative to a starting position of the data source, wherein the record is to be written to one of a plurality of partitions of a database, wherein the record is one of a plurality of records written to the one partition and the position of the record is farthest from the starting position of the data source among the plurality of records written to the one partition, obtaining the position of the record in the data source, initiating a transaction to write the record to the one partition and to store the position of the record in the database, committing the transaction after the record is successfully written to the one partition and the position of the record is successfully stored in the database; upon a restart following a failure, avoiding writing the record of the committed transaction to the one partition by rejecting any record with a position that is less than or equal to the position of the committed transaction. - View Dependent Claims (9, 10, 11, 12, 13, 14)
-
-
15. A computer readable storage medium encoded with a computer program for transferring data from data sources to database partitions,
wherein the computer program, when executed on a computer, causes the computer to: -
read a record from a data source, the record having a position that uniquely identifies the record in the data source relative to a starting position of the data source, wherein the record is to be written to one of a plurality of partitions of a database, wherein the record is one of a plurality of records written to the one partition and the position of the record is farthest from a starting position of the data source among the plurality of records written to the one partition; obtain the position of the record in the data source; initiate a transaction to write the record to the one partition and to store the position of the record in the database; commit the transaction after the record is successfully written to the one partition and the position of the record is successfully stored in the database; and upon a restart following a failure, avoiding writing the record of the committed transaction to the one partition by rejecting any record with a position that is less than or equal to the position of the committed transaction. - View Dependent Claims (16, 17, 18, 19)
-
Specification