我正在嘗試讀取給定 Firestore 集合下的所有文檔并將文檔作為結(jié)構(gòu)數(shù)組返回。函數(shù)內(nèi)的日志將數(shù)據(jù)輸出為Firestore文檔，但函數(shù)外的struct數(shù)組始終是空數(shù)組。讀取集合下所有文檔的功能。func (fc *FirebaseClient) ReadCollection(collectionPath string, objects interface{}) error { ctx := context.Background() opt := option.WithCredentialsJSON([]byte(os.Getenv("FIREBASE_CREDENTIALS"))) client, err := firestore.NewClient(ctx, os.Getenv("FIREBASE_PROJECT_ID"), opt) if err != nil { return err } defer client.Close() collectionRef := client.Collection(collectionPath) docs, err := collectionRef.DocumentRefs(ctx).GetAll() if err != nil { return err } log.Printf("Total documents: %i", len(docs)) objs := make([]interface{}, len(docs)) for i, doc := range docs { docsnap, err := doc.Get(ctx) if err != nil { return err } if err := docsnap.DataTo(&objs[i]); err != nil { return err } log.Printf("obj: %v", objs[i]) } objects = objs log.Printf("objects: %v", objects) return nil}調(diào)用函數(shù)的代碼 var ss []SomeStruct fc := new(insightech.FirebaseClient) if err := fc.ReadCollection("mycollection", ss); err != nil { return }ss始終是一個空數(shù)組。我不想指定結(jié)構(gòu)類型的原因是使 ReadCollection 函數(shù)通用，這樣我就可以調(diào)用它來讀取不同的集合。該代碼不會觸發(fā)任何錯誤，但結(jié)果是一個空數(shù)組，即使接口objects肯定是一個包含元素的數(shù)組。
1 回答
長風(fēng)秋雁
TA貢獻1757條經(jīng)驗 獲得超7個贊
以下代碼可以運行：
func (fc *FirebaseClient) ReadCollection(collectionPath string, objects interface{}) error {
ctx := context.Background()
opt := option.WithCredentialsJSON([]byte(os.Getenv("FIREBASE_CREDENTIALS")))
client, err := firestore.NewClient(ctx, os.Getenv("FIREBASE_PROJECT_ID"), opt)
if err != nil {
return err
}
defer client.Close()
collectionRef := client.Collection(collectionPath)
docs, err := collectionRef.DocumentRefs(ctx).GetAll()
if err != nil {
return err
}
log.Printf("Total documents: %i", len(docs))
dest := reflect.ValueOf(objects).Elem()
log.Printf("dest: %v", dest)
for _, doc := range docs {
docsnap, err := doc.Get(ctx)
if err != nil {
return err
}
obj := reflect.New(dest.Type().Elem())
if err := docsnap.DataTo(obj.Interface()); err != nil {
return err
}
log.Printf("obj: %v", obj)
dest = reflect.Append(dest, obj.Elem())
}
reflect.ValueOf(objects).Elem().Set(dest)
log.Printf("objects: %v", dest)
return nil
}
var ss []SomeStruct
fc := new(insightech.FirebaseClient)
if err := fc.ReadCollection("mycollection", &ss); err != nil {
return
}
- 1 回答
- 0 關(guān)注
- 165 瀏覽
添加回答
舉報
0/150
提交
取消