Java操作Mongo bulkWrite批量入库

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>