简介
项目开源地址:https://github.com/HouzuoGuo/tiedot
发起者留下了他的Twitter,貌似姓郭,是个美籍华人
项目简介中,有关于对性能的描述,有人用此数据库抓取了维基百科,保存5900万数据,共73G。
安装
配置好Go环境后,运行
go get github.com/HouzuoGuo/tiedot
入门
使用有2种方式,使用HTTP做接口,适用任何语言;使用嵌入式,使用Go语言,这里介绍使用Go语言,数据库的嵌入模式,足以应付百万请求/天了。
项目自带了演示代码,通过下面的命令执行
./tiedot -mode=example
性能评估命令
./tiedot -mode=bench # 对40万数据,进行增删改查 ./tiedot -mode=bench2 # 还没仔细看
项目中,example.go 文件是Go语言的使用示例
// It is very important to initialize random number generator seed! rand.Seed(time.Now().UTC().UnixNano()) // Create and open database创建并打开数据库 dir := "/tmp/MyDatabase" os.RemoveAll(dir) defer os.RemoveAll(dir) myDB, err := db.OpenDB(dir) if err != nil { panic(err) } // Create two collections Feeds and Votes创建2张表 // "2" means collection data and indexes are divided into two halves, allowing concurrent access from two threads if err := myDB.Create("Feeds", 2); err != nil { panic(err) } if err := myDB.Create("Votes", 2); err != nil { panic(err) } // What collections do I now have?查询都有哪些表 for name := range myDB.StrCol { fmt.Printf("I have a collection called %s\n", name) } // Rename collection "Votes" to "Points"把表"Votes"重命名为"Points" if err := myDB.Rename("Votes", "Points"); err != nil { panic(err) } // Drop (delete) collection "Points"删除表"Points" if err := myDB.Drop("Points"); err != nil { panic(err) } // Scrub (repair and compact) "Feeds"修复并压缩表"Feeds" myDB.Scrub("Feeds") // ****************** Document Management ****************** // Start using a collection使用表"Feeds" feeds := myDB.Use("Feeds") // Insert document (document must be map[string]interface{})插入数据 docID, err := feeds.Insert(map[string]interface{}{ "name": "Go 1.2 is released", "url": "golang.org"}) if err != nil { panic(err) } // Read document根据id查询数据 var readBack interface{} feeds.Read(docID, &readBack) // pass in document's physical ID fmt.Println(readBack) // Update document (document must be map[string]interface{})改数据 err = feeds.Update(docID, map[string]interface{}{ "name": "Go is very popular", "url": "google.com"}) if err != nil { panic(err) } // Delete document删除数据 feeds.Delete(docID) // Delete document feeds.Delete(123) // An ID which does not exist does no harm // ****************** Index Management ******************索引管理 // Secondary indexes assist in many types of queries // Create index (path leads to document JSON attribute)建索引 if err := feeds.Index([]string{"author", "name", "first_name"}); err != nil { panic(err) } if err := feeds.Index([]string{"Title"}); err != nil { panic(err) } if err := feeds.Index([]string{"Source"}); err != nil { panic(err) } // What indexes do I have on collection A?查询有哪些索引 for path := range feeds.SecIndexes { fmt.Printf("I have an index on path %s\n", path) } // Remove index删索引 if err := feeds.Unindex([]string{"author", "name", "first_name"}); err != nil { panic(err) } // ****************** Queries ******************查询表 // Let's prepare a number of docments for a start feeds.Insert(map[string]interface{}{"Title": "New Go release", "Source": "golang.org", "Age": 3}) feeds.Insert(map[string]interface{}{"Title": "Kitkat is here", "Source": "google.com", "Age": 2}) feeds.Insert(map[string]interface{}{"Title": "Good Slackware", "Source": "slackware.com", "Age": 1}) queryStr := `[{"eq": "New Go release", "in": ["Title"]}, {"eq": "slackware.com", "in": ["Source"]}]` var query interface{} json.Unmarshal([]byte(queryStr), &query)查询条件 queryResult := make(map[uint64]struct{}) // query result (document IDs) goes into map keys保存查询结果的变量 if err := db.EvalQuery(query, feeds, &queryResult); err != nil {执行查询 panic(err) } // Query results are physical document IDs打印查询结果 for id := range queryResult { fmt.Printf("Query returned document ID %d\n", id) } // To use the document itself, simply read it back for id := range queryResult { feeds.Read(id, &readBack) fmt.Printf("Query returned document %v\n", readBack) } // Gracefully close database关闭数据库 myDB.Close()
有疑问加站长微信联系(非本文作者)