JAVAmongodb聚合幾種查詢方式詳解

一、BasicDBObject

十載的鹽山網(wǎng)站建設(shè)經(jīng)驗(yàn)，針對設(shè)計(jì)、前端、開發(fā)、售后、文案、推廣等六對一服務(wù)，響應(yīng)快，48小時(shí)及時(shí)工作處理。網(wǎng)絡(luò)營銷推廣的優(yōu)勢是能夠根據(jù)用戶設(shè)備顯示端的尺寸不同，自動調(diào)整鹽山建站的顯示方式，使網(wǎng)站能夠適用不同顯示終端，在瀏覽器中調(diào)整網(wǎng)站的寬度，無論在任何一種瀏覽器上瀏覽網(wǎng)站，都能展現(xiàn)優(yōu)雅布局與設(shè)計(jì)，從而大程度地提升瀏覽體驗(yàn)。創(chuàng)新互聯(lián)從事“鹽山網(wǎng)站設(shè)計(jì)”,“鹽山網(wǎng)站推廣”以來，每個(gè)客戶項(xiàng)目都認(rèn)真落實(shí)執(zhí)行。

整個(gè)聚合查詢是統(tǒng)計(jì)用戶的各種狀態(tài)下的用戶數(shù)量為場景：

1.篩選條件：

date為查詢?nèi)掌冢?/p>

BasicDBObject Query = new BasicDBObject(); 
Query.put("time",new BasicDBObject("$gte", date + " 00:00:00")
 .append("$lte", date + " 23:59:59"));

如果有多個(gè)條件：直接加Query.put("status", 0);

如果有OR篩選：

BasicDBList values = new BasicDBList();
values.add(new BasicDBObject("status", new BasicDBObject("$exists",false)));
values.add(new BasicDBObject("status", 0));
Query.put("$or", values);

其中 new BasicDBObject("$exists",false)) 就是“status”不存在（MongoDB文檔可不等于實(shí)體的字段）

2.拼接match

DBObject Match = new BasicDBObject("$match", Query);

將上一步的Query放入macth篩選中

3.拼接分組條件

此步相當(dāng)于SQL的Group By

BasicDBObject GroupBy = new BasicDBObject();// 分組條件
GroupBy.put("userId", "$userId");//根據(jù)用戶ID來分組

同第一步的篩選一樣，如果有多個(gè)分組可直接添加在后面：GroupBy.put("status", "$status");

4.分組后查詢

首先把分組拼接上：

DBObject Select = new BasicDBObject("_id", GroupBy);

如果我們要對分組后的數(shù)據(jù)進(jìn)行操作：（這里是用戶的統(tǒng)計(jì)數(shù)量）

Select.put("count", new BasicDBObject("$sum", 1));

5.拼接$group

DBObject Group = new BasicDBObject("$group", Select);

至此。我們拼接，mongodb的語句到此結(jié)束

下面我們開始查詢操作：

import com.mongodb.AggregationOutput;
import org.springframework.data.mongodb.core.MongoTemplate;
AggregationOutput Output = mongoTemplate.getCollection("這里是mongodb的數(shù)據(jù)表名")
  .aggregate(Match, Group);

讀取查詢結(jié)果：

Iterable<DBObject> map = Output.results();
//遍歷map
for (DBObject dbObject : map) {
  //這里讀取到的map為{"_id":{"userId":1,"status"0}}...   
  Map<String, Object> resultMap = (Map<String, Object>) dbObject.get("_id");

  //這里截取掉.0   
  Integer userId = Integer.parseInt(CommUtil.toString(ausgMap.get("userId")).replace(".0",""));

  //在這里我們就可以對我們的數(shù)據(jù)進(jìn)行操作了；  
  Integer count = Integer.parseInt(CommUtil.toString(dbObject.get("count")));
     
}

二、DBObject

不多說，如果大家覺得第一種方法特別長篇大論，那么下面我給大家?guī)硪环N代碼更簡潔的聚合查詢：

直接上代碼吧。

1.注意導(dǎo)入的包:

import com.mongodb.DBObject; import com.mongodb.util.JSON;

2.$macth:

(beginDay-查詢開始日期；endDay-查詢結(jié)束日期)

DBObject match = (DBObject) JSON.parse("{$match:{'status':'1','time':
  {$gte:'"+beginDay+"',$lte:'"+endDay+"'}}}");

3.$group:

（以userId分組，統(tǒng)計(jì)用戶數(shù)量，累加amout字段值，取amout字段最大值）

DBObject group = (DBObject) JSON.parse("{$group:{_id:'$userId', 
  count:{$sum:1},total:{$sum:'$amount'},maxSigle:{$max:'$amount'}}}");

條件拼接完，開始查詢：

List<DBObject> list = new ArrayList<DBObject>();
list.add(match); list.add(group);
AggregationOutput Output = mongoTemplate.getCollection("表名").aggregate(list);

遍歷結(jié)果就不用在說了。上面已經(jīng)詳細(xì)描述了

第二種方法是不是比一種方式簡單多了。但是比較考驗(yàn)自身對mongodb語句熟悉性。

【擴(kuò)展】

接著上面的方法進(jìn)行擴(kuò)展

//status 為0或者為1 ; type 不為11；time在beginDay ~ endDay時(shí)間段內(nèi)
DBObject match = (DBObject) JSON.parse("{$match:{'status':{$in:['0','1']},
  type:{$ne:11},'time':{$gte:'"+beginDay+"',$lte:'"+endDay+"'}}}");

//以用戶Id分組，統(tǒng)計(jì)查詢次數(shù)，取最后一次time的時(shí)間
DBObject group = (DBObject) JSON.parse("{$group:{_id:'$userId', 
  count:{$sum:1},lastTime:{$max:'$time'} }}");

//在上一步統(tǒng)計(jì)出的結(jié)果中篩選次數(shù)大于100的數(shù)據(jù)
DBObject groupMatch = (DBObject) JSON.parse("{$match:{count:{$gte:100}}}");

//$project----查詢結(jié)果中需要顯示哪些字段，顯示則設(shè)置為1。如下需要不顯示_id 域（字段），則需如下指定：
//db.集合名.aggregate( [ { $project : { _id: 0, count: 1 , lastSuccTime: 1 } } ] )
DBObject project = (DBObject) JSON.parse("{$project:{_id:1,count:1,lastSuccTime:1}}");

DBObject sort = (DBObject) JSON.parse("{$sort:{'count':-1}}");//排序

List<DBObject> list = new ArrayList<DBObject>();
list.add(match);
list.add(group);
list.add(groupMatch);
list.add(project);
list.add(sort);
AggregationOutput catchOutPut = mongoTemplate.getCollection("表名")
  .aggregate(list);//查詢結(jié)果

三、BasicDBObject+腳本語句

BasicDBObject groupIndex = new BasicDBObject();
BasicDBObject distinctQuery = new BasicDBObject();
distinctQuery.put("userId", new BasicDBObject("$in", userIds));//UserIds數(shù)組
BasicDBObject initIndex = new BasicDBObject();
initIndex.put("count", 0);//給count賦初值

// 腳本（doc代表數(shù)據(jù)庫的數(shù)據(jù).prev代表查詢結(jié)果//prev.count這里的count就是上一步initIndex的count）
String reduce = "function(doc, prev) {if(doc.status==0){prev.count+= 1;};}";
List<Map<String, Object>> basicDBList = (List<Map<String, Object>>) mongoTemplate.
  getCollection("Collection").group(groupIndex, distinctQuery, initIndex, reduce, null);

最后循環(huán)遍歷List即可得到結(jié)果【PS：group這種聚合方式有個(gè)限制條件--->超過20000數(shù)據(jù)就會報(bào)錯(cuò)】

以上就是我在普通業(yè)務(wù)處理中用到mongodb聚合處理。如果有更好的方法或是有需要改進(jìn)的地方，歡迎大家給我留言~

網(wǎng)站標(biāo)題：JAVAmongodb聚合幾種查詢方式詳解
網(wǎng)頁鏈接：http://jinyejixie.com/article12/jjgdgc.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供網(wǎng)站設(shè)計(jì)、手機(jī)網(wǎng)站建設(shè)、營銷型網(wǎng)站建設(shè)、做網(wǎng)站、Google、網(wǎng)站維護(hù)

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來源：創(chuàng)新互聯(lián)

猜你還喜歡下面的內(nèi)容

成人午夜视频全免费观看高清-秋霞福利视频一区二区三区-国产精品久久久久电影小说-亚洲不卡区三一区三区一区

JAVAmongodb聚合幾種查詢方式詳解