-- 创建月表和日表的存储过程 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事件调度器允许在预定义的时间执行特定任务,如定期创建和删除分区。这个事件可能会按照每天、每周或每月等周期触发,确保分区表始终保持最优状态。 "表.txt"文件可能包含了一些示例表结构或者分区设计的说明...
- 定期任务:结合事件调度器,存储过程可用于执行定时任务,如定期备份或清理过期数据。 10. **存储过程的调试** Navicat等工具提供了存储过程的调试功能,可以设置断点,逐行执行,查看变量值,便于定位问题。 ...
**dolphinScheduler**(简称DS)是一款强大的分布式任务调度平台,支持多种类型的作业执行,如Shell、Python、Spark等。它能够高效地管理任务间的依赖关系,并提供了丰富的功能来满足企业级的数据处理需求。在大数据...
Azkaban大数据任务调度器是一种高效的工作流管理系统,专门设计用于解决复杂的数据处理流程中的任务调度问题。在大数据处理场景中,通常会涉及到多个独立或相互依赖的任务单元,如Shell脚本、Java程序、MapReduce...
### Azkaban任务调度安装配置和使用 #### 一、Azkaban介绍 ##### 1.1 为什么需要Azkaban 在大数据处理领域,一个完整的数据分析系统往往由多个任务单元组成,如Shell脚本、Java程序、MapReduce作业、Hive SQL脚本...
学习Quartz.NET时,开发者应熟悉上述概念,掌握其配置和编程模型,以便在项目中灵活运用,实现高效的任务调度和消息调度。通过不断的实践和探索,可以充分发挥Quartz.NET的潜力,解决各种定时任务场景的需求。
博客园文章可能会进一步解释如何在实际项目中使用Quartz.NET,包括如何配置Scheduler、如何处理并发执行、错误恢复策略、持久化设置(例如使用SQLite、MySQL等数据库存储Job和Trigger信息)等高级话题。 此外,源码...
这里分享自己已经跑起来的Oracle版本分布式任务调度平台XXL-JOB资源。 官方只有Mysql版本的DEMO,由于近期单位项目需要,将原来DEMO稍作修改后改成了oracle版本,主要修改工作包括修改配置文件,数据库连接方式,pom...
这些注册中心用于节点信息的暴露和Master选举,同时使用MongoDB或MySQL存储任务队列和执行日志。 **任务类型支持** 1. **实时任务**:提交后立即执行的任务。 2. **定时任务**:在特定时间点执行的任务。 3. **...
默认情况下,Quartz使用内存存储,但为了保证任务调度的高可用性和持久性,通常会配置使用数据库来保存调度信息。这样,即使应用程序重启,之前调度的Job和Trigger也会被重新加载。 ### 结语 Quartz作为一个功能...
9. **自动化任务**:通过创建和调度任务,开发者可以自动化执行一系列数据库操作,包括存储过程的测试和部署。 10. **数据库对比和同步**:DbForge Studio还提供了数据库结构和数据的对比与同步功能,确保在不同...
通过以上分析,我们可以看出`analyData`项目是一个结合了Java编程、数据库操作、定时任务调度和微服务架构的典型实例,涉及的知识点广泛且深入,对于提升Java开发者在实际项目中的技能具有很好的学习价值。
标题“任务调度临时表保存大数据量会员”暗示了我们在讨论如何在处理大量会员数据时,利用任务调度和临时表来优化存储和处理流程。在这个场景中,可能涉及到数据库管理、任务调度系统以及大数据处理策略。 首先,让...
在数据库管理中,存储过程(Procedures)和Job任务是两个关键的概念,它们极大地提高了数据库操作的效率和灵活性。本文将深入探讨存储过程的编写及其与Job任务的结合使用。 **存储过程(Procedures)** 存储过程是...
数据库支持使用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连接器,这将帮助用户将DolphinScheduler与MySQL数据库进行集成,实现任务调度的数据存储。 Apache DolphinScheduler 1.3.4是该版本的安装包,名为`...
本项目主要涵盖了Python爬虫技术、Flask框架的使用、Echarts数据可视化、MySQL数据库的运用以及在Linux系统上的项目部署和任务定时调度。通过这个实战项目,你可以深入理解并掌握一系列关键的IT技能。 首先,Python...
MySQL是广泛使用的开源关系型数据库,它在本项目中主要负责存储任务调度的相关数据,如任务定义、执行记录等。通过设计合理的数据库模型,可以确保数据的一致性和持久性,从而保证任务调度的稳定性和可靠性。 在...
在IT行业中,"job调用的存储过程"是一个常见的数据库管理任务,主要涉及数据库调度和自动化操作。这里我们将深入探讨这个主题,以及与之相关的标签"job",并结合提供的压缩包子文件名称来推测可能的应用场景。 首先...
在本"CRM项目全流程任务调度"中,我们主要关注的是如何有效地管理和执行项目的各个阶段,确保数据的高效流动和处理。以下是根据提供的文件名解析出的相关知识点: 1. **ETL过程**: - `crm_dwd_dws.job` 和 `crm_...