MySQL之存儲過程按月建立表

時間 2020-09-11

標籤 mysql 存儲過程按月建立欄目 MySQL 简体版

原文原文鏈接

具體很少說，直接上代碼。歡迎一塊兒交流和學習。
建立一個按月建立表的存儲過程，SQL語句以下:mysql

DELIMITER // 
DROP PROCEDURE IF EXISTS create_table_by_month //
CREATE PROCEDURE `create_table_by_month`()
BEGIN

    #--提早申明變量,後面會用到
        DECLARE nextMonth varchar(20);
        DECLARE nextTABLE varchar(20);
        DECLARE csql varchar(5210);
        DECLARE outputParam int;
        DECLARE tableName_1 varchar(20);
        DECLARE tableName_2 varchar(20);
        DECLARE table_prefix varchar(20);

    #--獲取下個月
    SELECT SUBSTR(replace(DATE_ADD(CURDATE(), INTERVAL 1 MONTH), '-', ''), 1, 6) INTO @nextMonth;
    #--對上面的SQL語句拆分分析:
    #MySQL時間函數date_add()爲日期增長一個時間間隔，此sql的意思就是當前日期增長一個月後的日期
    #select DATE_ADD(CURDATE(), INTERVAL 1 MONTH); 
    ##返回20201006
    #select replace('2020-10-06', '-', '');
    ##返回20201006
    #select replace(DATE_ADD(CURDATE(), INTERVAL 1 MONTH), '-', '');
    ##返回202010
    #SELECT SUBSTR(20201006,1,6);
    ##賦值到變量@nextMonth 中
    #SELECT SUBSTR(20201006,1,6) INTO @nextMonth;

# 表1
        #設置表前綴變量值爲td_user_banks_log_
        set @table_prefix = 'td_user_banks_log_';

        #定義表1的名稱
        SET @tableName_1 = CONCAT(@table_prefix, @nextMonth);
        ##定義建立表的SQL語句
        set @csql=concat("create table if not exists ",@tableName_1,"(
                `id` int(11) NOT NULL AUTO_INCREMENT,
                `app_id` varchar(100) NOT NULL,
                `user_id` int(11) NOT NULL DEFAULT '0' COMMENT '用戶ID',
                `type` tinyint(2) NOT NULL DEFAULT '1' COMMENT '1 簽到獎勵 2 活動獎勵 3 兌換',
                `gold_coin` int(11) NOT NULL,
                `remarks` varchar(200) NOT NULL DEFAULT '' COMMENT '備註',
                `create_at` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP,
                PRIMARY KEY (`id`),
                KEY `app_id` (`app_id`),
                KEY `user_id` (`user_id`),
                KEY `type` (`type`),
                KEY `create_at` (`create_at`)
            ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;");
    #PREPARE介紹：
    ##語句用於預備一個語句，並指定名稱statement_name，之後引用該語句。語句名稱對大小寫不敏感。
    ##preparable_stmt能夠是一個文字字符串，也能夠是一個包含了語句文本的用戶變量。該文本必須表現爲一個單一的SQL語句，而不是多個語句。
    PREPARE create_stmt from @csql;  
        EXECUTE create_stmt;
    DEALLOCATE PREPARE  create_stmt;

# 表2 和表1是一樣的SQL，此處不作介紹:
        set @table_prefix = 'td_sign_log_';

        SET @tableName_2 = CONCAT(@table_prefix, @nextMonth);

        set @csql=concat("create table if not exists ",@tableName_2,"(
            `id` int(11) NOT NULL AUTO_INCREMENT,
            `app_id` varchar(100) NOT NULL,
            `user_id` int(11) NOT NULL,
            `day` int(11) NOT NULL DEFAULT '0' COMMENT '天',
            `sign_type` tinyint(2) NOT NULL DEFAULT '1' COMMENT '1 簽到 2 補籤  3 累計獎勵',
            `type` tinyint(2) NOT NULL DEFAULT '1' COMMENT '1 金幣',
            `num` int(11) NOT NULL DEFAULT '0',
            `data_id` int(11) NOT NULL DEFAULT '0',
            `create_at` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP,
            PRIMARY KEY (`id`),
            KEY `app_id` (`app_id`),
            KEY `user_id` (`user_id`),
            KEY `type` (`type`),
            KEY `data_id` (`data_id`),
            KEY `create_at` (`create_at`),
            KEY `sign_type` (`sign_type`),
            KEY `day` (`day`)
        ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;");

        PREPARE create_stmt from @csql;  
        EXECUTE create_stmt;
        DEALLOCATE PREPARE  create_stmt;

        SELECT COUNT(1) INTO @outputParam  FROM information_schema.`TABLES` WHERE TABLE_NAME in (@tableName_1, @tableName_2);
        SELECT @outputParam;

END //
delimiter ;

#--每個月建立一個當月表的定時任務:sql

create  EVENT `create_table_by_month` ON SCHEDULE EVERY 1 MONTH STARTS '2020-09-06 12:40:00' ON COMPLETION NOT PRESERVE ENABLE DO call create_table_by_month();

常識提示：在計劃任務中，某個具體的時間來調用存儲過程SQL1語句執行。這個指定的具體時間必須是未來的時間才能夠的app

#查看建立存儲過程的SQL語句:ide

show create  PROCEDURE create_table_by_month\G

#刪除存儲過程:函數

DROP PROCEDURE IF EXISTS create_table_by_month;

#刪除計劃任務學習

drop event create_table_by_month1;

以上存儲過程的SQL語句和定時器的SQL語句都是生產環境使用過的日誌

#排查報錯：
發現mysql的日誌報錯，原來的存儲過程的SQL語句裏面增長的索引鍵字段正好是表中不存在的字段，因此包下面的錯誤。因而去掉存儲過程當中的索引鍵字段SQL就OK了。code

2020-09-06T12:40:00.244879+08:00 604392 [ERROR] Event Scheduler: [root@localhost][test0001.create_table_by_month1] Key column 'sign_date' doesn't exist in table
2020-09-06T12:40:00.244926+08:00 604392 [Note] Event Scheduler: [root@localhost].[test0001.create_table_by_month1] event execution failed.

上述的存儲過程只是本博主線上業務環境的SQL,切勿直接套用,形成損失與本博文無關。鑑於學習交流初心發表此處，僅供你們學習交流參考用。orm