Lines Matching refs:db_
37 ASSERT_TRUE(db_->DeleteRange(WriteOptions(), db_->DefaultColumnFamily(), in TEST_F()
45 ASSERT_TRUE(indexedBatch.DeleteRange(db_->DefaultColumnFamily(), "dr1", "dr1") in TEST_F()
53 ASSERT_OK(db_->DeleteRange(WriteOptions(), db_->DefaultColumnFamily(), in TEST_F()
55 ASSERT_OK(db_->Flush(FlushOptions())); in TEST_F()
68 const Snapshot* snapshot = db_->GetSnapshot(); in TEST_F()
69 db_->DeleteRange(WriteOptions(), db_->DefaultColumnFamily(), "a", "z"); in TEST_F()
70 db_->Flush(FlushOptions()); in TEST_F()
79 db_->ReleaseSnapshot(snapshot); in TEST_F()
104 const Snapshot* snapshot = db_->GetSnapshot(); in TEST_F()
105 db_->DeleteRange(WriteOptions(), db_->DefaultColumnFamily(), Key(0), Key(1)); in TEST_F()
129 db_->ReleaseSnapshot(snapshot); in TEST_F()
149 const Snapshot* snapshot = db_->GetSnapshot(); in TEST_F()
152 ASSERT_OK(db_->DeleteRange(WriteOptions(), db_->DefaultColumnFamily(), in TEST_F()
175 dbfull()->TEST_GetFilesMetaData(db_->DefaultColumnFamily(), &files); in TEST_F()
182 db_->ReleaseSnapshot(snapshot); in TEST_F()
189 const Snapshot* snapshot = db_->GetSnapshot(); in TEST_F()
194 ASSERT_OK(db_->DeleteRange(WriteOptions(), db_->DefaultColumnFamily(), in TEST_F()
197 ASSERT_OK(db_->Flush(FlushOptions())); in TEST_F()
201 dbfull()->TEST_GetFilesMetaData(db_->DefaultColumnFamily(), &files); in TEST_F()
204 db_->ReleaseSnapshot(snapshot); in TEST_F()
208 db_->Put(WriteOptions(), "b1", "val"); in TEST_F()
210 db_->DeleteRange(WriteOptions(), db_->DefaultColumnFamily(), "a", "c")); in TEST_F()
211 db_->Put(WriteOptions(), "b2", "val"); in TEST_F()
213 db_->DeleteRange(WriteOptions(), db_->DefaultColumnFamily(), "a", "b")); in TEST_F()
218 ASSERT_OK(db_->Flush(FlushOptions())); in TEST_F()
222 ASSERT_TRUE(db_->Get(ReadOptions(), "b1", &value).IsNotFound()); in TEST_F()
223 ASSERT_OK(db_->Get(ReadOptions(), "b2", &value)); in TEST_F()
228 db_->Put(WriteOptions(), "unused", "val"); // prevents empty after compaction in TEST_F()
229 db_->Put(WriteOptions(), "b1", "val"); in TEST_F()
230 ASSERT_OK(db_->Flush(FlushOptions())); in TEST_F()
232 db_->DeleteRange(WriteOptions(), db_->DefaultColumnFamily(), "a", "c")); in TEST_F()
233 ASSERT_OK(db_->Flush(FlushOptions())); in TEST_F()
235 db_->DeleteRange(WriteOptions(), db_->DefaultColumnFamily(), "a", "b")); in TEST_F()
236 ASSERT_OK(db_->Flush(FlushOptions())); in TEST_F()
247 ASSERT_TRUE(db_->Get(ReadOptions(), "b1", &value).IsNotFound()); in TEST_F()
264 snapshot = db_->GetSnapshot(); in TEST_F()
266 db_->DeleteRange(WriteOptions(), db_->DefaultColumnFamily(), in TEST_F()
269 db_->Put(WriteOptions(), GetNumericStr(i), "val"); in TEST_F()
271 db_->Flush(FlushOptions()); in TEST_F()
278 ASSERT_OK(db_->Get(read_opts, GetNumericStr(i), &value)); in TEST_F()
280 ASSERT_TRUE(db_->Get(read_opts, GetNumericStr(i), &value).IsNotFound()); in TEST_F()
283 db_->ReleaseSnapshot(snapshot); in TEST_F()
301 db_->DeleteRange(WriteOptions(), db_->DefaultColumnFamily(), in TEST_F()
310 db_->Put(WriteOptions(), GetNumericStr(kNumPerFile * kNumFiles), "val"); in TEST_F()
313 db_->Put(WriteOptions(), GetNumericStr(i * kNumPerFile + j), "val"); in TEST_F()
318 db_->CompactRange(CompactRangeOptions(), nullptr, nullptr); in TEST_F()
331 db_->Get(read_opts, GetNumericStr(i * kNumPerFile + j), &value)); in TEST_F()
334 db_->Get(read_opts, GetNumericStr(i * kNumPerFile + j), &value) in TEST_F()
360 db_->DeleteRange(WriteOptions(), db_->DefaultColumnFamily(), in TEST_F()
386 ASSERT_OK(db_->EnableAutoCompaction({db_->DefaultColumnFamily()})); in TEST_F()
388 ASSERT_OK(db_->SetOptions(db_->DefaultColumnFamily(), in TEST_F()
420 db_->DeleteRange(WriteOptions(), db_->DefaultColumnFamily(), in TEST_F()
447 reinterpret_cast<ColumnFamilyHandleImpl*>(db_->DefaultColumnFamily()) in TEST_F()
470 db_->DeleteRange(WriteOptions(), db_->DefaultColumnFamily(), "key", in TEST_F()
475 db_->Merge(WriteOptions(), "key", val); in TEST_F()
478 db_->Put(WriteOptions(), "prevent_trivial_move", ""); in TEST_F()
487 ASSERT_OK(db_->Get(read_opts, "key", &actual)); in TEST_F()
491 db_->CompactRange(CompactRangeOptions(), nullptr, nullptr); in TEST_F()
494 ASSERT_OK(db_->Get(read_opts, "key", &actual)); in TEST_F()
513 ASSERT_OK(db_->Put(WriteOptions(), "key", val)); in TEST_F()
514 ASSERT_OK(db_->DeleteRange(WriteOptions(), db_->DefaultColumnFamily(), in TEST_F()
516 ASSERT_OK(db_->Merge(WriteOptions(), "key", val)); in TEST_F()
517 ASSERT_OK(db_->Flush(FlushOptions())); in TEST_F()
521 ASSERT_OK(db_->Get(read_opts, "key", &actual)); in TEST_F()
537 db_->DeleteRange(WriteOptions(), db_->DefaultColumnFamily(), "dr1", in TEST_F()
539 db_->Put(WriteOptions(), "key", "val"); in TEST_F()
540 db_->Flush(FlushOptions()); in TEST_F()
541 const Snapshot* snapshot = db_->GetSnapshot(); in TEST_F()
542 db_->DeleteRange(WriteOptions(), db_->DefaultColumnFamily(), "dr2", in TEST_F()
544 db_->Put(WriteOptions(), "key", "val"); in TEST_F()
545 db_->Flush(FlushOptions()); in TEST_F()
549 db_->CompactRange(CompactRangeOptions(), nullptr, nullptr); in TEST_F()
554 db_->ReleaseSnapshot(snapshot); in TEST_F()
594 const Snapshot* snapshot = db_->GetSnapshot(); in TEST_F()
596 db_->Put(WriteOptions(), GetNumericStr(i), "val"); in TEST_F()
601 db_->DeleteRange(WriteOptions(), db_->DefaultColumnFamily(), in TEST_F()
611 auto* iter = db_->NewIterator(read_opts); in TEST_F()
628 db_->ReleaseSnapshot(snapshot); in TEST_F()
634 db_->Put(WriteOptions(), "key", "val"); in TEST_F()
636 db_->DeleteRange(WriteOptions(), db_->DefaultColumnFamily(), "a", "z")); in TEST_F()
640 ASSERT_TRUE(db_->Get(read_opts, "key", &value).IsNotFound()); in TEST_F()
656 db_->Put(WriteOptions(), "key", "val"); in TEST_F()
658 db_->DeleteRange(WriteOptions(), db_->DefaultColumnFamily(), "a", "z")); in TEST_F()
659 db_->Put(WriteOptions(), "blah", "val"); in TEST_F()
663 ASSERT_TRUE(db_->Get(read_opts, "key", &value).IsNotFound()); in TEST_F()
670 db_->Put(WriteOptions(), "key", "val"); in TEST_F()
672 const Snapshot* snapshot = db_->GetSnapshot(); in TEST_F()
674 db_->DeleteRange(WriteOptions(), db_->DefaultColumnFamily(), "a", "z")); in TEST_F()
675 ASSERT_OK(db_->Flush(FlushOptions())); in TEST_F()
679 ASSERT_TRUE(db_->Get(read_opts, "key", &value).IsNotFound()); in TEST_F()
680 db_->ReleaseSnapshot(snapshot); in TEST_F()
693 db_->Merge(WriteOptions(), "key", val); in TEST_F()
696 db_->DeleteRange(WriteOptions(), db_->DefaultColumnFamily(), "key", in TEST_F()
703 ASSERT_OK(db_->Get(read_opts, "key", &actual)); in TEST_F()
709 ASSERT_OK(db_->Get(read_opts, "key", &actual)); in TEST_F()
721 db_->Put(WriteOptions(), "sst_key", "val"); in TEST_F()
723 const Snapshot* snapshot = db_->GetSnapshot(); in TEST_F()
725 db_->DeleteRange(WriteOptions(), db_->DefaultColumnFamily(), "a", "z")); in TEST_F()
726 ASSERT_OK(db_->Flush(FlushOptions())); in TEST_F()
727 db_->Put(WriteOptions(), "imm_key", "val"); in TEST_F()
729 db_->DeleteRange(WriteOptions(), db_->DefaultColumnFamily(), "a", "z")); in TEST_F()
730 db_->Put(WriteOptions(), "mem_key", "val"); in TEST_F()
732 db_->DeleteRange(WriteOptions(), db_->DefaultColumnFamily(), "a", "z")); in TEST_F()
738 ASSERT_OK(db_->Get(read_opts, key, &value)); in TEST_F()
740 db_->ReleaseSnapshot(snapshot); in TEST_F()
755 db_->DeleteRange(WriteOptions(), db_->DefaultColumnFamily(), in TEST_F()
758 db_->Put(WriteOptions(), GetNumericStr(i), "val"); in TEST_F()
761 auto* iter = db_->NewIterator(read_opts); in TEST_F()
788 snapshot = db_->GetSnapshot(); in TEST_F()
789 db_->DeleteRange(WriteOptions(), db_->DefaultColumnFamily(), in TEST_F()
792 db_->Put(WriteOptions(), GetNumericStr(i), "val"); in TEST_F()
796 auto* iter = db_->NewIterator(read_opts); in TEST_F()
805 db_->ReleaseSnapshot(snapshot); in TEST_F()
815 db_->Put(WriteOptions(), "sst_key", "val"); in TEST_F()
817 const Snapshot* snapshot = db_->GetSnapshot(); in TEST_F()
819 db_->DeleteRange(WriteOptions(), db_->DefaultColumnFamily(), "a", "z")); in TEST_F()
820 ASSERT_OK(db_->Flush(FlushOptions())); in TEST_F()
821 db_->Put(WriteOptions(), "imm_key", "val"); in TEST_F()
823 db_->DeleteRange(WriteOptions(), db_->DefaultColumnFamily(), "a", "z")); in TEST_F()
824 db_->Put(WriteOptions(), "mem_key", "val"); in TEST_F()
826 db_->DeleteRange(WriteOptions(), db_->DefaultColumnFamily(), "a", "z")); in TEST_F()
830 auto* iter = db_->NewIterator(read_opts); in TEST_F()
839 db_->ReleaseSnapshot(snapshot); in TEST_F()
844 db_->Put(WriteOptions(), "key", "val"); in TEST_F()
846 const Snapshot* snapshot = db_->GetSnapshot(); in TEST_F()
848 db_->DeleteRange(WriteOptions(), db_->DefaultColumnFamily(), "a", "z")); in TEST_F()
854 auto* iter = db_->NewIterator(read_opts); in TEST_F()
862 ASSERT_OK(db_->Flush(FlushOptions())); in TEST_F()
867 db_->ReleaseSnapshot(snapshot); in TEST_F()
885 db_->Put(WriteOptions(), db_->DefaultColumnFamily(), Key(0), "val")); in TEST_F()
886 ASSERT_OK(db_->Flush(FlushOptions())); in TEST_F()
893 ASSERT_OK(db_->Put(WriteOptions(), db_->DefaultColumnFamily(), Key(i), in TEST_F()
896 ASSERT_OK(db_->Flush(FlushOptions())); in TEST_F()
897 ASSERT_OK(db_->DeleteRange(WriteOptions(), db_->DefaultColumnFamily(), Key(0), in TEST_F()
904 const Snapshot* snapshot = db_->GetSnapshot(); in TEST_F()
905 ASSERT_OK(db_->DeleteRange(WriteOptions(), db_->DefaultColumnFamily(), in TEST_F()
908 ASSERT_OK(db_->Flush(FlushOptions())); in TEST_F()
913 db_->EnableAutoCompaction({db_->DefaultColumnFamily()}); in TEST_F()
915 db_->ReleaseSnapshot(snapshot); in TEST_F()
937 ASSERT_OK(db_->DeleteRange(WriteOptions(), db_->DefaultColumnFamily(), Key(0), in TEST_F()
941 ASSERT_TRUE(db_->Get(ReadOptions(), Key(i), &value).IsNotFound()); in TEST_F()
968 ASSERT_OK(db_->Flush(FlushOptions())); in TEST_F()
973 const Snapshot* snapshot = db_->GetSnapshot(); in TEST_F()
974 db_->DeleteRange(WriteOptions(), db_->DefaultColumnFamily(), Key(0), in TEST_F()
996 db_->GetColumnFamilyMetaData(&meta); in TEST_F()
998 ASSERT_OK(db_->CompactFiles( in TEST_F()
1004 ASSERT_OK(db_->CompactRange(CompactRangeOptions(), &begin, &end)); in TEST_F()
1007 ASSERT_OK(db_->SetOptions(db_->DefaultColumnFamily(), in TEST_F()
1014 db_->ReleaseSnapshot(snapshot); in TEST_F()
1036 ASSERT_OK(db_->Flush(FlushOptions())); in TEST_F()
1042 const Snapshot* snapshot = db_->GetSnapshot(); in TEST_F()
1043 db_->DeleteRange(WriteOptions(), db_->DefaultColumnFamily(), in TEST_F()
1057 ASSERT_OK(db_->Flush(FlushOptions())); in TEST_F()
1107 db_->ReleaseSnapshot(snapshot); in TEST_F()
1118 auto cf = db_->DefaultColumnFamily(); in TEST_F()
1120 ASSERT_OK(db_->Put(WriteOptions(), cf, "a", "a")); in TEST_F()
1121 ASSERT_OK(db_->Flush(FlushOptions(), cf)); in TEST_F()
1126 ASSERT_OK(db_->DeleteRange(WriteOptions(), cf, "b", "c")); in TEST_F()
1128 auto snapshot = db_->GetSnapshot(); in TEST_F()
1129 ASSERT_OK(db_->DeleteRange(WriteOptions(), cf, "a", "b")); in TEST_F()
1130 ASSERT_OK(db_->Flush(FlushOptions(), cf)); in TEST_F()
1131 db_->ReleaseSnapshot(snapshot); in TEST_F()
1140 auto s = db_->Get(ReadOptions(), "a", &v); in TEST_F()
1178 ASSERT_OK(db_->Merge(WriteOptions(), "key", "dummy")); in TEST_F()
1179 ASSERT_OK(db_->Flush(FlushOptions())); in TEST_F()
1187 ASSERT_OK(db_->Merge(WriteOptions(), "key", value)); in TEST_F()
1192 snapshot = db_->GetSnapshot(); in TEST_F()
1194 ASSERT_OK(db_->DeleteRange(WriteOptions(), db_->DefaultColumnFamily(), in TEST_F()
1197 ASSERT_OK(db_->Flush(FlushOptions())); in TEST_F()
1201 ASSERT_TRUE(db_->Get(ReadOptions(), "key", &value).IsNotFound()); in TEST_F()
1212 ASSERT_TRUE(db_->Get(ReadOptions(), "key", &value).IsNotFound()); in TEST_F()
1220 ASSERT_TRUE(db_->Get(ReadOptions(), "key", &value).IsNotFound()); in TEST_F()
1222 db_->ReleaseSnapshot(snapshot); in TEST_F()
1277 ASSERT_OK(db_->Merge(WriteOptions(), key, value)); in TEST_F()
1280 snapshots[0] = db_->GetSnapshot(); in TEST_F()
1283 snapshots[1] = db_->GetSnapshot(); in TEST_F()
1285 ASSERT_OK(db_->DeleteRange(WriteOptions(), db_->DefaultColumnFamily(), in TEST_F()
1288 ASSERT_OK(db_->Flush(FlushOptions())); in TEST_F()
1293 auto* iter = db_->NewIterator(ReadOptions()); in TEST_F()
1306 ASSERT_OK(db_->CompactRange(CompactRangeOptions(), nullptr /* begin_key */, in TEST_F()
1317 ASSERT_OK(db_->Merge(WriteOptions(), Key(i), value)); in TEST_F()
1319 ASSERT_OK(db_->Flush(FlushOptions())); in TEST_F()
1326 db_->ReleaseSnapshot(snapshots[0]); in TEST_F()
1327 db_->ReleaseSnapshot(snapshots[1]); in TEST_F()
1333 ASSERT_OK(db_->CompactRange(CompactRangeOptions(), &begin_key, &end_key)); in TEST_F()
1364 ASSERT_OK(db_->Merge(WriteOptions(), Key(j % kNumKeys), value)); in TEST_F()
1368 snapshot = db_->GetSnapshot(); in TEST_F()
1382 ASSERT_OK(db_->DeleteRange(WriteOptions(), db_->DefaultColumnFamily(), in TEST_F()
1386 ASSERT_OK(db_->Flush(FlushOptions())); in TEST_F()
1390 ASSERT_OK(db_->CompactRange(CompactRangeOptions(), nullptr /* begin_key */, in TEST_F()
1395 auto* iter = db_->NewIterator(ReadOptions()); in TEST_F()
1404 db_->ReleaseSnapshot(snapshot); in TEST_F()
1417 const Snapshot* snapshot = db_->GetSnapshot(); in TEST_F()
1419 ASSERT_OK(db_->DeleteRange(WriteOptions(), db_->DefaultColumnFamily(), Key(0), in TEST_F()
1422 db_->Flush(FlushOptions()); in TEST_F()
1426 auto* iter = db_->NewIterator(read_opts); in TEST_F()
1436 db_->ReleaseSnapshot(snapshot); in TEST_F()
1458 snapshot(db_->GetSnapshot(), in TEST_F()
1459 [this](const Snapshot* s) { db_->ReleaseSnapshot(s); }); in TEST_F()
1461 ASSERT_OK(db_->DeleteRange(WriteOptions(), db_->DefaultColumnFamily(), Key(0), in TEST_F()
1468 std::unique_ptr<Iterator> iter(db_->NewIterator(read_opts)); in TEST_F()
1506 db_->Flush(FlushOptions()); in TEST_F()
1516 ASSERT_OK(db_->DeleteRange(WriteOptions(), db_->DefaultColumnFamily(), in TEST_F()
1525 db_->Flush(FlushOptions()); in TEST_F()
1540 db_->GetLiveFilesMetaData(&all_metadata); in TEST_F()
1557 ASSERT_OK(db_->GetPropertiesOfAllTables(&all_table_props)); in TEST_F()
1589 ASSERT_OK(db_->Flush(FlushOptions())); in TEST_F()
1594 ASSERT_OK(db_->DeleteRange(WriteOptions(), db_->DefaultColumnFamily(), Key(1), in TEST_F()
1596 ASSERT_OK(db_->Flush(FlushOptions())); in TEST_F()
1628 ASSERT_OK(db_->Flush(FlushOptions())); in TEST_F()
1636 ASSERT_OK(db_->Flush(FlushOptions())); in TEST_F()