前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >MySQL存储过程举例

MySQL存储过程举例

作者头像
July
发布2020-05-17 20:36:28
5980
发布2020-05-17 20:36:28
举报
文章被收录于专栏:数据库干货铺数据库干货铺

存储过程可能是很多人都比较喜欢使用的,但MySQL不建议使用存储过程,如果临时用的话可以考虑。

本次简单介绍今天协助一位读者的实现的简单需求的存储过程,其中涉及循环、动态sql等主要的MySQL存储过程知识点。

需求:

遍历所有【test_ondev_0-9】开头的表,将其中的所有数据按表中的col字段存储到【test_ondev_history_ + col的值】的表里面,当【test_ondev_history_ + col】不存在的时候复制test_ondev_history的结构创建该表,并将数据存储进表里。

程序思路:

  • 遍历表名
  • 将每张表的col字段的内容统计出来
  • 创建 test_ondev_history_ + col 的表
  • 将数据插入进去test_ondev_history_ + col表中
  • 继续遍历其他表

使用存储过程实现:

代码语言:txt
复制
DELIMITER $$

CREATE PROCEDURE `p_copy_data`()
    BEGIN
    
    DECLARE i INT;
   
    DECLARE  v_sql_col VARCHAR(200);
    DECLARE j INT;
    DECLARE max_id_s INT;
    DECLARE max_id INT;
    DECLARE v_tbname VARCHAR(50);
    DECLARE v_tbname_s VARCHAR(50);
    DECLARE v_col VARCHAR(50);
    DECLARE  v_sql_create VARCHAR(200);
    DECLARE  v_sql_insert VARCHAR(200);

    
    CREATE TABLE IF NOT EXISTS temp_col(id INT PRIMARY KEY AUTO_INCREMENT,col VARCHAR(50));
    CREATE TABLE IF NOT EXISTS tbnames(id INT PRIMARY KEY AUTO_INCREMENT,tbname VARCHAR(50));
    TRUNCATE TABLE tbnames;
    INSERT INTO tbnames(tbname)
    SELECT  table_name FROM information_schema.`TABLES` WHERE table_name REGEXP   'test_ondev_[0-9]';
      SET i = (SELECT MIN(id) FROM   tbnames);
     SET  max_id_s = (SELECT MAX(id) FROM   tbnames);
        
    WHILE  i <=max_id_s
    DO
    TRUNCATE TABLE  temp_col;
    SET v_tbname_s = (SELECT tbname FROM  tbnames  WHERE id = i);
    SET v_sql_col = CONCAT('insert into temp_col(col)  select distinct   col  from  ',v_tbname_s);
    SET  @v_sql_col := v_sql_col;
    PREPARE stmt FROM @v_sql_col;
    EXECUTE stmt ;
    DEALLOCATE PREPARE stmt;

    SET j =1;
    SET  max_id = (SELECT  MAX(id) FROM temp_col );
    WHILE  j <= max_id
    DO
    SET  v_col = (SELECT col  FROM temp_col  WHERE id =j);
    SET v_tbname = CONCAT('test_ondev_history_',v_col );
    SET v_sql_create = CONCAT('create table  if not exists ',v_tbname,'  like test_ondev_history;');
    SET  @v_sql_create := v_sql_create;
    PREPARE stmt FROM @v_sql_create;
    EXECUTE stmt ;
    DEALLOCATE PREPARE stmt;
        SET  v_sql_insert = CONCAT('insert into ',v_tbname,' select * from ',v_tbname_s," where  col='", v_col ,"';");
        
        SET  @v_sql_insert := v_sql_insert;
    PREPARE stmt FROM @v_sql_insert;
    EXECUTE stmt ;
    DEALLOCATE PREPARE stmt;
    
    SET j = j + 1;
    END WHILE;
    
    SET  i = i + 1;
    END  WHILE;
    

    END$$

TIPS:

MySQL不建议使用存储过程,如果临时用的话可以考虑临时使用。

另外,该过程是第一版实现历史数据的迁移,如果需要重复执行还有不少优化空间,例如:

  • 遍历表的时候需要指定对应库;
  • 上述过程不能重复执行,如果重复执行,需要怎么改进;
  • 中途涉及创建表,如果不创建哪些临时表改如何调整;

这些就留给大家思考了,也欢迎来和我沟通。文章如果有误,欢迎斧正 ,非常感谢。

本文参与 腾讯云自媒体分享计划,分享自微信公众号。
原始发表:2020-05-07,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 数据库干货铺 微信公众号,前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体分享计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
相关产品与服务
云数据库 SQL Server
腾讯云数据库 SQL Server (TencentDB for SQL Server)是业界最常用的商用数据库之一,对基于 Windows 架构的应用程序具有完美的支持。TencentDB for SQL Server 拥有微软正版授权,可持续为用户提供最新的功能,避免未授权使用软件的风险。具有即开即用、稳定可靠、安全运行、弹性扩缩等特点。
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档