Sequelize中用group by进行分组聚合查询

更新时间：2016年12月12日 08:34:16 投稿：daisy

大家都知道在SQL查询中，分组查询是较常用的一种查询方式。分组查询是指通过GROUP BY关键字，将查询结果按照一个或多个字段进行分组，分组时字段值相同的会被分为一组。在Node.js基于Sequelize的ORM框架中，同样支持分组查询，使用非常简单方便。下面来看看详细的介绍。

一、SQL与Sequelize中的分组查询

1.1 SQL中的分组查询

SQL查询中，通GROUP BY语名实现分组查询。GROUP BY子句要和聚合函数配合使用才能完成分组查询，在SELECT查询的字段中，如果没有使用聚合函数就必须出现在ORDER BY子句中。分组查询后，查询结果为一个或多个列分组后的结果集。

GROUP BY语法

SELECT 列名, 聚合函数(列名)
FROM 表名
WHERE 列名 operator value
GROUP BY 列名 
[HAVING 条件表达式] [WITH ROLLUP]

在以上语句中：

聚合函数 - 分组查询通常要与聚合函数一起使用，聚合函数包括：

COUNT()-用于统计记录条数
SUM()-用于计算字段的值的总和
AVG()-用于计算字段的值的平均值
MAX-用于查找查询字段的最大值
MIX-用于查找查询字段的最小值

GROUP BY子名-用于指定分组的字段

HAVING子名-用于过滤分组结果，符合条件表达式的结果将会被显示

WITH ROLLUP子名-用于指定追加一条记录，用于汇总前面的数据

1.2 Sequelize中的分组查询

使用聚合函数

Sequelize提供了聚合函数，可以直接对模型进行聚合查询：

aggregate(field, aggregateFunction, [options])-通过指定的聚合函数进行查询
sum(field, [options])-求和
count(field, [options])-统计查询结果数
max(field, [options])-查询最大值
min(field, [options])-查询最小值

以上这些聚合函数中，可以通过options.attributes、options.attributes属性指定分组相关字段，并可以通过options.having指定过滤条件，但没有直接指定WITH ROLLUP子句的参数。

如，使用.sum()查询订单数量大于1的用户订单额：

Order.sum('price', {attributes:['name'], group:'name', plain:false, having:['COUNT(?)>?', 'name', 1]}).then(function(result){
 console.log(result);
})

生成的SQL语句如下：

SELECT `name`, sum(`price`) AS `sum` FROM `orders` AS `Orders` GROUP BY name HAVING COUNT('name')>1;

使用聚合参数

除直接使用聚合函数外，也可以在findAll()等方法中，指定聚合查询相关参数实现聚合查询。查询时，同样可以通过通过options.attributes、options.attributes属性指定分组相关字段，并可以通过options.having指定过滤条件。与直接使用聚合函数查询不一样，通过参数构建聚合查询时，要以数组或对象形式设置options.attributes参数中的聚合字段，并需要通过sequelize.fn()方法传入聚合函数。

如，使用.findAll()查询订单数量大于1的用户订单额：

Order.findAll({attributes:['name', [sequelize.fn('SUM', sequelize.col('price')), 'sum']], group:'name', having:['COUNT(?)>?', 'name', 1], raw:true}).then(function(result){
 console.log(result);
})

生成的SQL语句如下：

SELECT `name`, sum(`price`) AS `sum` FROM `orders` AS `Orders` GROUP BY name HAVING COUNT('name')>1;

二、使用示例

现在订单表，数据如下：

> select * from orders;
+---------+-------------+--------+-----------+---------------------+
| orderId | orderNumber | price | name  | createdOn   |
+---------+-------------+--------+-----------+---------------------+
|  1 | 00001  | 128.00 | 张小三 | 2016-11-25 10:12:49 |
|  2 | 00002  | 102.00 | 张小三 | 2016-11-25 10:12:49 |
|  4 | 00004  | 99.00 | 王小五 | 2016-11-25 10:12:49 |
|  3 | 00003  | 199.00 | 赵小六 | 2016-11-25 10:12:49 |
+---------+-------------+--------+-----------+---------------------+

2.1 简单使用

使用分组查询，统计每个客户的订单总额。

使用SQL语句，可以像下面这样查询：

> select name, SUM(price) from orders GROUP BY name;
+-----------+------------+
| name  | SUM(price) |
+-----------+------------+
| 张小三 |  230.00 |
| 王小五 |  99.00 |
| 赵小六 |  199.00 |
+-----------+------------+

而在Sequelize中可以像下面这样实现：

Order.findAll({attributes:['sum', [sequelize.fn('SUM', sequelize.col('name')), 'sum']], group:'name', raw:true}).then(function(result){
 console.log(result);
})

2.2 使用HAVING子句

统计订单数量大于1的用户的订单总金额。

使用SQL语句，可以像下面这样实现：

> select name, SUM(price) from orders GROUP BY name HAVING count(1)>1;
+-----------+------------+
| name  | SUM(price) |
+-----------+------------+
| 张小三 |  230.00 |
| 赵小六 |  199.00 |
+-----------+------------+

而使用Sequelize可以像下面这样查询：

Order.findAll({attributes:['sum', [sequelize.fn('SUM', sequelize.col('name')), 'sum']], group:'name', having:['COUNT(?)>?', 'name', 1], raw:true}).then(function(result){
 console.log(result);
})

2.3 使用WITH ROLLUP子句

WITH ROLLUP子句是MySQL 5.5+新增的特性，用于汇总统计结果。但本文发布时，Sequelize还不支持该特性。

增加总和统计列：

> select name, SUM(price) from orders GROUP BY name WITH ROLLUP;
+-----------+------------+
| name  | SUM(price) |
+-----------+------------+
| 张小三 |  230.00 |
| 王小五 |  99.00 |
| 赵小六 |  199.00 |
| NULL  |  528.00 |
+-----------+------------+

2.4 连接查询与分组

为了管理方便，我们会将不同的信息保存在不同的表中。如，我们会将订单信息放在一张表中，而将客户信息保存在另一张表中。对于存在关联关系的两张表，我们会使用连接查询来查找关联数据，在进行连接查询时，同样可以以使用聚合函数。

订单表如下：

> select * from orders;
+---------+-------------+--------+------------+---------------------+
| orderId | orderNumber | price | customerId | createdOn   |
+---------+-------------+--------+------------+---------------------+
|  1 | 00001  | 128.00 |   1 | 2016-11-25 10:12:49 |
|  2 | 00002  | 102.00 |   1 | 2016-11-25 10:12:49 |
|  3 | 00003  | 199.00 |   4 | 2016-11-25 10:12:49 |
|  4 | 00004  | 99.00 |   3 | 2016-11-25 10:12:49 |
+---------+-------------+--------+------------+---------------------+

客户表结构如下：

> select * from customers;
+----+-----------+-----+---------------------+---------------------+
| id | name  | sex | birthday   | createdOn   |
+----+-----------+-----+---------------------+---------------------+
| 1 | 张小三 | 1 | 1986-01-22 08:00:00 | 2016-11-25 10:16:35 |
| 2 | 李小四 | 2 | 1987-11-12 08:00:00 | 2016-11-25 10:16:35 |
| 3 | 王小五 | 1 | 1988-03-08 08:00:00 | 2016-11-25 10:16:35 |
| 4 | 赵小六 | 1 | 1989-08-11 08:00:00 | 2016-11-25 10:16:35 |
+----+-----------+-----+---------------------+---------------------+

使用连接查询并分组查询，统计每个客户的订单总额。

使用SQL语句查询如下：

> select c.name, SUM(o.price) AS sum from customers AS c INNER JOIN orders AS o ON o.customerId =c.id GROUP BY c.name;

Sequelize中进行连接查询时，首先需要建立模型间的关联关系：

Order.belongsTo(Customer, {foreignKey: 'customerId'});

连接查询及分组：

var include = [{
 model: Customer,
 required: true,
 attributes: ['name'],
}]
Order.findAll({include:include, attributes:[[sequelize.fn('SUM', sequelize.col('price')), 'sum']], group:'Customer.name', having:['COUNT(?)>?', 'name', 1], raw:true, rollup:true}).then(function(result){
 console.log(result);
})

总结

以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作能带来一定的帮助，如果有疑问大家可以留言交流。

您可能感兴趣的文章:

关于Yarn的使用及说明
这篇文章主要介绍了关于Yarn的使用及说明,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
2023-11-11
node.js爬虫框架node-crawler初体验
这篇文章主要介绍了node.js爬虫框架node-crawler的相关资料，帮助大家利用node.js进行爬虫，感兴趣的朋友可以了解下
2020-10-10
用NODE.JS中的流编写工具是要注意的事项
Nodejs读写流流的传输过程默认是以buffer的形式传输的,除非你给他设置其他编码形式, 小伙伴可以参考下。
2016-03-03
node.js中的fs.lchownSync方法使用说明
这篇文章主要介绍了node.js中的fs.lchownSync方法使用说明,本文介绍了fs.lchownSync的方法说明、语法、接收参数、使用实例和实现源码,需要的朋友可以参考下
2014-12-12
详解NodeJs项目 CentOs linux服务器线上部署
这篇文章主要介绍了NodeJs项目 CentOs linux服务器线上部署，本文给大家介绍的非常详细，具有一定的参考借鉴价值,需要的朋友可以参考下
2019-09-09
node 文件上传接口的转发的实现
这篇文章主要介绍了node 文件上传接口的转发的实现，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2019-09-09
详解nodejs实现本地上传图片并预览功能（express4.0+）
本篇文章主要介绍了nodejs实现本地上传图片并预览功能（express4.0+），具有一定的参考价值，有兴趣的可以了解一下
2017-06-06
搭建一个nodejs脚手架的方法步骤
这篇文章主要介绍了如何搭建一个nodejs脚手架的方法步骤，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2019-06-06
Node.js文件编码格式的转换的方法
这篇文章主要介绍了Node.js文件编码格式的转换的方法，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧
2018-04-04
关于Node.js中的JXcore打包示例
这篇文章主要介绍了关于Node.js中的JXcore打包示例,JXcore 是一个支持多线程的 Node.js 发行版本，基本不需要对你现有的代码做任何改动就可以直接线程安全地以多线程运行,需要的朋友可以参考下
2023-05-05

Sequelize中用group by进行分组聚合查询

相关文章

最新评论

大家感兴趣的内容

最近更新的内容

常用在线小工具