I was trying to decode the data of the cursor into a map[string]interface{}, I tried it directly but it doesn't works at all, so I fount that I have to convert it to a BSON document and next convert it to a map[string]interface{}, and finally into a JSON string. I tried the following code:
...
for cursor.Next(context.Background()) {
err = cursor.Decode(&itemBson)
...
b, err := bson.Marshal(itemBson)
...
err = bson.Unmarshal(b, &itemMap)
...
}
...
But the bson document has the following value:
map[_id:ObjectID("5c2d0809a49bad7d547ec028") applications:bson.Array[bson.Document{bson.Element{"enabled": true}}] userName:coto userUUID:df2d ea92-c189-53b3-aafe-485d0be23bee]
And the map parsed as JSON:
{"_id":"5c2d0809a49bad7d547ec028","applications":[{}],"userName":"coto","userUUID":"df2dea92-c189-53b3-aafe-485d0be23bee"}
As you can see the key "applications" is empty in the JSON, but it really has content in the BSON document. I don't know why the data disappear.
How I can solve this error? Thanks.
Solved:
I solved this error using the following code:
var jsonDocuments []map[string]interface{}
var byteDocuments []byte
var bsonDocument bson.D
var jsonDocument map[string]interface{}
var temporaryBytes []byte
for cursor.Next(context.Background()) {
err = cursor.Decode(&bsonDocument)
if err != nil {
report.Report{Error: err, Trace: report.Trace()}.Send()
requestContext.StatusCode(500)
return `500 Internal server error`
}
temporaryBytes, err = bson.MarshalExtJSON(bsonDocument, true, true)
if err != nil {
report.Report{Error: err, Trace: report.Trace()}.Send()
requestContext.StatusCode(500)
return `500 Internal server error`
}
err = json.Unmarshal(temporaryBytes, &jsonDocument)
if err != nil {
report.Report{Error: err, Trace: report.Trace()}.Send()
requestContext.StatusCode(500)
return `500 Internal server error`
}
jsonDocuments = append(jsonDocuments, jsonDocument)
}
The bson.M
from the official mongo-go-driver is pimitive.M
which is the type of map[string]interface{}
. Without seeing your declared variables, it's hard to tell what went wrong. Here is a working example using the official mongo-go-driver.
func TestUnmarshal(t *testing.T) {
uri := "mongodb://localhost/stackoverflow?replicaSet=replset"
ctx := context.Background()
client, err := mongo.Connect(ctx, uri)
if err != nil {
t.Fatal(err)
}
c := client.Database("stackoverflow").Collection("acoll")
list := []bson.M{bson.M{"enabled": true}}
id := primitive.NewObjectID()
c.InsertOne(ctx, bson.M{"_id": id, "applications": list, "userName": "my name"})
var itemBson bson.M
var itemMap map[string]interface{}
cur, _ := c.Find(ctx, bson.M{})
for cur.Next(ctx) {
cur.Decode(&itemBson)
t.Log(itemBson)
b, _ := bson.Marshal(itemBson)
bson.Unmarshal(b, &itemMap)
t.Log(itemMap)
}
}
output of go test
unmarshal_test.go:28: map[_id:ObjectID("5c380ae501d48897a1ac27c6") applications:[map[enabled:true]] userName:my name]
unmarshal_test.go:31: map[userName:my name _id:ObjectID("5c380ae501d48897a1ac27c6") applications:[map[enabled:true]]]