Java操作MongoDB插入聚合数据报Invalid BSON field name $match错误如何解决

错误原因 #

你出现报错的核心问题是把聚合管道的阶段定义对象直接当成了待插入的业务文档传入insertMany，$match、$addFields这类是聚合操作的专属关键字，不属于普通业务文档允许的字段名，所以触发了BSON字段校验错误。
同时你的逻辑遗漏了最关键的一步：你没有在源数据集合上执行聚合查询拿到结果，直接把管道配置本身当成数据插入了。

解决方案1：应用层中转插入（适合小数据量场景） #

先在源集合执行你的聚合管道拿到处理后的文档，再把结果写入目标集合，代码调整如下：

String sourceCollectionName = "你的源集合名"; // 补充你要读取数据的源集合名称
String targetCollectionName = "SampleCollection";

MongoCollection<Document> sourceCollection = mongoOps.getCollection(sourceCollectionName);
MongoCollection<Document> targetCollection;

if (!mongoOps.collectionExists(targetCollectionName)) {
    targetCollection = mongoOps.createCollection(targetCollectionName);
    LOG.info("Collection %s was successfully created", targetCollectionName);
} else {
    targetCollection = mongoOps.getCollection(targetCollectionName);
}

List<? extends Bson> pipeline  = Arrays.asList(
        new Document()
                .append("$match", new Document()
                        .append("key", "PP")
                        .append("Amount", "RR")
                ),
        new Document()
                .append("$addFields", new Document()
                        .append("ID", "$_id")
                        .append("Period", nextPeriod)
                        .append("Type", new Document()
                                .append("key", "PP")
                                .append("value", "Statement")
                        )
                        .append("amount", new Document()
                                .append("$multiply", Arrays.asList(
                                        "$Amount.amount",
                                        Decimal128.parse("0.0")
                                )
                        )
                )
                .append("index", true)
        ),
        new Document()
                .append("$project", new Document()
                        .append("_id", 0.0)
                        .append("Amt", 0.0)
                        .append("Amount", 0.0)
                        .append("ClearAmount", 0.0)
                )
);

// 核心调整：在源集合执行聚合，拿到处理后的结果
List<Document> resultList = sourceCollection.aggregate(pipeline).into(new ArrayList<>());
// 插入结果到目标集合
targetCollection.insertMany(resultList);

解决方案2：用$merge阶段服务端直接写入（推荐，适合全场景） #

不需要把数据拉到应用层，直接在聚合管道末尾加$merge阶段，所有逻辑都在MongoDB服务端执行，性能更高，也是你原本预期的实现方式，代码调整如下：

String sourceCollectionName = "你的源集合名";
String targetCollectionName = "SampleCollection";

MongoCollection<Document> sourceCollection = mongoOps.getCollection(sourceCollectionName);

// 不用提前创建目标集合，$merge会自动创建不存在的集合
List<? extends Bson> pipeline  = Arrays.asList(
        new Document()
                .append("$match", new Document()
                        .append("key", "PP")
                        .append("Amount", "RR")
                ),
        new Document()
                .append("$addFields", new Document()
                        .append("ID", "$_id")
                        .append("Period", nextPeriod)
                        .append("Type", new Document()
                                .append("key", "PP")
                                .append("value", "Statement")
                        )
                        .append("amount", new Document()
                                .append("$multiply", Arrays.asList(
                                        "$Amount.amount",
                                        Decimal128.parse("0.0")
                                )
                        )
                )
                .append("index", true)
        ),
        new Document()
                .append("$project", new Document()
                        .append("_id", 0.0)
                        .append("Amt", 0.0)
                        .append("Amount", 0.0)
                        .append("ClearAmount", 0.0)
                ),
        // 新增$merge阶段，直接写入目标集合
        new Document("$merge", new Document()
                .append("into", targetCollectionName)
                .append("whenMatched", "replace") // 匹配到重复数据时的处理策略，可根据需求调整为keepExisting/insert/fail等
                .append("whenNotMatched", "insert")
        )
);

// 直接执行聚合即可，服务端自动完成写入
sourceCollection.aggregate(pipeline).toCollection();

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