猿问

golang Couchbase n1ql 查询将参数传递给?

我正在尝试找到一种将参数传递给查询的方法,但不太确定如何。网站上的API看起来有点过时了?


myQuery := gocb.NewN1qlQuery("SELECT * FROM default")

rows, err := myBucket.ExecuteN1qlQuery(myQuery)

if err != nil {

    fmt.Printf("N1QL query error: %s\n", err)

}

var row interface{}

for rows.Next(&row) {

    fmt.Printf("Row: %+v\n", row)

}

if err := rows.Close(); err != nil {

    fmt.Printf("N1QL query error: %s\n", err)

}

因为,实际上 ExecuteN1qlQuery 需要两个参数:


func (b *Bucket) ExecuteN1qlQuery(q *N1qlQuery, params interface{}) (ViewResults, error)

我不确定如何使用它......就像我想用占位符创建一个查询,并通过参数将值传递给 ExecuteN1qlQuery。与 SQL 类似(准备 -> 执行)。例如这样的事情:


    myQuery := gocb.NewN1qlQuery("SELECT * FROM default where a=? and b=?")

    rows, err := myBucket.ExecuteN1qlQuery(myQuery,[]string{"b","c"})

    if err != nil {

        fmt.Printf("N1QL query error: %s\n", err)

    }

    var row interface{}

    for rows.Next(&row) {

        fmt.Printf("Row: %+v\n", row)

    }

    if err := rows.Close(); err != nil {

        fmt.Printf("N1QL query error: %s\n", err)

    }


千巷猫影
浏览 120回答 2
2回答

湖上湖

您发布的有关如何执行此操作的示例来自我们在 github 上的开发人员指南存储库:https://github.com/couchbaselabs/devguide-examples/blob/master/go/query-placeholders.go。基本上,您使用的 $ 引用一个接口和一个以 1 开头的相应位置参数。对于您的示例,它看起来像:// Setup a new query with a placeholdermyQuery := gocb.NewN1qlQuery("SELECT * FROM default where a=$1 and b=$2")// Setup an array for parametersvar myParams []interface{}myParams = append(myParams,"foo")myParams = append(myParams,"bar")// Execute Queryrows, err := bucket.ExecuteN1qlQuery(myQuery, myParams)if err != nil {    fmt.Println("ERROR EXECUTING N1QL QUERY:", err)}// Iterate through rows and print outputvar row interface{}for rows.Next(&row) {    fmt.Printf("Results: %+v\n", row)}

哆啦的时光机

刚刚找到的例子        myQuery := gocb.NewN1qlQuery("SELECT airportname, city, country FROM `travel-sample` " +        "WHERE type='airport' AND city=$1 ")    // Setup an array for parameters    var myParams []interface{}    myParams = append(myParams, "Reno")    // Execute Query    rows, err := bucket.ExecuteN1qlQuery(myQuery, myParams)
随时随地看视频慕课网APP

相关分类

Go
我要回答