瀚高数据库适配定时框架Quartz

Posted 瀚高PG实验室

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了瀚高数据库适配定时框架Quartz相关的知识,希望对你有一定的参考价值。

瀚高数据库
目录
环境
文档用途
详细信息

环境
系统平台:N/A
版本:4.5
文档用途
本文档用于在java应用适配hgdb时,解决定时框架Quartz遇到的问题

详细信息
更改HGDB脚本
应用系统在适配瀚高数据库时,数据库往往都是通过迁移工具从mysql或oracle迁移而来,迁移之后需要更改quartz所需的表结构,原因为,迁移后,源库的boolean类型的数据存储并没有改变,迁移之后为varchar(1),瀚高数据库支持boolean类型,需要将所需字段类型改为boolean,如若不然,需要加隐士转换将character varying 类型转为boolean存储。

quartz所需的表包括QRTZ_FIRED_TRIGGERS、QRTZ_PAUSED_TRIGGER_GRPS、QRTZ_SCHEDULER_STATE、QRTZ_LOCKS、QRTZ_SIMPLE_TRIGGERS、QRTZ_SIMPROP_TRIGGERS、QRTZ_CRON_TRIGGERS、QRTZ_BLOB_TRIGGERS、QRTZ_TRIGGERS、QRTZ_JOB_DETAILS、QRTZ_CALENDARS共11张表。

需要注意的是,应用系统中在开发的时候,有时候会根据自己的喜好改了表名前缀,根据配置文件中tablePrefix的值,找到对应的表进行修改就可以。

需要更改的表字段为:

表QRTZ_JOB_DETAILS的字段IS_DURABLE类型改为boolean

表QRTZ_JOB_DETAILS的字段IS_NONCONCURRENT类型改为boolean

表QRTZ_JOB_DETAILS的字段IS_UPDATE_DATA类型改为boolean

表QRTZ_JOB_DETAILS的字段REQUESTS_RECOVERY类型改为boolean

表QRTZ_SIMPROP_TRIGGERS的字段BOOL_PROP_1类型改为boolean

表QRTZ_SIMPROP_TRIGGERS的字段BOOL_PROP_2类型改为boolean

表QRTZ_FIRED_TRIGGERS的字段IS_NONCONCURRENT类型改为boolean

表QRTZ_FIRED_TRIGGERS的字段REQUESTS_RECOVERY类型改为boolean

替换驱动代理
在quartz的配置文件中,更改org.quartz.jobStore.driverDelegateClass,通过该配置项可设置不同数据库的“方言”。可能的选择包括:

org.quartz.impl.jdbcjobstore.StdJDBCDelegate(完全兼容JDBC的驱动)

org.quartz.impl.jdbcjobstore.MSSQLDelegate(Microsoft SQL Server和Sybase)

org.quartz.impl.jdbcjobstore.PostgreSQLDelegate

org.quartz.impl.jdbcjobstore.WebLogicDelegate(WebLogic驱动)

org.quartz.impl.jdbcjobstore.oracle.OracleDelegate

org.quartz.impl.jdbcjobstore.oracle.WebLogicOracleDelegate(Weblogic使用的Oracle驱动)

org.quartz.impl.jdbcjobstore.oracle.weblogic.WebLogicOracleDelegate(Weblogic使用的Oracle)

org.quartz.impl.jdbcjobstore.CloudscapeDelegate

org.quartz.impl.jdbcjobstore.DB2v6Delegate

org.quartz.impl.jdbcjobstore.DB2v7Delegate

org.quartz.impl.jdbcjobstore.DB2v8Delegate

org.quartz.impl.jdbcjobstore.HSQLDBDelegate

org.quartz.impl.jdbcjobstore.PointbaseDelegate

org.quartz.impl.jdbcjobstore.SybaseDelegate

适配瀚高数据库时,需要将该项的值设置为

org.quartz.impl.jdbcjobstore.PostgreSQLDelegat

集群部署产生行锁的解决方案
当多个weblogic节点发布时,定时框架采用的是SELECT * FROM SP_QRTZ_LOCKS WHERE LOCK_NAME = :1 FOR UPDATE获取锁的形式,当能锁住记录则执行定时任务。多个节点执行会产生大量的行锁。为了解决这个问题SELECT * FROM SP_QRTZ_LOCKS WHERE LOCK_NAME = :1 FOR UPDATE NOWAIT ,可以解决锁的问题,但会导致任务出错退出。最后通过SELECT * FROM 0LOCKS UPDLOCK WHERE SCHED_NAME = 1 AND LOCK_NAME = ? FOR UPDATE SKIP LOCKED 可完美解决。

最终配置如下:

quartz:

  properties:

    org:

      quartz:

        scheduler:

          #实例名称,缺省QuartzScheduler

          instanceName: myScheduler 

          instanceId: AUTO

        jobStore:

          class: org.quartz.impl.jdbcjobstore.JobStoreTX

          # Driver代理

          driverDelegateClass: org.quartz.impl.jdbcjobstore.PostgreSQLDelegate

          #表前缀

          tablePrefix: QRTZ_  

          isClustered: false

          clusterCheckinInterval: 10000

          useProperties: false

          #####################################################################

          #在LOCKS表中选择一行,然后在这一行放一把锁。默认为“SELECT * FROM 

          #0LOCKS WHERE SCHED_NAME =1 AND LOCK_NAME = ? FOR UPDATE”,

          #这对于大多数数据库都适用。“0”由上面的配置的TABLE_PREFIX在运行

          #时替换,而“1”由scheduler的名字替换。

          #####################################################################

          selectWithLockSQL : SELECT * FROM 0LOCKS UPDLOCK WHERE SCHED_NAME = 1 AND LOCK_NAME = ? FOR UPDATE SKIP LOCKED

        threadPool:

          class: org.quartz.simpl.SimpleThreadPool

          threadCount: 10

          threadPriority: 5

          threadsInheritContextClassLoaderOfInitializingThread: true

    job-store-type: jdbc

以上是关于瀚高数据库适配定时框架Quartz的主要内容,如果未能解决你的问题,请参考以下文章

springboot整合quartz项目使用(含完整代码)

SpringBoot与quartz框架实现分布式定时任务

分布式定时任务调度框架 - Quartz学习及实战记录笔记

分布式定时任务调度框架 - Quartz学习及实战记录笔记

一文揭秘定时任务调度框架quartz

quartz定时任务框架之实例