MySQL 存储过程编写指南

编程并不是一个机械性的工作，而是需要有思考，有创新的工作，语法是固定的，但解决问题的思路则是依靠人的思维，这就需要我们坚持学习和更新自己的知识。今天golang学习网就整理分享《MySQL 存储过程编写指南》，文章讲解的知识点主要包括MySQL、存储过程，如果你对数据库方面的知识点感兴趣，就不要错过golang学习网，在这可以对大家的知识积累有所帮助，助力开发能力的提升。

引言

因标签过多，在实际的应用过程中，对标签表的结构进行了变更。

从过去的标签随意选择，现在需要对标签进行分类，简化选择难度。添加科目分类之后，需要对历史上已经被使用过的标签添加科目信息，进行数据的迁移工作。

在数据迁移时，使用到了存储过程，遇到了诸多问题，特此记录，分享爬坑过程。

存储过程

存储过程（

-- 标识符替换
DELIMITER $$

-- 存储过程定义

-- 重新定义标识符
DELIMITER ;

定义存储过程

-- 存储过程
CREATE PROCEDURE procedure_name(IN param BIGINT)
BEGIN

  -- 存储过程具体实现

END$$

游标示例

请重点注意以下示例代码中的顺序问题，一定是先声明变量，再声明游标，再处理，否则

-- 声明变量
DECLARE tag_id BIGINT;
DECLARE done INT DEFAULT FALSE;
-- 声明游标
DECLARE cur CURSOR FOR SELECT `id` FROM `tag`;
-- 声明 not found 处理
DECLARE CONTINUE HANDLER FOR NOT FOUND SET done = TRUE;

OPEN cur;
FETCH cur INTO tag_id;

WHILE NOT done DO
  -- 遍历标签表 逐条迁移数据
  CALL migrate_tag_info_by_id(tag_id);
  FETCH cur INTO tag_id;
END WHILE;

HANDLER

需要重点注意以下代码：

-- 声明 not found 处理
DECLARE CONTINUE HANDLER FOR NOT FOUND SET done = TRUE;

去查阅相关博客，声明

WHILE NOT done DO
  -- 遍历标签表 逐条迁移数据
  CALL migrate_tag_info_by_id(tag_id);
  FETCH cur INTO tag_id;
END WHILE;

调试方法

编写存储过程最难的就是写了几十行代码的存储过程，执行的时候错误不是按行报的，而是一类通用的错误，非常难调试。

在查阅相关资料后，

-- 标识符替换
DELIMITER $$

-- 存储过程 根据标签 id 迁移试题对标签的引用数据
CREATE PROCEDURE migrate_subject_tag_ref_by_id(IN tag_id BIGINT)
BEGIN

  DECLARE tag_name VARCHAR(255);
  DECLARE subject_id BIGINT;
  DECLARE course_id BIGINT;
  DECLARE tag_ref_id BIGINT;
  DECLARE done INT DEFAULT FALSE;

  DECLARE cur CURSOR FOR
  SELECT `subject`.`id`, `subject`.`course_id`
  FROM `subject_tags`
  INNER JOIN `subject`
  ON `subject_tags`.`subjects_id` = `subject`.`id`
  WHERE `subject_tags`.`tags_id` = tag_id;

  DECLARE CONTINUE HANDLER FOR NOT FOUND SET done = TRUE;

  SELECT `name` INTO tag_name FROM `tag` WHERE `id` = tag_id;

  OPEN cur;
  FETCH cur INTO subject_id, course_id;

  WHILE NOT done DO

    SELECT `id` INTO tag_ref_id FROM `tag`
    WHERE `tag`.`name` = tag_name AND `tag`.`course_id` = course_id;

    UPDATE `subject_tags` SET `tags_id` = tag_ref_id
    WHERE `subjects_id` = subject_id AND `tags_id` = tag_id;

    FETCH cur INTO subject_id, course_id;
  END WHILE;

END$$

-- 存储过程 根据标签 id 迁移新标签数据
CREATE PROCEDURE migrate_tag_info_by_id(IN tag_id BIGINT)
BEGIN

  DECLARE tag_name VARCHAR(255);
  DECLARE course_id BIGINT;
  DECLARE done INT DEFAULT FALSE;

  DECLARE cur CURSOR FOR
  SELECT `subject`.`course_id`
  FROM `subject_tags`
  INNER JOIN `subject`
  ON `subject_tags`.`subjects_id` = `subject`.`id`
  WHERE `subject_tags`.`tags_id` = tag_id
  GROUP BY `subject`.`course_id`;

  DECLARE CONTINUE HANDLER FOR NOT FOUND SET done = TRUE;

  SELECT `name` INTO tag_name FROM `tag` WHERE `id` = tag_id;

  OPEN cur;
  FETCH cur INTO course_id;

  WHILE NOT done DO
    -- 创建新标签
    INSERT INTO `tag`(`name`, `course_id`) VALUES(tag_name, course_id);
    FETCH cur INTO course_id;
  END WHILE;

  -- 迁移对历史标签的引用
  CALL migrate_subject_tag_ref_by_id(tag_id);
  -- 删除历史标签
  DELETE FROM `tag` WHERE `tag`.`id` = tag_id;

END$$

-- 存储过程 迁移所有标签数据
CREATE PROCEDURE migrate_all_tag_info()
BEGIN

  DECLARE tag_id BIGINT;
  DECLARE done INT DEFAULT FALSE;
  DECLARE cur CURSOR FOR SELECT `id` FROM `tag`;
  DECLARE CONTINUE HANDLER FOR NOT FOUND SET done = TRUE;

  OPEN cur;
  FETCH cur INTO tag_id;

  WHILE NOT done DO
    -- 遍历标签表 逐条迁移数据
    CALL migrate_tag_info_by_id(tag_id);
    FETCH cur INTO tag_id;
  END WHILE;

END$$
-- 重新定义标识符
DELIMITER ;

CALL migrate_all_tag_info();

版权声明

本文作者：河北工业大学梦云智开发团队 - 张喜硕

好了，本文到此结束，带大家了解了《MySQL 存储过程编写指南》，希望本文对你有所帮助！关注golang学习网公众号，给大家分享更多数据库知识！