Home
last modified time | relevance | path

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

/rocksdb-6.9/java/src/test/java/org/rocksdb/
DAbstractTransactionTest.java189 txn.put(testCf, k1, v1); in getPut_cf()
220 final List<ColumnFamilyHandle> cfList = Arrays.asList(testCf, testCf); in multiGetPut_cf()
260 txn.put(testCf, k1, v1); in getForUpdate_cf()
291 final List<ColumnFamilyHandle> cfList = Arrays.asList(testCf, testCf); in multiGetForUpdate_cf()
353 txn.put(testCf, k1, v1); in getIterator_cf()
397 txn.put(testCf, k1, v1); in delete_cf()
400 txn.delete(testCf, k1); in delete_cf()
512 final List<ColumnFamilyHandle> cfList = Arrays.asList(testCf, testCf); in multiGetPutUntracked_cf()
573 txn.put(testCf, k1, v1); in deleteUntracked_cf()
675 txn.put(testCf, k2, v2); in numKeys()
[all …]
DOptimisticTransactionTest.java30 txn.put(testCf, k1, v1); in getForUpdate_cf_conflict()
31 assertThat(txn.get(testCf, readOptions, k1)).isEqualTo(v1); in getForUpdate_cf_conflict()
40 txn2.put(testCf, k1, v12); in getForUpdate_cf_conflict()
108 final List<ColumnFamilyHandle> cfList = Arrays.asList(testCf, testCf); in multiGetForUpdate_cf_conflict()
111 txn.put(testCf, keys[0], values[0]); in multiGetForUpdate_cf_conflict()
112 txn.put(testCf, keys[1], values[1]); in multiGetForUpdate_cf_conflict()
123 txn2.put(testCf, keys[0], otherValue); in multiGetForUpdate_cf_conflict()
124 assertThat(txn2.get(testCf, readOptions, keys[0])) in multiGetForUpdate_cf_conflict()
196 txn.put(testCf, k1, v1); in undoGetForUpdate_cf_conflict()
206 txn3.undoGetForUpdate(testCf, k1); in undoGetForUpdate_cf_conflict()
[all …]
DTransactionTest.java27 final ColumnFamilyHandle testCf = dbContainer.getTestColumnFamily(); in getForUpdate_cf_conflict() local
30 txn.put(testCf, k1, v1); in getForUpdate_cf_conflict()
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()
41 txn2.put(testCf, k1, v12); // should cause an exception! in getForUpdate_cf_conflict()
99 final ColumnFamilyHandle testCf = dbContainer.getTestColumnFamily(); in multiGetForUpdate_cf_conflict() local
100 final List<ColumnFamilyHandle> cfList = Arrays.asList(testCf, testCf); in multiGetForUpdate_cf_conflict()
103 txn.put(testCf, keys[0], values[0]); in multiGetForUpdate_cf_conflict()
104 txn.put(testCf, keys[1], values[1]); in multiGetForUpdate_cf_conflict()
116 txn2.put(testCf, keys[0], otherValue); // should cause an exception! in multiGetForUpdate_cf_conflict()