为了账号安全,请及时绑定邮箱和手机立即绑定

gocb:批量获取操作示例

gocb:批量获取操作示例

Go
牛魔王的故事 2021-11-15 15:56:00
最近发布的 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)

        }

}


查看完整回答
反对 回复 2021-11-15
  • 1 回答
  • 0 关注
  • 211 浏览
慕课专栏
更多

添加回答

举报

0/150
提交
取消
意见反馈 帮助中心 APP下载
官方微信