From 229e8c15b1f5f8e4d940e466358d1af441955121 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E7=8E=8B=E7=A5=81?= <593401899@qq.com>
Date: Tue, 14 Mar 2023 04:33:38 +0000
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E6=95=B0=E6=8D=AE=E5=BA=93?=
 =?UTF-8?q?=E6=98=AFpgsql=E6=97=B6quartz=E5=90=AF=E5=8A=A8=E5=A4=B1?=
 =?UTF-8?q?=E8=B4=A5=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

Signed-off-by: 王祁 <593401899@qq.com>
---
 .../src/main/java/net/maku/quartz/config/ScheduleConfig.java     | 9 +++++++++
 .../main/java/net/maku/framework/common/constant/Constant.java   | 5 +++++
 2 files changed, 14 insertions(+)

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