18. Mysql 存储过程，实现动态数据透视

文章目录

    • 概述
    • 常见操作
      • 创建存储过程
      • 存储过程局部变量定义和赋值
      • 查看存储过程
      • 删除存储过程
      • 调用存储过程
    • 示例-动态数据透视详细讲解
    • 总结
    • 参考资料

概述

Mysql 存储过程是一组预先编译的 sql 语句集合，它们被存储在数据库中，并可以被多次调用执行。存储过程可以接受参数、执行复杂的逻辑操作，并返回结果或修改数据库的状态。

存储过程有以下几个优点：

  1. 代码复用：存储过程可以将常用的操作逻辑封装起来，以便在多个地方重复使用，避免重复编写相同的 sql 语句。

  2. 提高性能：存储过程在编译时进行优化，可以减少通信开销，提高数据库的执行效率。

  3. 安全性：存储过程可以控制对数据库的访问权限，只暴露必要的接口，提高数据的安全性。

  4. 简化操作：存储过程可以执行复杂的数据库操作，减少客户端与数据库之间的交互次数，简化了客户端的代码。

常见操作

创建存储过程

使用 create procedure 语句来创建存储过程，语法如下：

create procedure procedure_name ([in|out|inout] parameter_name data_type [, ...])
begin-- 存储过程的代码逻辑
end;

其中，procedure_name是存储过程的名称，parameter_name是存储过程的参数名，data_type是参数的数据类型。 in、out 或 inout 类型解释如下：，分别表示输入参数、输出参数和输入输出参数。

  • in ：表示当前参数为输入参数，存储过程只是读取这个参数的值。如果没有定义参数种类， 默认就是 in 。
  • out ：表示当前参数为输出参数，执行完成之后，调用这个存储过程的客户端或者应用程序就可以读取这个参数返回的值。
  • inout ：表示当前参数既可以为输入参数，也可以为输出参数。

存储过程局部变量定义和赋值

局部变量的定义和赋值，在上一节有提到过，具体可查看：Mysql 变量的使用。

declare <变量名> <变量类型> default <默认值>;
set <变量名>=<值>;

查看存储过程

# 查看存储过程和函数的创建信息
show create procedure 存储过程名称;
# 查看存储过程状态信息
show procedure status like '%max_salary%';

删除存储过程

删除是必修课，在任何一个DDL语句中都必须学习创建和删除，语法如下：

drop procedure [if exists] 存储过程名称;

调用存储过程

使用 call 语句来调用存储过程，procedure_name是存储过程的名称，parameter_value是存储过程的参数值。参数值可以是常量、变量或表达式。

call procedure_name([parameter_value, ...]);

示例

没有任何参数情况

drop procedure if exists employee_avg_salary;
create procedure employee_avg_salary()
beginselect avg(salary) from emps;
end;
call employee_avg_salary();

存在 in 参数情况

drop procedure if exists show_someone_salary;
create procedure show_someone_salary(in empname varchar(20))
beginselect salary from employeeswhere last_name = empname;
end;
CALL show_someone_salary('Abel');

存在 out 参数情况

drop procedure if exists show_min_salary;
create procedure show_min_salary(out ms double)
beginselect min(salary) into msfrom emps;
end;
call show_min_salary(@ms);-- 调用
select @ms;-- 查看输出变量

存在 in 和 out 参数情况

drop procedure if exists show_someone_salary2;
create procedure show_someone_salary2(in empname varchar(20),out empsalary decimal(10,2))
beginselect salary into empsalaryfrom employeeswhere last_name = empname;
end;
call show_someone_salary2('abel',@empsalary);-- 调用
select @empsalary;-- 查看输出值

存在 inout 参数情况

drop procedure if exists show_mgr_name;
create procedure show_mgr_name(inout empname varchar(25))
beginselect last_name into empnamefrom empswhere employee_id = (select manager_idfrom empswhere last_name = empname);
end;
set @empname := 'Abel';
call show_mgr_name(@empnam);
select @empnam;

示例-动态数据透视详细讲解

数据准备和需求

准备一张产品销售表，其中产品会随着新品发布会增加，需要是我想要看到区域对应每个产品的金额，并且新增加的产品也要透视。

create table sql_test1.sales
(id           int comment '销售id',product_name varchar(255) comment '产品名称',amount       double comment '金额',region       varchar(255) comment '区域',create_time  datetime default current_timestamp null comment '创建时间'
);
insert into sql_test1.sales(id,product_name,amount,region) values (1,'Product A',2000,'North');
insert into sql_test1.sales(id,product_name,amount,region) values (2,'Product B',3000,'South');
insert into sql_test1.sales(id,product_name,amount,region) values (3,'Product A',1500,'East');
insert into sql_test1.sales(id,product_name,amount,region) values (4,'Product C',2500,'West');
insert into sql_test1.sales(id,product_name,amount,region) values (5,'Product B',1800,'North');

数据测试和实现

首先，查看现有产品对应区域的金额现状。

select region, sum(case when product_name = 'Product A' then amount else 0 end) as `Product A`, sum(case when product_name = 'Product B' then amount else 0 end) as `Product B`, sum(case when product_name = 'Product C' then amount else 0 end) as `Product C`
from sql_test1.sales
group by region;
+--------+-----------+-----------+-----------+
| region | Product A | Product B | Product C |
+--------+-----------+-----------+-----------+
| North  |      2000 |      1800 |         0 |
| South  |         0 |      3000 |         0 |
| East   |      1500 |         0 |         0 |
| West   |         0 |         0 |      2500 |
+--------+-----------+-----------+-----------+

其次，我们利用上一节 Mysql 动态 sql ，让代码自动生成要执行的动态 sql 。\n\t 表示换行符和制表符。

# 录入新产品数据
insert into sql_test1.sales(id,product_name,amount,region) values (1,'Product D',2000,'North');
# 编辑动态sql进行测试
set @dynamic_column_sql = null; -- 定义动态列的变量
select group_concat(distinct concat('max(case when product_name = \'',product_name,'\' then amount else 0 end) as `',product_name, '`') separator '\n\t, ') into @dynamic_column_sql
from sql_test1.sales;-- 利用 group_concat 函数拼接出需要透视的动态列文本，并更新@dynamic_column_sql变量
set @pivot_sql = concat('select region\n\t, ', @dynamic_column_sql, '\nfrom sql_test1.sales \ngroup by region;');-- 整体拼接
select @pivot_sql;
+--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
| @pivot_sql                                                                                                                                                                                                                                                                                                                                                                                       |
+--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
| select region, max(case when product_name = 'Product A' then amount else 0 end) as `Product A`, max(case when product_name = 'Product B' then amount else 0 end) as `Product B`, max(case when product_name = 'Product C' then amount else 0 end) as `Product C`, max(case when product_name = 'Product D' then amount else 0 end) as `Product D`
from sql_test1.sales 
group by region; |
+--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+

最后，我们看到上一步拼接的动态 sql 自动添加了新产品 Product D 的汇总情况，这就是我们要执行的，进一步封装成存储过程，简单执行。

drop procedure if exists dynamic_pivot;
create procedure dynamic_pivot()
beginset @dynamic_column_sql = null;select group_concat(distinct concat('max(case when product_name = \'',product_name,'\' then amount else 0 end) as `',product_name, '`') separator '\n\t, ') into @dynamic_column_sqlfrom sql_test1.sales;set @pivot_sql = concat('select region\n\t, ', @dynamic_column_sql, '\nfrom sql_test1.sales \ngroup by region;');prepare stmt from @pivot_sql;execute stmt;deallocate prepare stmt;
end;
call dynamic_pivot();

创建存储过程后，不需要改任何代码，每次只需要 call dynamic_pivot();就可以轻松查看区域对应的产品金额了。

总结

存储过程是MySQL中一种非常有用的数据库对象，可以提高数据库的性能、代码的复用性和数据的安全性。除了实现动态数据透视，它的作用远不止这些，多去实践操作，我相信你会发现更多妙用。

参考资料

  • Mysql 变量的使用
  • Mysql 动态SQL
  • MySQL Documentation Stored Procedures
  • MySQL Tutorial Stored Procedures
  • Mysql 自定义函数

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/589498.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

结构体：修改默认对齐数、结构体传参

结构体：修改默认对齐数、结构体传参

//——————7.修改默认对齐数 #pragma&#xff1a;预处理指令&#xff0c;可以改变我们的默认对齐数。 //#include <stdio.h> //#pragma pack(8)//设置默认对齐数为8//设置的开始 //struct S1 //{ // char c1; // int i; // char c2; //}; //#prag…
阅读更多...
PromQL语法

PromQL语法

PromQL&#xff08;Prometheus Query Language&#xff09;是 Prometheus 内置的数据查询语言&#xff0c;它能实现对事件序列数据的查询、聚合、逻辑运算等。它被广泛应用在 Prometheus 的日常应用当中&#xff0c;包括对数据查询、可视化、告警处理当中。简单地说&#xff0c…
阅读更多...
易趋产品升级（EasyTrack 11_V1.3） | 集成飞书、WPS、个性化设置，增强团队协作和用户体验

易趋产品升级（EasyTrack 11_V1.3） | 集成飞书、WPS、个性化设置，增强团队协作和用户体验

企业在项目管理过程中&#xff0c;经常会遇到项目信息同步不及时、沟通障碍以及管理软件使用不便捷等难题&#xff0c;导致团队协作效率低下。这种情况下&#xff0c;如果使用了多个办公软件&#xff08;如&#xff1a;钉钉、企业微信、项目管理软件等&#xff09;&#xff0c;…
阅读更多...
35--JDK新特性

35--JDK新特性

1、新语法结构 新的语法结构&#xff0c;为我们勾勒出了 Java 语法进化的一个趋势&#xff0c;将开发者从复杂、繁琐的低层次抽象中逐渐解放出来&#xff0c;以更高层次、更优雅的抽象&#xff0c;既降低代码量&#xff0c;又避免意外编程错误的出现&#xff0c;进而提高代码质…
阅读更多...
【VB测绘程序设计】案例6——华氏温度与摄氏温度之间的转换程序（附源代码）

【VB测绘程序设计】案例6——华氏温度与摄氏温度之间的转换程序（附源代码）

【VB测绘程序设计】案例6——华氏温度与摄氏温度之间的转换程序（附源代码） 文章目录 前言一、界面显示二、程序说明三、程序代码1程序变换2程序变换四、数据演示总结前言 本文主要掌握Val（）函数以及String数据类型的应用，通过2个text来输入数据，2个Command控件来执行转换…
阅读更多...
Java——功能开发思路

Java——功能开发思路

目录 前言一、准备工作—准备各类文件1、准备实体类、枚举类、常量类2、准备配置文件 二、先编写Controller三、再编写Service、serviceImpl四、再编写mapper后续敬请期待 前言 Java开发功能简单思路 一、准备工作—准备各类文件 提前知道需要用到哪些类可以提前准备好&#…
阅读更多...
智能客服系统要素分析：提升客户满意度与工作效率的关键要素

智能客服系统要素分析：提升客户满意度与工作效率的关键要素

智能客服系统是企业建立完善服务框架的重要工具。市面上存在着形态各异的各种客服系统&#xff0c;如何选择一款最适合自己企业的产品是很多采购人员想知道的问题。事实上&#xff0c;不同的智能客服系统之间的主要功能并未存在太大的区别&#xff0c;它们往往会在一些亮点功能…
阅读更多...
位运算trick

位运算trick

位运算本质上不是一种算法&#xff0c;而是一种trick&#xff0c;用来节约时间/空间的trick。背后常常有集合论、状态压缩等思想的支撑。这里探讨的位运算指的是其背后的指导思想而不是trick本身。因此对trick本身的证明就略过了。 位运算各种trick的详解请参照灵神的教学贴&a…
阅读更多...
Resilience4j相关面试题及答案

Resilience4j相关面试题及答案

1、什么是Resilience4j&#xff0c;与Hystrix有何不同&#xff1f; Resilience4j是一个为Java 8和函数式编程设计的故障恢复库&#xff0c;它主要利用了Vavr库中的函数式编程概念。Resilience4j提供了一系列的故障恢复机制&#xff0c;包括断路器&#xff08;Circuit Breaker&…
阅读更多...
09 标准库软件模拟I2C时序

09 标准库软件模拟I2C时序

引言&#xff1a; 你需要的I2C知识这里都有&#xff0c; 本文涵盖了I2C的基本知识和在各个主流平台的开发实例&#xff0c; 总之&#xff0c; 你需要的&#xff0c;都在这里&#xff0c; 后续我也会继续更新在嵌入式开发中常见的通信协议。 一、I2C的基本知识 1. I2C介绍 IIC总…
阅读更多...
C++导论

C++导论

C导论 C&#xff08;读作"C plus plus"&#xff09;是一种通用编程语言&#xff0c;由Bjarne Stroustrup在1980年代初期创造。它是C语言的扩展&#xff0c;同时也支持面向对象编程&#xff08;OOP&#xff09;范式。C被广泛用于开发各种类型的应用程序&#xff0c;包…
阅读更多...
留言板（Mybatis连接数据库版）

留言板（Mybatis连接数据库版）

目录 1.添加Mybatis和SQL的依赖 2.建立数据库和需要的表 3.对应表中的字段&#xff0c;补充Java对象 4.对代码进行逻辑分层 5.后端逻辑代码 之前的项目实例【基于Spring MVC的前后端交互案例及应用分层的实现】https://blog.csdn.net/weixin_67793092/article/details/134…
阅读更多...
HTTPS协议详解

HTTPS协议详解

目录 前言 一、HTTPS协议 1、加密是什么 2、为什么要加密 二、常见加密方式 1、对称加密 2、非对称加密 三、数据摘要与数据指纹 1、数据摘要 2、数据指纹 四、HTTPS加密策略探究 1、只使用对称加密 2、只使用非对称加密 3、双方都使用非对称加密 4、对称加密非…
阅读更多...
html-css-js使用axios和ajax获取接口并携带请求头+获取输入框或选择器内容

html-css-js使用axios和ajax获取接口并携带请求头+获取输入框或选择器内容

需求&#xff1a;使用axios或者Ajax获取接口&#xff0c;有些需要获取到输入框&#xff0c;或者选择器内容之后传给接口&#xff0c;也就是写了几种不同请求的方法&#xff0c;网上有很多方法&#xff0c;本文章算是个归纳吧。 一、axios请求传参请求头 1.github下载axios 我…
阅读更多...
MS2358：96KHz、24bit 音频 ADC

MS2358：96KHz、24bit 音频 ADC

产品简述 MS2358 是带有采样速率 8kHz-96kHz 的立体声音频模数 转换器&#xff0c;适合于面向消费者的专业音频系统。 MS2358 通过使用增强型双位 Δ - ∑ 技术来实现其高精度 的特点。 MS2358 支持单端的模拟输入&#xff0c;所以不需要外部器 件&#xff0c;非常适…
阅读更多...
C++每日一练（7）：爬山

C++每日一练（7）：爬山

题目描述 LeiQ最近参加了一个登山俱乐部&#xff0c;部长给他了一个n*m地图,地图上的每一个格子的值表示一个山的海拔高度&#xff0c;LeiQ现在在(x,y)表示在地图上的位置,他想要登上地图上最高的山&#xff0c;所以他想知道他爬上最高的山的山顶还需向上爬多少米。 例如: x\y…
阅读更多...
领域驱动设计（Domain-Driven Design DDD)——模型驱动设计的构造块2

领域驱动设计（Domain-Driven Design DDD)——模型驱动设计的构造块2

书接上回领域驱动设计&#xff08;Domain-Driven Design DDD)——模型驱动设计的构造块1-CSDN博客 四、领域对象的生命周期 每个对象都有生命周期&#xff0c;管理这些对象面临诸多挑战&#xff0c;主要的挑战有以下两类。 在整个生命周期中维护完整性 防止模型陷入管理…
阅读更多...
内侧APP分发平台：移动应用开发的加速器

内侧APP分发平台：移动应用开发的加速器

在数字化时代&#xff0c;移动应用已成为企业触达用户的重要渠道。为了迅速占领市场&#xff0c;开发者需要一种能够快速发布和测试移动应用的解决方案。内侧APP分发平台应运而生&#xff0c;它通过简化应用的封装、测试和分发流程&#xff0c;极大地提升了移动应用的上市速度。…
阅读更多...
【v8漏洞利用模板】starCTF2019 -- OOB

【v8漏洞利用模板】starCTF2019 -- OOB

文章目录 前言参考题目环境配置漏洞分析与测试漏洞利用通用技巧各种数据类型转换如何泄漏 libcWASM 执行 shellcode利用相关函数模板 前言 一道入门级别的 v8 题目&#xff0c;不涉及太多的 v8 知识&#xff0c;很适合入门&#xff0c;对于这个题目&#xff0c;网上已经有很多…
阅读更多...
Golang学习之路一四常量与枚举

Golang学习之路一四常量与枚举

Golang学习之路一四常量与枚举 常量 const 关键字 定义常量 package mainimport "fmt"// 声明在函数外部 const filename "123.txt"const (username "admin"password "admin" )func main() {// 声明在函数的内部const filename …
阅读更多...
最新文章

Copyright @ 2022~2023