Hawkin
/
arangodb
mirror of https://gitee.com/bigwinds/arangodb
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

delete views when dropping database

This commit is contained in:
Jan Christoph Uhde 2017-04-04 11:22:22 +02:00
parent 80197fc95e
commit cea5fa8e4f
1 changed files with 4 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
arangod/RocksDBEngine/RocksDBEngine.cpp
View File

@ -719,14 +719,7 @@ Result RocksDBEngine::dropDatabase(TRI_voc_tick_t id) {
rocksdb::WriteOptions options; // TODO: check which options would make sense rocksdb::WriteOptions options; // TODO: check which options would make sense
// remove views // remove views
for (auto& val : indexKVPairs(id)) { for (auto& val : viewKVPairs(id)) {
// delete view documents
// uint64_t objectId =
// basics::VelocyPackHelper::stringUInt64(val.second.slice(), "objectId");
// TODO FIXME get elements of views
// RocksDBKeyBounds bounds = RocksDBKeyBounds::DatabaseViewRange(); //really
// res = rocksutils::removeLargeRange(_db, bounds);
// delete view
globalRocksDBRemove(val.first.string(), options); globalRocksDBRemove(val.first.string(), options);
} }
@ -735,8 +728,9 @@ Result RocksDBEngine::dropDatabase(TRI_voc_tick_t id) {
// delete index documents // delete index documents
uint64_t objectId = uint64_t objectId =
basics::VelocyPackHelper::stringUInt64(val.second.slice(), "objectId"); basics::VelocyPackHelper::stringUInt64(val.second.slice(), "objectId");
VPackSlice min, max; // TODO FIXME RocksDBKeyBounds bounds = RocksDBKeyBounds::IndexRange(
RocksDBKeyBounds bounds = RocksDBKeyBounds::IndexRange(objectId, min, max); objectId, VPackSlice::minKeySlice(), VPackSlice::maxKeySlice()
);
res = rocksutils::removeLargeRange(_db, bounds); res = rocksutils::removeLargeRange(_db, bounds);
// delete index // delete index
globalRocksDBRemove(val.first.string(), options); globalRocksDBRemove(val.first.string(), options);