UnQLite是一个嵌入式NoSQL（键/值存储和文档存储）数据库引擎。不同于其他绝大多数NoSQL数据库，UnQLite没有一个独立的服务器进程。UnQLite直接读/写普通的磁盘文件。包含多个数据集的一个完整的数据库，存储在单一的磁盘文件中。数据库文件格式是跨平台的，可以在32位和64位系统或大端和小端架构之间，自由拷贝一个数据库。UnQLite的主要特点。 详情参考:http://unqlite.github.io/2013/05/26/about/

unqlite安装与配置:

这个我就不多说了，直接上shell脚本。 以下是ubuntu安装shell脚本

<!-- lang: shell -->
#! /bin/sh

# 下载源码
wget -c http://unqlite.org/db/unqlite-db-116.zip

# 解压源码
unzip unqlite-db-116.zip

# 编译源码
gcc -Wall -fPIC -c *.c
gcc -shared -Wl,-soname,libunqlite.so.1 -o libunqlite.so.1.0 *.o

# 建立软链接
sudo cp `pwd`/libunqlite.so.1.0 /usr/local/lib/
sudo cp `pwd`/unqlite.h /usr/local/include/
sudo ln -sf /usr/local/lib/libunqlite.so.1.0 /usr/local/lib/libunqlite.so.1
sudo ln -sf /usr/local/lib/libunqlite.so.1 /usr/local/lib/libunqlite.so

# 建立共享
sudo ldconfig /usr/local/lib/libunqlite.so

# 下载golang unqlite驱动包
git clone git@github.com:ceh/gounqlite.git

使用google go语言测试unqlite数据库

以下是测试代码:

<!-- lang: cpp -->
package main

import (
    "bytes"
    "fmt"
    "github.com/ceh/gounqlite"
    "sync"
    "time"
)

var (
    db    *gounqlite.Handle
    mutex sync.Mutex
)

func init() {
    mutex.Lock()
	defer mutex.Unlock()

	if db != nil {
		return
	}

	// 如果open定义为":mem:"字符，数据存储在内存中;
	// 指定路径文件，数据会存储在文件中。
	udb,err := gounqlite.Open(":mem:")
	if err != nil {
		fmt.Println("Open: ",err.Error())
		return
	}

	db = udb
}

// 测试数据
var kvs = []struct {
    key   []byte
    value []byte
}{
    {[]byte("name"),[]byte("viney")},{[]byte("国家"),[]byte("中国")},{[]byte("email"),[]byte("viney.chow@gmail.com")},}

// 性能测试
func benchmark() {
    count := 1000
    finish := make(chan bool)

    t := time.Now()
        for i := 0; i < count; i++ {
	    go func(i int) {
		    defer func() { finish <- true }()
		    byt := []byte(fmt.Sprint(i))
		    if err := db.Store(byt,byt); err != nil {
			    fmt.Println("benchmark: ",err.Error())
			    return
		    }
	    }(i)
    }

    for i := 0; i < count; i++ {
	    <-finish
    }

    fmt.Println(time.Now().Sub(t).String())
}

func main() {
    // 性能测试
    benchmark()

    // 添加数据/修改数据
    // 如果key有数据会修改数据,否则添加数据
    for _,v := range kvs {
	    // 添加数据
	    if err := db.Store(v.key,v.value); err != nil {
		    fmt.Println("insert: ",err.Error(),string(v.key),string(v.value))
		    return
	    }

	    // 查询
	    if value,err := db.Fetch(v.key); err != nil {
		    fmt.Println("Fetch: ",err.Error())
		    return
	    } else if !bytes.Equal(v.value,value) {
		    fmt.Println("Equal: ",string(v.value),string(value))
		    return
	    }

	    // 修改数据
	    var hello []byte = []byte("hello")
	    if err := db.Store(v.key,hello); err != nil {
		    fmt.Println("update: ",err.Error())
		    return
	    }

	    // 查询修改之后的数据
	    if value,err.Error())
		    return
	    } else if !bytes.Equal(hello,string(hello),string(value))
		    return
	    }

	    // 追加数据
	    var world []byte = []byte("world")
	    if err := db.Append(v.key,world); err != nil {
		    fmt.Println("Append: ",err.Error())
		    return
	    }

	    // 查询追加之后的数据
	    if value,err.Error())
		    return
	    } else if value != nil {
		    hello = append(hello,world...)
		    if !bytes.Equal(value,hello) {
			    fmt.Println("Equal: ",string(value),string(hello))
			    return
		    }
	    }

	    // 删除
	    if err := db.Delete(v.key); err != nil {
		    fmt.Println("Delete: ",err.Error())
		    return
	    }
    }

    // 关闭open
    defer func() {
	    if err := db.Close(); err != nil {
		    fmt.Println("Close: ",err.Error())
		    return
	    }
    }()
}

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!