Class Transaction
public class Transaction : RocksObject, IDynamicMetaObjectProvider, IJVMBridgeCore, IEquatable<IJVMBridgeBase>, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeDefinition, IAutoCloseable- Inheritance
-
Transaction
- Implements
- Inherited Members
-
JVMBridgeBase<AutoCloseable>.SExecuteWithSignature(Type, IJavaType, string, string, params object[])JVMBridgeBase<AutoCloseable>.SExecute<TReturn, TConverter>(Type, IJavaType, string, params object[])JVMBridgeBase<AutoCloseable>.SExecuteWithSignatureArray<TArrayType>(string, string, params object[])
Constructors
Transaction()
Default constructor: even if the corresponding Java class does not have one, it is mandatory for JCOBridge
public Transaction()Transaction(IJVMBridgeBaseInitializer)
Internal constructor: used internally from JCOBridge
[Obsolete("This public initializer is needed for JCOBridge internal use, other uses can produce unidentible behaviors.")]
public Transaction(IJVMBridgeBaseInitializer initializer)Parameters
initializerIJVMBridgeBaseInitializer
Transaction(params object[])
Generic constructor: it is useful for JCOBridge when there is a derived class which needs to pass arguments to the highest JVMBridgeBase class
public Transaction(params object[] args)Parameters
argsobject[]
Properties
BridgeClassName
Java class name to be instantiated
public override string BridgeClassName { get; }Property Value
CommitTimeWriteBatch
public WriteBatch CommitTimeWriteBatch { get; }Property Value
ElapsedTime
public long ElapsedTime { get; }Property Value
ID
public long ID { get; }Property Value
Id
public long Id { get; }Property Value
IsBridgeAbstract
true if the BridgeClassName is an abstract class, i.e. cannot be created an instance
public override bool IsBridgeAbstract { get; }Property Value
IsBridgeCloseable
true if the BridgeClassName implements Closeable
public override bool IsBridgeCloseable { get; }Property Value
IsBridgeInterface
true if the BridgeClassName is an interface, i.e. does not have any public constructor
public override bool IsBridgeInterface { get; }Property Value
IsBridgeStatic
true if the BridgeClassName is a static class, i.e. does not have any public constructor
public override bool IsBridgeStatic { get; }Property Value
Iterator
public RocksIterator Iterator { get; }Property Value
LogNumber
https://www.javadoc.io/doc/org.rocksdb/rocksdbjni/10.1.3/org/rocksdb/Transaction.html#getLogNumber() https://www.javadoc.io/doc/org.rocksdb/rocksdbjni/10.1.3/org/rocksdb/Transaction.html#setLogNumber(long)
public long LogNumber { get; set; }Property Value
Name
https://www.javadoc.io/doc/org.rocksdb/rocksdbjni/10.1.3/org/rocksdb/Transaction.html#getName() https://www.javadoc.io/doc/org.rocksdb/rocksdbjni/10.1.3/org/rocksdb/Transaction.html#setName(java.lang.String)
public String Name { get; set; }Property Value
NumDeletes
public long NumDeletes { get; }Property Value
NumKeys
public long NumKeys { get; }Property Value
NumMerges
https://www.javadoc.io/doc/org.rocksdb/rocksdbjni/10.1.3/org/rocksdb/Transaction.html#getNumMerges()
public long NumMerges { get; }Property Value
NumPuts
public long NumPuts { get; }Property Value
Snapshot
public Snapshot Snapshot { get; }Property Value
State
public Transaction.TransactionState State { get; }Property Value
WaitingTxns
public Transaction.WaitingTransactions WaitingTxns { get; }Property Value
WriteBatch
public WriteBatchWithIndex WriteBatch { get; }Property Value
WriteOptions
https://www.javadoc.io/doc/org.rocksdb/rocksdbjni/10.1.3/org/rocksdb/Transaction.html#getWriteOptions() https://www.javadoc.io/doc/org.rocksdb/rocksdbjni/10.1.3/org/rocksdb/Transaction.html#setWriteOptions(org.rocksdb.WriteOptions)
public WriteOptions WriteOptions { get; set; }Property Value
Methods
ClearSnapshot()
public void ClearSnapshot()Commit()
public void Commit()Exceptions
Delete(ColumnFamilyHandle, byte[])
public void Delete(ColumnFamilyHandle arg0, byte[] arg1)Parameters
arg0ColumnFamilyHandlearg1byte[]
Exceptions
Delete(ColumnFamilyHandle, byte[], bool)
public void Delete(ColumnFamilyHandle arg0, byte[] arg1, bool arg2)Parameters
arg0ColumnFamilyHandlearg1byte[]arg2bool
Exceptions
Delete(ColumnFamilyHandle, byte[][])
public void Delete(ColumnFamilyHandle arg0, byte[][] arg1)Parameters
arg0ColumnFamilyHandlearg1byte[][]
Exceptions
Delete(ColumnFamilyHandle, byte[][], bool)
public void Delete(ColumnFamilyHandle arg0, byte[][] arg1, bool arg2)Parameters
arg0ColumnFamilyHandlearg1byte[][]arg2bool
Exceptions
Delete(byte[])
https://www.javadoc.io/doc/org.rocksdb/rocksdbjni/10.1.3/org/rocksdb/Transaction.html#delete(byte[])
public void Delete(byte[] arg0)Parameters
Exceptions
Delete(byte[][])
public void Delete(byte[][] arg0)Parameters
Exceptions
DeleteUntracked(ColumnFamilyHandle, byte[])
public void DeleteUntracked(ColumnFamilyHandle arg0, byte[] arg1)Parameters
arg0ColumnFamilyHandlearg1byte[]
Exceptions
DeleteUntracked(ColumnFamilyHandle, byte[][])
public void DeleteUntracked(ColumnFamilyHandle arg0, byte[][] arg1)Parameters
arg0ColumnFamilyHandlearg1byte[][]
Exceptions
DeleteUntracked(byte[])
public void DeleteUntracked(byte[] arg0)Parameters
Exceptions
DeleteUntracked(byte[][])
public void DeleteUntracked(byte[][] arg0)Parameters
Exceptions
DisableIndexing()
public void DisableIndexing()EnableIndexing()
public void EnableIndexing()Get(ReadOptions, ByteBuffer, ByteBuffer)
public GetStatus Get(ReadOptions arg0, ByteBuffer arg1, ByteBuffer arg2)Parameters
arg0ReadOptionsarg1ByteBufferarg2ByteBuffer
Returns
Exceptions
Get(ReadOptions, ColumnFamilyHandle, ByteBuffer, ByteBuffer)
public GetStatus Get(ReadOptions arg0, ColumnFamilyHandle arg1, ByteBuffer arg2, ByteBuffer arg3)Parameters
arg0ReadOptionsarg1ColumnFamilyHandlearg2ByteBufferarg3ByteBuffer
Returns
Exceptions
Get(ReadOptions, ColumnFamilyHandle, byte[])
public byte[] Get(ReadOptions arg0, ColumnFamilyHandle arg1, byte[] arg2)Parameters
arg0ReadOptionsarg1ColumnFamilyHandlearg2byte[]
Returns
Exceptions
Get(ReadOptions, ColumnFamilyHandle, byte[], byte[])
public GetStatus Get(ReadOptions arg0, ColumnFamilyHandle arg1, byte[] arg2, byte[] arg3)Parameters
arg0ReadOptionsarg1ColumnFamilyHandlearg2byte[]arg3byte[]
Returns
Exceptions
Get(ReadOptions, byte[])
public byte[] Get(ReadOptions arg0, byte[] arg1)Parameters
arg0ReadOptionsarg1byte[]
Returns
Exceptions
Get(ReadOptions, byte[], byte[])
public GetStatus Get(ReadOptions arg0, byte[] arg1, byte[] arg2)Parameters
arg0ReadOptionsarg1byte[]arg2byte[]
Returns
Exceptions
GetForUpdate(ReadOptions, ByteBuffer, ByteBuffer, bool)
public GetStatus GetForUpdate(ReadOptions arg0, ByteBuffer arg1, ByteBuffer arg2, bool arg3)Parameters
arg0ReadOptionsarg1ByteBufferarg2ByteBufferarg3bool
Returns
Exceptions
GetForUpdate(ReadOptions, ColumnFamilyHandle, ByteBuffer, ByteBuffer, bool)
public GetStatus GetForUpdate(ReadOptions arg0, ColumnFamilyHandle arg1, ByteBuffer arg2, ByteBuffer arg3, bool arg4)Parameters
arg0ReadOptionsarg1ColumnFamilyHandlearg2ByteBufferarg3ByteBufferarg4bool
Returns
Exceptions
GetForUpdate(ReadOptions, ColumnFamilyHandle, ByteBuffer, ByteBuffer, bool, bool)
public GetStatus GetForUpdate(ReadOptions arg0, ColumnFamilyHandle arg1, ByteBuffer arg2, ByteBuffer arg3, bool arg4, bool arg5)Parameters
arg0ReadOptionsarg1ColumnFamilyHandlearg2ByteBufferarg3ByteBufferarg4boolarg5bool
Returns
Exceptions
GetForUpdate(ReadOptions, ColumnFamilyHandle, byte[], bool)
public byte[] GetForUpdate(ReadOptions arg0, ColumnFamilyHandle arg1, byte[] arg2, bool arg3)Parameters
arg0ReadOptionsarg1ColumnFamilyHandlearg2byte[]arg3bool
Returns
Exceptions
GetForUpdate(ReadOptions, ColumnFamilyHandle, byte[], bool, bool)
public byte[] GetForUpdate(ReadOptions arg0, ColumnFamilyHandle arg1, byte[] arg2, bool arg3, bool arg4)Parameters
arg0ReadOptionsarg1ColumnFamilyHandlearg2byte[]arg3boolarg4bool
Returns
Exceptions
GetForUpdate(ReadOptions, ColumnFamilyHandle, byte[], byte[], bool)
public GetStatus GetForUpdate(ReadOptions arg0, ColumnFamilyHandle arg1, byte[] arg2, byte[] arg3, bool arg4)Parameters
arg0ReadOptionsarg1ColumnFamilyHandlearg2byte[]arg3byte[]arg4bool
Returns
Exceptions
GetForUpdate(ReadOptions, ColumnFamilyHandle, byte[], byte[], bool, bool)
public GetStatus GetForUpdate(ReadOptions arg0, ColumnFamilyHandle arg1, byte[] arg2, byte[] arg3, bool arg4, bool arg5)Parameters
arg0ReadOptionsarg1ColumnFamilyHandlearg2byte[]arg3byte[]arg4boolarg5bool
Returns
Exceptions
GetForUpdate(ReadOptions, byte[], bool)
public byte[] GetForUpdate(ReadOptions arg0, byte[] arg1, bool arg2)Parameters
arg0ReadOptionsarg1byte[]arg2bool
Returns
Exceptions
GetForUpdate(ReadOptions, byte[], byte[], bool)
public GetStatus GetForUpdate(ReadOptions arg0, byte[] arg1, byte[] arg2, bool arg3)Parameters
arg0ReadOptionsarg1byte[]arg2byte[]arg3bool
Returns
Exceptions
GetIterator(ColumnFamilyHandle)
public RocksIterator GetIterator(ColumnFamilyHandle arg0)Parameters
Returns
GetIterator(ReadOptions)
public RocksIterator GetIterator(ReadOptions arg0)Parameters
arg0ReadOptions
Returns
GetIterator(ReadOptions, ColumnFamilyHandle)
public RocksIterator GetIterator(ReadOptions arg0, ColumnFamilyHandle arg1)Parameters
Returns
IsDeadlockDetect()
public bool IsDeadlockDetect()Returns
Merge(ByteBuffer, ByteBuffer)
public void Merge(ByteBuffer arg0, ByteBuffer arg1)Parameters
arg0ByteBufferarg1ByteBuffer
Exceptions
Merge(ColumnFamilyHandle, ByteBuffer, ByteBuffer)
public void Merge(ColumnFamilyHandle arg0, ByteBuffer arg1, ByteBuffer arg2)Parameters
arg0ColumnFamilyHandlearg1ByteBufferarg2ByteBuffer
Exceptions
Merge(ColumnFamilyHandle, ByteBuffer, ByteBuffer, bool)
public void Merge(ColumnFamilyHandle arg0, ByteBuffer arg1, ByteBuffer arg2, bool arg3)Parameters
arg0ColumnFamilyHandlearg1ByteBufferarg2ByteBufferarg3bool
Exceptions
Merge(ColumnFamilyHandle, byte[], byte[])
public void Merge(ColumnFamilyHandle arg0, byte[] arg1, byte[] arg2)Parameters
arg0ColumnFamilyHandlearg1byte[]arg2byte[]
Exceptions
Merge(ColumnFamilyHandle, byte[], byte[], bool)
public void Merge(ColumnFamilyHandle arg0, byte[] arg1, byte[] arg2, bool arg3)Parameters
arg0ColumnFamilyHandlearg1byte[]arg2byte[]arg3bool
Exceptions
Merge(byte[], byte[])
public void Merge(byte[] arg0, byte[] arg1)Parameters
Exceptions
MergeUntracked(ByteBuffer, ByteBuffer)
public void MergeUntracked(ByteBuffer arg0, ByteBuffer arg1)Parameters
arg0ByteBufferarg1ByteBuffer
Exceptions
MergeUntracked(ColumnFamilyHandle, ByteBuffer, ByteBuffer)
public void MergeUntracked(ColumnFamilyHandle arg0, ByteBuffer arg1, ByteBuffer arg2)Parameters
arg0ColumnFamilyHandlearg1ByteBufferarg2ByteBuffer
Exceptions
MergeUntracked(ColumnFamilyHandle, byte[], byte[])
public void MergeUntracked(ColumnFamilyHandle arg0, byte[] arg1, byte[] arg2)Parameters
arg0ColumnFamilyHandlearg1byte[]arg2byte[]
Exceptions
MergeUntracked(byte[], byte[])
public void MergeUntracked(byte[] arg0, byte[] arg1)Parameters
Exceptions
MultiGetAsList(ReadOptions, List<ColumnFamilyHandle>, List<byte[]>)
public List<byte[]> MultiGetAsList(ReadOptions arg0, List<ColumnFamilyHandle> arg1, List<byte[]> arg2)Parameters
arg0ReadOptionsarg1List<ColumnFamilyHandle>arg2List<byte[]>
Returns
Exceptions
MultiGetAsList(ReadOptions, List<byte[]>)
public List<byte[]> MultiGetAsList(ReadOptions arg0, List<byte[]> arg1)Parameters
arg0ReadOptionsarg1List<byte[]>
Returns
Exceptions
MultiGetForUpdateAsList(ReadOptions, List<ColumnFamilyHandle>, List<byte[]>)
public List<byte[]> MultiGetForUpdateAsList(ReadOptions arg0, List<ColumnFamilyHandle> arg1, List<byte[]> arg2)Parameters
arg0ReadOptionsarg1List<ColumnFamilyHandle>arg2List<byte[]>
Returns
Exceptions
MultiGetForUpdateAsList(ReadOptions, List<byte[]>)
public List<byte[]> MultiGetForUpdateAsList(ReadOptions arg0, List<byte[]> arg1)Parameters
arg0ReadOptionsarg1List<byte[]>
Returns
Exceptions
Prepare()
public void Prepare()Exceptions
Put(ByteBuffer, ByteBuffer)
public void Put(ByteBuffer arg0, ByteBuffer arg1)Parameters
arg0ByteBufferarg1ByteBuffer
Exceptions
Put(ColumnFamilyHandle, ByteBuffer, ByteBuffer)
public void Put(ColumnFamilyHandle arg0, ByteBuffer arg1, ByteBuffer arg2)Parameters
arg0ColumnFamilyHandlearg1ByteBufferarg2ByteBuffer
Exceptions
Put(ColumnFamilyHandle, ByteBuffer, ByteBuffer, bool)
public void Put(ColumnFamilyHandle arg0, ByteBuffer arg1, ByteBuffer arg2, bool arg3)Parameters
arg0ColumnFamilyHandlearg1ByteBufferarg2ByteBufferarg3bool
Exceptions
Put(ColumnFamilyHandle, byte[], byte[])
public void Put(ColumnFamilyHandle arg0, byte[] arg1, byte[] arg2)Parameters
arg0ColumnFamilyHandlearg1byte[]arg2byte[]
Exceptions
Put(ColumnFamilyHandle, byte[], byte[], bool)
public void Put(ColumnFamilyHandle arg0, byte[] arg1, byte[] arg2, bool arg3)Parameters
arg0ColumnFamilyHandlearg1byte[]arg2byte[]arg3bool
Exceptions
Put(ColumnFamilyHandle, byte[][], byte[][])
public void Put(ColumnFamilyHandle arg0, byte[][] arg1, byte[][] arg2)Parameters
arg0ColumnFamilyHandlearg1byte[][]arg2byte[][]
Exceptions
Put(ColumnFamilyHandle, byte[][], byte[][], bool)
public void Put(ColumnFamilyHandle arg0, byte[][] arg1, byte[][] arg2, bool arg3)Parameters
arg0ColumnFamilyHandlearg1byte[][]arg2byte[][]arg3bool
Exceptions
Put(byte[], byte[])
public void Put(byte[] arg0, byte[] arg1)Parameters
Exceptions
Put(byte[][], byte[][])
public void Put(byte[][] arg0, byte[][] arg1)Parameters
Exceptions
PutLogData(byte[])
public void PutLogData(byte[] arg0)Parameters
PutUntracked(ColumnFamilyHandle, byte[], byte[])
public void PutUntracked(ColumnFamilyHandle arg0, byte[] arg1, byte[] arg2)Parameters
arg0ColumnFamilyHandlearg1byte[]arg2byte[]
Exceptions
PutUntracked(ColumnFamilyHandle, byte[][], byte[][])
public void PutUntracked(ColumnFamilyHandle arg0, byte[][] arg1, byte[][] arg2)Parameters
arg0ColumnFamilyHandlearg1byte[][]arg2byte[][]
Exceptions
PutUntracked(byte[], byte[])
public void PutUntracked(byte[] arg0, byte[] arg1)Parameters
Exceptions
PutUntracked(byte[][], byte[][])
public void PutUntracked(byte[][] arg0, byte[][] arg1)Parameters
Exceptions
RebuildFromWriteBatch(WriteBatch)
public void RebuildFromWriteBatch(WriteBatch arg0)Parameters
arg0WriteBatch
Exceptions
Rollback()
public void Rollback()Exceptions
RollbackToSavePoint()
public void RollbackToSavePoint()Exceptions
SetLockTimeout(long)
public void SetLockTimeout(long arg0)Parameters
SetSavePoint()
https://www.javadoc.io/doc/org.rocksdb/rocksdbjni/10.1.3/org/rocksdb/Transaction.html#setSavePoint()
public void SetSavePoint()Exceptions
SetSnapshot()
public void SetSnapshot()SetSnapshotOnNextOperation()
public void SetSnapshotOnNextOperation()SetSnapshotOnNextOperation(AbstractTransactionNotifier)
public void SetSnapshotOnNextOperation(AbstractTransactionNotifier arg0)Parameters
SingleDelete(ColumnFamilyHandle, byte[])
public void SingleDelete(ColumnFamilyHandle arg0, byte[] arg1)Parameters
arg0ColumnFamilyHandlearg1byte[]
Exceptions
SingleDelete(ColumnFamilyHandle, byte[], bool)
public void SingleDelete(ColumnFamilyHandle arg0, byte[] arg1, bool arg2)Parameters
arg0ColumnFamilyHandlearg1byte[]arg2bool
Exceptions
SingleDelete(ColumnFamilyHandle, byte[][])
public void SingleDelete(ColumnFamilyHandle arg0, byte[][] arg1)Parameters
arg0ColumnFamilyHandlearg1byte[][]
Exceptions
SingleDelete(ColumnFamilyHandle, byte[][], bool)
public void SingleDelete(ColumnFamilyHandle arg0, byte[][] arg1, bool arg2)Parameters
arg0ColumnFamilyHandlearg1byte[][]arg2bool
Exceptions
SingleDelete(byte[])
public void SingleDelete(byte[] arg0)Parameters
Exceptions
SingleDelete(byte[][])
public void SingleDelete(byte[][] arg0)Parameters
Exceptions
UndoGetForUpdate(ColumnFamilyHandle, byte[])
public void UndoGetForUpdate(ColumnFamilyHandle arg0, byte[] arg1)Parameters
arg0ColumnFamilyHandlearg1byte[]
UndoGetForUpdate(byte[])
public void UndoGetForUpdate(byte[] arg0)