MongoDB 聚合与特定字段不匹配

如何解决MongoDB 聚合与特定字段不匹配

我是 MongoDB 中的 Aggregation 新手,我试图通过举例来理解它的概念。

我正在尝试使用聚合对我的子文档进行分页,但返回的文档始终是所有文档特定字段的整体值。

我想对包含对象 ID 数组的 following 字段进行分页。

我有这个用户架构:

const UserSchema = new mongoose.Schema({
    username: {
        type: String,unique: true,required: true
    },firstname: String,lastname: String,following: [{
        type: mongoose.Schema.Types.ObjectId,ref: 'User'
    }],...
},{ timestamps: true,toJSON: { virtuals: true },toObject: { getters: true,virtuals: true } });

没有聚合,我可以对following进行分页, 我有这条路线,通过他们的 username

获取用户的帖子
router.get(
    '/v1/:username/following',isAuthenticated,async (req,res,next) => {
        try {
            const { username } = req.params;
            const { offset: off } = req.query;

            let offset = 0;
            if (typeof off !== undefined && !isNaN(off)) offset = parseInt(off);

            const limit = 2;
            const skip = offset * limit;

            const user = await User
                .findOne({ username })
                .populate({
                    path: 'following',select: 'profilePicture username fullname',options: {
                        skip,limit,}
                })

          
            res.status(200).send(user.following);
        } catch (e) {
            console.log(e);
            res.status(500).send(e)
        }
    }
);

我的分页版本使用聚合:

const following = await User.aggregate([
                {
                    $match: { username }
                },{
                    $lookup: {
                        'from': User.collection.name,'let': { 'following': '$following' },'pipeline': [
                            {
                                $project: {
                                    'fullname': 1,'username': 1,'profilePicture': 1
                                }
                            }
                        ],'as': 'following'
                    },},{
                    $project: {
                        '_id': 0,'following': {
                            $slice: ['$following',skip,limit]
                        }
                    }
                }
            ]);

假设我有这个文件:

[
                {
                    _id: '5fdgffdgfdgdsfsdfsf',username: 'gagi',following: []
                },{
                    _id: '5fgjhkljvlkdsjfsldkf',username: 'kuku',{
                    _id: '76jghkdfhasjhfsdkf',username: 'john',following: ['5fdgffdgfdgdsfsdfsf','5fgjhkljvlkdsjfsldkf']
                },]

当我为用户 john: /john/following 测试我的路由时,一切都很好,但是当我测试没有任何以下内容的不同用户时:/gagi/following,返回的结果与john 的以下聚合似乎与用户名不匹配。

/john/following |以下:2

/kuku/following |以下:0

汇总结果:

[
  {
    _id: '5fdgffdgfdgdsfsdfsf',...
  },{
    _id: '5fgjhkljvlkdsjfsldkf',...
  }
]

我希望 /kuku/following 返回一个空数组 [] 但结果与 john 的相同。实际上,我测试的所有用户名都返回相同的结果。

我认为我的实现一定有问题,因为我才刚刚开始探索聚合。

解决方法

Mongoose 使用 DBRef 能够在检索到字段后填充该字段。
DBRefs 只在客户端处理,MongoDB 聚合没有任何操作符来处理这些。

聚合管道返回所有用户的原因是查找的管道没有匹配阶段,因此集合中的所有文档都被选中并包含在查找中。

那里的示例文档显示了一个字符串数组而不是 DBRefs,这不适用于 populate

本质上,您必须决定是使用聚合还是填充来处理连接。

对于填充,请使用示例架构中所示的 ref

对于聚合,存储一个 ObjectId 数组,以便您可以使用查找与 _id 字段链接。

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。

相关推荐


使用本地python环境可以成功执行 import pandas as pd import matplotlib.pyplot as plt # 设置字体 plt.rcParams['font.sans-serif'] = ['SimHei'] # 能正确显示负号 p
错误1:Request method ‘DELETE‘ not supported 错误还原:controller层有一个接口,访问该接口时报错:Request method ‘DELETE‘ not supported 错误原因:没有接收到前端传入的参数,修改为如下 参考 错误2:cannot r
错误1:启动docker镜像时报错:Error response from daemon: driver failed programming external connectivity on endpoint quirky_allen 解决方法:重启docker -> systemctl r
错误1:private field ‘xxx‘ is never assigned 按Altʾnter快捷键,选择第2项 参考:https://blog.csdn.net/shi_hong_fei_hei/article/details/88814070 错误2:启动时报错,不能找到主启动类 #
报错如下,通过源不能下载,最后警告pip需升级版本 Requirement already satisfied: pip in c:\users\ychen\appdata\local\programs\python\python310\lib\site-packages (22.0.4) Coll
错误1:maven打包报错 错误还原:使用maven打包项目时报错如下 [ERROR] Failed to execute goal org.apache.maven.plugins:maven-resources-plugin:3.2.0:resources (default-resources)
错误1:服务调用时报错 服务消费者模块assess通过openFeign调用服务提供者模块hires 如下为服务提供者模块hires的控制层接口 @RestController @RequestMapping("/hires") public class FeignControl
错误1:运行项目后报如下错误 解决方案 报错2:Failed to execute goal org.apache.maven.plugins:maven-compiler-plugin:3.8.1:compile (default-compile) on project sb 解决方案:在pom.
参考 错误原因 过滤器或拦截器在生效时,redisTemplate还没有注入 解决方案:在注入容器时就生效 @Component //项目运行时就注入Spring容器 public class RedisBean { @Resource private RedisTemplate<String
使用vite构建项目报错 C:\Users\ychen\work>npm init @vitejs/app @vitejs/create-app is deprecated, use npm init vite instead C:\Users\ychen\AppData\Local\npm-
参考1 参考2 解决方案 # 点击安装源 协议选择 http:// 路径填写 mirrors.aliyun.com/centos/8.3.2011/BaseOS/x86_64/os URL类型 软件库URL 其他路径 # 版本 7 mirrors.aliyun.com/centos/7/os/x86
报错1 [root@slave1 data_mocker]# kafka-console-consumer.sh --bootstrap-server slave1:9092 --topic topic_db [2023-12-19 18:31:12,770] WARN [Consumer clie
错误1 # 重写数据 hive (edu)> insert overwrite table dwd_trade_cart_add_inc > select data.id, > data.user_id, > data.course_id, > date_format(
错误1 hive (edu)> insert into huanhuan values(1,'haoge'); Query ID = root_20240110071417_fe1517ad-3607-41f4-bdcf-d00b98ac443e Total jobs = 1
报错1:执行到如下就不执行了,没有显示Successfully registered new MBean. [root@slave1 bin]# /usr/local/software/flume-1.9.0/bin/flume-ng agent -n a1 -c /usr/local/softwa
虚拟及没有启动任何服务器查看jps会显示jps,如果没有显示任何东西 [root@slave2 ~]# jps 9647 Jps 解决方案 # 进入/tmp查看 [root@slave1 dfs]# cd /tmp [root@slave1 tmp]# ll 总用量 48 drwxr-xr-x. 2
报错1 hive> show databases; OK Failed with exception java.io.IOException:java.lang.RuntimeException: Error in configuring object Time taken: 0.474 se
报错1 [root@localhost ~]# vim -bash: vim: 未找到命令 安装vim yum -y install vim* # 查看是否安装成功 [root@hadoop01 hadoop]# rpm -qa |grep vim vim-X11-7.4.629-8.el7_9.x
修改hadoop配置 vi /usr/local/software/hadoop-2.9.2/etc/hadoop/yarn-site.xml # 添加如下 <configuration> <property> <name>yarn.nodemanager.res