Packages

rocksdb

1.9.0
3.1.2 3.1.1 3.1.0 3.0.0 2.6.2 2.6.1 retired 2.6.0 retired 2.5.0 2.4.1 2.4.0 2.3.0 2.2.0 2.1.0 2.0.0 1.9.0 1.8.0 1.7.0 1.6.0 1.5.1 1.5.0 1.4.0 1.3.2 1.3.1 1.3.0 1.2.0 1.1.1 1.1.0 1.0.0 0.26.2 0.26.1 0.26.0 0.25.0 0.24.0 0.23.3 0.23.2 0.23.1 0.23.0 0.22.0 0.21.0 0.20.1 0.20.0 0.19.0 0.18.0 0.17.0 0.16.0 0.15.0 0.14.0 0.13.1 0.13.0 0.12.0 0.11.0 0.10.0 0.9.1 0.9.0 0.8.2 0.8.1 0.8.0 0.7.1 0.7.0 0.6.4 0.6.3 0.6.2 0.6.1 0.6.0

RocksDB for Erlang

HexDocs

Current section

Files

Jump to
Readme
64 Versions
0 Dependencies
Dependants
Files
Activity
rocksdb deps rocksdb examples rocksdb_backup_restore_example.cc
Raw

deps/rocksdb/examples/rocksdb_backup_restore_example.cc 

// Copyright (c) 2011-present, Facebook, Inc.  All rights reserved.

//  This source code is licensed under both the GPLv2 (found in the

//  COPYING file in the root directory) and Apache 2.0 License

//  (found in the LICENSE.Apache file in the root directory).



#include <cstdio>

#include <string>

#include <vector>



#include "rocksdb/db.h"

#include "rocksdb/options.h"

#include "rocksdb/utilities/backup_engine.h"



using ROCKSDB_NAMESPACE::BackupEngine;

using ROCKSDB_NAMESPACE::BackupEngineOptions;

using ROCKSDB_NAMESPACE::BackupEngineReadOnly;

using ROCKSDB_NAMESPACE::BackupInfo;

using ROCKSDB_NAMESPACE::DB;

using ROCKSDB_NAMESPACE::Env;

using ROCKSDB_NAMESPACE::Options;

using ROCKSDB_NAMESPACE::ReadOptions;

using ROCKSDB_NAMESPACE::Status;

using ROCKSDB_NAMESPACE::WriteOptions;



#if defined(OS_WIN)

std::string kDBPath = "C:\\Windows\\TEMP\\rocksdb_example";

#else

std::string kDBPath = "/tmp/rocksdb_example";

#endif



int main() {

  DB* db;

  Options options;

  // Optimize RocksDB. This is the easiest way to get RocksDB to perform well

  options.IncreaseParallelism();

  options.OptimizeLevelStyleCompaction();

  // create the DB if it's not already present

  options.create_if_missing = true;



  // open DB

  Status s = DB::Open(options, kDBPath, &db);

  assert(s.ok());



  // Put key-value

  db->Put(WriteOptions(), "key1", "value1");

  assert(s.ok());



  // create backup

  BackupEngine* backup_engine;

  s = BackupEngine::Open(Env::Default(),

                         BackupEngineOptions("/tmp/rocksdb_example_backup"),

                         &backup_engine);

  assert(s.ok());



  backup_engine->CreateNewBackup(db);

  assert(s.ok());



  std::vector<BackupInfo> backup_info;

  backup_engine->GetBackupInfo(&backup_info);



  s = backup_engine->VerifyBackup(1);

  assert(s.ok());



  // Put key-value

  db->Put(WriteOptions(), "key2", "value2");

  assert(s.ok());



  db->Close();

  delete db;

  db = nullptr;



  // restore db to backup 1

  BackupEngineReadOnly* backup_engine_ro;

  s = BackupEngineReadOnly::Open(

      Env::Default(), BackupEngineOptions("/tmp/rocksdb_example_backup"),

      &backup_engine_ro);

  assert(s.ok());



  s = backup_engine_ro->RestoreDBFromBackup(1, "/tmp/rocksdb_example",

                                            "/tmp/rocksdb_example");

  assert(s.ok());



  // open db again

  s = DB::Open(options, kDBPath, &db);

  assert(s.ok());



  std::string value;

  s = db->Get(ReadOptions(), "key1", &value);

  assert(!s.IsNotFound());



  s = db->Get(ReadOptions(), "key2", &value);

  assert(s.IsNotFound());



  delete backup_engine;

  delete backup_engine_ro;

  delete db;



  return 0;

}