BoltDB简单使用教程
- 时间:
- 浏览:0
1.BoltDB简介
Bolt是有4个多多纯粹Key/Value模型的多线程 。该项目的目标是为不需用删改数据库服务器(如Postgres或MySQL)的项目提供有4个多多简单,快速,可靠的数据库。
BoltDB只需用将其链接到你的应用多线程 代码中即可使用BoltDB提供的API来高效的存取数据。若果BoltDB支持删改可序列化的ACID事务,让应用多线程 都需用更简单的补救多样化操作。
其源码地址为:https://github.com/boltdb/bolt
2.BoltDB内部结构
BoltDB设计源于LMDB,具有以下特点:
-
使用Go语言编写
-
不需用服务器即可运行
-
支持数据内部结构
-
直接使用API存取数据,这么查询句子;
-
支持删改可序列化的ACID事务,这些 内部结构比LevelDB强;
-
数据保趋于稳定内存映射的文件里。这么wal、多线程 压缩和垃圾回收;
-
通过COW技术,可实现无锁的读写并发,若果无法实现无锁的写写并发,这就注定了读性能超高,但写性能一般,适合与读多写少的场景。
BoltDB是有4个多多Key/Value(键/值)存储,这意味着着着这么像SQL RDBMS(MySQL,PostgreSQL等)中的表,这么行,这么列。相反,数据作为键值对存储(如在Golang Maps中)。键值对存储在Buckets中,它们旨在对相似 的对进行分组(这与RDBMS中的表相似 )。若果,为了获得Value(值),需用知道该Value所在的桶和钥匙。
3.BoltDB的安装
Linux中:
$ go get github.com/boltdb/bolt/...
Windows中:
1.前提是若果安装GO语言环境.
2.安装git for windows :
http://git-for-windows.github.io/
3.安装Git后不上能 执行命令:
go get github.com/boltdb/bolt/...
来安装第三方包。这条命令它会把 类库包源代码,下载解压到你的 %GOPATH% 路径中间去,比如:C:\go\gopath\ src\github.com\...
前面是gopath路径,中间是类库,若果它都不同去执行 go install xxx ,生成 D:\go\gopath\pkg\xxxx 有4个多多多的包路径。
注意:
【在GoLand开发工具中,是都需用直接获取GitHub中的源代码的,该法律最好的办法更便捷!】
4. 在代码中导入第三方包:
import ( "github.com/boltdb/bolt" // 从环境变量:%goPath% 中定义的路径去查找第三方类库 )
4.BoltDB简单使用
4.1 打开或创建数据库
//1.数据库创建 //在这里gland直接运行,生成的my.db在main.go上层目录;命令行build在运行句子是当前目录!!! db, err := bolt.Open("chaorsBlock.db", 0300, nil) if err != nil { log.Fatal(err) } defer db.Close()
注意:
若果通过goland多线程
运行创建的my.db会保趋于稳定$GOPATH /src/Project目录下
若果通过go build main.go ; ./main 执行生成的my.db,会保趋于稳定当前目录$GOPATH /src/Project/package下
4.2 数据库操作
4.2.1 创建数据库表
//2.创建表 err = db.Update(func(tx *bolt.Tx) error { //判断要创建的表算不算趋于稳定 b := tx.Bucket([]byte("MyBlocks")) if b == nil { //创建叫"MyBucket"的表 _, err := tx.CreateBucket([]byte("MyBlocks")) if err != nil { //也都需用在这里对表做插入操作 log.Fatal(err) } } //一定要返回nil return nil }) //更新数据库失败 if err != nil { log.Fatal(err) }
4.2.2 更新
//3.更新表数据 err = db.Update(func(tx *bolt.Tx) error { //取出叫"MyBucket"的表 b := tx.Bucket([]byte("MyBlocks")) //往表中间存储数据 if b != nil { //插入的键值对数据类型需用是字节数组 err := b.Put([]byte("l"), []byte("0x0000")) err := b.Put([]byte("ll"), []byte("0x0001")) err := b.Put([]byte("lll"), []byte("0x0002")) if err != nil { log.Fatal(err) } } //一定要返回nil return nil }) //更新数据库失败 if err != nil { log.Fatal(err) }
4.2.3 查询
//4.查看表数据 err = db.View(func(tx *bolt.Tx) error { //取出叫"MyBucket"的表 b := tx.Bucket([]byte("MyBlocks")) //往表中间存储数据 if b != nil { data := b.Get([]byte("l")) fmt.Printf("%s\n", data) data := b.Get([]byte("l")) fmt.Printf("%s\n", data) } //一定要返回nil return nil }) //查询数据库失败 if err != nil { log.Fatal(err) }