com.neocoretechs.rocksack.session

Class TransactionManager

java.lang.Object

com.neocoretechs.rocksack.session.TransactionManager

public final class TransactionManager
extends java.lang.Object

Singleton transaction manager which maintains the map of TransactionIds to TransactionSessions. We can access and manipulate this map in order to get us to the eventual map of mangled transaction names and RocksDb TransactionDb Transaction instances in TransactionSession.

Author:

Jonathan Groff Copyright (C) NeoCoreTechs 2024

Method Summary

Modifier and Type	Method and Description
static void	checkpoint(TransactionId uid) Checkpoint all transactions with given transaction Id
static void	commit(TransactionId uid) Commit all transactions with given transaction Id
static TransactionManager	getInstance()
static java.util.concurrent.ConcurrentHashMap<java.lang.String,com.neocoretechs.rocksack.session.TransactionManager.SessionAndTransaction>	getTransactions(TransactionId transactionId) Get the Transaction objects formed from id.
static java.util.List<org.rocksdb.Transaction>	getTransactions(TransactionId transactionId, java.lang.String clazz) Get the Transaction objects formed from id and class name.
static void	rollback(TransactionId uid) Rollback all transactions with given transaction Id
static void	rollbackToCheckpoint(TransactionId uid) Rollback to checkpoint all transactions with given transaction Id

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

getInstance

public static TransactionManager getInstance()

getTransactions

public static java.util.concurrent.ConcurrentHashMap<java.lang.String,com.neocoretechs.rocksack.session.TransactionManager.SessionAndTransaction> getTransactions(TransactionId transactionId)

Get the Transaction objects formed from id.

Parameters:

transactionId -

Returns:

Set of names and RocksDb Transaction objects or null if none found

getTransactions

public static java.util.List<org.rocksdb.Transaction> getTransactions(TransactionId transactionId,
                                                                      java.lang.String clazz)

Get the Transaction objects formed from id and class name.

Parameters:

transactionId -

clazz -

Returns:

Set of names and RocksDb Transaction objects or null if none found

commit

public static void commit(TransactionId uid)
                   throws org.rocksdb.RocksDBException

Commit all transactions with given transaction Id

Parameters:

uid - the transaction Id

Throws:

org.rocksdb.RocksDBException

rollback

public static void rollback(TransactionId uid)
                     throws org.rocksdb.RocksDBException

Rollback all transactions with given transaction Id

Parameters:

uid - the transaction Id

Throws:

org.rocksdb.RocksDBException

checkpoint

public static void checkpoint(TransactionId uid)
                       throws org.rocksdb.RocksDBException

Checkpoint all transactions with given transaction Id

Parameters:

uid - the transaction Id

Throws:

org.rocksdb.RocksDBException

rollbackToCheckpoint

public static void rollbackToCheckpoint(TransactionId uid)
                                 throws org.rocksdb.RocksDBException

Rollback to checkpoint all transactions with given transaction Id

Parameters:

uid - the transaction Id

Throws:

org.rocksdb.RocksDBException