An embedded key/value database for Go.
 
 
Go to file
Ben Johnson 9e26598765 Update README.md 2014-01-21 15:47:28 -07:00
LICENSE Initial commit 2013-12-20 10:26:14 -08:00
Makefile Initial db.open. 2014-01-11 22:51:01 -07:00
README.md Update README.md 2014-01-21 15:47:28 -07:00
branch_node.go Intermediate commit. 2014-01-21 15:00:48 -07:00
bucket.go Intermediate commit. 2014-01-21 15:00:48 -07:00
const.go DB.Open(), pages, and meta. 2014-01-10 07:32:12 -07:00
cursor.go Intermediate commit. 2014-01-21 15:00:48 -07:00
db.go Intermediate commit. 2014-01-21 15:00:48 -07:00
db_test.go Begin Transaction.Cursor(). 2014-01-13 10:35:04 -07:00
error.go Initial db.open. 2014-01-11 22:51:01 -07:00
file.go Finish open coverage. 2014-01-13 08:25:56 -07:00
file_test.go Finish open coverage. 2014-01-13 08:25:56 -07:00
info.go DB.Open(), pages, and meta. 2014-01-10 07:32:12 -07:00
meta.go Add system buckets. 2014-01-14 13:01:02 -07:00
node.go Intermediate commit. 2014-01-21 15:00:48 -07:00
os.go Finish open coverage. 2014-01-13 08:25:56 -07:00
os_test.go Finish open coverage. 2014-01-13 08:25:56 -07:00
page.go Intermediate commit. 2014-01-21 15:00:48 -07:00
reader.go Initial db.open. 2014-01-11 22:51:01 -07:00
rwcursor.go Intermediate commit. 2014-01-21 15:00:48 -07:00
rwtransaction.go Intermediate commit. 2014-01-21 15:00:48 -07:00
stat.go Add mock OS. 2014-01-12 14:59:03 -07:00
syscall_darwin.go Mock syscall. 2014-01-12 15:50:35 -07:00
syscall_darwin_test.go Mock syscall. 2014-01-12 15:50:35 -07:00
transaction.go Refactoring to RWCursor, RWTxn, and branch/leaf nodes and pages. 2014-01-17 15:23:39 -07:00
transaction_test.go Refactoring to RWCursor, RWTxn, and branch/leaf nodes and pages. 2014-01-17 15:23:39 -07:00
warn.go Basic types. 2014-01-08 08:06:17 -07:00

README.md

bolt

Overview

A low-level key/value database for Go.

API

Database

The database is the object that represents your data as a whole It is split up into buckets which is analogous to tables in a relational database.

Opening and closing a database

db := DB()
err := db.Open("/path/to/db", 0666)
...
err := db.Close()

Buckets

Buckets are where your actual key/value data gets stored. You can create new buckets from the database and look them up by name.

Creating a bucket

b, err := db.CreateBucket("widgets")

Retrieve an existing bucket

b, err := db.Bucket("widgets")

Retrieve a list of all buckets

buckets, err := db.Buckets()

Deleting a bucket

err := db.DeleteBucket("widgets")

Transactions

Versioning of data in the bucket data happens through a Transaction. These transactions can be either be read-only or read/write transactions. Transactions are what keeps Bolt consistent and allows data to be rolled back if needed.

It may seem strange that read-only access needs to be wrapped in a transaction but this is so Bolt can keep track of what version of the data is currently in use. The space used to hold data is kept until the transaction closes.

One important note is that long running transactions can cause the database to grow in size quickly. Please double check that you are appropriately closing all transactions after you're done with them.

Creating and closing a read-only transaction

t, err := db.Transaction()
t.Close()

Creating and committing a read/write transaction

t, err := db.RWTransaction()
err := t.Commit()

Creating and aborting a read/write transaction

t, err := db.RWTransaction()
err := t.Abort()

Cursors

Cursors provide access to a specific bucket within a transaction.

Creating a read-only cursor

t, err := db.Transaction()
c, err := b.Cursor("widgets")

Creating a read/write cursor

t, err := db.RWTransaction()
c, err := t.RWCursor("widgets")

Iterating over a cursor

for k, v, err := c.First(); k != nil; k, v, err = c.Next() {
	if err != nil {
		return err
	}
	... DO SOMETHING ...
}

Retrieve a value for a specific key

value, err := c.Get([]byte("foo"))
value, err := c.GetString("foo")

Set the value for a key (RWCursor only)

err := c.Put([]byte("foo"), []byte("bar"))
err := c.PutString("foo", "bar")

Delete a given key

err := c.Delete([]byte("foo"))
err := c.DeleteString("foo")