MongoDB聚合查询中数组对象内ObjectId字段的精确匹配

{
  "_id": ObjectId("65b123456789012345678900"),
  "description": "这是一个包含实体数组的文档",
  "abc": [
    { "_id": ObjectId("65b12345678901234567890a"), "name": "实体A" },
    { "_id": ObjectId("65b12345678901234567890b"), "name": "实体B" },
    { "_id": ObjectId("65b12345678901234567890c"), "name": "实体C" }
  ]
}

const mongoose = require('mongoose');

// 假设您已经建立了Mongoose连接
// mongoose.connect('mongodb://localhost:27017/mydatabase', { useNewUrlParser: true, useUnifiedTopology: true })
//   .then(() => console.log('MongoDB connected'))
//   .catch(err => console.error('MongoDB connection error:', err));

// 定义一个简单的Schema和Model以供演示
const MySchema = new mongoose.Schema({
    description: String,
    abc: [{
        _id: mongoose.Schema.Types.ObjectId,
        name: String
    }]
}, { collection: 'MyCollection' }); // 指定集合名称
const MyModel = mongoose.model('MyCollectionModel', MySchema);

/**
 * 演示如何在聚合查询中匹配数组对象内的ObjectId字段。
 * @param {string[]} stringIdsToMatch 待匹配的字符串ID数组
 */
async function matchArrayObjectIds(stringIdsToMatch) {
    // 核心步骤：将字符串ID转换为ObjectId类型
    const objectIdsToMatch = stringIdsToMatch.map(id => new mongoose.Types.ObjectId(id));

    // 构建聚合管道
    const pipeline = [
        {
            $match: {
                // 正确匹配数组中对象的_id字段
                'abc._id': { $in: objectIdsToMatch }
            }
        }
    ];

    try {
        const results = await MyModel.aggregate(pipeline);
        console.log('匹配数组对象内_id的结果:', JSON.stringify(results, null, 2));
        return results;
    } catch (error) {
        console.error('查询出错:', error);
        throw error;
    }
}

// 示例调用：假设我们想匹配实体A和实体C的ID
const targetEntityIds = ['65b12345678901234567890a', '65b12345678901234567890c'];

// 运行示例（在实际应用中，请确保MongoDB连接已建立）
// matchArrayObjectIds(targetEntityIds);

// 复用MyModel定义

/**
 * 演示如何在聚合查询中匹配根文档的ObjectId字段。
 * @param {string[]} stringRootIds 待匹配的根文档字符串ID数组
 */
async function matchRootDocumentIds(stringRootIds) {
    // 核心步骤：将字符串ID转换为ObjectId类型
    const objectRootIds = stringRootIds.map(id => new mongoose.Types.ObjectId(id));

    // 构建聚合管道
    const pipeline = [
        {
            $match: {
                // 匹配根文档的_id字段
                _id: { $in: objectRootIds }
            }
        }
    ];

    try {
        const results = await MyModel.aggregate(pipeline);
        console.log('匹配根文档_id的结果:', JSON.stringify(results, null, 2));
        return results;
    } catch (error) {
        console.error('查询出错:', error);
        throw error;
    }
}

// 示例调用：假设我们想匹配ID为"65b123456789012345678900"的根文档
const targetDocumentIds = ['65b123456789012345678900'];

// 运行示例（在实际应用中，请确保MongoDB连接已建立）
// matchRootDocumentIds(targetDocumentIds);