在Prisma中进行数据统计时，按月分组并计算总和是高频需求，比如统计每个月的订单总金额、每个月的用户新增数量等。实现这个需求需要结合Prisma的groupBy能力和数据库的日期处理函数，不同数据库的处理方式略有差异。
核心实现思路
Prisma本身提供了groupBy方法用于分组查询，但原生的groupBy不支持直接对日期字段做月份提取，因此需要借助数据库的日期函数先提取出月份信息，再基于提取后的月份字段进行分组，最后对目标数值字段做求和计算。
不同数据库的实现示例
PostgreSQL数据库
PostgreSQL可以使用EXTRACT函数提取日期的月份，结合Prisma的原生查询能力实现需求。假设我们有一个Order模型，包含createdAt订单创建时间字段和amount订单金额字段，要统计每个月的订单总金额，代码如下：
import { PrismaClient } from '@prisma/client'
const prisma = new PrismaClient()
async function getMonthlyOrderSum() {
// 使用Prisma原生查询，提取月份并分组求和
const result = await prisma.$queryRaw<Array<{ month: number, total_amount: number }>>`
SELECT
EXTRACT(MONTH FROM "createdAt") AS month,
SUM(amount) AS total_amount
FROM "Order"
GROUP BY EXTRACT(MONTH FROM "createdAt")
ORDER BY month ASC
`
return result
}
// 调用函数获取结果
getMonthlyOrderSum().then(res => {
console.log('月度订单总金额统计:', res)
})
MySQL数据库
MySQL使用MONTH函数提取日期的月份，实现逻辑和PostgreSQL类似，只是日期函数不同：
import { PrismaClient } from '@prisma/client'
const prisma = new PrismaClient()
async function getMonthlyOrderSum() {
const result = await prisma.$queryRaw<Array<{ month: number, total_amount: number }>>`
SELECT
MONTH(createdAt) AS month,
SUM(amount) AS total_amount
FROM Order
GROUP BY MONTH(createdAt)
ORDER BY month ASC
`
return result
}
getMonthlyOrderSum().then(res => {
console.log('月度订单总金额统计:', res)
})
SQLite数据库
SQLite使用strftime函数提取月份，格式字符串%m表示提取两位月份：
import { PrismaClient } from '@prisma/client'
const prisma = new PrismaClient()
async function getMonthlyOrderSum() {
const result = await prisma.$queryRaw<Array<{ month: string, total_amount: number }>>`
SELECT
strftime('%m', createdAt) AS month,
SUM(amount) AS total_amount
FROM Order
GROUP BY strftime('%m', createdAt)
ORDER BY month ASC
`
return result
}
getMonthlyOrderSum().then(res => {
console.log('月度订单总金额统计:', res)
})
注意事项
- 如果数据跨年份，上述方法会把不同年份的同一个月份合并统计，如果需要按年月分组，可以提取年份和月份组合分组，比如PostgreSQL中使用
EXTRACT(YEAR FROM "createdAt")提取年份，然后同时按年份和月份分组。 - 原生查询中的表名和字段名需要注意大小写，PostgreSQL默认对双引号内的标识符区分大小写，MySQL在Windows环境下不区分大小写，Linux环境下区分，需要根据实际数据库配置调整。
- 求和的字段如果是可选字段，需要提前处理空值，避免求和结果出现错误，可以在SQL中使用
COALESCE函数将空值转为0，比如SUM(COALESCE(amount, 0))。
扩展：按年月分组统计
如果需要同时区分年份和月份，以PostgreSQL为例，实现代码如下：
async function getMonthlyOrderSumByYear() {
const result = await prisma.$queryRaw<Array<{ year: number, month: number, total_amount: number }>>`
SELECT
EXTRACT(YEAR FROM "createdAt") AS year,
EXTRACT(MONTH FROM "createdAt") AS month,
SUM(amount) AS total_amount
FROM "Order"
GROUP BY EXTRACT(YEAR FROM "createdAt"), EXTRACT(MONTH FROM "createdAt")
ORDER BY year ASC, month ASC
`
return result
}