Quartz

1.更改HGDB腳本

Text

應(yīng)用系統(tǒng)在適配瀚高數(shù)據(jù)庫時，數(shù)據(jù)庫往往都是通過遷移工具從mysql或oracle遷移而來，遷移之后需要更改quartz所需的表結(jié)構(gòu)，原因為，遷移后，源庫的boolean類型的數(shù)據(jù)存儲并沒有改變，遷移之后為varchar(1)，瀚高數(shù)據(jù)庫支持boolean類型，需要將所需字段類型改為boolean，如若不然，需要加隱士轉(zhuǎn)換將character varying 類型轉(zhuǎn)為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張表。需要注意的是，應(yīng)用系統(tǒng)中在開發(fā)的時候，有時候會根據(jù)自己的喜好改了表名前綴，根據(jù)配置文件中tablePrefix的值，找到對應(yīng)的表進(jìn)行修改就可以。
需要更改的表字段為：
表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.替換驅(qū)動代理

Text

在quartz的配置文件中，更改org.quartz.jobStore.driverDelegateClass，通過該配置項可設(shè)置不同數(shù)據(jù)庫的“方言”?？赡艿倪x擇包括：
org.quartz.impl.jdbcjobstore.StdJDBCDelegate(完全兼容JDBC的驅(qū)動)
org.quartz.impl.jdbcjobstore.MSSQLDelegate(Microsoft SQL Server和Sybase)
org.quartz.impl.jdbcjobstore.PostgreSQLDelegate
org.quartz.impl.jdbcjobstore.WebLogicDelegate(WebLogic驅(qū)動)
org.quartz.impl.jdbcjobstore.oracle.OracleDelegate
org.quartz.impl.jdbcjobstore.oracle.WebLogicOracleDelegate(Weblogic使用的Oracle驅(qū)動)
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
適配瀚高數(shù)據(jù)庫時，需要將該項的值設(shè)置為org.quartz.impl.jdbcjobstore.PostgreSQLDelegat

3.集群部署產(chǎn)生行鎖的解決方案

當(dāng)多個weblogic節(jié)點發(fā)布時，定時框架采用的是SELECT * FROM SP_QRTZ_LOCKS WHERE LOCK_NAME = :1 FOR UPDATE獲取鎖的形式，當(dāng)能鎖住記錄則執(zhí)行定時任務(wù)。多個節(jié)點執(zhí)行會產(chǎn)生大量的行鎖。為了解決這個問題SELECT * FROM SP_QRTZ_LOCKS WHERE LOCK_NAME = :1 FOR UPDATE NOWAIT ，可以解決鎖的問題，但會導(dǎo)致任務(wù)出錯退出。最后通過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表中選擇一行，然后在這一行放一把鎖。默認(rèn)為“SELECT * FROM 
          #{0}LOCKS WHERE SCHED_NAME ={1} AND LOCK_NAME = ? FOR UPDATE”，
          #這對于大多數(shù)數(shù)據(jù)庫都適用?！?#123;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