Quartz

1.更改HGDB脚本
Text
应用系统在适配瀚高数据库时,数据库往往都是通过迁移工具从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
2.替换驱动代理
Text
在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
3.集群部署产生行锁的解决方案

当多个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 {0}LOCKS 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
#{0}LOCKS WHERE SCHED_NAME ={1} AND LOCK_NAME = ? FOR UPDATE”,
#这对于大多数数据库都适用。“{0}”由上面的配置的TABLE_PREFIX在运行
#时替换,而“{1}”由scheduler的名字替换。
#####################################################################
selectWithLockSQL : SELECT * FROM {0}LOCKS 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