mongoDB 分组查询

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了mongoDB 分组查询，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含6160字，纯文字阅读大概需要9分钟。

内容图文

1、准备数据

from pymongo import MongoClient
import datetime
?
client=MongoClient('mongodb://localhost:27017')
table=client['db1']['emp']
?
l=[
('张飞','male',18,'20170301','teacher',7300.33,401,1), #以下是教学部
('张云','male',78,'20150302','teacher',1000000.31,401,1),
('刘备','male',81,'20130305','teacher',8300,401,1),
('关羽','male',73,'20140701','teacher',3500,401,1),
('曹操','male',28,'20121101','teacher',2100,401,1),
('诸葛亮','female',18,'20110211','teacher',9000,401,1),
('周瑜','male',18,'19000301','teacher',30000,401,1),
('司马懿','male',48,'20101111','teacher',10000,401,1),
?
('袁绍','female',48,'20150311','sale',3000.13,402,2),#以下是销售部门
('张全蛋','female',38,'20101101','sale',2000.35,402,2),
('鹌鹑蛋','female',18,'20110312','sale',1000.37,402,2),
('王尼玛','female',18,'20160513','sale',3000.29,402,2),
('我尼玛','female',28,'20170127','sale',4000.33,402,2),
?
('杨过','male',28,'20160311','operation',10000.13,403,3), #以下是运营部门
('小龙女','male',18,'19970312','operation',20000,403,3),
('郭靖','female',18,'20130311','operation',19000,403,3),
('黄蓉','male',18,'20150411','operation',18000,403,3),
('梅超风','female',18,'20140512','operation',17000,403,3)
]
?
for n,item in enumerate(l):
    d={
        "_id":n,
        'name':item[0],
        'sex':item[1],
        'age':item[2],
        'hire_date':datetime.datetime.strptime(item[3],'%Y%m%d'),
        'post':item[4],
        'salary':item[5]
    }
    table.save(d)
?
# 准备数据

View Code

分组的概念与mysql相同,以某个字段作为依据进行归类,其目的是为了统计

2、$match

#match 用于对数据进行筛选
{"$match":{"字段":"条件"}},可以使用任何常用查询操作符$gt,$lt,$in等
?
#例1、select * from db1.emp where post='teacher';  # mysql的查询语句
db.emp.aggregate({"$match":{"post":"teacher"}}) #mongo的查询语句
?
#例2、select * from db1.emp where id > 3;  
db.emp.aggregate(
    {"$match":{"_id":{"$gt":3}}},
)

View Code

3、$project

#1、 project翻译为投射 ,即将一个数据结果映射为另一个结果 过程中可以对某些数据进行修改  控制其最终显示的结果， 1表示显示，0不显示；_id默认是1，其余默认是0。
{"$project":{"要保留的字段名":1,"要去掉的字段名":0,"新增的字段名":"表达式"}}
?
#1、select name,post,(age+1) as new_age from db1.emp;
db.emp.aggregate(
    {"$project":{
        "name":1,
        "post":1
        }})
?
#2、表达式之数学表达式
{"$add":[expr1,expr2,...,exprN]} #相加
{"$subtract":[expr1,expr2]} #第一个减第二个
{"$multiply":[expr1,expr2,...,exprN]} #相乘
{"$divide":[expr1,expr2]} #第一个表达式除以第二个表达式的商作为结果
{"$mod":[expr1,expr2]} #第一个表达式除以第二个表达式得到的余数作为结果

#例:所有人年龄加1显示
db.emp.aggregate(
    {"$project":{
        "name":1,
        "post":1,
        "new_age":{"$add":["$age",1]}
        }})
# 错误示范: 原因:参加运算的字段不能被隐藏
db.emp.aggregate(
    {"$project":{
    "name":1,
    "salary":1,
    "age":0,
    "new_age":{"$add":["$age",1]}
    }})
?
?
#3、表达式之日期表达式:$year,$month,$week,$dayOfMonth,$dayOfWeek,$dayOfYear,$hour,$minute,$second
#例如：select name,date_format("%Y") as hire_year from db1.emp
db.emp.aggregate(
    {"$project":{"name":1,"hire_year":{"$year":"$hire_date"}}}
)
?
#例如查看每个员工的工作多长时间
db.emp.aggregate(
    {"$project":{"name":1,"hire_period":{
        "$subtract":[
            {"$year":new Date()},
            {"$year":"$hire_date"}
        ]
    }}}
)
?
?
?
#4、字符串表达式
{"$substr":[字符串/$值为字符串的字段名,起始位置,截取几个字节]}
{"$concat":[expr1,expr2,...,exprN]} #指定的表达式或字符串连接在一起返回,只支持字符串拼接
{"$toLower":expr}
{"$toUpper":expr}
?
?
db.emp.aggregate( {"$project":{"NAME":{"$toUpper":"$name"}}})
?
#5、逻辑表达式
$and
$or
$not
其他见Mongodb权威指南

View Code

4、$group

# $group用于分组
# 分组后具体信息被影藏 
db.emp.aggregate(
    {"$match":{"_id":{"$gt":3}}},
    {"$group":{"_id":"$post"}}  
)
?
# 通常我们要对分组后的内容进行统计这就需要对应的几个聚合函数
?
# select id,avg(salary) from db1.emp where id > 3 group by post;  
db.emp.aggregate(
    {"$match":{"_id":{"$gt":3}}},
    {"$group":{"_id":"$post",'avg_salary':{"$avg":"$salary"}}},
)
# math用于匹配 与mysql不同的是没有顺序限制 每一个操作像是一个管道接收上一个的数据进行处理再传给下一个
?
# select id,avg(salary) from db1.emp where id > 3 group by post having avg(salary) > 10000;  
db.emp.aggregate(
    {"$match":{"_id":{"$gt":3}}},
    {"$group":{"_id":"$post",'avg_salary':{"$avg":"$salary"}}},
      {"$match":{"avg_salary":{"$gt":10000}}}
)
?
?
# 对应的聚合函数 $sum、$avg、$max、$min、$first、$last
?
?
#1、将分组字段传给$group函数的_id字段即可
{"$group":{"_id":"$sex"}} #按照性别分组
{"$group":{"_id":"$post"}} #按照职位分组
{"$group":{"_id":{"state":"$state","city":"$city"}}} #按照多个字段分组，比如按照州市分组
?
#2、分组后聚合得结果,类似于sql中聚合函数的聚合操作符：$sum、$avg、$max、$min、$first、$last
#例1：select post,max(salary) from db1.emp group by post; 
db.emp.aggregate({"$group":{"_id":"$post","max_salary":{"$max":"$salary"}}})
?
#例2：去每个部门最大薪资与最低薪资
db.emp.aggregate({"$group":{"_id":"$post","max_salary":{"$max":"$salary"},"min_salary":{"$min":"$salary"}}})
?
#例3：如果字段是排序后的，那么$first,$last会很有用,比用$max和$min效率高
db.emp.aggregate({"$group":{"_id":"$post","first_id":{"$first":"$_id"}}})
?
#例4：求每个部门的总工资
db.emp.aggregate({"$group":{"_id":"$post","count":{"$sum":"$salary"}}})
?
#例5：求每个部门的人数
db.emp.aggregate({"$group":{"_id":"$post","count":{"$sum":1}}})
?
?
#3、数组操作符
{"$addToSet":expr}：不重复
{"$push":expr}：重复
# 等同于group_concat
#例：查询岗位名以及各岗位内的员工姓名:select post,group_concat(name) from db1.emp group by post;
db.emp.aggregate({"$group":{"_id":"$post","names":{"$push":"$name"}}})
db.emp.aggregate({"$group":{"_id":"$post","names":{"$addToSet":"$name"}}})

View Code

5、$sort ,limit,skip

{"$sort":{"字段名":1,"字段名":-1}} #1升序，-1降序
{"$limit":n} 
{"$skip":n} #跳过多少个文档
#例1、取平均工资最高的前两个部门
?
db.emp.aggregate(
{
    "$group":{"_id":"$post","平均工资":{"$avg":"$salary"}}
},
{
    "$sort":{"平均工资":-1}
},
{
    "$limit":2
}
)
#例2、
db.emp.aggregate(
{
    "$group":{"_id":"$post","平均工资":{"$avg":"$salary"}}
},
{
    "$sort":{"平均工资":-1}
},
{
    "$limit":2
},
{
    "$skip":1
}
)
排序：$sort、限制：$limit、跳过：$skip

View Code

6、$sample

# 随机取出n条记录
#集合users包含的文档如下
{ "_id" : 1, "name" : "dave123", "q1" : true, "q2" : true }
{ "_id" : 2, "name" : "dave2", "q1" : false, "q2" : false  }
{ "_id" : 3, "name" : "ahn", "q1" : true, "q2" : true  }
{ "_id" : 4, "name" : "li", "q1" : true, "q2" : false  }
{ "_id" : 5, "name" : "annT", "q1" : false, "q2" : true  }
{ "_id" : 6, "name" : "li", "q1" : true, "q2" : true  }
{ "_id" : 7, "name" : "ty", "q1" : false, "q2" : true  }
?
#下述操作时从users集合中随机选取3个文档
db.users.aggregate({"$sample":{"size":3}})
随机选取n个：$sample

View Code

内容总结

以上是互联网集市为您收集整理的mongoDB 分组查询全部内容，希望文章能够帮你解决mongoDB 分组查询所遇到的程序开发问题。如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容，请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/913177.html

来源：【匿名】

【上一篇】MongoDB图形化工具使用ssh连接【下一篇】在MongoDB上如何进行数据的导入与导出

更多 ►

【mongoDB 分组查询】教程文章相关的互联网学习教程文章

数据的保存include_once ‘mDB.class.php‘;$m=new mDB();$m->setDB(‘mydb‘);// $m->save(‘stu‘,[‘dept‘=>‘财务‘,‘name‘=>‘张三‘,‘age‘=>73]);// $m->save(‘stu‘,[‘dept‘=>‘计算机‘,‘name‘=>‘张四‘,‘age‘=>53]);// $m->save(‘stu‘,[‘dept‘=>‘计算机‘,‘name‘=>‘张五‘,‘age‘=>23]);// $m->save(‘stu‘,[‘dept‘=>‘财务‘,‘name‘=>‘张六‘,‘age‘=>93]);// $m->save(‘stu‘,[‘dept‘=...

MongoDB学习笔记之分组（group）使用示例【代码】

// 准备测试数据 db.user.drop(); for(var i=10; i< 100; i++) {db.user.insert({name:"user" + i, age : Math.floor(Math.random()*10)+ 20, sex : Math.floor(Math.random()*3)%2 ==0 ? ‘M‘ : ‘F‘,chinese : Math.floor(Math.random()*50)+50,math : Math.floor(Math.random()*50)+50,english : Math.floor(Math.random()*50)+50,class : "C" + i%5}) }// group函数 // 按照class进行分组，显示每个class中的用户姓名和性别 ...

mongodb group分组【代码】

先插入测试数据：for(var i=1; i<20; i++){ var num=i%6; db.test.insert({_id:i,name:"user_"+i,age:num});} 说明，如果有_id这个，mongodb就不会生成_id，会采用你提供的_id. 1.普通分组查询db.test.group({key:{age:true},initial:{num:0},$reduce:function(doc,prev){prev.num++}}); [{"age" : 1,"num" : 4},{"age" : 2,"num" : 3},{"age" : 3,"num" : 3},{"age" : 4,"num" : 3},{"age" : 5,"num" : 3},{"age" : 0,"nu...

MongoDB中使用MapReduce进行分组统计【图】

MongoDB中使用MapReduce进行分组统计最近在统计某一个时间段的url去重数，由于数据量巨大导致报错，提示： distinct failed: { MongoDB中使用MapReduce进行分组统计最近在统计某一个时间段的url去重数，，由于数据量巨大导致报错，提示： distinct failed: { "errmsg" : "exception: distinct too big, 16mb cap", "code" : 17217, "ok" : 0 } at src/mongo/shell/collection.js:1108 经过查阅资料，最终通过mapreduce来解决如下...

mongodb分组排序【代码】

@Overridepublic MessageDto getCheckInMembersByFlight(String fltDt, String fltNr, String channel,String origincd,String destcd) {log.info("请求参数："+"fltDt:"+fltDt+",fltNr:"+fltNr+",channel:"+channel+",origincd:"+origincd+",destcd:"+destcd);MessageDto messageDto = new MessageDto();boolean flag = (null !=fltDt&&!("").equals(fltDt)&&null !=fltNr&&!("").equals(fltNr)&&null !=channel&&!("").equals(ch...

MongoDB,分组,聚合【代码】【图】

… 而不是find 管道在Unix和Linux中一般用于将当前命令的输出结果作为下一个命令的参数。MongoDB的聚合管道将MongoDB文档在一个管道处理完毕后将结果传递给下一个管道处理。管道操作是可以重复的。每一个操作符(集合)都会接受一连串的文档,对这些文档做一些类型转换,最后将转换后的文档作为结果传递给下一个操作符,对于最后一个操作符,是将结果返回给客户端 //分组(这里制定了分组字段 $+字段名)//这里可以理解为,吧lastModifyByU...

MongoDB学习笔记~管道中的分组实现group+distinct【代码】

多分组(group+distinct) db.M_User_Footprints.aggregate([{ $group: { _id: { UserInfoID: "$UserInfoID", ObjID: "$PlayVideo.ObjID" } } },{ $group: { _id: "$_id.UserInfoID", count: { $sum: 1 } } },{ $sort: { "_id": 1 } } ]);注意，这里的第二个分组用的是第一个分组的_id，所以加上了$_id，这表示使用上面group的数据源来作为第二个分组的键。而如果只是单个分组，就很容易实现了，也看一下代码//单分组 db.M_User_Foo...

mongodb 分组查询【代码】【图】

‘mDB.class.php‘;$m=new mDB();$m->setDB(‘mydb‘);// $m->save(‘stu‘,[‘dept‘=>‘财务‘,‘name‘=>‘张三‘,‘age‘=>73]);// $m->save(‘stu‘,[‘dept‘=>‘计算机‘,‘name‘=>‘张四‘,‘age‘=>53]);// $m->save(‘stu‘,[‘dept‘=>‘计算机‘,‘name‘=>‘张五‘,‘age‘=>23]);// $m->save(‘stu‘,[‘dept‘=>‘财务‘,‘name‘=>‘张六‘,‘age‘=>93]);// $m->save(‘stu‘,[‘dept‘=>‘计算机‘,‘name‘=>‘...

mongodb命令行group分组和java代码中group分组【代码】【图】

db.test.group({key:{"age":1},initial:{"count":0},$reduce:function(doc,out){ out.count++; } ,$finalize:function(out){ return out; }})执行代码及结果如图：2、java原生代码进行上述操作：public class MonTest {public static void main(String[] args) {monGroup();}public static void monGroup() {ServerAddress sa = new ServerAddress("192.168.0.201", 37017);List<MongoCredential> mongoCredentialList = new Array...

Mongodb 分组查询例子

db.tblCard.aggregate([ { $match: { "sNo": { "$exists": true }, "pNo": { "$exists": true }, "pEffDate": { "$gte": ISODate("2017-01-01T00:00:00.000+0800"), "$lte": ISODate("2017-05-01T08:00:00.000+0800") } } ...

mongodb基础学习12-分组group操作【图】

group可以实现常用的统计操作，如求最大值，最小值，求和其中reduce是最关键的操作，是对每一条记录的具体操作下面来看例子：分组count求和部分结果下面的加了个查询条件，即查询价格大于50的数据求分组商品总数量求分组最贵商品价格求分组商品平均价格问题：group不支持分片集群，如果想要支持分片，可以用aggregate框架或者mapReducemongodb基础学习12-分组group操作标签：bubuko 最大值结果 aggregate http mapr 基...

MongoDB分组查询，聚合查询，以及复杂查询【代码】

准备数据 from pymongo import MongoClient import datetimeclient=MongoClient(mongodb://localhost:27017) table=client[db1][emp]l=[ (张飞,male,18,20170301,,7300.33,401,1), #以下是教学部 (张云,male,78,20150302,teacher,1000000.31,401,1), (刘备,male,81,20130305,teacher,8300,401,1), (关羽,male,73,20140701,teacher,3500,401,1), (曹操,male,28,20121101,teacher,2100,401,1), (诸葛亮,female,18,20110211,teacher,9...

mongodb 分组求最大值

先上代码 db.getCollection("playback").aggregate([ {$match:{"game_record_id":{$in:[68,69]}}},{$group:{ _id:"$game_record_id", record_id:{$max:"$record_id"}, data:{$max: ‘$$ROOT‘} } }, {$project:{_id:1,record_id:1,data:{user_id:1}}}]) $match 是查询条件 $group 分组 , _id是分组字段，record_id 是每组里面的最大值，data 是每组里面的最大值最在的一行全部数据 $project 控制显示字段 ...

Mongodb按照日期分组统计【代码】

或者 Aggregation.project().and(DateOperators.DateToString.dateOf("createTime").toString("%Y-%m-%d")).as("name"), Aggregation.group("time").count().as("count") dateAsFormattedString(）方法会默认将当前时间转为系统默认的时区 2.进行时间补偿（默认当前时区是东八区，即8x3600x1000=28800000） Aggregation.project().andExpression("add(createTime,28800000)").as("time"), Aggregation.group("time").count().as("c...

MongoVUE下实现MongoDB的Group分组查询【图】

我们知道，MongoDB是一种非关系型数据库，所以它的查询方式与标准的结构化查询语言SQL有很大的不同。但无论它是怎么复杂的一种结构，当它经过开发者的双手后，（一）选中需要分组的表，选择“Collection--Group”，打开分组功能。　　（二）在Key下面输入需要分组的字段，Conditions下输入分组过滤条件。打开ReduceTab页，在Initial Value出输入“{"count": 0}”，下面Reduce功能处输入：functionReduce(doc, out) {　　out.co...

首页 / MONGODB / mongoDB 分组查询

mongoDB 分组查询

内容导读

内容图文

1、准备数据

2、$match

3、$project

4、$group

5、$sort ,limit,skip

6、$sample

内容总结

内容备注

内容手机端

【mongoDB 分组查询】教程文章相关的互联网学习教程文章

mongodb 分组查询【代码】【图】

MongoDB学习笔记之分组（group）使用示例【代码】

mongodb group分组【代码】

MongoDB中使用MapReduce进行分组统计【图】

mongodb分组排序【代码】

MongoDB,分组,聚合【代码】【图】

MongoDB学习笔记~管道中的分组实现group+distinct【代码】

mongodb 分组查询【代码】【图】

mongodb命令行group分组和java代码中group分组【代码】【图】

Mongodb 分组查询例子

mongodb基础学习12-分组group操作【图】

MongoDB分组查询，聚合查询，以及复杂查询【代码】

mongodb 分组求最大值

Mongodb按照日期分组统计【代码】

MongoVUE下实现MongoDB的Group分组查询【图】

MONGODB - 相关标签

分组 - 相关标签

MONGODB - 技术教程分类

MONGODB - 最新教程

MONGODB - 最热教程