作者:ReganYue
一、什么是BoltDB
這是一款純粹使用Go語言編寫的key/value數(shù)據(jù)庫,據(jù)說它是參考了開源的內(nèi)存映射數(shù)據(jù)庫LMDB。值得注意的是,這款數(shù)據(jù)庫不支持網(wǎng)絡(luò)連接,也沒有復(fù)雜的SQL語句查詢支持。但是它在Go的應(yīng)用中能夠比較方便的來達到數(shù)據(jù)持久化。
二、使用場景
- Go語言編寫的程序,這個程序需要內(nèi)嵌數(shù)據(jù)庫。
- 不需要復(fù)雜的SQL語句查詢。
- 這款數(shù)據(jù)庫更擅長讀的操作,所以在讀多寫少的場景下,它效果比較好。
三、安裝及使用方法
安裝方法很簡單,就是在命令行執(zhí)行:
go get github.com/boltdb/bolt/...
那么我們?nèi)绾未蜷_數(shù)據(jù)庫呢?我們來看一看下面這段代碼。
package mainimport ( "log" "github.com/boltdb/bolt")func main() { // Open the my.db data file in your current directory. // It will be created if it doesnt exist. db, err := bolt.Open("my.db", 0600, nil) if err != nil { log.Fatal(err) } defer db.Close() ...}
這個 bolt.Open()是在給定的路徑上打開數(shù)據(jù)庫。如果要打開的數(shù)據(jù)庫文件不存在,則將自動創(chuàng)建該文件。**
**第二個參數(shù)是文件模式。第三個參數(shù)傳入nil值就讓Bolt使用默認選項打開數(shù)據(jù)庫。
Bolt 多個進程無法同時打開同一個數(shù)據(jù)庫。打開一個已經(jīng)打開的 Bolt 數(shù)據(jù)庫會導(dǎo)致它掛起,直到另一個進程關(guān)閉它。為了防止無限期等待,我們需要給 Open()
函數(shù)一個超時參數(shù):
db, err := bolt.Open("my.db", 0600, &bolt.Options{Timeout: 1 * time.Second})
事務(wù)
Bolt一次只支持一個讀寫事務(wù),但是一次可以支持多個只讀事務(wù)。
用于讀寫的事務(wù)API是Update,二用于讀的事務(wù)API是View。
err := db.Update(func(tx *bolt.Tx) error { ... return nil})
err := db.View(func(tx *bolt.Tx) error { ... return nil})
注意:只讀事務(wù)和讀寫事務(wù)通常不應(yīng)同時在同一個 goroutine 中打開。這可能會導(dǎo)致死鎖,因為讀寫事務(wù)需要定期重新映射數(shù)據(jù)文件,但在只讀事務(wù)打開時無法這樣做。
還有一種****Batch事務(wù)**可以減小并發(fā)寫操作的開銷。Batch 僅在有多個 goroutine 調(diào)用它時才有用。**
err := db.Batch(func(tx *bolt.Tx) error { ... return nil})
讀寫操作
db.Update(func(tx *bolt.Tx) error { b := tx.Bucket([]byte("MyBucket")) err := b.Put([]byte("answer"), []byte("42")) return err})
這是往數(shù)據(jù)庫中寫入鍵為answer值為42的數(shù)據(jù)。
db.View(func(tx *bolt.Tx) error { b := tx.Bucket([]byte("MyBucket")) v := b.Get([]byte("answer")) fmt.Printf("The answer is: %s/n", v) return nil})
這是讀取鍵為answer的數(shù)據(jù)。
是不是發(fā)現(xiàn)有個tx.Bucket()不知道是干什么的呢?
Bolt有個很有意思的地方就是這個Bucket,這個是這個數(shù)據(jù)庫組織數(shù)據(jù)的基本方式,比如有一個Bucket叫公司,這個Bucket里面還建一個Bucket叫部門,里面建一個key:ReganYue,這就說明ReganYue是這個部門里面的人,但是同時也是這個公司里面的人,這個key屬于部門這個Bucket,也屬于公司這個Bucket。