我一直在努力适应Merge
of gorethink
(RethinkDB的Go驱动程序)。
result,err:=r.Table("quote").GetAllByIndex("idUser",idUser).
OrderBy(r.Desc("created_at")).Merge(func(row r.Term) interface{}{
res,_:=r.Table("article").Get(row.Field("idArticle")).Run(session)
// TODO
return map[string]interface{}{
// TODO
}
}).Run(session)
我有三个集合:article
、quote
和user
有了上述职能,我打算:
在用于JavaScript的RethinkDB API中,我实现了如下所示:
findAllByUser = function(idU){
return r.table(table)
.filter({idUser: idU})
.orderBy(r.desc('created_at'))
.merge(function(quote){
var article = r.table('article').get(quote('idArticle'));
return {
tags: {keywords: article('keywords')}
}
})
.run(connection)
.then(function(result){
return result.toArray();
});
}
但我还是没能在重新思考中做到这一点。如何获得Term
row.Field("idArticle")
的值,并将其用于以后的查询和Merge
发布于 2016-03-30 03:23:41
非常感谢。我设法解决了这个恐慌的错误
真正的答案是:
result,err:=r.Table("quote").Filter(r.Row.Field("idUser").Eq(idUser)).
OrderBy(r.Desc("created_at")).
Merge(func(quote r.Term) interface{}{
fmt.Println(quote.Field("idArticle"))
article:=r.Table("article").Get(quote.Field("idArticle"))
return map[string]interface{}{
"tags":map[string]interface{}{
"keywords":article.Field("keywords"),
},
}
}).
Run(config.Connection())
我因为昨晚光标结果返回地址的声明而惊慌失措:它是:var all map[string]interface{}
,而它应该是:var all []interface{}
,然后它在err=result.All(&all)
中惊慌了
发布于 2016-03-29 23:03:42
从https://github.com/dancannon/gorethink/issues/291抄袭我的答案
您应该能够在不调用Run
的情况下通过使用子查询来转换JS查询。例如:
r.Table(table)
.Filter(map[string]interface{}{"idUser": idU})
.OrderBy(r.Desc("created_at"))
.Merge(func(quote r.Term){
article := r.Table("article").Get(quote.Field("idArticle"))
return map[string]interface{}{
"tags": map[string]interface{}{
"keywords": article("keywords"),
},
}
})
https://stackoverflow.com/questions/36287265
复制相似问题