public class TransactionImpl extends Object implements Transaction
Modifier and Type | Field and Description |
---|---|
static long |
DEFAULT_TXN_TIMEOUT |
TXN_STATUS_ACTIVE, TXN_STATUS_COMMITTED, TXN_STATUS_COMMITTING, TXN_STATUS_NO_TXN, TXN_STATUS_PREPARED, TXN_STATUS_PREPARING, TXN_STATUS_ROLLED_BACK, TXN_STATUS_ROLLING_BACK, TXN_STATUS_UNKNOWN
Constructor and Description |
---|
TransactionImpl(FactoryImpl factory,
long txnId) |
Modifier and Type | Method and Description |
---|---|
void |
attachGetOp(String name,
Object key,
Data value) |
void |
attachPutMultiOp(String name,
Object key,
Data value) |
Data |
attachPutOp(String name,
Object key,
Data value,
boolean newRecord) |
Data |
attachPutOp(String name,
Object key,
Data value,
int timeout,
long ttl,
boolean newRecord) |
Data |
attachPutOp(String name,
Object key,
Data value,
long timeout,
boolean newRecord,
int index) |
Data |
attachPutOp(String name,
Object key,
Data value,
long timeout,
long ttl,
boolean newRecord,
int index) |
Data |
attachRemoveOp(String name,
Object key,
Data value,
boolean newRecord) |
Data |
attachRemoveOp(String name,
Object key,
Data value,
boolean newRecord,
int valueCount) |
void |
begin()
Creates a new transaction and associate it with the current thread.
|
void |
commit()
Commits the transaction associated with the current thread.
|
boolean |
containsEntry(String name,
Object key,
Object value) |
boolean |
containsValue(String name,
Object value) |
Data |
get(String name,
Object key) |
long |
getId() |
void |
getMulti(String name,
Object key,
Collection col) |
int |
getStatus()
Returns the status of the transaction associated with the current thread.
|
boolean |
has(String name,
Object key) |
boolean |
has(String name,
Object key,
Object value) |
boolean |
isNew(String name,
Object key) |
boolean |
isRemoved(String name,
Object key) |
List<Map.Entry> |
newEntries(String name) |
Map |
newKeys(String name) |
void |
rollback()
Rolls back the transaction associated with the current thread.
|
int |
size(String name) |
String |
toString() |
public static final long DEFAULT_TXN_TIMEOUT
public TransactionImpl(FactoryImpl factory, long txnId)
public Data attachPutOp(String name, Object key, Data value, int timeout, long ttl, boolean newRecord)
public Data attachPutOp(String name, Object key, Data value, long timeout, boolean newRecord, int index)
public Data attachPutOp(String name, Object key, Data value, long timeout, long ttl, boolean newRecord, int index)
public Data attachRemoveOp(String name, Object key, Data value, boolean newRecord, int valueCount)
public void begin() throws IllegalStateException
Transaction
begin
in interface Transaction
IllegalStateException
- if transaction is already beganpublic void commit() throws IllegalStateException
Transaction
commit
in interface Transaction
IllegalStateException
- if transaction didn't begin.public void rollback() throws IllegalStateException
Transaction
rollback
in interface Transaction
IllegalStateException
- if transaction didn't begin.public long getId()
public int getStatus()
Transaction
getStatus
in interface Transaction
public int size(String name)
public void getMulti(String name, Object key, Collection col)
Copyright © 2013 Hazelcast, Inc.. All rights reserved.