feat: handle db using liquibase and expose endpoints

scheduler/boot-scheduler-quartz/src/main/java/com/scheduler/quartz/job/SampleJob.java

@@ -1,12 +1,14 @@
 package com.scheduler.quartz.job;
 
 import com.scheduler.quartz.service.OddEvenService;
+import org.quartz.DisallowConcurrentExecution;
 import org.quartz.Job;
 import org.quartz.JobExecutionContext;
 import org.quartz.JobExecutionException;
 import org.springframework.stereotype.Component;
 
 @Component
+@DisallowConcurrentExecution
 public class SampleJob implements Job {
 
     private final OddEvenService oddEvenService;

scheduler/boot-scheduler-quartz/src/main/java/com/scheduler/quartz/job/SchedulerRegistrationService.java

@@ -2,6 +2,7 @@
 
 import static org.quartz.DateBuilder.futureDate;
 import static org.quartz.JobBuilder.newJob;
+import static org.quartz.SimpleScheduleBuilder.simpleSchedule;
 import static org.quartz.TriggerBuilder.newTrigger;
 
 import org.quartz.*;
@@ -14,18 +15,23 @@ public class SchedulerRegistrationService {
     @Bean
     JobDetail registerOddJob() {
         return newJob(SampleJob.class)
-                .withIdentity("sample-job")
+                .withIdentity("sample-job", "sample-group")
                 .usingJobData("jobName", "odd")
                 .storeDurably()
+                .requestRecovery()
                 .build();
     }
 
     @Bean
     Trigger triggerOddJob(JobDetail registerOddJob) {
         return newTrigger()
-                .withIdentity("trigger-sample-job")
+                .withIdentity("trigger-sample-job", "sample-group")
                 .forJob(registerOddJob.getKey())
-                .startAt(futureDate(5, DateBuilder.IntervalUnit.SECOND))
+                .startAt(futureDate(10, DateBuilder.IntervalUnit.SECOND))
+                .withSchedule(simpleSchedule()
+                        .withIntervalInSeconds(5) // Run every 2 seconds
+                        .repeatForever()
+                        .withMisfireHandlingInstructionFireNow())
                 .build();
     }
 }

scheduler/boot-scheduler-quartz/src/main/java/com/scheduler/quartz/model/response/JobStatus.java

@@ -0,0 +1,3 @@
+package com.scheduler.quartz.model.response;
+
+public record JobStatus(String jobName, boolean completed) {}

scheduler/boot-scheduler-quartz/src/main/java/com/scheduler/quartz/service/JobsService.java

@@ -0,0 +1,52 @@
+package com.scheduler.quartz.service;
+
+import com.scheduler.quartz.model.response.JobStatus;
+import java.util.Comparator;
+import java.util.LinkedList;
+import java.util.List;
+import java.util.stream.Collectors;
+import org.quartz.*;
+import org.quartz.impl.matchers.GroupMatcher;
+import org.quartz.utils.Key;
+import org.springframework.stereotype.Service;
+
+@Service
+public class JobsService {
+
+    private final Scheduler scheduler;
+    private final String groupName = "sample-group";
+
+    public JobsService(Scheduler scheduler) {
+        this.scheduler = scheduler;
+    }
+
+    public boolean deleteJob(String id) throws SchedulerException {
+        JobKey jobKey = new JobKey(id, groupName);
+        return scheduler.deleteJob(jobKey);
+    }
+
+    public List<String> getJobs() throws SchedulerException {
+        return scheduler.getJobKeys(GroupMatcher.jobGroupEquals(groupName)).stream()
+                .map(Key::getName)
+                .sorted(Comparator.naturalOrder())
+                .collect(Collectors.toList());
+    }
+
+    public List<JobStatus> getJobsStatuses() throws SchedulerException {
+        LinkedList<JobStatus> list = new LinkedList<>();
+        for (JobKey jobKey : scheduler.getJobKeys(GroupMatcher.jobGroupEquals(groupName))) {
+            JobDetail jobDetail = scheduler.getJobDetail(jobKey);
+            List<? extends Trigger> triggers = scheduler.getTriggersOfJob(jobDetail.getKey());
+            for (Trigger trigger : triggers) {
+                Trigger.TriggerState triggerState = scheduler.getTriggerState(trigger.getKey());
+                if (Trigger.TriggerState.COMPLETE.equals(triggerState)) {
+                    list.add(new JobStatus(jobKey.getName(), true));
+                } else {
+                    list.add(new JobStatus(jobKey.getName(), false));
+                }
+            }
+        }
+        list.sort(Comparator.comparing(JobStatus::jobName));
+        return list;
+    }
+}

scheduler/boot-scheduler-quartz/src/main/java/com/scheduler/quartz/web/controller/JobsController.java

@@ -0,0 +1,33 @@
+package com.scheduler.quartz.web.controller;
+
+import com.scheduler.quartz.model.response.JobStatus;
+import com.scheduler.quartz.service.JobsService;
+import java.util.List;
+import org.quartz.SchedulerException;
+import org.springframework.web.bind.annotation.*;
+
+@RestController
+@RequestMapping("/api/jobs")
+public class JobsController {
+
+    private final JobsService jobsService;
+
+    public JobsController(JobsService jobsService) {
+        this.jobsService = jobsService;
+    }
+
+    @GetMapping
+    List<String> getJobs() throws SchedulerException {
+        return jobsService.getJobs();
+    }
+
+    @GetMapping("/statuses")
+    List<JobStatus> getJobsStatuses() throws SchedulerException {
+        return jobsService.getJobsStatuses();
+    }
+
+    @DeleteMapping("/{id}")
+    boolean deleteJob(@PathVariable String id) throws SchedulerException {
+        return jobsService.deleteJob(id);
+    }
+}

scheduler/boot-scheduler-quartz/src/main/resources/application.properties

@@ -28,6 +28,7 @@ spring.jpa.properties.hibernate.connection.provider_disables_autocommit=true
 spring.jpa.properties.hibernate.jdbc.lob.non_contextual_creation=true
 
 spring.quartz.job-store-type=jdbc
-spring.quartz.jdbc.initialize-schema=always
+#spring.quartz.jdbc.initialize-schema=always
+spring.quartz.properties.org.quartz.jobStore.isClustered=true
 spring.quartz.properties.org.quartz.jobStore.useProperties=true
 spring.quartz.properties.org.quartz.jobStore.driverDelegateClass=org.quartz.impl.jdbcjobstore.PostgreSQLDelegate

scheduler/boot-scheduler-quartz/src/main/resources/db/changelog/db.changelog-master.yaml

@@ -2,4 +2,16 @@ databaseChangeLog:
   - includeAll:
       path: migration/
       errorIfMissingOrEmpty: true
-      relativeToChangelogFile: true
+      relativeToChangelogFile: true
+
+  - changeSet:
+      dbms: postgresql
+      id: create-spring-quartz-metadata
+      author: raja
+      changes:
+        - sqlFile:
+            encoding: UTF-8
+            path: classpath:/org/quartz/impl/jdbcjobstore/tables_postgres.sql
+            relativeToChangelogFile: false
+            splitStatements: true
+            stripComments: true