如何在MongoDB中使用聚合函数将JSON字符串转换为对象？（基于Golang Migrate迁移场景）

嘿，我之前做MongoDB迁移的时候也碰到过一模一样的问题！要把存JSON的字符串字段转成嵌套BSON对象，确实MongoDB的$convert没有直接转对象的参数，但有几个靠谱的方案，你可以根据自己的MongoDB版本和场景来选：

方法1：用MongoDB 4.4+原生的$parseJSON函数 #

MongoDB 4.4新增了$parseJSON聚合操作符，专门用来把合法的JSON字符串转换成BSON对象，这是最省心的方案。你可以在updateMany里结合聚合管道来更新字段：

db.your_collection.updateMany(
  {}, // 匹配所有需要更新的文档，也可以加过滤条件
  [
    {
      $set: {
        // 把your_string_field（存JSON的字符串字段）转成嵌套对象，存到your_nested_field
        your_nested_field: { $parseJSON: "$your_string_field" }
      }
    }
    // 如果转换后不需要保留原字符串字段，可以加个$unset
    // { $unset: "your_string_field" }
  ]
)

注意：这个方法要求你的MongoDB版本至少是4.4，而且字符串必须是合法的JSON格式，否则$parseJSON会返回错误。

方法2：低版本MongoDB用$function自定义解析逻辑 #

如果你的MongoDB版本在4.2到4.4之间，还可以用$function操作符，通过JavaScript来手动解析JSON字符串：

db.your_collection.updateMany(
  {},
  [
    {
      $set: {
        your_nested_field: {
          $function: {
            body: function(jsonStr) {
              // 用JS的JSON.parse解析字符串
              return JSON.parse(jsonStr);
            },
            args: ["$your_string_field"], // 传入要转换的字段
            lang: "js"
          }
        }
      }
    }
  ]
)

注意：这个方法需要MongoDB开启JavaScript支持（默认是开启的），而且如果数据量很大，性能可能不如原生的$parseJSON，适合小批量迁移或者旧版本环境。

方法3：在Go迁移脚本里手动处理（不依赖MongoDB版本） #

既然你用的是Golang Migrate，也可以直接在Go代码里完成转换逻辑，这种方式最灵活，还能处理各种异常情况（比如非法JSON字符串）：

package migrations

import (
  "context"
  "encoding/json"
  "go.mongodb.org/mongo-driver/bson"
  "go.mongodb.org/mongo-driver/bson/primitive"
  "go.mongodb.org/mongo-driver/mongo"
)

func Up_XXXX(db *mongo.Database) error {
  coll := db.Collection("your_collection")

  // 查询所有需要更新的文档
  cursor, err := coll.Find(context.TODO(), bson.M{})
  if err != nil {
    return err
  }
  defer cursor.Close(context.TODO())

  for cursor.Next(context.TODO()) {
    var doc struct {
      ID               primitive.ObjectID `bson:"_id"`
      YourStringField  string             `bson:"your_string_field"`
      YourNestedField  interface{}        `bson:"your_nested_field,omitempty"`
    }

    if err := cursor.Decode(&doc); err != nil {
      // 可以记录错误日志，继续处理下一个文档
      continue
    }

    // 解析JSON字符串
    var nestedObj interface{}
    if err := json.Unmarshal([]byte(doc.YourStringField), &nestedObj); err != nil {
      // 处理非法JSON的情况，比如跳过或标记错误
      continue
    }

    // 更新文档
    _, err := coll.UpdateByID(context.TODO(), doc.ID, bson.M{
      "$set": bson.M{"your_nested_field": nestedObj},
    })
    if err != nil {
      return err
    }
  }

  return cursor.Err()
}

这种方式的好处是不依赖MongoDB版本，还能灵活处理解析失败的情况，适合复杂的JSON结构或者需要额外校验的场景。

最后提醒 #

不管用哪种方法，一定要先在测试环境验证，并且备份好数据！如果是超大批量的数据，建议分批次处理，避免影响数据库性能。

内容的提问来源于stack exchange，提问作者user17368196