golang操作bolt数据库

栏目: Go · 发布时间: 7年前

package main

import (
	"fmt"

	"github.com/boltdb/bolt"
)

var (
	db     *bolt.DB
	bucket []byte
)

const dbname = "module.db"

func init() {
	//创建bolt数据库本地文件
	dbc, err := bolt.Open(dbname, 0600, nil)

	//初始化bucket
	bucket = []byte("demoBucket")
	if err != nil {
		fmt.Println("open err:", err)
		return
	} else {
		db = dbc
	}
	//创建bucket
	db.Update(func(tx *bolt.Tx) error {
		_, err := tx.CreateBucket(bucket)
		return err
	})
}

//把数据插入到bolt数据库中,相当于 redis 中的set命令
func insert(key, value string) {

	k := []byte(key)
	v := []byte(value)
	db.Update(func(tx *bolt.Tx) error {
		b := tx.Bucket(bucket)
		err := b.Put(k, v)
		return err
	})
}

//读取一条数据
func read(key string) string {
	k := []byte(key)
	var val []byte
	db.View(func(tx *bolt.Tx) error {
		b := tx.Bucket(bucket)
		val = b.Get(k)
		return nil
	})
	return string(val)
}

//遍历指定的bucket中的数据
func fetchAll(buk []byte) {
	db.View(func(tx *bolt.Tx) error {
		b := tx.Bucket(buk)
		cur := b.Cursor()
		for k, v := cur.First(); k != nil; k, v = cur.Next() {
			fmt.Printf("key is %s,value is %s\n", k, v)
		}
		return nil
	})
}

func main() {
	defer db.Close()

	insert("hello", "Hello World,This is Bolt Database11..")
	insert("hello2", "Hello World,This is Bolt Database22..")
	fmt.Println(read("hello"))
	fmt.Println(read("hello2"))

	insert("news1", "this is a title.")

	fetchAll(bucket)

}

以上就是本文的全部内容,希望本文的内容对大家的学习或者工作能带来一定的帮助,也希望大家多多支持 码农网

查看所有标签

猜你喜欢:

本站部分资源来源于网络,本站转载出于传递更多信息之目的,版权归原作者或者来源机构所有,如转载稿涉及版权问题,请联系我们

跨境电商——阿里巴巴速卖通宝典

跨境电商——阿里巴巴速卖通宝典

速卖通大学 编著 / 电子工业出版社 / 2015-1 / 69.00元

跨境电商作为中国电子商务发展的最新趋势,受到了全社会越来越多的重视,大量中国卖家借助阿里巴巴速卖通平台,将产品直接售卖到全球的消费者手中,通过这条短得不能再短的交易链,获得了丰厚的回报。 但同时,跨境电商这一贸易形式,对卖家的综合素质要求比较高:卖家要对海外市场比较熟悉,对跨境物流有所把握,能够用外语进行产品介绍和客户交流,通过跨境结算拿到货款……诸如此类的门槛,让不少新卖家心生畏难,而所有......一起来看看 《跨境电商——阿里巴巴速卖通宝典》 这本书的介绍吧!

RGB转16进制工具
RGB转16进制工具

RGB HEX 互转工具

html转js在线工具
html转js在线工具

html转js在线工具

HSV CMYK 转换工具
HSV CMYK 转换工具

HSV CMYK互换工具