Django/Postgres中如何多字段关联后分组统计换算金额总和
完全可以通过Django ORM实现该需求,不需要强制编写原生SQL,Postgres环境下两种方式都可以正常运行。
注:你给出的ExchangeRate模型定义有笔误,实际使用时需要补全继承:
class ExchangeRate(models.Model):
Django ORM实现方案
需要用到Django内置的查询表达式、子查询、日期截断函数,示例代码如下:
from django.db.models import F, Sum, Subquery, OuterRef, TruncMonth, Coalesce # 构造子查询:匹配交易记录对应日期、对应币种的汇率 rate_subquery = ExchangeRate.objects.filter( currency=OuterRef("currency"), date=OuterRef("date") ).values("rate")[:1] # 执行查询:关联汇率 -> 计算折算金额 -> 按月分组求和 monthly_converted_total = Transaction.objects.annotate( # 匹配汇率,无匹配时默认汇率设为1,可根据需求调整 rate=Coalesce(Subquery(rate_subquery), 1), converted_amount=F("amount") * F("rate") ).annotate( # 将交易日期截断到当月第一天,用于按月分组 transaction_month=TruncMonth("date") ).values("transaction_month").annotate( # 按月汇总折算后总金额 monthly_total=Sum("converted_amount") ).order_by("transaction_month")
返回结果的每一条会包含transaction_month(当月第一天的日期对象)和monthly_total(当月折算后总金额)两个字段。
原生SQL实现方案(Postgres适用)
如果更习惯写SQL,也可以直接用Postgres的DATE_TRUNC函数实现,示例代码如下:
from django.db import connection # 替换SQL中的yourapp为你自己的Django应用名,自定义过表名的话直接用自定义表名 raw_sql = """ SELECT DATE_TRUNC('month', t.date) AS transaction_month, SUM(t.amount * COALESCE(e.rate, 1)) AS monthly_total FROM yourapp_transaction t LEFT JOIN yourapp_exchangerate e ON t.currency_id = e.currency_id AND t.date = e.date GROUP BY transaction_month ORDER BY transaction_month; """ # 执行SQL获取结果 with connection.cursor() as cursor: cursor.execute(raw_sql) # 返回结果为元组列表,每个元组对应(月份, 总金额) result = cursor.fetchall()
注意事项
- 要保证同一日期、同一币种在ExchangeRate表中只有一条汇率记录,否则会出现关联结果异常
- 示例中用了LEFT JOIN + COALESCE处理无匹配汇率的场景,如果不需要保留无汇率的交易,把LEFT JOIN改成INNER JOIN即可
- 如果需要拆分显示年份、月份,可在ORM中额外引入
ExtractYear、ExtractMonth函数,或者在SQL中用EXTRACT(YEAR FROM t.date)、EXTRACT(MONTH FROM t.date)做字段拆分
内容的提问来源于stack exchange,提问作者Kritz
相关产品推荐
相关产品推荐

