具体不多说,直接上代码。欢迎一起交流和学习。
创建一个按月创建表的存储过程,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,切勿直接套用,造成损失与本博文无关。鉴于学习交流初心发表此处,仅供大家学习交流参考用。
到此这篇关于mysql之存储过程按月创建表的方法步骤的文章就介绍到这了,更多相关mysql 按月创建表内容请搜索www.887551.com以前的文章或继续浏览下面的相关文章希望大家以后多多支持www.887551.com!