AND、OR和IN操作

  1. AND:
  3. public void testAnd(){  
  4.     //agender='female' AND age > 27    
  5.     DBObject queryCondition = new BasicDBObject();  
  6.     queryCondition.put("agender", "female");  
  7.     queryCondition.put("age", new BasicDBObject("$gt", 27));  
  8.     DBCursor dbCursor = coll.find(queryCondition);  
  9.     assertEquals(1, dbCursor.size());  
  10.     assertEquals("Jane", dbCursor.next().get("username"));  
  11. }  
  14. OR:
  16. public void testOrSingleField(){  
  17.     DBObject queryCondition = new BasicDBObject();        
  18.     //age<15 OR age>27  
  19.     queryCondition = new BasicDBObject();  
  20.     BasicDBList values = new BasicDBList();  
  21.     values.add(new BasicDBObject("age", new BasicDBObject("$gt", 27)));  
  22.     values.add(new BasicDBObject("age", new BasicDBObject("$lt", 15)));  
  23.     queryCondition.put("$or", values);  
  25.     DBCursor dbCursor = coll.find(queryCondition);  
  26.     assertEquals(3, dbCursor.size());  
  27.     assertEquals("tom", dbCursor.next().get("username"));  
  28. }  
  31. OR:
  33. public void testOrMultiFields(){  
  34.     DBObject queryCondition = new BasicDBObject();        
  35.     //agender=female OR age<=23  
  36.     queryCondition = new BasicDBObject();  
  37.     BasicDBList values = new BasicDBList();  
  38.     values.add(new BasicDBObject("agender", "female"));  
  39.     values.add(new BasicDBObject("age", new BasicDBObject("$lte", 23)));  
  40.     queryCondition.put("$or", values);  
  42.     DBCursor dbCursor = coll.find(queryCondition);  
  43.     assertEquals(4, dbCursor.size());  
  44.     assertEquals("Jim", dbCursor.next().get("username"));  
  45. }
  48. IN:
  50. public void testIn(){  
  51.     DBObject queryCondition = new BasicDBObject();        
  52.     //age in [13, 47]  
  53.     queryCondition = new BasicDBObject();  
  54.     BasicDBList values = new BasicDBList();  
  55.     values.add(13);  
  56.     values.add(47);  
  57.     queryCondition.put("age", new BasicDBObject("$in", values));  
  59.     DBCursor dbCursor = coll.find(queryCondition);  
  60.     assertEquals(2, dbCursor.size());  
  61.     assertEquals("tom", dbCursor.next().get("username"));  
  62. }

JAVA mongodb 聚合几种查询方式详解

  1. https://www.jb51.net/article/137196.htm
  2. 一、BasicDBObject
  4. 整个聚合查询是统计用户的各种状态下的用户数量为场景：
  6. 1.筛选条件：
  8. date为查询日期：
  10. BasicDBObject Query = new BasicDBObject(); 
  11. Query.put("time",new BasicDBObject("$gte", date + " 00:00:00")
  12.  .append("$lte", date + " 23:59:59"));
  15. 如果有多个条件：直接加Query.put("status", 0);
  17. 如果有OR筛选：
  19. BasicDBList values = new BasicDBList();
  20. values.add(new BasicDBObject("status", new BasicDBObject("$exists",false)));
  21. values.add(new BasicDBObject("status", 0));
  22. Query.put("$or", values);
  25. 其中 new BasicDBObject("$exists",false)) 就是“status”不存在（mongodb文档可不等于实体的字段）
  27. 2.拼接match
  29. DBObject Match = new BasicDBObject("$match", Query);
  32. 将上一步的Query放入macth筛选中
  34. 3.拼接分组条件
  36. 此步相当于SQL的Group By
  38. BasicDBObject GroupBy = new BasicDBObject();// 分组条件
  39. GroupBy.put("userId", "$userId");//根据用户ID来分组
  42. 同第一步的筛选一样，如果有多个分组可直接添加在后面：GroupBy.put("status", "$status");
  44. 4.分组后查询
  46. 首先把分组拼接上：
  48. DBObject Select = new BasicDBObject("_id", GroupBy);
  51. 如果我们要对分组后的数据进行操作：（这里是用户的统计数量）
  53. Select.put("count", new BasicDBObject("$sum", 1));
  56. 5.拼接$group
  58. DBObject Group = new BasicDBObject("$group", Select);
  61. 至此。我们拼接，mongodb的语句到此结束
  63. 下面我们开始查询操作：
  65. import com.mongodb.AggregationOutput;
  66. import org.springframework.data.mongodb.core.MongoTemplate;
  67. AggregationOutput Output = mongoTemplate.getCollection("这里是mongodb的数据表名")
  68.   .aggregate(Match, Group);
  71. 读取查询结果：
  73. Iterable<DBObject> map = Output.results();
  74. //遍历map
  75. for (DBObject dbObject : map) {
  76.   //这里读取到的map为{"_id":{"userId":1,"status"0}}...   
  77.   Map<String, Object> resultMap = (Map<String, Object>) dbObject.get("_id");
  79.   //这里截取掉.0   
  80.   Integer userId = Integer.parseInt(CommUtil.toString(ausgMap.get("userId")).replace(".0",""));
  82.   //在这里我们就可以对我们的数据进行操作了；  
  83.   Integer count = Integer.parseInt(CommUtil.toString(dbObject.get("count")));
  85. }
  88. 二、DBObject
  90. 不多说，如果大家觉得第一种方法特别长篇大论，那么下面我给大家带来一种代码更简洁的聚合查询：
  92. 直接上代码吧。
  94. 1.注意导入的包:
  96. import com.mongodb.DBObject; import com.mongodb.util.JSON;
  99. 2.$macth:
  101. (beginDay-查询开始日期；endDay-查询结束日期)
  103. DBObject match = (DBObject) JSON.parse("{$match:{'status':'1','time':
  104.   {$gte:'"+beginDay+"',$lte:'"+endDay+"'}}}");
  107. 3.$group:
  109. （以userId分组，统计用户数量，累加amout字段值，取amout字段最大值）
  111. DBObject group = (DBObject) JSON.parse("{$group:{_id:'$userId', 
  112.   count:{$sum:1},total:{$sum:'$amount'},maxSigle:{$max:'$amount'}}}");
  115. 条件拼接完，开始查询：
  117. List<DBObject> list = new ArrayList<DBObject>();
  118. list.add(match); list.add(group);
  119. AggregationOutput Output = mongoTemplate.getCollection("表名").aggregate(list);
  122. 遍历结果就不用在说了。上面已经详细描述了
  124. 第二种方法是不是比一种方式简单多了。但是比较考验自身对mongodb语句熟悉性。
  126. 【扩展】
  128. 接着上面的方法进行扩展
  130. //status 为0或者为1 ; type 不为11；time在beginDay ~ endDay时间段内
  131. DBObject match = (DBObject) JSON.parse("{$match:{'status':{$in:['0','1']},
  132.   type:{$ne:11},'time':{$gte:'"+beginDay+"',$lte:'"+endDay+"'}}}");
  134. //以用户Id分组，统计查询次数，取最后一次time的时间
  135. DBObject group = (DBObject) JSON.parse("{$group:{_id:'$userId', 
  136.   count:{$sum:1},lastTime:{$max:'$time'} }}");
  138. //在上一步统计出的结果中筛选次数大于100的数据
  139. DBObject groupMatch = (DBObject) JSON.parse("{$match:{count:{$gte:100}}}");
  141. //$project----查询结果中需要显示哪些字段，显示则设置为1。如下需要不显示_id 域（字段），则需如下指定：
  142. //db.集合名.aggregate( [ { $project : { _id: 0, count: 1 , lastSuccTime: 1 } } ] )
  143. DBObject project = (DBObject) JSON.parse("{$project:{_id:1,count:1,lastSuccTime:1}}");
  145. DBObject sort = (DBObject) JSON.parse("{$sort:{'count':-1}}");//排序
  147. List<DBObject> list = new ArrayList<DBObject>();
  148. list.add(match);
  149. list.add(group);
  150. list.add(groupMatch);
  151. list.add(project);
  152. list.add(sort);
  153. AggregationOutput catchOutPut = mongoTemplate.getCollection("表名")
  154.   .aggregate(list);//查询结果
  157. 三、BasicDBObject+脚本语句
  159. BasicDBObject groupIndex = new BasicDBObject();
  160. BasicDBObject distinctQuery = new BasicDBObject();
  161. distinctQuery.put("userId", new BasicDBObject("$in", userIds));//UserIds数组
  162. BasicDBObject initIndex = new BasicDBObject();
  163. initIndex.put("count", 0);//给count赋初值
  165. // 脚本（doc代表数据库的数据.prev代表查询结果//prev.count这里的count就是上一步initIndex的count）
  166. String reduce = "function(doc, prev) {if(doc.status==0){prev.count+= 1;};}";
  167. List<Map<String, Object>> basicDBList = (List<Map<String, Object>>) mongoTemplate.
  168.   getCollection("Collection").group(groupIndex, distinctQuery, initIndex, reduce, null);
  171. 最后循环遍历List即可得到结果【PS：group这种聚合方式有个限制条件--->超过20000数据就会报错】
  173. 以上就是我在普通业务处理中用到mongodb聚合处理