Distributed transaction management with tokens
A system, method and computer product for managing distributed transactions of a database. A transaction manager is provided for each of a plurality of transactions of the database. Each transaction manager is configured to perform functions that include generating a transaction token that specifies data to be visible for a transaction on the database. The database contains both row and column storage engines, and the transaction token includes a transaction identifier (TID) for identifying committed transactions and uncommitted transactions. A last computed transaction is designated with a computed identifier (CID), record-level locking of records of the database is performed using the TID and CID to execute the transaction, and the plurality of transactions of the database are executed with each transaction manager.
1. A method comprising:
generating, by a transaction manager, a transaction token specifying that changes to a database by one or more of a plurality of transactions are visible to a transaction of the plurality of transactions associated with the transaction manager and that changes to the database by others of the plurality of transactions are not visible to the transaction associated with the transaction manager; and
performing record-level locking of a first record in a plurality of records of the database using the transaction token to execute the transaction by at least:
generating an index of the plurality of records in the database as a persistent data structure, the index having a column for computed identifiers, the transaction token including a maximum visible computed identifier for identifying a plurality of committed transactions and a plurality of uncommitted transactions,
generating a delta index having a at least one row and at least one column including a transaction identifier (TID) in the at least one column, and
replacing the TID in the at least one column of the delta index with a computed identifier (CID) for an uncommitted transaction of the plurality of uncommitted transactions that become committed.
2. The method in accordance with claim 1 , wherein performing record-level locking of the first record further comprises storing the TID associated with one or more records in the plurality of records in the database in every row of the at least one row and in the at least one column of the delta index.
3. The method in accordance with claim 1 , wherein the transactions of the database are distributed transactions.
4. A system comprising:
at least one data processor;
memory storing instructions which, when executed by the at least one data processor, causes the at least one data processor to perform operations comprising:
generating, by a transaction manager, a transaction token specifying that changes to a database by one or more of a plurality of transactions are visible to a transaction of the plurality of transactions associated with the transaction manager and that changes to the database by others of the plurality of transactions are not visible to the transaction associated with the transaction manager; and
performing record-level locking of a first record in a plurality of records of the database using the transaction token to execute the transaction by at least:
generating an index of the plurality of records in the database as a persistent data structure, the index having a column for computed identifiers, the transaction token including a maximum visible computed identifier for identifying a plurality of committed transactions and a plurality of uncommitted transactions,
generating a delta index having a at least one row and at least one column including a transaction identifier (TID) in the at least one column, and
replacing the TID in the at least one column of the delta index with a computed identifier (CID) for an uncommitted transaction of the plurality of uncommitted transactions that become committed.
5. The system of claim 4 , wherein performing record-level locking of the first record further comprises storing the TID associated with one or more records in the plurality of records in the database in every row of the at least one row and in the at least one column of the delta index.
6. The system of claim 4 , wherein the transactions of the database are distributed transactions.
7. A non-transitory computer program product storing instructions, which when executed by at least one data processor of at least one computing system, implement operations comprising:
generating, by a transaction manager, a transaction token specifying that changes to a database by one or more of a plurality of transactions are visible to a transaction of the plurality of transactions associated with the transaction manager and that changes to the database by others of the plurality of transactions are not visible to the transaction associated with the transaction manager; and
performing record-level locking of a first record in a plurality of records of the database using the transaction token to execute the transaction by at least:
generating an index of the plurality of records in the database as a persistent data structure, the index having a column for computed identifiers, the transaction token including a maximum visible computed identifier for identifying a plurality of committed transactions and a plurality of uncommitted transactions,
generating a delta index having a at least one row and at least one column including a transaction identifier (TID) in the at least one column, and
replacing the TID in the at least one column of the delta index with a computed identifier (CID) for an uncommitted transaction of the plurality of uncommitted transactions that become committed.
8. The computer program product of claim 7 , wherein performing record-level locking of the first record further comprises storing the TID associated with one or more records in the plurality of records in the database in every row of the at least one row and in the at least one column of the delta index.
9. The computer program product of claim 7 , wherein the transactions of the database are distributed transactions.
10. The method of claim 1 , wherein the index includes at least one of a main index or a history index.
11. The system of claim 4 , wherein the index includes at least one of a main index or a history index.
12. The computer program product of claim 7 , wherein the index includes at least one of a main index or a history index.