Extended transactions

• US 8,112,389 B2
• Filed: 10/26/2010
• Issued: 02/07/2012
• Est. Priority Date: 10/11/2006
• Status: Active Grant

• Current Assignee: Jonathan P. Ruby
• Original Assignee: Jonathan P. Ruby
• Inventors: Ruby, Jonathan P.
• Primary Examiner(s): Jalil, Neveen Abel
• Assistant Examiner(s): YOUNG, KEVIN L.
• Application Number:
  US12/912,654
• Publication Number:
  US 20110270812A1
• Time in Patent Office: 469 Days
• Field of Search: 707/607
• US Class Current: 707/607
• CPC Class Codes: G06F 9/466 Transaction processing

Abstract

Multiple atomic “component” database transactions are combined into a single extended transaction through message passing. The multiple component transactions that comprise a single extended transaction may, in combination, perform a single computation. The component transactions may pass messages to each other by writing and reading records to and from one or more databases. The resulting extended transaction may be distributed and/or long-lived.

Claims

1. A system comprising:

a database system comprising;

a first database tangibly stored in at least a first computer-readable medium;

first atomic transaction means for using a first processor communicatively coupled to a first memory to execute a first component transaction instance atomically on the first database, the first atomic transaction means comprising;

first operation execution means to perform a first operation to produce first application data within an atomicity guarantee of the first component transaction instance;

first application data storage means for storing the first application data in a first record of the first database within the atomicity guarantee of the first component transaction instance;

first state storage means for storing a first state of a computation, based on the first operation, in a second record of the first database within the atomicity guarantee of the first component transaction instance;

a second database tangibly stored in at least a second computer-readable medium;

second atomic transaction means for using a second processor communicatively coupled to a second memory to execute a second component transaction instance atomically on the second database, the second atomic transaction means comprising;

means for reading the first state of the computation from the second record of the first database;

second operation execution means to perform a second operation, in response to the first state, to produce second application data within an atomicity guarantee of the second component transaction instance;

second application data storage means for storing the second application data in a third record of the second database within the atomicity guarantee of the second component transaction instance; and

second state storage means for storing a second state of the computation, based on the second operation, in a fourth record of the second database within the atomicity guarantee of the second component transaction instance;

wherein the system further comprises;

means for attempting to write, into the plurality of fields having a plurality of original values in a plurality of databases, a plurality of new values; and

means for returning the plurality of fields to the plurality of original values to the plurality of original values if the attempt fails with respect to at least one of the plurality of fields.

2. The system of claim 1, wherein the first and second databases are the same database.

3. The system of claim 1, wherein the second record and the fourth records are the same records.

4. The system of claim 1, wherein the first atomic transaction means further comprises:

transaction stimulus message generation means for storing a transaction stimulus message in a fifth record of the first database within the atomicity guarantee of the first component transaction instance; and

wherein the system further comprises;

transaction stimulus reception means for receiving the transaction stimulus message by reading the fifth record from the first database; and

transaction stimulus message execution means for causing, in response to reading the fifth record, the second atomic transaction means to execute the second component transaction instance.

5. The system of claim 4, wherein the transaction stimulus reception means comprises means for receiving the transaction stimulus message over the Internet.

6. The system of claim 5, wherein the transaction stimulus reception means comprises means for receiving the transaction stimulus message in an email message.

7. The system of claim 4, wherein the transaction stimulus message specifies the second operation.

8. The system of claim 4, wherein the fifth record is the same as the second record.

9. The system of claim 4, wherein the transaction stimulus message generation means comprises means for storing the transaction stimulus message to control an order in which a plurality of other transaction instances execute.

10. The system of claim 4, wherein the transaction stimulus message generation means comprises means for writing the transaction stimulus message to control whether another transaction instance is permitted to update a field in a database.

11. The system of claim 1, wherein the first and second databases are of different types.

12. The system of claim 1, wherein the transaction stimulus reception means is external to the database system.

13. The system of claim 1, wherein the means for reading comprises means for reading the first state an arbitrary amount of time after the first state storage means stores the first state in the second record of the first database.

14. A computer-implemented method for use with a database system, the method performed by a processor executing computer program instructions tangibly embodied in a first computer-readable storage medium, the database system comprising first database and second database tangibly stored in at least one second computer-readable storage medium, the method comprising:

(A) executing a first component transaction instance atomically on the first database, comprising;

(1) performing a first operation and thereby producing first application data within an atomicity guarantee of the first component transaction instance;

(2) storing the first application data in a first record of the first database within the atomicity guarantee of the first component transaction instance; and

(3) storing a first state of a computation, based on the first operation, in a second record of the first database within the atomicity guarantee of the first component transaction instance;

(B) executing a second component transaction instance atomically on the second database, comprising;

(1) reading the first state of the computation from the second record of the first database;

(2) performing a second operation, in response to the first state, to produce second application data within an atomicity guarantee of the second component transaction instance;

(3) storing the second application data in a third record of the second database within the atomicity guarantee of the second component transaction instance; and

(4) storing a second state of the computation, based on the second operation, in a fourth record of the second database within the atomicity guarantee of the second component transaction instance;

wherein (A) further comprises;

attempting to write, into a plurality of fields having a plurality of original values in a plurality of databases, a plurality of new values; and

returning the plurality of fields to the plurality of original values if the attempt fails with respect to at least one of the plurality of fields.

15. The method of claim 14, wherein the first and second databases are the same database.

16. The method of claim 14, wherein the second and fourth records are the same record.

17. The method of claim 14, wherein (A) further comprises:

(4) storing a transaction stimulus message in a fifth record of the first database within an atomicity guarantee of the first component transaction instance; and

wherein the method further comprises;

(C) receiving the transaction stimulus message by reading the first record from the first database; and

(D) performing (B) in response to receiving the transaction stimulus message.

18. The method of claim 17, wherein (A) (4) comprises storing the transaction stimulus message to control an order in which a plurality of other transaction instances execute.

19. The method of claim 17, wherein (A) (4) comprises storing the transaction stimulus message to control whether another transaction instance is permitted to update a field in a database.

20. The method of claim 14, wherein (B) (1) comprises reading the first state an arbitrary amount of time after (A) (3).

21. The method of claim 17, wherein (C) comprises reading the first record from the first database using a transaction stimulus reception means, wherein the transaction stimulus reception means is external to the database system.

22. The method of claim 17, wherein the fifth record is the same as the second record.