aboutsummaryrefslogtreecommitdiff
path: root/rwtransaction_test.go
diff options
context:
space:
mode:
authorBen Johnson <benbjohnson@yahoo.com>2014-02-13 10:59:47 -0700
committerBen Johnson <benbjohnson@yahoo.com>2014-02-13 10:59:47 -0700
commit34005ecd76f65c18920e686e3bfdb9ad5e5754a2 (patch)
tree3597cf9a764ba9e99779477a70f7bb71848d1a4c /rwtransaction_test.go
parentMerge pull request #24 from benbjohnson/remap (diff)
parentAPI Documentation. (diff)
downloaddedo-34005ecd76f65c18920e686e3bfdb9ad5e5754a2.tar.gz
dedo-34005ecd76f65c18920e686e3bfdb9ad5e5754a2.tar.xz
Merge pull request #29 from benbjohnson/cleanup
API Documentation
Diffstat (limited to 'rwtransaction_test.go')
-rw-r--r--rwtransaction_test.go18
1 files changed, 12 insertions, 6 deletions
diff --git a/rwtransaction_test.go b/rwtransaction_test.go
index 88a246f..67855be 100644
--- a/rwtransaction_test.go
+++ b/rwtransaction_test.go
@@ -44,7 +44,7 @@ func TestRWTransactionRecreateBucket(t *testing.T) {
// Create the same bucket again.
err = db.CreateBucket("widgets")
- assert.Equal(t, err, &Error{"bucket already exists", nil})
+ assert.Equal(t, err, BucketExistsError)
})
}
@@ -52,7 +52,7 @@ func TestRWTransactionRecreateBucket(t *testing.T) {
func TestRWTransactionCreateBucketWithoutName(t *testing.T) {
withOpenDB(func(db *DB, path string) {
err := db.CreateBucket("")
- assert.Equal(t, err, &Error{"bucket name cannot be blank", nil})
+ assert.Equal(t, err, BucketNameRequiredError)
})
}
@@ -63,7 +63,7 @@ func TestRWTransactionCreateBucketWithLongName(t *testing.T) {
assert.NoError(t, err)
err = db.CreateBucket(strings.Repeat("X", 256))
- assert.Equal(t, err, &Error{"bucket name too long", nil})
+ assert.Equal(t, err, BucketNameTooLargeError)
})
}
@@ -152,7 +152,9 @@ func TestRWTransactionPutMultiple(t *testing.T) {
// Verify all items exist.
txn, _ := db.Transaction()
for _, item := range items {
- if !assert.Equal(t, item.Value, txn.Get("widgets", item.Key)) {
+ value, err := txn.Get("widgets", item.Key)
+ assert.NoError(t, err)
+ if !assert.Equal(t, item.Value, value) {
db.CopyFile("/tmp/bolt.put.multiple.db")
t.FailNow()
}
@@ -188,11 +190,15 @@ func TestRWTransactionDelete(t *testing.T) {
txn, _ := db.Transaction()
for j, exp := range items {
if j > i {
- if !assert.Equal(t, exp.Value, txn.Get("widgets", exp.Key)) {
+ value, err := txn.Get("widgets", exp.Key)
+ assert.NoError(t, err)
+ if !assert.Equal(t, exp.Value, value) {
t.FailNow()
}
} else {
- if !assert.Nil(t, txn.Get("widgets", exp.Key)) {
+ value, err := txn.Get("widgets", exp.Key)
+ assert.NoError(t, err)
+ if !assert.Nil(t, value) {
t.FailNow()
}
}