使用mongo-go-driver将结果转换为不带结构的JSON

okxuctiv  于 2023-03-16  发布在  Go
关注(0)|答案(2)|浏览(106)

在将结果转换为JSON之前,我不想使用结构体。假设我有一些结果:

result, err := collection.Find(ctx, filter, options)

我可以收集docs变量中的所有结果和doc变量中的最后结果:

var doc bson.Raw
    var docs []bson.Raw    
    for result.Next(ctx) {
            document, err := result.DecodeBytes()
            if err != nil {
                log.Println(err)
            }
            doc = document
            docs = append(docs, doc)
        }

我可以轻松地将最后一个结果转换为JSON,而无需使用任何结构体:

var jsonDoc bson.M
err = bson.Unmarshal(doc, &jsonDoc)
return jsonDoc

我无法将文档转换为JSON并在我的Rest服务器中作为结果使用。

2019年1月17日更新:

我在REST服务器中使用result,如下所示:

user.GET("/booking/customer/:id", func(c *gin.Context) {
    result := GetAllCustomerBookings(c.Param("id"))
    c.JSON(http.StatusOK, result)
})

所以它不可能是一个循环。问题是:如何将[]bson.Raw转换为[]byte或bson. Raw。假设现在数组的每个值中都有{JSON}。我需要一个如下所示的JSON:[{JSON},{JSON},...]。
使用nodejs更容易,因为我可以在一个JSON文档中发送所有记录,Go和mongodb-go-driver需要遍历所有记录,我不知道如何构建一个JSON文档。

Nodejs和mongodb等效项:

router.get('/bookings/customer/:id', function (req, res, next) {
    db.Bookings.find({
        "booking.customer._id": {
            $eq: req.params.id
        }
    }).sort({
            "booking.arrival_date": -1
        },
        function (err, bookings) {
            if (err) {
                res.send(err);
            } else {
                res.json(bookings);
            }
        });
});
sd2nnvve

sd2nnvve1#

这个代码可以工作。经过几个小时的尝试,感谢好运,我设法解决了这个问题。也许有人会解释这个问题?
我用bson.M代替bson.Raw,用result.Decode()代替result.DecodeBytes(),现在我得到的输出和nodejs给我的一样。

var docs []bson.M
    for result.Next(ctx) {
        var document bson.M
        err = result.Decode(&document)
        if err != nil {
            log.Println(err)
        }
        docs = append(docs, document)
    }
    return docs
gv8xihay

gv8xihay2#

您也可以使用以下命令:

var results []bson.M
if err := cursor.All(context.TODO(), &results); err != nil {
    log.Panic(err)
}

要查看结果或转换为json,请使用以下命令:

res, _ := json.Marshal(results)
fmt.Println(string(res))

如果你想自己做,你可以这样做:

var convertedResult []map[string]interface{}
for _, item := range results {
    convertedItem := make(map[string]interface{})
    for key, val := range item {
        switch v := val.(type) {
        case primitive.ObjectID:
            convertedItem[key] = v.Hex()
        case bson.M:
            subMap := make(map[string]interface{})
            for subKey, subVal := range v {
                subMap[subKey] = subVal
            }
            convertedItem[key] = subMap
        case bson.A:
            subArray := make([]interface{}, len(v))
            for i, subVal := range v {
                subArray[i] = subVal
            }
            convertedItem[key] = subArray
        default:
            convertedItem[key] = v
        }
    }
    convertedResult = append(convertedResult, convertedItem)
}

jsonBytes, err := json.Marshal(convertedResult)
if err != nil {
    panic(err)
}
jsonString := string(jsonBytes)

fmt.Println(jsonString)

相关问题