com.neocoretechs.rocksack.session

Class OptimisticTransactionSession

java.lang.Object

com.neocoretechs.rocksack.session.Session

com.neocoretechs.rocksack.session.TransactionSession

com.neocoretechs.rocksack.session.OptimisticTransactionSession

public class OptimisticTransactionSession
extends TransactionSession

Extends the TransactionSession class to include optimistic transaction semantics. In RocksDb an OptimisticTransactionDB instance contains the transaction classes and methods to provide atomicity. Transactions are linked to a OptimisticTransactionDb, a subclass of RocksDB. Each transaction may be named, and the name must be unique. To enforce uniqueness considering these constraints, the name formed will be a concatenation of Transaction Id, which is a UUID, the class name, which is also a column family or the default column family, and the Alias, or none, which is the default database path.

From the TransactionManager we link the transaction Id's to an instance of this and associated transaction.

Author:

Jonathan Groff Copyright (C) NeoCoreTechs 2023,2024

Constructor Summary

Constructors

Constructor and Description
OptimisticTransactionSession(org.rocksdb.OptimisticTransactionDB kvStore, org.rocksdb.Options options, java.util.ArrayList<org.rocksdb.ColumnFamilyDescriptor> columnFamilyDescriptor, java.util.List<org.rocksdb.ColumnFamilyHandle> columnFamilyHandles)

Method Summary

Modifier and Type	Method and Description
org.rocksdb.Transaction	BeginTransaction() Initiate a transaction.

Methods inherited from class com.neocoretechs.rocksack.session.TransactionSession

BeginTransaction, getAllPreparedTransactions, getLockStatusData, getTransaction, isTransactionLinked, linkSessionAndTransaction, toString

Methods inherited from class com.neocoretechs.rocksack.session.Session

Close, Close

Methods inherited from class java.lang.Object

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

Constructor Detail

OptimisticTransactionSession

public OptimisticTransactionSession(org.rocksdb.OptimisticTransactionDB kvStore,
                                    org.rocksdb.Options options,
                                    java.util.ArrayList<org.rocksdb.ColumnFamilyDescriptor> columnFamilyDescriptor,
                                    java.util.List<org.rocksdb.ColumnFamilyHandle> columnFamilyHandles)

Method Detail

BeginTransaction

public org.rocksdb.Transaction BeginTransaction()

Initiate a transaction.

Overrides:

BeginTransaction in class TransactionSession

Returns:

The RocksDB transaction instance.