SQL批量数据清洗核心是用集合操作替代逐行处理,通过内置函数与条件逻辑一次性修正脏数据,关键在准确定位问题类型、匹配SQL能力边界并验证效果。

SQL批量数据清洗核心在于用集合操作代替逐行处理,靠内置函数和条件逻辑一次性修正大量脏数据。关键不是写得多,而是想得准——先定位问题类型,再匹配SQL能力边界,最后验证效果。
识别常见脏数据模式
批量清洗前必须明确要处理什么。典型问题包括:
- 空值与占位符混用:如 NULL、'NULL'、''、'N/A'、'未知' 都表示缺失,但数据库当不同值对待
- 格式不统一:手机号带空格/横线/括号('138 1234 5678'、'138-1234-5678')、日期存为字符串('20230101'、'01/01/2023')
- 逻辑错误:年龄为负数、注册时间晚于订单时间、状态字段出现不存在的值(如 status='pending_pay' 但枚举只支持 'paid'/'cancelled')
- 重复与冗余:完全重复行、主键不唯一、同一客户多条记录仅联系方式不同
用UPDATE+CASE批量标准化字段
这是最常用也最高效的清洗手段,尤其适合格式转换、空值归一、状态映射等场景。
例如统一手机号:去掉所有非数字字符,补足11位(假设国内)
UPDATE users
SET phone = REPLACE(REPLACE(REPLACE(REPLACE(phone, ' ', ''), '-', ''), '(', ''), ')', '')
WHERE phone REGEXP '[^0-9]';登录后复制
再统一空值表达:
UPDATE users
SET gender = CASE
WHEN gender IN ('', 'NULL', 'N/A', '未知') THEN NULL
WHEN gender IN ('男', 'M', 'm', '1') THEN 'M'
WHEN gender IN ('女', 'F', 'f', '0') THEN 'F'
ELSE 'O'
END;登录后复制
⚠️ 注意:执行前务必备份或在事务中测试(BEGIN; ... ROLLBACK;)
版权声明:除非特别标注,否则均为本站原创文章,转载时请以链接形式注明文章出处。
还木有评论哦,快来抢沙发吧~