quartz

public Result save(QuartzBean quartz) {
        LOGGER.info("新增任务");
        try {
            if (quartz.getOldJobGroup() != null) {
                JobKey key = new JobKey(quartz.getOldJobName(), quartz.getOldJobGroup());
                scheduler.deleteJob(key);
            }
            Class cls = Class.forName(quartz.getJobClassName());
            cls.newInstance();
            JobDetail job = JobBuilder.newJob(cls).withIdentity(quartz.getJobName(),
                    quartz.getJobGroup())
                    .withDescription(quartz.getDescription()).build();
            CronScheduleBuilder cronScheduleBuilder = CronScheduleBuilder.cronSchedule(quartz.getCronExpression());
            Trigger trigger = TriggerBuilder.newTrigger().withIdentity("trigger" + quartz.getJobName(), quartz.getJobGroup())
                    .startNow().withSchedule(cronScheduleBuilder).build();
            scheduler.scheduleJob(job, trigger);
        } catch (Exception e) {
            e.printStackTrace();
            return Result.error();
        }
        return Result.ok();
    }

我先声明一下我是quartz的初学者,但是在整合springboot的时候发现只要调一下这个新增接口就能在数据库qrtz_cron_triggers和qrtz_job_details表中添加进去了,我用druid去监控也没监控到sql语句,这是quartz自己在操作数据库吗???有没有大神帮我一下啊

阅读 1.9k
1 个回答

是的,quartz有个复杂的配置文件,当配置使用数据库,并且正确指定数据库jdbc参数后,quargz会自己保存job到数据库里,甚至可以配成cluster。 你找下你classpath下的quartz的配置文件,一般可以看到这样的内容就是干这个的:

org.quartz.dataSource.quartzDataSource.driver = com.mysql.jdbc.Driver
org.quartz.dataSource.quartzDataSource.URL = jdbc:mysql://localhost:3306/db
撰写回答
你尚未登录,登录后可以
  • 和开发者交流问题的细节
  • 关注并接收问题和回答的更新提醒
  • 参与内容的编辑和改进,让解决方法与时俱进
推荐问题