`

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 ;

 

分享到:
评论

相关推荐

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

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

    mysql的计划任务与事件调度实例分析

    mysql事件类似于UNIX中的cron作业或Windows中的任务调度程序。我们可以在优化数据库表,清理日志,归档数据或在非高峰时间生成复杂的报告的时候使用mysql事件。 mysql使用一个名为事件调度线程的特殊线程来执行所有...

    MySQL Event Scheduler(事件调度器)

    一、概述 事件调度器是在 MySQL 5.1 中新增的另一个特色功能,可以作为定时任务调度器,取代部分原先只能用操作系统任务调度器才能完成的定时功&gt;能。例如,Linux 中的 crontabe 只能精确到每分钟执行一次,而 MySQL ...

    基于Datax和Celery的数据库数据传输调度工具(python)

    依赖MySQL存储任务和数据源, Redis用于做celery的任务调度中间件 使用方式 修改MySQL配置 config/mysql.ini 修改celery配置 config/celery_config.py 修改Redis配置 config/redis.ini 本程序建议集成为Docker镜像, ...

    微服务电商项目SpringBoot+SpringCloud +Maven+Redis+ActiveMQ+XXLJOB(分布式任务调度)+ Freemarker

    SpringCloud Eureka作为注册中心、Feign客户端调用工具、断路器Hystrix 视图展示使用Freemarker、数据库层使用Mybatis框架、缓存使用Redis、数据库使用MySQL 项目管理工具使用Maven、版本控制工具使用SVN、项目自动...

    PHPScheduler:具有可插入后端的 PHP 调度程序任务运行器

    任务存储是可插入的,因此您可以选择要存储任务的位置。 目前,计划了以下后端(但您可以轻松添加更多):在记忆中done对调试和任务缓冲很有用。文件done使用单个服务器运行? 无法访问数据库或 Redis? 这个是给你...

    mysql定时任务(event事件)实现详解

    事件取代了原先只能由操作系统的计划任务来执行的工作,而且MySQL的事件调度器可以精确到每秒钟执行一个任务,而操作系统的计划任务(如:Linux下的CRON或Windows下的任务计划)只能精确到每分钟执行一次。...

    mysql中event事件使用详解.docx

    Event即事件,也是一种数据库对象,又叫时间触发器或者事件调度器,与triggers的事件触发不同,tiggers会因为update、delete、insert等事件触发,而event类似与linux crontab计划任务,用于时间触发,当到了设定执行...

    light-task-scheduler.rar

    (Mongo or Mysql)存储任务队列和任务执行日志, netty做底层通信。 JobClient : 主要负责提交任务, 和 接收任务执行反馈结果。 JobTracker : 负责接收并分配任务,任务调度。 TaskTracker: 负责执行任务,执行完反馈...

    SQLyog v11 11 32位和64位

    它是一款功能强大的MYSQL数据库管理工具,内置多个高级工具,可以导入外部数据,SQL调度器和报告工具向导会引导您通过若干步骤调度查询的执行,结果可以发送给多个接收者,您还可以使用该功能执行例如 ANALYZE, ...

    基于ssm+Vue的任务发布接收平台(源码+部署说明+系统介绍+数据库).zip

    在数据库方面,该系统使用了MySQL作为数据库存储介质,并设计了相应的数据表来存储任务信息、用户信息等数据。同时,为了保证数据的安全性和完整性,还采用了一些常见的数据库安全措施,如加密传输、防止SQL注入等。...

    最新ssm项目物流配送人员车辆调度管理系统的设计与实现+vue.zip

    3. **配送任务调度**:根据订单需求和地理位置,智能分配配送任务给最合适的车辆和配送员。 4. **实时追踪与监控**:通过集成GPS定位系统,实时追踪车辆位置,确保配送过程的透明化和可监控。 5. **优化路线规划**:...

    Big Whale任务调度系统-其他

    巨鲸任务调度平台为美柚大数据研发的分布式计算任务调度系统,提供Spark、Flink等批处理任务的DAG执行调度和流处理任务的状态监测调度,并具有重复应用检测、大内存应用检测等功能。 服务基于Spring Boot 2.0开发,...

    sqlyog ultimcate 11

    它是一款功能强大的MYSQL数据库管理工具,内置多个高级工具,可以导入外部数据,SQL调度器和报告工具向导会引导您通过若干步骤调度查询的执行,结果可以发送给多个接收者,您还可以使用该功能执行例如 ANALYZE, ...

    ssm任务发布接收平台&源码&论文&手把手指导

    在数据库方面,该系统使用了MySQL作为数据库存储介质,并设计了相应的数据表来存储任务信息、用户信息等数据。同时,为了保证数据的安全性和完整性,还采用了一些常见的数据库安全措施,如加密传输、防止SQL注入等。...

    SQLyog Ultimate12.09

    它是一款功能强大的MYSQL数据库管理工具,内置多个高级工具,可以导入外部数据,SQL调度器和报告工具向导会引导您通过若干步骤调度查询的执行,结果可以发送给多个接收者,您还可以使用该功能执行例如 ANALYZE, ...

    基于Vue和SpringBoot的毕设分配选题管理系统.zip

    MySQL拥有庞大的开发者社区和丰富的第三方插件、库、中间件支持,提供了丰富的文档、教程、论坛以及专业服务,极大地简化了开发、运维和故障排查过程。 关键组件与日志 系统数据库 MySQL内部包含几个特殊的系统...

    springcloud项目实战微服务架构源代码+文档说明(电商版一套完整架构)

    功能包含电商模块,会员、SSO、订单、商品、支付、消息、微信、H5和PC、移动端、优惠券、后台系统、任务调度等模块。 项目源代码技术点: SpringBoot+SpringCloud +Maven+Redis+ActiveMQ+XXLJOB(分布式任务调度)+ ...

    SpringBoot + Mysql 博客管理系统【前端+后台】.rar

    * 任务调度:`quartz 2.3` * 持久层框架:`MyBatis 3` &lt;a href="http://baomidou.oschina.io/mybatis-plus-doc/#/" target="_blank"&gt;mybatisplus&lt;/a&gt; 2.1.4 * 数据库连接池:`Alibaba Druid 1.0.2` * 日志管理:`...

    gopherCron:golang开箱即用的秒级分布式定时任务系统

    Mysql#任务日志存储 cronexpr#github.com/gorhill/cronexpr cron表达解析器 实现功能 秒级定时任务 任务日志查看 随时结束任务进程 分散扩展 健康摘要检测(分项目显示对应的健康摘要IP及例程数) 任务日志集中...

Global site tag (gtag.js) - Google Analytics