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