Java操作MongoDB(聚合函数)向Mongo插入及查询数据
2024-05-07 06:00:18
数据库结果展示
插入后数据结构如下
具体内容
聚合函数(aggregate)
1.1 作用
用于处理数据(诸如统计平均值，求和等)，并返回计算后的数据结果,是MongoDB的高级查询语言，它允许我们通过转换和合并多个文档中的数据来生成新的单个文档中不存在的信息
1.2 聚合管道
1.2.1 $project实例
db.article.aggregate({ $project : {title : 1 ,author : 1 ,}});
这样的话结果中就只还有_id,tilte和author三个字段了，默认情况下_id字段是被包含的，如果要想不包含_id话可以这样:
db.article.aggregate({ $project : {_id : 0 ,title : 1 ,author : 1}});
1.2.2 $match实例
db.articles.aggregate( [{ $match : { score : { $gt : 70, $lte : 90 } } },{ $group: { _id: null, count: { $sum: 1 } } }] );
match用于获取分数大于70小于或等于90记录，然后将符合条件的记录送到下一阶段match用于获取分数大于70小于或等于90记录，然后将符合条件的记录送到下一阶段match用于获取分数大于70小于或等于90记录，然后将符合条件的记录送到下一阶段group管道操作符进行处理。
1.2.3 $skip实例
db.article.aggregate({ $skip : 5 });
经过$skip管道操作符处理后，前五个文档被"过滤"掉
1.2.4 $group实例(按性别分组，计算年龄和)
db.user.aggregate([{$group:{_id:"$sex",num:{$sum:"$age"}}
}])
1.2.5 $limit: 限制经过管道的文档数量( $limit的参数只能是一个正整数)
db.article.aggregate({ $limit : 5 });
1.2.6 $unwind：将数组元素拆分为独立字段
例如:article文档中有一个名字为tags数组字段：
> db.article.find() {"_id" : ObjectId("528751b0e7f3eea3d1412ce2"),
"author" : "Jone", "title" : "Abook",
"tags" : [ "good", "fun", "good" ] }
使用$unwind后:
> db.article.aggregate({$project:{author:1,title:1,tags:1}},{$unwind:"$tags"})
{"result" : [{"_id" : ObjectId("528751b0e7f3eea3d1412ce2"),"author" : "Jone","title" : "A book",
"tags" : "good"},{"_id" : ObjectId("528751b0e7f3eea3d1412ce2"),"author" : "Jone","title" : "A book",
"tags" : "fun"},{"_id" : ObjectId("528751b0e7f3eea3d1412ce2"),"author" : "Jone","title" : "A book","tags" : "good"}],"ok" : 1
}
1.2.7 $sort 实例
db.users.aggregate( { $sort : { age : -1, posts: 1 } });
1.3 组聚合操作符
1.4 Boolean类型聚合操作符
1.5 比较类型聚合操作符
1.6 算术类型聚合操作符
1.7 字符串类型聚合操作符
1.8 日期类型聚合操作符
1.9 条件类型聚合操作符
注：以上操作符都必须在管道操作符的表达式内来使用。
各个表达式使用参照:http://docs.mongodb.org/manual/reference/operator/aggregation-group/
Java操作Mongo(聚合函数)使用
2.1 插入(插入后数据库结构见最上方)
废话不多说 上代码(主要代码):
@Overridepublic void addDocument(String identity, String applicationKey, List<Map<String, String>> list) {//创建一个连接，自带连接池效果MongoClient mongoClient = MongoClients.create("mongodb://192.168.10.8:27017");//操作一个数据库，如果数据库不存在，当您为该数据库首次存储数据时，会自动创建数据库。MongoDatabase spitdbDatabase = mongoClient.getDatabase(applicationKey);//得到一个集合对象，如果集合不存在，当您为该数据库首次存储数据时，会自动创建集合。MongoCollection<Document> collection = spitdbDatabase.getCollection(identity);//创建一个文档，参数可以接收键值对，也可以直接接收一个Map对象//文档对象的本质是BSON类型，该类型对应java.util.Map;BSON数组对应的是java.util.ListList<Document> documentList = MongoUtils.listForDocument(list);Map<String, List<Document>> map = new HashMap<>();//int size = documentList.size();double number = 10.0;int n = 1;String[] s;for (Document document : documentList) {String gmtTarget = document.get("gmtTarget") + "";s = gmtTarget.split(" ");if (map.containsKey(s[0])) {if (map.get(s[0]).size() < number) {map.get(s[0]).add(document);} else {List<Document> documents = new ArrayList<>();documents.add(document);map.put(s[0] + "." + n, documents);n++;}} else {List<Document> documents = new ArrayList<>();documents.add(document);map.put(s[0], documents);}}FindIterable<Document> documents = collection.find();Map<String, Object> map1 = new LinkedHashMap<>();int val = 0;for (Document document1 : documents) {map1.put("_id" + "." + val, document1.get("_id"));val++;}for (String key : map.keySet()) {collectionDemo(map.get(key));Document document = new Document();//当数组在表中不存在时 就新建数组if (documents == null || map1.containsValue(key) == false) {document.append("_id", key).append("gmtStart", map.get(key).get(0).get("gmtTarget")).append("gmtEnd", map.get(key).get(map.get(key).size() - 1).get("gmtTarget")).append("count", map.get(key).size()).append("records", map.get(key));collection.insertOne(document);} else {//若存在 则在原有对应数组后插入新数据Document y2 = null;List<Document> list2 = map.get(key);for (int i = 0; i < map.get(key).size(); i++) {String gmtTarget = (String) map.get(key).get(i).get("gmtTarget");String[] s1 = gmtTarget.split(" ");y2 = new Document("_id", s1[0]);}//在数组后加入新数据 若数据存在 则不会存入Document update = new Document().append("$addToSet", new Document().append("records", new Document().append("$each", list2)));//获取数据的时间判断其所属数组 并将数据存入对应数组中collection.updateMany(y2, update);FindIterable<Document> documents1 = collection.find(y2);ArrayList<Document> records = null;for (Document document1 : documents1) {//获取对应数组相关信息records = (ArrayList<Document>) document1.get("records");}//System.out.println(records);collectionDemo(records);//向新数组新增数据后数组对应参数随之改变 给各个参数分别赋值Document update2 = new Document().append("$set", new Document().append("count", records.size()).append("gmtStart",records.get(0).get("gmtTarget")).append("gmtEnd", records.get(records.size() - 1).get("gmtTarget")).append("records", records));collection.updateOne(y2, update2);}}//释放资源mongoClient.close();}
2.2 查询
废话不多说 上代码(主要代码):
@RequestMapping(value = "/findMongo", method = RequestMethod.POST)public ResponseMessage findMongo(Integer index, @RequestBody Map<String, String> map) {if (index == null || index < 1) {index = 1;}MongoClient mongoClient = new MongoClient(host, port);MongoDatabase db = mongoClient.getDatabase(map.get("applicationKey"));//MongoDatabase db = mongoClient.getDatabase("dgg8be05077d4890910ed2ce8b481");//MongoCollection<Document> doc = db.getCollection(map.get("identity"));MongoCollection<Document> doc = db.getCollection(map.get("identity"));Page<Document> page = new Page<>();Map<String, String> mapKey = new HashMap<>();for (Map.Entry<String, String> entry : map.entrySet()) {if (StringUtils.isNotEmpty(entry.getValue())) {mapKey.put(entry.getKey(), entry.getValue());}}String identity = mapKey.get("identity");String applicationKey = mapKey.get("applicationKey");//Query query = new Query();//SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH-mm-ss");if (map != null && map.size() != 0 && !mapKey.isEmpty()) {// match(相当于 WHERE 或者 HAVING )BasicDBObject query = new BasicDBObject();List<BasicDBObject> list = new ArrayList<>();for (Map.Entry<String, String> entry : mapKey.entrySet()) {String key = entry.getKey();if (key.equals("identity") || key.equals("applicationKey") || key.equals("pageUrl")) {} else {String value = entry.getValue();if (value.contains("~")) {String[] split = value.split("~");String startTime = null;String endTime = null;try {startTime = split[0];endTime = split[1];} catch (Exception e) {e.printStackTrace();}list.add(new BasicDBObject("records.gmtTarget", new BasicDBObject("$gte", startTime)));list.add(new BasicDBObject("records.gmtTarget", new BasicDBObject("$lte", endTime)));} else {list.add(new BasicDBObject(("records") + "." + key, value));}}}if (list != null && list.size() > 0) {BasicDBObject[] array = new BasicDBObject[list.size()];list.toArray(array);query.append("$and", array);BasicDBObject match = new BasicDBObject("$match", query);BasicDBObject unwind = new BasicDBObject("$unwind", "$records");// BasicDBObject project = new BasicDBObject("$project", new BasicDBObject("count", new BasicDBObject("$size","$records")));BasicDBObject project = new BasicDBObject("$project", new BasicDBObject("records", 1));//sort（排序）BasicDBObject sort = new BasicDBObject("$sort", new BasicDBObject("count", -1));//1:正序，-1倒序//skip(跳过前面多少条数据，分页时使用)//limt(只要前多少条数据，分页时使用)BasicDBObject limit = new BasicDBObject("$limit", 15);BasicDBObject skip = new BasicDBObject("$skip", 0);List<BasicDBObject> aggregateList = new ArrayList<>();aggregateList.add(unwind);aggregateList.add(project);aggregateList.add(match);aggregateList.add(sort);aggregateList.add(limit);aggregateList.add(skip);AggregateIterable<Document> aggregate = mongoClient.getDatabase(applicationKey).getCollection(identity).aggregate(aggregateList);List<Document> list1 = new ArrayList<>();int totalCount = 0;for (Document document : aggregate) {list1.add(document);if (list1 != null) {totalCount++;}int totalPage = totalCount % 15 == 0 ? totalCount / 15 : totalCount / 15 + 1;page.setStartIndex((index - 1) * 15);page.setTotalRecords(totalCount);page.setTotalPage(totalPage);page.setRecords(list1);}page.setCurrentPage(index);page.setPageSize(Page.DEFAULT_VALUE);return success(page);} else {FindIterable<Document> iter = doc.find().skip(0).limit(15);int totalCount = 0;Page<Document> page1 = new Page<>();List<Document> list1 = new ArrayList<>();for (Document document : iter) {MongoCursor<Document> iterator = iter.iterator();iterator.next();if (document.get("_id") != null) {totalCount++;}document.remove("_id");Object records = document.get("records");document.put("records", records);list1.add(document);page1.setCurrentPage(index);page1.setPageSize(Page.DEFAULT_VALUE);int totalPage = totalCount % 15 == 0 ? totalCount / 15 : totalCount / 15 + 1;page1.setStartIndex((index - 1) * 15);page1.setTotalRecords(totalCount);page1.setTotalPage(totalPage);page1.setRecords(list1);}return success(page1);}} else {FindIterable<Document> iter = doc.find().skip(0).limit(15);int totalCount = 0;Page<Document> page1 = new Page<>();List<Document> list = new ArrayList<>();for (Document document : iter) {MongoCursor<Document> iterator = iter.iterator();iterator.next();if (document.get("_id") != null) {totalCount++;}document.remove("_id");Object records = document.get("records");document.put("records", records);list.add(document);page1.setCurrentPage(index);page1.setPageSize(Page.DEFAULT_VALUE);int totalPage = totalCount % 15 == 0 ? totalCount / 15 : totalCount / 15 + 1;page1.setStartIndex((index - 1) * 15);page1.setTotalRecords(totalCount);page1.setTotalPage(totalPage);page1.setRecords(list);}return success(page1);}}
至此 操作完成
Java操作MongoDB(聚合函数)向Mongo插入及查询数据相关推荐
- Java操作Mongodb数据（增删改查聚合查询）
文章目录 一.Java操作MongoDB 二.使用步骤 1.基础配置 2.实体类 3.MongoDB表数据 3.增删改查聚合查询 总结 一.Java操作MongoDB 上一篇文章介绍了,如何在本地使用 ...
- Java操作MongoDB数据库CRUD（增删查改）
Java操作MongoDB数据库CRUD(增删查改) 借助mongo-java-driver包,对MongoDB数据库的集合(DataTable)及文档(BSON对象数据)进行增删查改操作.本文的核心 ...
- Java操作MongoDB详解
Java操作MongoDB详解 1. MongoDB概述 1.1 MongoDB简介 1.2 MongoDB概念 2. MongoDB安装 2.1 MongoDB下载 2.2 MongoDB安装 2. ...
- java操作mongodb（连接池）（转）
原文链接: java操作mongodb(连接池) Mongo的实例其实就是一个数据库连接池,这个连接池里默认有10个链接.我们没有必要重新实现这个链接池,但是我们可以更改这个连接池的配置.因为Mong ...
- 【MongoDB for Java】Java操作MongoDB
软件151--熊佳杨 开发环境: System:Windows IDE:eclipse.MyEclipse 8 Database:mongoDB 开发依赖库: JavaEE5.mongo-2.5.3. ...
- mongodb for java_【MongoDB for Java】Java操作MongoDB
上一篇文章: http://www.cnblogs.com/hoojo/archive/2011/06/01/2066426.html介绍到了在MongoDB的控制台完成MongoDB的数据操作,通过 ...
- Java操作MongoDB
之前我们介绍的MongoDB的操作都是在shell命令中写的,在项目开发时我们当然都是用程序去操作MongoDB的,本文我们来看看如何用Java代码操作MongoDB. 本文是MongoDB系列的第十 ...
- Java操作MongoDB的基本操作
目录 Java连接MongoDB Java操作MongoDB MongoDB库操作 查看MongoDB链接中的所有的库 使用库查看库中的集合 MongoDB集合操作 插入数据 删除数据 修改数据 查询 ...
- Java操作MongoDB增删改查的基本操作
今天来讲一讲我们如何使用Java来对MongoDB进行增删改查 目录 一,Java链接MongoDB 导入MongoDB驱动包 获取链接对象 关闭链接 二,Java操作MongoDB 查看库,查看集合 ...
- java excel 插入新行_POI ，Java 操作 Excel 實現行的插入（insert row）
POI ,Java 操作 Excel 實現行的插入(insert row) 前幾天,正在做一個項目,主要用 POI 來操作 Excel 其中,要使用一個,插入功能.主要是因為從數據庫,返回結果集(數據 ...
最新文章
- DataBinding
- Cache相关基本概念理解
- c语言计算机二级考试要点,全国计算机二级考试c语言考试要点
- java properties 路径问题_Java 读取Properties文件时应注意的路径问题
- redis linux无法启动服务,CentOS7 下redis不能开机启动，求解？
- 计算机网络子网划分路由配置实验报告,洛阳理工学院+计算机网络+实验5子网划分路由配置...
- linux远程升级运行程序,运用RedHat的Kickstart升级Linux系统方法
- 使用glew和glad 新建窗口
- 微信小程序获取unionid为空
- linux字符界面下安装鼠标,Linux下有趣的命令：安装oneko实现小猫追鼠标
- 加快战略转型进程：统帅电器挺进年轻用户市场
- 小米开源语音模型 Kaldi-ONNX 转换工具，助力移动端部署！
- ql的python学习之路-day3
- matlabeig函数根据什么原理_vue3.0 源码解析二 ：响应式原理（下)
- 使用CSS实现透明边框的效果——兼容当前各种主流浏览器[xyytIT]
- 微软IE浏览器1月市场份额再创新低 跌至67.6%
- java课程设计签到系统_学生课堂签到系统设计及实现.doc
- 64k超高清3d程序 Warez出品的精品动画 近25万倍的压缩的精品
- java右移位_Java移位运算
- java写渗透工具_常用渗透测试工具使用tips