Skip to content

Commit 4290bd4

Browse files
coderbradleecoderbradlee
committed
x
1 parent ba92672 commit 4290bd4

File tree

2 files changed

+160
-61
lines changed

2 files changed

+160
-61
lines changed

‎test/boltdb_test.go

Lines changed: 99 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,99 @@
1+
package test
2+
3+
import (
4+
"bytes"
5+
"fmt"
6+
"testing"
7+
8+
bolt "go.etcd.io/bbolt"
9+
)
10+
11+
func TestYY(t *testing.T) {
12+
testopenfile()
13+
}
14+
15+
func testopenfile() {
16+
db, err := bolt.Open("my.db", 0600, nil)
17+
if err != nil {
18+
fmt.Println(err)
19+
}
20+
fmt.Println(db)
21+
//err = db.Update(func(tx *bolt.Tx) error {
22+
// b, err := tx.CreateBucket([]byte("MyBucket11111"))
23+
//
24+
// if err != nil {
25+
// return fmt.Errorf("create bucket: %s", err)
26+
// }
27+
// b, err = tx.CreateBucket([]byte("MyBucket22222"))
28+
// if err != nil {
29+
// return fmt.Errorf("create bucket: %s", err)
30+
// }
31+
// bytes := make([]byte, 8)
32+
// binary.BigEndian.PutUint64(bytes, 1)
33+
// err = b.Put(bytes, []byte("1"))
34+
// if err != nil {
35+
// return err
36+
// }
37+
// binary.BigEndian.PutUint64(bytes, 10)
38+
// err = b.Put(bytes, []byte("10"))
39+
// if err != nil {
40+
// return err
41+
// }
42+
// binary.BigEndian.PutUint64(bytes, 100)
43+
// //err = b.Put([]byte{100}, []byte("zhangsan2"))
44+
// //if err != nil {
45+
// // return err
46+
// //}
47+
// err = b.Put(bytes, []byte("100"))
48+
// return err
49+
//})
50+
//err = db.View(func(tx *bolt.Tx) error {
51+
// if err := tx.ForEach(func(name []byte, b *bolt.Bucket) error {
52+
// fmt.Println(string(name))
53+
// return nil
54+
// }); err != nil {
55+
// fmt.Println(err)
56+
// }
57+
// return nil
58+
//})
59+
//
60+
//fmt.Println(err)
61+
err = db.Update(func(tx *bolt.Tx) error {
62+
b, err := tx.CreateBucket([]byte("MyBucket"))
63+
64+
if err != nil {
65+
return fmt.Errorf("create bucket: %s", err)
66+
}
67+
68+
err = b.Put([]byte("history1"), []byte("1"))
69+
if err != nil {
70+
return err
71+
}
72+
err = b.Put([]byte("history2"), []byte("2"))
73+
if err != nil {
74+
return err
75+
}
76+
err = b.Put([]byte("history3"), []byte("3"))
77+
if err != nil {
78+
return err
79+
}
80+
err = b.Put([]byte("history4"), []byte("4"))
81+
if err != nil {
82+
return err
83+
}
84+
err = b.Put([]byte("history5"), []byte("5"))
85+
return err
86+
})
87+
var allKey [][]byte
88+
err = db.View(func(tx *bolt.Tx) error {
89+
c := tx.Bucket([]byte("MyBucket")).Cursor()
90+
prefix := []byte("history")
91+
for k, _ := c.Seek(prefix); bytes.HasPrefix(k, prefix); k, _ = c.Next() {
92+
allKey = append(allKey, k)
93+
}
94+
return nil
95+
})
96+
for _, k := range allKey {
97+
fmt.Println(k)
98+
}
99+
}

‎test/main_test.go

Lines changed: 61 additions & 61 deletions
Original file line numberDiff line numberDiff line change
@@ -2,14 +2,11 @@ package test
22

33
import (
44
"encoding/base64"
5-
"encoding/binary"
65
"encoding/hex"
76
"fmt"
87
"math/big"
98
"testing"
109
"time"
11-
12-
bolt "go.etcd.io/bbolt"
1310
)
1411

1512
//
@@ -357,13 +354,13 @@ func testxx() {
357354
//encodeString2 := base64.StdEncoding.EncodeToString([]byte(hex.EncodeToString(out2)))
358355
//fmt.Println(encodeString2)
359356

360-
input := []byte("40")
357+
input := []byte("83")
361358
//input, _ := hex.DecodeString("0000000000000000000000006356908ace09268130dee2b7de643314bbeb36830000000000000000000000000000000000000000000000000000000000000004")
362359
// 演示base64编码
363360
encodeString := base64.StdEncoding.EncodeToString(input)
364361
fmt.Println(encodeString)
365362

366-
decodeBytes, err := base64.StdEncoding.DecodeString("MDAwMDAwMDAwMDAwMDAwMDAwMDAwMDAwMDAwMDAwMDAwMDAwMDAwMDA2NzY1Yzc5MzFjMDQ5YzYyODljMDAwMA==")
363+
decodeBytes, err := base64.StdEncoding.DecodeString("MDAwMDAwMDAwMDAwMDAwMDAwMDAwMDAwMDAwMDAwMDAwMDAwMDAwMDA2NzY1Yzc5M2ZhMTAwNzlkMDAwMDAwMA==")
367364
if err != nil {
368365
fmt.Println(err)
369366
}
@@ -388,73 +385,76 @@ func testxx() {
388385
break
389386
}
390387
}
388+
for i := uint8(0); i < 0; i++ {
389+
fmt.Println("wahttttat")
390+
}
391391
}
392392
func TestXx(t *testing.T) {
393393
//testyy()
394394
//testDijkstra()
395395
//testopenfile()
396396
//testudp()
397397
//testbroard()
398-
//testxx()
399-
testopenfile()
398+
testxx()
399+
//testopenfile()
400400
//fmt.Println(tt)
401401
//time.Sleep(time.Second * 3)
402402
}
403403

404-
func testopenfile() {
405-
//db, err := bolt.Open("my.db", 0600, nil)
406-
//if err != nil {
407-
// fmt.Println(err)
408-
//}
409-
//fmt.Println(db)
410-
db, err := bolt.Open("my.db", 0600, nil)
411-
if err != nil {
412-
fmt.Println(err)
413-
}
414-
fmt.Println(db)
415-
err = db.Update(func(tx *bolt.Tx) error {
416-
b, err := tx.CreateBucket([]byte("MyBucket11111"))
417-
418-
if err != nil {
419-
return fmt.Errorf("create bucket: %s", err)
420-
}
421-
b, err = tx.CreateBucket([]byte("MyBucket22222"))
422-
if err != nil {
423-
return fmt.Errorf("create bucket: %s", err)
424-
}
425-
bytes := make([]byte, 8)
426-
binary.BigEndian.PutUint64(bytes, 1)
427-
err = b.Put(bytes, []byte("1"))
428-
if err != nil {
429-
return err
430-
}
431-
binary.BigEndian.PutUint64(bytes, 10)
432-
err = b.Put(bytes, []byte("10"))
433-
if err != nil {
434-
return err
435-
}
436-
binary.BigEndian.PutUint64(bytes, 100)
437-
//err = b.Put([]byte{100}, []byte("zhangsan2"))
438-
//if err != nil {
439-
// return err
440-
//}
441-
err = b.Put(bytes, []byte("100"))
442-
return err
443-
})
444-
err = db.View(func(tx *bolt.Tx) error {
445-
if err := tx.ForEach(func(name []byte, b *bolt.Bucket) error {
446-
fmt.Println(string(name))
447-
return nil
448-
}); err != nil {
449-
fmt.Println(err)
450-
}
451-
return nil
452-
})
453-
454-
fmt.Println(err)
455-
456-
}
457-
404+
//func testopenfile() {
405+
// //db, err := bolt.Open("my.db", 0600, nil)
406+
// //if err != nil {
407+
// // fmt.Println(err)
408+
// //}
409+
// //fmt.Println(db)
410+
// db, err := bolt.Open("my.db", 0600, nil)
411+
// if err != nil {
412+
// fmt.Println(err)
413+
// }
414+
// fmt.Println(db)
415+
// err = db.Update(func(tx *bolt.Tx) error {
416+
// b, err := tx.CreateBucket([]byte("MyBucket11111"))
417+
//
418+
// if err != nil {
419+
// return fmt.Errorf("create bucket: %s", err)
420+
// }
421+
// b, err = tx.CreateBucket([]byte("MyBucket22222"))
422+
// if err != nil {
423+
// return fmt.Errorf("create bucket: %s", err)
424+
// }
425+
// bytes := make([]byte, 8)
426+
// binary.BigEndian.PutUint64(bytes, 1)
427+
// err = b.Put(bytes, []byte("1"))
428+
// if err != nil {
429+
// return err
430+
// }
431+
// binary.BigEndian.PutUint64(bytes, 10)
432+
// err = b.Put(bytes, []byte("10"))
433+
// if err != nil {
434+
// return err
435+
// }
436+
// binary.BigEndian.PutUint64(bytes, 100)
437+
// //err = b.Put([]byte{100}, []byte("zhangsan2"))
438+
// //if err != nil {
439+
// // return err
440+
// //}
441+
// err = b.Put(bytes, []byte("100"))
442+
// return err
443+
// })
444+
// err = db.View(func(tx *bolt.Tx) error {
445+
// if err := tx.ForEach(func(name []byte, b *bolt.Bucket) error {
446+
// fmt.Println(string(name))
447+
// return nil
448+
// }); err != nil {
449+
// fmt.Println(err)
450+
// }
451+
// return nil
452+
// })
453+
//
454+
// fmt.Println(err)
455+
//
456+
//}
457+
//
458458
// err = db.View(func(tx *bolt.Tx) error {
459459
// c := tx.Bucket([]byte("MyBucket")).Cursor()
460460
// //for k, v := c.Last(); k != nil; k, v = c.Prev() {

0 commit comments

Comments
 (0)