MYSQL如何对数据进行自动化升级--以如果某数据表存在并且某字段不存在时则执行更新操作为例

数据库小白一枚，正在不断学习积累知识，现将学习到的知识记录一下，也是将我的所得分享给大家！而今天这篇文章《MYSQL如何对数据进行自动化升级--以如果某数据表存在并且某字段不存在时则执行更新操作为例》带大家来了解一下MYSQL如何对数据进行自动化升级--以如果某数据表存在并且某字段不存在时则执行更新操作为例，希望对大家的知识积累有所帮助，从而弥补自己的不足，助力实战开发！

我们在进行新的功能开发时，由于历史项目的存在，需要在程序起动时对数据进行判断，如果发现是历史版本的数据，则需要对数据进行一些特定的处理；如果是最新的数据，则跳过处理过程。这在系统的版本迭代中尤为重要！本文将阐述如何自动化的实现该过程。

何为自动化

1. 每次系统启动，均执行一次我们设定好的SQL语句。
2. 当数据表存在且未升级时，进行数据表的升级操作。
3. 当数据表不存在或数据已经升过级时，不对数据表进行操作。

功能描述

在数据库

-- 将 ; 转义为 // (即遇到//才相当于;) 防止定义 存储过程 时中，遇到 ; 而中断的问题。
DELIMITER //
-- 如果存在存储过程（sql函数）FUN20180516则将其删除
DROP PROCEDURE IF EXISTS `FUN20180516` //
-- 新建存储过程（sql函数），起名为：FUN20180518。相当于C中的(void FUN20180516())
CREATE PROCEDURE `FUN20180516` ()
-- 定义函数开始（相当于C中的 { )
BEGIN
--     声明变量 int hasDb
    DECLARE hasDb INT;
    DECLARE hasDbType INT;
--     执行语句(查询数据表是否存在)，并将返回值给hasDb
   SELECT count(*) INTO hasDb FROM information_schema.tables WHERE (table_schema = 'measurement') AND (table_name= 'web_app_menu');
--     如果数据表存在（注意：用=来判断，而不是==)
    IF hasDb = 1 THEN
--         判断字段是否存在
        SELECT count(*) INTO hasDbType FROM information_schema.columns WHERE (table_schema = 'measurement') and (table_name= 'web_app_menu') and (column_name = 'db_type');
--         字段不存在，则执行以下代码    
        IF hasDbType = 0 THEN
            ALTER TABLE `web_app_menu` ADD `db_type` VARCHAR(31) NOT NULL;
            UPDATE `web_app_menu` SET `db_type` = 'web_app_menu' WHERE db_type = '';
            DELETE wr.* FROM web_app_menu_role wr WHERE wr.web_app_menu_id IN (SELECT w.id FROM web_app_menu w WHERE w.id IN (select w1.p_id FROM web_app_menu w1 WHERE w.route_name = 'measurementStandardAssessmentApply'));
            DELETE wr.* FROM web_app_menu_role wr WHERE wr.web_app_menu_id IN (SELECT w.id FROM web_app_menu w WHERE w.route_name = 'measurementStandardAssessmentApply');
            DELETE w.* FROM web_app_menu w WHERE w.p_id IN (SELECT id FROM (SELECT id FROM web_app_menu w2 WHERE w2.route_name = 'measurementStandardAssessmentApply') x);
            DELETE w.* FROM web_app_menu w WHERE w.route_name = 'measurementStandardAssessmentApply';
--             控制台打印日志
            SELECT '20180516 success';
        end if;
    END IF;
-- 下面我们用 // 相当于 END ;也就是说，我们的函数定义完了，你可以一并进行加载了。
END //
-- 再将 ; 恢复为 ;。防止后面的语句中，使用; 而不生效的问题
DELIMITER ;
-- 调用函数
call FUN20180516();

结合spring

首先：

-- spring.datasource.separator=//已经过;进行了改写
-- 如果存在存储过程（sql函数）FUN20180516则将其删除
DROP PROCEDURE IF EXISTS `FUN20180516` //
-- 新建存储过程（sql函数），起名为：FUN20180518。相当于C中的(void FUN20180516())
CREATE PROCEDURE `FUN20180516` ()
    -- 定义函数开始（相当于C中的 { )
    BEGIN
        --  声明变量 int hasDb
        DECLARE hasDb INT;
        DECLARE hasDbType INT;
        --  执行语句(查询数据表是否存在)，并将返回值给hasDb
        SELECT count(*) INTO hasDb FROM information_schema.tables WHERE (table_schema = 'measurement') and (table_schema = 'measurement') AND (table_name= 'web_app_menu');
        --  如果数据表存在（注意：用=来判断，而不是==)
        IF hasDb = 1 THEN
            --      判断字段是否存在
            SELECT count(*) INTO hasDbType FROM information_schema.columns WHERE (table_name= 'web_app_menu') and (column_name = 'db_type');
            --      字段不存在，则执行以下代码
            IF hasDbType = 0 THEN
                ALTER TABLE `web_app_menu` ADD `db_type` VARCHAR(31) NOT NULL;
                UPDATE `web_app_menu` SET `db_type` = 'web_app_menu' WHERE db_type = '';
                DELETE wr.* FROM web_app_menu_role wr WHERE wr.web_app_menu_id IN (SELECT w.id FROM web_app_menu w WHERE w.id IN (select w1.p_id FROM web_app_menu w1 WHERE w.route_name = 'measurementStandardAssessmentApply'));
                DELETE wr.* FROM web_app_menu_role wr WHERE wr.web_app_menu_id IN (SELECT w.id FROM web_app_menu w WHERE w.route_name = 'measurementStandardAssessmentApply');
                DELETE w.* FROM web_app_menu w WHERE w.p_id IN (SELECT id FROM (SELECT id FROM web_app_menu w2 WHERE w2.route_name = 'measurementStandardAssessmentApply') x);
                DELETE w.* FROM web_app_menu w WHERE w.route_name = 'measurementStandardAssessmentApply';
                --          控制台打印日志
                SELECT '20180516 success';
            end if;
        END IF;
    END //
-- 调用函数
call FUN20180516() //

application.properties

spring.datasource.separator=//

参考

http://www.cnblogs.com/geaozh...
http://blog.sina.com.cn/s/blo...
https://www.techonthenet.com/...
https://dba.stackexchange.com...
https://docs.spring.io/spring...
https://stackoverflow.com/que...

今天关于《MYSQL如何对数据进行自动化升级--以如果某数据表存在并且某字段不存在时则执行更新操作为例》的内容介绍就到此结束，如果有什么疑问或者建议，可以在golang学习网公众号下多多回复交流；文中若有不正之处，也希望回复留言以告知！