绝大多数情况下不该,数据库只该存和查;若必须用,则仅限TRIM、大小写转换、简单替换、类型转换、补默认值等轻量确定性操作,禁用正则提取、模糊去重、HTTP调用及游标逐行处理。

SQL存储过程里该不该做清洗
绝大多数情况下,不该。数据库只该存和查,不是Python或Pandas的替代品。硬塞复杂清洗逻辑进存储过程,会拖慢执行、难调试、更难维护——尤其当涉及正则提取、HTTP校验、模糊匹配或深度嵌套时。
但如果你被卡在必须用存储过程的环境里(比如老系统只开放了存储过程调用权限,或上游无法改),那就得守住边界:只做轻量、确定性高、无外部依赖的操作。
-
TRIM()去首尾空格 -
UPPER()/LOWER()统一大小写 -
REPLACE()简单字符替换(如把' '换成' ') -
CONVERT()或TRY_CAST()强制类型转换(推荐用TRY_CAST避免报错中断) -
COALESCE()或ISNULL()补默认值
别碰:REGEXP_REPLACE()(MySQL 8.0+ 可用但不支持捕获组)、地址分词、模糊去重、循环调用 API、CURSOR 逐行处理——这些都在埋雷。
MySQL 8.0+ 存储过程中批量格式化字符串字段
MySQL 8.0 起原生支持 REGEXP_REPLACE(),这是少数能真正替代部分应用层清洗的函数。但它只支持固定模式替换,不能用 $1 引用捕获组。
常见错误是直接对大表全量 UPDATE——锁表时间长,还可能触发 max_allowed_packet 超限。
- 务必加
WHERE条件限定范围,例如只处理status = 'raw'的记录 - 把清洗拆成小批次,用
LIMIT+OFFSET或主键范围(如id BETWEEN 1000 AND 2000)分批提交 - 别用
DECLARE CONTINUE HANDLER吞掉所有异常,至少保留SQLSTATE 'HY000'类报错,否则脏数据静默入库
示例:清洗电话字段,去掉括号、空格、横线,只留数字
UPDATE users SET phone = REGEXP_REPLACE(phone, '[^0-9]', '') WHERE status = 'raw' AND phone REGEXP '[^0-9]';
SQL Server 存储过程安全去重:用 CTE + ROW_NUMBER(),别用 DISTINCT INTO
直接 DELETE 去重最容易丢数据——没事务、没验证、没保留逻辑。真正可用的写法必须带事务、带日志、带明确保留规则。
SELECT DISTINCT * INTO #temp 看似简单,实则三类硬伤:丢失标识列、破坏约束、无法控制保留哪条重复记录。尤其当原表有 IDENTITY、CHECK 或外键时,等于绕过所有数据完整性保障。
- 必须用
WITH CTE AS ()定义临时结果集,不能直接对原表DELETE FROM table WHERE套子查询(SQL Server 不允许) -
PARTITION BY的列要和业务去重标准严格一致(如按customer_id,order_date去重,就不能漏掉任一列) -
ORDER BY必须明确指定保留哪条,例如ORDER BY created_time DESC保留最新记录;用(SELECT NULL)虽语法合法,但结果不可控,线上禁止 - 执行前先
SELECT * FROM CTE WHERE rn > 1验证待删行,再执行DELETE
PostgreSQL 自动化清洗:存储过程 + pg_cron 定时调度
PostgreSQL 没有内置定时任务,但通过扩展 pg_cron 可以实现真正的无人值守清洗。它直接集成在数据库内,比外部脚本更可靠,也更容易监控。
关键点不在“怎么写存储过程”,而在“怎么安全触发”。比如清洗日志表:
- 查
pg_class.relname匹配log_202301这类命名规则时,必须加AND relkind = 'r',排除索引、视图干扰 - 如果分区依据是
created_at字段,不能只看表名,得用pg_get_expr(relpartbound, oid)解析实际边界值,否则会漏删或错删 - 执行
DROP TABLE前加IF EXISTS,避免因并发导致报错中断后续清理
示例:查出早于当前月份6个月的日志分区表名
SELECT relname
FROM pg_class c
JOIN pg_namespace n ON n.oid = c.relnamespace
WHERE n.nspname = 'public'
AND c.relname ~ '^log_\d{6}$'
AND c.relkind = 'r'
AND SUBSTRING(c.relname, 5, 6)::int <
EXTRACT(YEAR FROM CURRENT_DATE)::int * 100 +
EXTRACT(MONTH FROM CURRENT_DATE)::int - 6;真正容易被忽略的是:清洗动作必须可逆、可验证、可开关。哪怕只是 TRIM(),也得记录影响行数、保留原始值快照、支持回滚条件——否则自动化就等于自动埋坑。

















