| /rocksdb-6.9/java/src/main/java/org/rocksdb/ |
| D | Transaction.java | 444 public byte[] getForUpdate(final ReadOptions readOptions, in getForUpdate() method in Transaction
448 return getForUpdate(nativeHandle_, readOptions.nativeHandle_, key, key.length, in getForUpdate()
470 public byte[] getForUpdate(final ReadOptions readOptions, in getForUpdate() method in Transaction
474 return getForUpdate(nativeHandle_, readOptions.nativeHandle_, key, key.length, in getForUpdate()
522 public byte[] getForUpdate(final ReadOptions readOptions, final byte[] key, in getForUpdate() method in Transaction
525 return getForUpdate( in getForUpdate()
1907 private native byte[] getForUpdate(final long handle, final long readOptionsHandle, in getForUpdate() method in Transaction
1910 private native byte[] getForUpdate(final long handle, final long readOptionsHandle, in getForUpdate() method in Transaction
|
| /rocksdb-6.9/java/src/test/java/org/rocksdb/ |
| D | TransactionTest.java | 31 assertThat(txn.getForUpdate(readOptions, testCf, k1, true)).isEqualTo(v1); in getForUpdate_cf_conflict()
37 assertThat(txn3.getForUpdate(readOptions, testCf, k1, true)).isEqualTo(v1); in getForUpdate_cf_conflict()
64 assertThat(txn.getForUpdate(readOptions, k1, true)).isEqualTo(v1); in getForUpdate_conflict()
70 assertThat(txn3.getForUpdate(readOptions, k1, true)).isEqualTo(v1); in getForUpdate_conflict()
|
| D | AbstractTransactionTest.java | 259 assertThat(txn.getForUpdate(readOptions, testCf, k1, true)).isNull(); in getForUpdate_cf()
261 assertThat(txn.getForUpdate(readOptions, testCf, k1, true)).isEqualTo(v1); in getForUpdate_cf()
266 public void getForUpdate() throws RocksDBException { in getForUpdate() method in AbstractTransactionTest
272 assertThat(txn.getForUpdate(readOptions, k1, true)).isNull(); in getForUpdate()
274 assertThat(txn.getForUpdate(readOptions, k1, true)).isEqualTo(v1); in getForUpdate()
762 assertThat(txn.getForUpdate(readOptions, testCf, k1, true)).isNull(); in undoGetForUpdate_cf()
764 assertThat(txn.getForUpdate(readOptions, testCf, k1, true)).isEqualTo(v1); in undoGetForUpdate_cf()
776 assertThat(txn.getForUpdate(readOptions, k1, true)).isNull(); in undoGetForUpdate()
778 assertThat(txn.getForUpdate(readOptions, k1, true)).isEqualTo(v1); in undoGetForUpdate()
|
| D | OptimisticTransactionTest.java | 37 assertThat(txn3.getForUpdate(readOptions, testCf, k1, true)).isEqualTo(v1); in getForUpdate_cf_conflict()
74 assertThat(txn3.getForUpdate(readOptions, k1, true)).isEqualTo(v1); in getForUpdate_conflict()
203 assertThat(txn3.getForUpdate(readOptions, testCf, k1, true)).isEqualTo(v1); in undoGetForUpdate_cf_conflict()
237 assertThat(txn3.getForUpdate(readOptions, k1, true)).isEqualTo(v1); in undoGetForUpdate_conflict()
|
| D | TransactionDBTest.java | 138 assertThat(txn.getForUpdate(readOptions, key, true)).isEqualTo(value); in lockStatusData()
|
| /rocksdb-6.9/java/samples/src/main/java/ |
| D | OptimisticTransactionSample.java | 113 final byte[] value = txn.getForUpdate(readOptions, key1, true); in repeatableRead()
172 value = txn.getForUpdate(readOptions, keyY, true); in readCommitted_monotonicAtomicViews()
|
| D | TransactionSample.java | 117 final byte[] value = txn.getForUpdate(readOptions, key1, true); in repeatableRead()
170 value = txn.getForUpdate(readOptions, keyY, true); in readCommitted_monotonicAtomicViews()
|