SpringBoot2集成Quartz配置独立数据源

article/2025/10/7 16:33:22

需求说明

Quartz配置需要部署独立的表结构，但是经常存于业务表之间，有些时候可能需要与业务表分开配置，所以在此给Quartz配置独立的数据源

一.版本介绍

Springboot版本为2.1.6 多数据源配置使用druid进行配置,数据库使用的为Oracle11g,如果使用的是MySQL,直接将数据库的地址和驱动改一下即可

    <parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>2.1.6.RELEASE</version><relativePath/></parent><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-quartz</artifactId></dependency><dependency><groupId>com.alibaba</groupId><artifactId>druid-spring-boot-starter</artifactId><version>1.1.17</version></dependency><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><optional>true</optional></dependency>

二.Quartz配置介绍

spring:datasource:type: com.alibaba.druid.pool.DruidDataSourcedriver-class-name: oracle.jdbc.driver.OracleDriverdruid:business: # 配置业务数据源url: jdbc:oracle:thin:@127.0.0.1:1521:orclusername: businesspassword: businessquartz:   #配置Quartz数据源url: jdbc:oracle:thin:@127.0.0.1:1521:orclusername: quartzpassword: quartz# 下面为连接池的补充设置，应用到上面所有数据源中# 初始化大小，最小，最大initialSize: 5minIdle: 5maxActive: 15# 配置获取连接等待超时的时间maxWait: 60000# 配置间隔多久才进行一次检测，检测需要关闭的空闲连接，单位是毫秒timeBetweenEvictionRunsMillis: 60000minEvictableIdleTimeMillis: 300000validationQuery: SELECT 1 FROM DUALtestWhileIdle: truetestOnBorrow: falsetestOnReturn: false# 打开PSCache，并且指定每个连接上PSCache的大小poolPreparedStatements: true# 配置监控统计拦截的filters，去掉后监控界面sql无法统计，'wall'用于防火墙maxPoolPreparedStatementPerConnectionSize: 20filters: stat,wall,log4j2# 通过connectProperties属性来打开mergeSql功能；慢SQL记录connectionProperties: druid.stat.mergeSql=true;druid.stat.slowSqlMillis=5000# 合并多个DruidDataSource的监控数据useGlobalDataSourceStat: trueremove-abandoned: trueremove-abandoned-timeout: 180log-abandoned: truequartz:jdbc:initialize-schema: never #配置是否每次重启项目都自动生成Quartz表结构,在此使用always生成一次后就可以改为never配置job-store-type: jdbcproperties:org:quartz:scheduler:instanceName: etlCleanSchedulerinstanceId: AUTOjobStore:class: org.quartz.impl.jdbcjobstore.JobStoreTXdriverDelegateClass: org.quartz.impl.jdbcjobstore.StdJDBCDelegatetablePrefix: QRTZ_  #Quartz表前缀isClustered: trueclusterCheckinInterval: 10000useProperties: falsethreadPool:class: org.quartz.simpl.SimpleThreadPool#线程数 一个任务使用一个线程threadCount: 100threadPriority: 5threadsInheritContextClassLoaderOfInitializingThread: true

三.配置多数据源

package com.rubikstack.etlclean.config;import com.alibaba.druid.pool.DruidDataSource;
import lombok.extern.slf4j.Slf4j;
import org.apache.ibatis.session.SqlSessionFactory;
import org.mybatis.spring.SqlSessionFactoryBean;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.autoconfigure.quartz.QuartzDataSource;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;
import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
import tk.mybatis.spring.annotation.MapperScan;import javax.sql.DataSource;
import java.util.Properties;@Slf4j
@Configuration
@MapperScan(basePackages = DataSourceConfig.MAPPER_PACKAGE, sqlSessionFactoryRef = DataSourceConfig.SESSION_FACTORY)
public class DataSourceConfig {@Value("${mybatis.queryLimit}")private String queryLimit;static final String SESSION_FACTORY = "dbSqlSessionFactory";private static final String DATASOURCE_NAME = "dbDataSource";/*** mapper类的包路径*/static final String MAPPER_PACKAGE = "com.example.mapper";static final String MODEL_PACKAGE = "com.example.model";/*** 自定义mapper的xml文件路径*/private static final String MAPPER_XML_PATH = "classpath*:com.example.mapper/*Mapper.xml";/*** 数据源配置的前缀，必须与application.properties中配置的对应数据源的前缀一致*/private static final String BUSINESS_DATASOURCE_PREFIX = "spring.datasource.druid.business";private static final String QUARTZ_DATASOURCE_PREFIX = "spring.datasource.druid.quartz";@Primary@Bean(name = DATASOURCE_NAME)@ConfigurationProperties(prefix = BUSINESS_DATASOURCE_PREFIX)public DruidDataSource druidDataSource() {return new DruidDataSource();}/*** 配置Mybatis环境*/@Primary@Bean(name = SESSION_FACTORY)public SqlSessionFactory sqlSessionFactory() {log.info("配置SqlSessionFactory开始");final SqlSessionFactoryBean sessionFactoryBean = new SqlSessionFactoryBean();sessionFactoryBean.setDataSource(druidDataSource());try {PathMatchingResourcePatternResolver resolver = new PathMatchingResourcePatternResolver();// 自定义mapper的xml文件地址，当通用mapper提供的默认功能无法满足我们的需求时，可以自己添加实现，与mybatis写mapper一样sessionFactoryBean.setMapperLocations(resolver.getResources(MAPPER_XML_PATH));org.apache.ibatis.session.Configuration configuration = new org.apache.ibatis.session.Configuration();Properties properties = new Properties();properties.put("queryLimit",queryLimit);configuration.setVariables(properties);configuration.setMapUnderscoreToCamelCase(true);configuration.setLogImpl(org.apache.ibatis.logging.stdout.StdOutImpl.class);sessionFactoryBean.setConfiguration(configuration);sessionFactoryBean.setTypeAliasesPackage(MODEL_PACKAGE);return sessionFactoryBean.getObject();} catch (Exception e) {log.error("配置SqlSessionFactory失败，error:{}", e.getMessage());throw new RuntimeException(e.getMessage());}}/*** @QuartzDataSource 注解则是配置Quartz独立数据源的配置*/@Bean@QuartzDataSource @ConfigurationProperties(prefix = QUARTZ_DATASOURCE_PREFIX)public DataSource quartzDataSource(){return new DruidDataSource();}
}

有关@QuartzDataSource的配置请看SpringBoot官方文档
https://docs.spring.io/spring-boot/docs/current-SNAPSHOT/reference/htmlsingle/#boot-features-quartz