Java MongoDB 多联查询_如漩涡_java mongodb联表查询

irpas 02-07 7972

Java MongoDB 多联查询前言联表Select列表结构生成管道

前言

我使用的是spring包里的mongoTemplate进行操作Mongo，那基本单表的操作满足日常需求了；但是难免会有要联表操作的时候，mongo-data包里提供了一种Aggregation类，可以理解为建立管道。

联表

LookupOperation这个类就是用来进行联表操作的类，具体方法：

newLookup ，用来创建一个LookupOperation.Builder；from，要连接哪张表，类似Mysql的JOIN；localField，主表哪个字段去连接，指明出来；foreignField ，连接的那个表哪个字段关联；as，从表结果集名，最后会在主表多出这个自定义列，默认List；理解为as一个别名，会把从表的数据以数组的形式在as字段内 // 联表 LookupOperation lookupOperation = LookupOperation.newLookup() // 连接哪张表 .from("Item") // 主表哪个字段连接 .localField("sItemId") // 从表哪个字段关联 .foreignField("_id") // 从表结果集名最后会在主表多出这个自定义列默认List .as("item"); Select列

ProjectionOperation这个类可以理解为构造Mysql的Select列

// 类似mysql的select列如果要用从表的列就as自定义列名点属性 ProjectionOperation projectionOperation = Aggregation.project("id", "sItemId", "iCount", "item.iDuration", "item.sName", "item.sIcon", "item.sDes", "item.iItemType"); 表结构

Item

{ "_id": "111", "sActiveId": "222", "sName": "333", "sIcon": "444", "sDes": "555", "iItemType": NumberInt("1"), "sValue": "666", "iProperty": [ "0" ], "iDuration": NumberInt("77"), "createTime": ISODate("2022-03-23T08:13:19.694Z"), "updateTime": ISODate("2022-03-23T08:13:19.694Z"), "iStatus": NumberInt("0") }

ItemUser

{ "_id": "222", "sActiveId": "333", "sItemId": "111", "sUserId": "444", "iCount": NumberInt("4") } 生成管道 // 联表 LookupOperation lookupOperation = LookupOperation.newLookup() // 连接哪张表 .from("Item") // 主表哪个字段连接 .localField("sItemId") // 从表哪个字段关联 .foreignField("_id") // 从表结果集名最后会在主表多出这个自定义列默认List .as("item"); // 查询 Criteria criteria = Criteria.where("sUserId").is("444"); // 类似mysql的select列如果要用从表的列就as自定义列名点属性 ProjectionOperation projectionOperation = Aggregation.project("id", "sItemId", "iCount", "item.iDuration", "item.sName", "item.sIcon", "item.sDes", "item.iItemType"); // 建立管道 Aggregation aggregation = Aggregation.newAggregation( // 联表 lookupOperation, // 查询 Aggregation.match(criteria), // 将某个集合列拆成字段添加主表 Aggregation.unwind("item"), // 排序 Aggregation.sort(Sort.Direction.DESC, "createTime"), // select projectionOperation ); AggregationResults<JSONObject> aggregationResults = mongoTemplate.aggregate(aggregation, "ItemUser", JSONObject.class); List<JSONObject> result = aggregationResults.getMappedResults();

前面提到，as会在主表新增个列，列里内容是数组，Aggregation.unwind(“item”)的作用就是把as列里数组拆掉，通过ProjectionOperation 加在主表自定义字段中