| Java中mongodb指定DB通过aggregate聚合查询操作示例 | 您所在的位置：网站首页 › mongodb导入数据 › Java中mongodb指定DB通过aggregate聚合查询操作示例 |
Java中mongodb指定DB通过aggregate聚合查询操作示例
|
目录 前言： 应用场景： 命令描述： 代码示例： 聚会查询： 数量查询： 前言：大家都知道，mongodb是一个非关系型数据库，也就是说，mongodb数据库中的每张表是独立存在的，表与表之间没有任何依赖关系。当我们数据量非常大时，都通过筛选条件去筛选不尽人意；所以，我们设计的时候，就直接通过DB进行区分，如：聊天记录，通过roomId建DB等。在mongodb中，除了各种CRUD语句之外，还给我们提供了聚合的功能，这篇文章主要来跟大家聊聊mongodb的aggregate的操作。 应用场景：最近因开发直播项目，用MongoDB存储用户聊天数据，后期数据量会非常大。处理好数据结构，每天处理上亿的数据没问题，小编以前就用Mongodb存储路由器访问记录数据，每天过亿。 MongoDB 是一种文档型数据库，里面分为数据库（DBs）和集合（Collections），分别相当于SQL的数据库和数据表。数据因为本次业务原因，做的都是查询操作，没有增删改等操作。 命令描述：
管道的概念： 管道在Unix和Linux中一般用于将当前命令的输出结果作为下一个命令的参数。 MongoDB的聚合管道将MongoDB文档在一个管道处理完毕后将结果传递给下一个管道处理。管道操作是可以重复的。 表达式：处理输入文档并输出。表达式是无状态的，只能用于计算当前聚合管道的文档，不能处理其它的文档。 这里我们介绍一下聚合框架中常用的几个操作： ● $project：(select)修改输入文档的结构。可以用来重命名、增加或删除域，也可以用于创建计算结果以及嵌套文档。 ● $match：(where)用于过滤数据，只输出符合条件的文档。 $match使用MongoDB的标准查询操作。 ● $group：(group by)将集合中的文档分组，可用于统计结果。 ● $match：(having)。 ● $sum：(sum)可用于统计结果。 ● $sum $sortByCount：(count)可用于统计数。 ● $lookup：(join)建立连接。 ● $limit：(limit)用来限制MongoDB聚合管道返回的文档数。 ● $skip：(偏移量)在聚合管道中跳过指定数量的文档，并返回余下的文档。 ● $unwind：将文档中的某一个数组类型字段拆分成多条，每条包含数组中的一个值。 ● $sort：(order by, 1升序，-1降序)将输入文档排序后输出。 ● $geoNear：输出接近某一地理位置的有序文档。 代码示例：需要注意的是，MongoDB有一个管道的概念，相当于一层一层的过滤，顺序不能乱，否则会报错（A pipeline stage specification object must contain exactly obe field）。这其实和我们在用sql语句查询时候是一样的，都是select.....where....group by....order by....limit...顺序不能乱是一样的。 聚会查询： // match(相当于 WHERE 或者 HAVING ) BasicDBObject query= new BasicDBObject(); BasicDBObject[] array = { new BasicDBObject("time", new BasicDBObject("$gte", "2018-09-12")),new BasicDBObject("time", new BasicDBObject("$lte","2018-12-25"))}; query.append("$and", array); BasicDBObject match = new BasicDBObject("$match", query); // group（相当于 GROUP BY） BasicDBObject group = new BasicDBObject("$group", new BasicDBObject("_id", "$subject") .append("count", new BasicDBObject("$sum", 1))); // sort（排序） BasicDBObject sort = new BasicDBObject("$sort", new BasicDBObject("count", -1));//1:正序，-1倒序 // skip(跳过前面多少条数据，分页时使用) //limt(只要前多少条数据，分页时使用) BasicDBObject limit = new BasicDBObject("$limit", pageSize); BasicDBObject skip = new BasicDBObject("$skip", (pageNo - 1) * pageSize); // queryList集合里的**顺序不能乱**，否则会报错。 List queryList = new ArrayList(); queryList .add(match); queryList .add(group); queryList .add(sort); queryList .add(skip); queryList .add(limit); // 变量dbName，动态指向DB AggregateIterable iterable = mongoClient.mongoClient.getDatabase(dbName).getCollection(gatherName).aggregate(queryList );上面的代码就是进行聚合后的操作，查询出的集合里有(_id,count)两个字段，_id对应的值就是subject,count对应的值是总数，这样我们就可以查出结果了，并且进行了分页操作，只需要传入相应pageNo和pageSize就可以了。 数量查询：由于我们设计的时候，是通过房间为维度roomID作为DB（变量DBName），查询数量可以通过以下方式： // 获取聊天总数 Long count = mongoTemplate.getCollection(DBName).countDocuments();如果本篇文章对你有帮助的话，很高兴能够帮助上你。 当然，如果你觉得文章有什么让你觉得不合理、或者有更简单的实现方法又或者有理解不来的地方，希望你在看到之后能够在评论里指出来，我会在看到之后尽快的回复你。 |
【本文地址】