Mongo bulkWrite示例

public boolean insertBulk(String collectionName, JSONArray array) {MongoCollection<Document> collection = db.getCollection(collectionName);List<InsertOneModel<Document>> documentList = array.stream().map(item -> {Document document = Document.parse(((JSONObject)item).toJSONString());document.put("_id", document.getString("id"));return new InsertOneModel<Document>(document);}).collect(Collectors.toList());ListUtils.partition(documentList,1000).forEach(item->{collection.bulkWrite(item);});return true; }

ListUtils.partition來自于

<dependency><groupId>org.apache.commons</groupId><artifactId>commons-collections4</artifactId><version>4.3</version> </dependency>

總結(jié)

以上是生活随笔為你收集整理的Java操作Mongo bulkWrite批量入库的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。