springboot+quartz+sqlserver springboot整合quartz持久化到sqlserver数据库

- 日理万妓 2022-04-17 06:59 612阅读 0赞

**目录**

1、执行sqlserver数据库脚本

2、配置application-quartz.properties参数

3、配置类

4、调度类

5、触发类

--------------------

# 1、执行sqlserver数据库脚本 #

IF EXISTS (SELECT \* FROM dbo.sysobjects WHERE id = OBJECT\_ID(N'\[dbo\].\[FK\_QRTZ\_TRIGGERS\_QRTZ\_JOB\_DETAILS\]') AND OBJECTPROPERTY(id, N'ISFOREIGNKEY') = 1)  
ALTER TABLE \[dbo\].\[QRTZ\_TRIGGERS\] DROP CONSTRAINT FK\_QRTZ\_TRIGGERS\_QRTZ\_JOB\_DETAILS  
GO  
IF EXISTS (SELECT \* FROM dbo.sysobjects WHERE id = OBJECT\_ID(N'\[dbo\].\[FK\_QRTZ\_CRON\_TRIGGERS\_QRTZ\_TRIGGERS\]') AND OBJECTPROPERTY(id, N'ISFOREIGNKEY') = 1)  
ALTER TABLE \[dbo\].\[QRTZ\_CRON\_TRIGGERS\] DROP CONSTRAINT FK\_QRTZ\_CRON\_TRIGGERS\_QRTZ\_TRIGGERS  
GO  
IF EXISTS (SELECT \* FROM dbo.sysobjects WHERE id = OBJECT\_ID(N'\[dbo\].\[FK\_QRTZ\_SIMPLE\_TRIGGERS\_QRTZ\_TRIGGERS\]') AND OBJECTPROPERTY(id, N'ISFOREIGNKEY') = 1)  
ALTER TABLE \[dbo\].\[QRTZ\_SIMPLE\_TRIGGERS\] DROP CONSTRAINT FK\_QRTZ\_SIMPLE\_TRIGGERS\_QRTZ\_TRIGGERS  
GO  
IF EXISTS (SELECT \* FROM dbo.sysobjects WHERE id = OBJECT\_ID(N'\[dbo\].\[FK\_QRTZ\_SIMPROP\_TRIGGERS\_QRTZ\_TRIGGERS\]') AND OBJECTPROPERTY(id, N'ISFOREIGNKEY') = 1)  
ALTER TABLE \[dbo\].\[QRTZ\_SIMPROP\_TRIGGERS\] DROP CONSTRAINT FK\_QRTZ\_SIMPROP\_TRIGGERS\_QRTZ\_TRIGGERS  
GO  
IF  EXISTS (SELECT \* FROM sys.foreign\_keys WHERE object\_id = OBJECT\_ID(N'\[dbo\].\[FK\_QRTZ\_JOB\_LISTENERS\_QRTZ\_JOB\_DETAILS\]') AND parent\_object\_id = OBJECT\_ID(N'\[dbo\].\[QRTZ\_JOB\_LISTENERS\]'))  
ALTER TABLE \[dbo\].\[QRTZ\_JOB\_LISTENERS\] DROP CONSTRAINT \[FK\_QRTZ\_JOB\_LISTENERS\_QRTZ\_JOB\_DETAILS\]  
IF  EXISTS (SELECT \* FROM sys.foreign\_keys WHERE object\_id = OBJECT\_ID(N'\[dbo\].\[FK\_QRTZ\_TRIGGER\_LISTENERS\_QRTZ\_TRIGGERS\]') AND parent\_object\_id = OBJECT\_ID(N'\[dbo\].\[QRTZ\_TRIGGER\_LISTENERS\]'))  
ALTER TABLE \[dbo\].\[QRTZ\_TRIGGER\_LISTENERS\] DROP CONSTRAINT \[FK\_QRTZ\_TRIGGER\_LISTENERS\_QRTZ\_TRIGGERS\]  
IF EXISTS (SELECT \* FROM dbo.sysobjects WHERE id = OBJECT\_ID(N'\[dbo\].\[QRTZ\_CALENDARS\]') AND OBJECTPROPERTY(id, N'ISUSERTABLE') = 1)  
DROP TABLE \[dbo\].\[QRTZ\_CALENDARS\]  
GO  
IF EXISTS (SELECT \* FROM dbo.sysobjects WHERE id = OBJECT\_ID(N'\[dbo\].\[QRTZ\_CRON\_TRIGGERS\]') AND OBJECTPROPERTY(id, N'ISUSERTABLE') = 1)  
DROP TABLE \[dbo\].\[QRTZ\_CRON\_TRIGGERS\]  
GO  
IF EXISTS (SELECT \* FROM dbo.sysobjects WHERE id = OBJECT\_ID(N'\[dbo\].\[QRTZ\_BLOB\_TRIGGERS\]') AND OBJECTPROPERTY(id, N'ISUSERTABLE') = 1)  
DROP TABLE \[dbo\].\[QRTZ\_BLOB\_TRIGGERS\]  
GO  
IF EXISTS (SELECT \* FROM dbo.sysobjects WHERE id = OBJECT\_ID(N'\[dbo\].\[QRTZ\_FIRED\_TRIGGERS\]') AND OBJECTPROPERTY(id, N'ISUSERTABLE') = 1)  
DROP TABLE \[dbo\].\[QRTZ\_FIRED\_TRIGGERS\]  
GO  
IF EXISTS (SELECT \* FROM dbo.sysobjects WHERE id = OBJECT\_ID(N'\[dbo\].\[QRTZ\_PAUSED\_TRIGGER\_GRPS\]') AND OBJECTPROPERTY(id, N'ISUSERTABLE') = 1)  
DROP TABLE \[dbo\].\[QRTZ\_PAUSED\_TRIGGER\_GRPS\]  
GO  
IF  EXISTS (SELECT \* FROM sys.objects WHERE object\_id = OBJECT\_ID(N'\[dbo\].\[QRTZ\_JOB\_LISTENERS\]') AND type in (N'U'))  
DROP TABLE \[dbo\].\[QRTZ\_JOB\_LISTENERS\]  
IF EXISTS (SELECT \* FROM dbo.sysobjects WHERE id = OBJECT\_ID(N'\[dbo\].\[QRTZ\_SCHEDULER\_STATE\]') AND OBJECTPROPERTY(id, N'ISUSERTABLE') = 1)  
DROP TABLE \[dbo\].\[QRTZ\_SCHEDULER\_STATE\]  
GO  
IF EXISTS (SELECT \* FROM dbo.sysobjects WHERE id = OBJECT\_ID(N'\[dbo\].\[QRTZ\_LOCKS\]') AND OBJECTPROPERTY(id, N'ISUSERTABLE') = 1)  
DROP TABLE \[dbo\].\[QRTZ\_LOCKS\]  
GO  
IF  EXISTS (SELECT \* FROM sys.objects WHERE object\_id = OBJECT\_ID(N'\[dbo\].\[QRTZ\_TRIGGER\_LISTENERS\]') AND type in (N'U'))  
DROP TABLE \[dbo\].\[QRTZ\_TRIGGER\_LISTENERS\]  
IF EXISTS (SELECT \* FROM dbo.sysobjects WHERE id = OBJECT\_ID(N'\[dbo\].\[QRTZ\_JOB\_DETAILS\]') AND OBJECTPROPERTY(id, N'ISUSERTABLE') = 1)  
DROP TABLE \[dbo\].\[QRTZ\_JOB\_DETAILS\]  
GO  
IF EXISTS (SELECT \* FROM dbo.sysobjects WHERE id = OBJECT\_ID(N'\[dbo\].\[QRTZ\_SIMPLE\_TRIGGERS\]') AND OBJECTPROPERTY(id, N'ISUSERTABLE') = 1)  
DROP TABLE \[dbo\].\[QRTZ\_SIMPLE\_TRIGGERS\]  
GO  
IF EXISTS (SELECT \* FROM dbo.sysobjects WHERE id = OBJECT\_ID(N'\[dbo\].\[QRTZ\_SIMPROP\_TRIGGERS\]') AND OBJECTPROPERTY(id, N'ISUSERTABLE') = 1)  
DROP TABLE \[dbo\].QRTZ\_SIMPROP\_TRIGGERS  
GO  
IF EXISTS (SELECT \* FROM dbo.sysobjects WHERE id = OBJECT\_ID(N'\[dbo\].\[QRTZ\_TRIGGERS\]') AND OBJECTPROPERTY(id, N'ISUSERTABLE') = 1)  
DROP TABLE \[dbo\].\[QRTZ\_TRIGGERS\]  
GO  
CREATE TABLE \[dbo\].\[QRTZ\_CALENDARS\] (  
  \[SCHED\_NAME\] \[NVARCHAR\] (100)  NOT NULL ,  
  \[CALENDAR\_NAME\] \[NVARCHAR\] (200)  NOT NULL ,  
  \[CALENDAR\] \[IMAGE\] NOT NULL  
) ON \[PRIMARY\]  
GO  
CREATE TABLE \[dbo\].\[QRTZ\_CRON\_TRIGGERS\] (  
  \[SCHED\_NAME\] \[NVARCHAR\] (100)  NOT NULL ,  
  \[TRIGGER\_NAME\] \[NVARCHAR\] (150)  NOT NULL ,  
  \[TRIGGER\_GROUP\] \[NVARCHAR\] (150)  NOT NULL ,  
  \[CRON\_EXPRESSION\] \[NVARCHAR\] (120)  NOT NULL ,  
  \[TIME\_ZONE\_ID\] \[NVARCHAR\] (80)   
) ON \[PRIMARY\]  
GO  
CREATE TABLE \[dbo\].\[QRTZ\_FIRED\_TRIGGERS\] (  
  \[SCHED\_NAME\] \[NVARCHAR\] (100)  NOT NULL ,  
  \[ENTRY\_ID\] \[NVARCHAR\] (95)  NOT NULL ,  
  \[TRIGGER\_NAME\] \[NVARCHAR\] (150)  NOT NULL ,  
  \[TRIGGER\_GROUP\] \[NVARCHAR\] (150)  NOT NULL ,  
  \[INSTANCE\_NAME\] \[NVARCHAR\] (200)  NOT NULL ,  
  \[FIRED\_TIME\] \[BIGINT\] NOT NULL ,  
  \[PRIORITY\] \[INTEGER\] NOT NULL ,  
  \[STATE\] \[NVARCHAR\] (16)  NOT NULL,  
  \[JOB\_NAME\] \[NVARCHAR\] (150)  NULL ,  
  \[JOB\_GROUP\] \[NVARCHAR\] (150)  NULL ,  
  \[IS\_NONCONCURRENT\] BIT  NULL ,  
  \[REQUESTS\_RECOVERY\] BIT  NULL   
) ON \[PRIMARY\]  
GO  
CREATE TABLE \[dbo\].\[QRTZ\_PAUSED\_TRIGGER\_GRPS\] (  
  \[SCHED\_NAME\] \[NVARCHAR\] (100)  NOT NULL ,  
  \[TRIGGER\_GROUP\] \[NVARCHAR\] (150)  NOT NULL   
) ON \[PRIMARY\]  
GO  
CREATE TABLE \[dbo\].\[QRTZ\_SCHEDULER\_STATE\] (  
  \[SCHED\_NAME\] \[NVARCHAR\] (100)  NOT NULL ,  
  \[INSTANCE\_NAME\] \[NVARCHAR\] (200)  NOT NULL ,  
  \[LAST\_CHECKIN\_TIME\] \[BIGINT\] NOT NULL ,  
  \[CHECKIN\_INTERVAL\] \[BIGINT\] NOT NULL  
) ON \[PRIMARY\]  
GO  
CREATE TABLE \[dbo\].\[QRTZ\_LOCKS\] (  
  \[SCHED\_NAME\] \[NVARCHAR\] (100)  NOT NULL ,  
  \[LOCK\_NAME\] \[NVARCHAR\] (40)  NOT NULL   
) ON \[PRIMARY\]  
GO  
CREATE TABLE \[dbo\].\[QRTZ\_JOB\_DETAILS\] (  
  \[SCHED\_NAME\] \[NVARCHAR\] (100)  NOT NULL ,  
  \[JOB\_NAME\] \[NVARCHAR\] (150)  NOT NULL ,  
  \[JOB\_GROUP\] \[NVARCHAR\] (150)  NOT NULL ,  
  \[DESCRIPTION\] \[NVARCHAR\] (250) NULL ,  
  \[JOB\_CLASS\_NAME\] \[NVARCHAR\] (250)  NOT NULL ,  
  \[IS\_DURABLE\] BIT  NOT NULL ,  
  \[IS\_NONCONCURRENT\] BIT  NOT NULL ,  
  \[IS\_UPDATE\_DATA\] BIT  NOT NULL ,  
  \[REQUESTS\_RECOVERY\] BIT  NOT NULL ,  
  \[JOB\_DATA\] \[IMAGE\] NULL  
) ON \[PRIMARY\]  
GO  
CREATE TABLE \[dbo\].\[QRTZ\_SIMPLE\_TRIGGERS\] (  
  \[SCHED\_NAME\] \[NVARCHAR\] (100)  NOT NULL ,  
  \[TRIGGER\_NAME\] \[NVARCHAR\] (150)  NOT NULL ,  
  \[TRIGGER\_GROUP\] \[NVARCHAR\] (150)  NOT NULL ,  
  \[REPEAT\_COUNT\] \[INTEGER\] NOT NULL ,  
  \[REPEAT\_INTERVAL\] \[BIGINT\] NOT NULL ,  
  \[TIMES\_TRIGGERED\] \[INTEGER\] NOT NULL  
) ON \[PRIMARY\]  
GO  
CREATE TABLE \[dbo\].\[QRTZ\_SIMPROP\_TRIGGERS\] (  
  \[SCHED\_NAME\] \[NVARCHAR\] (100)  NOT NULL ,  
  \[TRIGGER\_NAME\] \[NVARCHAR\] (150)  NOT NULL ,  
  \[TRIGGER\_GROUP\] \[NVARCHAR\] (150)  NOT NULL ,  
  \[STR\_PROP\_1\] \[NVARCHAR\] (512) NULL,  
  \[STR\_PROP\_2\] \[NVARCHAR\] (512) NULL,  
  \[STR\_PROP\_3\] \[NVARCHAR\] (512) NULL,  
  \[INT\_PROP\_1\] \[INT\] NULL,  
  \[INT\_PROP\_2\] \[INT\] NULL,  
  \[LONG\_PROP\_1\] \[BIGINT\] NULL,  
  \[LONG\_PROP\_2\] \[BIGINT\] NULL,  
  \[DEC\_PROP\_1\] \[NUMERIC\] (13,4) NULL,  
  \[DEC\_PROP\_2\] \[NUMERIC\] (13,4) NULL,  
  \[BOOL\_PROP\_1\] BIT NULL,  
  \[BOOL\_PROP\_2\] BIT NULL,  
) ON \[PRIMARY\]  
GO  
CREATE TABLE \[dbo\].\[QRTZ\_BLOB\_TRIGGERS\] (  
  \[SCHED\_NAME\] \[NVARCHAR\] (100)  NOT NULL ,  
  \[TRIGGER\_NAME\] \[NVARCHAR\] (150)  NOT NULL ,  
  \[TRIGGER\_GROUP\] \[NVARCHAR\] (150)  NOT NULL ,  
  \[BLOB\_DATA\] \[IMAGE\] NULL  
) ON \[PRIMARY\]  
GO  
CREATE TABLE \[dbo\].\[QRTZ\_TRIGGERS\] (  
  \[SCHED\_NAME\] \[NVARCHAR\] (100)  NOT NULL ,  
  \[TRIGGER\_NAME\] \[NVARCHAR\] (150)  NOT NULL ,  
  \[TRIGGER\_GROUP\] \[NVARCHAR\] (150)  NOT NULL ,  
  \[JOB\_NAME\] \[NVARCHAR\] (150)  NOT NULL ,  
  \[JOB\_GROUP\] \[NVARCHAR\] (150)  NOT NULL ,  
  \[DESCRIPTION\] \[NVARCHAR\] (250) NULL ,  
  \[NEXT\_FIRE\_TIME\] \[BIGINT\] NULL ,  
  \[PREV\_FIRE\_TIME\] \[BIGINT\] NULL ,  
  \[PRIORITY\] \[INTEGER\] NULL ,  
  \[TRIGGER\_STATE\] \[NVARCHAR\] (16)  NOT NULL ,  
  \[TRIGGER\_TYPE\] \[NVARCHAR\] (8)  NOT NULL ,  
  \[START\_TIME\] \[BIGINT\] NOT NULL ,  
  \[END\_TIME\] \[BIGINT\] NULL ,  
  \[CALENDAR\_NAME\] \[NVARCHAR\] (200)  NULL ,  
  \[MISFIRE\_INSTR\] \[INTEGER\] NULL ,  
  \[JOB\_DATA\] \[IMAGE\] NULL  
) ON \[PRIMARY\]  
GO  
ALTER TABLE \[dbo\].\[QRTZ\_CALENDARS\] WITH NOCHECK ADD  
  CONSTRAINT \[PK\_QRTZ\_CALENDARS\] PRIMARY KEY  CLUSTERED  
  (  
    \[SCHED\_NAME\],  
    \[CALENDAR\_NAME\]  
  )  ON \[PRIMARY\]  
GO  
ALTER TABLE \[dbo\].\[QRTZ\_CRON\_TRIGGERS\] WITH NOCHECK ADD  
  CONSTRAINT \[PK\_QRTZ\_CRON\_TRIGGERS\] PRIMARY KEY  CLUSTERED  
  (  
    \[SCHED\_NAME\],  
    \[TRIGGER\_NAME\],  
    \[TRIGGER\_GROUP\]  
  )  ON \[PRIMARY\]  
GO  
ALTER TABLE \[dbo\].\[QRTZ\_FIRED\_TRIGGERS\] WITH NOCHECK ADD  
  CONSTRAINT \[PK\_QRTZ\_FIRED\_TRIGGERS\] PRIMARY KEY  CLUSTERED  
  (  
    \[SCHED\_NAME\],  
    \[ENTRY\_ID\]  
  )  ON \[PRIMARY\]  
GO  
ALTER TABLE \[dbo\].\[QRTZ\_PAUSED\_TRIGGER\_GRPS\] WITH NOCHECK ADD  
  CONSTRAINT \[PK\_QRTZ\_PAUSED\_TRIGGER\_GRPS\] PRIMARY KEY  CLUSTERED  
  (  
    \[SCHED\_NAME\],  
    \[TRIGGER\_GROUP\]  
  )  ON \[PRIMARY\]  
GO  
ALTER TABLE \[dbo\].\[QRTZ\_SCHEDULER\_STATE\] WITH NOCHECK ADD  
  CONSTRAINT \[PK\_QRTZ\_SCHEDULER\_STATE\] PRIMARY KEY  CLUSTERED  
  (  
    \[SCHED\_NAME\],  
    \[INSTANCE\_NAME\]  
  )  ON \[PRIMARY\]  
GO  
ALTER TABLE \[dbo\].\[QRTZ\_LOCKS\] WITH NOCHECK ADD  
  CONSTRAINT \[PK\_QRTZ\_LOCKS\] PRIMARY KEY  CLUSTERED  
  (  
    \[SCHED\_NAME\],  
    \[LOCK\_NAME\]  
  )  ON \[PRIMARY\]  
GO  
ALTER TABLE \[dbo\].\[QRTZ\_JOB\_DETAILS\] WITH NOCHECK ADD  
  CONSTRAINT \[PK\_QRTZ\_JOB\_DETAILS\] PRIMARY KEY  CLUSTERED  
  (  
    \[SCHED\_NAME\],  
    \[JOB\_NAME\],  
    \[JOB\_GROUP\]  
  )  ON \[PRIMARY\]  
GO  
ALTER TABLE \[dbo\].\[QRTZ\_SIMPLE\_TRIGGERS\] WITH NOCHECK ADD  
  CONSTRAINT \[PK\_QRTZ\_SIMPLE\_TRIGGERS\] PRIMARY KEY  CLUSTERED  
  (  
    \[SCHED\_NAME\],  
    \[TRIGGER\_NAME\],  
    \[TRIGGER\_GROUP\]  
  )  ON \[PRIMARY\]  
GO  
ALTER TABLE \[dbo\].\[QRTZ\_SIMPROP\_TRIGGERS\] WITH NOCHECK ADD  
  CONSTRAINT \[PK\_QRTZ\_SIMPROP\_TRIGGERS\] PRIMARY KEY  CLUSTERED  
  (  
    \[SCHED\_NAME\],  
    \[TRIGGER\_NAME\],  
    \[TRIGGER\_GROUP\]  
  )  ON \[PRIMARY\]  
GO  
ALTER TABLE \[dbo\].\[QRTZ\_TRIGGERS\] WITH NOCHECK ADD  
  CONSTRAINT \[PK\_QRTZ\_TRIGGERS\] PRIMARY KEY  CLUSTERED  
  (  
    \[SCHED\_NAME\],  
    \[TRIGGER\_NAME\],  
    \[TRIGGER\_GROUP\]  
  )  ON \[PRIMARY\]  
GO  
ALTER TABLE \[dbo\].\[QRTZ\_CRON\_TRIGGERS\] ADD  
  CONSTRAINT \[FK\_QRTZ\_CRON\_TRIGGERS\_QRTZ\_TRIGGERS\] FOREIGN KEY  
  (  
    \[SCHED\_NAME\],  
    \[TRIGGER\_NAME\],  
    \[TRIGGER\_GROUP\]  
  ) REFERENCES \[dbo\].\[QRTZ\_TRIGGERS\] (  
    \[SCHED\_NAME\],  
    \[TRIGGER\_NAME\],  
    \[TRIGGER\_GROUP\]  
  ) ON DELETE CASCADE  
GO  
ALTER TABLE \[dbo\].\[QRTZ\_SIMPLE\_TRIGGERS\] ADD  
  CONSTRAINT \[FK\_QRTZ\_SIMPLE\_TRIGGERS\_QRTZ\_TRIGGERS\] FOREIGN KEY  
  (  
    \[SCHED\_NAME\],  
    \[TRIGGER\_NAME\],  
    \[TRIGGER\_GROUP\]  
  ) REFERENCES \[dbo\].\[QRTZ\_TRIGGERS\] (  
    \[SCHED\_NAME\],  
    \[TRIGGER\_NAME\],  
    \[TRIGGER\_GROUP\]  
  ) ON DELETE CASCADE  
GO  
ALTER TABLE \[dbo\].\[QRTZ\_SIMPROP\_TRIGGERS\] ADD  
  CONSTRAINT \[FK\_QRTZ\_SIMPROP\_TRIGGERS\_QRTZ\_TRIGGERS\] FOREIGN KEY  
  (  
    \[SCHED\_NAME\],  
    \[TRIGGER\_NAME\],  
    \[TRIGGER\_GROUP\]  
  ) REFERENCES \[dbo\].\[QRTZ\_TRIGGERS\] (  
    \[SCHED\_NAME\],  
    \[TRIGGER\_NAME\],  
    \[TRIGGER\_GROUP\]  
  ) ON DELETE CASCADE  
GO  
ALTER TABLE \[dbo\].\[QRTZ\_TRIGGERS\] ADD  
  CONSTRAINT \[FK\_QRTZ\_TRIGGERS\_QRTZ\_JOB\_DETAILS\] FOREIGN KEY  
  (  
    \[SCHED\_NAME\],  
    \[JOB\_NAME\],  
    \[JOB\_GROUP\]  
  ) REFERENCES \[dbo\].\[QRTZ\_JOB\_DETAILS\] (  
    \[SCHED\_NAME\],  
    \[JOB\_NAME\],  
    \[JOB\_GROUP\]  
  )  
GO  
CREATE INDEX IDX\_QRTZ\_T\_J ON QRTZ\_TRIGGERS(SCHED\_NAME,JOB\_NAME,JOB\_GROUP)  
CREATE INDEX IDX\_QRTZ\_T\_JG ON QRTZ\_TRIGGERS(SCHED\_NAME,JOB\_GROUP)  
CREATE INDEX IDX\_QRTZ\_T\_C ON QRTZ\_TRIGGERS(SCHED\_NAME,CALENDAR\_NAME)  
CREATE INDEX IDX\_QRTZ\_T\_G ON QRTZ\_TRIGGERS(SCHED\_NAME,TRIGGER\_GROUP)  
CREATE INDEX IDX\_QRTZ\_T\_STATE ON QRTZ\_TRIGGERS(SCHED\_NAME,TRIGGER\_STATE)  
CREATE INDEX IDX\_QRTZ\_T\_N\_STATE ON QRTZ\_TRIGGERS(SCHED\_NAME,TRIGGER\_NAME,TRIGGER\_GROUP,TRIGGER\_STATE)  
CREATE INDEX IDX\_QRTZ\_T\_N\_G\_STATE ON QRTZ\_TRIGGERS(SCHED\_NAME,TRIGGER\_GROUP,TRIGGER\_STATE)  
CREATE INDEX IDX\_QRTZ\_T\_NEXT\_FIRE\_TIME ON QRTZ\_TRIGGERS(SCHED\_NAME,NEXT\_FIRE\_TIME)  
CREATE INDEX IDX\_QRTZ\_T\_NFT\_ST ON QRTZ\_TRIGGERS(SCHED\_NAME,TRIGGER\_STATE,NEXT\_FIRE\_TIME)  
CREATE INDEX IDX\_QRTZ\_T\_NFT\_MISFIRE ON QRTZ\_TRIGGERS(SCHED\_NAME,MISFIRE\_INSTR,NEXT\_FIRE\_TIME)  
CREATE INDEX IDX\_QRTZ\_T\_NFT\_ST\_MISFIRE ON QRTZ\_TRIGGERS(SCHED\_NAME,MISFIRE\_INSTR,NEXT\_FIRE\_TIME,TRIGGER\_STATE)  
CREATE INDEX IDX\_QRTZ\_T\_NFT\_ST\_MISFIRE\_GRP ON QRTZ\_TRIGGERS(SCHED\_NAME,MISFIRE\_INSTR,NEXT\_FIRE\_TIME,TRIGGER\_GROUP,TRIGGER\_STATE)  
CREATE INDEX IDX\_QRTZ\_FT\_TRIG\_INST\_NAME ON QRTZ\_FIRED\_TRIGGERS(SCHED\_NAME,INSTANCE\_NAME)  
CREATE INDEX IDX\_QRTZ\_FT\_INST\_JOB\_REQ\_RCVRY ON QRTZ\_FIRED\_TRIGGERS(SCHED\_NAME,INSTANCE\_NAME,REQUESTS\_RECOVERY)  
CREATE INDEX IDX\_QRTZ\_FT\_J\_G ON QRTZ\_FIRED\_TRIGGERS(SCHED\_NAME,JOB\_NAME,JOB\_GROUP)  
CREATE INDEX IDX\_QRTZ\_FT\_JG ON QRTZ\_FIRED\_TRIGGERS(SCHED\_NAME,JOB\_GROUP)  
CREATE INDEX IDX\_QRTZ\_FT\_T\_G ON QRTZ\_FIRED\_TRIGGERS(SCHED\_NAME,TRIGGER\_NAME,TRIGGER\_GROUP)  
CREATE INDEX IDX\_QRTZ\_FT\_TG ON QRTZ\_FIRED\_TRIGGERS(SCHED\_NAME,TRIGGER\_GROUP)

# 2、配置application-quartz.properties参数 #

\#默认或是自己改名字都行  
org.quartz.scheduler.instanceName= YinQinQuartzScheduler

\#如果使用集群，instanceId必须唯一，设置成AUTO  
org.quartz.scheduler.instanceId = AUTO

org.quartz.scheduler.rmi.export= false  
org.quartz.scheduler.rmi.proxy=false  
org.quartz.scheduler.wrapJobExecutionInUserTransaction= false

org.quartz.threadPool.class= org.quartz.simpl.SimpleThreadPool  
org.quartz.threadPool.threadCount= 10  
org.quartz.threadPool.threadPriority= 5  
org.quartz.threadPool.threadsInheritContextClassLoaderOfInitializingThread= true

org.quartz.jobStore.misfireThreshold= 60000  
\#============================================================================  
\# Configure JobStore  
\#============================================================================

\#  
\#org.quartz.jobStore.class: org.quartz.simpl.RAMJobStore

\#存储方式使用JobStoreTX，也就是数据库  
org.quartz.jobStore.class=org.quartz.impl.jdbcjobstore.JobStoreTX  
org.quartz.jobStore.driverDelegateClass=org.quartz.impl.jdbcjobstore.StdJDBCDelegate  
\#使用自己的配置文件  
org.quartz.jobStore.useProperties=true  
\#数据库中quartz表的表名前缀  
org.quartz.jobStore.tablePrefix=QRTZ\_  
org.quartz.jobStore.dataSource=qzDS  
\#是否使用集群（如果项目只部署到 一台服务器，就不用了）  
org.quartz.jobStore.isClustered = false

\#============================================================================  
\# Configure Datasources  
\#============================================================================  
\#配置数据源  
org.quartz.dataSource.qzDS.driver=com.microsoft.sqlserver.jdbc.SQLServerDriver  
org.quartz.dataSource.qzDS.URL=jdbc:sqlserver://ip:1433;DatabaseName=数据库名称  
org.quartz.dataSource.qzDS.user=sa  
org.quartz.dataSource.qzDS.password=\*\*\*\*\*\*

# 3、配置类 #

import org.quartz.spi.TriggerFiredBundle;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.beans.factory.config.AutowireCapableBeanFactory;
    import org.springframework.scheduling.quartz.AdaptableJobFactory;
    import org.springframework.stereotype.Component;
    
    /**
     * @Description
     */
    @Component
    public class JobFactory extends AdaptableJobFactory {
        @Autowired
        private AutowireCapableBeanFactory capableBeanFactory;
    
        @Override
        protected Object createJobInstance(TriggerFiredBundle bundle) throws Exception {
            //调用父类的方法
            Object jobInstance = super.createJobInstance(bundle);
            //进行注入
            capableBeanFactory.autowireBean(jobInstance);
            return jobInstance;
        }
    }

import org.quartz.Scheduler;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.beans.factory.config.PropertiesFactoryBean;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.core.io.ClassPathResource;
    import org.springframework.scheduling.quartz.SchedulerFactoryBean;
    
    import java.io.IOException;
    import java.util.Properties;
    
    
    /**
     * @Description
     */
    @Configuration
    public class QuartzConfig {
    
        @Autowired
        private JobFactory jobFactory;
    
        @Bean
        public Properties quartzProperties() throws IOException {
            PropertiesFactoryBean propertiesFactoryBean = new PropertiesFactoryBean();
            propertiesFactoryBean.setLocation(new ClassPathResource("/application-quartz.properties"));
            propertiesFactoryBean.afterPropertiesSet();
            return propertiesFactoryBean.getObject();
        }
    
    
        @Bean
        public SchedulerFactoryBean schedulerFactoryBean() throws IOException {
            SchedulerFactoryBean schedulerFactoryBean = new SchedulerFactoryBean();
    
            schedulerFactoryBean.setOverwriteExistingJobs(true);
            schedulerFactoryBean.setQuartzProperties(quartzProperties());
            schedulerFactoryBean.setJobFactory(jobFactory);
    
            return schedulerFactoryBean;
        }
    
    
        // 创建schedule
        @Bean(name = "scheduler")
        public Scheduler scheduler() throws IOException {
            return schedulerFactoryBean().getScheduler();
        }
    }

# 4、调度类 #

--------------------

@RestController
    @RequestMapping(value = "/test")
    public class TestController {
    
        private static Logger logger = LoggerFactory.getLogger(TestController.class);
        @Autowired
        private QuartzService quartzService;
    
        @RequestMapping(value = "test11")
        public String test11() {
            quartzService.addJob(DynamicJob.class, "测试2", "测试分组1", 10, 2);
            return "去控制台查看打印";
        }
    }

import java.util.ArrayList;
    import java.util.HashMap;
    import java.util.List;
    import java.util.Map;
    import java.util.Set;
    
    import javax.annotation.PostConstruct;
    
    import org.quartz.*;
    import org.quartz.DateBuilder.IntervalUnit;
    import org.quartz.impl.matchers.GroupMatcher;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.scheduling.quartz.QuartzJobBean;
    import org.springframework.stereotype.Service;
    @Service
    public class QuartzService {
        @Autowired
        private Scheduler scheduler;
    
        @PostConstruct
        public void startScheduler() {
            try {
                scheduler.start();
            } catch (SchedulerException e) {
                e.printStackTrace();
            }
        }
    
        /**
         * 增加一个job
         *
         * @param jobClass
         *            任务实现类
         * @param jobName
         *            任务名称
         * @param jobGroupName
         *            任务组名
         * @param jobTime
         *            时间表达式 (这是每隔多少秒为一次任务)
         * @param jobTimes
         *            运行的次数 （<0:表示不限次数）
         */
        public void addJob(Class<? extends Job> jobClass, String jobName, String jobGroupName, int jobTime,
                           int jobTimes) {
            try {
                JobDetail jobDetail = JobBuilder.newJob(jobClass).withIdentity(jobName, jobGroupName)// 任务名称和组构成任务key
                        .build();
                // 使用simpleTrigger规则
                Trigger trigger = null;
                if (jobTimes < 0) {
                    trigger = TriggerBuilder.newTrigger().withIdentity(jobName, jobGroupName)
                            .withSchedule(SimpleScheduleBuilder.repeatSecondlyForever(1).withIntervalInSeconds(jobTime))
                            .startNow().build();
                } else {
                    trigger = TriggerBuilder
                            .newTrigger().withIdentity(jobName, jobGroupName).withSchedule(SimpleScheduleBuilder
                                    .repeatSecondlyForever(1).withIntervalInSeconds(jobTime).withRepeatCount(jobTimes))
                            .startNow().build();
                }
                scheduler.scheduleJob(jobDetail, trigger);
            } catch (SchedulerException e) {
                e.printStackTrace();
            }
        }
    
        /**
         * 增加一个job
         *
         * @param jobClass
         *            任务实现类
         * @param jobName
         *            任务名称
         * @param jobGroupName
         *            任务组名
         * @param jobTime
         *            时间表达式 （如：0/5 * * * * ? ）
         */
        public void addJob(Class<? extends QuartzJobBean> jobClass, String jobName, String jobGroupName, String jobTime) {
            try {
                // 创建jobDetail实例，绑定Job实现类
                // 指明job的名称，所在组的名称，以及绑定job类
                JobDetail jobDetail = JobBuilder.newJob(jobClass).withIdentity(jobName, jobGroupName)// 任务名称和组构成任务key
                        .build();
                // 定义调度触发规则
                // 使用cornTrigger规则
                Trigger trigger = TriggerBuilder.newTrigger().withIdentity(jobName, jobGroupName)// 触发器key
                        .startAt(DateBuilder.futureDate(1, IntervalUnit.SECOND))
                        .withSchedule(CronScheduleBuilder.cronSchedule(jobTime)).startNow().build();
                // 把作业和触发器注册到任务调度中
                scheduler.scheduleJob(jobDetail, trigger);
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    
        /**
         * 修改 一个job的 时间表达式
         *
         * @param jobName
         * @param jobGroupName
         * @param jobTime
         */
        public void updateJob(String jobName, String jobGroupName, String jobTime) {
            try {
                TriggerKey triggerKey = TriggerKey.triggerKey(jobName, jobGroupName);
                CronTrigger trigger = (CronTrigger) scheduler.getTrigger(triggerKey);
                trigger = trigger.getTriggerBuilder().withIdentity(triggerKey)
                        .withSchedule(CronScheduleBuilder.cronSchedule(jobTime)).build();
                // 重启触发器
                scheduler.rescheduleJob(triggerKey, trigger);
            } catch (SchedulerException e) {
                e.printStackTrace();
            }
        }
    
        /**
         * 删除任务一个job
         *
         * @param jobName
         *            任务名称
         * @param jobGroupName
         *            任务组名
         */
        public void deleteJob(String jobName, String jobGroupName) {
            try {
                scheduler.deleteJob(new JobKey(jobName, jobGroupName));
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    
        /**
         * 暂停一个job
         *
         * @param jobName
         * @param jobGroupName
         */
        public void pauseJob(String jobName, String jobGroupName) {
            try {
                JobKey jobKey = JobKey.jobKey(jobName, jobGroupName);
                scheduler.pauseJob(jobKey);
            } catch (SchedulerException e) {
                e.printStackTrace();
            }
        }
    
        /**
         * 恢复一个job
         *
         * @param jobName
         * @param jobGroupName
         */
        public void resumeJob(String jobName, String jobGroupName) {
            try {
                JobKey jobKey = JobKey.jobKey(jobName, jobGroupName);
                scheduler.resumeJob(jobKey);
            } catch (SchedulerException e) {
                e.printStackTrace();
            }
        }
    
        /**
         * 立即执行一个job
         *
         * @param jobName
         * @param jobGroupName
         */
        public void runAJobNow(String jobName, String jobGroupName) {
            try {
                JobKey jobKey = JobKey.jobKey(jobName, jobGroupName);
                scheduler.triggerJob(jobKey);
            } catch (SchedulerException e) {
                e.printStackTrace();
            }
        }
    
        /**
         * 获取所有计划中的任务列表
         *
         * @return
         */
        public List<Map<String, Object>> queryAllJob() {
            List<Map<String, Object>> jobList = null;
            try {
                GroupMatcher<JobKey> matcher = GroupMatcher.anyJobGroup();
                Set<JobKey> jobKeys = scheduler.getJobKeys(matcher);
                jobList = new ArrayList<Map<String, Object>>();
                for (JobKey jobKey : jobKeys) {
                    List<? extends Trigger> triggers = scheduler.getTriggersOfJob(jobKey);
                    for (Trigger trigger : triggers) {
                        Map<String, Object> map = new HashMap<>();
                        map.put("jobName", jobKey.getName());
                        map.put("jobGroupName", jobKey.getGroup());
                        map.put("description", "触发器:" + trigger.getKey());
                        Trigger.TriggerState triggerState = scheduler.getTriggerState(trigger.getKey());
                        map.put("jobStatus", triggerState.name());
                        if (trigger instanceof CronTrigger) {
                            CronTrigger cronTrigger = (CronTrigger) trigger;
                            String cronExpression = cronTrigger.getCronExpression();
                            map.put("jobTime", cronExpression);
                        }
                        jobList.add(map);
                    }
                }
            } catch (SchedulerException e) {
                e.printStackTrace();
            }
            return jobList;
        }
    
        /**
         * 获取所有正在运行的job
         *
         * @return
         */
        public List<Map<String, Object>> queryRunJob() {
            List<Map<String, Object>> jobList = null;
            try {
                List<JobExecutionContext> executingJobs = scheduler.getCurrentlyExecutingJobs();
                jobList = new ArrayList<Map<String, Object>>(executingJobs.size());
                for (JobExecutionContext executingJob : executingJobs) {
                    Map<String, Object> map = new HashMap<String, Object>();
                    JobDetail jobDetail = executingJob.getJobDetail();
                    JobKey jobKey = jobDetail.getKey();
                    Trigger trigger = executingJob.getTrigger();
                    map.put("jobName", jobKey.getName());
                    map.put("jobGroupName", jobKey.getGroup());
                    map.put("description", "触发器:" + trigger.getKey());
                    Trigger.TriggerState triggerState = scheduler.getTriggerState(trigger.getKey());
                    map.put("jobStatus", triggerState.name());
                    if (trigger instanceof CronTrigger) {
                        CronTrigger cronTrigger = (CronTrigger) trigger;
                        String cronExpression = cronTrigger.getCronExpression();
                        map.put("jobTime", cronExpression);
                    }
                    jobList.add(map);
                }
            } catch (SchedulerException e) {
                e.printStackTrace();
            }
            return jobList;
        }
    }

# 5、触发类 #

--------------------

import org.quartz.Job;
    import org.quartz.JobExecutionContext;
    import org.quartz.JobExecutionException;
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    
    import java.io.BufferedReader;
    import java.io.IOException;
    import java.io.InputStream;
    import java.io.InputStreamReader;
    
    public class DynamicJob implements Job {
        private static Logger logger = LoggerFactory.getLogger(DynamicJob.class);
    
        @Override
        public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
            System.out.println("quartz定时任务执行");
    
        }
    }