Long-lived data transactions

Patent metadata

Field	Value
Publication number	US-9589009-B2
Application number	US-201213365442-A
Country	US
Kind code	B2
Filing date	Feb 3, 2012
Priority date	Oct 14, 2005
Publication date	Mar 7, 2017
Grant date	Mar 7, 2017

Abstract

In one embodiment, a method includes accessing a mapping that represents a correspondence between a column in a source database and a column in a temporary storage table, in response to receiving a data operation request to execute a data operation on a column of the source database. The method further includes changing the temporary storage table by executing the data operation on the temporary storage table and performing a reconstruction operation using data from the temporary storage table and the source database.

First claim

What is claimed is:

1. A method for managing long-lived data transactions comprising:
in response to receipt of a data operation request to execute a data operation on a column of a source database, accessing a mapping that represents a correspondence between the column of the source database and a column in a temporary storage table that is configured to store one or more changes to be made to the source database;
changing the temporary storage table by executing the data operation on the temporary storage table using the mapping; and
after the executing, performing a reconstruction operation that reconstructs data in the source database to a particular point-in-time by, at least in part, incorporating less than all of the one or more changes to be made to the source database, using change data from the temporary storage table and source data from the source database, wherein the performing the reconstruction operation further comprises:
setting search criteria to specify one or more records to be retrieved from the source table;
setting sort criteria to specify order of the one or more records to be retrieved from the source table;
retrieving the source data from the source database based on the search and sort criteria;
reading the change data from the temporary storage table; and
updating the source data from the source database with the change data from the temporary storage table.

2. The method of claim 1 , further comprising:
creating the mapping in a mapping table, in response to the column of the source database being processed for a first time, by
determining the correspondence between the column in the temporary storage table and the column in the source database, and
storing the mapping in the mapping table.

3. The method of claim 2 , wherein the creating the mapping further comprises:
identifying one or more columns in the temporary storage table, wherein
each of the one or more columns in the temporary storage table is of a same type as the column in the source database, and
each of the one or more of columns in the temporary storage table is at least as long as the column in the source database;

identifying one of the one or more columns in the temporary storage table as a next unmapped column, wherein the column in the temporary storage table is the next unmapped column; and
associating the column in the source database and the next unmapped column.

4. The method of claim 1 , wherein the column in the temporary storage table is a column of a same type and at least a same length as the column of the source database.

5. The method of claim 1 , wherein the data operation is at least one operation of
an insert operation,
an update operation, or
a delete operation, and
the at least one operation is performed as part of a data transaction,
the data transaction beings during a first user session and completes during a second user session, and
the one or more changes are to be made to the source database during life of a data transaction including the data operation.

6. The method of claim 1 , wherein the changing the temporary storage table comprises:
executing another data operation on the temporary storage table, wherein
the executing the other data operation uses the mapping,
the other data operation is another part of a data transaction,
the executing the other data operation causes another change to be made to the temporary storage table, and
the other data operation is configured to be executed on the column of the source database.

7. The method of claim 1 , further comprising: upon completion of the data operation,
committing the change data to the source database, and
purging, from the temporary storage table, contents of the temporary storage table related to the change data.

8. The method of claim 1 , further comprising: performing a rollback of the change data in the temporary storage table.

9. The method of claim 1 , wherein
the data operation request comprises a plurality of data operations,
the plurality of data operations comprises the data operation, and
the plurality of data operations is executed on the temporary storage table on an incremental basis.

10. The method of claim 1 , wherein the executing the data operation on the temporary storage table further comprises:
accessing the temporary storage table;
identifying the column in the temporary storage table using the mapping; and
executing the data operation on a record identified by the column in the temporary storage table.

11. The method of claim 1 , wherein the performing the reconstruction operation further comprises:
issuing a first query to the source database to populate the source data in the source database;
issuing a second query to the temporary storage table to populate the change data in the temporary storage table; and
superimposing the change data from the temporary storage table over the source data from the source database.

12. A non-transitory computer-readable storage medium for managing long-live data transactions comprising program instructions executable to:
in response to receipt of a data operation request to execute a data operation on a column of a source database, access a mapping that represents a correspondence between the column of the source database and a column in a temporary storage table that is configured to store one or more changes to be made to the source database;
change the temporary storage table by executing the data operation on the temporary storage table using the mapping; and
perform a reconstruction operation that reconstructs data in the source database to a particular point-in-time by, at least in part, incorporating less than all of the one or more changes to be made to the source database, using change data from the temporary storage table and source data from the source database after the data operation is executed, wherein the performing the reconstruction operation further comprises:
setting search criteria to specify one or more records to be retrieved from the source table;
setting sort criteria to specify order of the one or more records to be retrieved from the source table;
retrieving the source data from the source database based on the search and sort criteria;
reading the change data from the temporary storage table; and
updating the source data from the source database with the change data from the temporary storage table.

13. The non-transitory computer-readable storage medium of claim 12 , wherein the program instructions are further executable to:
create the mapping in the mapping table, wherein
the program instructions executable to create comprise program instructions executable to determine the correspondence between the column in the temporary storage table and the column in the source database, and
store the mapping in the mapping table.

14. The non-transitory computer-readable storage medium of claim 13 , wherein the program instructions are further executable to:
identify one or more columns in the temporary storage table, wherein
each of the one or more columns in the temporary storage table is of a same type as the column in the source database, and
each of the one or more of columns in the temporary storage table is at least as long as the column in the source database;

identify one of the one or more columns in the temporary storage table as a next unmapped column, wherein the column in the temporary storage table is the next unmapped column; and
associate the column in the source database and the next unmapped column.

15. The non-transitory computer-readable storage

Assignees

• Shringi Kanchan
• Lu Min
• Zhang Xiaopei (Joyce)
• Naran Siemel
• Yaseen Rahim
• Degenhardt Jon Rexford
• Oracle Int Corp

Inventors

• Shringi Kanchan
• Lu Min
• Zhang Xiaopei (Joyce)
• Naran Siemel
• Yaseen Rahim
• Degenhardt Jon Rexford

Classifications

• G06F16/2365 Primary

  Ensuring data consistency and integrity · CPC title

• G06F17/30371 Primary

  Physics · mapped topic