diff --git a/maku-boot-module/maku-module-quartz/src/main/java/net/maku/quartz/config/ScheduleConfig.java b/maku-boot-module/maku-module-quartz/src/main/java/net/maku/quartz/config/ScheduleConfig.java index 88bf0dd..2f91dd4 100644 --- a/maku-boot-module/maku-module-quartz/src/main/java/net/maku/quartz/config/ScheduleConfig.java +++ b/maku-boot-module/maku-module-quartz/src/main/java/net/maku/quartz/config/ScheduleConfig.java @@ -3,6 +3,8 @@ package net.maku.quartz.config; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.scheduling.quartz.SchedulerFactoryBean; +import org.springframework.beans.factory.annotation.Value; +import net.maku.framework.common.constant.Constant; import javax.sql.DataSource; import java.util.Properties; @@ -16,6 +18,9 @@ import java.util.Properties; @Configuration public class ScheduleConfig { + @Value("spring.datasource.driver-class-name") + private String driver; + @Bean public SchedulerFactoryBean schedulerFactoryBean(DataSource dataSource) { // quartz参数 @@ -38,6 +43,10 @@ public class ScheduleConfig { prop.put("org.quartz.jobStore.tablePrefix", "QRTZ_"); prop.put("org.quartz.jobStore.selectWithLockSQL", "SELECT * FROM {0}LOCKS UPDLOCK WHERE LOCK_NAME = ?"); + //postgreSql数据库配置 + if(Constant.PGSQL_DRIVER.equals(driver)){ + prop.put("org.quartz.jobStore.driverDelegateClass", "org.quartz.impl.jdbcjobstore.PostgreSQLDelegate"); + } SchedulerFactoryBean factory = new SchedulerFactoryBean(); factory.setSchedulerName("MakuScheduler"); factory.setDataSource(dataSource); diff --git a/maku-framework/src/main/java/net/maku/framework/common/constant/Constant.java b/maku-framework/src/main/java/net/maku/framework/common/constant/Constant.java index eda6358..7e5d7e5 100644 --- a/maku-framework/src/main/java/net/maku/framework/common/constant/Constant.java +++ b/maku-framework/src/main/java/net/maku/framework/common/constant/Constant.java @@ -44,4 +44,9 @@ public interface Constant { */ String OK = "OK"; + /** + * pgsql的driver + */ + String PGSQL_DRIVER = "org.postgresql.Driver"; + } \ No newline at end of file