diff options
author | Ben Johnson <benbjohnson@yahoo.com> | 2014-03-21 22:00:34 -0600 |
---|---|---|
committer | Ben Johnson <benbjohnson@yahoo.com> | 2014-03-21 22:00:34 -0600 |
commit | e8d3ae6287ff3e8efa8d3583bb805a3b8dd8e84f (patch) | |
tree | f119755516f9dc0d99f8f32009cd65af427bd593 /cmd/bolt/main_test.go | |
parent | Merge pull request #71 from benbjohnson/munmap-fix (diff) | |
download | dedo-e8d3ae6287ff3e8efa8d3583bb805a3b8dd8e84f.tar.gz dedo-e8d3ae6287ff3e8efa8d3583bb805a3b8dd8e84f.tar.xz |
Add 'bolt get'.
Diffstat (limited to 'cmd/bolt/main_test.go')
-rw-r--r-- | cmd/bolt/main_test.go | 75 |
1 files changed, 75 insertions, 0 deletions
diff --git a/cmd/bolt/main_test.go b/cmd/bolt/main_test.go new file mode 100644 index 0000000..5c70c97 --- /dev/null +++ b/cmd/bolt/main_test.go @@ -0,0 +1,75 @@ +package main_test + +import ( + "io/ioutil" + "os" + "strings" + "testing" + + "github.com/boltdb/bolt" + . "github.com/boltdb/bolt/cmd/bolt" + "github.com/stretchr/testify/assert" +) + +// Ensure that a value can be retrieved from the CLI. +func TestGet(t *testing.T) { + SetTestMode(true) + open(func(db *bolt.DB) { + db.Do(func(tx *bolt.Tx) error { + tx.CreateBucket("widgets") + tx.Bucket("widgets").Put([]byte("foo"), []byte("bar")) + return nil + }) + output := run("get", db.Path(), "widgets", "foo") + assert.Equal(t, "bar", output) + }) +} + +// Ensure that an error is reported if the database is not found. +func TestGetDBNotFound(t *testing.T) { + SetTestMode(true) + output := run("get", "no/such/db", "widgets", "foo") + assert.Equal(t, "stat no/such/db: no such file or directory", output) +} + +// Ensure that an error is reported if the bucket is not found. +func TestGetBucketNotFound(t *testing.T) { + SetTestMode(true) + open(func(db *bolt.DB) { + output := run("get", db.Path(), "widgets", "foo") + assert.Equal(t, "bucket not found: widgets", output) + }) +} + +// Ensure that an error is reported if the key is not found. +func TestGetKeyNotFound(t *testing.T) { + SetTestMode(true) + open(func(db *bolt.DB) { + db.Do(func(tx *bolt.Tx) error { + return tx.CreateBucket("widgets") + }) + output := run("get", db.Path(), "widgets", "foo") + assert.Equal(t, "key not found: foo", output) + }) +} + +// open creates and opens a Bolt database in the temp directory. +func open(fn func(*bolt.DB)) { + f, _ := ioutil.TempFile("", "bolt-") + f.Close() + os.Remove(f.Name()) + defer os.RemoveAll(f.Name()) + + db, err := bolt.Open(f.Name(), 0600) + if err != nil { + panic("db open error: " + err.Error()) + } + fn(db) +} + +// run executes a command against the CLI and returns the output. +func run(args ...string) string { + args = append([]string{"bolt"}, args...) + NewApp().Run(args) + return strings.TrimSpace(LogBuffer()) +} |