如何使用$ unwind迭代精确值

如何解决如何使用$ unwind迭代精确值

我是猫鼬和mongodb的新手。

在我的addtocart模式中,我添加了$lookups和投影以填充添加到购物车中的产品。

当前响应 product_purchase_quantity中,它在添加到购物车集合中的数组中,是键和值。因此,在$lookups中,我尝试添加{$unwind: '$product_purchase_quantity'},但是在添加add_to_cart_products之后,对象打印两次。我不知道错误在哪里?

下面我提到了预期的结果。

AddToCart架构:

  lookups: [
      {
        from: 'shop_db_products',let: {
          productId: '$add_to_cart_products.product',purchaseQuantity: '$add_to_cart_products.product_quantity',productItemId: '$add_to_cart_products.product_item',},pipeline: [
          {
            $match: { $expr: { $in: ['$_id','$$productId'] } },{
            $lookup: {
              from: 'shop_db_products',localField: 'product_id',foreignField: '_id',as: 'products',{
            $project: {
              _id: true,product: {
                _id: '$_id',product_name: '$product_name',product_purchase_quantity: '$$purchaseQuantity',product_item: {
                $reduce: {
                  input: {
                    $filter: {
                      input: '$product_items',cond: {
                        $in: ['$$this._id','$$productItemId'],initialValue: {},in: {
                    _id: '$$this._id',product_size: { $concat: [{ $toString: '$$this.product_size.value' },'$$this.product_size.unit'] },product_price: '$$this.product_price',product_type: '$$this.product_type'
                  },],localField: '',as: 'add_to_cart_products',model: 'ProductModel',

AddToCart收藏

[
{
    
      "add_to_cart_user": "5f0076b7bd530928fc0c0285","add_to_cart_products": [
        {
          "product": "5f05a0270b4f3a5c41c70826","product_item": "5f05a0270b4f3a5c41c70877","product_quantity": 5
        },{
          "product": "5f05a0270b4f3a5c41c70827","product_item": "5f05a0270b4f3a5c41c70666","product_quantity": 3
        }
      ],"add_to_cart_product_total": 5,"add_to_cart_discount": 50,"add_to_tax": "5eae321d21924800122f978e","add_to_cart_grand_total": 500
    }
]

当前响应:

{
    "_id": "5fa2a09b3c6316482098f6ff","add_to_cart_status_is_active": true,"add_to_cart_tax": 8,"add_to_cart_products": [
        {
            "product": {
                "_id": "5f05a0270b4f3a5c41c70826","product_name": "Avery Apricot Sour"
            },"product_purchase_quantity": [
                5,3
            ],"product_item": {
                "_id": "5f05a0270b4f3a5c41c70877","product_size": "22oz","product_price": 13.99
            }
        },{
            "product": {
                "_id": "5f05a0270b4f3a5c41c70827","product_name": "Avery Dugana"
            },"product_item": {
                "_id": "5f05a0270b4f3a5c41c70666","product_price": 8.99
            }
        }
    ]
}

预期的响应:

{
    "_id": "5fa2a09b3c6316482098f6ff","add_to_cart_products": [
        {
            "product": {
                 "_id": "5f05a0270b4f3a5c41c70826","product_purchase_quantity": 5,{
            "product": {
                 "_id": "5f05a0270b4f3a5c41c70827","product_purchase_quantity": 3,"product_price": 8.99
            }
        }
    ]
}

产品(shop_db_products)集合:

[
    {
        "_id": "5f05a0270b4f3a5c41c70826","product_no": "PRO04087","product_store_no": "1001","product_dept_no": "Irish Whiskey","product_name": "2Gingers","product_overview": "No Overview","product_items": [
            {
                "_id": "5f05a0270b4f3a5c41c70877","product_item_number": "857566003019","product_price": 20.99,"product_cost": 20.99,"product_size": "750ml","product_type": "Bottle","product_value": 0,"product_quantity": 0,"product_images": [
                    "pro04087-857566003019-1.png"
                ],"product_item_is_active": true
            }
        ]
    },...
]

解决方法

在执行$ lookup之前,您必须先$ add_to_cart_products放开

db.addToCart.aggregate([
  {
    $unwind: "$add_to_cart_products"
  },{
    $lookup: {
      from: "shop_db_products",let: {
        productId: "$add_to_cart_products.product",purchaseQuantity: "$add_to_cart_products.product_quantity",productItemId: "$add_to_cart_products.product_item"
      },pipeline: [
        {
          $match: {
            $expr: {
              $eq: [
                "$_id","$$productId"
              ]
            }
          }
        },{
          $project: {
            _id: true,product: {
              _id: "$_id",product_name: "$product_name",},product_purchase_quantity: "$$purchaseQuantity",product_item: {
              $reduce: {
                input: {
                  $filter: {
                    input: "$product_items",cond: {
                      $eq: [
                        "$$this._id","$$productItemId"
                      ],initialValue: {},in: {
                  _id: "$$this._id",product_size: "$$this.product_size",product_price: "$$this.product_price",product_type: "$$this.product_type"
                }
              }
            }
          }
        }
      ],as: "add_to_cart_products"
    }
  },{
    $unwind: "$add_to_cart_products"
  },{
    $group: {
      _id: "$_id","add_to_cart_products": {
        $push: "$add_to_cart_products"
      }
    }
  }
])

MongoDB Playground

,

另一种方式 没有减速器,带有$ unwind

https://mongoplayground.net/p/3uWA5pVBv83

db.addToCart.aggregate([
  {
    "$unwind": "$add_to_cart_products"
  },{
    "$lookup": {
      "from": "shop_db_products","let": {
        "productId": "$add_to_cart_products.product","purchaseQuantity": "$add_to_cart_products.product_quantity","productItemId": "$add_to_cart_products.product_item"
      },"pipeline": [
        {
          "$match": {
            "$expr": {
              "$eq": [
                "$_id",{
          "$unwind": "$product_items"
        },{
          "$match": {
            "$expr": {
              "$eq": [
                "$product_items._id","$$productItemId"
              ]
            }
          }
        },{
          "$project": {
            "_id": true,"product": {
              "_id": "$_id","product_name": "$product_name"
            },"product_purchase_quantity": "$$purchaseQuantity","product_item": "$product_items"
          }
        }
      ],"as": "productResolved"
    }
  },{
    "$unwind": "$productResolved"
  },{
    "$group": {
      "_id": "$_id","add_to_cart_products": {
        "$push": "$productResolved"
      }
    }
  }
])

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