thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-15 03:53:41 +00:00
Code Issues Packages Projects Releases Wiki Activity

disable WAL

Browse Source
This commit is contained in:
Han Fei 2024-07-09 15:22:20 +00:00
parent 36e51f3ce0
commit d89ed1fdcb
1 changed files with 14 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
src/Coordination/RocksDBContainer.h
View File

@ -8,6 +8,7 @@
#include <IO/ReadBufferFromString.h>
#include <rocksdb/convenience.h>
#include <rocksdb/options.h>
#include <rocksdb/status.h>
#include <rocksdb/table.h>
#include <rocksdb/snapshot.h>
@ -195,7 +196,6 @@ public:
rocksdb_dir, status.ToString());
}
rocksdb_ptr = std::unique_ptr<rocksdb::DB>(db);
/// storage_ptr = storage_;
initialized = true;
}
@ -312,8 +312,10 @@ public:
}
else if (status.IsNotFound())
{
// storage->addDigest(value, key);
status = rocksdb_ptr->Put(rocksdb::WriteOptions(), encoded_key, value.getEncodedString());
rocksdb::WriteOptions write_options;
write_options.disableWAL = true;
status = rocksdb_ptr->Put(write_options, encoded_key, value.getEncodedString());
if (status.ok())
{
counter++;
@ -336,7 +338,10 @@ public:
else if (!status.ok())
throw Exception(ErrorCodes::ROCKSDB_ERROR, "Got rocksdb error during get. The error message is {}.", status.ToString());
status = rocksdb_ptr->Put(rocksdb::WriteOptions(), encoded_key, value.getEncodedString());
rocksdb::WriteOptions write_options;
write_options.disableWAL = true;
status = rocksdb_ptr->Put(write_options, encoded_key, value.getEncodedString());
if (status.ok())
counter += increase_counter;
else
@ -361,7 +366,11 @@ public:
{
/// storage->removeDigest(value, key);
const std::string & encoded_key = getEncodedKey(key);
auto status = rocksdb_ptr->Delete(rocksdb::WriteOptions(), encoded_key);
rocksdb::WriteOptions write_options;
write_options.disableWAL = true;
auto status = rocksdb_ptr->Delete(write_options, encoded_key);
if (status.IsNotFound())
return false;
if (status.ok())
@ -445,8 +454,6 @@ private:
std::unique_ptr<rocksdb::DB> rocksdb_ptr;
/// Storage* storage_ptr;
const rocksdb::Snapshot * snapshot;
bool snapshot_mode{false};