MySql 定时任务和存储过程,每月创建一张表

2024-04-17 05:48

本文主要是介绍MySql 定时任务和存储过程,每月创建一张表,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

最近用MySQL做了一个每月1号00:00:00创建一张表并将上个月的表数据导入到新创建的表中,在此做个小记。

1. 要做这个之前先要:

    -- 设置好时区set time_zone = '+8:00';-- 开启事件调度器set GLOBAL event_scheduler = 1;-- 选择数据库use test;

2. 先创建一个存储过程或者函数:

-- 创建create_table_app_open_log_month表的存储过程
CREATE PROCEDURE create_table_app_open_log_month()
BEGIN
DECLARE `@suffix` VARCHAR(15);
DECLARE `@sqlstr` VARCHAR(2560);
SET `@suffix` = DATE_FORMAT(DATE_SUB(NOW(),INTERVAL 1 MONTH),'_%Y%m');
SET @sqlstr = CONCAT(
"CREATE TABLE jc_",
`@suffix`,
"(`id` int(11) NOT NULL AUTO_INCREMENT,`i_company` varchar(255) COLLATE utf8_bin DEFAULT NULL,`ii_company` varchar(255) COLLATE utf8_bin DEFAULT NULL,`iii_company` varchar(255) COLLATE utf8_bin DEFAULT NULL,`iv_company` varchar(255) COLLATE utf8_bin DEFAULT NULL,`iclass_name` varchar(255) COLLATE utf8_bin DEFAULT NULL,`iiclass_name` varchar(255) COLLATE utf8_bin DEFAULT NULL,`iiiclass_name` varchar(255) COLLATE utf8_bin DEFAULT NULL,`ivclass_name` varchar(255) COLLATE utf8_bin DEFAULT NULL,`work_no` varchar(255) COLLATE utf8_bin DEFAULT NULL,`name` varchar(255) COLLATE utf8_bin DEFAULT NULL,`sex` varchar(255) COLLATE utf8_bin DEFAULT NULL,`birthday` date DEFAULT NULL,`rz_date` date DEFAULT NULL,`siling` decimal(3,1) DEFAULT NULL,`age` int(11) DEFAULT NULL,`zhiwei` varchar(255) COLLATE utf8_bin DEFAULT NULL,`zhilei` varchar(255) COLLATE utf8_bin DEFAULT NULL,`zhizhong` varchar(255) COLLATE utf8_bin DEFAULT NULL,`zhideng` varchar(255) COLLATE utf8_bin DEFAULT NULL,`zhiji` varchar(255) COLLATE utf8_bin DEFAULT NULL,`fxueli` varchar(255) COLLATE utf8_bin DEFAULT NULL,`fschool` varchar(255) COLLATE utf8_bin DEFAULT NULL,`fzhuanye` varchar(255) COLLATE utf8_bin DEFAULT NULL,`ftype` varchar(255) COLLATE utf8_bin DEFAULT NULL,`hxueli` varchar(255) COLLATE utf8_bin DEFAULT NULL,`hxuewei` varchar(255) COLLATE utf8_bin DEFAULT NULL,`hschool` varchar(255) COLLATE utf8_bin DEFAULT NULL,`hzhuanye` varchar(255) COLLATE utf8_bin DEFAULT NULL,`htype` varchar(255) COLLATE utf8_bin DEFAULT NULL,`zhicheng` varchar(255) COLLATE utf8_bin DEFAULT NULL,`zc_level` varchar(255) COLLATE utf8_bin DEFAULT NULL,`zyzg` varchar(255) COLLATE utf8_bin DEFAULT NULL,`zzmm` varchar(255) COLLATE utf8_bin DEFAULT NULL,`hyzk` varchar(255) COLLATE utf8_bin DEFAULT NULL,`syzk` varchar(255) COLLATE utf8_bin DEFAULT NULL,`cy_date` date DEFAULT NULL,`lsgl` decimal(3,1) DEFAULT NULL,`zhuangtai` tinyint(4) DEFAULT NULL,`w_date` date DEFAULT NULL,`lz_date` date DEFAULT NULL,PRIMARY KEY (`id`),UNIQUE KEY `work_no` (`work_no`)
) ENGINE=InnoDB AUTO_INCREMENT=129 DEFAULT CHARSET=utf8 COLLATE=utf8_bin;"
);
PREPARE stmt FROM @sqlstr;
EXECUTE stmt;END;

给表插入数据

CREATE PROCEDURE insert_table_app_open_log_month() 
BEGIN
SET @suffix = DATE_FORMAT(DATE_SUB(NOW(),INTERVAL 1 MONTH),'_%Y_%m'); 
SET @tableName = CONCAT("jc" ,@suffix);SET @InsertStr = CONCAT("insert into ",@tableName," select * from jichu");
PREPARE stmt FROM @InsertStr;
EXECUTE stmt;
SET @InsertGuid = CONCAT("insert into guidang(table_name) VALUES('",@tableName,"')");PREPARE stmt FROM @InsertGuid;
EXECUTE stmt;
END
END;

上面带变量的sql语句一定要注意空格。

3. 创建定时任务或者叫调度器事件:

DELIMITER $$
SET GLOBAL event_scheduler = 1;
CREATE EVENT event_create_table_every_month2
ON SCHEDULE EVERY 1 MONTH
STARTS '2021-12-06 15:03:00'
ON  COMPLETION  PRESERVE
ENABLE
DO
BEGIN
CALL create_table_app_open_log_month();
CALL insert_table_app_open_log_month();
END$$  
-- 将分隔符重置为;
DELIMITER ;
-- 创建定时任务
-- 以$$作为分隔符
DELIMITER $$  
SET GLOBAL event_scheduler = 1;  
-- 事件名
CREATE EVENT event_create_table_every_month
-- 间隔一个月  
ON SCHEDULE EVERY 1 MONTH
-- 第一次执行时间
STARTS date_add(date_add(date_sub(curdate(),interval day(curdate())-1 day), interval 1 month),interval 0 hour) 
ON  COMPLETION  PRESERVE  
ENABLE  
DO  
BEGIN  
-- 要调用的函数或者存储过程
CALL create_table_app_open_log_month();
END $$  
-- 将分隔符重置为;
DELIMITER ;

参考:MySql 定时任务和存储过程,每月创建一张表_xl_love的专栏-CSDN博客

Mysql用存储过程和事件每月定时创建一张数据库表_https的技术博客_51CTO博客_mysql创建存储过程

这篇关于MySql 定时任务和存储过程,每月创建一张表的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/910941

相关文章

MySQL的JDBC编程详解

《MySQL的JDBC编程详解》:本文主要介绍MySQL的JDBC编程,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录前言一、前置知识1. 引入依赖2. 认识 url二、JDBC 操作流程1. JDBC 的写操作2. JDBC 的读操作总结前言本文介绍了mysq

java.sql.SQLTransientConnectionException连接超时异常原因及解决方案

《java.sql.SQLTransientConnectionException连接超时异常原因及解决方案》:本文主要介绍java.sql.SQLTransientConnectionExcep... 目录一、引言二、异常信息分析三、可能的原因3.1 连接池配置不合理3.2 数据库负载过高3.3 连接泄漏

Linux下MySQL数据库定时备份脚本与Crontab配置教学

《Linux下MySQL数据库定时备份脚本与Crontab配置教学》在生产环境中,数据库是核心资产之一,定期备份数据库可以有效防止意外数据丢失,本文将分享一份MySQL定时备份脚本,并讲解如何通过cr... 目录备份脚本详解脚本功能说明授权与可执行权限使用 Crontab 定时执行编辑 Crontab添加定

oracle 11g导入\导出(expdp impdp)之导入过程

《oracle11g导入导出(expdpimpdp)之导入过程》导出需使用SEC.DMP格式,无分号;建立expdir目录(E:/exp)并确保存在;导入在cmd下执行,需sys用户权限;若需修... 目录准备文件导入(impdp)1、建立directory2、导入语句 3、更改密码总结上一个环节,我们讲了

ShardingProxy读写分离之原理、配置与实践过程

《ShardingProxy读写分离之原理、配置与实践过程》ShardingProxy是ApacheShardingSphere的数据库中间件,通过三层架构实现读写分离,解决高并发场景下数据库性能瓶... 目录一、ShardingProxy技术定位与读写分离核心价值1.1 技术定位1.2 读写分离核心价值二

MyBatis-plus处理存储json数据过程

《MyBatis-plus处理存储json数据过程》文章介绍MyBatis-Plus3.4.21处理对象与集合的差异:对象可用内置Handler配合autoResultMap,集合需自定义处理器继承F... 目录1、如果是对象2、如果需要转换的是List集合总结对象和集合分两种情况处理,目前我用的MP的版本

MySQL中On duplicate key update的实现示例

《MySQL中Onduplicatekeyupdate的实现示例》ONDUPLICATEKEYUPDATE是一种MySQL的语法,它在插入新数据时,如果遇到唯一键冲突,则会执行更新操作,而不是抛... 目录1/ ON DUPLICATE KEY UPDATE的简介2/ ON DUPLICATE KEY UP

MySQL分库分表的实践示例

《MySQL分库分表的实践示例》MySQL分库分表适用于数据量大或并发压力高的场景,核心技术包括水平/垂直分片和分库,需应对分布式事务、跨库查询等挑战,通过中间件和解决方案实现,最佳实践为合理策略、备... 目录一、分库分表的触发条件1.1 数据量阈值1.2 并发压力二、分库分表的核心技术模块2.1 水平分

Python与MySQL实现数据库实时同步的详细步骤

《Python与MySQL实现数据库实时同步的详细步骤》在日常开发中,数据同步是一项常见的需求,本篇文章将使用Python和MySQL来实现数据库实时同步,我们将围绕数据变更捕获、数据处理和数据写入这... 目录前言摘要概述:数据同步方案1. 基本思路2. mysql Binlog 简介实现步骤与代码示例1

Java Kafka消费者实现过程

《JavaKafka消费者实现过程》Kafka消费者通过KafkaConsumer类实现,核心机制包括偏移量管理、消费者组协调、批量拉取消息及多线程处理,手动提交offset确保数据可靠性,自动提交... 目录基础KafkaConsumer类分析关键代码与核心算法2.1 订阅与分区分配2.2 拉取消息2.3