MongoDB-上一个和下一个内部子文档

如何解决MongoDB-上一个和下一个内部子文档

我正在尝试使用聚合框架从我的集合中获取3个子文档(我只想使用聚合,因为这是长管道的一部分)。 我只知道一个子文档的一个属性。我还需要检索该subdoc以及上一个和下一个。 示例:

[
  {
    "title": "Title 34","subDoc": {
      "subtitle": "subtitle 8","order": 8
    }
  },{
    "title": "Title 34","subDoc": {
      "subtitle": "subtitle 6","order": 6
    }
  },"subDoc": {
      "subtitle": "subtitle 11","order": 11
    }
  },"subDoc": {
      "subtitle": "subtitle 13","order": 13
    }
  },"subDoc": {
      "subtitle": "subtitle 7","order": 7
    }
  }
]

我只知道一个字幕顺序(例如,“ 11”),我需要获取以下内容:

[
  {
    "title": "Title 34","subDoc": [
      {
        "subtitle": "subtitle 8","order": 8
      },{
        "subtitle": "subtitle 11","order": 11
      },{
        "subtitle": "subtitle 13","order": 13
      }
    ]
  }
]

我尝试了展开,排序,限制,但是我只能获取上一个或下一个文档,而不能同时获取两个文档。

这里的游乐场: https://mongoplayground.net/p/0228GD-b6oZ

解决方法

您可以通过以下步骤实现用例:

  1. subDoc.order
  2. 进行$ sort
  3. 将所有文档分组到一个数组中
  4. 查找先前和当前数组元素的索引
  5. $ group基于title,并使用$ addToSet附加必需的文档
  6. $ project阶段将数据转换为预期的输出

基于示例文档要考虑的边际案例:

  1. 没有先前的文件 例如:subDoc.order=6,返回文档[6,7]
  2. 没有当前文档 例如:subDoc.order= 14,返回空
  3. 没有下一个文档 例如:subDoc.order= 13,返回文档[11,13]
  4. document count=1时,当前文档存在,但没有上一个或下一个文档

您可以使用以下聚合查询:

db.collection.aggregate([
  {
    "$sort": {
      "subDoc.order": 1
    }
  },{
    $project: {
      "title": 1,"order": "$subDoc.order","subtitle": "$subDoc.subtitle"
    }
  },{
    $group: {
      _id: null,data: {
        $push: "$$ROOT"
      },count: {
        "$sum": 1
      }
    }
  },{
    $addFields: {
      "previousDoc": {
        $subtract: [
          {
            $indexOfArray: [
              "$data.order",11
            ]
          },1
        ]
      },"nextDoc": {
        $add: [
          {
            $indexOfArray: [
              "$data.order",currentDoc: {
        $indexOfArray: [
          "$data.order",11
        ]
      }
    }
  },{
    "$addFields": {
      "next": {
        $arrayElemAt: [
          "$data","$nextDoc"
        ]
      },previous: {
        $arrayElemAt: [
          "$data","$previousDoc"
        ]
      },current: {
        $arrayElemAt: [
          "$data","$currentDoc"
        ]
      }
    }
  },{
    $unwind: "$data"
  },{
    $group: {
      _id: "$data.title",p: {
        "$addToSet": {
          $cond: [
            {
              $and: [
                {
                  $lt: [
                    "$currentDoc",1
                  ]
                },]
            },"$$REMOVE","$previous"
          ]
        }
      },c: {
        "$addToSet": {
          $cond: [
            {
              $and: [
                {
                  $lt: [
                    "$currentDoc",0
                  ]
                },{
                  $ne: [
                    "$count",1
                  ]
                }
              ]
            },"$current"
          ]
        }
      },n: {
        "$addToSet": {
          $cond: [
            {
              $lt: [
                "$nextDoc",1
              ]
            },"$next"
          ]
        }
      },}
  },{
    $project: {
      subDoc: {
        "$concatArrays": [
          "$p","$c","$n"
        ]
      }
    }
  },{
    $project: {
      "subDoc.subtitle": 1,"subDoc.order": 1
    }
  }
])

MongoDB Playground

,

您可以尝试

  • $sortorder升序
  • $grouptitle,并制作subDoc对象数组和subDocOrder订单字段数组
  • $addFields添加三个字段,prevOrder前一个订单号($indeOfArray获得前一个索引11并减去1)和nextOrder下一个订单号({{1} }以获得下一个索引11并加2),$indeOfArray大小为sizeSubDoc数组
subDoc
  • let order = 11; db.collection.aggregate([ { $sort: { "subDoc.order": 1 } },{ $group: { _id: "$title",subDoc: { $push: "$subDoc" },subDocOrder: { $push: "$subDoc.order" } } },{ $addFields: { prevOrder: { $subtract: [{ $indexOfArray: ["$subDocOrder",order] },1] },nextOrder: { $add: [{ $indexOfArray: ["$subDocOrder",2] },sizeSubDoc: { $size: "$subDoc" } } },以显示必填字段,并获取$project数组
  • subDoc从2个条件中获取范围,首先检查$range小于0,然后返回0,否则返回prevOrder,第二个检查preOrder大于{的大小{1}}数组,然后返回大小,否则返回nextOrder,最后我们得到范围的开始号和结束号
  • subDoc迭代我们要在地图中输入的上述创建的范围数组的循环,然后检入将返回nextOrder形式的范围数组
$map

Playground


涵盖的测试用例:

  1. 如果当前元素是第一个元素,意味着没有上一个元素怎么办? (这将仅返回当前元素和下一个元素)
  2. 如果当前元素是最后一个元素,意味着没有下一个元素怎么办? (这将仅返回当前和先前的元素)
  3. 如果$arrayElemAt仅具有一个当前元素怎么办? (这将仅返回单个当前元素)
  4. 找不到您输入的11是什么? (这将返回空白数组)
,

我认为这是解决方案,如果您确实想通过聚合来实现,但是结构已修改,则可以在方便时进行映射

db.collection.aggregate([
  {
    "$sort": {
      "subDoc.order": 1
    }
  },{
    "$group": {
      "_id": "$title","next": {
        "$push": {
          "$cond": [
            {
              "$gt": [
                "$subDoc.order",11
              ]
            },{
              "id": "$_id","item": "$$CURRENT.subDoc"
            },"$$REMOVE"
          ]
        }
      },"prev": {
        "$push": {
          "$cond": [
            {
              "$lt": [
                "$subDoc.order","current": {
        "$push": {
          "$cond": [
            {
              "$eq": [
                "$subDoc.order","$$REMOVE"
          ]
        }
      }
    }
  },{
    $project: {
      _id: 1,next: {
        $slice: [
          "$next",prev: {
        $slice: [
          "$prev",-1
        ]
      },current: 1
    }
  }
])

输出看起来像这样

[
  {
    "_id": "Title 34","current": [
      {
        "id": "33","item": {
          "order": 11,"subtitle": "subtitle 11"
        }
      }
    ],"next": [
      {
        "id": "15","item": {
          "order": 12,"subtitle": "subtitle 12"
        }
      }
    ],"prev": [
      {
        "id": "34","item": {
          "order": 8,"subtitle": "subtitle 8"
        }
      }
    ]
  }
]

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 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