Packages

rocksdb

2.2.0
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
63 Versions
0 Dependencies
Dependants
Files
Activity
rocksdb deps rocksdb examples column_families_example.cc
Raw

deps/rocksdb/examples/column_families_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/slice.h"



#if defined(OS_WIN)

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

#else

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

#endif



using ROCKSDB_NAMESPACE::ColumnFamilyDescriptor;

using ROCKSDB_NAMESPACE::ColumnFamilyHandle;

using ROCKSDB_NAMESPACE::ColumnFamilyOptions;

using ROCKSDB_NAMESPACE::DB;

using ROCKSDB_NAMESPACE::DBOptions;

using ROCKSDB_NAMESPACE::Options;

using ROCKSDB_NAMESPACE::ReadOptions;

using ROCKSDB_NAMESPACE::Slice;

using ROCKSDB_NAMESPACE::Status;

using ROCKSDB_NAMESPACE::WriteBatch;

using ROCKSDB_NAMESPACE::WriteOptions;



int main() {

  // open DB

  Options options;

  options.create_if_missing = true;

  DB* db;

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

  assert(s.ok());



  // create column family

  ColumnFamilyHandle* cf;

  s = db->CreateColumnFamily(ColumnFamilyOptions(), "new_cf", &cf);

  assert(s.ok());



  // close DB

  s = db->DestroyColumnFamilyHandle(cf);

  assert(s.ok());

  delete db;



  // open DB with two column families

  std::vector<ColumnFamilyDescriptor> column_families;

  // have to open default column family

  column_families.push_back(ColumnFamilyDescriptor(

      ROCKSDB_NAMESPACE::kDefaultColumnFamilyName, ColumnFamilyOptions()));

  // open the new one, too

  column_families.push_back(

      ColumnFamilyDescriptor("new_cf", ColumnFamilyOptions()));

  std::vector<ColumnFamilyHandle*> handles;

  s = DB::Open(DBOptions(), kDBPath, column_families, &handles, &db);

  assert(s.ok());



  // put and get from non-default column family

  s = db->Put(WriteOptions(), handles[1], Slice("key"), Slice("value"));

  assert(s.ok());

  std::string value;

  s = db->Get(ReadOptions(), handles[1], Slice("key"), &value);

  assert(s.ok());



  // atomic write

  WriteBatch batch;

  batch.Put(handles[0], Slice("key2"), Slice("value2"));

  batch.Put(handles[1], Slice("key3"), Slice("value3"));

  batch.Delete(handles[0], Slice("key"));

  s = db->Write(WriteOptions(), &batch);

  assert(s.ok());



  // drop column family

  s = db->DropColumnFamily(handles[1]);

  assert(s.ok());



  // close db

  for (auto handle : handles) {

    s = db->DestroyColumnFamilyHandle(handle);

    assert(s.ok());

  }

  delete db;



  return 0;

}