Merge pull request #38 from ucwong/dev

add bolt batch func

Author: ucwong

bolt/bolt.go

@@ -213,5 +213,13 @@ func (b *Bolt) Close() error {
 }
 
 func (b *Bolt) Batch(kvs map[string][]byte) error {
-	panic("Not support")
+	return b.engine.Batch(func(tx *bolt.Tx) error {
+		bucket := tx.Bucket([]byte(GLOBAL))
+		for k, v := range kvs {
+			if err := bucket.Put([]byte(k), v); err != nil {
+				return err
+			}
+		}
+		return nil
+	})
 }

bolt/bolt_test.go

@@ -71,6 +71,16 @@ func bolt1() {
 	for _, i := range res {
 		fmt.Printf("suffix...%v...%s\n", len(res), string(i))
 	}
+	kvs := make(map[string][]byte)
+	kvs["batch1"] = []byte("batchv1")
+	kvs["batch2"] = []byte("batchv2")
+	kvs["batch3"] = []byte("batchv3")
+	kvs["batch4"] = []byte("batchv4")
+	db.Batch(kvs)
+	res = db.Prefix([]byte("batch"))
+	for _, i := range res {
+		fmt.Printf("prefix(batch)...%v...%s\n", len(res), string(i))
+	}
 	res = db.Scan()
 	for _, i := range res {
 		fmt.Printf("scan...%v...%v\n", len(res), len(i))