我正在尝试使用github.com/globalsign/mgo
:将以下Mongo查询翻译为Go
db.getCollection('cluster').find({"clusterName": {"$in": ["clusterA", "clusterB"]}})
"clusterName";是一个字符串字段。基本上,最简单的选择是对列表中的每个值执行多次mongo调用。
我写的查询:
func ReadClusters(clusterNames []string) (*[]kusto.Cluster, error) {
var clusters *[]kusto.Cluster
err := readObjects(clusterCollection, bson.M{"clusterName": bson.M{"$in": clusterNames}}, &clusters, "" /* sortField */)
if err != nil {
return nil, err
}
return clusters, nil
}
我的助手功能:
func readObjects(collection string, query bson.M, dest interface{}, sortField string) error {
err := getDocuments(collection, query, dest, sortField)
if err != nil {
if err == mgo.ErrNotFound {
return ErrNotFound
}
return err
}
return nil
}
func getDocuments(collectionName string, query bson.M, dest interface{}, sortField string) error {
session := client.Copy()
defer session.Close()
collection := getCollection(session, collectionName)
find := collection.Find(query)
if sortField != "" {
find = find.Sort(sortField)
}
return find.All(dest)
}
我得到错误:
2020/07/09 11:58:46 http://panic serving[::1]:54085:结果参数必须是切片地址
我目前使用的是Go1.11,在go.mod
下看到的mgo版本是github.com/globalsign/mgo v0.0.0-20181015135952-eeefdecb41b8
clusters
已经是指向切片的指针类型,因此取其地址将是指向指向切片的指示器的指针。
将其声明为非指向切片的指针:
var clusters []kusto.Cluster