偷偷努力,悄无声息地变强,然后惊艳所有人!哈哈,小伙伴们又来学习啦~今天我将给大家介绍《使用“reflect”将数据附加到指向已定义结构的接口》,这篇文章主要会讲到等等知识点,不知道大家对其都有多少了解,下面我们就一起来看一吧!当然,非常希望大家能多多评论,给出合理的建议,我们一起学习,一起进步!
问题内容我正在尝试创建一个函数,它从 mongo 集合中获取所有文档并查询它们以声明的结构。为了实现这一点,我设置了类型接口函数的参数,以便它可以使用两个结构。这是我的代码:
在包实体中:
type project struct {
title string
position string
....
}
type projects struct {
projects []project
}
在当前包中:
var docs entities.Projects
var doc entities.Project
//doc represents a document from Mongo Collection
//docs represents an array of documents, each element is a document
//collection has type *mongo.Collection and points to the desired collection on MongoDB.
createQuery(&doc, &docs, collection)
func createQuery(doc interface{}, docs interface{}, c *mongo.Collection) {
documents := reflect.ValueOf(docs).Elem()
document := reflect.ValueOf(doc)
cur, err := c.Find(context.Background(), bson.D{{}})
if err != nil {
log.Fatal(err)
}
for cur.Next(context.Background()) {
err = cur.Decode(document.Interface())
if err != nil {
log.Fatal(err)
}
//Error is thrown here
documents.Set(reflect.Append(documents, document))
fmt.Println(doc)
}
if err := cur.Err(); err != nil {
log.Fatal(err)
}
if err != nil {
fmt.Printf("oh shit this is the error %s \n", err)
}
cur.Close(context.Background())
fmt.Printf("documents: %+v\n", documents.Interface())
fmt.Printf("document: %+v\n", document.CanSet())
}
---ERROR OUTPUT---
panic: reflect: call of reflect.Append on struct Value
我能够使用文档变量将数据设置为 doc,尽管在执行 document.canset() 时为 false(因此它甚至可能不起作用)。当我尝试将文档附加到文档界面时,程序就会中断。
解决方案
问题中的代码将结构 docs
传递给需要切片的函数。传递 docs
中切片字段的地址,而不是 docs
本身。
createquery
函数可以从切片本身确定切片元素类型。无需传递示例值。
var docs entities.projects
createquery(&docs.projects, collection)
for _, doc := range docs.projects {
fmt.println(doc.title)
}
对 cur.decode
的调用需要一个指向未初始化值的指针。使用reflect.new 来创建该值。
func createquery(docs interface{}, c *mongo.collection) {
docsv := reflect.valueof(docs).elem()
doct := docsv.type().elem()
cur, err := c.find(context.background(), bson.d{{}})
if err != nil {
log.fatal(err)
}
for cur.next(context.background()) {
docpv := reflect.new(doct)
err = cur.decode(docpv.interface())
if err != nil {
log.fatal(err)
}
docsv.set(reflect.append(docsv, docpv.elem()))
}
if err := cur.err(); err != nil {
log.fatal(err)
}
cur.close(context.background())
}
顺便说一句,如果 entities.projects
结构类型只有一个字段,则不需要该结构类型。使用 []project
代替:
var docs []entities.Project
createQuery(&docs, collection)
for _, doc := range docs {
fmt.Println(doc.Title)
}
理论要掌握,实操不能落!以上关于《使用“reflect”将数据附加到指向已定义结构的接口》的详细介绍,大家都掌握了吧!如果想要继续提升自己的能力,那么就来关注编程网公众号吧!