java操作mongodb之多表聯查的實現($lookup)
最近在開發的過程中,一個列表的查詢,涉及到了多表的關聯查詢,由于持久層使用的是mongodb,對這個非關系型數據使用的不是很多,所以在實現此功能的過程中出現了不少問題,現在此做記錄,一為加深自己的理解,以后遇到此類問題可以快速的解決,二為遇到同樣問題的小伙伴提供一點小小的幫助。
全文分為兩部分:
使用robo3t編寫多表關系的查詢語句 將編寫的查詢語句整合到java項目多表聯查的查詢語句:此處使用的為mongodb的robo3t可視化工具,先說下需求:從A(假如說是日志表)表中查詢出符合條件的數據,根據A表中符合條件數據查詢B(假如說是信息表)表中的數據,此處也可以將B表的查詢條件加入進來(類型于關系型數據庫中的臨時表)
mongo查詢語句:
db.getCollection(’A’).aggregate([ { $lookup:{ from:’B’, localField:’userid’, foreignField:’userid’, as:’userinfo’} }, { $unwind:’$userrole’//把一個數組展成多個,就比如說按多表連查的userrole數組中有10數據,那么用$unwind將把一條帶數組的數據分成10條,這10條數據除了userrole不同之外,其它數據都是相同的,就類似于一個展開操作 }, { $match:{’username’:’zhangsan’} }, { $group:{ _id:{ userid:’$userid’,//這個屬性必須是要A表中有的 userrole:’$userrole.roleid’,//A表中有一個集合,里面存放的對象有一個名為roleid的屬性 }, operateTime:{ $last:’$operateTime’//取A表操作時間最后一條件數 } info:{ $first:’$userinfo’//因為數組的擴展,造成了大量的重復數據(只有userrole不同),$first是只取最新的一條 }} }, { $sort:{’operateTime’:-1}//操作時間倒序,-1:倒序,1:升序 }, { $skip:0//跳過幾條數據,也就是從第幾條數據開始取 }, { $limit:5//每頁顯示幾條數據 }]);
java代碼整合查詢語句
//定義分組字段String[] groupIds = new String[] {'$userid','$userrole.roleid'};//定義查詢條件Criteria criteria = new Criteria();//相當于where username = 'zhangsan'criteria.and('username').is('zhangsan');//相當于 where age not in('15','20')criteria.and('age').nin('15','20');//in操作對應的語句//criteria.and('').in();//定義排序條件Sort sort = new Sort(Direction.DESC,'operateTime');//聯合查詢總條數,分頁用Aggregation aggregationCount = Aggregation.newAggregation( Aggregation.match(criteria);//查詢條件 Aggregation.group(groupIds);//分組字段);//聯合查詢條件Aggregation newAggregation = Aggregation.newAggregation( Aggregation.lookup(’B’,’userid’,’userid’,’userinfo’),//從表名,主表聯接字段,從表聯接字段,別名 Aggregation.unwind('$userrole'), Aggregation.match(criteria), Aggregation.group(groupIds) .last('$operateTime').as('operateTime')//取值,起別名 .first('$userinfo').as('info'), Aggregation.sort(sort), Aggregation.skip(pageSize*(pageNumber-1L)),//Long類型的參數 Aggregation.limit(pageSize));//查詢AggregationResults<BasicDBObject> aggregate = mongoTemplate.aggregate( newAggregation ,'A',BasicDBObject.class//A表,是查詢的主表);int count = mongoTemplate.aggregate(aggregationCount ,'A',BasicDBObject.class).getMappedResults().size();//組裝分頁對象Page<BasicDBObject> pager = new Page<>(aggregate.getMappedResults(),count,pageSize,pageNumber,page*(pageNumber-1));//對象轉換將BasicDBObject轉換成前面需要的類型.....
到此這篇關于java操作mongodb之多表聯查的實現($lookup)的文章就介紹到這了,更多相關java mongodb多表聯查內容請搜索好吧啦網以前的文章或繼續瀏覽下面的相關文章希望大家以后多多支持好吧啦網!
相關文章:
