迁移PostgreSQL至MongoDB：JSON数组ID转ObjectID方法求助

核心思路 #

先把从PostgreSQL查出来的JSON数组字符串解析成Java的字符串列表，再循环调用你已有的convertIDToMongo函数逐个转换，最后把转换后的ObjectID集合存入MongoDB文档。

具体实现步骤（以Java为例） #

假设你用JDBC从PostgreSQL拿到的JSON数组结果是String jsonArrayStr（比如["956c5b0a5341d14c23ceed071bf136f8", "abc123..."]），可以这么处理：

1. 解析JSON数组为Java字符串列表
   用Jackson或者Gson都能轻松搞定，这里以Jackson为例：

   import com.fasterxml.jackson.core.type.TypeReference;
   import com.fasterxml.jackson.databind.ObjectMapper;
   import org.bson.types.ObjectId;
   import java.util.List;
   
   // 初始化ObjectMapper（建议全局单例）
   private static final ObjectMapper objectMapper = new ObjectMapper();
   
   public List<ObjectId> convertJsonArrayToObjectIds(String jsonArrayStr) throws Exception {
       // 把JSON数组字符串转成List<String>
       List<String> pgIds = objectMapper.readValue(jsonArrayStr, new TypeReference<List<String>>() {});
       // 遍历调用已有的convertIDToMongo，收集结果
       return pgIds.stream()
                   .map(this::convertIDToMongo) // 这里调用你已有的转换函数
                   .collect(java.util.stream.Collectors.toList());
   }
   

2. 集成到迁移流程
   在你的迁移代码里，拿到SQL查询结果后，调用上面的方法：

   // 假设从ResultSet中获取JSON数组字段
   String jsonAArrayStr = resultSet.getString("json->'A'");
   List<ObjectId> mongoIds = convertJsonArrayToObjectIds(jsonAArrayStr);
   // 把mongoIds存入MongoDB文档
   Document mongoDoc = new Document();
   mongoDoc.put("A", mongoIds);
   // 后续写入MongoDB的逻辑...
   

异常处理建议 #

• 如果JSON数组为空（比如[]），解析后会得到空列表，直接存入MongoDB即可，不用额外处理。
• 如果遇到无效的PostgreSQL ID（比如长度不对、字符非法），可以在convertIDToMongo里加判断，或者在流处理时过滤：

  return pgIds.stream()
              .filter(id -> ObjectId.isValid(id)) // 先校验ID合法性
              .map(this::convertIDToMongo)
              .collect(java.util.stream.Collectors.toList());
  

替代方案：数据库层预处理 #

如果不想在Java里解析，也可以在PostgreSQL端把JSON数组拆成多行，再批量转换：

SELECT json_array_elements_text(json::json->'A') AS pg_id FROM your_table;

这样查出来的是每个ID一行的结果，你可以批量读取这些ID，调用convertIDToMongo后再按原分组聚合回数组存入MongoDB。不过这种方式需要额外处理分组逻辑，适合数据量不大的场景。

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