天天看点

leveldb源码分析 之 入门使用

LevelDB是google开源的一个key-value存储引擎库,类似于开源的Lucene索引库一样。其他的软件开发者可以利用该库做二次开发,来满足定制需求。LevelDB采用日志式的写方式来提高写性能,但是牺牲了部分读性能。为了弥补牺牲了的读性能,一些人提议使用SSD作为存储介质。

对于本地化的Key-value存储引擎来说,简单的使用一般都分成三个基本的步骤:(1)打开一个数据库实例;(2)对这个数据库实例进行插入,修改和查询操作;(3)最后在使用完成之后,关闭该数据库。下面将详细讨论该三个步骤:

一、打开一个数据库实例

一个leveldb数据库有一个对应一个文件系统目录的名字。该数据库的所有内容都存储在这个目录下。下面的代码描述了怎样打开一个数据库或者建立一个新的数据库。

Cpp代码

leveldb源码分析 之 入门使用
leveldb源码分析 之 入门使用
leveldb源码分析 之 入门使用
  1. #include <assert.h>  
  2. #include "leveldb/db.h"  
  3. leveldb::DB* db;   
  4. leveldb::Options options;   
  5. options.create_if_missing = true;   
  6. leveldb::Status status = leveldb::DB::Open(options,"/tmp/testdb", &db);   
  7. assert(status.ok());   
  8. 如果打开已存在数据库的时候,需要抛出错误。将以下代码插在leveldb::DB::Open方法前面:   
  9. options.error_if_exists = true;  
#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对应的值。

C代码

leveldb源码分析 之 入门使用
leveldb源码分析 之 入门使用
leveldb源码分析 之 入门使用
  1. std::string value;   
  2. leveldb::Status s = db->Get(leveldb::ReadOptions(), key1, &value);   
  3. if(s.ok()) s = db->Put(leveldb::WriteOptions(), key2, value);   
  4. if(s.ok()) s = db->Delete(leveldb::WriteOptions(), key1);  
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);      

三、关闭数据库

在对数据库进行了一系列的操作之后,需要对数据库进行关闭。该操作比较简单:

C代码

leveldb源码分析 之 入门使用
leveldb源码分析 之 入门使用
leveldb源码分析 之 入门使用
  1. ... open the db as described above...   
  2. ... do something with db ...   
  3. delete db;  
... 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

C代码

leveldb源码分析 之 入门使用
leveldb源码分析 之 入门使用
leveldb源码分析 之 入门使用
  1. #include <assert.h>  
  2. #include <string.h>  
  3. #include <leveldb/db.h>  
  4. #include <iostream>  
  5. int main(){   
  6.     leveldb::DB* db;   
  7.     leveldb::Options options;   
  8.     options.create_if_missing = true;   
  9.     leveldb::Status status = leveldb::DB::Open(options,"/tmp/testdb", &db);   
  10.     assert(status.ok());   
  11.     //write key1,value1  
  12.     std::string key="key";   
  13.     std::string value = "value";   
  14.     status = db->Put(leveldb::WriteOptions(), key,value);   
  15.     assert(status.ok());   
  16.     status = db->Get(leveldb::ReadOptions(), key, &value);   
  17.     assert(status.ok());   
  18.     std::cout<<value<<std::endl;   
  19.     std::string key2 = "key2";   
  20.     //move the value under key to key2  
  21.     status = db->Put(leveldb::WriteOptions(),key2,value);   
  22.     assert(status.ok());   
  23.     status = db->Delete(leveldb::WriteOptions(), key);   
  24.     assert(status.ok());   
  25.     status = db->Get(leveldb::ReadOptions(),key2, &value);   
  26.     assert(status.ok());   
  27.     std::cout<<key2<<"==="<<value<<std::endl;   
  28.     status = db->Get(leveldb::ReadOptions(),key, &value);   
  29.     if(!status.ok()) std::cerr<<key<<"  "<<status.ToString()<<std::endl;   
  30.     else std::cout<<key<<"==="<<value<<std::endl;   
  31.     delete db;   
  32.     return 0;   
  33. }  
#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的路径。

 编译命令:

g++ -o leveldb leveldb.cpp -L /root/research/leveldb-1.7.0 -lleveldb -I /root/research/leveldb-1.7.0/include

运行时会出现 :./leveldb: error while loading shared libraries: libleveldb.so.1: cannot open shared object file: No such file or directory

这个问题。

解决方法:

把自己需要的so会存放在/usr/local/lib这个目录底下,然后。

所以,在/etc/ld.so.conf.d的文件夹中 新建一个文件 加入/usr/local/lib这一行,保存之后,再运行:/sbin/ldconfig –v更新一下配置即可。

ldconfig 命令的用途,主要是在默认搜寻目录(/lib和/usr/lib)以及动态库配置文件/etc/ld.so.conf内所列的目录下,搜索出可共享的动态 链接库(格式如前介绍,lib*.so*),进而创建出动态装入程序(ld.so)所需的连接和缓存文件.缓存文件默认为 /etc/ld.so.cache,此文件保存已排好序的动态链接库名字列表.

ldconfig通常在系统启动时运行,而当用户安装了一个新的动态链接库时,就需要手工运行这个命令.

ldconfig命令行用法如下:

ldconfig [-v|--verbose] [-n] [-N] [-X] [-f CONF] [-C CACHE] [-r ROOT] [-l] [-p|--print-cache] [-c FORMAT] [--format=FORMAT] [-V] [- |--help|--usage] path...

ldconfig可用的选项说明如下:

(1) -v或--verbose : 用此选项时,ldconfig将显示正在扫描的目录及搜索到的动态链接库,还有它所创建的连接的名字.

5、运行结果./test:

C代码

leveldb源码分析 之 入门使用
leveldb源码分析 之 入门使用
leveldb源码分析 之 入门使用
  1. value   
  2. key2===value   
  3. key  NotFound: