Question

怎样操作leveldb数据库，实现增删改查

Answer 1

LevelDB 简介
一、LevelDB入门

LevelDB是Google开源的持久化KV单机数据库，具有
很高的随机写，顺序读/写性能，但是随机读的性能很一般，也就是说，LevelDB很适合应用在查询较少，而写很多的场景。LevelDB应用了LSM
(Log Structured Merge)
策略，lsm_tree对索引变更进行延迟及批量处理，并通过一种类似于归并排序的方式高效地将更新迁移到磁盘，降低索引插入开销，关于LSM，本文在后
面也会简单提及。

根据LevelDB官方网站的描述，LevelDB的特点和限制如下：

特点：
1、key和value都是任意长度的字节数组；
2、entry（即一条K-V记录）默认是按照key的字典顺序存储的，当然开发者也可以重载这个排序函数；
3、提供的基本操作接口：Put()、Delete()、Get()、Batch()；
4、支持批量操作以原子操作进行；
5、可以创建数据全景的snapshot(快照)，并允许在快照中查找数据；
6、可以通过前向（或后向）迭代器遍历数据（迭代器会隐含的创建一个snapshot）；
7、自动使用Snappy压缩数据；
8、可移植性；

限制：
1、非关系型数据模型（NoSQL），不支持sql语句，也不支持索引；
2、一次只允许一个进程访问一个特定的数据库；
3、没有内置的C/S架构，但开发者可以使用LevelDB库自己封装一个server;

LevelDB本身只是一个lib库，在源码目录make编译即可，然后在我们的应用程序里面可以直接include leveldb/include/db.h头文件，该头文件有几个基本的数据库操作接口，下面是一个测试例子：

#include <iostream>
#include <string>
#include <assert.h>    
#include "leveldb/db.h"    

using namespace std;

int main(void)
{      

   leveldb::DB      *db;    
   leveldb::Options  options;    
   options.create_if_missing = true;    

   // open
   leveldb::Status status = leveldb::DB::Open(options,"/tmp/testdb", &db);    
   assert(status.ok());    

   string key = "name";    
   string value = "chenqi";    

   // write
   status = db->Put(leveldb::WriteOptions(), key, value);    
   assert(status.ok());    

   // read
   status = db->Get(leveldb::ReadOptions(), key, &value);    
   assert(status.ok());    

   cout<<value<<endl;    

   // delete
   status = db->Delete(leveldb::WriteOptions(), key);    
   assert(status.ok());        

   status = db->Get(leveldb::ReadOptions(),key, &value);    
   if(!status.ok()) {
       cerr<<key<<"    "<<status.ToString()<<endl;
   } else {
       cout<<key<<"==="<<value<<endl;    
   }  

   // close
   delete db;    

   return 0;    
}

上面的例子演示了如何插入、获取、删除一条记录，编译代码：

g++ -o test test.cpp libleveldb.a -lpthread -Iinclude

执行./test后，会在/tmp下面生成一个目录testdb，里面包含若干文件：

------------------------------------------------------------
LevelDB
是google开源的一个key-value存储引擎库，类似于开源的Lucene索引库一样。其他的软件开发者可以利用该库做二次开发，来满足定制需
求。LevelDB采用日志式的写方式来提高写性能，但是牺牲了部分读性能。为了弥补牺牲了的读性能，一些人提议使用SSD作为存储介质。
对于本地化的Key-value存储引擎来说，简单的使用一般都分成三个基本的步骤：（1）打开一个数据库实例；（2）对这个数据库实例进行插入，修改和查询操作；（3)最后在使用完成之后，关闭该数据库。下面将详细讨论该三个步骤：
一、打开一个数据库实例
一个leveldb数据库有一个对应一个文件系统目录的名字。该数据库的所有内容都存储在这个目录下。下面的代码描述了怎样打开一个数据库或者建立一个新的数据库。

#include <assert.h>    
#include "leveldb/db.h"    
   
leveldb::DB* db;    
leveldb::Options options;    
options.create_if_missing = true;    
leveldb::Status status = leveldb::DB::Open(options,"/tmp/testdb", &db);    
assert(status.ok());  


如果打开已存在数据库的时候，需要抛出错误。将以下代码插在leveldb::DB::Open方法前面：    
options.error_if_exists = true;

二、对数据库的简单读、写操作
LevelDB提供了Put，Delete和Get三个方法对数据库进行修改和查询。例如，下面的代码片段描述了怎样将key1对应的value值，移到key2对应的值。
std::string value;    
leveldb::Status s = db->Get(leveldb::ReadOptions(), key1, &value);    
if(s.ok()) s = db->Put(leveldb::WriteOptions(), key2, value);    
if(s.ok()) s = db->Delete(leveldb::WriteOptions(), key1);



三、关闭数据库
在对数据库进行了一系列的操作之后，需要对数据库进行关闭。该操作比较简单：
... open the db as described above...    
... do something with db ...    
delete db;


上面对levelDB的简单使用做了基本的介绍，接下来就是如何自己写一个完成并且能运行的例子。
1、下载源码  git clone https://code.google.com/p/leveldb/
2、编译源码  cd leveldb && make all
3、编写test.cpp
#include <assert.h>    
#include <string.h>    
#include <leveldb/db.h>    
#include <iostream>    
   
int main(){    
       leveldb::DB* db;    
       leveldb::Options options;    
       options.create_if_missing = true;    
       leveldb::Status status = leveldb::DB::Open(options,"/tmp/testdb", &db);    
       assert(status.ok());    
   
       //write key1,value1    
       std::string key="key";    
       std::string value = "value";    
   
       status = db->Put(leveldb::WriteOptions(), key,value);    
       assert(status.ok());    
   
       status = db->Get(leveldb::ReadOptions(), key, &value);    
       assert(status.ok());    
       std::cout<<value<<std::endl;    
       std::string key2 = "key2";    
           
       //move the value under key to key2    
           
       status = db->Put(leveldb::WriteOptions(),key2,value);    
       assert(status.ok());    
       status = db->Delete(leveldb::WriteOptions(), key);    
   
       assert(status.ok());    
           
       status = db->Get(leveldb::ReadOptions(),key2, &value);    
           
       assert(status.ok());    
       std::cout<<key2<<"==="<<value<<std::endl;    
           
       status = db->Get(leveldb::ReadOptions(),key, &value);    
           
       if(!status.ok()) std::cerr<<key<<"    "<<status.ToString()<<std::endl;    
       else std::cout<<key<<"==="<<value<<std::endl;    
           
       delete db;    
       return 0;    
}



4、编译链接 g++ -o test test.cpp ../leveldb/libleveldb.a -lpthread -I../leveldb/include
    注意libleveldb.a 和leveldb include的路径。

5、运行结果./test：
value    
key2===value    
key    NotFound: