quartz 持久化 數據庫表

此處只包括配置數據庫操做

 

quartz 持久化數據庫表格字段解釋建表,SQL語句在dbTables文件夾中能夠找到,介紹下咱們開發主要使用到的表： （版本不同，可能數據庫表也不同，這裏使用2.2.1）

一、QRTZ_JOB_DETAILS：存儲的是job的詳細信息，包括：[DESCRIPTION]描述，[IS_DURABLE]是否持久化，[JOB_DATA]持久化對象等基本信息。

二、QRTZ_TRIGGERS：觸發器信息,包含：job的名，組外鍵，[DESCRIPTION]觸發器的描述等基本信息，還有[START_TIME]開始執行時間，[END_TIME]結束執行時間，[PREV_FIRE_TIME]上次執行時間，[NEXT_FIRE_TIME]下次執行時間，[TRIGGER_TYPE]觸發器類型：simple和cron，[TRIGGER_STATE]執行狀態：WAITING，PAUSED，ACQUIRED分別爲：等待，暫停，運行中。

三、QRTZ_CRON_TRIGGERS：保存cron表達式。

四、QRTZ_SCHEDULER_STATE：存儲集羣中note實例信息，quartz會定時讀取該表的信息判斷集羣中每一個實例的當前狀態，INSTANCE_NAME:以前配置文件中org.quartz.scheduler.instanceId配置的名字，就會寫入該字段，若是設置爲AUTO,quartz會根據物理機名和當前時間產生一個名字。  [LAST_CHECKIN_TIME]上次檢查時間，[CHECKIN_INTERVAL]檢查間隔時間。

五、QRTZ_PAUSED_TRIGGER_GRPS：暫停的任務組信息。

六、QRTZ_LOCKS，悲觀鎖發生的記錄信息。

七、QRTZ_FIRED_TRIGGERS，正在運行的觸發器信息。

八、QRTZ_SIMPLE_TRIGGERS，簡單的出發器詳細信息。

九、QRTZ_BLOB_TRIGGERS,觸發器存爲二進制大對象類型(用於Quartz用戶本身觸發數據庫定製本身的觸發器，然而JobStore不明白怎麼存放實例的時候)。

 

 quartz.properties

# Default Properties file for use by StdSchedulerFactory
# to create a Quartz Scheduler Instance, if a different
# properties file is not explicitly specified.
#

org.quartz.scheduler.instanceName= DefaultQuartzScheduler
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

org.quartz.jobStore.class=  org.quartz.impl.jdbcjobstore.JobStoreTX
org.quartz.jobStore.driverDelegateClass = org.quartz.impl.jdbcjobstore.StdJDBCDelegate
org.quartz.jobStore.tablePrefix = QRTZ_

#不須要整合其餘框架數據庫時--------須要整合時，如下備註相反便可
org.quartz.jobStore.dataSource = qzDS

org.quartz.dataSource.qzDS.driver= net.sourceforge.jtds.jdbc.Driver
org.quartz.dataSource.qzDS.URL = jdbc:jtds:sqlserver://localhost:1433/quartz
org.quartz.dataSource.qzDS.user= sa
org.quartz.dataSource.qzDS.password= 1234
org.quartz.dataSource.qzDS.maxConnections = 30
#org.quartz.jobStore.selectWithLockSQL=select * from {0}LOCKS UPDLOCK WHERE LOCK_NAME=?

　　

整合SpringMVC：

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns="http://www.springframework.org/schema/beans"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd">

    <!-- 導入數據庫配置 -->
    <import resource="spring-datasources.xml"/>
　　 <!-- 配置job可以使用springmvc bean -->
    <bean id="jobFactory" class="com.ice.quartz.factory.JobFactory"></bean>

    <bean id="jobRecordListener" class="com.ice.quartz.listener.JobRecordListener" />
    <bean id="triggerRecordListener" class="com.ice.quartz.listener.TriggerRecordListener" />
    <bean id="DefaultQuartzScheduler" lazy-init="false" autowire="no" class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
        <property name="dataSource" ref="defaultDataSource"/>
        <property name="configLocation" value="classpath:quartz.properties" />
        <property name="jobFactory" ref="jobFactory"></property>
        <property name="triggers">
            <list>
                <ref bean="hourTrigger"></ref>
                <ref bean="dayTrigger"></ref>
                <ref bean="weekTrigger"></ref>
                <ref bean="monthTrigger"></ref>
                <ref bean="quarterTrigger"></ref>
                <ref bean="yearTrigger"></ref>
            </list>
        </property>
　　　　 <!-- 使用注入方式使用springMVC bean -->
        <property name="schedulerContextAsMap">
            <map>
                <entry key="jobTriggerRecordMapper" value-ref="jobTriggerRecordMapper"></entry>
            </map>
        </property>
        <property name="globalJobListeners" ref="jobRecordListener"></property>
        <property name="globalTriggerListeners" ref="triggerRecordListener"></property>
    </bean>
</beans>

　　

配置job可以使用springmvc bean 

package com.ice.quartz.factory;

import org.quartz.spi.TriggerFiredBundle;
import org.springframework.beans.BeansException;
import org.springframework.context.ApplicationContext;
import org.springframework.context.ApplicationContextAware;
import org.springframework.scheduling.quartz.SpringBeanJobFactory;

/**
 * @author sky
 * @version 1.0
 * @since 4.0
 */
public class JobFactory extends SpringBeanJobFactory implements ApplicationContextAware {
    private ApplicationContext applicationContext;

    @Override
    protected Object createJobInstance(TriggerFiredBundle bundle) throws Exception {
        Object jobInstance = super.createJobInstance(bundle);
        applicationContext.getAutowireCapableBeanFactory().autowireBean(jobInstance);
        return jobInstance;
    }

    @Override
    public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
        this.applicationContext = applicationContext;
    }
}