mysql实现列转行和行转列方式

 更新时间:2025年08月05日 10:03:52   作者:北风toto  
这篇文章主要介绍了mysql实现列转行和行转列方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教

1、行转列(将多行数据转为单行多列)

1.1、使用 CASE WHEN + 聚合函数

SELECT 
    id,
    MAX(CASE WHEN subject = '数学' THEN score ELSE NULL END) AS '数学',
    MAX(CASE WHEN subject = '语文' THEN score ELSE NULL END) AS '语文',
    MAX(CASE WHEN subject = '英语' THEN score ELSE NULL END) AS '英语'
FROM student_scores
GROUP BY id;

1.2、使用 IF + 聚合函数

SELECT 
    id,
    MAX(IF(subject = '数学', score, NULL)) AS '数学',
    MAX(IF(subject = '语文', score, NULL)) AS '语文',
    MAX(IF(subject = '英语', score, NULL)) AS '英语'
FROM student_scores
GROUP BY id;

1.3、使用 PIVOT (MySQL 8.0+)

SELECT 
    id,
    JSON_UNQUOTE(JSON_EXTRACT(pivot_data, '$.数学')) AS '数学',
    JSON_UNQUOTE(JSON_EXTRACT(pivot_data, '$.语文')) AS '语文',
    JSON_UNQUOTE(JSON_EXTRACT(pivot_data, '$.英语')) AS '英语'
FROM (
    SELECT 
        id,
        JSON_OBJECTAGG(subject, score) AS pivot_data
    FROM student_scores
    GROUP BY id
) AS t;

1.4、dataworks使用wm_concat函数和keyvalue

  • 缺点:当字符串存在英文冒号时会导致获取的值为空;中文冒号不受影响
  • 如果存在重复的数据,将导致取数时随机取其中一个;核心原因为wm_concat函数在拼接时顺序不固定,哪怕是增加了order by也没有用
  • keyvalue从字符串中取值时,如果有重复key,从左到右取第一个key的值
select  id
        ,keyvalue(column_value,'name') as name
        ,keyvalue(column_value,'age') as age
from    (
            select  id
                    ,wm_concat(';',concat(obj_name,':',obj_value)) as column_value
            from    school
            group by id
        ) 
;
-- 如果值存在英文冒号,导致取值为空的原因,看下面两个sql例子即可理解
-- 返回null
select keyvalue('name:小红:3737;age:13','name');
-- 返回3737
select keyvalue('name:小红:3737;age:13','name:小红');

2、列转行(将多列数据转为多行)

2.1、使用 UNION ALL

SELECT id, '数学' AS subject, 数学 AS score FROM student_scores_pivot
UNION ALL
SELECT id, '语文' AS subject, 语文 AS score FROM student_scores_pivot
UNION ALL
SELECT id, '英语' AS subject, 英语 AS score FROM student_scores_pivot
ORDER BY id, subject;

2.2、使用 CROSS JOIN + 条件筛选

  • 优点是不用频繁读取磁盘
SELECT 
    s.id,
    c.subject,
    CASE c.subject
        WHEN '数学' THEN s.数学
        WHEN '语文' THEN s.语文
        WHEN '英语' THEN s.英语
    END AS score
FROM student_scores_pivot s
CROSS JOIN (
    SELECT '数学' AS subject UNION ALL
    SELECT '语文' UNION ALL
    SELECT '英语'
) c;
  • 同样的语句,使用values和row
SELECT 
    s.id,
    c.subject,
    CASE c.subject
        WHEN '数学' THEN s.数学
        WHEN '语文' THEN s.语文
        WHEN '英语' THEN s.英语
    END AS score
FROM student_scores_pivot s
CROSS JOIN (
	values
    row('数学') 
    ,row('语文')
    ,row('英语')
) c(subject);

2.3、使用 JSON 函数 (MySQL 8.0+)

SELECT 
    id,
    jt.subject,
    jt.score
FROM student_scores_pivot,
JSON_TABLE(
    JSON_OBJECT(
        '数学', 数学,
        '语文', 语文,
        '英语', 英语
    ),
    '$.*' COLUMNS(
        subject VARCHAR(10) PATH '$.key',
        score INT PATH '$.value'
    )
) AS jt;

3、动态行转列

  • 对于不确定列名的情况,可以使用存储过程动态生成SQL:
DELIMITER //
CREATE PROCEDURE dynamic_pivot(IN table_name VARCHAR(100), IN row_id VARCHAR(100), IN pivot_col VARCHAR(100), IN value_col VARCHAR(100))
BEGIN
    DECLARE done INT DEFAULT FALSE;
    DECLARE col_name VARCHAR(100);
    DECLARE col_list TEXT DEFAULT '';
    DECLARE cur CURSOR FOR 
        SELECT DISTINCT pivot_col FROM table_name;
    DECLARE CONTINUE HANDLER FOR NOT FOUND SET done = TRUE;
    
    OPEN cur;
    read_loop: LOOP
        FETCH cur INTO col_name;
        IF done THEN
            LEAVE read_loop;
        END IF;
        SET col_list = CONCAT(col_list, 
            IF(col_list = '', '', ', '), 
            'MAX(CASE WHEN ', pivot_col, ' = ''', col_name, ''' THEN ', value_col, ' ELSE NULL END) AS `', col_name, '`');
    END LOOP;
    CLOSE cur;
    
    SET @sql = CONCAT('SELECT ', row_id, ', ', col_list, ' FROM ', table_name, ' GROUP BY ', row_id, ';');
    PREPARE stmt FROM @sql;
    EXECUTE stmt;
    DEALLOCATE PREPARE stmt;
END //
DELIMITER ;

-- 调用存储过程
CALL dynamic_pivot('student_scores', 'id', 'subject', 'score');

4、详细测试demo

4.1、dataworks使用wm_concat函数和keyvalue实现行转列

-- 创建表
create table if not exists school (
`id` string,
`obj_name` string,
`obj_value` string
);

-- 插入测试数据
insert into school
values 
('1','name','小明'),
('1','age','12'),
('2','name','小红'),
('2','age','13')
;


-- 列转行
select  id
        ,keyvalue(column_value,'name') as name
        ,keyvalue(column_value,'age') as age
from    (
            select  id
                    ,wm_concat(';',concat(obj_name,':',obj_value)) as column_value
            from    school
            group by id
        ) 
;

总结

以上为个人经验,希望能给大家一个参考,也希望大家多多支持脚本之家。

相关文章

  • Navicat for Mysql 字段注释中文乱码问题及解决

    Navicat for Mysql 字段注释中文乱码问题及解决

    这篇文章主要介绍了Navicat for Mysql 字段注释中文乱码问题及解决方案,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
    2023-09-09
  • MySQL学习必备条件查询数据

    MySQL学习必备条件查询数据

    这篇文章主要介绍了MySQL学习必备条件查询数据,首先通过利用where语句可以对数据进行筛选展开主题相关内容,具有一定的参考价值,需要的小伙伴可以参考一下,希望对你有所帮助
    2022-03-03
  • 将数据插入到MySQL表中的详细教程

    将数据插入到MySQL表中的详细教程

    这篇文章主要介绍了将数据插入到MySQL表中的详细教程,文中给出了在PHP脚本中操作的示例,是MySQL入门学习中的基础知识,需要的朋友可以参考下
    2015-05-05
  • Mac上安装MySQL过程分享

    Mac上安装MySQL过程分享

    这篇文章主要介绍了Mac上安装MySQL过程分享,本文共分4步完成,简单易懂,需要的朋友可以参考下
    2014-11-11
  • MySQL如何保证备份数据的一致性详解

    MySQL如何保证备份数据的一致性详解

    在高并发的场景下,大量的请求直接访问Mysql很容易造成性能问题,下面这篇文章主要给大家介绍了关于MySQL如何保证备份数据一致性的相关资料,文中通过图文介绍的非常详细,需要的朋友可以参考下
    2022-05-05
  • Mysql5.7.14 linux版密码忘记完美解决办法

    Mysql5.7.14 linux版密码忘记完美解决办法

    这篇文章主要介绍了Mysql5.7.14 linux版密码忘记完美解决办法,需要的朋友可以参考下
    2017-08-08
  • MySQL中DROP、DELETE与TRUNCATE的对比分析

    MySQL中DROP、DELETE与TRUNCATE的对比分析

    在MySQL数据库操作中,DROP、DELETE和TRUNCATE是三个常用的数据操作命令,本文将从多个维度对这三个命令进行详细对比和解析,帮助读者更好地掌握它们的应用,感兴趣的朋友一起看看吧
    2025-07-07
  • Linux系统利用crontab定时备份Mysql数据库方法

    Linux系统利用crontab定时备份Mysql数据库方法

    本文教你如果快速利用系统crontab来定时执行备份文件,按日期对备份结果进行保存
    2021-09-09
  • Windows 11 和 Rocky 9 Linux 平台 MySQL 8.0.33 简易安装详细教程

    Windows 11 和 Rocky 9 Linux 平台 MySQL 8.0.33 简易安装详细教程

    这篇文章主要介绍了Windows 11和Rocky9 Linux平台MySQL8.0.33简易安装教程,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2023-05-05
  • MySQL如何查看正在运行的SQL详解

    MySQL如何查看正在运行的SQL详解

    在项目开发里面总是要查看后台执行的sql语句,mysql数据库也不例外,下面这篇文章主要给大家介绍了关于MySQL如何查看正在运行的SQL的相关资料,文中介绍的非常详细,需要的朋友可以参考下
    2023-01-01

最新评论