MongoDB Node.js驱动中ObjectId与字符串不匹配的$lookup解决方法

这个问题我之前处理过好几次，核心痛点就是MongoDB的$lookup对字段类型要求严格——app_users._id是ObjectId类型，而bookings.user_id是字符串类型，两者根本匹配不上，自然查不出结果。下面给你两种实用的解决方案，你可以根据自己的场景选：

既然app_users的_id用的是MongoDB标准的ObjectId，那最好把bookings里的user_id也转换成ObjectId类型。这不仅能解决当前的关联问题，还符合MongoDB的设计规范，后续查询性能也更优。

你可以用updateMany批量修改现有数据，代码示例如下：

const MongoClient = require('mongodb').MongoClient;
const assert = require('assert');
const url = 'mongodb://root:root@localhost:3000/app';
const dbName = 'app';

MongoClient.connect(url, function(err, client) {
  assert.equal(err, null);
  const db = client.db(dbName);
  
  // 批量将bookings中字符串类型的user_id转为ObjectId
  db.collection('bookings').updateMany(
    { user_id: { $type: "string" } }, // 只匹配还没转换的字符串类型字段
    [
      { $set: { user_id: { $toObjectId: "$user_id" } } }
    ],
    function(err, result) {
      assert.equal(err, null);
      console.log(`成功修改了${result.modifiedCount}条数据`);
      
      // 修改完成后执行原lookup查询，就能正常关联了
      db.collection('app_users').aggregate([{
        $lookup: {
          from: 'bookings',
          localField: '_id',
          foreignField: 'user_id',
          as: 'bookings'
        }
      }]).toArray(function(err, docs) {
        assert.equal(err, null);
        console.log(docs);
        client.close();
      });
    }
  );
});

⚠️ 提醒：执行批量更新前，最好先备份数据，或者先用find查询一小部分数据测试转换效果，避免意外。

如果暂时不能修改bookings集合的数据（比如涉及线上业务不能停服），可以在聚合管道里动态转换其中一方的类型，让两者匹配。这里给你两种实现方式：

方式A：把app_users的_id转成字符串 #

在$lookup之前用$addFields新增一个字符串类型的id_str字段，再用它和bookings.user_id关联：

const MongoClient = require('mongodb').MongoClient;
const assert = require('assert');
const url = 'mongodb://root:root@localhost:3000/app';
const dbName = 'app';

MongoClient.connect(url, function(err, client) {
  assert.equal(err, null);
  const db = client.db(dbName);
  
  db.collection('app_users').aggregate([
    {
      $addFields: {
        id_str: { $toString: "$_id" } // 将ObjectId类型的_id转为字符串
      }
    },
    {
      $lookup: {
        from: 'bookings',
        localField: 'id_str', // 用转换后的字符串字段关联
        foreignField: 'user_id',
        as: 'bookings'
      }
    }
  ]).toArray(function(err, docs) {
    assert.equal(err, null);
    console.log(docs);
    client.close();
  });
});

方式B：把bookings的user_id转成ObjectId #

这种方式用$lookup的let和pipeline参数，在子管道里把bookings.user_id转成ObjectId后再匹配，灵活性更高：

const MongoClient = require('mongodb').MongoClient;
const assert = require('assert');
const url = 'mongodb://root:root@localhost:3000/app';
const dbName = 'app';

MongoClient.connect(url, function(err, client) {
  assert.equal(err, null);
  const db = client.db(dbName);
  
  db.collection('app_users').aggregate([
    {
      $lookup: {
        from: 'bookings',
        let: { target_user_id: "$_id" }, // 传入app_users的ObjectId类型_id
        pipeline: [
          {
            $match: {
              $expr: {
                // 将bookings的user_id转为ObjectId，再和传入的_id匹配
                $eq: [ { $toObjectId: "$user_id" }, "$$target_user_id" ]
              }
            }
          }
        ],
        as: 'bookings'
      }
    }
  ]).toArray(function(err, docs) {
    assert.equal(err, null);
    console.log(docs);
    client.close();
  });
});

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