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>

Java操作Mongo bulkWrite批量入库相关推荐

java操作elasticsearch实现批量添加数据（bulk）
java操作elasticsearch实现批量添加主要使用了bulk 代码如下: //bulk批量操作(批量添加) @Testpublic void test7() throws IOExceptio ...
MySQL批量入库的几种方式详解
MySQL批量入库的几种方式详解 1. MySQL批量入库概述 2. Hutool封装jdbc方式 3. Jdbc直接或批量执行方式 4. MyBatis批量入库方式 5. MySQL批量入库总结 1 ...
java批量下载demo_Java批量入库Demo
java中往数据库批量插入数据Demo java代码: //入库数据是需要批量入库的List int len =入库数据.size(); //每次循环10条 int incremnet = 10; / ...
java操作postgress的copy In入库操作
我们使用的数据库是Greeplum(GP),也就是基于PostGress开发的分布式数据库,至于为什么是分布式的,我也不知道,毕竟要学的东西很多..... 但是GP在入库操作的使用是相当慢的,可能我没 ...
elasticSearch入门到java操作api一套搞定
目录写在前面一.下载地址二.solr与es比较三.安装elasticsearch 四.安装可视化界面(hand插件) 使用五.安装kibana 六.学习es核心概念七.IK分词器插件八. ...
Spring Boot实战解决高并发数据入库: Redis 缓存+MySQL 批量入库
前言最近在做阅读类的业务,需要记录用户的PV,UV: 项目状况:前期尝试业务阶段: 特点: 快速实现(不需要做太重,满足初期推广运营即可) 快速投入市场去运营收集用户的原始数据,三要素: 谁在什 ...
高并发简单解决方案————redis队列缓存+mysql 批量入库(ThinkPhP)
源码地址:https://github.com/Tinywan/PHP_Experience 问题分析问题一:要求日志最好入库:但是,直接入库mysql确实扛不住,批量入库没有问题,done.[批量 ...
python处理完数据导入数据库_python操作数据库之批量导入
python操作数据库之批量导入 Python语法简洁清晰,特色之一是强制用空白符(white space)作为语句缩进. Python具有丰富和强大的库.它常被昵称为胶水语言,能够把用其他语言制作的 ...
在 Java 中，如何批量读取本项目资源目录下的所有文件
在 Java 中,如何批量读取本项目资源目录下的所有文件读取资源目录下的指定文件方法 1:使用 JDK 中原始 API 方法 2:借助 Spring 附录将 InputStream 转化为 by ...

Java操作Mongo bulkWrite批量入库

Java操作Mongo bulkWrite批量入库相关推荐

最新文章

热门文章