使用MongoDB Java 3.0驱动程序进行批量上传

Question

在早期版本的MongoDB Java驱动程序中，要运行查询并对结果进行无序批量增补，我们要做的就是：

BulkWriteOperation bulk = dbCollection.initializeUnorderedBulkOperation();
    bulk.find(searchQuery).upsert().update(new BasicDBObject("$set", getDbObjectModel()));

但是在版本3中，随着Bson Document支持和MongoCollection.bulkWrite（）方法的引入，该怎么做？

我尝试了这个：

List<WriteModel<Document>> documentList = new ArrayList<>();

collection.bulkWrite(documentList, new BulkWriteOptions().ordered(false));

但是，我需要upsert功能。

谢谢。

Answer 1

您仍然可以使用所有功能，只是BulkWrites现在具有不同的语法：

    MongoCollection<Document> collection = db.getCollection("sample");

    List<WriteModel<Document>> updates = Arrays.<WriteModel<Document>>asList(
        new UpdateOneModel<Document>(
                new Document(),                   // find part
                new Document("$set",1),           // update part
                new UpdateOptions().upsert(true)  // options like upsert
        )
    );

    BulkWriteResult bulkWriteResult = collection.bulkWrite(updates);

因此，您可以使用UpdateOneModel（或如果需要，可以使用很多），并将设置UpdateOptions为构造函数的第三个参数。

需要一些时间来适应，但是基本上它只是使用与其他地方相同的语法来构建“列表”。我想这就是改变的主要原因。