常用的MongoDB查询语句的示例代码_MongoDB

来源:脚本之家  责任编辑:小易  
目录
背景方法查询示例示例一示例二示例三示例四尾言

背景

最近做了几个规则逻辑。用到mongo查询比较多,就是查询交易信息跑既定规则筛选出交易商户,使用聚合管道进行统计和取出简单处理后的数据,用SQL代替业务代码逻辑的判断。

方法

MongoDB聚合使用aggregate,聚合管道采取自动向下子执行方式,基本语法格式:

db.COLLECTION_NAME.aggregate(AGGREGATE_OPERATION)

聚合框架中常用的操作:

$project:修改输入文档的结构。可以用来重命名、增加或删除域,也可以用于创建计算结果以及嵌套文档。 match:用于过滤数据,只输出符合条件的文档。match:用于过滤数据,只输出符合条件的文档。match使用MongoDB的标准查询操作。 $limit:用来限制MongoDB聚合管道返回的文档数。 $skip:在聚合管道中跳过指定数量的文档,并返回余下的文档。 $unwind:将文档中的某一个数组类型字段拆分成多条,每条包含数组中的一个值。 $group:将集合中的文档分组,可用于统计结果。 $sort:将输入文档排序后输出。 $geoNear:输出接近某一地理位置的有序文档。

表达式 描述 实例
$sum 计算总和。 db.mycol.aggregate([{\(group : {_id : "\)by_user", num_tutorial : {likes"}}}])
$avg 计算平均值 db.mycol.aggregate([{\(group : {_id : "\)by_user", num_tutorial : {likes"}}}])
$min 获取集合中所有文档对应值得最小值。 db.mycol.aggregate([{\(group : {_id : "\)by_user", num_tutorial : {likes"}}}])
$max 获取集合中所有文档对应值得最大值。 db.mycol.aggregate([{\(group : {_id : "\)by_user", num_tutorial : {likes"}}}])
$push 在结果文档中插入值到一个数组中。 db.mycol.aggregate([{\(group : {_id : "\)by_user", url : {url"}}}])
$addToSet 在结果文档中插入值到一个数组中,但不创建副本。 db.mycol.aggregate([{\(group : {_id : "\)by_user", url : {url"}}}])
$first 根据资源文档的排序获取第一个文档数据。 db.mycol.aggregate([{\(group : {_id : "\)by_user", first_url : {url"}}}])
$last 根据资源文档的排序获取最后一个文档数据 db.mycol.aggregate([{\(group : {_id : "\)by_user", last_url : {url"}}}])

查询示例

示例一

部分字段说明:transAmt:交易金额,transType:交易类型,transTime:交易时间,mercNum:商户编号

查询交易信息,交易商户昨天交易笔数大于三百,交易金额累加大于三百万,这里现根据$match将交易信息筛选出来,然后使用$group根据商户编号分组,统计交易笔数和累加交易金额,将分组结果判断匹配交易笔数大于三百,交易金额大于三百万。

db.getCollection('box_order').aggregate([
  {
    $match: {
                "transTime":{$gte:ISODate("2020-01-03T00:00:00.000Z"),$lt:ISODate("2020-01-10T00:00:00.000Z")},
                "transType":"consume",
                "transStatus":{$in:["tsProcessing","success"]}
               }
  },
  {
    $group: {
                  "_id": "$mercNum",
                  "count": {"$sum": 1},
                  "totalAmt": {"$sum": "$transAmt"}
             }
  },
  {
    $match: {
                  "count": {"$gte": 300},
                  "totalAmt": {"$gte": 3000000}
                }
  }
])

示例二

部分字段说明:cardNo:交易卡号,transType:交易类型,transTime:交易时间,mercNum:商户编号

查询时间段内指定卡号下的交易商户信息。

根据卡号和交易时间将交易数据查出来,然后只显示商户号和卡号两列字段,根据商户号和卡号分组去重,再根据卡号分组,将商户号转化成一个字段变成数组。

db.getCollection('order_202011').aggregate([
  {
    "$match": {
      "detailInfo.cardNo": {
        "$in": [
          "YtCZ7KhCVG5xerKUg8bzJhVAjW/hWAWj",
          "cQ7QQ0yCVW6LhHtJNVRq2A==",
          "6KDpHmQ9s+0SQAGAUyLJ4A==",
          "cQ7QQ0yCVW7iSegn8uqIfg==",
          "ZEOcXdI4rfvswAz7dQ80hw==",
          "6KDpHmQ9s+2Nz61PPuOamw=="
        ]
      },
      "baseInfo.transTime": {
        "$gte": new Date(2020,10,01),
        "$lt": new Date(2020,10,24)
      }
    }
  },
  {
    "$project": {
      "merchantInfo.mercNum": 1,
      "detailInfo.cardNo": 1
    }
  },
  {
    "$group": {
      "_id": {
        "mercNum": "$merchantInfo.mercNum",
        "cardNo": "$detailInfo.cardNo"
      }
    }
  },
  {
    "$group": {
      "_id": "$_id.cardNo",
      "mercNums": {
        "$push": "$_id.mercNum"
      }
    }
  }
])

示例三

根据指定商户和其他条件查询交易信息,根据卡号分组并组装成一个字段的集合,最后筛选掉id只保留cardNos数组

db.getCollection('box_order_fxq_202104').aggregate([
    {
        "$match": {
            "mercNum": "M15201812030753174730",
			"transTime": {
				"$gte": ISODate("2021-04-17T16:00:00.000Z"),
				"$lt": ISODate("2021-04-18T16:00:00.000Z")
			},
            "mercLevel": {
                "$in": [
                    "C",
                    "D",
                    "E"
                ]
            },
            "payType": "POSPAY",
            "transType": "consume",
            "cardType": "2"
        }
    },
    {
        "$group": {
            "_id": null,
            "cardNos": {
                "$push": "$cardNo"  //$addToSet
            }
        }
    },
    {
        "$project":{
            "cardNos":1,"_id":0
        }
    }
])

查询结果:

{
    "cardNos" : [
        "n2IwHHhfEAJcm6RFsoNPcBVAjW/hWAWj",
        "n2IwHHhfEAJcm6RFsoNPcBVAjW/hWAWj"
    ]
}

示例四

根据时间查询交易信息后,根据商户号分组,并将第一个交易信息存放入data字段中。(如果是需要全部的商户交易信息那么将$first修改为$push

db.getCollection('order').aggregate([
    {
        "$match": {
            "startTrxTime": {
                "$gte": ISODate("2021-07-20T16:00:00.000Z"),
                "$lt": ISODate("2021-07-21T16:00:00.000Z")
            }
        }
    },
    {
        "$group": {
            "_id": "$subMerchantNo",
            'data':{'$first': '$$ROOT'}  //$push
        }
    },
    {
        "$sort": {
            "_id": 1
        }
    }
])

尾言

最近那个到查询的大差不差,要注意的都是一些小改动,一般情况正常查就可以。后续有什么不一样的会继续补充。先到这里

到此这篇关于整理最近用的MongoDB查询语句的文章就介绍到这了,更多相关Mongo查询语句内容请搜索真格学网以前的文章或继续浏览下面的相关文章希望大家以后多多支持真格学网!

您可能感兴趣的文章:springboot实现将自定义日志格式存储到mongodb中mongodb中oplog介绍和格式详析SpringBoot整合之SpringBoot整合MongoDB的详细步骤MongoDB安装使用并实现Python操作数据库浅析MongoDB之安全认证SpringBoot整合MongoDB的实现步骤详解MongoDB的条件查询和排序mongodb的安装和开机自启动详细讲解

  • 本文相关:
  • 利用golang驱动操作mongodb数据库的步骤
  • 浅析mongodb 全文检索
  • mongodb使用自带的命令行工具进行备份和恢复的教程
  • mongodb快速入门笔记(七)mongodb的用户管理操作
  • mongodb的分片集群基本配置教程
  • windows下mongodb简单配置教程
  • mongo管理用户相关操作总结
  • ubuntu16.04手动安装mongodb的详细教程
  • mongodb 数据库操作详解--创建,切换,删除
  • mongodb系列教程(五):mongo语法和mysql语法对比学习
  • MongoDB查询语句中db.coll.find({name:"test1"})和db.coll.fi...
  • kettle中mongodb查询语句怎么写
  • mongodb 时间范围查询语句怎么写
  • 如何提高mongodb查询速度
  • mongodb语句可以写成批处理吗
  • java直接操作mongodb语句
  • mongoDB查询排序问题
  • mongodb怎么查询数组中的值
  • java中,mongodb怎么按条件查询
  • python操作mongodb根据_id查询数据的实现方法
  • MongoDB的统计查询和条件统计查询问题请教
  • 网站首页网页制作脚本下载服务器操作系统网站运营平面设计媒体动画电脑基础硬件教程网络安全mssqlmysqlmariadboracledb2mssql2008mssql2005sqlitepostgresqlmongodbredisaccess数据库文摘数据库其它首页mongodbspringboot实现将自定义日志格式存储到mongodb中mongodb中oplog介绍和格式详析springboot整合之springboot整合mongodb的详细步骤mongodb安装使用并实现python操作数据库浅析mongodb之安全认证springboot整合mongodb的实现步骤详解mongodb的条件查询和排序mongodb的安装和开机自启动详细讲解利用golang驱动操作mongodb数据库的步骤浅析mongodb 全文检索mongodb使用自带的命令行工具进行备份和恢复的教程mongodb快速入门笔记(七)mongodb的用户管理操作mongodb的分片集群基本配置教程windows下mongodb简单配置教程mongo管理用户相关操作总结ubuntu16.04手动安装mongodb的详细教程mongodb 数据库操作详解--创建,切换,删除mongodb系列教程(五):mongo语法和mysql语法对比学习mongodb常用操作命令大全mongodb各种查询操作详解mongodb数据库插入、更新和删除操mongodb 数据库操作--备份 还原 浅谈mysql和mariadb区别(mariadbmongodb中使用distinct去重的简单mongodb插入数据的3种方法mongodb整库备份与还原以及单个cmongodb常见错误与解决方法小结(mongodb查询操作限制返回字段的方mongodb增量/全量备份脚本的实现详解mongodb数据库的特色和优点介绍mongodb副本集和分片示例详解php库 查询mongodb中的文档id的方法cgroup限制mongodb进程内存大小mongodb数据库的日志文件深入分析关于mongodb参数说明与常见错误处理的总结mongodb凭什么跻身数据库排行前五mongo中模糊查询的综合应用windows系统下安装mongodb与robomongo环境
    免责声明 - 关于我们 - 联系我们 - 广告联系 - 友情链接 - 帮助中心 - 频道导航
    Copyright © 2017 www.zgxue.com All Rights Reserved