最近發布的 gocb lib（couchbase 的官方 golang 客戶端）提供了用于執行批量操作（獲取、刪除等）的 API。我很想看到這樣一個操作的完整示例，唉——我的圍棋技能缺乏，網上也沒有。我想看到一個片段，(1) 編譯和 (2) 執行多重獲取，最后 (3) 設法訪問從 couchbase 返回的值。這是在線存在的小文檔：http : //developer.couchbase.com/documentation/server/4.0/sdks/go-beta/bulk-operations.html以下代碼（執行插入）是不夠的：我想要 Get（特別是 - 如何查看 get 操作結果的內容）。myBucket, _ := myCluster.OpenBucket("default", "")var items []gocb.BulkOpitems = append(items, &gocb.InsertOp{Key: "document_name_1", Value: "Hello World 1"})items = append(items, &gocb.InsertOp{Key: "document_name_2", Value: "Hello World 2"})err := bucket.Do(items)
1 回答
四季花海
TA貢獻1811條經驗 獲得超5個贊
只需用*InsertOp值替換*GetOp值，然后讀取它們的Value字段：
package main
import "fmt"
import "gopkg.in/couchbaselabs/gocb.v1"
func main() {
getKeys()
}
func getKeys() {
myCluster, err := gocb.Connect("couchbase://<couchbase-address>")
if err != nil {
fmt.Println("cluster error:", err)
}
myBucket, err := myCluster.OpenBucket("Test", "") //case sensitive!
if err != nil {
fmt.Println("bucket error:", err)
}
var items []gocb.BulkOp
items = append(items, &gocb.GetOp{Key: "document_name_1"})
items = append(items, &gocb.GetOp{Key: "document_name_2"})
err = myBucket.Do(items)
if err != nil {
fmt.Println("Do error:", err)
panic(err)
}
for _, g := range items {
//"downcast" the instance back to its concrete type - GetOp
t := g.(*gocb.GetOp)
fmt.Println(t)
}
}
- 1 回答
- 0 關注
- 235 瀏覽
添加回答
舉報
0/150
提交
取消