MySQL之存储过程按月创建表的方法步骤
作者:wjw555 发布时间:2024-01-25 02:40:40
标签:MySQL,存储过程,按月创建表
具体不多说,直接上代码。欢迎一起交流和学习。
创建一个按月创建表的存储过程,SQL语句如下:
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 ;
#--每月创建一个当月表的定时任务:
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语句执行。这个指定的具体时间必须是将来的时间才可以的
#查看创建存储过程的SQL语句:
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了。
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,切勿直接套用,造成损失与本博文无关。鉴于学习交流初心发表此处,仅供大家学习交流参考用。
来源:https://blog.51cto.com/wujianwei/2529168
0
投稿
猜你喜欢
- 笔者在网站开发中,采用PHP4.0+MySQL3.23.38建立了多种应用。下面,以一个简单的聊天室设计为例,介绍PHP+MySQL在网页开
- phpinfo函数phpinfo函数 PHP中提供了PHPInfo()函数,该函数返回 PHP 的所有信息,包括了 PHP 的编译选项及扩充
- 本文实例讲述了Python 类的私有属性和私有方法。分享给大家供大家参考,具体如下:xx:公有变量_xx:公有变量或方法,不能通过impor
- 你也许已经掌握了id、class、后台选择器这些基本的css选择器。但这远远不是css的全部。下面向大家系统的解析css中30个最常用的选择
- Win7安装mysql的具体过程,我的版本是5.5.21 以下是我的安装步骤:1、首先单击MySQL5.5.21的安装文件,出现该数据库的安
- scrapy是一个基于Twisted的异步处理框架,可扩展性很强。优点此处不再一一赘述。下面介绍一些概念性知识,帮助大家理解scrapy。一
- 什么是docstring在软件工程中,其实编码所占的部分是非常小的,大多是其它的事情,比如写文档。文档是沟通的工具。 在Python中,比较
- 1、网页在加载时,页面代码中的js文件引用(如下)都会向服务器产生http请求,因为在body.onload事件之前加载的文件(这里我称之为
- 我就废话不多说了,大家还是直接看代码吧!import socketimport sysimport timeimport structHOS
- 一、前言这篇文章主要是记录一下php生成静态页面的大致步骤,关于页面静态化,大家想必都听说过,但是真正用的时候反而不是很多。有些页面考虑到访
- 第一、几种常用方法读取TXT文档:urlopen()读取PDF文档:pdfminer3k第二、乱码问题(1)、from urllib.req
- Infopath的使用避免了最终用户以完全手写的方式生成XML数据文件,同时也可以统一XML文件的格式,在MOSS系统和网站开发中被广泛使用
- 1. 带默认值的参数在了解带星号(*)的参数之前,先看下带有默认值的参数,函数定义如下:>> def defaultValueA
- 通过三种方式给大家介绍,具体详情如下所示:方式一:原理:创建一个新的空字典,用循环的方式来获取列表中的每一个元素,判断获取的元素是否存在字典
- 本文实例为大家分享了OpenCV+face++实现实时人脸识别解锁功能的具体代码,供大家参考,具体内容如下1.背景最近做一个小东西,需要登录
- javascript的分号代表语句的结束符,但由于javascript具有分号自动插入规则,所以它是一个十分容易让人模糊的东西,在一般情况下
- 什么是集合1.集合是一个可变容器2.集合内的数据对象都是唯一的(不能重复)3.集合是无序的存储结构,集合内的数据没有先后关系4.集合是可迭代
- AlexNet是2012年ImageNet比赛的冠军,虽然过去了很长时间,但是作为深度学习中的经典模型,AlexNet不但有助于我们理解其中
- 本文实例讲述了Python实现的摇骰子猜大小功能小游戏。分享给大家供大家参考,具体如下:最近学习Python的随机数,逻辑判断,循环的用法,
- 额。。。每个请求都有token值的传入,但是token非常易变,一旦变化,所有的接口用例都得改一遍token,工作量太大了。。。那么有没有一