Mongodb 关联表查询

Awbeci - 2021-09-30 13:27:23

---

前言

最近学习使用mongodb中间使用关联表查询问题遇到一些问题记录下来分享给大家。

mongodb关联查询

之前使用SQL语法来查询oracle、sqlserver、mysql表之间的关联，但是到mongodb之后完全无从下手，写法完全不一样，于是到网上查询mongodb关联表查询的写法，于是参考代码自己试着写了下，但是发现有好多问题，比如我有两个表user和apple，

user表：

idnameagecreateDtObjectId(1xxxx1)zhangsan32ObjectId(2xxxx2)lishi23ObjectId(3xxxx3)wangwu19ObjectId(4xxxx4)liuliu28

apple表：

iduiddevicecreateDtObjectId(axxxxa)1xxxx110ObjectId(bxxxxb)2xxxx22ObjectId(cxxxxc)3xxxx37ObjectId(dxxxxd)4xxxx41

user实体类：

@Setter
@Getter
public class User {
    private String id;
    private String name;
    private Integer age;
    private Date createDt;
}

apple实体类：

@Setter
@Getter
public class Apple {
    private String id;
    private String uid;
    private Integer device;
    private Date createDt;
}

user和apple之间是一对一关系，现在我的查询要求是：按device数量从大到小排序查询用户数据。

查询结果应该是：

idnameagecreateDtObjectId(1xxxx1)zhangsan32ObjectId(3xxxx3)wangwu19ObjectId(2xxxx2)lishi23ObjectId(4xxxx4)liuliu28

我们分别使用user表和apple表做主表来查询，那么使用mongodb语法我们试着来写一下。

以user表做主表查询

// 1、添加_id字段类型转换
AddFieldsOperation addFieldsOperation = AddFieldsOperation.addField("_id").withValue(ConvertOperators.ToString.toString("$_id")).build();

// 2、按参数顺序：被关联表apple，主表user.id，被关联表apple.uid，别名
LookupOperation lookupOperation = Aggregation.lookup("apple", "_id", "uid", "apple_as");

// 3、查询哪些字段，类似sql里面的 select 选择器
ProjectionOperation project = Aggregation.project("name","age","createDt").and("apple_as.device").as("device");

// 4、按照apple.device数量排序
// 注意：不能使用apple_as.device，并且 device字段必须出现在project里面，否则查询失败
SortOperation sort = Aggregation.sort(Sort.Direction.DESC, "device");

// 5、添加取List中
List<AggregationOperation> operationList = Lists.newArrayList();
operationList.add(addFieldsOperation);
operationList.add(lookupOperation);
operationList.add(project);
operationList.add(sort);
Aggregation agg = Aggregation.newAggregation(operationList);

// 因为返回的是User实体类，所以不会出现device字段，你可以使用Map.class来返回想要的字段
AggregationResults<User> aggregationResults = mongoTemplate.aggregate(agg, "user", User.class);
// 6、返回关联查询结果
List<User> dataList = aggregationResults.getMappedResults();

注意：我们在查询之前要把主表的id转换成String类型，因为被关联表的uid就是String类型，否则查询失败

以apple表做主表查询

// 1、添加uid字段类型转换
AddFieldsOperation addFieldsOperation = AddFieldsOperation.addField("uid").withValue(ConvertOperators.ToObjectId.toObjectId("$uid")).build();

// 2、按参数顺序：被关联表user，主表apple.uid，被关联表user.id，别名
LookupOperation lookupOperation = Aggregation.lookup("user", "uid", "_id", "user_as");

// 3、查询哪些字段，类似sql里面的 select 选择器
// 注意：因为user是被关联表，所以要使用user_as别名的方式来获取用户信息字段
ProjectionOperation project = Aggregation.project("user_as.name","user_as.age","user_as.createDt","device");

// 4、按照apple.device数量排序
SortOperation sort = Aggregation.sort(Sort.Direction.DESC, "device");

// 5、添加取List中
List<AggregationOperation> operationList = Lists.newArrayList();
operationList.add(addFieldsOperation);
operationList.add(lookupOperation);
operationList.add(project);
operationList.add(sort);
Aggregation agg = Aggregation.newAggregation(operationList);

// 因为返回的是User实体类，所以不会出现device字段，你可以使用Map.class来返回想要的字段
AggregationResults<User> aggregationResults = mongoTemplate.aggregate(agg, "apple", User.class);
// 6、返回关联查询结果
List<User> dataList = aggregationResults.getMappedResults();

注意：我们在查询之前要把主表的uid转换ObjectId类型，因为被关联表的_id就是ObjectId类型，否则查询失败

总结

1、mongodb关联查询一定要注意ObjectId类型和String类型之间的转换，否则不成功
2、project中出现的字段会影响 sort排序
3、operationList的添加前后顺序也会影响查询
4、如果查询失败要多试几遍，到底是哪一步出现的影响，我也是不断的试错才总结出来的。
5、如果有条件的话可以加如下代码：

AggregationOperation match = Aggregation.match(Criteria.where("uid").is(uid));
LimitOperation limit = Aggregation.limit(10);

operationList.add(match);
operationList.add(limit);

引用

MongoTemplate聚合（一）$lookup

Mongo学习笔记（三） 通过Aggregation和lookup进行多级关联查询

Springboot整合MongoDB系列(五)---LookupOperation关联查询

mongoTemplate关联查询

Spring Data MongoDB: Projections and Aggregations

Java使用MongoTemplate操作MangoDB，实现根据时间等条件组合查询，解决ISODate的问题

Tags 标签

mongodb3.xmongodb

扩展阅读