/
listkeys.go
53 lines (46 loc) · 1.1 KB
/
listkeys.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
package main
import (
"os"
"flag"
"log"
"github.com/syndtr/goleveldb/leveldb"
"github.com/teambo-org/teambo/util"
)
var db *leveldb.DB
var db_path *string = flag.String("d", "", "Database Path")
var prefix *string = flag.String("p", "", "Prefix")
func list_keys() error {
// r := ldb_util.BytesPrefix([]byte(*prefix))
iter := db.NewIterator(nil, nil)
for iter.Next() {
log.Println(string(iter.Key()) + ": " + string(iter.Value()))
}
iter.Release()
return iter.Error()
}
func main() {
var config_path *string = flag.String("conf", "./app.conf", "Location of config file")
flag.Parse()
if *db_path == "" {
log.Println("Database Path Required")
return
}
util.Config.Parse(*config_path)
path := util.Config.Get("app.data")+"/" + *db_path + ".ldb"
if _, err := os.Stat(path); err != nil {
log.Println("Database not found: " + path)
return
}
dbh, err := leveldb.OpenFile(path, nil)
db = dbh
if err != nil {
log.Println(err)
return
}
log.Println("=== Listing from " + path + " ===")
if *prefix != "" {
log.Println("=== With Prefix " + *prefix + " ===")
}
list_keys()
db.Close()
}