MongoDB Java：如何获取写错误文件？

Question

我通过mongodb java api 3.6.1和方法insertMany(List<Document>)使用无序批量一次在mongodb 3.6中插入1000个文档。

try {
    collection.insertMany(docs);
} catch (MongoBulkWriteException e) {
    // e is :
   // Bulk write operation error on server myserver.com:27011. Write errors: [BulkWriteError{index=0, code=11000, message='E11000 duplicate key error collection: foodb.bar index: bar.id_1 dup key: { : 1 }', details={ }}].     
}

假设只有一个文档触发了重复键错误。所有其他999个文件都已成功插入。 我怎么知道哪个文件触发了错误？

当然，当获得重复键错误时，我可以使用重复的bar.id搜索我的文档列表，但这很不方便（这意味着解析WriteError消息......）如果在bar.id中有两个文件具有相同的List<Document>，在不询问数据库的情况下，几乎不可能知道哪个触发了错误。

谢谢

Answer 1

MongoBulkWriteException包含List<BulkWriteError>，每个失败的写入将由此列表中的元素表示。此列表中的每个元素都包含一个index属性，该属性使用提供的文档列表中的元素索引进行填充。

因此，您可以使用此index来确定哪些提供的文档失败。

这是一个测试案例，展示了这一点：

@Test
public void canBulkWriteAndIdentifySpecificFailedDocuments() throws IOException {
    MongoClient mongoClient = new MongoClientFactory().create();

    MongoCollection<Document> collection = mongoClient.getDatabase("stackoverflow").getCollection("bulkwrite");

    // fresh start for this test case
    collection.drop();

    Document knownDocument = new Document().append("name", new BsonString("beep"));
    collection.insertOne(knownDocument);

    collection.createIndex(new BasicDBObject("name", 1), new IndexOptions().unique(true));

    int createDuplicateOnIndex = 2;
    List<Document> docs = Lists.newArrayList();
    for (int i = 0; i < 5; i++) {
        if (i == createDuplicateOnIndex) {
            // deliberately trigger a duplicate key exception
            docs.add(knownDocument);
        } else {
            docs.add(new Document().append("name", new BsonString("beep" + i)));
        }
    }

    try {
        collection.insertMany(docs, new InsertManyOptions().ordered(false));
    } catch (MongoBulkWriteException ex) {
        assertThat(ex.getWriteResult().getInsertedCount(), is(4));
        assertThat(ex.getMessage(), containsString("duplicate key error"));
        assertThat(ex.getWriteErrors().size(), is(1));
        assertThat(ex.getWriteErrors().get(0).getIndex(), is(createDuplicateOnIndex));
        assertThat(ex.getWriteErrors().get(0).getCode(), is(11000));
        assertThat(ex.getWriteErrors().get(0).getMessage(), startsWith("E11000 duplicate key error"));
    }
}

在这个测试案例中我们......

1. 写一份文件
2. 在目标集合上创建唯一索引
3. 编写一组文档（使用new InsertManyOptions().ordered(false)进行无序写入），其中一个文档违反了唯一索引
4. 断言批量插入会导致抛出MongoBulkWriteException，并且此异常报告4次成功写入，1次使用E11000 duplicate key error写入失败，并且索引值清楚地表明此失败与给定列表中的第三个文档（index == 2）相关联。