postgresql自定义聚合函数是解决特定汇总逻辑的刚需工具，因其执行模型支持“按组逐行累积+终值变形”两阶段计算，而普通函数、子查询或窗口函数无法替代；创建需严格定义状态函数（sfunc）、终值函数（finalfunc）和聚合本身，并确保类型、初始值与执行语义一致。
PostgreSQL 的自定义聚合函数不是“高级彩蛋”，而是解决特定汇总逻辑的刚需工具——当你发现 COUNT、SUM、STRING_AGG 都没法直接表达业务规则（比如“每单起步价+里程×单价，再四舍五入到十位”），就必须自己造一个聚合。
为什么不能只用普通函数或子查询
普通标量函数（如 taxi_accum）只能处理单行；子查询或窗口函数无法天然支持“按组累积 + 最终变形”的两阶段计算。而聚合函数的执行模型是刚性的：每组内逐行调用状态函数（SFUNC），最后统一调用终值函数（FINALFUNC）。跳过这个模型，就等于绕开 PostgreSQL 的执行器优化路径，容易踩坑：
- 手动在应用层分组累加 → 网络往返多、并发下易错、无法被
GROUP BY推送下推 - 用
ARRAY_AGG+UNNEST模拟 → 内存暴涨、无索引支持、无法流式处理大组数据 - 把逻辑写进
SELECT子句（如(3.5 + SUM(km)*2.2)::numeric）→ 无法封装定价策略变更，所有 SQL 都得同步改
创建聚合函数的三步实操链
以“出租车计价聚合 taxi(numeric, numeric)”为例，必须严格按顺序定义三个对象：
1. 状态累积函数（SFUNC）：taxi_accum(numeric, numeric, numeric)
- 第一个参数是上一轮结果（初始为
INITCOND），后两个是当前行字段和外部传参 - 必须返回与第一个参数同类型的值（这里是
numeric） - 别漏写
LANGUAGE 'plpgsql'和VOLATILE（因涉及浮点运算，不可标记为IMMUTABLE）
2. 终值处理函数（FINALFUNC）：taxi_final(numeric)
- 只接收一个参数：SFUNC 最终累积出的状态值
- 这里做四舍五入到十位：
round($1 + 5, -1)（加5再取整是经典技巧） - 注意：返回类型必须与聚合声明的
STYPE兼容
3. 聚合本身：CREATE AGGREGATE taxi(numeric, numeric)
-
STYPE = numeric：状态类型，必须和 SFUNC 第一个参数、FINALFUNC 唯一参数一致 -
INITCOND = 3.50：起步价，不能写成字符串'3.50'，否则类型不匹配报错ERROR: invalid input syntax for type numeric - 不指定
COMBINEFUNC时，该聚合无法并行执行（对大数据量影响明显）
常见错误现象与定位方法
执行 SELECT trip_id, taxi(km, 2.2) FROM t_taxi GROUP BY trip_id 报错？先查这几点：
-
ERROR: function taxi(numeric, numeric) does not exist→ 聚合未创建，或当前 schema 不在search_path中（用SELECT current_schemas(true)检查） -
ERROR: column "km" must appear in the GROUP BY clause or be used in an aggregate function→ 忘了GROUP BY trip_id，聚合函数不能脱离分组上下文单独使用 - 结果全为
NULL→ FINALFUNC 返回了NULL（比如数组越界访问ret[sss+1]且sss+1超出长度），加RAISE NOTICE打印中间值最直接 - 性能极差 → 检查 SFUNC 是否做了不必要的 I/O（如查表、调外部 API），聚合函数内严禁此类操作
字符串拼接类聚合的兼容性陷阱
想实现类似 MySQL 的 GROUP_CONCAT？别直接抄 array_to_comma_string 示例：
-
array_append在大数据量下内存占用线性增长，比原生STRING_AGG慢 3–5 倍 - PostgreSQL 9.6+ 已内置
STRING_AGG(expr, delimiter)，优先用它；自定义仅用于需要特殊分隔逻辑（如“最后一项前加 and”） - 若坚持自定义，
STYPE设为text比text[]更省内存，但 FINALFUNC 得手动处理空值和分隔符边界 - 注意排序：原生
STRING_AGG支持ORDER BY，自定义聚合需在 SFUNC 里维护有序数组，成本陡增
真正难的从来不是写完三个函数，而是让 FINALFUNC 的输出类型、SFUNC 的状态迁移、以及 INITCOND 的默认值，在所有边缘输入（空组、全 NULL 列、超长字符串）下保持行为一致——这点没测试覆盖，上线就等于埋雷。
