xref: /aosp_15_r20/external/leveldb/issues/issue178_test.cc (revision 9507f98c5f32dee4b5f9e4a38cd499f3ff5c4490)
1*9507f98cSAndroid Build Coastguard Worker // Copyright (c) 2013 The LevelDB Authors. All rights reserved.
2*9507f98cSAndroid Build Coastguard Worker // Use of this source code is governed by a BSD-style license that can be
3*9507f98cSAndroid Build Coastguard Worker // found in the LICENSE file. See the AUTHORS file for names of contributors.
4*9507f98cSAndroid Build Coastguard Worker 
5*9507f98cSAndroid Build Coastguard Worker // Test for issue 178: a manual compaction causes deleted data to reappear.
6*9507f98cSAndroid Build Coastguard Worker #include <cstdlib>
7*9507f98cSAndroid Build Coastguard Worker #include <iostream>
8*9507f98cSAndroid Build Coastguard Worker #include <sstream>
9*9507f98cSAndroid Build Coastguard Worker 
10*9507f98cSAndroid Build Coastguard Worker #include "gtest/gtest.h"
11*9507f98cSAndroid Build Coastguard Worker #include "leveldb/db.h"
12*9507f98cSAndroid Build Coastguard Worker #include "leveldb/write_batch.h"
13*9507f98cSAndroid Build Coastguard Worker #include "util/testutil.h"
14*9507f98cSAndroid Build Coastguard Worker 
15*9507f98cSAndroid Build Coastguard Worker namespace {
16*9507f98cSAndroid Build Coastguard Worker 
17*9507f98cSAndroid Build Coastguard Worker const int kNumKeys = 1100000;
18*9507f98cSAndroid Build Coastguard Worker 
Key1(int i)19*9507f98cSAndroid Build Coastguard Worker std::string Key1(int i) {
20*9507f98cSAndroid Build Coastguard Worker   char buf[100];
21*9507f98cSAndroid Build Coastguard Worker   std::snprintf(buf, sizeof(buf), "my_key_%d", i);
22*9507f98cSAndroid Build Coastguard Worker   return buf;
23*9507f98cSAndroid Build Coastguard Worker }
24*9507f98cSAndroid Build Coastguard Worker 
Key2(int i)25*9507f98cSAndroid Build Coastguard Worker std::string Key2(int i) { return Key1(i) + "_xxx"; }
26*9507f98cSAndroid Build Coastguard Worker 
TEST(Issue178,Test)27*9507f98cSAndroid Build Coastguard Worker TEST(Issue178, Test) {
28*9507f98cSAndroid Build Coastguard Worker   // Get rid of any state from an old run.
29*9507f98cSAndroid Build Coastguard Worker   std::string dbpath = testing::TempDir() + "leveldb_cbug_test";
30*9507f98cSAndroid Build Coastguard Worker   DestroyDB(dbpath, leveldb::Options());
31*9507f98cSAndroid Build Coastguard Worker 
32*9507f98cSAndroid Build Coastguard Worker   // Open database.  Disable compression since it affects the creation
33*9507f98cSAndroid Build Coastguard Worker   // of layers and the code below is trying to test against a very
34*9507f98cSAndroid Build Coastguard Worker   // specific scenario.
35*9507f98cSAndroid Build Coastguard Worker   leveldb::DB* db;
36*9507f98cSAndroid Build Coastguard Worker   leveldb::Options db_options;
37*9507f98cSAndroid Build Coastguard Worker   db_options.create_if_missing = true;
38*9507f98cSAndroid Build Coastguard Worker   db_options.compression = leveldb::kNoCompression;
39*9507f98cSAndroid Build Coastguard Worker   ASSERT_LEVELDB_OK(leveldb::DB::Open(db_options, dbpath, &db));
40*9507f98cSAndroid Build Coastguard Worker 
41*9507f98cSAndroid Build Coastguard Worker   // create first key range
42*9507f98cSAndroid Build Coastguard Worker   leveldb::WriteBatch batch;
43*9507f98cSAndroid Build Coastguard Worker   for (size_t i = 0; i < kNumKeys; i++) {
44*9507f98cSAndroid Build Coastguard Worker     batch.Put(Key1(i), "value for range 1 key");
45*9507f98cSAndroid Build Coastguard Worker   }
46*9507f98cSAndroid Build Coastguard Worker   ASSERT_LEVELDB_OK(db->Write(leveldb::WriteOptions(), &batch));
47*9507f98cSAndroid Build Coastguard Worker 
48*9507f98cSAndroid Build Coastguard Worker   // create second key range
49*9507f98cSAndroid Build Coastguard Worker   batch.Clear();
50*9507f98cSAndroid Build Coastguard Worker   for (size_t i = 0; i < kNumKeys; i++) {
51*9507f98cSAndroid Build Coastguard Worker     batch.Put(Key2(i), "value for range 2 key");
52*9507f98cSAndroid Build Coastguard Worker   }
53*9507f98cSAndroid Build Coastguard Worker   ASSERT_LEVELDB_OK(db->Write(leveldb::WriteOptions(), &batch));
54*9507f98cSAndroid Build Coastguard Worker 
55*9507f98cSAndroid Build Coastguard Worker   // delete second key range
56*9507f98cSAndroid Build Coastguard Worker   batch.Clear();
57*9507f98cSAndroid Build Coastguard Worker   for (size_t i = 0; i < kNumKeys; i++) {
58*9507f98cSAndroid Build Coastguard Worker     batch.Delete(Key2(i));
59*9507f98cSAndroid Build Coastguard Worker   }
60*9507f98cSAndroid Build Coastguard Worker   ASSERT_LEVELDB_OK(db->Write(leveldb::WriteOptions(), &batch));
61*9507f98cSAndroid Build Coastguard Worker 
62*9507f98cSAndroid Build Coastguard Worker   // compact database
63*9507f98cSAndroid Build Coastguard Worker   std::string start_key = Key1(0);
64*9507f98cSAndroid Build Coastguard Worker   std::string end_key = Key1(kNumKeys - 1);
65*9507f98cSAndroid Build Coastguard Worker   leveldb::Slice least(start_key.data(), start_key.size());
66*9507f98cSAndroid Build Coastguard Worker   leveldb::Slice greatest(end_key.data(), end_key.size());
67*9507f98cSAndroid Build Coastguard Worker 
68*9507f98cSAndroid Build Coastguard Worker   // commenting out the line below causes the example to work correctly
69*9507f98cSAndroid Build Coastguard Worker   db->CompactRange(&least, &greatest);
70*9507f98cSAndroid Build Coastguard Worker 
71*9507f98cSAndroid Build Coastguard Worker   // count the keys
72*9507f98cSAndroid Build Coastguard Worker   leveldb::Iterator* iter = db->NewIterator(leveldb::ReadOptions());
73*9507f98cSAndroid Build Coastguard Worker   size_t num_keys = 0;
74*9507f98cSAndroid Build Coastguard Worker   for (iter->SeekToFirst(); iter->Valid(); iter->Next()) {
75*9507f98cSAndroid Build Coastguard Worker     num_keys++;
76*9507f98cSAndroid Build Coastguard Worker   }
77*9507f98cSAndroid Build Coastguard Worker   delete iter;
78*9507f98cSAndroid Build Coastguard Worker   ASSERT_EQ(kNumKeys, num_keys) << "Bad number of keys";
79*9507f98cSAndroid Build Coastguard Worker 
80*9507f98cSAndroid Build Coastguard Worker   // close database
81*9507f98cSAndroid Build Coastguard Worker   delete db;
82*9507f98cSAndroid Build Coastguard Worker   DestroyDB(dbpath, leveldb::Options());
83*9507f98cSAndroid Build Coastguard Worker }
84*9507f98cSAndroid Build Coastguard Worker 
85*9507f98cSAndroid Build Coastguard Worker }  // anonymous namespace
86*9507f98cSAndroid Build Coastguard Worker 
main(int argc,char ** argv)87*9507f98cSAndroid Build Coastguard Worker int main(int argc, char** argv) {
88*9507f98cSAndroid Build Coastguard Worker   testing::InitGoogleTest(&argc, argv);
89*9507f98cSAndroid Build Coastguard Worker   return RUN_ALL_TESTS();
90*9507f98cSAndroid Build Coastguard Worker }
91