Home
last modified time | relevance | path

Searched refs:txnDb (Results 1 – 3 of 3) sorted by relevance

/rocksdb-6.9/java/samples/src/main/java/
DOptimisticTransactionSample.java21 final OptimisticTransactionDB txnDb = in main()
32 readCommitted(txnDb, writeOptions, readOptions); in main()
41 repeatableRead(txnDb, writeOptions, readOptions); in main()
77 value = txnDb.get(readOptions, key1); in readCommitted()
83 txnDb.put(writeOptions, key2, value2); in readCommitted()
104 txnDb.beginTransaction(writeOptions, txnOptions)) { in repeatableRead()
109 txnDb.put(writeOptions, key1, value1); in repeatableRead()
153 txnDb.beginTransaction(writeOptions, txnOptions)) { in readCommitted_monotonicAtomicViews()
156 Snapshot snapshot = txnDb.getSnapshot(); in readCommitted_monotonicAtomicViews()
162 txnDb.put(writeOptions, keyY, valueY); in readCommitted_monotonicAtomicViews()
[all …]
DTransactionSample.java22 final TransactionDB txnDb = in main()
33 readCommitted(txnDb, writeOptions, readOptions); in main()
42 repeatableRead(txnDb, writeOptions, readOptions); in main()
59 private static void readCommitted(final TransactionDB txnDb, in readCommitted() argument
78 value = txnDb.get(readOptions, key1); in readCommitted()
84 txnDb.put(writeOptions, key2, value2); in readCommitted()
94 private static void repeatableRead(final TransactionDB txnDb, in repeatableRead() argument
110 txnDb.put(writeOptions, key1, value1); in repeatableRead()
153 Snapshot snapshot = txnDb.getSnapshot(); in readCommitted_monotonicAtomicViews()
159 txnDb.put(writeOptions, keyY, valueY); in readCommitted_monotonicAtomicViews()
[all …]
/rocksdb-6.9/java/src/test/java/org/rocksdb/
DTransactionTest.java247 final TransactionDB txnDb; in startDb() local
249 txnDb = TransactionDB.open(options, txnDbOptions, in startDb()
263 columnFamilyHandles, txnDb, txnDbOptions, columnFamilyOptions, options); in startDb()
269 private final TransactionDB txnDb; field in TransactionTest.TransactionDBContainer
275 final TransactionDB txnDb, final TransactionDBOptions txnDbOptions, in TransactionDBContainer() argument
281 this.txnDb = txnDb; in TransactionDBContainer()
287 return txnDb.beginTransaction(writeOptions, txnOptions); in beginTransaction()
292 return txnDb.beginTransaction(writeOptions, txnOptions); in beginTransaction()
302 txnDb.close(); in close()