MongoDB中的加减乘除运算详解

前言

很多同学因为对MongoDB不熟悉,加之应用的不是很多,有时候会认为MongoDB数据库对一些功能不支持,或者认为支持不好。今天我们 演示一下 MongoDB对“加减乘除”的使用。

在MongoDB数据库中“加减乘除”运算,又称为 数学表达式(mathematical expression;或算术表达式),主要用于操作数值。

1.$add操作符(+)

1.1 语法及功能介绍

$add 操作符主要用于将一组数字相加;也可以用于在指定时间上添加一定的时间间隔。时间间隔单位为milliseconds(毫秒)。

$add操作符的语法:

{ $add: [ <expression1>, <expression2>, ... ] }

这个操作符接受一个或多个表达式作为参数,将这些表达式相加。

1.2 案例演示

例如我们有一个sales的集合, 其中有 商品类别 字段、商品价格 字段,商品服务费 字段。

{ "_id" : 1, "item" : "abc", "price" : 10, "fee" : 2, date: ISODate("2014-03-01T08:00:00Z") }
{ "_id" : 2, "item" : "jkl", "price" : 20, "fee" : 1, date: ISODate("2014-03-01T09:00:00Z") }
{ "_id" : 3, "item" : "xyz", "price" : 5, "fee" : 0, date: ISODate("2014-03-15T09:00:00Z") }

如果有个需求,要统计 商品 的 总费用(price + fee),那么其统计SQL 如下:

db.sales.aggregate(
 [
 { $project: { item: 1, total: { $add: [ "$price", "$fee" ] } } }
 ]
)

结果显示如下:

{ "_id" : 1, "item" : "abc", "total" : 12 }
{ "_id" : 2, "item" : "jkl", "total" : 21 }
{ "_id" : 3, "item" : "xyz", "total" : 5 }

现在我们来看下在时间上的$add运算,例如,在上面的集合中,我们想看看商品的 有效日期 ,假如商品的有效日期是在现有的date字段数据 + 3天(注意时间参数的单位为毫秒)。

有效日期 命名为 expire_date,则相应的SQL如下:

db.sales.aggregate(
 [
 { $project: { item: 1, expire_date: { $add: [ "$date", 3*24*60*60*1000 ] } } }
 ]
)

结果显示为 :

{ "_id" : 1, "item" : "abc", "expire_date" : ISODate("2014-03-04T08:00:00Z") }
{ "_id" : 2, "item" : "jkl", "expire_date" : ISODate("2014-03-04T09:00:00Z") }
{ "_id" : 3, "item" : "xyz", "expire_date" : ISODate("2014-03-18T09:00:00Z") }

注:此案例中有关时间的这种运算,在SQL Server 数据库中是通过函数 DATEADD()来实现的。

2.$subtract操作符(-)

2.1 语法及功能介绍

$subtract操作符是$add的逆运算,它可以计算两个数值的差值;可以计算 2个日期时间的间隔;还可以在指定日期上减去指定的时间间隔。关于时间的计算,参数的单位都是milliseconds(毫秒)。

$subtract操作符的语法

{ $subtract: [ <expression1>, <expression2> ] }

接受两个表达式作为参数,用第一个表达式减去第二个表达式作为结果。

2.2 案例演示

将案例1的集合 sales清空,插入以下数据

{ "_id" : 1, "item" : "abc", "price" : 10, "fee" : 2, "discount" : 5, "date" : ISODate("2014-03-01T08:00:00Z") }
{ "_id" : 2, "item" : "jkl", "price" : 20, "fee" : 1, "discount" : 2, "date" : ISODate("2014-03-01T09:00:00Z") }

新的数据,添加了 商品打折 的字段 。如果此时统计商品的总费用,则需要 商品价格字段 + 服务费用字段 - 打折字段

SQL 语句如下

db.sales.aggregate( [ { $project: { item: 1, total: { $subtract: [ { $add: [ "$price", "$fee" ] }, "$discount" ] } } } ] )

统计结果显示如下

{ "_id" : 1, "item" : "abc", "total" : 7 }
{ "_id" : 2, "item" : "jkl", "total" : 19 }

关于时间的减法运算有2个场景

场景1 :计算两个日期的时间间隔(统计单位为毫秒)

例如,我们计算sales中商品已生成存在的时间(现在的时间-集合中date字段)

db.sales.aggregate( [ { $project: { item: 1, dateDifference: { $subtract: [ new Date(), "$date" ] } } } ] )

结果显示为

{ "_id" : 1, "item" : "abc", "dateDifference" : NumberLong("154747094624") }
{ "_id" : 2, "item" : "jkl", "dateDifference" : NumberLong("154743494624") }

注:此案例中关于时间的这种运算,在SQL Server 数据库中是通过函数 DATEDiff()来实现的。

场景2:指定日期上减去一定的时间间隔

假如sales集合中的商品一般是规定提前3个小时package的(date字段 --3个小时),那么我们来计算出 这个package_date

实现SQL的语句如下

db.sales.aggregate( [ { $project: { item: 1, dateDifference: { $subtract: [ "$date", 3 * 60 * 60 * 1000 ] } } } ] )

结果显示如下

{ "_id" : 1, "item" : "abc", "dateDifference" : ISODate("2014-03-01T05:00:00Z") }
{ "_id" : 2, "item" : "jkl", "dateDifference" : ISODate("2014-03-01T06:00:00Z") }

注:此案例中关于时间的这种运算,在SQL Server数据库中是通过函数 DATEADD()来实现的。

3.$multiply操作符(*)

3.1 语法及功能介绍

$multiply操作符主要用来一组数值相乘。

$multiplyt操作符的语法

{ $multiply: [ <expression1>, <expression2>, ... ] }

接受一个或多个表达式,并将它们相乘。

3.2 案例演示

将案例2的集合 sales清空,插入以下数据

{ "_id" : 1, "item" : "abc", "price" : 10, "quantity": 2, date: ISODate("2014-03-01T08:00:00Z") }
{ "_id" : 2, "item" : "jkl", "price" : 20, "quantity": 1, date: ISODate("2014-03-01T09:00:00Z") }
{ "_id" : 3, "item" : "xyz", "price" : 5, "quantity": 10, date: ISODate("2014-03-15T09:00:00Z") }

在这个商品销售集合中,有商品的价格字段,还有商品数量字段,我们需要统计出,每个商品的总额(商品价格*商品数据量)

统计的SQL语句:

 db.sales.aggregate(
 [
 { $project: { item: 1, total_price: { $multiply: [ "$price", "$quantity" ] } } }
 ]
)

结果显示如下:

{ "_id" : 1, "item" : "abc", "total_price" : 20 }
{ "_id" : 2, "item" : "jkl", "total_price" : 20 }
{ "_id" : 3, "item" : "xyz", "total_price" : 50 }

4.$divide操作符(/)

4.1 语法及功能介绍

$divide操作符主要用来2个数字相除。

$divide操作符的语法为:

{ $divide: [ <expression1>, <expression2> ] }

接受两个表达式,将第一个表达式除以第二个表达式的商作为结果。

4.2 案例演示

例如我们有一个关于项目计划的集合planning , 在这个集合中 有关于耗时的字段 hours,数据格式如下。

{ "_id" : 1, "name" : "A", "hours" : 80, "resources" : 7 },
{ "_id" : 2, "name" : "B", "hours" : 40, "resources" : 4 }

上面的数据是安照工时统计的,如果我们安照工作日统计(工时/8),其SQL语句如下:

db.planning.aggregate(
 [
 { $project: { name: 1, workdays: { $divide: [ "$hours", 8 ] } } }
 ]
)

结果显示如下:

{ "_id" : 1, "name" : "A", "workdays" : 10 }
{ "_id" : 2, "name" : "B", "workdays" : 5 }

5 求余 运算($mod)

讲到除法运算,自然就会想到求余的运算(%),下面我们简单介绍以下求余运算符$mod。

5.1 语法及功能介绍

语法:

{ $mod: [ <expression1>, <expression2> ] }

接受两个表达式,将第一个表达式除以第二个表达式得到的余数作为结果。

5.2 案例演示

还是上面的关于任务计划的集合,上面有工时字段,还有任务字段,数据格式如下:

{ "_id" : 1, "project" : "A", "hours" : 80, "tasks" : 7 }
{ "_id" : 2, "project" : "B", "hours" : 40, "tasks" : 4 }

我们统计每个任务平均后,剩余的时间,SQL语句如下:

db.planning.aggregate(
 [
 { $project: { remainder: { $mod: [ "$hours", "$tasks" ] } } }
 ]
)

结果显示如下:

{ "_id" : 1, "remainder" : 3 }
{ "_id" : 2, "remainder" : 0 }

6.案例分析

在文章的最后一节,我们用一个例子,巩固一下上面的学习,同时引入另外一个知识点----逻辑表达式。

6.1 案例探究

假如有个大学教授想通过某种比较复杂的计算为他的学生打分:出勤率占10%,日常测验成绩占30%,期末考试成绩占60%,但如果是老师宠爱的学生,那么分数就是100.

关于学生students集合的数据格式如下

{ "_id" : 1, "sno" : 201501010001, "name" : "xiaoming", "attendanceAvg" : 90, "quizzAvg" : 95, "testAvg" : 98, "teacherPet" : true }
{ "_id" : 2, "sno" : 201501010002, "name" : "xiaoli", "attendanceAvg" : 100, "quizzAvg" : 90, "testAvg" : 90, "teacherPet" : false }
{ "_id" : 3, "sno" : 201501010003, "name" : "xiaohong", "attendanceAvg" : 100, "quizzAvg" : 80, "testAvg" : 100, "teacherPet" : false }

满足此教授老师需求的查询SQL语句如下:

db.students.aggregate(
 [
 {
  $project:
  {

   "sno": 1, "name": 1,
   grade:
   {
    $cond: ["$teacherPet", 100, {
    "$add":
     [
     { "$multiply": ["$attendanceAvg", .1] },
     { "$multiply": ["$quizzAvg", .3] },
     { "$multiply": ["$testAvg", .6] }
     ]
    }]
   }
  }
 }
 ]
)

查询的结果如下

{ "_id" : 1, "sno" : 201501010001, "name" : "xiaoming", "grade" : 100 }
{ "_id" : 2, "sno" : 201501010002, "name" : "xiaoli", "grade" : 91 }
{ "_id" : 3, "sno" : 201501010003, "name" : "xiaohong", "grade" : 94 }

在本例中我们不仅用到了数学表达式$add,$$multiply,还用到了逻辑表达式$cond(if 老师宠爱的学生 就100,否则 计算分数...)。下面,我们粗略讲解一下关于 MongoDB的逻辑表达式。

6.2 常用逻辑表达式

类别 操作符 语法 功能用途
布尔表达式 $and {$and: [ <expression1>, <expression2>, ... ]} 如果所有表达式的值为true,那就返回true,否则返回false。
$or {$or: [ <expression1>, <expression2>, ... ]} 只要有任意表达式的值为true,那就返回true,否则返回false。
$not { $not: [ <expression> ] } 对expression取反。
控制表达式 $cond { $cond: { if: <boolean-expression>, then: <true-case>, else: <false-case-> } }
或者
{ $cond: [ <boolean-expression>, <true-case>, <false-case> ] }
 如果boolean-expression为的值是true,那就返回true-case,否则返回false-case。
 $ifNull  { $ifNull: [ <expression>,<replacement-expression-if-null> ] }  如果expression是null,那就返回replacement-expression-if-null,否则返回expression。
比较表达式  $cmp  { $cmp: [ <expression1>,<expression2> ] }  比较expression1和expression2,如果相等,返回0;如果前者大于后者,返回一个正数1;如果前者小于后者。返回一个负数-1。
 $strcasecmp  { $strcasecmp: [<expression1>,<expression2> ] }  $cmp的细化。用来比较expression1和expression2;区分大小写,主要针对ASCII characters。如果相等,返回0;如果前者大于后者,返回一个正数1;如果前者小于后者。返回一个负数-1。
 $eq/$ne/$gt/$gte/$lt/$lte  $eq/$ne/$gt/$gte/$lt/$lte :[ <expression1>,<expression2> ]  对expression1和expression2执行相应的比较操作,返回比较的结构(true或false)。

通过这些操作符,就可以在聚合中使用更复杂的逻辑。

总结

以上就是这篇文章的全部内容了,希望本文的内容对大家的学习或者工作具有一定的参考学习价值,如果有疑问大家可以留言交流,谢谢大家对我们的支持。

(0)

相关推荐

  • pyspark操作MongoDB的方法步骤

    如何导入数据 数据可能有各种格式,虽然常见的是HDFS,但是因为在Python爬虫中数据库用的比较多的是MongoDB,所以这里会重点说说如何用spark导入MongoDB中的数据. 当然,首先你需要在自己电脑上安装spark环境,简单说下,在这里下载spark,同时需要配置好JAVA,Scala环境. 这里建议使用Jupyter notebook,会比较方便,在环境变量中这样设置 PYSPARK_DRIVER_PYTHON=jupyter PYSPARK_DRIVER_PYTHON_OPTS=

  • 详解Java 连接MongoDB集群的几种方式

    先决条件 先运行mongodb肯定是必须的,然后导入以下包: import com.mongodb.MongoClient; import com.mongodb.MongoClientURI; import com.mongodb.ServerAddress; import com.mongodb.MongoCredential; import com.mongodb.MongoClientOptions; MongoClient MongoClient()实例表示到数据库的连接池; 你将只需

  • Docker容器化部署尝试——多容器通信(node+mongoDB+nginx)

    原因是这样的 想要部署一个mocker平台,就在朋友的推荐下选择了 api-mocker 这个现成的项目 该项目分为服务端node.客户端vue.以及数据库mongoDB 在尝试直接部署的时候发现需要装一大堆的环境,node.mongo.nginx啊,特别的麻烦,之前简单的使用过docker,就在想能不能用docker免环境直接部署呢?于是就有了这次的尝试 多容器通信 该项目分为3个部分,于是就要建立3个容器(node.mongo.nginx) 那容器之间怎么实现通信呢? # 通过link指令建

  • Python使用pymongo库操作MongoDB数据库的方法实例

    python操作mongodb数据库 # !/usr/bin/env python # -*- coding:utf-8 -*- """ 使用pymongo库操作MongoDB数据库 """ import pymongo # 1.连接数据库服务器,获取客户端对象 mongo_client=pymongo.MongoClient('localhost',27017) # 2.获取数据库对象 db=mongo_client.myDB # db=mon

  • MongoDB聚合分组取第一条记录的案例与实现方法

    前言 今天开发同学向我们提了一个紧急的需求,从集合mt_resources_access_log中,根据字段refererDomain分组,取分组中最近一笔插入的数据,然后将这些符合条件的数据导入到集合mt_resources_access_log_new中. 接到这个需求,还是有些心虚的,原因有二,一是,业务需要,时间紧:二是,实现这个功能MongoDB聚合感觉有些复杂,聚合要走好多步. 数据记录格式如下: 记录1 { "_id" : ObjectId("5c1e23eaa

  • Python操作mongodb数据库的方法详解

    本文实例讲述了Python操作mongodb数据库的方法.分享给大家供大家参考,具体如下: 安装pymongo 下载pymongo: https://pypi.python.org/packages/82/26/f45f95841de5164c48e2e03aff7f0702e22cef2336238d212d8f93e91ea8/pymongo-3.4.0.tar.gz#md5=aa77f88e51e281c9f328cea701bb6f3e 安装pymongo: 解压后,cmd进入pymon

  • windows与mac安装mongodb数据库的方法步骤与注意事项

    nosql数据库 --mongodb数据库! Mongo DB 是目前在IT行业非常流行的一种非关系型数据库(NoSql),其灵活的数据存储方式备受当前IT从业人员的青睐.Mongo DB很好的实现了面向对象的思想(OO思想),在Mongo DB中每一条记录都是一个Document对象.Mongo DB最大的优势在于所有的数据持久操作都无需开发人员手动编写SQL语句,直接调用方法就可以轻松的实现CRUD操作. windows 安装 这里我说的是命令行安装方法 准备.到官网下载相应的版本 http

  • c#操作mongodb插入数据效率

    mongodb的数据插入速度是其一个亮点,同样的10000条数据,插入的速度要比Mysql和sqlserver都要快,当然这也是要看使用者怎么个使用法,你代码如果10000次写入使用10000次连接,那也是比不过其他数据库使用事务一次性提交的速度的. 同样,mongo也提供的一次性插入巨量数据的方法,因为mongodb没有事务这回事,所以在在C#驱动里,具体方法是InsertManyAsync()一次性插入多个文档.与之对应的是InsertOneAsync,这个是一次插入一个文档: Insert

  • 在pycharm上mongodb配置及可视化设置方法

    一.mongodb安装 在官网下载适应于自己平台的mongodb,在此安装环境为Windows7-64bit 下载完成后直接安装,连续点击next选项直到,此处注意!!!!! 切勿勾选左下选项,安装过程可能非常漫长,勾选选项为mongodb可视化工具,可另外下载 安装完成后配置过程结合官方工作手册进行设置(https://docs.mongodb.com/manual/tutorial/install-mongodb-on-windows/),mongodb安装完成. 二.配置pycharm 首

  • Java操作MongoDB插入数据进行模糊查询与in查询功能

    由于需要用MongoDB缓存数据,所以自己写了一套公共的存放和读取方法 具体如下: 存放mongodb: /** * 公共方法:设置Object类型缓存 * @author shijing * @param param * @param sysGuid */ public void setObjData(Map<String,Object> param, String sysGuid, String enumBpd){ DBObject dbObject = new BasicDBObject

随机推荐