syy/SYYTe
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

!11 修复数据库是pgsql时添加quartz模块启动失败报long类型问题 

Merge pull request !11 from 王祁/master
This commit is contained in:
阿沐 2023-03-14 06:01:10 +00:00 committed by Gitee
parent 88da850e4d 229e8c15b1
commit 2f034547e4
No known key found for this signature in database
GPG Key ID: 173E9B9CA92EEF8F
2 changed files with 14 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
maku-boot-module/maku-module-quartz/src/main/java/net/maku/quartz/config/ScheduleConfig.java
View File

@ -3,6 +3,8 @@ package net.maku.quartz.config;
import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration; import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.quartz.SchedulerFactoryBean; 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 javax.sql.DataSource;
import java.util.Properties; import java.util.Properties;
@ -16,6 +18,9 @@ import java.util.Properties;
@Configuration @Configuration
public class ScheduleConfig { public class ScheduleConfig {
@Value("spring.datasource.driver-class-name")
private String driver;
@Bean @Bean
public SchedulerFactoryBean schedulerFactoryBean(DataSource dataSource) { public SchedulerFactoryBean schedulerFactoryBean(DataSource dataSource) {
// quartz参数 // quartz参数
@ -38,6 +43,10 @@ public class ScheduleConfig {
prop.put("org.quartz.jobStore.tablePrefix", "QRTZ_"); prop.put("org.quartz.jobStore.tablePrefix", "QRTZ_");
prop.put("org.quartz.jobStore.selectWithLockSQL", "SELECT * FROM {0}LOCKS UPDLOCK WHERE LOCK_NAME = ?"); 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(); SchedulerFactoryBean factory = new SchedulerFactoryBean();
factory.setSchedulerName("MakuScheduler"); factory.setSchedulerName("MakuScheduler");
factory.setDataSource(dataSource); factory.setDataSource(dataSource);

5
maku-framework/src/main/java/net/maku/framework/common/constant/Constant.java
View File

@ -44,4 +44,9 @@ public interface Constant {
*/ */
String OK = "OK"; String OK = "OK";
/**
* pgsql的driver
*/
String PGSQL_DRIVER = "org.postgresql.Driver";
} }