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

Posted 2023-03-02 瀚高PG实验室

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

环境
系统平台：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