Go入门笔记36-一个LevelDB的Go封装

Go LevelDB默认的Get,Put用着很不习惯，稍微封装了下，我的项目结构体比较多，所以默认按value结构体设计,项目中缓存用啥持续纠结，从map->SyncMap->leveldb->ssdb->ledisdb->redis->leveldb研究了一遍,最后还是暂时使用leveldb。

1、代码

package uleveldb

import (
        "encoding/json"
        "fmt"

        "github.com/syndtr/goleveldb/leveldb"
        "github.com/syndtr/goleveldb/leveldb/errors"
        "github.com/syndtr/goleveldb/leveldb/iterator"
        "github.com/syndtr/goleveldb/leveldb/opt"
        "github.com/syndtr/goleveldb/leveldb/util"
)

type Uleveldb struct {
        DB *leveldb.DB
}

//打开Db
func OpenDb(path string) *Uleveldb {
        newdb, err := leveldb.OpenFile(path, nil)
        if _, corrupted := err.(*errors.ErrCorrupted); corrupted {
                newdb, err = leveldb.RecoverFile(path, nil)
        }

        if err != nil {
                panic(err)
        }
        uleveldb := Uleveldb{}
        uleveldb.DB = newdb
        return &uleveldb
}

//释放资源
func (uleveldb *Uleveldb) Close() {
        uleveldb.DB.Close()
}

/**
 * @description: 存储数据
 * @param  {*}
 * @return {*}
 * @param {interface{}} key
 * @param {interface{}} value
 */
func (uleveldb *Uleveldb) Put(key string, value interface{}) error {

        result, err := json.Marshal(value)
        if err != nil {
                fmt.Println("error")
                return err
        }
        err = uleveldb.DB.Put([]byte(key), []byte(result), nil)
        return err
}

/**
 * @description: 读取数据
 * @param  {*}
 * @return {*}
 * @param {interface{}} key
 * @param {interface{}} value
 */
func (uleveldb *Uleveldb) Get(key interface{}) ([]byte, error) {

        return uleveldb.DB.Get([]byte(key.(string)), nil)
}

/**
 * @description: 删除数据
 * @param  {*}
 * @return {*}
 * @param {string} key
 * @param {interface{}} value
 */
func (uleveldb *Uleveldb) Delete(key string) error {

        return uleveldb.DB.Delete([]byte(key), nil)
}

/**
 * @description:  返回指定当前DB迭代器
 * @param  {*}
 * @return {*}
 * @param {string} key
 * @param {interface{}} value
 */
func (uleveldb *Uleveldb) NewIterator(slice *util.Range, ro *opt.ReadOptions) iterator.Iterator {

        return uleveldb.DB.NewIterator(slice, ro)
}