From 484f4183e831021be7662afa6de4bc33d9350e12 Mon Sep 17 00:00:00 2001 From: aoshiguchen <1052045476@qq.com> Date: Thu, 1 Sep 2022 19:03:15 +0800 Subject: [PATCH] =?UTF-8?q?=E6=96=B0=E5=A2=9E=E8=B0=83=E5=BA=A6=E7=AE=A1?= =?UTF-8?q?=E7=90=86=E7=9B=B8=E5=85=B3=E8=A1=A8=E7=BB=93=E6=9E=84=E5=AE=9A?= =?UTF-8?q?=E4=B9=89?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../core/scheduler/test1/Launcher.java | 2 +- .../src/main/resources/sql/init-structure.sql | 29 +++++++++++++++++++ 2 files changed, 30 insertions(+), 1 deletion(-) diff --git a/neutrino-core/src/test/java/fun/asgc/neutrino/core/scheduler/test1/Launcher.java b/neutrino-core/src/test/java/fun/asgc/neutrino/core/scheduler/test1/Launcher.java index 08650423..ba21a3d7 100644 --- a/neutrino-core/src/test/java/fun/asgc/neutrino/core/scheduler/test1/Launcher.java +++ b/neutrino-core/src/test/java/fun/asgc/neutrino/core/scheduler/test1/Launcher.java @@ -34,7 +34,7 @@ public class Launcher { SchedulerFactory schedulerFactory = new StdSchedulerFactory(); Scheduler scheduler = schedulerFactory.getScheduler(); - CronScheduleBuilder cronScheduleBuilder = CronScheduleBuilder.cronSchedule("0/1 * * * * ?").withMisfireHandlingInstructionDoNothing(); + CronScheduleBuilder cronScheduleBuilder = CronScheduleBuilder.cronSchedule("0/5 * * * * ?").withMisfireHandlingInstructionDoNothing(); CronTrigger cronTrigger = TriggerBuilder.newTrigger().withIdentity(triggerKey).withSchedule(cronScheduleBuilder).build(); Class jobClass_ = RemoteHttpJobBean.class; // Class.forName(jobInfo.getJobClass()); diff --git a/neutrino-proxy-server/src/main/resources/sql/init-structure.sql b/neutrino-proxy-server/src/main/resources/sql/init-structure.sql index 86672994..c891cd0c 100644 --- a/neutrino-proxy-server/src/main/resources/sql/init-structure.sql +++ b/neutrino-proxy-server/src/main/resources/sql/init-structure.sql @@ -91,3 +91,32 @@ CREATE TABLE IF NOT EXISTS `user_connect_record` ( `type` INTEGER(2) NOT NULL, `create_time` INTEGER(20) NOT NULL ); + +#############################调度管理相关表############################# +#触发器信息表 +CREATE TABLE IF NOT EXISTS `job_qrtz_trigger_info` ( + `id` INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT, + `job_cron` VARCHAR(128) NOT NULL , + `job_desc` VARCHAR(255) NOT NULL, + `create_time` INTEGER(20) NOT NULL, + `update_time` INTEGER(20) NOT NULL, + `alarm_email` VARCHAR(255), + `alarm_ding` VARCHAR(255), + `executor_handler` VARCHAR(255) DEFAULT NULL, + `executor_param` VARCHAR(512) DEFAULT NULL, + `executor_timeout` INTEGER(20) NOT NULL DEFAULT '0' +); + +#触发器日志表 +CREATE TABLE IF NOT EXISTS `job_qrtz_trigger_log` ( + `id` INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT, + `job_id` INTEGER(20) NOT NULL, + `executor_handler` VARCHAR(255) NOT NULL, + `executor_param` VARCHAR(512) DEFAULT NULL, + `create_time` INTEGER(20) NOT NULL, + `code` INTEGER(20) NOT NULL, + `msg` TEXT, + `alarm_status` INTEGER(2) NOT NULL DEFAULT '0' +); +CREATE INDEX IF NOT EXISTS I_create_time ON job_qrtz_trigger_log(create_time); +CREATE INDEX IF NOT EXISTS I_code ON job_qrtz_trigger_log(code);