`

mysql存储过程和任务调度器

 
阅读更多
-- 创建月表和日表的存储过程
delimiter $$

use `devicitydb1`$$

drop procedure if exists `createTable`$$

create definer=`devicityusr01`@`%` procedure `createTable`()
begin
  declare sql_str varchar(20000);
  declare tname varchar(200);
  declare dataStr varchar(2000);
  declare i int;
  
  set i=0;
  while i<=7 do
   -- 创建日表
	  set sql_str=' create table if not exists tableName ( MGMT_INFO_VALUE_ID  VARCHAR(60) NOT NULL,MGMT_ENTITY_ID  VARCHAR(512) DEFAULT NULL,MGMT_INFO_ID  VARCHAR(255) DEFAULT NULL,    FROM_DATE  DATETIME DEFAULT NULL,    THRU_DATE  DATETIME DEFAULT NULL,    ITEM_VALUE0  VARCHAR(255) DEFAULT NULL,    ITEM_VALUE1  VARCHAR(255) DEFAULT NULL,    ITEM_VALUE2  VARCHAR(255) DEFAULT NULL,    ITEM_VALUE3  VARCHAR(255) DEFAULT NULL,    ITEM_VALUE4  VARCHAR(255) DEFAULT NULL,    ITEM_VALUE5  VARCHAR(255) DEFAULT NULL,    ITEM_VALUE6  VARCHAR(255) DEFAULT NULL,    ITEM_VALUE7  VARCHAR(255) DEFAULT NULL,    ITEM_VALUE8  VARCHAR(255) DEFAULT NULL,    ITEM_VALUE9  VARCHAR(255) DEFAULT NULL,    ITEM_DIM0  VARCHAR(255) DEFAULT NULL,    ITEM_DIM1  VARCHAR(255) DEFAULT NULL,    ITEM_DIM2  VARCHAR(255) DEFAULT NULL,    ITEM_DIM3  VARCHAR(255) DEFAULT NULL,    ITEM_DIM4  VARCHAR(255) DEFAULT NULL,    ITEM_DIM5  VARCHAR(255) DEFAULT NULL,    ITEM_DIM6  VARCHAR(255) DEFAULT NULL,    ITEM_DIM7  VARCHAR(255) DEFAULT NULL,    ITEM_DIM8  VARCHAR(255) DEFAULT NULL,    ITEM_DIM9  VARCHAR(255) DEFAULT NULL,    STATUS_ID  VARCHAR(20) DEFAULT NULL,    PERIOD_DATE  DATE DEFAULT NULL,    PERIOD_TIME  DATE DEFAULT NULL,    MEDIATION_OBJECT_ID  VARCHAR(20) DEFAULT NULL,    MEDIATION_DATE  DATETIME DEFAULT NULL,    EVENT_LEVEL  VARCHAR(10) DEFAULT NULL,    INFO_COUNT  DECIMAL(19,2) DEFAULT NULL,    MEDIATION_DELAY  DECIMAL(19,2) DEFAULT NULL,    DATA_BASE_DELAY  DECIMAL(19,2) DEFAULT NULL,    SUM_DELAY  DECIMAL(19,2) DEFAULT NULL,    COMMENTS  VARCHAR(400) DEFAULT NULL,    INFO_VALUE_UID  VARCHAR(255) DEFAULT NULL,    LAST_UPDATED_STAMP  DATETIME DEFAULT NULL,    LAST_UPDATED_TX_STAMP  DATETIME DEFAULT NULL,    CREATED_STAMP  DATETIME DEFAULT NULL,    CREATED_TX_STAMP  DATETIME DEFAULT NULL,    VALUE_DESC  VARCHAR(255) DEFAULT NULL,    NATIVE_CODE  VARCHAR(255) DEFAULT NULL,    RESOURCE_ID  VARCHAR(20) DEFAULT NULL,    SERVICE_ID  VARCHAR(20) DEFAULT NULL,    BUSINESS_ID  VARCHAR(20) DEFAULT NULL,    PARTY_ID  VARCHAR(20) DEFAULT NULL,  FACILITY_ID  VARCHAR(20) DEFAULT NULL ) ENGINE=INNODB DEFAULT CHARSET=utf8';
	 -- set dataStr=curdate();
	  set dataStr=date_sub(curdate(),interval -i day);
	  set dataStr=replace(dataStr, '-','');
	  if i=7 then 
	         --  创建月表
	 	 set dataStr=substring(dataStr,1,length(dataStr)-2); -- 精确到月 创建月表
	  end if;
	  
	  
	   set tname=concat('mgmt_info_value_',dataStr) ;
	   set sql_str=replace(sql_str, 'tableName',tname) ;
	--   select sql_str  from dual; 
	  set @delSql = sql_str;
	    prepare stmt from @delSql;
	    execute stmt;
	  select sql_str  from dual; 
	  
	set i=i+1;
 end while;
  
end$$

delimiter ;


-- 事件调度器-----------------------------
delimiter $$

-- SET GLOBAL event_scheduler = ON$$     -- required for event to execute but not create    

create		EVENT `devicitydb1`.`event_call_procedure`

on schedule
	
	   every 1 day
         -- EVERY 1 MINUTE 
	  -- STARTS  '2014-05-26 16:11:00' 
	 -- AT TIMESTAMP  '2014-05-26 16:27:00'
	 
on completion  preserve
 enable 
do
	begin
	  call createTable();
	end$$
delimiter ;

 

分享到:
评论

相关推荐

    MySQL分区表自动创建及删除存储过程

    MySQL事件调度器允许在预定义的时间执行特定任务,如定期创建和删除分区。这个事件可能会按照每天、每周或每月等周期触发,确保分区表始终保持最优状态。 "表.txt"文件可能包含了一些示例表结构或者分区设计的说明...

    mysql存储过程(2)

    - 定期任务:结合事件调度器,存储过程可用于执行定时任务,如定期备份或清理过期数据。 10. **存储过程的调试** Navicat等工具提供了存储过程的调试功能,可以设置断点,逐行执行,查看变量值,便于定位问题。 ...

    dolphinScheduler海豚调度器动态传递任务执行参数

    **dolphinScheduler**(简称DS)是一款强大的分布式任务调度平台,支持多种类型的作业执行,如Shell、Python、Spark等。它能够高效地管理任务间的依赖关系,并提供了丰富的功能来满足企业级的数据处理需求。在大数据...

    Azkaban 大数据任务调度器

    Azkaban大数据任务调度器是一种高效的工作流管理系统,专门设计用于解决复杂的数据处理流程中的任务调度问题。在大数据处理场景中,通常会涉及到多个独立或相互依赖的任务单元,如Shell脚本、Java程序、MapReduce...

    Azkaban任务调度安装配置和使用

    ### Azkaban任务调度安装配置和使用 #### 一、Azkaban介绍 ##### 1.1 为什么需要Azkaban 在大数据处理领域,一个完整的数据分析系统往往由多个任务单元组成,如Shell脚本、Java程序、MapReduce作业、Hive SQL脚本...

    quartznet任务调度和消息调度

    学习Quartz.NET时,开发者应熟悉上述概念,掌握其配置和编程模型,以便在项目中灵活运用,实现高效的任务调度和消息调度。通过不断的实践和探索,可以充分发挥Quartz.NET的潜力,解决各种定时任务场景的需求。

    任务调度源码.net

    博客园文章可能会进一步解释如何在实际项目中使用Quartz.NET,包括如何配置Scheduler、如何处理并发执行、错误恢复策略、持久化设置(例如使用SQLite、MySQL等数据库存储Job和Trigger信息)等高级话题。 此外,源码...

    分布式任务调度平台XXL-JOB(Oracle版)

    这里分享自己已经跑起来的Oracle版本分布式任务调度平台XXL-JOB资源。 官方只有Mysql版本的DEMO,由于近期单位项目需要,将原来DEMO稍作修改后改成了oracle版本,主要修改工作包括修改配置文件,数据库连接方式,pom...

    分布式任务调度系统调研

    这些注册中心用于节点信息的暴露和Master选举,同时使用MongoDB或MySQL存储任务队列和执行日志。 **任务类型支持** 1. **实时任务**:提交后立即执行的任务。 2. **定时任务**:在特定时间点执行的任务。 3. **...

    任务调度Quartz框 架

    默认情况下,Quartz使用内存存储,但为了保证任务调度的高可用性和持久性,通常会配置使用数据库来保存调度信息。这样,即使应用程序重启,之前调度的Job和Trigger也会被重新加载。 ### 结语 Quartz作为一个功能...

    DbForge_Studio_for_MySQL6.3存储过程调试工具

    9. **自动化任务**:通过创建和调度任务,开发者可以自动化执行一系列数据库操作,包括存储过程的测试和部署。 10. **数据库对比和同步**:DbForge Studio还提供了数据库结构和数据的对比与同步功能,确保在不同...

    analyData:这是一个java定时任务,定时调用mysql的存储过程

    通过以上分析,我们可以看出`analyData`项目是一个结合了Java编程、数据库操作、定时任务调度和微服务架构的典型实例,涉及的知识点广泛且深入,对于提升Java开发者在实际项目中的技能具有很好的学习价值。

    任务调度临时表保存大数据量会员

    标题“任务调度临时表保存大数据量会员”暗示了我们在讨论如何在处理大量会员数据时,利用任务调度和临时表来优化存储和处理流程。在这个场景中,可能涉及到数据库管理、任务调度系统以及大数据处理策略。 首先,让...

    存储过程Procedures及Job任务编写

    在数据库管理中,存储过程(Procedures)和Job任务是两个关键的概念,它们极大地提高了数据库操作的效率和灵活性。本文将深入探讨存储过程的编写及其与Job任务的结合使用。 **存储过程(Procedures)** 存储过程是...

    基于Spring Boot的Quartz任务调度系统.zip

    数据库支持使用MySQL存储任务信息,支持逻辑删除。 技术栈 开发环境MacOS, IntelliJ IDEA, Git, JDK1.8, Maven 3.8, MySQL 5.78.0 技术路线Spring Boot 2.0, MySQL 5.68.0, Spring Quartz 2.3, Swagger 2, ...

    dolphinscheduler安装包和mysql的jdbc连接jar包

    在本压缩包中,包含的是DolphinScheduler的安装包以及MySQL的JDBC连接器,这将帮助用户将DolphinScheduler与MySQL数据库进行集成,实现任务调度的数据存储。 Apache DolphinScheduler 1.3.4是该版本的安装包,名为`...

    Python爬取疫情实战:Flask搭建webEcharts可视化大屏MySQL数据库Linux项目部署与任务定时调度.zip

    本项目主要涵盖了Python爬虫技术、Flask框架的使用、Echarts数据可视化、MySQL数据库的运用以及在Linux系统上的项目部署和任务定时调度。通过这个实战项目,你可以深入理解并掌握一系列关键的IT技能。 首先,Python...

    基于Dubbo的分布式任务调度系统.zip

    MySQL是广泛使用的开源关系型数据库,它在本项目中主要负责存储任务调度的相关数据,如任务定义、执行记录等。通过设计合理的数据库模型,可以确保数据的一致性和持久性,从而保证任务调度的稳定性和可靠性。 在...

    job调用的存储过程

    在IT行业中,"job调用的存储过程"是一个常见的数据库管理任务,主要涉及数据库调度和自动化操作。这里我们将深入探讨这个主题,以及与之相关的标签"job",并结合提供的压缩包子文件名称来推测可能的应用场景。 首先...

    CRM项目全流程任务调度.zip

    在本"CRM项目全流程任务调度"中,我们主要关注的是如何有效地管理和执行项目的各个阶段,确保数据的高效流动和处理。以下是根据提供的文件名解析出的相关知识点: 1. **ETL过程**: - `crm_dwd_dws.job` 和 `crm_...

Global site tag (gtag.js) - Google Analytics