`
clearity
  • 浏览: 36920 次
  • 性别: Icon_minigender_1
  • 来自: 北京
社区版块
存档分类
最新评论

MongoDB:聚集和分组例子

 
阅读更多



 

在本文章中,会演示MongoDB使用聚集函数对文档进行分组的用法。

1.测试数据

网站主机域名列表的JSON格式文件

 

 

website.json
{ "_id" : 1, "domainName" : "test1.com", "hosting" : "hostgator.com" }
{ "_id" : 2, "domainName" : "test2.com", "hosting" : "aws.amazon.com"}
{ "_id" : 3, "domainName" : "test3.com", "hosting" : "aws.amazon.com" }
{ "_id" : 4, "domainName" : "test4.com", "hosting" : "hostgator.com" }
{ "_id" : 5, "domainName" : "test5.com", "hosting" : "aws.amazon.com" }
{ "_id" : 6, "domainName" : "test6.com", "hosting" : "cloud.google.com" }
{ "_id" : 7, "domainName" : "test7.com", "hosting" : "aws.amazon.com" }
{ "_id" : 8, "domainName" : "test8.com", "hosting" : "hostgator.com" }
{ "_id" : 9, "domainName" : "test9.com", "hosting" : "cloud.google.com" }
{ "_id" : 10, "domainName" : "test10.com", "hosting" : "godaddy.com" }

 

 

导入website文档

 

 

> mongoimport -d testdb -c website --file website.json
connected to: 127.0.0.1
Mon Jan 13 14:30:22.662 imported 10 objects

 

 

 

注意
如果是已存在的文档, 加 --upsert 选项来覆盖数据.
> mongoimport -d testdb -c website --file website.json --upsert

 

 

2.分组例子

使用db.collection.aggregate和$group函数进行文档分组

  2.1 下面的例子通过“hosting”字段分组并显示每个主机总数

  

> db.website.aggregate(
    { 
	$group : {_id : "$hosting", total : { $sum : 1 }}
    }
  );

  结果

 

  

  

{
        "result" : [
                {
                        "_id" : "godaddy.com",
                        "total" : 1
                },
                {
                        "_id" : "cloud.google.com",
                        "total" : 2
                },
                {
                        "_id" : "aws.amazon.com",
                        "total" : 4
                },
                {
                        "_id" : "hostgator.com",
                        "total" : 3
                }
        ],
        "ok" : 1
}

 

 

用SQL可以表示为:

  

SELECT hosting, SUM(hosting) AS total
       FROM website
       GROUP BY hosting

 

 2.2 使用$sort函数进行排序

  

>  db.website.aggregate(
     { 
	$group : {_id : "$hosting", total : { $sum : 1 }}
     },
     {
	$sort : {total : -1}
     }
  );

 

  结果 -- “total“的降序显示,升序显示的话用$sort : {total : 1}实现

 

{
        "result" : [
                {
                        "_id" : "aws.amazon.com",
                        "total" : 4
                },
                {
                        "_id" : "hostgator.com",
                        "total" : 3
                },
                {
                        "_id" : "cloud.google.com",
                        "total" : 2
                },
                {
                        "_id" : "godaddy.com",
                        "total" : 1
                }
        ],
        "ok" : 1
}

 

  2.3 使用$match函数来对匹配”aws.amazon.com“的数据根据”hosting“分组

  

> db.website.aggregate(
    { 
	$match : {hosting : "aws.amazon.com"}
    },
    { 
	$group : { _id : "$hosting", total : { $sum : 1 } }
    }
  );

 

  输出:

  

{
        "result" : [
                {
                        "_id" : "aws.amazon.com",
                        "total" : 4
                }
        ],
        "ok" : 1
}

 

 详细例子请参照官方手册 MongoDB Aggregation guide 

 

3.把分组数据导出成CSV或者JSON格式文件

通过函数mongoexport来实现

  3.1 将分组的结果保存到变量中,本例变量为”groupdata

  

> var groupdata = db.website.aggregate(
    { 
	$group : {_id : "$hosting", total : { $sum : 1 }}
    },
    {
	$sort : {total : -1}
    }
  );

 

  3.2 将”groupdata.result“插入到新集合中

  

> db.websitegroup.insert(groupdata.result);
 
> db.websitegroup.find().pretty()
{ "_id" : "aws.amazon.com", "total" : 4 }
{ "_id" : "hostgator.com", "total" : 3 }
{ "_id" : "cloud.google.com", "total" : 2 }
{ "_id" : "godaddy.com", "total" : 1 }
>

 

  3.3 将集合websitegroup导出到CSV文件

   

c:\> mongoexport -d testdb -c websitegroup -f _id,total -o group.csv --csv
connected to: 127.0.0.1
exported 4 records

    

    CSV文件中数据

    

group.csv
_id,total
"aws.amazon.com",4.0
"cloud.google.com",2.0
"godaddy.com",1.0
"hostgator.com",3.0

    

    3.4 将”websitegroup“集合中数据导出到JSON文件

    

c:\> mongoexport -d testdb -c websitegroup -o group.json
connected to: 127.0.0.1
exported 4 records

    

    group.json文件内容

    

group.json
{ "_id" : "aws.amazon.com", "total" : 4 }
{ "_id" : "cloud.google.com", "total" : 2 }
{ "_id" : "godaddy.com", "total" : 1 }
{ "_id" : "hostgator.com", "total" : 3 }

 

  • 大小: 23 KB
分享到:
评论

相关推荐

    MongoDB: The Definitive Guide

    MongoDB: The Definitive Guide MongoDB is a powerful, flexible, and scalable general­purpose database. It combines the ability to scale out with features such as secondary indexes, range queries, ...

    解决Linux上MongoDB启动脚本错误---env: /etc/init.d/mongodb : no such file or directory

    - 启动MongoDB:`sudo systemctl start mongodb` - 设置开机启动:`sudo systemctl enable mongodb` 6. **手动创建启动脚本** 如果系统确实不支持Init.d,但需要使用旧的启动方式,可以手动创建一个启动脚本。这...

    深入学习MongoDB:Scaling MongoDB && 50 Tips and Tricks for MongoDB Developers

    深入学习MongoDB:Scaling MongoDB && 50 Tips and Tricks for MongoDB Developers深入学习MongoDB中文版Scaling MongoDB英文版50 Tips and Tricks for MongoDB Developers英文版高清完整目录3本打包合集

    Windows上安装MongoDB:完整步骤详解.pdf

    1. 连接MongoDB:输入`mongo.exe`命令,连接到本地MongoDB服务。 2. 创建数据库:使用`use <database_name>`命令,如`use testdb`,创建一个名为"testdb"的数据库。 3. 插入数据:在选定的数据库中,使用`db....

    fdb-document-layer:在FoundationDB上的文档数据模型,实现了MongoDB:registered:有线协议

    文档层使用MongoDB:registered:有线协议,允许通过现有的MongoDB:registered:客户端绑定使用MongoDB:registered:API。 所有持久数据都存储在FoundationDB键值存储中。 文档层实现了MongoDB:registered:API(v ...

    掌握MongoDB:NoSQL数据库基础与高级特性教程.rar

    什么是 MongoDB MongoDB 简介 MongoDB 特点 安装与配置 安装 MongoDB 启动与配置 MongoDB 基本操作 数据库和集合 文档操作 查询操作 基本查询 高级查询 索引与性能优化 创建索引 索引类型 索引优化 聚合操作 聚合...

    pm2-mongodb:用于监视mongodb数据库的PM2模块

    描述 PM2模块可自动监视mongodb的生命体征: 查询,输入,更新,删除 连接数 已用存储空间 网络速度(输入和输出) 代表名称和状态 pm2-mongodb ... pm2 set pm2-mongodb:ip 42.42.42.42 (我的mongod

    Spring集成MongoDB官方指定jar包:spring-data-mongodb-1.4.1.RELEASE.jar

    Spring集成MongoDB官方指定jar包:spring-data-mongodb-1.4.1.RELEASE.jar

    puppet-mongodb:mongodb安装

    mongodb人偶模块 目录 概述 从OS存储库或从MongoDB社区/企业存储库在RHEL / Ubuntu / Debian上安装MongoDB。 模块说明 ...如果只想使用默认选项安装服务器,则可以运行include mongodb::server 。

    feathers-mongodb:mongodb的羽毛服务

    羽毛mongodb 用于数据库适配器,使用用于。 $ npm install --save mongodb feathers-mongodb ... connect ( 'mongodb://localhost:27017/feathers' ) . then ( client => { app . use ( '/messages' ,

    mqemitter-mongodb:基于MongoDB的MQEmitter

    安装$ npm install mqemitter-mongodb --save例子var mongodb = require ( 'mqemitter-mongodb' )var mq = mongodb ( { url : 'mongodb://127.0.0.1/mqemitter?auto_reconnect'} )var msg = { topic : 'hello world'...

    docker-mongodb:一个盒子里的MongoDB

    docker run -d --name mongodb -p 27017:27017 -v /data/mongodb:/var/lib/mongodb anapsix/mongodb 作为客户: docker run -it --rm anapsix/mongodb mongo --help 配置 您可以像通常那样通过命令行传递配置选项...

    Mongodb数据库JAVA操作例子

    MongoClient mongoClient = MongoClients.create("mongodb://localhost:27017"); MongoDatabase database = mongoClient.getDatabase("yourDatabaseName"); MongoCollection<Document> collection = database....

    MongoDB权威指南中文版高清版带书签PDF

    MongoDB是一种分布式文档数据库系统,以其灵活性、可扩展性和高性能而受到广泛的欢迎,尤其适合处理大规模数据。在《MongoDB权威指南》这本书中,作者详细地介绍了MongoDB的基础知识、安装配置、数据模型、查询语言...

    MongoDB PPT

    MongoDB是一种流行的开源、分布式文档型数据库,设计用于处理海量数据并提供高可用性和可扩展性。MongoDB的PPT通常会涵盖以下关键知识点: 1. **文档型数据库**: MongoDB是文档数据库,它存储JSON(JavaScript ...

    mongodb例子

    总的来说,这个“mongodb例子”将帮助初学者快速掌握MongoDB的基础操作和核心概念,从而能够在实际项目中灵活运用。通过实践和探索,学习者能够更好地理解NoSQL数据库的优势,并了解如何利用MongoDB来处理大数据和...

    joola.datastore-mongodb:Joola 的 MongoDB 数据存储

    是一个数据分析和可视化中间件,旨在帮助您快速构建自定义的嵌入式数据分析应用程序。... "dsn" : "mongodb://localhost:27017/joola" } } } } 你们都准备好了。 为确保它正常工作,请运行一个节点并监视日志以查

    SpringBoot-JPA-MongoDB:SpringBoot-JPA-MongoDB

    spring.data.mongodb.uri=mongodb://localhost:27017/mydatabase ``` 或者 ```yaml spring: data: mongodb: uri: mongodb://localhost:27017/mydatabase ``` **8. 测试** 使用JUnit或其他测试框架编写测试用例,...

Global site tag (gtag.js) - Google Analytics