MongoDB Shell脚本遍历源集合匹配目标集合更新文档及报错解决

报错根因 #

当前抛出的TypeError: comment.appliesTo.targets._id is undefined错误，本质是代码取属性的路径和实际文档结构不匹配。 #

现有脚本的核心问题 #

• 错误把数组当对象取属性。源集合的appliesTo.targets是文档数组结构，代码直接通过foo.appliesTo.targets._id.documentId取值，相当于从数组对象上访问不存在的嵌套属性，必然拿到undefined抛出报错。
• 字段名不匹配。从你贴的源集合查询输出样例看，target条目下的id字段是barId，但代码里写死取documentId，就算解决了数组取值的问题，也会因为字段对不上查不到匹配数据。
• 缺少实际写入逻辑。现有代码只实现了匹配文档的查询，没有调用任何更新接口，就算查到目标文档也不会执行Text字段的新增/更新操作。
• 结构健壮性不足。没有对源文档的空值、数组结构做校验，遇到个别结构异常的文档就会直接中断整个遍历流程。

修正实现 #

修正后的代码完全匹配文档结构，同时实现要求的更新逻辑：通过$set操作符天然支持“字段不存在就新增、存在就覆盖更新”的语义，不需要额外判断字段是否存在。

// copyFoosToBars.js
function main() {
    print('Starting script.')
    print()

    var foosDb = db.getSiblingDB('foos');
    var barsDb = db.getSiblingDB('bars');
    var sourceCollection = foosDb.getCollection('foos');
    var targetCollection = barsDb.getCollection('bars');

    // 筛选符合条件的源文档，投影保留targets结构用于取值
    var sourceCursor = sourceCollection.find(
        {
            "appliesTo.targets.type": "Document",
            "_meta.deleted": null
        },
        {
            "_id": 0,
            "appliesTo.targets": 1
        }
    );

    let matchedCount = 0;
    let updatedCount = 0;

    sourceCursor.forEach(function(fooDoc) {
        // 结构校验，避免异常文档中断脚本
        if (!fooDoc.appliesTo || !Array.isArray(fooDoc.appliesTo.targets)) {
            return;
        }

        // 从targets数组中取出类型为Document的有效条目
        const documentTarget = fooDoc.appliesTo.targets.find(target => target.type === 'Document');
        if (!documentTarget || !documentTarget._id) {
            return;
        }

        // 兼容两种id字段命名的情况，按需调整成实际的字段名即可
        const matchDocumentId = documentTarget._id.documentId || documentTarget._id.barId;
        if (!matchDocumentId) {
            return;
        }

        matchedCount++;

        // 匹配目标集合并更新Text字段，命中即写入
        const updateResult = targetCollection.updateOne(
            { "_id.documentId": matchDocumentId },
            { $set: { "Text": "hi there" } }
        );

        if (updateResult.modifiedCount > 0) {
            updatedCount++;
            print(`Updated document, id: ${matchDocumentId}`);
        }
    });

    print()
    print('----------------------------------------------')
    print(`Execution completed. Matched source documents: ${matchedCount}, Updated target documents: ${updatedCount}`)
}

main()

执行注意事项 #

• 当前Mongo shell客户端和4.0.22版本的服务端不匹配（启动时的版本警告），建议替换为同版本的shell客户端，避免出现游标遍历、写操作的兼容性问题。
• 首次执行前可以先把updateOne逻辑替换成findOne查询，打印匹配到的目标文档ID做校验，确认匹配逻辑正确后再开启实际写入，避免误操作。
• 如果源集合数据量超过1万条，建议替换成bulkWrite批量更新逻辑，减少数据库交互次数，降低脚本执行的耗时。

内容的提问来源于stack exchange，提问作者Pure.Krome